Integration test and intellisense comments added for createStreamAs method

Author: MichaelCSnyder

__tests__/integrationtests.js

@@ -9,9 +9,9 @@ server using the command 'docker compose-up'. This will spin up a ksqlDB server
 describe('--Integration Tests--', () => {
 
   describe('--Method Tests--', () => {
-    beforeAll((done) => {
+    beforeAll(async () => {
       client = new ksqljs({ ksqldbURL: 'http://localhost:8088' });
-      done();
+      await client.ksql('DROP STREAM IF EXISTS TESTJESTSTREAM DELETE TOPIC;');
     });
 
     afterAll(async () => {
@@ -75,7 +75,37 @@ describe('--Integration Tests--', () => {
       const expectData = data[0].slice(0, 3);
       expect(expectPullData).toEqual(expectData);
     })
+
+    describe('materialized streams utilizing createStreamAs', () => {
+      beforeAll(async () => {
+        await client.ksql('DROP STREAM IF EXISTS testAsStream;')
+        await client.ksql('DROP STREAM IF EXISTS newTestStream DELETE TOPIC;');
+
+        newStreamQueryId = await client.createStream('newTestStream', ['name VARCHAR', 'age INTEGER'], 'newTestTopic', 'json', 1);
+        testAsQueryId = await client.createStreamAs('testAsStream', ['name', 'age'], 'newTestStream', {
+          kafka_topic: 'newTestTopic',
+          value_format: 'json',
+          partitions: 1
+      }, 'age > 50');
+      })
+
+      afterAll(async () => {
+        await client.ksql('DROP STREAM IF EXISTS testAsStream;')
+        await client.ksql('DROP STREAM IF EXISTS newTestStream DELETE TOPIC;');
+      })
+
+      it('creates materialized stream', async () => {
+        let streamFound = false;
+        const {streams} = await client.ksql('LIST STREAMS;');
+
+        for (let i = 0; i < streams.length; i++) {
+          if (streams[i].name, streams[i].name === 'TESTASSTREAM') streamFound = true;
+        }
+        expect(streamFound).toBe(true);
+      });
+    })
   })
+  
   describe('--Health Tests--', () => {
     beforeAll((done) => {
       client = new ksqljs({ ksqldbURL: 'http://localhost:8088' });

ksqljs/ksqlJS.js

@@ -276,8 +276,8 @@ class ksqljs {
       });
 
       req.on("end", () => {
-        resolve(msgOutput);
         session.close();
+        resolve(msgOutput);
       });
     })
   }

ksqljsTest.js

@@ -81,7 +81,7 @@ pullFromTo(); */
 
 //---------------------Test Stream Creation As-------------------
 
-const createStreamAsTest = async () => {
+/* const createStreamAsTest = async () => {
     const queryId = await client.createStreamAs('TestAsStream', ['latitude', 'longitude'], 'riderLocations', {
         kafka_topic: 'TestAsStream',
         value_format: 'json',
@@ -91,7 +91,7 @@ const createStreamAsTest = async () => {
     console.log('this is the queryId: ', queryId);
 };
 
-createStreamAsTest();
+createStreamAsTest(); */
 
 // (streamName, selectColumns, sourceStream, propertiesObj, conditionsObj)
 //   const defaultProps = {

package.json

@@ -4,7 +4,7 @@
   "description": "",
   "main": "ksqljsTest.js",
   "scripts": {
-    "test": "jest --verbose"
+    "test": "jest --verbose --detectOpenHandles"
   },
   "keywords": [],
   "author": "",