Skip to content

Commit

Permalink
🚨 fix linting issues
Browse files Browse the repository at this point in the history
  • Loading branch information
drieshooghe committed Oct 20, 2022
1 parent 7dbe5a0 commit 11fc132
Show file tree
Hide file tree
Showing 4 changed files with 19 additions and 4 deletions.
9 changes: 8 additions & 1 deletion lib/integration/event-store/mongodb.event-store.ts
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,14 @@ export class MongoDBEventStore extends EventStore {
},
)
.map(({ event, payload, eventId, aggregateId, version, occurredOn, correlationId, causationId }) =>
EventEnvelope.from(event, payload, { eventId, aggregateId, version, occurredOn, correlationId, causationId }),
EventEnvelope.from(event, payload, {
eventId,
aggregateId,
version,
occurredOn,
correlationId,
causationId,
}),
);

const entities = [];
Expand Down
5 changes: 4 additions & 1 deletion lib/interfaces/aggregate/snapshot-handler.ts
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,10 @@ export abstract class SnapshotHandler<A extends AggregateRoot = AggregateRoot> {
}
async *loadMany(filter?: { fromId?: Id; limit?: number }): AsyncGenerator<SnapshotEnvelope<A>[]> {
const id = filter?.fromId?.value;
for await (const envelopes of this.snapshotStore.getLastEnvelopes<A>(this.streamName, { ...filter, fromId: id })) {
for await (const envelopes of this.snapshotStore.getLastEnvelopes<A>(this.streamName, {
...filter,
fromId: id,
})) {
yield envelopes;
}
}
Expand Down
6 changes: 5 additions & 1 deletion lib/models/event-envelope.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,11 @@ export class EventEnvelope<E extends IEvent = IEvent> {
payload: IEventPayload<E>,
metadata: Omit<EventEnvelopeMetadata, 'eventId' | 'occurredOn'>,
): EventEnvelope<E> {
return new EventEnvelope<E>(event, payload, { eventId: Id.generate().value, occurredOn: new Date(), ...metadata });
return new EventEnvelope<E>(event, payload, {
eventId: Id.generate().value,
occurredOn: new Date(),
...metadata,
});
}

static from<E extends IEvent = IEvent>(
Expand Down
3 changes: 2 additions & 1 deletion rome.json
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,8 @@
},
"formatter": {
"enabled": true,
"lineWidth": 120
"lineWidth": 120,
"indentStyle": "tab"
},
"javascript": {
"formatter": {
Expand Down

0 comments on commit 11fc132

Please sign in to comment.