commit before pull from Jonathan's branch

Author: matthewxing1

__tests__/integrationtests.js

@@ -32,21 +32,28 @@ describe('--Integration Tests--', () => {
       expect(streamExists).toEqual(true);
     })
 
-    it('.push properly creates a push query', () => {
+    it('.push properly creates a push query', async () => {
       let pushActive = false;
-      client.push('SELECT * FROM TESTJESTSTREAM EMIT CHANGES LIMIT 1;', async (data) => {
+      await client.push('SELECT * FROM TESTJESTSTREAM EMIT CHANGES LIMIT 1;', async (data) => {
         if (JSON.parse(data).queryId) {
           pushActive = true;
         }
         expect(pushActive).toEqual(true)
       });
     })
 
-    it('.terminate properly terminates a push query', () => {
-      client.push('SELECT * FROM TESTJESTSTREAM EMIT CHANGES LIMIT 3;', async (data) => {
-        const terminateRes = await client.terminate(JSON.parse(data).queryId);
+    it('.terminate properly terminates a push query', async () => {
+      let terminateRes;
+      await client.push('SELECT * FROM TESTJESTSTREAM EMIT CHANGES LIMIT 3;', async (data) => {
+        terminateRes = await client.terminate(JSON.parse(data).queryId);
         expect(terminateRes.wasTerminated).toEqual(true);
       })
+      // console.log("this is terminate", terminateRes);
+      // const queriesList = await client.ksql("LIST QUERIES;");
+      // console.log(queriesList);
+      // const queryIdDelete = (queriesList.queries[0]).id;
+      // const response = await client.terminate(queryIdDelete);
+      // console.log(response);
     })
 
     it('.insertStream properly inserts a row into a stream', async () => {
@@ -65,7 +72,6 @@ describe('--Integration Tests--', () => {
 
     it('.pull receives the correct data from a pull query', async () => {
       const pullData = await client.pull("SELECT * FROM TESTJESTSTREAM;");
-      console.log(pullData[1]);
       expect(pullData[1]).toEqual(["stab-rabbit", "123@mail.com", 100]);
     })
 

ksqljs/ksqlJS.js

@@ -150,6 +150,47 @@ class ksqljs {
         console.error(error);
         throw new ksqlDBError(error);
       });
+    // return new Promise((resolve, reject) => {
+    //   const session = http2.connect(
+    //     this.ksqldbURL,
+    //     this.httpsAgentHttp2 ? this.httpsAgentHttp2 : {}
+    //   );
+  
+    //   session.on("error", (err) => reject(err));
+  
+    //   const req = session.request(
+    //     this.secret && this.API ?
+    //       {
+    //         ":path": "/ksql",
+    //         ":method": "POST",
+    //         "Authorization": this.API && this.secret ? `Basic ${Buffer.from(this.API + ":" + this.secret, 'utf8').toString('base64')}` : '',
+    //       }
+    //       :
+    //       {
+    //         ":path": "/ksql",
+    //         ":method": "POST",
+    //       }
+    //   );
+      
+    //   const query = builder.build("TERMINATE ?;", queryId);
+
+    //   const reqBody = {
+    //     sql: query,
+    //     Accept: "application/json, application/vnd.ksqlapi.delimited.v1",
+    //   };
+  
+    //   req.write(JSON.stringify(reqBody), "utf8");
+    //   req.end();
+    //   req.setEncoding("utf8");
+  
+    //   req.on("data", (data) => {
+    //     console.log("Here's the response", data);
+    //     resolve();
+    //   });
+  
+    //   req.on("end", () => {
+    //     session.close()});
+    // })
   }
 
   /**