chore: define symbols for DI

pulsate-dev · Dec 16, 2024 · ae429c2 · ae429c2
1 parent a33ac55
commit ae429c2
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 3 deletions.
diff --git a/pkg/notification/adaptor/repository/dummy/notification.ts b/pkg/notification/adaptor/repository/dummy/notification.ts
@@ -1,4 +1,4 @@
-import { Option, Result } from '@mikuroxina/mini-fn';
+import { Ether, Option, Result } from '@mikuroxina/mini-fn';
 import type {
   Notification,
   NotificationID,
@@ -8,6 +8,7 @@ import {
   NOTIFICATION_MAX_LIMIT,
   type NotificationFilter,
   type NotificationRepository,
+  notificationRepoSymbol,
 } from '../../../model/repository/notification.js';
 
 export class InMemoryNotificationRepository implements NotificationRepository {
@@ -89,3 +90,8 @@ export class InMemoryNotificationRepository implements NotificationRepository {
     return Result.ok(undefined);
   }
 }
+export const inMemoryNotificationRepo = (data?: Notification[]) =>
+  Ether.newEther(
+    notificationRepoSymbol,
+    () => new InMemoryNotificationRepository(data),
+  );
diff --git a/pkg/notification/adaptor/repository/prisma/notification.ts b/pkg/notification/adaptor/repository/prisma/notification.ts
@@ -1,4 +1,4 @@
-import { Option, Result } from '@mikuroxina/mini-fn';
+import { Ether, Option, Result } from '@mikuroxina/mini-fn';
 import type { Prisma, PrismaClient } from '@prisma/client';
 import type { AccountID } from '../../../../accounts/model/account.js';
 import {
@@ -12,6 +12,7 @@ import {
   NOTIFICATION_MAX_LIMIT,
   type NotificationFilter,
   type NotificationRepository,
+  notificationRepoSymbol,
 } from '../../../model/repository/notification.js';
 
 export class PrismaNotificationRepository implements NotificationRepository {
@@ -239,3 +240,8 @@ export class PrismaNotificationRepository implements NotificationRepository {
     }
   }
 }
+export const prismaNotificationRepo = (client: PrismaClient) =>
+  Ether.newEther(
+    notificationRepoSymbol,
+    () => new PrismaNotificationRepository(client),
+  );
diff --git a/pkg/notification/model/repository/notification.ts b/pkg/notification/model/repository/notification.ts
@@ -1,4 +1,4 @@
-import type { Option, Result } from '@mikuroxina/mini-fn';
+import { Ether, type Option, type Result } from '@mikuroxina/mini-fn';
 import type { Notification, NotificationID } from '../notification.js';
 
 export interface NotificationFilter {
@@ -77,3 +77,5 @@ export interface NotificationRepository {
    */
   updateReadAt(notification: Notification): Promise<Result.Result<Error, void>>;
 }
+export const notificationRepoSymbol =
+  Ether.newEtherSymbol<NotificationRepository>();