Merge pull request #2 from codenotary/feat/update_schema

Feat/update schema

Author: Hextar

.env

@@ -0,0 +1,6 @@
+IMMUDB_DEV_PATH=/path/to/immudb/repo
+IMMUDB_HOST=127.0.0.1
+IMMUDB_PORT=3322
+IMMUDB_TEST_PORT=56789
+IMMUDB_USER=immudb
+IMMUDB_PWD=immudb

.gitignore

@@ -4,3 +4,4 @@ root.json
 test/immudb
 .nyc_output
 test/root.json
+.vscode

README.md

@@ -171,17 +171,15 @@ Atomic multi-key write (all entries are persisted or none):
 
 ```
   req = {
-    skvList: [{
+    keys: [{
       key: 'key1',
-      payload: 'value1',
-      timestamp: Math.floor(Date.now()/100),
+      payload: 'value1'
     },{
       key: 'key2',
-      payload: 'value2',
-      timestamp: Math.floor(Date.now()/100),
+      payload: 'value2'
     }]
   }
-  res = await cl.setBatchSV(req)
+  res = await cl.setBatch(req)
 ```
 
 Atomic multi-key read (all entries are retrieved or none):
@@ -193,7 +191,7 @@ Atomic multi-key read (all entries are retrieved or none):
         key: 'key2',
       }],
     }
-    res = await cl.getBatchSV(req)
+    res = await cl.getBatch(req)
 ```
 
 ### Closing the client

examples/.env

@@ -0,0 +1,4 @@
+IMMUDB_HOST=127.0.0.1
+IMMUDB_PORT=3322
+IMMUDB_USER=immudb
+IMMUDB_PWD=immudb

examples/auth-management.js

@@ -1,27 +1,46 @@
+/*
+Copyright 2019-2020 vChain, Inc.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+	http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+const dotenv = require('dotenv').config()
 const ImmudbClient = require("../lib/client")
 const types = require('../lib/types')
 
+const IMMUDB_HOST = process.env.IMMUDB_HOST || '127.0.0.1'
+const IMMUDB_PORT = process.env.IMMUDB_PORT || 3322
+const IMMUDB_USER = process.env.IMMUDB_USER || 'immudb'
+const IMMUDB_PWD = process.env.IMMUDB_PWD || 'immudb'
+
 ImmudbClient({
-  address: '127.0.0.1:3322',
+  address: `${IMMUDB_HOST}:${IMMUDB_PORT}`,
 }, main)
 
-const rand = '' + Math.floor(Math.random()
-  * Math.floor(100000))
- 
 async function main(err, cl) {
   if (err) {
     return console.log(err)
   }
 
   try {
-    let req = { username: 'immudb', password: 'immudb' }
+    let req = { username: IMMUDB_USER, password: IMMUDB_PWD }
     let res = await cl.login(req)
 
     res = await cl.useDatabase({ database: 'defaultdb' })
+    console.log('success: useDatabase:', res)
 
-    await cl.updateAuthConfig({ auth: types.auth.enabled })
+    res = await cl.updateAuthConfig({ auth: types.auth.enabled })
+    console.log('success: updateAuthConfig')
 
-    await cl.updateMTLSConfig({ enabled: false })
+    res = await cl.updateMTLSConfig({ enabled: false })
+    console.log('success: updateMTLSConfig')
 
   } catch (err) {
     console.log(err)

examples/batch-operations.js

@@ -0,0 +1,55 @@
+const ImmudbClient = require('../lib/client')
+
+const IMMUDB_HOST = process.env.IMMUDB_HOST || '127.0.0.1'
+const IMMUDB_PORT = process.env.IMMUDB_PORT || 3322
+const IMMUDB_USER = process.env.IMMUDB_USER || 'immudb'
+const IMMUDB_PWD = process.env.IMMUDB_PWD || 'immudb'
+
+ImmudbClient({
+    address: `${IMMUDB_HOST}:${IMMUDB_PORT}`,
+  }, main)
+
+const rand = '' + Math.floor(Math.random()
+  * Math.floor(100000))
+ 
+async function main(err, cl) {
+  if (err) {
+    return console.log(err)
+  }
+
+  try {
+    // login using the specified username and password
+    let req = { username: IMMUDB_USER, password: IMMUDB_PWD }
+    let res = await cl.login(req)
+    console.log('success: login', res)
+
+    // create database
+    req = { database: rand }
+    res = await cl.createDatabase(req)
+    console.log('success: createDatabase', res)
+
+    // use database just created
+    req = { database: rand }
+    res = await cl.useDatabase(req)
+    console.log('success: useDatabase', res)
+    
+    // execute a batch insert
+    req = { keys: [] }
+    for (let i = 0; i < 20; i++) {
+      req.keys.push({ key: i, value: i })
+    }
+    res = await cl.setBatch(req)
+    console.log(`success: setBatch`, res)
+
+    // execute a batch read
+    req = { keys: [] }
+    for (let i = 0; i < 20; i++) {
+      req.keys.push({ key: i })
+    }
+    res = await cl.getBatch(req)
+    console.log(`success: getBatch`, res)
+ 
+  } catch (err) {
+    console.log(err)
+  }
+}

examples/database-management.js

@@ -1,10 +1,28 @@
+/*
+Copyright 2019-2020 vChain, Inc.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+	http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+const dotenv = require('dotenv').config()
 const util = require('util')
-
 const ImmudbClient = require('../lib/client')
 
+const IMMUDB_HOST = process.env.IMMUDB_HOST || '127.0.0.1'
+const IMMUDB_PORT = process.env.IMMUDB_PORT || 3322
+const IMMUDB_USER = process.env.IMMUDB_USER || 'immudb'
+const IMMUDB_PWD = process.env.IMMUDB_PWD || 'immudb'
+
 ImmudbClient({
-  address: '127.0.0.1:3322',
-}, main)
+    address: `${IMMUDB_HOST}:${IMMUDB_PORT}`,
+  }, main)
 
 const rand = '' + Math.floor(Math.random()
   * Math.floor(100000))
@@ -15,21 +33,27 @@ async function main(err, cl) {
   }
 
   try {
-    let req = { username: 'immudb', password: 'immudb' }
+    let req = { username: IMMUDB_USER, password: IMMUDB_PWD }
     let res = await cl.login(req)
 
     await cl.createDatabase({ database: rand })
+    console.log('success: createDatabase', res);
 
     res = await cl.useDatabase({ database: rand })
+    console.log('success: useDatabase', res);
 
     res = await cl.set({ key: rand, value: rand })
 
     res = await cl.listDatabases()
+    console.log('success: listDatabases', res);
+
     console.log(util.inspect(res, false, 8, true))
 
     res = await cl.printTree()
+    console.log('success: printTree', res);
 
     res = await cl.health()
+    console.log('success: health', res);
 
   } catch (err) {
     console.log(err)