Sam: Projection read model copies to MongoDB

.eslintrc.js

@@ -13,7 +13,7 @@ module.exports = {
         '@typescript-eslint/unified-signatures': 'off',
         'import/no-extraneous-dependencies': 'off',
         'eol-last': 'error',
-        'no-multiple-empty-lines': ['error', { 'max': 1, 'maxEOF': 0 }],
+        'no-multiple-empty-lines': ['error', {'max': 1, 'maxEOF': 0 }],
         'header/header': [
             2,
             'line',
@@ -61,7 +61,7 @@ module.exports = {
 		        'MethodDefinition[accessibility!="private"][value.type="FunctionExpression"]:not(MethodDefinition[value.type="TSEmptyBodyFunctionExpression"] + MethodDefinition[value.type="FunctionExpression"])',
             ]
         }],
-        
+
         'jsdoc/require-returns': ['error', {
             'contexts': [
                 'ArrowFunctionExpression',

.github/workflows/workflow.yml

@@ -1,7 +1,7 @@
 name: TypeScript Library CI/CD
 
 env:
-  PRERELEASE_BRANCHES: legolas, gimli # Comma separated list of prerelease branch names. 'alpha,rc, ...'
+  PRERELEASE_BRANCHES: legolas, gimli, sam # Comma separated list of prerelease branch names. 'alpha,rc, ...'
 
 on:
   push:

.gitignore

@@ -65,3 +65,5 @@ Samples/**/data
 Source/**/Distribution
 Samples/**/Distribution
 Source/**/README.md
+
+.idea

Samples/Container/package.json

@@ -1,7 +1,7 @@
 {
     "name": "container",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,10 +12,10 @@
         "build": "tsc -p ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0",
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5",
         "inversify": "^6.0.1",
         "reflect-metadata": "^0.1.13",
         "winston": "^3.3.4"

Samples/ExpressJS/package.json

@@ -1,7 +1,7 @@
 {
     "name": "expressjs",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,11 +12,11 @@
         "build": "tsc -b ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0",
-        "@dolittle/sdk.extensions.express": "22.1.0",
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5",
+        "@dolittle/sdk.extensions.express": "22.2.0-sam.5",
         "body-parser": "^1.19.1",
         "express": "^4.17.2",
         "winston": "^3.4.0"

Samples/MongoDBProjections/.eslintrc.js

@@ -0,0 +1,11 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+module.exports = {
+    extends: '../../.eslintrc.js',
+    rules: {
+        'no-restricted-globals': 'off',
+        '@typescript-eslint/naming-convention' : 'off',
+        'jsdoc/require-jsdoc': 'off',
+    }
+};

Samples/MongoDBProjections/DishCounter.ts

@@ -0,0 +1,25 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+import { convertToMongoDB, copyProjectionToMongoDB, on, projection, MongoDBConversion, ProjectionContext } from '@dolittle/sdk.projections';
+
+import { DishPrepared } from './DishPrepared';
+
+@projection('98f9db66-b6ca-4e5f-9fc3-638626c9ecfa')
+@copyProjectionToMongoDB()
+export class DishCounter {
+
+    name: string = 'Unknown';
+
+    numberOfTimesPrepared: number = 0;
+
+    @convertToMongoDB(MongoDBConversion.Date)
+    lastPrepared: Date = new Date(0);
+
+    @on(DishPrepared, _ => _.keyFromProperty('Dish'))
+    on(event: DishPrepared, projectionContext: ProjectionContext) {
+        this.name = event.Dish;
+        this.numberOfTimesPrepared ++;
+        this.lastPrepared = projectionContext.eventContext.occurred.toJSDate();
+    }
+}

Samples/MongoDBProjections/DishPrepared.ts

@@ -0,0 +1,9 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+import { eventType } from '@dolittle/sdk.events';
+
+@eventType('1844473f-d714-4327-8b7f-5b3c2bdfc26a')
+export class DishPrepared {
+    constructor(readonly Dish: string, readonly Chef: string) {}
+}

Samples/MongoDBProjections/index.ts

@@ -0,0 +1,39 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+// Sample code for the tutorial at https://dolittle.io/docs/tutorials/projections/
+
+import { DolittleClient } from '@dolittle/sdk';
+import { TenantId } from '@dolittle/sdk.execution';
+import { setTimeout } from 'timers/promises';
+import { DateTime } from 'luxon';
+
+import { DishCounter } from './DishCounter';
+import { DishPrepared } from './DishPrepared';
+
+(async () => {
+    const client = await DolittleClient
+        .setup()
+        .connect();
+
+    const eventStore = client.eventStore.forTenant(TenantId.development);
+
+    await eventStore.commit(new DishPrepared('Bean Blaster Taco', 'Mr. Taco'), 'Dolittle Tacos');
+    await eventStore.commit(new DishPrepared('Bean Blaster Taco', 'Mrs. Tex Mex'), 'Dolittle Tacos');
+    await eventStore.commit(new DishPrepared('Avocado Artillery Tortilla', 'Mr. Taco'), 'Dolittle Tacos');
+    await eventStore.commit(new DishPrepared('Chili Canon Wrap', 'Mrs. Tex Mex'), 'Dolittle Tacos');
+
+    await setTimeout(1000);
+
+    const db = await client.resources.forTenant(TenantId.development).mongoDB.getDatabase();
+    const dishCounterCollection = db.collection(DishCounter);
+
+    for (const { name, numberOfTimesPrepared, lastPrepared } of await dishCounterCollection.find().toArray()) {
+        client.logger.info(`The kitchen has prepared ${name} ${numberOfTimesPrepared} times. The last time was ${lastPrepared}`);
+    }
+
+    const dishesPreparedToday = await dishCounterCollection.find({ lastPrepared: { $gte: DateTime.utc().startOf('day').toJSDate(), $lte: DateTime.utc().endOf('day').toJSDate() }}).toArray();
+    for (const { name } of await dishCounterCollection.find().toArray()) {
+        client.logger.info(`The kitchen has prepared ${name} today`);
+    }
+})();

Samples/MongoDBProjections/package.json

@@ -0,0 +1,27 @@
+{
+    "name": "mongodb-projections",
+    "private": true,
+    "version": "22.2.0-sam.5",
+    "main": "index.js",
+    "author": "Dolittle",
+    "license": "MIT",
+    "scripts": {
+        "watch": "nodemon --watch **/*.ts --exec 'ts-node' index.ts",
+        "start": "ts-node index.ts",
+        "test": "mocha",
+        "build": "tsc -p ./tsconfig.json"
+    },
+    "dependencies": {
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5",
+        "inversify": "^6.0.1",
+        "reflect-metadata": "^0.1.13",
+        "winston": "^3.3.4"
+    },
+    "devDependencies": {
+        "nodemon": "^2.0.4",
+        "ts-node": "^8.10.1"
+    }
+}

Samples/MongoDBProjections/tsconfig.json

@@ -0,0 +1,16 @@
+{
+    "extends": "../../tsconfig.settings.json",
+    "compilerOptions": {
+        "sourceRoot": "../",
+        "inlineSourceMap": true,
+        "sourceMap": false,
+        "emitDecoratorMetadata": true,
+        "experimentalDecorators": true,
+        "outDir": "Distribution"
+    },
+    "include": ["**/*.ts"],
+    "exclude": ["node_modules", "Distribution"],
+    "references": [
+        { "path": "../../Source/sdk" }
+    ]
+}

Samples/Tutorials/Aggregates/package.json

@@ -1,7 +1,7 @@
 {
     "name": "samples.aggregates",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,11 +12,11 @@
         "build": "tsc -b ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.aggregates": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0"
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.aggregates": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5"
     },
     "devDependencies": {
         "nodemon": "^2.0.4",

Samples/Tutorials/Embeddings/package.json

@@ -1,7 +1,7 @@
 {
     "name": "embeddings",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,10 +12,10 @@
         "build": "tsc -b ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0"
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5"
     },
     "devDependencies": {
         "nodemon": "^2.0.4",

Samples/Tutorials/EventHorizon/Consumer/package.json

@@ -1,7 +1,7 @@
 {
     "name": "eventhorizon-consumer",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,11 +12,11 @@
         "build": "tsc -p ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.eventhorizon": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0"
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.eventhorizon": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5"
     },
     "devDependencies": {
         "nodemon": "^2.0.4",

Samples/Tutorials/EventHorizon/Producer/package.json

@@ -1,7 +1,7 @@
 {
     "name": "eventhorizon-producer",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,11 +12,11 @@
         "build": "tsc -p ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.eventhorizon": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0"
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.eventhorizon": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5"
     },
     "devDependencies": {
         "nodemon": "^2.0.4",

Samples/Tutorials/GettingStarted/package.json

@@ -1,7 +1,7 @@
 {
     "name": "kitchen",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,10 +12,10 @@
         "build": "tsc -b ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0",
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5",
         "winston": "3.3.2"
     },
     "devDependencies": {

Samples/Tutorials/Projections/package.json

@@ -1,7 +1,7 @@
 {
     "name": "projections",
     "private": true,
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "main": "index.js",
     "author": "Dolittle",
     "license": "MIT",
@@ -12,10 +12,10 @@
         "build": "tsc -b ./tsconfig.json"
     },
     "dependencies": {
-        "@dolittle/sdk": "22.1.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.events.handling": "22.1.0"
+        "@dolittle/sdk": "22.2.0-sam.5",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.events.handling": "22.2.0-sam.5"
     },
     "devDependencies": {
         "nodemon": "^2.0.4",

Source/aggregates/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@dolittle/sdk.aggregates",
-    "version": "22.1.0",
+    "version": "22.2.0-sam.5",
     "description": "Dolittle is a decentralized, distributed, event-driven microservice platform built to harness the power of events.",
     "keywords": [
         "Dolittle",
@@ -46,12 +46,12 @@
     "dependencies": {
         "@dolittle/concepts": "6.0.0",
         "@dolittle/rudiments": "6.0.0",
-        "@dolittle/sdk.artifacts": "22.1.0",
-        "@dolittle/sdk.events": "22.1.0",
-        "@dolittle/sdk.execution": "22.1.0",
-        "@dolittle/sdk.protobuf": "22.1.0",
-        "@dolittle/sdk.resilience": "22.1.0",
-        "@dolittle/sdk.services": "22.1.0",
+        "@dolittle/sdk.artifacts": "22.2.0-sam.5",
+        "@dolittle/sdk.events": "22.2.0-sam.5",
+        "@dolittle/sdk.execution": "22.2.0-sam.5",
+        "@dolittle/sdk.protobuf": "22.2.0-sam.5",
+        "@dolittle/sdk.resilience": "22.2.0-sam.5",
+        "@dolittle/sdk.services": "22.2.0-sam.5",
         "@dolittle/types": "6.0.0",
         "winston": "3.3.2"
     },