fix: do not use deprecated features

Author: DavidVujic

examples/addtask.js

@@ -2,18 +2,21 @@ const { createClient, ZooKeeper } = require('./wrapper.js');
 const notifier = require('./notifier.js');
 const { createNode, persistentNode } = require('./createnode.js');
 
-const noop = () => {};
+async function createTask(client, data) {
+    // eslint-disable-next-line no-bitwise
+    const message = await createNode(client, '/tasks/task-', persistentNode | ZooKeeper.ZOO_SEQUENCE, data);
+    notifier.emit('addTask', message);
+}
 
 async function addTask(data) {
     const client = createClient();
-    client.connect({}, noop);
 
-    await client.on_connected();
-    notifier.emit('connect', `addTask: session established, id=${client.client_id}`);
+    client.on('connect', () => {
+        notifier.emit('connect', `addTask: session established, id=${client.client_id}`);
 
-    // eslint-disable-next-line no-bitwise
-    const message = await createNode(client, '/tasks/task-', persistentNode | ZooKeeper.ZOO_SEQUENCE, data);
-    notifier.emit('addTask', message);
+        createTask(client, data);
+    });
+    client.init({});
 }
 
 module.exports = {

examples/createworker.js

@@ -2,29 +2,32 @@ const { createClient, ZooKeeper } = require('./wrapper.js');
 const notifier = require('./notifier.js');
 const logger = require('./logger.js');
 
-const noop = () => {};
-
 function emit(client, path) {
     logger.log(`(${path}) client id: ${client.client_id}`);
     notifier.emit('createWorker', client);
 }
 
-async function createWorker() {
-    const client = createClient();
-    client.connect({}, noop);
-
-    client.on_connected();
-    notifier.emit('connect', `createWorker: session established, id=${client.client_id}`);
-
+async function createWorkerPath(client, path) {
     try {
         // eslint-disable-next-line no-bitwise
-        const path = await client.create('/workers/worker-', '', ZooKeeper.ZOO_EPHEMERAL | ZooKeeper.ZOO_SEQUENCE);
-        emit(client, path);
+        const createdPath = await client.create(path, '', ZooKeeper.ZOO_EPHEMERAL | ZooKeeper.ZOO_SEQUENCE);
+        emit(client, createdPath);
     } catch (error) {
         logger.error(error);
     }
 }
 
+async function createWorker() {
+    const client = createClient();
+
+    client.on('connect', () => {
+        notifier.emit('connect', `createWorker: session established, id=${client.client_id}`);
+        createWorkerPath(client, '/workers/worker-');
+    });
+
+    client.init({});
+}
+
 module.exports = {
     createWorker,
 };

examples/electleader.js

@@ -47,12 +47,13 @@ async function runForLeader(client, path) {
 
 async function electLeader(path) {
     const client = createClient();
-    client.connect({}, () => {});
 
-    await client.on_connected();
+    client.on('connect', () => {
+        notifier.emit('connect', `electLeader: session established, id=${client.client_id}`);
+        runForLeader(client, path);
+    });
 
-    notifier.emit('connect', `electLeader: session established, id=${client.client_id}`);
-    await runForLeader(client, path);
+    client.init({});
 }
 
 module.exports = {