rooch: add alby API and sqlite support.

Author: ghpZ54K8ZRwU62zGVSePPs97yAv9swuAY0mVDR4

.env.sample

@@ -18,11 +18,19 @@ POSTGRES_PASSWORD=xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\
 # Prisma postgres config
 DATABASE_URL="postgresql://${POSTGRES_USER}:${POSTGRES_PASSWORD}@postgres_db:5432/${POSTGRES_DB}"
 
+# Sqlite config
+SQLITE_PATH=sqlite.db
+
+# Prisma sqlite config
+DATABASE_URL_DEV="file:${SQLITE_PATH}"
+
 # Optionals
 SENTRY_DSN=""
 ECDSA_PRIVATE_KEY="" # for verity analysis.
 
 # Integrations
 X_BEARER_TOKEN=""
 
-OPEN_AI_TOKEN=""
+OPEN_AI_TOKEN=""
+
+ALBY_ACCESS_TOKEN=""

.gitignore

@@ -126,12 +126,11 @@ temp*
 
 # else
 .script
+deno.lock
 
 # Prisma
-prisma/.db
-prisma/.db*
-orchestrator/prisma/.db
-orchestrator/prisma/.db*
+orchestrator/prisma-dev/*.db
+orchestrator/prisma-dev/*.db*
 .infisical.json
 .aptos
 migration_lock.toml

docs/ROOCH.md

@@ -13,14 +13,22 @@ Before running the script, ensure you have the following prerequisites installed
 
 ### Step-by-Step Instructions
 
-#### Step 1: Create a Roach Account
+#### Step 1: Create a Rooch Account
 
-First, you need to create a Roach account. This account will be used throughout the setup process.
+First, you need to have `rooch` binary in hand. The `rooch` binary can be downloaded from the [Rooch GitHub repo](https://github.com/rooch-network/rooch). Use the `rooch` binary to create a Rooch account. This account will be used throughout the setup process.
+
+```bash
+rooch init
+```
+
+or
 
 ```bash
 rooch account create
 ```
 
+if there already exists an account.
+
 #### Step 2: Clear and Start Local Network
 
 Clear any existing state and start the local network.
@@ -32,12 +40,11 @@ rooch server start
 
 #### Step 3: Deploy Contracts
 
-Navigate to the `rooch` directory, build the contracts for development, publish them with named addresses and update `.env` `ROOCH_ORACLE_ADDRESS` with deployed Address
+Navigate to this repo's [rooch](../rooch) directory, build the contracts for development, and publish them with named addresses and update `.env` `ROOCH_ORACLE_ADDRESS` with deployed Address
 
 ```bash
 cd rooch
-rooch move build --dev
-rooch move publish --named-addresses verity=default --sender default
+rooch move publish --named-addresses verity=default,verity_test_foreign_module=default --sender default
 cd ..
 ```
 
@@ -72,7 +79,7 @@ pnpm prisma:deploy
 **In Development (for SQLite):**
 
 ```bash
-pnpm clean:db
+pnpm clean:db:dev
 pnpm prisma:generate:dev
 pnpm prisma:deploy:dev
 ```
@@ -82,19 +89,18 @@ pnpm prisma:deploy:dev
 Copy the example environment file to create your own `.env` file:
 
 ```bash
-cp .env.example .env
+cp .env.sample .env
 ```
 
 Export the Rooch Private Key:
 
 ```bash
 rooch account export --address <Rooch Address>
-
 ```
 
 
-To connect to the local Rooch node, set `ROOCH_CHAIN_ID` to `"localnet"`.  
-Otherwise, connect to testNet by setting `ROOCH_CHAIN_ID` to `"testnet"`, or to TestNet by setting `ROOCH_CHAIN_ID` to `"testnet"`.  
+To connect to the local Rooch node, set `ROOCH_CHAIN_ID` to `"localnet"`.
+Otherwise, connect to DevNet by setting `ROOCH_CHAIN_ID` to `"devnet"`, or to TestNet by setting `ROOCH_CHAIN_ID` to `"testnet"`.
 Ensure that `ROOCH_ORACLE_ADDRESS` is set to the address of the deployed module, e.g., `"0x85859e45551846d9ab8651bb0b6f6e1740c9d758cfda05cfc39d49e2a604d783"`.
 
 #### Step 7: Register supported URL
@@ -103,19 +109,19 @@ Additional steps for managing supported orchestrator URL
 - To add URL
 
 ```bash
-rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::registry::add_supported_url --sender-account 0x694cbe655b126e9e6a997e86aaab39e538abf30a8c78669ce23a98740b47b65d --args 'string:https://api.openai.com/v1/chat/completions' --args 'u256:50000' --args 'u64:40' --args 'u256:4000' --args 'u256:5000' 
+rooch move run --function <contract_address>::registry::add_supported_url --sender-account <orchestrator_address> --args 'string:https://api.openai.com/v1/chat/completions' --args 'u256:50000' --args 'u64:40' --args 'u256:4000' --args 'u256:5000'
 ```
 
 - to remove URLs
 
 ```bash
-rooch move run --function  0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::registry::remove_supported_url --sender-account <orchestrator_address> --args 'string:https://api.twitter.com/2/users/'
+rooch move run --function  <contract_address>::registry::remove_supported_url --sender-account <orchestrator_address> --args 'string:https://api.openai.com/v1/chat/completions'
 ```
 
-- To view supported URLS
+- To view supported URLs
 
 ```bash
- rooch move view --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::registry::get_supported_urls  --args 'address:0x694cbe655b126e9e6a997e86aaab39e538abf30a8c78669ce23a98740b47b65d' 
+ rooch move view --function <contract_address>::registry::get_supported_urls  --args 'address:<orchestrator_address>'
 ```
 
 
@@ -144,7 +150,7 @@ Here's an example of requesting the Twitter Followers Count on a Local Rooch Nod
 ```bash
 rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::example_caller::request_data --sender-account default --args 'string:https://api.x.com/2/users/by/username/elonmusk?user.fields=public_metrics' --args 'string:GET' --args 'string:{}' --args 'string:{}' --args 'string:.data.public_metrics.followers_count' --args 'address:0x694cbe655b126e9e6a997e86aaab39e538abf30a8c78669ce23a98740b47b65d' --args 'u256:50000'
 ```
-or 
+or
 ```bash
 rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::example_caller::request_data --sender-account default --args 'string:https://api.openai.com/v1/chat/completions' --args 'string:POST' --args 'string:{}' --args 'string:{"model": "gpt-4o-mini", "messages": [{"role": "user", "content": "Say this is a test!"}],"temperature": 0.7}' --args 'string:.choices[].message.content' --args 'address:0x694cbe655b126e9e6a997e86aaab39e538abf30a8c78669ce23a98740b47b65d' --args 'u256:50000000'
 ```
@@ -155,28 +161,28 @@ rooch state -a /object/0x7a01ddf194f8a1c19212d56f747294352bf2e5cf23e6e10e64937aa
 ```
 
 
-Additionally, 
+Additionally,
 For notification calls you can allocated an portion form escrow for notification per fulfilment Request(Recommended 1Rgas for the first fulfilment).
 ```bash
 rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::update_notification_gas_allocation --sender-account default  --args 'address:0x27e46e033da11c4d1f986081877e80cefb2b29dec1c559c97c3ccf12e910aba7' --args 'string:example_caller::receive_data' --args 'u256:10000000'
 ```
 
 #### Step 10: Manage Escrow balance
 
-- To view balance 
+- To view balance
 
 ```bash
-rooch move view --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::get_user_balance  --args 'address:<your_address>' 
+rooch move view --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::get_user_balance  --args 'address:<your_address>'
 ```
 
 - To withdraw Balance
 ```bash
-rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::withdraw_from_escrow  --args 'u256:<amount>' 
+rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::withdraw_from_escrow  --args 'u256:<amount>'
 ```
 
-- To Deposit 
+- To Deposit
 ```bash
-rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::deposit_to_escrow  --args 'u256:<amount>' 
+rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::oracles::deposit_to_escrow  --args 'u256:<amount>'
 ```
 
 To confirm the `Request` Object State, use the Object ID generated from the initial transaction to query the state of the response object.
@@ -190,7 +196,7 @@ An example of requesting the Twitter Followers Count on a Rooch Testnet:
 rooch move run --function 0xf1290fb0e7e1de7e92e616209fb628970232e85c4c1a264858ff35092e1be231::example_caller::request_data --sender-account default --args 'string:https://api.x.com/2/users/by/username/elonmusk?user.fields=public_metrics' --args 'string:GET' --args 'string:{}' --args 'string:{}' --args 'string:.data.public_metrics.followers_count' --args 'address:0x694cbe655b126e9e6a997e86aaab39e538abf30a8c78669ce23a98740b47b65d'
 ```
 
-To check the state of the response object on testnet, devnet, or mainnet, 
+To check the state of the response object on testnet, devnet, or mainnet,
 
 1. Switch to the relevant network using `rooch env switch --alias <NETWORK_ALIAS>`
 2. Use the following command:

orchestrator/prisma-dev/index.ts

@@ -0,0 +1,4 @@
+import { PrismaClient } from "@prisma/client";
+
+const prismaClient = new PrismaClient();
+export default prismaClient;

orchestrator/prisma-dev/schema.prisma

@@ -0,0 +1,43 @@
+// This is your Prisma schema file,
+// learn more about it in the docs: https://pris.ly/d/prisma-schema
+
+generator client {
+  provider = "prisma-client-js"
+}
+
+datasource db {
+  provider = "sqlite"
+  url      = env("DATABASE_URL_DEV")
+}
+
+model Events{
+  id                        String @id @default(cuid())
+  eventHandleId             String
+  eventSeq                  BigInt
+  eventType                 String
+  eventData                 String
+  eventIndex                String
+  decoded_event_data        String  //JSON String
+  chain                     String   @default("ROOCH-testnet")
+
+  status                    Int
+  retries                   Int
+  response                  String?
+  indexedAt                 DateTime  @default(now())
+  updateAt                  DateTime  @updatedAt
+
+  @@index([eventHandleId, eventSeq,chain])
+}
+
+model Keeper{
+  id                        String    @id @default(cuid())
+  chain                     String    @default("ROOCH-testnet")
+  module                    String
+  privateKey                String
+
+  createdAt                 DateTime  @default(now())
+  updateAt                  DateTime  @updatedAt
+
+  @@unique([chain, module])
+
+}

orchestrator/src/env.ts

@@ -25,6 +25,7 @@ const baseConfig = {
   // Integrations
   xBearerToken: process.env.X_BEARER_TOKEN ?? "",
   openAIToken: process.env.OPEN_AI_TOKEN ?? "",
+  albyAccessToken: process.env.ALBY_ACCESS_TOKEN ?? "",
 };
 
 interface IEnvVars {
@@ -43,6 +44,7 @@ interface IEnvVars {
   batchSize: number;
   xBearerToken: string;
   openAIToken: string;
+  albyAccessToken: string;
 }
 
 const envVarsSchema = Joi.object({
@@ -93,6 +95,7 @@ const envVarsSchema = Joi.object({
   // Integrations
   xBearerToken: Joi.string().allow("").required(),
   openAIToken: Joi.string().allow("").required(),
+  albyAccessToken: Joi.string().allow("").required(),
 
   // Common
   sentryDSN: Joi.string().allow("", null),
@@ -117,6 +120,7 @@ export default {
   integrations: {
     xBearerToken: envVars.xBearerToken,
     openAIToken: envVars.openAIToken,
+    albyAccessToken: envVars.albyAccessToken,
   },
   rooch: {
     chainId: envVars.roochChainId,

orchestrator/src/indexer/base.ts

@@ -1,6 +1,7 @@
 import { log } from "@/logger";
 import { type ProcessedRequestAdded, RequestStatus } from "@/types";
 
+import { instance as albyInstance } from "@/integrations/alby";
 import { instance as openAIInstance } from "@/integrations/openAI";
 import { instance as xTwitterInstance } from "@/integrations/xtwitter";
 
@@ -50,6 +51,9 @@ export abstract class Indexer {
     if (openAIInstance.isApprovedPath(url)) {
       return openAIInstance;
     }
+    if (albyInstance.isApprovedPath(url)) {
+      return albyInstance;
+    }
     return null;
   }
 

orchestrator/src/indexer/rooch.ts

@@ -1,4 +1,5 @@
 import env from "@/env";
+import { instance as albyInstance } from "@/integrations/alby";
 import { instance as xTwitterInstance } from "@/integrations/xtwitter";
 import { log } from "@/logger";
 import type { IEvent, IRequestAdded, JsonRpcResponse, ProcessedRequestAdded, RoochNetwork } from "@/types";
@@ -115,6 +116,7 @@ export default class RoochIndexer extends Indexer {
     for (let i = 0; i < skippedRequests.length; i++) {
       try {
         await new Promise((resolve) => setTimeout(resolve, xTwitterInstance.getRequestRate));
+        await new Promise((resolve) => setTimeout(resolve, albyInstance.getRequestRate));
         const event = skippedRequests[i];
         const data = await this.processRequestAddedEvent(event);
         if (data) {

orchestrator/src/integrations/alby.ts

@@ -0,0 +1,15 @@
+import env from "@/env";
+import { BasicBearerAPIHandler } from "./base";
+
+export default class AlbyIntegration extends BasicBearerAPIHandler {
+  validatePayload(path: string): boolean {
+    return true;
+  }
+}
+
+export const instance = new AlbyIntegration(
+  env.integrations.albyAccessToken,
+  ["api.getalby.com"],
+  ["/nwc/nip47/info", "/nwc/nip47", "/nwc/publish", "/nwc/subscriptions", "/nwc/nip47/notifications", "/nwc/subscriptions/"],
+  60 * 1000,
+);

package.json

@@ -7,7 +7,14 @@
     "node": ">=18"
   },
   "type": "module",
-  "keywords": ["web3", "crypto", "blockchain", "move", "verity", "smart-contracts"],
+  "keywords": [
+    "web3",
+    "crypto",
+    "blockchain",
+    "move",
+    "verity",
+    "smart-contracts"
+  ],
   "author": "Ryan Soury <[email protected]>",
   "license": "LGPL-2.1",
   "bugs": {
@@ -21,14 +28,18 @@
     "lint": "biome check orchestrator/src/",
     "lint:fix": "biome check orchestrator/src/ --fix",
     "clean": "del dist",
-    "clean:db": "del ./orchestrator/prisma/.db*",
+    "clean:db": "del ./orchestrator/prisma/*.db*",
+    "clean:db:dev": "del ./orchestrator/prisma-dev/*.db*",
     "prepare": "husky",
     "format": "biome format orchestrator/src/ --fix",
     "sentry:sourcemaps": "sentry-cli sourcemaps inject --org usherlabs --project verity-move-oracles ./dist && sentry-cli sourcemaps upload --org usherlabs --project verity-move-oracles ./dist",
     "test": "jest --runInBand ",
     "prisma:generate": "prisma generate --schema=./orchestrator/prisma/schema.prisma",
+    "prisma:generate:dev": "prisma generate --schema=./orchestrator/prisma-dev/schema.prisma",
     "prisma:deploy": "prisma migrate deploy --schema=./orchestrator/prisma/schema.prisma",
-    "prisma:studio": "prisma studio --schema=./orchestrator/prisma/schema.prisma"
+    "prisma:deploy:dev": "prisma migrate deploy --schema=./orchestrator/prisma-dev/schema.prisma",
+    "prisma:studio": "prisma studio --schema=./orchestrator/prisma/schema.prisma",
+    "prisma:studio:dev": "prisma studio --schema=./orchestrator/prisma-dev/schema.prisma"
   },
   "devDependencies": {
     "@biomejs/biome": "^1.8.3",
@@ -65,13 +76,17 @@
     "tslog": "^4.9.3"
   },
   "lint-staged": {
-    "*.{js,ts,cjs,mjs,d.cts,d.mts,json,jsonc}": ["biome check --apply --no-errors-on-unmatched"]
+    "*.{js,ts,cjs,mjs,d.cts,d.mts,json,jsonc}": [
+      "biome check --apply --no-errors-on-unmatched"
+    ]
   },
   "prisma": {
     "schema": "orchestrator/prisma/schema.prisma"
   },
   "tsup": {
-    "entry": ["./orchestrator/src"],
+    "entry": [
+      "./orchestrator/src"
+    ],
     "splitting": false,
     "sourcemap": true,
     "clean": true