Skip to content

Commit 9ac66e5

Browse files
jakhogjakhog
authored
Merge pull request #45 from dolittle/get-projections
Get projections
2 parents 9ddd3dc + 396e922 commit 9ac66e5

71 files changed

Lines changed: 1006 additions & 250 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎.vscode/launch.json‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,19 @@
1717
"${workspaceFolder}/Samples/Basic/Distribution/*.js"
1818
]
1919
},
20+
{
21+
"type": "node",
22+
"request": "launch",
23+
"name": "Debug Projections Sample",
24+
"program": "${workspaceFolder}/Samples/Tutorials/Projections/Distribution/index.js",
25+
"cwd": "${workspaceFolder}/Samples/Tutorials/Projections",
26+
"preLaunchTask": "tsc: build - Samples/Tutorials/Projections/tsconfig.json",
27+
"protocol": "inspector",
28+
"outputCapture": "std",
29+
"outFiles": [
30+
"${workspaceFolder}/Samples/Tutorials/Projections/Distribution/*.js"
31+
]
32+
},
2033
{
2134
"name": "Launch Aggregates Sample",
2235
"type": "node",

‎.vscode/tasks.json‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,14 @@
2929
],
3030
"group": "build"
3131
},
32+
{
33+
"type": "typescript",
34+
"tsconfig": "Samples/Tutorials/Projections/tsconfig.json",
35+
"problemMatcher": [
36+
"$tsc"
37+
],
38+
"group": "build"
39+
},
3240
{
3341
"type": "typescript",
3442
"tsconfig": "Samples/Aggregates/tsconfig.json",

‎Samples/Tutorials/Projections/index.ts‎

Lines changed: 48 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,12 @@
44

55
import { Client } from '@dolittle/sdk';
66
import { TenantId } from '@dolittle/sdk.execution';
7-
import { projection, ProjectionResult } from '@dolittle/sdk.projections';
7+
import { ProjectionResult } from '@dolittle/sdk.projections';
88
import { Menu } from './Menu';
99
import { Chef } from './Chef';
1010
import { ChefFired } from './ChefFired';
1111
import { DishPrepared } from './DishPrepared';
12+
import { ScopeId } from '@dolittle/sdk.events';
1213

1314
const client = Client
1415
.forMicroservice('f39b1f61-d360-4675-b859-53c05c87c0e6')
@@ -17,39 +18,57 @@ const client = Client
1718
eventTypes.register(ChefFired);
1819
})
1920
.withProjections(projections => {
20-
// projections.createProjection('4a4c5b13-d4dd-4665-a9df-27b8e9b2054c')
21-
// .forReadModel(Chef)
22-
// .on(DishPrepared, _ => _.keyFromProperty('Chef'), (chef, event, ctx) => {
23-
// console.log(`Handling event ${JSON.stringify(event)} and read model ${JSON.stringify(chef)}`);
24-
// chef.name = event.Chef;
25-
// chef.dishes.push(event.Dish);
26-
// return chef;
27-
// });
28-
// .on(ChefFired, _ => _.keyFromProperty('Chef'), (chef, event, ctx) => {
29-
// console.log(`Firing ${chef.name}`);
30-
// return ProjectionResult.delete;
31-
// });
21+
projections.createProjection('4a4c5b13-d4dd-4665-a9df-27b8e9b2054c')
22+
.forReadModel(Chef)
23+
.on(DishPrepared, _ => _.keyFromProperty('Chef'), (chef, event, ctx) => {
24+
console.log(`Handling event ${JSON.stringify(event)} and read model ${JSON.stringify(chef)}`);
25+
chef.name = event.Chef;
26+
chef.dishes.push(event.Dish);
27+
return chef;
28+
})
29+
.on(ChefFired, _ => _.keyFromProperty('Chef'), (chef, event, ctx) => {
30+
console.log(`Firing ${chef.name}`);
31+
return ProjectionResult.delete;
32+
});
3233
projections.register(Menu);
33-
})
34+
})
3435
.build();
3536

3637
const beanBlaster = new DishPrepared('Bean Blaster Taco', 'Mr. Taco');
3738
const avocadoArtillery = new DishPrepared('Avocado Artillery Tortilla', 'Mr. Taco');
3839
const chiliCannon = new DishPrepared('Chili Cannon Wrap', 'Ms. TexMex');
3940
const mrTacoFired = new ChefFired('Mr. Taco');
4041

41-
console.log('starting comit');
42-
client.eventStore
43-
.forTenant(TenantId.development)
44-
.commit(beanBlaster, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
45-
client.eventStore
46-
.forTenant(TenantId.development)
47-
.commit(avocadoArtillery, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
48-
client.eventStore
49-
.forTenant(TenantId.development)
50-
.commit(chiliCannon, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
51-
52-
client.eventStore
53-
.forTenant(TenantId.development)
54-
.commit(mrTacoFired, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
55-
console.log('done comitng');
42+
(async () => {
43+
client.eventStore
44+
.forTenant(TenantId.development)
45+
.commit(beanBlaster, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
46+
client.eventStore
47+
.forTenant(TenantId.development)
48+
.commit(avocadoArtillery, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
49+
client.eventStore
50+
.forTenant(TenantId.development)
51+
.commit(chiliCannon, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
52+
53+
client.eventStore
54+
.forTenant(TenantId.development)
55+
.commit(mrTacoFired, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
56+
57+
const {state: menu} = await client.projections.forTenant(TenantId.development).get(Menu, 'bfe6f6e4-ada2-4344-8a3b-65a3e1fe16e9');
58+
console.log('Got menu', menu);
59+
60+
console.log('Getting all chefs');
61+
for (const [, { key, state: chef }] of await client.projections.forTenant(TenantId.development).getAll(Chef)) {
62+
console.log(`Found chef ${key}`, chef);
63+
}
64+
65+
console.log('Getting all chefs but specify ids');
66+
for (const [, { key, state: chef }] of await client.projections.forTenant(TenantId.development).getAll(Chef, '4a4c5b13-d4dd-4665-a9df-27b8e9b2054d')) {
67+
console.log(`Found chef ${key}`, chef);
68+
}
69+
70+
console.log('Getting all chefs with no type');
71+
for (const [, { key, state: chef }] of await client.projections.forTenant(TenantId.development).getAll('4a4c5b13-d4dd-4665-a9df-27b8e9b2054c', ScopeId.default)) {
72+
console.log(`Found chef ${key}`, chef);
73+
}
74+
})();

‎Source/aggregates/tsconfig.json‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
"include": ["**/*.ts"],
1010
"exclude": ["node_modules", "Distribution"],
1111
"references": [
12-
{ "path": "../artifacts" },
1312
{ "path": "../events" }
1413
]
1514
}

‎Source/artifacts/CannotHaveMultipleEventTypesAssociatedWithType.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,6 @@ import { EventType } from './EventType';
1414
*/
1515
export class CannotHaveMultipleEventTypesAssociatedWithType extends Exception {
1616
constructor(type: Constructor<any>, eventType: EventType, associatedEventType: EventType) {
17-
super(`${type} cannot be associated with ${eventType} because it is already associated with ${associatedEventType}`);
17+
super(`${type.name} cannot be associated with ${eventType} because it is already associated with ${associatedEventType}`);
1818
}
1919
}

‎Source/artifacts/CannotHaveMultipleTypesAssociatedWithEventType.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,6 @@ import { EventType } from './EventType';
1515
*/
1616
export class CannotHaveMultipleTypesAssociatedWithEventType extends Exception {
1717
constructor(eventType: EventType, type: Constructor<any>, associatedType: Constructor<any>) {
18-
super(`${eventType} cannot be associated with ${type} because it is already associated with ${associatedType}`);
18+
super(`${eventType} cannot be associated with ${type.name} because it is already associated with ${associatedType}`);
1919
}
2020
}

‎Source/artifacts/package.json‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,9 @@
3636
"@dolittle/concepts": "5.0.1",
3737
"@dolittle/rudiments": "5.0.1",
3838
"@dolittle/types": "5.0.1",
39-
"@dolittle/runtime.contracts": "5.3.0-projections.9"
39+
"@dolittle/runtime.contracts": "5.3.0-projections.11"
4040
},
4141
"devDependencies": {
4242
"@types/is-natural-number": "^4.0.0"
4343
}
44-
}
44+
}

‎Source/eventHorizon/package.json‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
},
3535
"dependencies": {
3636
"@dolittle/rudiments": "5.0.1",
37-
"@dolittle/runtime.contracts": "5.3.0-projections.9",
37+
"@dolittle/runtime.contracts": "5.3.0-projections.11",
3838
"@dolittle/sdk.events": "14.3.0-projections.0",
3939
"@dolittle/sdk.artifacts": "14.3.0-projections.0",
4040
"@dolittle/sdk.execution": "14.3.0-projections.0",
@@ -48,4 +48,4 @@
4848
"devDependencies": {
4949
"@types/luxon": "1.24.1"
5050
}
51-
}
51+
}

‎Source/eventHorizon/tsconfig.json‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,8 @@
99
"include": ["**/*.ts"],
1010
"exclude": ["node_modules", "Distribution"],
1111
"references": [
12-
{ "path": "../artifacts" },
1312
{ "path": "../execution" },
14-
{ "path": "../protobuf" },
15-
{ "path": "../services" }
13+
{ "path": "../events" },
14+
{ "path": "../protobuf" }
1615
]
1716
}

‎Source/events.filtering/IFilterProcessor.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
// Copyright (c) Dolittle. All rights reserved.
22
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
33

4-
import { IEventProcessor } from '@dolittle/sdk.events.processing/Internal';
4+
import { internal } from '@dolittle/sdk.events.processing';
55

6-
export type IFilterProcessor = IEventProcessor;
6+
export type IFilterProcessor = internal.IEventProcessor;

0 commit comments

Comments
 (0)