feat(server): send invite notification

packages/backend/server/src/core/notification/event.ts

@@ -0,0 +1,30 @@
+import { Injectable } from '@nestjs/common';
+
+import { OnEvent } from '../../base';
+import { Models } from '../../models';
+import { NotificationService } from './service';
+
+@Injectable()
+export class NotificationEvents {
+  constructor(
+    private readonly models: Models,
+    private readonly service: NotificationService
+  ) {}
+
+  @OnEvent('workspace.members.invited')
+  async onWorkspaceMemberInvited({
+    inviterId,
+    inviteId,
+  }: Events['workspace.members.invited']) {
+    const invite = await this.models.workspace.getMemberInvitation(inviteId);
+    if (!invite) {
+      return;
+    }
+    // TODO(@fengmk2): pass permission to createInvite
+    await this.service.createInvite({
+      workspaceId: invite.workspaceId,
+      userId: invite.userId,
+      createdBy: inviterId,
+    });
+  }
+}

packages/backend/server/src/core/workspaces/resolvers/team.ts

@@ -334,6 +334,10 @@ export class TeamWorkspaceResolver {
               permission,
             });
           }
+          this.event.emit('workspace.members.invited', {
+            inviterId: user.id,
+            inviteId: result,
+          });
         }
 
         return result;

packages/backend/server/src/core/workspaces/resolvers/workspace.ts

@@ -540,6 +540,10 @@ export class WorkspaceResolver {
           );
         }
       }
+      this.event.emit('workspace.members.invited', {
+        inviterId: user.id,
+        inviteId,
+      });
       return inviteId;
     } catch (e) {
       // pass through user friendly error

packages/backend/server/src/models/workspace.ts

@@ -29,6 +29,10 @@ declare global {
       to: string;
       workspaceId: string;
     };
+    'workspace.members.invited': {
+      inviterId: string;
+      inviteId: string;
+    };
     'workspace.members.updated': {
       workspaceId: string;
       count: number;