사용자 로그인 시 로그인 이벤트 수집 (#38)

feat: sign in event 수집

Author: rrgks6221

prisma/migrations/20250821062913_account_last_signed_in_at/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "account" ADD COLUMN     "lastSignedInAt" TIMESTAMP(3);

prisma/schema.prisma

@@ -28,9 +28,10 @@ model Account {
   role       AccountRole
   signInType SignInType
 
-  username      String?   @unique @db.VarChar(20)
-  password      String?
-  lastEnteredAt DateTime? @db.Timestamp(3)
+  username       String?   @unique @db.VarChar(20)
+  password       String?
+  lastEnteredAt  DateTime? @db.Timestamp(3)
+  lastSignedInAt DateTime? @db.Timestamp(3)
 
   createdAt DateTime @default(now()) @db.Timestamp(3)
   updatedAt DateTime @updatedAt @db.Timestamp(3)

src/modules/account/entities/account.entity.ts

@@ -1,5 +1,6 @@
 import { AccountCreatedEvent } from '@module/account/events/account-created-event/account-created.event';
 import { AccountEnteredEvent } from '@module/account/events/account-entered-event/account-entered.event';
+import { AccountSignedInEvent } from '@module/account/events/account-signed-in-event/account-signed-in.event';
 
 import {
   AggregateRoot,
@@ -22,6 +23,7 @@ export interface AccountProps {
   username?: string;
   password?: string;
   enteredAt?: Date;
+  lastSignedInAt?: Date;
 }
 
 interface CreateAccountProps {
@@ -95,4 +97,14 @@ export class Account extends AggregateRoot<AccountProps> {
 
     this.apply(new AccountEnteredEvent(this.id, { enteredAt: now }));
   }
+
+  signIn() {
+    const now = new Date();
+
+    this.props.lastSignedInAt = now;
+
+    this.updatedAt = now;
+
+    this.apply(new AccountSignedInEvent(this.id, { signedInAt: now }));
+  }
 }

src/modules/account/events/account-signed-in-event/account-signed-in.event.ts

@@ -0,0 +1,9 @@
+import { DomainEvent } from '@common/base/base.domain-event';
+
+interface AccountSignedInEventPayload {
+  signedInAt: Date;
+}
+
+export class AccountSignedInEvent extends DomainEvent<AccountSignedInEventPayload> {
+  readonly aggregate = 'Account';
+}

src/modules/account/mappers/account.mapper.ts

@@ -19,6 +19,7 @@ export class AccountMapper extends BaseMapper {
         username: raw.username ?? undefined,
         password: raw.password ?? undefined,
         enteredAt: raw.lastEnteredAt ?? undefined,
+        lastSignedInAt: raw.lastSignedInAt ?? undefined,
       },
     });
   }
@@ -33,6 +34,7 @@ export class AccountMapper extends BaseMapper {
       username: entity.props.username ?? null,
       password: entity.props.password ?? null,
       lastEnteredAt: entity.props.enteredAt ?? null,
+      lastSignedInAt: entity.props.lastSignedInAt ?? null,
     };
   }
 }

src/modules/auth/use-cases/sign-in-with-username/__spec__/sign-in-with-username.handler.spec.ts

@@ -13,6 +13,8 @@ import { SignInWithUsernameCommandFactory } from '@module/auth/use-cases/sign-in
 import { SignInWithUsernameCommand } from '@module/auth/use-cases/sign-in-with-username/sign-in-with-username.command';
 import { SignInWithUsernameHandler } from '@module/auth/use-cases/sign-in-with-username/sign-in-with-username.handler';
 
+import { EventStoreModule } from '@core/event-sourcing/event-store.module';
+
 describe(SignInWithUsernameHandler, () => {
   let handler: SignInWithUsernameHandler;
 
@@ -22,7 +24,7 @@ describe(SignInWithUsernameHandler, () => {
 
   beforeEach(async () => {
     const module: TestingModule = await Test.createTestingModule({
-      imports: [CqrsModule, AuthTokenModule],
+      imports: [CqrsModule, AuthTokenModule, EventStoreModule],
       providers: [SignInWithUsernameHandler],
     }).compile();
 

src/modules/auth/use-cases/sign-in-with-username/sign-in-with-username.handler.ts

@@ -13,12 +13,19 @@ import {
 } from '@module/auth/services/auth-token/auth-token.service.interface';
 import { SignInWithUsernameCommand } from '@module/auth/use-cases/sign-in-with-username/sign-in-with-username.command';
 
+import {
+  EVENT_STORE,
+  IEventStore,
+} from '@core/event-sourcing/event-store.interface';
+
 @CommandHandler(SignInWithUsernameCommand)
 export class SignInWithUsernameHandler
   implements ICommandHandler<SignInWithUsernameCommand, AuthToken>
 {
   constructor(
     private readonly queryBus: QueryBus,
+    @Inject(EVENT_STORE)
+    private readonly eventStore: IEventStore,
     @Inject(AUTH_TOKEN_SERVICE)
     private readonly authService: IAuthTokenService,
   ) {}
@@ -47,8 +54,12 @@ export class SignInWithUsernameHandler
       throw new SignInInfoNotMatchedError();
     }
 
+    account.signIn();
+
     const authToken = this.authService.generateAuthToken(account);
 
+    await this.eventStore.storeAggregateEvents(account);
+
     return authToken;
   }
 }