rfk: use test client in fork tests (#3)

* Erhant/get events test rfks (#2)

* fork test takes too long, revert

Author: erhant

.vscode/settings.json

@@ -1,5 +1,4 @@
 {
-  "jestrunner.jestCommand": "node ../../node_modules/jest/bin/jest.js",
   // https://raw.githubusercontent.com/PKief/vscode-material-icon-theme/main/images/folderIcons.png
   "material-icon-theme.folders.associations": {
     "abis": "Mappings",

README.md

@@ -42,6 +42,12 @@ yarn add dria-oracle-sdk
 pnpm add dria-oracle-sdk
 ```
 
+The SDK makes use of Arweave as well for large inputs & outputs to save gas, and this depends on a peer dependency:
+
+```sh
+pnpm add @irys/sdk
+```
+
 ## Usage
 
 Using Oracle SDK, the following happens when you make a request:

examples/common/index.mjs

@@ -7,7 +7,7 @@ import { readFileSync } from "fs";
 /** Setup an oracle & initialize it using env variables. */
 export async function setupOracle() {
   const SECRET_KEY = process.env.SECRET_KEY;
-  const RPC_URL = process.env.RPC_URL ?? "https://base-sepolia-rpc.publicnode.com";
+  const RPC_URL = "https://base-sepolia-rpc.publicnode.com";
   const COORDINATOR_ADDRESS = process.env.COORDINATOR_ADDRESS ?? "0x13f977bde221b470d3ae055cde7e1f84debfe202";
   const ARWEAVE_WALLET_PATH = process.env.ARWEAVE_WALLET_PATH;
 
@@ -19,21 +19,23 @@ export async function setupOracle() {
   }
 
   // create oracle client
+  const account = privateKeyToAccount(SECRET_KEY);
   const oracle = new Oracle(
     {
       public: createPublicClient({
         chain: baseSepolia,
         transport: http(RPC_URL),
       }),
       wallet: createWalletClient({
-        account: privateKeyToAccount(SECRET_KEY),
+        account: account,
         chain: baseSepolia,
         transport: http(RPC_URL),
       }),
     },
     storage
   );
 
+  console.log("Your address:", account.address);
   console.log("Initializing oracle for coordinator:", COORDINATOR_ADDRESS);
   await oracle.init(COORDINATOR_ADDRESS);
 

examples/events.mjs

@@ -0,0 +1,22 @@
+// Usage: node ./view.mjs
+import "dotenv/config";
+import { inspect } from "util";
+import { setupOracle } from "./common/index.mjs";
+
+async function main() {
+  const oracle = await setupOracle();
+
+  const protocol = process.argv[2] ?? "swan-purchase-protocol/0.1.0";
+  console.log("Viewing events for protocol:", protocol);
+
+  const taskEvents = await oracle.getEvents({ protocol });
+  console.log(
+    inspect(taskEvents, {
+      showHidden: true,
+      depth: null,
+      colors: true,
+    })
+  );
+}
+
+main().catch(console.error);

examples/view.mjs

@@ -10,6 +10,8 @@ async function main() {
   const taskId = BigInt(process.argv[2] ?? 1);
   console.log("Viewing task:", taskId);
 
+  // TODO: add request here
+
   console.log("\nGenerations:");
   const responses = await oracle.getResponses(taskId);
   for (const responseRaw of responses) {

package.json

@@ -1,12 +1,12 @@
 {
   "name": "dria-oracle-sdk",
-  "version": "0.0.9",
-  "description": "An on-chain AI oracle SDK for Dria",
+  "version": "0.0.10",
+  "description": "An on-chain LLM Oracle SDK for Dria",
   "license": "MIT",
   "author": "FirstBatch Team <[email protected]>",
   "homepage": "https://github.com/firstbatchxyz/dria-oracle-sdk#readme",
   "contributors": [
-    "Erhan Tezcan <[email protected]>"
+    "Erhan Tezcan <[email protected]> (https://github.com/erhant)"
   ],
   "files": [
     "dist/",
@@ -36,6 +36,7 @@
     "dotenv": "^16.4.5",
     "jest": "^29.7.0",
     "pkgroll": "^2.5.1",
+    "prool": "^0.0.16",
     "ts-jest": "^29.2.5",
     "ts-node": "^10.9.2",
     "tsx": "^4.19.2",