Skip to content

Commit 04ed2d1

Browse files
committed
Remove deprecated-replay
1 parent da33646 commit 04ed2d1

File tree

5 files changed

+7
-132
lines changed

5 files changed

+7
-132
lines changed

src/read-models/members/get-all.ts

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
import * as RA from 'fp-ts/ReadonlyArray';
22
import {DomainEvent, isEventOfType, Actor, User} from '../../types';
33
import {pipe} from 'fp-ts/lib/function';
4-
import {MultipleMembers} from './return-types';
5-
import {replayState} from '../shared-state';
6-
import {redactDetailsForActor} from '../shared-state/member/redact';
74

85
export const getAll = (
96
events: ReadonlyArray<DomainEvent>
@@ -17,22 +14,10 @@ export const getAll = (
1714
}))
1815
);
1916

20-
export const getAllDetails = (
21-
events: ReadonlyArray<DomainEvent>
22-
): MultipleMembers => pipe(events, replayState, state => state.members);
23-
2417
export const liftActorOrUser = (actorOrUser: Actor | User) =>
2518
Actor.is(actorOrUser)
2619
? actorOrUser
2720
: {
2821
tag: 'user' as const,
2922
user: actorOrUser,
3023
};
31-
32-
export const getAllDetailsAsActor =
33-
(actorOrUser: Actor | User) => (events: ReadonlyArray<DomainEvent>) =>
34-
pipe(
35-
events,
36-
getAllDetails,
37-
redactDetailsForActor(liftActorOrUser(actorOrUser))
38-
);
Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,16 @@
1+
import * as RA from 'fp-ts/ReadonlyArray';
12
import {pipe} from 'fp-ts/lib/function';
23
import {DomainEvent} from '../../types';
3-
import {replayState} from '../shared-state';
44
import {FailedLinking} from './failed-linking';
5+
import {isEventOfType} from '../../types';
56

67
export const getFailedImports = (
78
events: ReadonlyArray<DomainEvent>
89
): ReadonlyArray<FailedLinking> =>
910
pipe(
1011
events,
11-
replayState,
12-
state => state.failedImports,
13-
failedImports => Array.from(failedImports.values())
12+
RA.filter(
13+
isEventOfType('LinkingMemberNumberToAnAlreadyUsedEmailAttempted')
14+
),
15+
RA.map(({memberNumber, email}) => ({memberNumber, email}))
1416
);

src/read-models/members/index.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,10 @@
1-
import {getAll, getAllDetails, getAllDetailsAsActor} from './get-all';
1+
import {getAll} from './get-all';
22
import {lookupByEmail} from './lookup-by-email';
33
import {getFailedImports} from './get-failed-imports';
44

55
export const members = {
66
lookupByEmail,
77
getAll,
8-
getAllDetails,
9-
getAllDetailsAsActor,
108
getFailedImports,
119
};
1210

src/read-models/shared-state/deprecated-replay.ts

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

src/read-models/shared-state/index.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,6 @@ import {Dependencies} from '../../dependencies';
2424
import {dumpCurrentState, SharedDatabaseDump} from './debug/dump';
2525
import {getAllTroubleTicketFull} from './troubletickets/get';
2626

27-
export {replayState} from './deprecated-replay';
28-
2927
export type SharedReadModel = {
3028
db: BetterSQLite3Database;
3129
_underlyingReadModelDb: Database.Database; // This is exposed only to allow debug serialisation of the db.

0 commit comments

Comments
 (0)