fluencelabs/eip712-validation-node
1
0
Fork 0
mirror of https://github.com/fluencelabs/eip712-validation-node synced 2025-06-28 06:01:53 +00:00
Code Issues Projects Releases Wiki Activity

update db create

Browse Source
This commit is contained in:
boneyard93501
2021-09-30 10:56:01 -05:00
parent 8aad787da9
commit f75563f242
2 changed files with 38 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/index.ts
View File

@ -7,6 +7,7 @@ import { TypedDataUtils } from 'ethers-eip712'; // https://github.com/0xsequenc
import { eip_validation, Response } from "./eip_processor"; import { eip_validation, Response } from "./eip_processor";
import { get_db, create_table, insert_event } from './local_db'; import { get_db, create_table, insert_event } from './local_db';
var sqlite3 = require('sqlite3').verbose();
@ -50,12 +51,14 @@ async function main() {
// return (resp_str, signed_response); // return (resp_str, signed_response);
var db = await get_db(DB_PATH); var db = get_db(DB_PATH);
await create_table(db); const _table = await create_table(db);
await insert_event(db, JSON.parse(eip712_doc), response, signed_response); console.log(_table);
const _insert = insert_event(db, JSON.parse(eip712_doc), response, signed_response);
console.log(_insert);
db.close(); // db.close();
} }
main(); main();

44
src/local_db.ts
View File

@ -1,11 +1,14 @@
// import { sqlite3, open } from 'sqlite3'; // import { sqlite3, open } from 'sqlite3';
var sqlite3 = require("sqlite3").verbose(); // var sqlite3 = require("sqlite3").verbose();
// import "sqlite3";
import * as sqlite from 'sqlite3';
const sqlite3 = sqlite.verbose();
import { Response } from './eip_processor'; import { Response } from './eip_processor';
// db handler // db handler
export async function get_db(db_path: any) { export function get_db(db_path: any): sqlite.Database {
var db_path = db_path; var db_path = db_path;
if (db_path === null) { if (db_path === null) {
@ -17,31 +20,46 @@ export async function get_db(db_path: any) {
return console.error("failure to get sqlite: ", err.message); return console.error("failure to get sqlite: ", err.message);
} }
}); });
console.dir(db);
return db; return db;
} }
export async function create_table(db: any) { export async function create_table(db: sqlite.Database) {
const stmt = `create table if not exists snapshot ( const stmt = `create table if not exists snapshot (
snapshot_id integer primary key, snapshot_id integer primary key,
event_address text, event_address text,
event_signature text, event_signature text,
eip712_doc text, eip712_doc blob,
peer_id text, peer_id text,
timestamp integer, timestamp integer,
eip_validation boolean, eip_validation boolean,
ts_validation boolean, ts_validation boolean,
signed_response text signed_response text
)`; )`;
let promise = new Promise<void>((resolve, reject) => db.run(stmt, (res: sqlite.RunResult, err: Error) => {
console.dir(res);
if (err !== null) {
resolve()
} else {
reject(err)
}
}));
return promise;
db.run(stmt); db.run(stmt);
} }
export async function insert_event(db: any, eip_obj: any, response_obj: Response, signed_msg: string) {
export function insert_event(db: any, eip_obj: any, response_obj: Response, signed_msg: string) {
const stmt = `insert into snapshot values (?,?,?,?,?,?,?,?,?)`; const stmt = `insert into snapshot values (?,?,?,?,?,?,?,?,?)`;
// const stmt = `insert into snapshot values (?)`;
var cursor = db.prepare(stmt); var cursor = db.prepare(stmt);
const vals = [eip_obj.data.message.snapshot, eip_obj.address, eip_obj.sig, JSON.stringify(eip_obj.data), response_obj.peer_id, response_obj.timestamp, response_obj.eip_validation, response_obj.ts_validation, signed_msg]; var vals = [eip_obj.data.message.snapshot, eip_obj.address, eip_obj.sig, JSON.stringify(eip_obj.data), response_obj.peer_id, response_obj.timestamp, response_obj.eip_validation, response_obj.ts_validation, signed_msg];
// var vals = [1];
for (let v of vals) { for (let v of vals) {
console.log(typeof (v)); console.log(typeof (v));
} }