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;