1
1
import "reflect-metadata" ;
2
2
import { describe } from "@jest/globals" ;
3
3
import { Field } from "o1js" ;
4
- import { CachedMerkleTreeStore } from "@proto-kit/sequencer" ;
4
+ import { CachedMerkleTreeStore , ConsoleTracer } from "@proto-kit/sequencer" ;
5
5
import { expectDefined , RollupMerkleTree } from "@proto-kit/common" ;
6
6
7
7
import {
@@ -14,15 +14,17 @@ import {
14
14
// TODO Pull apart and test properly
15
15
// Needs redis instance
16
16
describe . skip ( "prisma" , ( ) => {
17
+ const tracer = new ConsoleTracer ( ) ;
18
+
17
19
it ( "merkle store" , async ( ) => {
18
- const db = new RedisConnectionModule ( ) ;
20
+ const db = new RedisConnectionModule ( tracer ) ;
19
21
db . config = {
20
22
host : "localhost" ,
21
23
port : 6379 ,
22
24
password : "password" ,
23
25
} ;
24
26
await db . start ( ) ;
25
- const store = new RedisMerkleTreeStore ( db ) ;
27
+ const store = new RedisMerkleTreeStore ( db , tracer ) ;
26
28
27
29
const cached = new CachedMerkleTreeStore ( store ) ;
28
30
const tree = new RollupMerkleTree ( cached ) ;
@@ -38,7 +40,7 @@ describe.skip("prisma", () => {
38
40
39
41
console . log ( `Root ${ tree . getRoot ( ) . toBigInt ( ) } ` ) ;
40
42
41
- const store2 = new RedisMerkleTreeStore ( db ) ;
43
+ const store2 = new RedisMerkleTreeStore ( db , tracer ) ;
42
44
43
45
const cached2 = new CachedMerkleTreeStore ( store2 ) ;
44
46
const tree2 = new RollupMerkleTree ( cached2 ) ;
@@ -57,10 +59,10 @@ describe.skip("prisma", () => {
57
59
} ) ;
58
60
59
61
it ( "fill and get" , async ( ) => {
60
- const db = new PrismaDatabaseConnection ( ) ;
62
+ const db = new PrismaDatabaseConnection ( tracer ) ;
61
63
db . config = { } ;
62
64
await db . start ( ) ;
63
- const service = new PrismaStateService ( db , "testMask" ) ;
65
+ const service = new PrismaStateService ( db , tracer , "testMask" ) ;
64
66
65
67
await service . openTransaction ( ) ;
66
68
service . writeStates ( [
0 commit comments