aboutsummaryrefslogtreecommitdiff
path: root/lib/event.model.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/event.model.ts')
-rw-r--r--lib/event.model.ts7
1 files changed, 4 insertions, 3 deletions
diff --git a/lib/event.model.ts b/lib/event.model.ts
index a430674..7768ffc 100644
--- a/lib/event.model.ts
+++ b/lib/event.model.ts
@@ -4,11 +4,11 @@ import createEventSchema, { EventDocument } from './event.schema';
import { LogDocument } from './log.schema';
import LogModel from './log.model';
-interface Event<Context> extends EventDocument<Context> {
+export interface Event<Context> extends EventDocument<Context> {
log(message: string): void;
start(): void;
complete(): void;
- fail(error: Error): void;
+ fail(error: Error | string): void;
computeNextRunAt(): Date;
getLogs(): Promise<LogDocument[]>;
}
@@ -26,7 +26,7 @@ const createEventModel = <Context>(name: string, contextSchema: Schema): EventMo
// Schema methods
schema.method('log', function(message: string) {
const timestamp = new Date().toLocaleString('en');
- console.log(`[${timestamp}] ${this.name}: ${message}`);
+ console.log(`[${timestamp}] ${this.type}: ${message}`);
return LogModel.create({ eventId: this._id, message });
});
@@ -45,6 +45,7 @@ const createEventModel = <Context>(name: string, contextSchema: Schema): EventMo
schema.method('fail', function(error: Error) {
this.log(error);
+ this.log('Event failed');
this.error = error;
this.status = 'failed';
return this.save();