fix typing issues

Author: github1

package.json

@@ -1,6 +1,6 @@
 {
   "name": "meshage",
-  "version": "0.4.5",
+  "version": "0.4.6",
   "description": "A simple service mesh. Messages sent within the service mesh can be consistently partitioned across members of the cluster.",
   "main": "./index.js",
   "types": "./index.d.ts",

src/backends/nats/docker-test-helper.ts

@@ -1,76 +1,97 @@
 // tslint:disable:typedef no-implicit-dependencies no-any
-import {Docker} from 'node-docker-api';
+import { Docker } from 'node-docker-api';
 // tslint:disable-next-line:no-submodule-imports
-import {execSync} from 'child_process';
+import { execSync } from 'child_process';
 import * as getPort from 'get-port';
 
 const testIdCounter = {};
 const testContainers = {};
 const testContainerPorts = {};
 let fetchedImage = false;
 
-const docker : Docker = new Docker(process.env.CI === 'true'
-  ? {protocol: 'http', host: 'localhost', port: '2375'}
-  : {socketPath: '/var/run/docker.sock'});
+const docker: Docker = new Docker(
+  process.env.CI === 'true'
+    ? { protocol: 'http', host: 'localhost', port: '2375' }
+    : { socketPath: '/var/run/docker.sock' }
+);
 
-function promisifyStream(stream) {
+function promisifyStream(stream: NodeJS.ReadableStream) {
   return new Promise((resolve, reject) => {
-    stream.on('data', (d) => console.log(d.toString()));
+    stream.on('data', (d: Buffer) => console.log(d.toString()));
     stream.on('end', resolve);
     stream.on('error', reject);
   });
 }
 
-export function stopContainersByName(...names : string[]) {
+export function stopContainersByName(...names: string[]) {
   for (const name of names) {
-    execSync(`bash -c "docker ps | grep ${name} | awk '{print \\$1}' | xargs -I{} docker stop {}"`);
-    execSync(`bash -c "docker ps -a | grep ${name} | awk '{print \\$1}' | xargs -I{} docker rm {}"`);
+    execSync(
+      `bash -c "docker ps | grep ${name} | awk '{print \\$1}' | xargs -I{} docker stop {}"`
+    );
+    execSync(
+      `bash -c "docker ps -a | grep ${name} | awk '{print \\$1}' | xargs -I{} docker rm {}"`
+    );
   }
 }
 
 // tslint:disable-next-line:no-any
-export async function startContainer(testId : string, image : string, tag : string, ...ports : string[]) : Promise<any> {
-  testIdCounter[testId] = (testIdCounter[testId] || 0);
+export async function startContainer(
+  testId: string,
+  image: string,
+  tag: string,
+  ...ports: string[]
+): Promise<any> {
+  testIdCounter[testId] = testIdCounter[testId] || 0;
   testIdCounter[testId]++;
-  const containerName = ['jest-test-container', image, tag, testId, testIdCounter[testId]].join('-')
+  const containerName = [
+    'jest-test-container',
+    image,
+    tag,
+    testId,
+    testIdCounter[testId],
+  ]
+    .join('-')
     .replace(/[^a-z0-9]+/g, '-');
   testContainers[testId] = testContainers[testId] || [];
   testContainers[testId].push(containerName);
   testContainerPorts[containerName] = testContainerPorts[containerName] || {};
-  let container = await docker.container.get(containerName);
+  let container = docker.container.get(containerName);
   try {
     const containerStatus = await container.status();
     console.log('Found existing container', containerStatus);
-    await stopContainersByName(testId);
+    stopContainersByName(testId);
   } catch (err) {
     // ignore
   }
   if (!fetchedImage) {
     fetchedImage = true;
-    await docker.image.create({}, {fromImage: image, tag: tag})
+    await docker.image
+      .create({}, { fromImage: image, tag: tag })
       .then(promisifyStream)
-      .then(() => docker.image.get(`${image}:${tag}`)
-        .status());
+      .then(() => docker.image.get(`${image}:${tag}`).status());
   }
   const createOpts = {
     Image: `${image}:${tag}`,
     name: containerName,
-    PortBindings: {}
+    PortBindings: {},
   };
   for (const portDef of ports) {
     const parts = portDef.split('/');
     const hostPort = await getPort();
-    createOpts.PortBindings[`${parts[0]}/${parts[1] || 'tcp'}`] = [{HostPort: `${hostPort}`}];
+    createOpts.PortBindings[`${parts[0]}/${parts[1] || 'tcp'}`] = [
+      { HostPort: `${hostPort}` },
+    ];
     testContainerPorts[containerName][parts[0]] = hostPort;
   }
   container = await docker.container.create(createOpts);
   await container.start();
-  await new Promise((resolve) => setTimeout(resolve, 1000));
+  await new Promise<void>((resolve) => setTimeout(resolve, 1000));
   try {
-    await container.logs({
-      stdout: true,
-      stderr: true
-    })
+    await container
+      .logs({
+        stdout: true,
+        stderr: true,
+      })
       .then(promisifyStream);
   } catch (err) {
     // ignore