*Add rpc ready call to consensusHandler and executionHandler to ensure we have a relay before continuing
This commit is contained in:
parent
62c6950957
commit
a03ae542b1
|
@ -65,6 +65,11 @@ async function handleRpcMethod(aq: ActiveQuery) {
|
||||||
}
|
}
|
||||||
|
|
||||||
async function consensusHandler(method: string, data: any) {
|
async function consensusHandler(method: string, data: any) {
|
||||||
|
// @ts-ignore
|
||||||
|
await (
|
||||||
|
await rpc.ready
|
||||||
|
)();
|
||||||
|
|
||||||
while (true) {
|
while (true) {
|
||||||
let query = await rpc.simpleQuery({
|
let query = await rpc.simpleQuery({
|
||||||
query: {
|
query: {
|
||||||
|
@ -87,6 +92,10 @@ async function consensusHandler(method: string, data: any) {
|
||||||
}
|
}
|
||||||
|
|
||||||
async function executionHandler(data: Map<string, string | any>) {
|
async function executionHandler(data: Map<string, string | any>) {
|
||||||
|
// @ts-ignore
|
||||||
|
await (
|
||||||
|
await rpc.ready
|
||||||
|
)();
|
||||||
while (true) {
|
while (true) {
|
||||||
let query = await rpc.simpleQuery({
|
let query = await rpc.simpleQuery({
|
||||||
query: {
|
query: {
|
||||||
|
|
Loading…
Reference in New Issue