Skip to content

Commit

Permalink
added node-nats-streaming support
Browse files Browse the repository at this point in the history
  • Loading branch information
Samikmalhotra committed Sep 14, 2021
1 parent eb64811 commit 5d795a3
Show file tree
Hide file tree
Showing 6 changed files with 129 additions and 6 deletions.
110 changes: 107 additions & 3 deletions package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@
"cookie-session": "^1.4.0",
"express": "^4.17.1",
"express-validator": "^6.12.1",
"jsonwebtoken": "^8.5.1"
"jsonwebtoken": "^8.5.1",
"node-nats-streaming": "^0.3.2"
}
}
2 changes: 1 addition & 1 deletion src/events/subjects.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
export enum Subjects {
TicketCreated = 'ticket:created',
OrderUpdated = 'order:updated'
TicketUpdated = 'ticket:updated',
}
1 change: 1 addition & 0 deletions src/events/ticket-created-event.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,5 +6,6 @@ export interface TicketCreatedEvent {
id: string;
title: string;
price: number;
userId: string;
};
}
11 changes: 11 additions & 0 deletions src/events/ticket-updated-event.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
import { Subjects } from './subjects';

export interface TicketUpdatedEvent {
subject: Subjects.TicketUpdated;
data: {
id: string;
title: string;
price: number;
userId: string;
}
}
8 changes: 7 additions & 1 deletion src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,10 @@ export * from './errors/request-validation-error'
export * from './middlewares/current-user'
export * from './middlewares/error-handler'
export * from './middlewares/require-auth'
export * from './middlewares/validate-request'
export * from './middlewares/validate-request'

export * from './events/base-listener'
export * from './events/base-publisher'
export * from './events/subjects'
export * from './events/ticket-created-event'
export * from './events/ticket-updated-event'

0 comments on commit 5d795a3

Please sign in to comment.