Use @testcontainers/weaviate, fix TODO comments

Author: tsmith023

package-lock.json

@@ -66,6 +66,7 @@
     "@curveball/core": "0.20.0",
     "@curveball/kernel": "0.20.1",
     "@rollup/plugin-babel": "^5.3.1",
+    "@testcontainers/weaviate": "^10.14.0",
     "@types/express": "^4.17.21",
     "@types/isomorphic-fetch": "^0.0.36",
     "@types/jest": "^29.4.0",
@@ -89,7 +90,6 @@
     "prettier": "^2.8.4",
     "prettier-plugin-organize-imports": "^3.2.4",
     "protobufjs": "^7.2.6",
-    "testcontainers": "^10.13.2",
     "ts-jest": "^29.0.5",
     "ts-node": "^10.9.2",
     "ts-proto": "^1.163.0",

package.json

@@ -1,19 +1,19 @@
-import { GenericContainer, StartedTestContainer } from 'testcontainers';
+import { StartedWeaviateContainer, WeaviateContainer } from '@testcontainers/weaviate';
 import weaviate from '..';
 import { WeaviateStartUpError } from '../errors';
 import { Meta } from '../openapi/types';
 import { DbVersion } from '../utils/dbVersion';
 
 describe('Integration testing of the ConnectionGRPC class', () => {
-  let container: StartedTestContainer;
+  let container: StartedWeaviateContainer;
 
   const getVersion = () =>
     fetch(`http://${container.getHost()}:${container.getMappedPort(8080)}/v1/meta`)
       .then((res) => res.json() as Promise<Meta>)
       .then((meta) => DbVersion.fromString(meta.version!));
 
   beforeAll(async () => {
-    container = await new GenericContainer(`semitechnologies/weaviate:${process.env.WEAVIATE_VERSION}`)
+    container = await new WeaviateContainer(`semitechnologies/weaviate:${process.env.WEAVIATE_VERSION}`)
       .withExposedPorts(8080, 50051)
       .withEnvironment({
         GRPC_MAX_MESSAGE_SIZE: '1',
@@ -32,13 +32,13 @@ describe('Integration testing of the ConnectionGRPC class', () => {
         port: container.getMappedPort(8080),
         grpcPort: container.getMappedPort(50051),
       });
-      expect(dbVersion.isLowerThan(1, 27, 0)).toBe(true); // TODO: change to 1.27.1 when it lands
+      expect(dbVersion.isLowerThan(1, 27, 1)).toBe(true);
     } catch (err) {
       expect(err).toBeInstanceOf(WeaviateStartUpError);
       expect((err as WeaviateStartUpError).message).toContain(
         'RESOURCE_EXHAUSTED: Attempted to send message with a size larger than 1'
       );
-      expect(dbVersion.isAtLeast(1, 27, 0)).toBe(true); // TODO: change to 1.27.1 when it lands
+      expect(dbVersion.isAtLeast(1, 27, 1)).toBe(true);
     }
   });
 });

src/connection/integration.test.ts

@@ -135,8 +135,8 @@ export class DbVersionSupport {
         supports:
           (version.isAtLeast(1, 24, 0) && version.isLowerThan(1, 24, 26)) ||
           (version.isAtLeast(1, 25, 0) && version.isLowerThan(1, 25, 22)) ||
-          (version.isAtLeast(1, 26, 0) && version.isLowerThan(1, 26, 8)),
-        // || (version.isAtLeast(1, 27, 0) && version.isLowerThan(1, 27, 1)), // TODO: comment back in when 1.27.1 lands
+          (version.isAtLeast(1, 26, 0) && version.isLowerThan(1, 26, 8)) ||
+          (version.isAtLeast(1, 27, 0) && version.isLowerThan(1, 27, 1)),
         message: this.errorMessage(
           'Named vectors insert fix',
           version.show(),