From f5ae7af91ea84ca55db3541bbd89ae594e62bd3b Mon Sep 17 00:00:00 2001 From: boneyard93501 <4523011+boneyard93501@users.noreply.github.com> Date: Sat, 23 Oct 2021 13:48:16 -0500 Subject: [PATCH] update service names --- src/index.ts | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/src/index.ts b/src/index.ts index 0ad990a..bfb0ccb 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,10 +1,10 @@ import { Fluence, KeyPair } from "@fluencelabs/fluence"; import { krasnodar } from "@fluencelabs/fluence-network-environment"; -import { registerProVoValidation, ProVoValidationDef, registerDataProvider, DataProviderDef } from "./_aqua/snapshot"; +import { registerEIPValidator, EIPValidatorDef, registerDataProvider, DataProviderDef } from "./_aqua/snapshot"; import { ethers } from "ethers"; import { TypedDataUtils } from 'ethers-eip712'; // https://github.com/0xsequence/ethers-eip712 import { eip_validation, Response } from "./eip_processor"; -import { get_db, create_table, insert_event, DBRecord, select_events, select_event } from './local_db'; +import { get_db, create_table, insert_event, DBRecord, DBResult, select_events, select_event } from './local_db'; import got from 'got'; import { base64 } from "ethers/lib/utils"; @@ -23,7 +23,9 @@ function sign_response(wallet: ethers.Wallet, response: Response): Promise { // todo: need to fix this to use local peer key @@ -76,9 +78,10 @@ class EIPValidator implements ProVoValidationDef { } } +// class exposed as service `DataProviderDef` in snapshot.aqua class DataProvider implements DataProviderDef { - get_record(snapshot_id: number) { + async get_record(snapshot_id: number): Promise { return select_event(snapshot_id); } @@ -118,7 +121,7 @@ async function main() { // console.log(peer); // console.log(Fluence.KeyPair); - registerProVoValidation("EIPValidator", new EIPValidator()); + registerEIPValidator("EIPValidator", new EIPValidator()); registerDataProvider("DataProvider", new DataProvider); // const eip_doc: any = await got('https://ipfs.fleek.co/ipfs/QmWGzSQFm57ohEq2ATw4UNHWmYU2HkMjtedcNLodYywpmS').json();