Integrate nonce test

package.json

@@ -15,7 +15,7 @@
     "format": "prettier --parser typescript --ignore-path .gitignore --write '**/*.{js,jsx,ts,tsx}'",
     "type-check": "tsc --noEmit",
     "check-nonce": "npm run build && node dist/helpers/scripts/checkNonceTracking.js",
-    "mocha": "mocha --config=tests/.mocharc.json --node-env=test --exit",
+    "mocha": "mocha --config=tests/.mocharc.json --node-env=test --timeout 10000 --exit",
     "test": "npm run lint && npm run test:unit:cover && npm run test:integration:cover",
     "test:unit": "npm run mocha -- 'tests/unit/**/*.test.ts'",
     "test:unit:storage": "npm run mocha -- 'tests/unit/storage.test.ts'",

tests/data/nonceSchema.ts

@@ -0,0 +1,10 @@
+import { TypesenseCollectionCreateSchema } from '../../src/@types'
+
+export const nonceSchema: TypesenseCollectionCreateSchema = {
+  name: 'nonce',
+  enable_nested_fields: true,
+  fields: [
+    { name: 'id', type: 'string' },
+    { name: 'nonce', type: 'int64', sort: true } // store nonce as string
+  ]
+}

tests/integration/database.test.ts

@@ -6,7 +6,7 @@ describe('Database', () => {
 
   before(async () => {
     const dbConfig = {
-      url: 'http://localhost:8108/?apiKey=xyz'
+      url: 'http://172.15.0.6:8108/?apiKey=xyz'
     }
     database = await new Database(dbConfig)
   })
@@ -43,7 +43,7 @@ describe('DdoDatabase CRUD', () => {
 
   before(async () => {
     const dbConfig = {
-      url: 'http://localhost:8108/?apiKey=xyz'
+      url: 'http://172.15.0.6:8108/?apiKey=xyz'
     }
     database = await new Database(dbConfig)
   })
@@ -79,7 +79,7 @@ describe('NonceDatabase CRUD', () => {
 
   before(async () => {
     const dbConfig = {
-      url: 'http://localhost:8108/?apiKey=xyz'
+      url: 'http://172.15.0.6:8108/?apiKey=xyz'
     }
     database = await new Database(dbConfig)
   })
@@ -114,7 +114,7 @@ describe('IndexerDatabase CRUD', () => {
 
   before(async () => {
     const dbConfig = {
-      url: 'http://localhost:8108/?apiKey=xyz'
+      url: 'http://172.15.0.6:8108/?apiKey=xyz'
     }
     database = await new Database(dbConfig)
   })

tests/integration/indexer.test.ts

@@ -43,7 +43,7 @@ describe('Indexer stores a new published DDO', () => {
 
   before(async () => {
     const dbConfig = {
-      url: 'http://localhost:8108/?apiKey=xyz'
+      url: 'http://172.15.0.6:8108/?apiKey=xyz'
     }
     database = await new Database(dbConfig)
     indexer = new OceanIndexer(database, mockSupportedNetworks)

tests/integration/nonce.test.ts

@@ -0,0 +1,68 @@
+import { expect } from 'chai'
+import { ethers } from 'ethers'
+import { nonceSchema } from '../data/nonceSchema.js'
+import {
+  Typesense,
+  convertTypesenseConfig
+} from '../../src/components/database/typesense'
+
+describe('handle nonce', () => {
+  let typesense: Typesense
+
+  before(() => {
+    const url = 'http://172.15.0.6:8108/?apiKey=xyz'
+    typesense = new Typesense(convertTypesenseConfig(url))
+  })
+
+  it('instance Typesense', async () => {
+    expect(typesense).to.be.instanceOf(Typesense)
+  })
+
+  it('create nonce collection', async () => {
+    let result
+    try {
+      result = await typesense.collections(nonceSchema.name).retrieve()
+    } catch (error) {
+      result = await typesense.collections().create(nonceSchema)
+    }
+    expect(result.enable_nested_fields).to.equal(true)
+    expect(result.fields).to.not.be.an('undefined')
+    expect(result.name).to.be.equal(nonceSchema.name)
+    expect(result.num_documents).to.equal(0)
+  })
+
+  it('should validate signature', async () => {
+    try {
+      await typesense
+        .collections(nonceSchema.name)
+        .documents()
+        .retrieve('0x4cc9DBfc4bEeA8c986c61DAABB350C2eC55e29d1')
+      console.log('document in checkDocumentExists: ', document)
+      // if not, create it now
+    } catch (ex) {
+      await typesense.collections(nonceSchema.name).documents().create({
+        id: '0x4cc9DBfc4bEeA8c986c61DAABB350C2eC55e29d1',
+        nonce: 1
+      })
+    }
+    const wallet = new ethers.Wallet(
+      '0xbee525d70c715bee6ca15ea5113e544d13cc1bb2817e07113d0af7755ddb6391'
+    )
+    // message to sign
+    const nonce = '1'
+    const expectedAddress = await wallet.getAddress()
+    // '0x8F292046bb73595A978F4e7A131b4EBd03A15e8a'
+    // sign message/nonce
+    const signature = await wallet.signMessage(nonce)
+    const actualAddress = ethers.verifyMessage(nonce, signature)
+    expect(actualAddress).to.be.equal(expectedAddress)
+  })
+
+  it('should get nonce (1)', async () => {
+    const document = await typesense
+      .collections('nonce')
+      .documents()
+      .retrieve('0x4cc9DBfc4bEeA8c986c61DAABB350C2eC55e29d1')
+    expect(document.nonce).to.be.equal(1)
+  })
+})

tests/integration/typesense.test.ts

@@ -11,7 +11,7 @@ describe('Typesense', () => {
   let typesense: Typesense
 
   before(() => {
-    const url = 'http://localhost:8108/?apiKey=xyz'
+    const url = 'http://172.15.0.6:8108/?apiKey=xyz'
     typesense = new Typesense(convertTypesenseConfig(url))
   })
 
@@ -29,7 +29,7 @@ describe('Typesense collections', () => {
   let typesense: Typesense
 
   before(() => {
-    const url = 'http://localhost:8108/?apiKey=xyz'
+    const url = 'http://172.15.0.6:8108/?apiKey=xyz'
     typesense = new Typesense(convertTypesenseConfig(url))
   })
 
@@ -79,7 +79,7 @@ describe('Typesense documents', () => {
   let typesense: Typesense
 
   before(() => {
-    const url = 'http://localhost:8108/?apiKey=xyz'
+    const url = 'http://172.15.0.6:8108/?apiKey=xyz'
     typesense = new Typesense(convertTypesenseConfig(url))
   })
 
@@ -143,7 +143,7 @@ describe('Typesense documents', () => {
   let typesense: Typesense
 
   before(() => {
-    const url = 'http://localhost:8108/?apiKey=xyz'
+    const url = 'http://172.15.0.6:8108/?apiKey=xyz'
     typesense = new Typesense(convertTypesenseConfig(url))
   })