Skip to content

Commit 446ddc7

Browse files
joelhoiskojoelhoisko
authored
Merge pull request #55 from dolittle/rename-part1
2 parents 775c496 + 52bc10f commit 446ddc7

43 files changed

Lines changed: 377 additions & 421 deletions

Some content is hidden

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

‎Samples/Tutorials/Embeddings/Chef.ts‎

Lines changed: 0 additions & 9 deletions
This file was deleted.

‎Samples/Tutorials/Embeddings/DishCounter.ts‎

Lines changed: 0 additions & 48 deletions
This file was deleted.

‎Samples/Tutorials/Embeddings/DishHandler.ts‎

Lines changed: 0 additions & 22 deletions
This file was deleted.

‎Samples/Tutorials/Embeddings/DishPrepared.ts‎

Lines changed: 0 additions & 10 deletions
This file was deleted.

‎Samples/Tutorials/Embeddings/Employee.ts‎

Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
// Copyright (c) Dolittle. All rights reserved.
2+
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
3+
// Sample code for the tutorial at https://dolittle.io/tutorials/embeddings/
4+
5+
import { CouldNotResolveUpdateToEvents, embedding, EmbeddingContext, EmbeddingProjectContext, on, resolveDeletionToEvents, resolveUpdateToEvents } from '@dolittle/sdk.embeddings';
6+
import { ProjectionResult } from '@dolittle/sdk.projections';
7+
import { EmployeeHired } from './EmployeeHired';
8+
import { EmployeeRetired } from './EmployeeRetired';
9+
import { EmployeeTransferred } from './EmployeeTransferred';
10+
11+
@embedding('e5577d2c-0de7-481c-b5be-6ef613c2fcd6')
12+
export class Employee {
13+
14+
constructor(
15+
public name: string = '',
16+
public workplace: string = 'Unassigned') {
17+
}
18+
19+
@resolveUpdateToEvents()
20+
resolveUpdateToEvents(updatedEmployee: Employee, context: EmbeddingContext) {
21+
if (this.name !== updatedEmployee.name) {
22+
return new EmployeeHired(updatedEmployee.name);
23+
} else if (this.workplace !== updatedEmployee.workplace) {
24+
return new EmployeeTransferred(this.name, this.workplace, updatedEmployee.workplace);
25+
}
26+
27+
throw new CouldNotResolveUpdateToEvents();
28+
}
29+
30+
@resolveDeletionToEvents()
31+
resolveDeletionToEvents(context: EmbeddingContext) {
32+
return new EmployeeRetired(this.name);
33+
}
34+
35+
@on(EmployeeHired)
36+
onEmployeeHired(event: EmployeeHired, context: EmbeddingProjectContext) {
37+
this.name = event.name;
38+
}
39+
40+
@on(EmployeeTransferred)
41+
onEmployeeTransferred(event: EmployeeTransferred, context: EmbeddingProjectContext) {
42+
this.workplace = event.to;
43+
}
44+
45+
@on(EmployeeRetired)
46+
onEmployeeRetired(event: EmployeeRetired, context: EmbeddingProjectContext) {
47+
return ProjectionResult.delete;
48+
}
49+
}

Samples/Tutorials/Embeddings/ChefFired.ts renamed to Samples/Tutorials/Embeddings/EmployeeHired.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44

55
import { eventType } from '@dolittle/sdk.events';
66

7-
@eventType('d3db6f3c-eee5-4b8a-9c6b-c9cd71e545ed')
8-
export class ChefFired {
9-
constructor(readonly Chef: string) {}
7+
@eventType('8fdf45bc-f484-4348-bcb0-4d6f134aaf6c')
8+
export class EmployeeHired {
9+
constructor(readonly name: string) {}
1010
}

Samples/Tutorials/Embeddings/ChefHired.ts renamed to Samples/Tutorials/Embeddings/EmployeeRetired.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44

55
import { eventType } from '@dolittle/sdk.events';
66

7-
@eventType('a7a499a8-816f-4bc5-96cc-a44a6f5d1b04')
8-
export class ChefHired {
9-
constructor(readonly Chef: string) {}
7+
@eventType('1932beb4-c8cd-4fee-9a7e-a92af3693510')
8+
export class EmployeeRetired {
9+
constructor(readonly name: string) {}
1010
}

Samples/Tutorials/Embeddings/DishRemoved.ts renamed to Samples/Tutorials/Embeddings/EmployeeTransferred.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
// Copyright (c) Dolittle. All rights reserved.
22
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
3-
// Sample code for the tutorial at https://dolittle.io/tutorials/projections/typescript/
3+
// Sample code for the tutorial at https://dolittle.io/tutorials/embeddings/
44

55
import { eventType } from '@dolittle/sdk.events';
66

7-
@eventType('e6b18cdd-5abd-402a-92b7-ec32941def4a')
8-
export class DishRemoved {
9-
constructor(readonly Dish: string) {}
7+
@eventType('b27f2a39-a2d4-43a7-9952-62e39cbc7ebc')
8+
export class EmployeeTransferred {
9+
constructor(readonly name: string, readonly from: string, readonly to: string) {}
1010
}

‎Samples/Tutorials/Embeddings/index.ts‎

Lines changed: 19 additions & 101 deletions
Original file line numberDiff line numberDiff line change
@@ -4,126 +4,44 @@
44

55
import { Client } from '@dolittle/sdk';
66
import { TenantId } from '@dolittle/sdk.execution';
7-
import { ProjectionResult } from '@dolittle/sdk.projections';
8-
import { Chef } from './Chef';
9-
import { ChefFired } from './ChefFired';
10-
import { ChefHired } from './ChefHired';
11-
import { DishCounter } from './DishCounter';
12-
import { DishHandler } from './DishHandler';
13-
import { DishPrepared } from './DishPrepared';
14-
import { DishRemoved } from './DishRemoved';
7+
import { Employee } from './Employee';
8+
import { EmployeeHired } from './EmployeeHired';
9+
import { EmployeeRetired } from './EmployeeRetired';
10+
import { EmployeeTransferred } from './EmployeeTransferred';
1511

1612
const client = Client
1713
.forMicroservice('f39b1f61-d360-4675-b859-53c05c87c0e6')
1814
.withEventTypes(eventTypes => {
19-
eventTypes.register(DishPrepared);
20-
eventTypes.register(DishRemoved);
21-
eventTypes.register(ChefHired);
22-
eventTypes.register(ChefFired);
15+
eventTypes.register(EmployeeHired);
16+
eventTypes.register(EmployeeTransferred);
17+
eventTypes.register(EmployeeRetired);
2318
})
24-
.withEventHandlers(builder =>
25-
builder.register(DishHandler))
2619
.withEmbeddings(builder => {
27-
builder.register(DishCounter);
28-
builder
29-
.createEmbedding('999a6aa4-4412-4eaf-a99b-2842cb191e7c')
30-
.forReadModel(Chef)
31-
.compare((receivedState, currentState, context) => {
32-
if (!currentState.name) {
33-
return new ChefHired(receivedState.name);
34-
}
35-
})
36-
.remove((currentState, context) => new ChefFired(currentState.name))
37-
.on(ChefHired, (currentState, event, context) => {
38-
currentState.name = event.Chef;
39-
return currentState;
40-
})
41-
.on(ChefFired, (currentState, event, context) => {
42-
return ProjectionResult.delete;
43-
});
20+
builder.register(Employee);
4421
})
4522
.build();
4623

4724
(async () => {
4825

26+
// wait for the registration to complete
4927
setTimeout(async () => {
50-
51-
const tacoCounter = new DishCounter();
52-
tacoCounter.dish = 'Taco';
53-
tacoCounter.numberOfTimesPrepared = 5;
54-
55-
const burritoCounter = new DishCounter();
56-
burritoCounter.dish = 'Burrito';
57-
burritoCounter.numberOfTimesPrepared = 3;
58-
59-
const wrapCounter = new DishCounter();
60-
wrapCounter.dish = 'Wrap';
61-
wrapCounter.numberOfTimesPrepared = 2;
62-
63-
await Promise.all([tacoCounter, burritoCounter, wrapCounter]
64-
.map(async counter => {
65-
console.log(`Updating dish: ${counter.dish}`);
66-
await client.embeddings
67-
.forTenant(TenantId.development)
68-
.update(DishCounter, counter.dish, counter);
69-
70-
const counterState = await client.embeddings
71-
.forTenant(TenantId.development)
72-
.get(DishCounter, counter.dish);
73-
console.log('Got dish:', counterState.state);
74-
75-
console.log(`Removed dish counter: ${counter}`);
76-
await client.embeddings
77-
.forTenant(TenantId.development)
78-
.remove(DishCounter, counter.dish);
79-
80-
const deletedCounter = await client.embeddings
81-
.forTenant(TenantId.development)
82-
.get(DishCounter, counter.dish);
83-
console.log(`Got a removed, initial dish counter: ${JSON.stringify(deletedCounter.state)}`);
84-
}));
85-
86-
const allDishCounters = await client.embeddings
87-
.forTenant(TenantId.development)
88-
.getAll(DishCounter);
89-
console.log(`Got all dishes:\n${[...allDishCounters].map(([key, value]) => `${key.value}: ${JSON.stringify(value.state, undefined, 2)}`).join('\n')}`);
90-
91-
const dishCounterKeys = await client.embeddings
92-
.forTenant(TenantId.development)
93-
.getKeys(DishCounter);
94-
console.log(`Got all keys: ${dishCounterKeys}`);
95-
96-
console.log('Hiring chefs!');
97-
const mrTaco = new Chef('Mr. Taco');
98-
const mrsTexMex = new Chef('Mrs. TexMex');
28+
// mock of the state from the external HR system
29+
const updatedEmployee = new Employee(
30+
'Mr. Taco',
31+
'Street Food Taco Truck');
9932

10033
await client.embeddings
10134
.forTenant(TenantId.development)
102-
.update(mrTaco.name, '999a6aa4-4412-4eaf-a99b-2842cb191e7c', mrTaco);
103-
await client.embeddings
104-
.forTenant(TenantId.development)
105-
.update(mrsTexMex.name, '999a6aa4-4412-4eaf-a99b-2842cb191e7c', mrsTexMex);
35+
.update(Employee, updatedEmployee.name, updatedEmployee);
36+
console.log(`Updated ${updatedEmployee.name}`);
10637

107-
console.log('Getting all chefs!');
108-
const allChefs = await client.embeddings
109-
.forTenant(TenantId.development)
110-
.getAll('999a6aa4-4412-4eaf-a99b-2842cb191e7c');
111-
console.log(`Got all chefs:\n${[...allChefs].map(([key, value]) => `${key.value}: ${JSON.stringify(value.state, undefined, 2)}`).join('\n')}`);
112-
113-
console.log('Removing Mr. Taco!');
11438
await client.embeddings
11539
.forTenant(TenantId.development)
116-
.remove(mrTaco.name, '999a6aa4-4412-4eaf-a99b-2842cb191e7c');
117-
const allChefsAgain = await client.embeddings
118-
.forTenant(TenantId.development)
119-
.getAll('999a6aa4-4412-4eaf-a99b-2842cb191e7c');
120-
console.log(`Getting all chefs again:\n${[...allChefsAgain].map(([key, value]) => `${key.value}: ${JSON.stringify(value.state, undefined, 2)}`).join('\n')}`);
40+
.delete(Employee, updatedEmployee.name);
41+
console.log(`Deleted ${updatedEmployee.name}`);
12142

122-
console.log('Getting Mr. Taco');
123-
const getMrTaco = await client.embeddings
43+
await client.embeddings
12444
.forTenant(TenantId.development)
125-
.get(mrTaco.name, '999a6aa4-4412-4eaf-a99b-2842cb191e7c');
126-
console.log('Got removed Mr. Taco:', getMrTaco.state);
127-
45+
.getKeys(Employee);
12846
}, 1000);
12947
})();

‎Source/embeddings/Builder/CompareDecoratedMethods.ts‎

Lines changed: 0 additions & 34 deletions
This file was deleted.

0 commit comments

Comments
 (0)