All code works, but using sleep fn. Add polling for status?

Author: lobrien

quickstart/AzureSearchClient.js

@@ -1,6 +1,4 @@
 class AzureSearchClient {
-    
-
     constructor (searchServiceHelper) {
         this.searchServiceHelper = searchServiceHelper;
     }
@@ -11,7 +9,6 @@ class AzureSearchClient {
         const response = await this.searchServiceHelper.request(endpoint, "GET", null);
         // Success has a few likely status codes: 200 or 204 (No Content), but accept all in 200 range...
         const exists = response.status >= 200 && response.status < 300;
-        this.searchServiceHelper.throwOnHttpError(response);
         return exists;
     }
 
@@ -26,7 +23,6 @@ class AzureSearchClient {
     async createIndexAsync(definition) {
         console.log("\n Creating index...");
         const endpoint = this.searchServiceHelper.getCreateIndexUrl();
-
         const response = await this.searchServiceHelper.request(endpoint, "PUT", definition);
         this.searchServiceHelper.throwOnHttpError(response);
         return this;
@@ -35,14 +31,13 @@ class AzureSearchClient {
     async loadDataAsync(hotelsData) {
         console.log("\n Adding hotel data...");
         const endpoint = this.searchServiceHelper.getPostDataUrl();
-
-        console.log(JSON.stringify(hotelsData));
         const response = await this.searchServiceHelper.request(endpoint,"POST", hotelsData);
         this.searchServiceHelper.throwOnHttpError(response);
         return this;
     }
 
     async queryAsync(searchTerm) {
+        console.log("\n Querying...")
         const endpoint = this.searchServiceHelper.getSearchUrl(searchTerm);
         const response = await this.searchServiceHelper.request(endpoint, "GET");
         this.searchServiceHelper.throwOnHttpError(response);

quickstart/SearchServiceHelper.js

@@ -19,6 +19,8 @@ class SearchServiceHelper {
 
 
     request(url, method, bodyJson = null) {
+        console.log(`\n${method} ${url}`);
+       
         const headers = {
             'content-type' : 'application/json',
             'api-key' : this.apiKey
@@ -34,16 +36,15 @@ class SearchServiceHelper {
                 headers : headers,
                 body : JSON.stringify(bodyJson)
             };
-        console.log(`\n${method} ${url}`);
         return fetch(url, init);
     }
 
     throwOnHttpError(response) {
         const statusCode = response.status;
         console.log(`Response Status: ${statusCode}`);
         if (statusCode >= 300){
-            console.log(`Request returned error code ${JSON.stringify(response)}`);
-            throw new UserException(`Failure in request. HTTP Status was ${statusCode}`);
+            console.log(`Request failed: ${JSON.stringify(response, null, 4)}`);
+            throw new Exception(`Failure in request. HTTP Status was ${statusCode}`);
         }
     }
 }

quickstart/index.js

@@ -24,28 +24,42 @@ const hotelData = { value : [
     require('./data/hotel4.json')
 ]}
 
+
+function sleep(ms)
+{
+    return(
+        new Promise(function(resolve, reject)
+        {
+            setTimeout(function() { resolve(); }, ms);
+        })
+    );
+}
+async function doQueries(client) {
+    return Promise.all(
+        queries.map(async query => {
+            const result = await client.queryAsync(query);
+            const body = await result.json();
+            const str = JSON.stringify(body, null, 4);
+            console.log(`Query: ${query} \n ${str}`);
+        })
+    );
+}
+
 const run = async () => {
     try {
         const cfg = getAzureConfiguration();
         const helper = new SearchServiceHelper(cfg.get("serviceName"), cfg.get("apiKey"), "hotels");
         const client = new AzureSearchClient(helper);
 
-        //const exists = await client.indexExistsAsync();
-        //await exists ? client.deleteIndexAsync() : Promise.resolve();
-        //const indexDefinition = require('./hotels_quickstart_index.json');
-        //await client.createIndexAsync(indexDefinition);
-        //await client.loadDataAsync(hotelData);
-        // var indexComplete = false
-        // do {
-        //     indexComplete = await client.indexCompletedAsync();
-        // }while(! indexComplete)
-        queries.forEach(async (query) => { 
-            const result = await client.queryAsync(query);
-            const body = await result.json();
-            const str = JSON.stringify(body, null, 4);
-            console.log(`Query: ${query} \n ${str}`);
-        });
-        console.log("Finished.");
+        const exists = await client.indexExistsAsync();
+        await exists ? client.deleteIndexAsync() : Promise.resolve();
+        await sleep(2000);
+        const indexDefinition = require('./hotels_quickstart_index.json');
+        await client.createIndexAsync(indexDefinition);
+        await sleep(2000);
+        await client.loadDataAsync(hotelData);
+        await sleep(5000);
+        await doQueries(client);
     } catch (x) {
         console.log(x);
     }