Migrate to Neo4j

.eslintrc.json

@@ -27,6 +27,7 @@
         ],
         "@typescript-eslint/explicit-module-boundary-types": 0,
         "@typescript-eslint/no-explicit-any": 0,
-        "@typescript-eslint/no-unused-vars": ["warn", { "argsIgnorePattern": "^_" }]
+        "@typescript-eslint/no-unused-vars": ["warn", { "argsIgnorePattern": "^_" }],
+        "@typescript-eslint/no-namespace": "off"
     }
 }

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 *.swp
 dist
+.vscode

README.md

@@ -1057,4 +1057,35 @@ We recommend querying using payment key hashes (`addr_vkh`) when possible (other
     ]
   }
   ```
+</details>
+
+</details>
+
+<details>
+  <summary> POST /v2.1/lastBlockBySlot</summary>
+
+Resolve the latest block created at a slot equal to or lower than a given slot.
+
+#### Request
+
+The field slots are required to be a non-empty array. Each entry is a tuple of two numbers: epoch and slot.
+
+```ts
+type SlotNo = number;
+type EpochNo = number;
+type Request = {
+  slots: Array<[EpochNo, SlotNo]>;
+};
+```
+
+#### Response
+
+```ts
+type Slot = [EpochNo, SlotNo];
+type Response = {
+  blockHashes: {
+    [key: Slot]: string | null;
+  };
+};
+```
 </details>

config/default.ts

@@ -39,5 +39,11 @@ export default {
       accessKeyId: process.env.PRICE_DATA_S3_ACCESS_KEY_ID,
       secretAccessKey: process.env.PRICE_DATA_S3_SECRET_ACCESS_KEY,
     },
+  },
+  network: process.env.NETWORK || "mainnet",
+  neo4j: {
+    url: process.env.NEO4J_URL || "neo4j://dus-01.emurgo-rnd.com:7687",
+    username: process.env.NEO4J_USERNAME || "neo4j",
+    password: process.env.NEO4J_PASSWORD || "neo4j"
   }
 };

package.json

@@ -11,7 +11,8 @@
     "dev": "tsc-watch --onSuccess \"node ./dist/index.js\"",
     "eslint": "eslint src tests",
     "test": "mocha -r ts-node/register tests/**/*.test.ts --slow 0",
-    "testtxhist": "mocha -r ts-node/register tests/txHistory.test.ts",
+    "test:file": "mocha -r ts-node/register",
+    "testtxhist": "npm run test:file -- tests/txHistory.test.ts",
     "prettier": "npx prettier --write src"
   },
   "author": "",
@@ -38,6 +39,7 @@
     "hash-wasm": "^4.9.0",
     "lodash": "^4.17.21",
     "mocha": "^10.0.0",
+    "neo4j-driver": "^5.7.0",
     "pg": "^8.8.0",
     "pm2": "^5.2.0",
     "semver-compare": "^1.0.0",

src/coin-price/sign.test.ts

@@ -5,6 +5,7 @@ import {
   PublicKey,
 } from "@emurgo/cardano-serialization-lib-nodejs";
 import { serializeTicker, sign, verify } from "./sign";
+import { createCslContext } from "../utils/csl";
 
 const TICKER = {
   from: "ADA",
@@ -18,18 +19,22 @@ const PUBLIC_KEY =
   "4711516aac6adccd06054939c45e2487df239ba86cc277ae56aaac0a83f0bf96";
 
 it("sign and verify a ticker", () => {
+  const ctx = createCslContext();
+
   const signature = sign(
     TICKER,
     serializeTicker,
-    PrivateKey.from_extended_bytes(Buffer.from(PRIVATE_KEY, "hex"))
+    ctx.wrap(PrivateKey.from_extended_bytes(Buffer.from(PRIVATE_KEY, "hex"))),
+    ctx
   );
 
   expect(
     verify(
       TICKER,
       serializeTicker,
       signature,
-      PublicKey.from_bytes(Buffer.from(PUBLIC_KEY, "hex"))
+      ctx.wrap(PublicKey.from_bytes(Buffer.from(PUBLIC_KEY, "hex"))),
+      ctx
     )
   ).to.equal(true);
 
@@ -39,7 +44,10 @@ it("sign and verify a ticker", () => {
       TICKER,
       serializeTicker,
       invalidSig,
-      PublicKey.from_bytes(Buffer.from(PUBLIC_KEY, "hex"))
+      ctx.wrap(PublicKey.from_bytes(Buffer.from(PUBLIC_KEY, "hex"))),
+      ctx
     )
   ).to.equal(false);
+
+  ctx.freeAll();
 });

src/coin-price/sign.ts

@@ -1,4 +1,5 @@
 import CardanoWasm from "@emurgo/cardano-serialization-lib-nodejs";
+import { CslContext } from "../utils/csl";
 import type { Ticker } from "./types";
 
 export function serializeTicker(ticker: Ticker): Buffer {
@@ -16,19 +17,21 @@ export function serializeTicker(ticker: Ticker): Buffer {
 export function sign(
   obj: any,
   serializer: (arg0: any) => Buffer,
-  privateKey: CardanoWasm.PrivateKey
+  privateKey: CardanoWasm.PrivateKey,
+  ctx: CslContext
 ): string {
-  return privateKey.sign(serializer(obj)).to_hex();
+  return ctx.wrap(privateKey.sign(serializer(obj))).to_hex();
 }
 
 export function verify(
   obj: any,
   serializer: (arg0: any) => Buffer,
   signatureHex: string,
-  publicKey: CardanoWasm.PublicKey
+  publicKey: CardanoWasm.PublicKey,
+  ctx: CslContext
 ): boolean {
   return publicKey.verify(
     serializer(obj),
-    CardanoWasm.Ed25519Signature.from_bytes(Buffer.from(signatureHex, "hex"))
+    ctx.wrap(CardanoWasm.Ed25519Signature.from_bytes(Buffer.from(signatureHex, "hex")))
   );
 }