@schemeless/event-store
Advanced tools
Comparing version
@@ -5,6 +5,11 @@ "use strict"; | ||
const ulid_1 = require("../util/ulid"); | ||
const dateDefault = (date) => { | ||
if (!date) | ||
return new Date(); | ||
return typeof date === 'string' ? new Date(date) : date; | ||
}; | ||
function defaultEventCreator(eventArgs, causalEvent) { | ||
const id = ulid_1.getUlid(); | ||
return Object.assign(Object.assign({}, eventArgs), { id, causationId: eventArgs.causationId || causalEvent ? causalEvent.id : undefined, correlationId: eventArgs.correlationId || (causalEvent ? causalEvent.correlationId || causalEvent.id : id), identifier: eventArgs.identifier || (causalEvent ? causalEvent.identifier : undefined), created: new Date() }); | ||
return Object.assign(Object.assign({}, eventArgs), { id, causationId: eventArgs.causationId || causalEvent ? causalEvent.id : undefined, correlationId: eventArgs.correlationId || (causalEvent ? causalEvent.correlationId || causalEvent.id : id), identifier: eventArgs.identifier || (causalEvent ? causalEvent.identifier : undefined), created: dateDefault(eventArgs.created) }); | ||
} | ||
exports.defaultEventCreator = defaultEventCreator; |
@@ -9,2 +9,3 @@ "use strict"; | ||
type: eventFlow.type, | ||
created: eventInput.created || undefined | ||
}); | ||
@@ -11,0 +12,0 @@ return new Promise((resolve, reject) => { |
{ | ||
"name": "@schemeless/event-store", | ||
"version": "2.2.0-rc.5", | ||
"version": "2.2.0-rc.6", | ||
"typescript:main": "src/index.ts", | ||
@@ -52,3 +52,3 @@ "main": "dist/index.js", | ||
}, | ||
"gitHead": "b9b92b2cb912888a13965e968ce1a64bcf3f3421" | ||
"gitHead": "555e67335e92ce27db9e6a63d847a499162de2b9" | ||
} |
429948
0.05%1496
0.4%