feat(extension-driver-ksqldb): adjust the dockerode container volume path

Author: andreashimin

packages/extension-driver-ksqldb/src/lib/restfulClient.ts

@@ -111,13 +111,9 @@ export class RestfulClient {
   }
 
   public async checkConnectionRunning(): Promise<boolean> {
-    try {
-      const status = await this.checkConnection();
-      const isRunning = status === 'RUNNING';
-      return isRunning;
-    } catch (e) {
-      return false;
-    }
+    const status = await this.checkConnection();
+    const isRunning = status === 'RUNNING';
+    return isRunning;
   }
 
   public async query({

packages/extension-driver-ksqldb/test/docker/compose.ts

@@ -74,7 +74,7 @@ export class Compose {
 
   private convertContainerConfig(service: ComposeConfig, network: string) {
     // dockerode does not support relative paths in container volumes
-    const Binds = (service['volumes'] || []).map((volume) => volume.replace('./', ''));
+    const Binds = (service['volumes'] || []).map((volume) => volume.replace('./', `${__dirname}/`));
     return {
       Image: service['image'],
       name: service['hostname'],

packages/extension-driver-ksqldb/test/ksqlDbServer.ts

@@ -93,7 +93,6 @@ export class KSqlDbServer {
 
   public async destroy() {
     await compose.down();
-    await BPromise.delay(60 * 1000);
   }
 
   public getProfile(name: string) {
@@ -111,7 +110,7 @@ export class KSqlDbServer {
 
   private async waitKSqlDbReady(client: RestfulClient): Promise<void> {
     // start to check connect after 1 minute
-    await BPromise.delay(60 * 1000);
+    // await BPromise.delay(60 * 1000);
     console.log(
       'Start to check ksqldb connection: ',
       `http://${this.host}:${this.port}`