add subscribe composable factory

Dative-GPI · Nov 5, 2024 · b9a1df9 · b9a1df9
1 parent 58acdd5
commit b9a1df9
Show file tree

Hide file tree

Showing 3 changed files with 31 additions and 1 deletion.
diff --git a/src/Bones.UI/abstractions/inotifyService.ts b/src/Bones.UI/abstractions/inotifyService.ts
@@ -15,4 +15,6 @@ export type AllEvent = NotifyEvent | "all";
 export type AddOrUpdateCallback<TDetails> = (ev: AddOrUpdateEvent, payload: TDetails) => void;
 export type DeleteCallback = (ev: DeleteEvent, id: any) => void;
 export type ResetCallback = (ev: ResetEvent) => void;
-export type AllCallback<TDetails> = AddOrUpdateCallback<TDetails> | DeleteCallback | ResetCallback;
+export type AllCallback<TDetails> = AddOrUpdateCallback<TDetails> | DeleteCallback | ResetCallback;
+
+export type SubscribeCall<TDetails> = [AddOrUpdateEvent, AddOrUpdateCallback<TDetails>] | [DeleteEvent, DeleteCallback] | [ResetEvent, ResetCallback] | [AllEvent, AllCallback<TDetails>];
diff --git a/src/Bones.UI/core/composableFactory.ts b/src/Bones.UI/core/composableFactory.ts
@@ -25,6 +25,27 @@ export class ComposableFactory {
         return ComposableFactory.customRemove(service.remove);
     }
 
+    public static subscribe<TDetails>(service: INotifyService<TDetails>) {
+        return () => {
+            let subscribersIds: number[] = [];
+
+            onUnmounted(() => {
+                subscribersIds.forEach(id => service.unsubscribe(id));
+                subscribersIds = [];
+            });
+
+            const subscribe: INotifyService<TDetails>["subscribe"] = (ev: any, callback: any) => {
+                const subscriberId = service.subscribe(ev, callback);
+                subscribersIds.push(subscriberId);
+                return subscriberId;
+            }
+
+            return {
+                subscribe
+            }
+        }
+    }
+
     public static custom<TDetails, TArgs extends any[]>(method: (...args: TArgs) => Promise<TDetails>, applyFactory?: () => (entity: Ref<TDetails>) => void) {
         return () => {
             const apply = applyFactory ? applyFactory() : () => { };

diff --git a/tests/Bones.UI.Tests/services/testUserService.ts b/tests/Bones.UI.Tests/services/testUserService.ts
@@ -23,6 +23,13 @@ const AccountLoginFactory = new ServiceFactory<TestUserDetailsDTO, TestUserDetai
 export const useTestUsersSync = ComposableFactory.sync<TestUserDetails, TestUserInfos>(testUserServiceFactory);
 export const useTestUserTrack = ComposableFactory.trackRef(testUserServiceFactory);
 
+export const useTestUserSubscribe = ComposableFactory.subscribe(testUserServiceFactory);
+
+const { subscribe } = useTestUserSubscribe();
+
+subscribe("add", (ev, payload) => {
+    console.log(ev, payload);
+});
 
 export const useLogin = ComposableFactory.custom(AccountLoginFactory.login, () => {
     const { sync } = useTestUsersSync();