Merge pull request #32 from oslabs-beta/mx/jestTestsBranch

Mx/jest tests branch

Author: jonathanluu17

__tests__/integrationtests.js

@@ -25,6 +25,7 @@ describe('--Integration Tests--', () => {
     })
 
     it('.createStream properly creates a stream', async () => {
+      await client.ksql('DROP STREAM IF EXISTS TESTJESTSTREAM DELETE TOPIC;')
       const result = await client.createStream('TESTJESTSTREAM', ['name VARCHAR', 'email varchar', 'age INTEGER'], 'testJestTopic', 'json', 1);
       const streams = await client.ksql('LIST STREAMS;');
       const allStreams = streams.streams;
@@ -56,17 +57,19 @@ describe('--Integration Tests--', () => {
     })
 
     it('.insertStream properly inserts a row into a stream', async () => {
-      const response = await client.insertStream('TESTJESTSTREAM', [
-        { "name": "stab-rabbit", "email": "123@mail.com", "age": 100 }
-      ]);
+      
       const data = [];
       await client.push('SELECT * FROM TESTJESTSTREAM EMIT CHANGES;', async (chunk) => {
         data.push(JSON.parse(chunk));
+        console.log(data);
         if (data[1]) {
           client.terminate(data[0].queryId);
           expect(data[1]).toEqual(["stab-rabbit", "123@mail.com", 100])
         }
       });
+      const response = await client.insertStream('TESTJESTSTREAM', [
+        { "name": "stab-rabbit", "email": "123@mail.com", "age": 100 }
+      ]);
     })
 
     it('.pull receives the correct data from a pull query', async () => {
@@ -98,24 +101,24 @@ describe('--Integration Tests--', () => {
         beforeAll(async () => {
           // await client.ksql('DROP STREAM IF EXISTS testAsStream;')
           // await client.ksql('DROP STREAM IF EXISTS newTestStream DELETE TOPIC;');
-  
+
           // 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');
+          }, '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;');
-  
+          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;
@@ -128,8 +131,8 @@ describe('--Integration Tests--', () => {
 
 
       describe('--Materialized Tables Tests--', () => {
-        beforeAll( async () => {
-          await client.createTableAs('testAsTable', 'newTestStream', ['name', 'LATEST_BY_OFFSET(age) AS recentAge'], {topic:'newTestTopic'},{WHERE: 'age >= 21', GROUP_BY: 'name'});
+        beforeAll(async () => {
+          await client.createTableAs('testAsTable', 'newTestStream', ['name', 'LATEST_BY_OFFSET(age) AS recentAge'], { topic: 'newTestTopic' }, { WHERE: 'age >= 21', GROUP_BY: 'name' });
         });
         afterAll(async () => {
           await client.ksql('DROP TABLE IF EXISTS testAsTable;');
@@ -138,29 +141,16 @@ describe('--Integration Tests--', () => {
         })
 
         it('creates a materialized table view of a stream', async () => {
-          const {tables} = await client.ksql('LIST TABLES;');
+          const { tables } = await client.ksql('LIST TABLES;');
           let tableFound = false;
-          for (let i = 0; i < tables.length; i++){
+          for (let i = 0; i < tables.length; i++) {
             if (tables[i].name === 'TESTASTABLE') {
               tableFound = true;
               break;
             }
           }
           expect(tableFound).toEqual(true);
         })
-
-        // it('receives updates from source stream', async () => {
-        //   let rowReceived = false;
-        //   await client.push('SELECT * FROM testAsTable EMIT CHANGES LIMIT 1;', async (data) => {
-        //     if (Array.isArray(JSON.parse(data))){
-        //       if (JSON.parse(data)[0] === "firstTester" && JSON.parse(data)[1] === 25){
-        //         rowReceived = true;
-        //       }
-        //     }
-        //   })
-        //   await client.insertStream('NEWTESTSTREAM', [{"NAME":"firstTester", "AGE":25}]);
-        //   await waitForExpect(() => expect(rowReceived).toEqual(true))
-        // })
       })
     })
   })