refactor services

.eslintrc.json

@@ -25,7 +25,10 @@
     {
       "files": ["*.ts", "*.tsx"],
       "extends": ["plugin:@nx/typescript"],
-      "rules": {}
+      "rules": {
+        "@typescript-eslint/no-empty-interface": ["warn"],
+        "@typescript-eslint/no-empty-function": ["warn"]
+      }
     },
     {
       "files": ["*.js", "*.jsx"],

api-gateway/src/accounting/accounting.module.ts

@@ -1,11 +1,11 @@
 import { createModule } from '@deepkit/app';
 import { provideRestateServiceProxy } from 'deepkit-restate';
 
-import { AccountingServiceApi } from '@ftgo/accounting-service-api';
+import { PaymentServiceApi } from '@ftgo/payment-service-api';
 
 import { AccountingController } from './accounting.controller';
 
 export class AccountingModule extends createModule({
   controllers: [AccountingController],
-  providers: [provideRestateServiceProxy<AccountingServiceApi>()],
+  providers: [provideRestateServiceProxy<PaymentServiceApi>()],
 }) {}

api-gateway/src/consumer/consumer.module.ts

@@ -1,11 +1,11 @@
 import { createModule } from '@deepkit/app';
 import { provideRestateServiceProxy } from 'deepkit-restate';
 
-import { ConsumerServiceApi } from '@ftgo/consumer-service-api';
+import { CustomerServiceApi } from '@ftgo/customer-service-api';
 
 import { ConsumerController } from './consumer.controller';
 
 export class ConsumerModule extends createModule({
   controllers: [ConsumerController],
-  providers: [provideRestateServiceProxy<ConsumerServiceApi>()],
+  providers: [provideRestateServiceProxy<CustomerServiceApi>()],
 }) {}

common/src/lib/repository.ts

@@ -6,14 +6,9 @@ import {
   TypeClass,
 } from '@deepkit/type';
 import { RestateContextStorage, RestateCustomContext } from 'deepkit-restate';
-import {
-  DatabaseQueryModel,
-  DeleteResult,
-  OrmEntity,
-  PatchResult,
-} from '@deepkit/orm';
+import { DatabaseQueryModel, OrmEntity } from '@deepkit/orm';
 
-import { Database } from '@ftgo/common';
+import { Database } from './database';
 
 export class RestateRepository<E extends OrmEntity> {
   readonly #type: TypeClass;
@@ -30,11 +25,8 @@ export class RestateRepository<E extends OrmEntity> {
     return this.contextStorage.getStore()!;
   }
 
-  async delete(
-    filter: DatabaseQueryModel<E>['filter'],
-  ): Promise<DeleteResult<E>> {
-    // TODO: serde
-    return await this.#ctx.run<DeleteResult<E>>(() =>
+  async delete(filter: DatabaseQueryModel<E>['filter']): Promise<void> {
+    await this.#ctx.run(() =>
       this.database.query(this.#type.classType).filter(filter).deleteOne(),
     );
   }
@@ -53,18 +45,18 @@ export class RestateRepository<E extends OrmEntity> {
   async patch(
     filter: DatabaseQueryModel<E>['filter'],
     changes: ChangesInterface<E> | DeepPartial<E>,
-  ): Promise<PatchResult<E>> {
-    // TODO: serde
-    return await this.#ctx.run<PatchResult<E>>(() =>
-      this.database
+  ): Promise<E> {
+    return await this.#ctx.run<E>(async () => {
+      const { returning } = await this.database
         .query(this.#type.classType)
         .filter(filter)
-        .patchOne(changes),
-    );
+        .patchOne(changes);
+      return returning as E;
+    }, this.#type);
   }
 
   async create(...args: ConstructorParameters<ClassType<E>>): Promise<E> {
-    return await this.#ctx.run(async () => {
+    return await this.#ctx.run<E>(async () => {
       const et = new this.#type.classType(...args);
       await this.database.persist(et);
       return et;

customer-service-api/README.md

@@ -0,0 +1,11 @@
+# customer-service-api
+
+This library was generated with [Nx](https://nx.dev).
+
+## Building
+
+Run `nx build customer-service-api` to build the library.
+
+## Running unit tests
+
+Run `nx test customer-service-api` to execute the unit tests via [Vitest](https://vitest.dev/).

consumer-service-api/package.json → customer-service-api/package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@ftgo/consumer-service-api",
+  "name": "@ftgo/customer-service-api",
   "version": "0.0.1",
   "type": "module",
   "dependencies": {

consumer-service-api/project.json → customer-service-api/project.json

@@ -1,25 +1,25 @@
 {
-  "name": "consumer-service-api",
+  "name": "customer-service-api",
   "$schema": "../node_modules/nx/schemas/project-schema.json",
-  "sourceRoot": "consumer-service-api/src",
+  "sourceRoot": "customer-service-api/src",
   "projectType": "library",
   "tags": [],
   "targets": {
     "build": {
       "executor": "@nx/js:tsc",
       "outputs": ["{options.outputPath}"],
       "options": {
-        "outputPath": "dist/consumer-service-api",
-        "main": "consumer-service-api/src/index.ts",
-        "tsConfig": "consumer-service-api/tsconfig.lib.json",
-        "assets": ["consumer-service-api/*.md"]
+        "outputPath": "dist/customer-service-api",
+        "main": "customer-service-api/src/index.ts",
+        "tsConfig": "customer-service-api/tsconfig.lib.json",
+        "assets": ["customer-service-api/*.md"]
       }
     },
     "test": {
       "executor": "@nx/vite:test",
       "outputs": ["{options.reportsDirectory}"],
       "options": {
-        "reportsDirectory": "../coverage/consumer-service-api"
+        "reportsDirectory": "../coverage/customer-service-api"
       }
     }
   }