Skip to content

Commit 6bfbc51

Browse files
committed
Code-review changes
1 parent 5748508 commit 6bfbc51

File tree

2 files changed

+13
-45
lines changed

2 files changed

+13
-45
lines changed

packages/persistance/src/services/prisma/mappers/EventMapper.ts

Lines changed: 12 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -4,25 +4,15 @@ import { Field } from "o1js";
44

55
import { ObjectMapper } from "../../../ObjectMapper";
66

7+
type EventData = {
8+
eventName: string;
9+
data: Field[];
10+
source: "afterTxHook" | "beforeTxHook" | "runtime";
11+
};
12+
713
@singleton()
8-
export class EventMapper
9-
implements
10-
ObjectMapper<
11-
{
12-
eventName: string;
13-
data: Field[];
14-
source: "afterTxHook" | "beforeTxHook" | "runtime";
15-
},
16-
Prisma.JsonObject
17-
>
18-
{
19-
public mapIn(input: Prisma.JsonObject): {
20-
eventName: string;
21-
data: Field[];
22-
source: "afterTxHook" | "beforeTxHook" | "runtime";
23-
} {
24-
if (input === undefined)
25-
return { eventName: "", data: [], source: "runtime" };
14+
export class EventMapper implements ObjectMapper<EventData, Prisma.JsonObject> {
15+
public mapIn(input: Prisma.JsonObject): EventData {
2616
return {
2717
eventName: input.eventName as string,
2818
data: (input.data as Prisma.JsonArray).map((field) =>
@@ -32,11 +22,7 @@ export class EventMapper
3222
};
3323
}
3424

35-
public mapOut(input: {
36-
eventName: string;
37-
data: Field[];
38-
source: "afterTxHook" | "beforeTxHook" | "runtime";
39-
}): Prisma.JsonObject {
25+
public mapOut(input: EventData): Prisma.JsonObject {
4026
return {
4127
eventName: input.eventName,
4228
data: input.data.map((field) => field.toString()),
@@ -60,23 +46,11 @@ export class EventMapper
6046

6147
@singleton()
6248
export class EventArrayMapper
63-
implements
64-
ObjectMapper<
65-
{
66-
eventName: string;
67-
data: Field[];
68-
source: "afterTxHook" | "beforeTxHook" | "runtime";
69-
}[],
70-
Prisma.JsonValue | undefined
71-
>
49+
implements ObjectMapper<EventData[], Prisma.JsonValue | undefined>
7250
{
7351
public constructor(private readonly eventMapper: EventMapper) {}
7452

75-
public mapIn(input: Prisma.JsonValue | undefined): {
76-
eventName: string;
77-
data: Field[];
78-
source: "afterTxHook" | "beforeTxHook" | "runtime";
79-
}[] {
53+
public mapIn(input: Prisma.JsonValue | undefined): EventData[] {
8054
if (input === undefined) return [];
8155

8256
if (Array.isArray(input)) {
@@ -87,13 +61,7 @@ export class EventArrayMapper
8761
return [];
8862
}
8963

90-
public mapOut(
91-
input: {
92-
eventName: string;
93-
data: Field[];
94-
source: "afterTxHook" | "beforeTxHook" | "runtime";
95-
}[]
96-
): Prisma.JsonValue {
64+
public mapOut(input: EventData[]): Prisma.JsonValue {
9765
return input.map((event) =>
9866
this.eventMapper.mapOut(event)
9967
) as Prisma.JsonArray;

packages/sequencer/src/protocol/production/sequencing/TransactionExecutionService.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -406,7 +406,7 @@ export class TransactionExecutionService {
406406
statusMessage: runtimeResult.statusMessage,
407407

408408
stateTransitions,
409-
events: beforeHookEvents.concat(afterHookEvents, runtimeResultEvents),
409+
events: beforeHookEvents.concat(runtimeResultEvents, afterHookEvents),
410410
},
411411
];
412412
}

0 commit comments

Comments
 (0)