patch(feat): octo post-transaction hook support.

Author: rash805115

packages/octo/src/decorators/module.decorator.ts

@@ -1,12 +1,18 @@
 import { PostModelActionCallback, PostModelActionHandleHook } from '../functions/hook/post-model-action-handle.hook.js';
+import {
+  PostModelTransactionCallback,
+  PostModelTransactionHandleHook,
+} from '../functions/hook/post-model-transaction-handle.hook.js';
 import { AModule } from '../functions/module/module.abstract.js';
 import { ModelSerializationService } from '../services/serialization/model/model-serialization.service.js';
 import { Container } from './container.js';
 
 export function Module({
   postModelActionHandles = [],
+  postModelTransactionHandles = [],
 }: {
-  postModelActionHandles: { ACTION_NAME: string; callback: PostModelActionCallback }[];
+  postModelActionHandles?: { ACTION_NAME: string; callback: PostModelActionCallback }[];
+  postModelTransactionHandles?: { callback: PostModelTransactionCallback }[];
 }): (constructor: any) => void {
   return function (constructor: any) {
     Container.get(ModelSerializationService).then((modelSerializationService) => {
@@ -18,5 +24,9 @@ export function Module({
     for (const { ACTION_NAME, callback } of postModelActionHandles) {
       PostModelActionHandleHook.register(ACTION_NAME, callback);
     }
+
+    for (const { callback } of postModelTransactionHandles) {
+      PostModelTransactionHandleHook.register(callback);
+    }
   };
 }

packages/octo/src/functions/hook/post-model-transaction-handle.hook.ts

@@ -0,0 +1,19 @@
+import { DiffMetadata } from '../diff/diff-metadata.js';
+import { AHook } from './hook.abstract.js';
+
+export type PostModelTransactionCallback = (modelTransaction: DiffMetadata[][]) => Promise<void>;
+
+export class PostModelTransactionHandleHook extends AHook {
+  private static readonly callbacks: PostModelTransactionCallback[] = [];
+
+  static async apply(modelTransaction: DiffMetadata[][]): Promise<void> {
+    for (const callback of this.callbacks) {
+      await callback(modelTransaction);
+    }
+  }
+
+  static register(callback: PostModelTransactionCallback): PostModelTransactionHandleHook {
+    this.callbacks.push(callback);
+    return this;
+  }
+}

packages/octo/src/services/transaction/transaction.service.ts

@@ -10,6 +10,7 @@ import { Container } from '../../decorators/container.js';
 import { Factory } from '../../decorators/factory.decorator.js';
 import { DiffMetadata } from '../../functions/diff/diff-metadata.js';
 import { Diff, DiffAction } from '../../functions/diff/diff.js';
+import { PostModelTransactionHandleHook } from '../../functions/hook/post-model-transaction-handle.hook.js';
 import { IModelAction } from '../../models/model-action.interface.js';
 import { OverlayDataRepository } from '../../overlays/overlay-data.repository.js';
 import { IResourceAction } from '../../resources/resource-action.interface.js';
@@ -289,6 +290,9 @@ export class TransactionService {
       yield resourceTransaction;
     }
 
+    // Run post transaction hooks.
+    await PostModelTransactionHandleHook.apply(modelTransaction);
+
     return modelTransaction;
   }