Create index integration tests

src/integration/control/createIndex.test.ts

@@ -0,0 +1,124 @@
+import { PineconeNotFoundError } from '../../errors';
+import { Pinecone } from '../../index';
+import { randomIndexName } from '../test-helpers';
+
+describe('create index', () => {
+  let indexName;
+  let pinecone: Pinecone;
+
+  beforeEach(async () => {
+    indexName = randomIndexName('createIndex');
+    pinecone = new Pinecone();
+  });
+
+  describe('happy path', () => {
+    afterEach(async () => {
+      await pinecone.deleteIndex(indexName);
+    });
+
+    test('simple create', async () => {
+      await pinecone.createIndex({
+        name: indexName,
+        dimension: 5,
+      });
+      const description = await pinecone.describeIndex(indexName);
+      expect(description.database?.name).toEqual(indexName);
+      expect(description.database?.dimension).toEqual(5);
+      expect(description.database?.metric).toEqual('cosine');
+      expect(description.database?.pods).toEqual(1);
+      expect(description.database?.replicas).toEqual(1);
+      expect(description.database?.shards).toEqual(1);
+      expect(description.status?.host).toBeDefined();
+    });
+
+    test('create with optional properties', async () => {
+      await pinecone.createIndex({
+        name: indexName,
+        dimension: 5,
+        metric: 'euclidean',
+        replicas: 2,
+        podType: 'p1.x2',
+      });
+
+      const description = await pinecone.describeIndex(indexName);
+      expect(description.database?.name).toEqual(indexName);
+      expect(description.database?.dimension).toEqual(5);
+      expect(description.database?.metric).toEqual('euclidean');
+      expect(description.database?.pods).toEqual(2);
+      expect(description.database?.replicas).toEqual(2);
+      expect(description.database?.shards).toEqual(1);
+      expect(description.status?.host).toBeDefined();
+      expect(description.status?.state).toEqual('Initializing');
+    });
+
+    test('create with utility prop: waitUntilReady', async () => {
+      await pinecone.createIndex({
+        name: indexName,
+        dimension: 5,
+        waitUntilReady: true,
+      });
+
+      const description = await pinecone.describeIndex(indexName);
+      expect(description.database?.name).toEqual(indexName);
+      expect(description.status?.state).toEqual('Ready');
+    });
+
+    test('create with utility prop: suppressConflicts', async () => {
+      await pinecone.createIndex({
+        name: indexName,
+        dimension: 5,
+      });
+      await pinecone.createIndex({
+        name: indexName,
+        dimension: 5,
+        suppressConflicts: true,
+      });
+
+      const description = await pinecone.describeIndex(indexName);
+      expect(description.database?.name).toEqual(indexName);
+    });
+  });
+
+  describe('error cases', () => {
+    test('create index with invalid index name', async () => {
+      try {
+        await pinecone.createIndex({
+          name: indexName + '-',
+          dimension: 5,
+        });
+      } catch (e) {
+        const err = e as PineconeNotFoundError;
+        expect(err.name).toEqual('PineconeBadRequestError');
+        expect(err.message).toContain('alphanumeric characters');
+      }
+    });
+
+    test('insufficient quota', async () => {
+      try {
+        await pinecone.createIndex({
+          name: indexName,
+          dimension: 5,
+          replicas: 20,
+        });
+      } catch (e) {
+        const err = e as PineconeNotFoundError;
+        expect(err.name).toEqual('PineconeBadRequestError');
+        expect(err.message).toContain('exceeds the project quota');
+      }
+    });
+
+    test('create from non-existent collection', async () => {
+      try {
+        await pinecone.createIndex({
+          name: indexName,
+          dimension: 5,
+          sourceCollection: 'non-existent-collection',
+        });
+      } catch (e) {
+        const err = e as PineconeNotFoundError;
+        expect(err.name).toEqual('PineconeBadRequestError');
+        expect(err.message).toContain('failed to fetch source collection');
+      }
+    });
+  });
+});

src/utils/middleware.ts

@@ -34,15 +34,15 @@ if (process && process.env && process.env.PINECONE_DEBUG) {
       if (context.init.body) {
         console.debug(chalk(`>>> Body: ${context.init.body}`, 'blue'));
       }
-      console.debug();
+      console.debug('');
     },
 
     post: async (context) => {
       console.debug(chalk(`<<< Status: ${context.response.status}`, 'green'));
       console.debug(
         chalk(`<<< Body: ${await context.response.text()}`, 'green')
       );
-      console.debug();
+      console.debug('');
     },
   };
 
@@ -65,7 +65,7 @@ if (process && process.env && process.env.PINECONE_DEBUG_CURL) {
         context.init.body ? `-d '${context.init.body}'` : ''
       }`;
       console.debug(chalk(cmd, 'red'));
-      console.debug();
+      console.debug('');
     },
   };
   debugMiddleware.push(debugCurlMiddleware);