chore: add ttl example code

Author: DavidVujic

examples/addtask.js

@@ -1,10 +1,10 @@
 const { constants } = require('./wrapper.js');
 const notifier = require('./notifier.js');
-const { createNode, persistentNode } = require('./createnode.js');
+const { createNode } = require('./createnode.js');
 
 async function createTask(client, data) {
     // eslint-disable-next-line no-bitwise
-    const message = await createNode(client, '/tasks/task-', persistentNode | constants.ZOO_SEQUENCE, data);
+    const message = await createNode(client, '/tasks/task-', constants.ZOO_PERSISTENT | constants.ZOO_PERSISTENT_SEQUENTIAL, data);
     notifier.emit('addTask', message);
 }
 

examples/createnode.js

@@ -1,21 +1,20 @@
 const { isClientConnected } = require('./wrapper.js');
 
-const persistentNode = 0;
-
 /**
  * @param client {ZooKeeperPromise}
  * @param path {string}
  * @param flags {number}
  * @param data {string|Buffer}
  * @returns {Promise}
  */
-async function createNode(client, path, flags, data = '') {
+async function createNode(client, path, flags, ttl, data = '') {
     try {
         if (!isClientConnected()) {
             throw new Error('createNode: client is not connected');
         }
 
-        const createdPath = await client.create(path, data, flags);
+        const createdPath = await client.create(path, data, flags, ttl);
+
         return `(created: ${createdPath})`;
     } catch (error) {
         return `${path} Error: ${error.message}`;
@@ -24,5 +23,4 @@ async function createNode(client, path, flags, data = '') {
 
 module.exports = {
     createNode,
-    persistentNode,
 };

examples/index.js

@@ -1,4 +1,4 @@
-const { getClient } = require('./wrapper.js');
+const { getClient, constants } = require('./wrapper.js');
 const { createNodes } = require('./setup.js');
 const { electLeader } = require('./electleader.js');
 const { createWorker } = require('./createworker.js');
@@ -22,7 +22,8 @@ async function init() {
     const client = getClient();
 
     client.on('connect', async () => {
-        await createNodes(client, ['/workers', '/assign', '/tasks', '/status']);
+        await createNodes(client, ['/workers', '/assign', '/tasks', '/status'], constants.ZOO_CONTAINER);
+        await createNodes(client, ['/myttl'], constants.ZOO_PERSISTENT_WITH_TTL, 5000);
 
         notifier.on('leader', async () => {
             await listen(client, '/workers');

examples/setup.js

@@ -1,10 +1,10 @@
 const notifier = require('./notifier.js');
-const { createNode, persistentNode } = require('./createnode.js');
+const { createNode } = require('./createnode.js');
 
-async function createAllNodes(client, paths) {
+async function createAllNodes(client, paths, flags, ttl) {
     const promises = [];
     paths.forEach((path) => {
-        promises.push(createNode(client, path, persistentNode));
+        promises.push(createNode(client, path, flags, ttl));
     });
 
     const messages = await Promise.all(promises);
@@ -13,8 +13,8 @@ async function createAllNodes(client, paths) {
     });
 }
 
-async function createNodes(client, paths) {
-    createAllNodes(client, paths);
+async function createNodes(client, paths, flags, ttl = undefined) {
+    createAllNodes(client, paths, flags, ttl);
 }
 
 module.exports = {