index provision added

Author: iyerrama29

dist/config.js

@@ -9,6 +9,11 @@ exports.config = {
     contentStore: {
         collectionName: 'contents',
         dbName: 'contentstack-persistent-db',
+        indexes: {
+            content_type_uid: 1,
+            locale: 1,
+            uid: 1
+        },
         limit: 100,
         locales: [],
         options: {

dist/stack.js

@@ -84,14 +84,40 @@ class Stack {
                 this.client = client;
                 return client.connect().then(() => {
                     this.db = client.db(dbName);
-                    return resolve(this.db);
+                    resolve(this.db);
+                    const bucket = [];
+                    const indexes = this.config.contentStore.indexes;
+                    const collectionName = this.config.contentStore.collectionName;
+                    for (let index in indexes) {
+                        if (indexes[index] === 1 || indexes[index] === -1) {
+                            bucket.push(this.createIndexes(this.config.contentStore.collectionName, index, indexes[index]));
+                        }
+                    }
+                    Promise.all(bucket)
+                        .then(() => {
+                        console.info(`Indexes created successfully in '${collectionName}' collection`);
+                    })
+                        .catch((error) => {
+                        console.error(`Failed while creating indexes in '${collectionName}' collection`);
+                        console.error(error);
+                    });
                 }).catch(reject);
             }
             catch (error) {
                 return reject(error);
             }
         });
     }
+    createIndexes(collectionId, index, type) {
+        return this.db.collection(collectionId)
+            .createIndex({
+            [index]: type
+        })
+            .then(() => {
+            console.info(`Index '${index}' created successfully!`);
+            return;
+        });
+    }
     close() {
         this.client.close();
     }
@@ -761,7 +787,7 @@ class Stack {
                                     referencesFound.push(new Promise((rs, rj) => {
                                         return self.db.collection(this.contentStore.collectionName)
                                             .find(query)
-                                            .project(self.config.projections)
+                                            .project(self.config.contentStore.projections)
                                             .toArray()
                                             .then((result) => {
                                             if (result.length === 0) {

src/config.ts

@@ -8,6 +8,12 @@ export const config = {
   contentStore: {
     collectionName: 'contents',
     dbName: 'contentstack-persistent-db',
+    indexes: {
+      // published_at: -1,
+      content_type_uid: 1,
+      locale: 1,
+      uid: 1
+    },
     limit: 100,
     locales: [
     ],

src/stack.ts

@@ -127,7 +127,26 @@ export class Stack {
         return client.connect().then(() => {
           this.db = client.db(dbName)
 
-          return resolve(this.db)
+          resolve(this.db)
+
+          // Create indexes in the background
+          const bucket: any = []
+          const indexes = this.config.contentStore.indexes
+          const collectionName = this.config.contentStore.collectionName
+          for (let index in indexes) {
+            if (indexes[index] === 1 || indexes[index] === -1) {
+              bucket.push(this.createIndexes(this.config.contentStore.collectionName, index, indexes[index]))
+            }
+          }
+
+          Promise.all(bucket)
+            .then(() => {
+              console.info(`Indexes created successfully in '${collectionName}' collection`)    
+            })
+            .catch((error) => {
+              console.error(`Failed while creating indexes in '${collectionName}' collection`)
+              console.error(error)
+            })
         }).catch(reject)
       } catch (error) {
 
@@ -136,6 +155,17 @@ export class Stack {
     })
   }
 
+  private createIndexes (collectionId, index, type) {
+    return this.db.collection(collectionId)
+      .createIndex({
+        [index]: type
+      })
+      .then(() => {
+        console.info(`Index '${index}' created successfully!`)
+        return
+      })
+  }
+
   /**
    * @summary
    *  Closes connection with mongodb
@@ -1176,7 +1206,7 @@ export class Stack {
                   referencesFound.push(new Promise((rs, rj) => {
                     return self.db.collection(this.contentStore.collectionName)
                       .find(query)
-                      .project(self.config.projections)
+                      .project(self.config.contentStore.projections)
                       .toArray()
                       .then((result) => {
                         if (result.length === 0) {

typings/config.d.ts

@@ -7,6 +7,11 @@ export declare const config: {
     contentStore: {
         collectionName: string;
         dbName: string;
+        indexes: {
+            content_type_uid: number;
+            locale: number;
+            uid: number;
+        };
         limit: number;
         locales: any[];
         options: {

typings/stack.d.ts

@@ -15,6 +15,7 @@ export declare class Stack {
     ascending(field?: any): this;
     descending(field?: any): this;
     connect(overrides?: {}): Promise<{}>;
+    private createIndexes;
     close(): void;
     language(code: any): this;
     and(queries: any): this;