diff --git a/aqua/snapshot.aqua b/aqua/snapshot.aqua
new file mode 100644
index 0000000..9998a16
--- /dev/null
+++ b/aqua/snapshot.aqua
@@ -0,0 +1,36 @@
+data PVResponse:
+    peer_id: string
+    timestamp: u64
+    eip_validation: bool
+    ts_validation: bool
+
+data DBResponse:
+    snapshot_id: u64
+
+service ProVoValidation("eip_validation"):
+    eip_validation(eip_str: string, peer_id: string)
+
+service DataProvider(""):
+    get_records()
+    get_record(snapshot_id: u64)
+
+
+func validate(relay: string, peer:string, eip712_json: string) -> PVResponse {
+    on peer via relay:
+        result <- ProVoValidation.eip_validation(eip712_json, peer)        
+    <- result
+}
+
+
+func get_record(relay:string, peer:string, snapshot_id: u64) -> DBResponse:
+    on peer via relay:
+        result <- DataProvider.get_record(snapshot_id)
+    <- result
+
+
+func get_records(relay:string, peer:string) -> []DBResponse:
+    on peer via relay:
+        result <- DataProvider.get_records()
+    <- result
+
+
diff --git a/data/snapshot.db b/data/snapshot.db
index 69bc957..dce3035 100644
Binary files a/data/snapshot.db and b/data/snapshot.db differ
diff --git a/src/index.ts b/src/index.ts
index d870cac..61c89cd 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -5,7 +5,7 @@
 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 } from './local_db';
+import { get_db, create_table, insert_event, DBRecord } from './local_db';
 
 var sqlite3 = require('sqlite3').verbose();
 
diff --git a/src/local_db.ts b/src/local_db.ts
index 4df8918..8583670 100644
--- a/src/local_db.ts
+++ b/src/local_db.ts
@@ -6,6 +6,17 @@ const sqlite3 = sqlite.verbose();
 import { Response } from './eip_processor';
 
 
+export interface DBRecord {
+    snapshot_id: number;
+    event_address: string;
+    event_signature: string;
+    eip712_doc: string;
+    peer_id: string;
+    timestamp: number;
+    eip_validation: boolean;
+    ts_validation: boolean;
+    signed_response: string;
+}
 
 // db handler
 export function get_db(db_path: any): sqlite.Database {