schemas outbox-event.schema.ts

0% Statements 0/16

0% Branches 0/4

100% Functions 0/0

0% Lines 0/14

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
import { Document, Schema as MongooseSchema } from 'mongoose';
 
@Schema({ timestamps: true, collection: 'outbox_events' })
export class OutboxEvent extends Document {
  @Prop({ required: true, index: true })
  tenantId: string;
 
  @Prop({ required: true, index: true })
  eventName: string; // e.g. "platform.user.created.v1"
 
  @Prop({ type: MongooseSchema.Types.Mixed, required: true })
  payload: any;
 
  @Prop({ required: true, default: 'PENDING', index: true })
  status: string; // "PENDING" | "PUBLISHED" | "FAILED"
 
  @Prop({ default: null })
  error: string;
 
  @Prop({ default: 0 })
  retries: number;
 
  @Prop({ default: null })
  correlationId: string;
 
  @Prop({ default: null })
  causationId: string;
 
  @Prop({ default: null })
  processedAt: Date;
}
 
export const OutboxEventSchema = SchemaFactory.createForClass(OutboxEvent);
OutboxEventSchema.index({ status: 1, createdAt: 1 });