bloxbean / yaci-store

A Cardano datastore implementation using Yaci
https://store.yaci.xyz/
MIT License
21 stars 8 forks source link

[Conway] Local protocol parameter query in scheduler fails for conway era #303

Open satran004 opened 4 months ago

satran004 commented 4 months ago

Environment: DevKit Node (Conway era)

2024-07-02T12:57:10.422+08:00  INFO 95829 --- [Yaci Store App] [KQueueEventLoopGroup-3-1] c.b.c.y.c.p.handshake.HandshakeAgent     : Handshake Ok!!! AcceptVersion(versionNumber=32784, versionData=N2NVersionData(initiatorOnlyDiffusionMode=false, peerSharing=0, query=false))
2024-07-02T12:57:10.457+08:00  INFO 95829 --- [Yaci Store App] [scheduling-1] .b.c.y.s.e.p.LocalProtocolParamsSchduler : Fetching protocol params ....
2024-07-02T12:57:10.458+08:00 ERROR 95829 --- [Yaci Store App] [scheduling-1] c.b.c.y.s.e.s.LocalProtocolParamService  : Local protocol param sync error Current state [Querying] doesn't support this message : MsgQuery(query=CurrentProtocolParamsQuery(era=Babbage), protocolVersion=AcceptVersion(versionNumber=32784, versionData=N2NVersionData(initiatorOnlyDiffusionMode=false, peerSharing=0, query=false)))
2024-07-02T12:57:10.458+08:00 ERROR 95829 --- [Yaci Store App] [scheduling-1] reactor.core.publisher.Operators         : Operator called default onErrorDropped

reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.IllegalStateException: Current state [Querying] doesn't support this message : MsgQuery(query=CurrentProtocolParamsQuery(era=Babbage), protocolVersion=AcceptVersion(versionNumber=32784, versionData=N2NVersionData(initiatorOnlyDiffusionMode=false, peerSharing=0, query=false)))
Caused by: java.lang.IllegalStateException: Current state [Querying] doesn't support this message : MsgQuery(query=CurrentProtocolParamsQuery(era=Babbage), protocolVersion=AcceptVersion(versionNumber=32784, versionData=N2NVersionData(initiatorOnlyDiffusionMode=false, peerSharing=0, query=false)))
    at com.bloxbean.cardano.yaci.core.protocol.State.verifyMessageType(State.java:35) ~[yaci-core-0.3.0-beta14.jar!/:na]
    at com.bloxbean.cardano.yaci.core.protocol.localstate.LocalStateQueryAgent.query(LocalStateQueryAgent.java:137) ~[yaci-core-0.3.0-beta14.jar!/:na]
    at com.bloxbean.cardano.yaci.helper.LocalStateQueryClient.lambda$executeQuery$6(LocalStateQueryClient.java:185) ~[yaci-helper-0.3.0-beta14.jar!/:na]
    at reactor.core.publisher.MonoCreate.subscribe(MonoCreate.java:61) ~[reactor-core-3.6.2.jar!/:3.6.2]
    at reactor.core.publisher.Mono.subscribe(Mono.java:4512) ~[reactor-core-3.6.2.jar!/:3.6.2]
    at reactor.core.publisher.Mono.subscribeWith(Mono.java:4578) ~[reactor-core-3.6.2.jar!/:3.6.2]
    at reactor.core.publisher.Mono.subscribe(Mono.java:4478) ~[reactor-core-3.6.2.jar!/:3.6.2]
    at reactor.core.publisher.Mono.subscribe(Mono.java:4414) ~[reactor-core-3.6.2.jar!/:3.6.2]
    at reactor.core.publisher.Mono.subscribe(Mono.java:4361) ~[reactor-core-3.6.2.jar!/:3.6.2]