Merge pull request #207 from weaviate/dev/1.27

Support new `v1.27` features in the `TSv3` client

Author: tsmith023

.github/workflows/main.yaml

@@ -7,9 +7,10 @@ on:
   pull_request:
 
 env:
-  WEAVIATE_124: 1.24.21
-  WEAVIATE_125: 1.25.8
-  WEAVIATE_126: 1.26.1
+  WEAVIATE_124: stable-v1.24-a8b364e
+  WEAVIATE_125: 1.25.21
+  WEAVIATE_126: 1.26.7
+  WEAVIATE_127: 1.27.0
 
 jobs:
   checks:
@@ -18,7 +19,7 @@ jobs:
     - uses: actions/checkout@v3
     - uses: actions/setup-node@v3
       with:
-        node-version: '18.x'
+        node-version: '22.x'
     - name: "Run checks"
       run: |
         npm ci
@@ -35,9 +36,10 @@ jobs:
         versions: [
           { node: "22.x", weaviate: $WEAVIATE_124},
           { node: "22.x", weaviate: $WEAVIATE_125},
-          { node: "18.x", weaviate: $WEAVIATE_126},
-          { node: "20.x", weaviate: $WEAVIATE_126},
-          { node: "22.x", weaviate: $WEAVIATE_126}
+          { node: "22.x", weaviate: $WEAVIATE_126},
+          { node: "18.x", weaviate: $WEAVIATE_127},
+          { node: "20.x", weaviate: $WEAVIATE_127},
+          { node: "22.x", weaviate: $WEAVIATE_127}
         ]
     steps:
     - uses: actions/checkout@v3
@@ -79,7 +81,7 @@ jobs:
       # Setup .npmrc file to publish to npm
       - uses: actions/setup-node@v3
         with:
-          node-version: '18.x'
+          node-version: '22.x'
           registry-url: 'https://registry.npmjs.org'
       - run: npm ci
       - run: npm run build

ci/run_dependencies.sh

@@ -21,18 +21,24 @@ function wait(){
 
   echo "Waiting for $1"
   while true; do
-    if curl -s $1 > /dev/null; then
+    # first check if weaviate already responds
+    if ! curl -s $1 > /dev/null; then
+      continue
+    fi
+
+    # endpoint available, check if it is ready
+    HTTP_STATUS=$(curl -s -o /dev/null -w "%{http_code}" "$1/v1/.well-known/ready")
+
+    if [ "$HTTP_STATUS" -eq 200 ]; then
       break
     else
-      if [ $? -eq 7 ]; then
-        echo "Weaviate is not up yet. (waited for ${ALREADY_WAITING}s)"
-        if [ $ALREADY_WAITING -gt $MAX_WAIT_SECONDS ]; then
-          echo "Weaviate did not start up in $MAX_WAIT_SECONDS."
-          exit 1
-        else
-          sleep 2
-          let ALREADY_WAITING=$ALREADY_WAITING+2
-        fi
+      echo "Weaviate is not up yet. (waited for ${ALREADY_WAITING}s)"
+      if [ $ALREADY_WAITING -gt $MAX_WAIT_SECONDS ]; then
+        echo "Weaviate did not start up in $MAX_WAIT_SECONDS."
+        exit 1
+      else
+        sleep 2
+        let ALREADY_WAITING=$ALREADY_WAITING+2
       fi
     fi
   done

src/backup/backupCreateStatusGetter.ts

@@ -1,4 +1,5 @@
 import Connection from '../connection/index.js';
+import { WeaviateInvalidInputError } from '../errors.js';
 import { BackupCreateStatusResponse } from '../openapi/types.js';
 import { CommandBase } from '../validation/commandBase.js';
 import { Backend } from './index.js';
@@ -29,7 +30,7 @@ export default class BackupCreateStatusGetter extends CommandBase {
   do = (): Promise<BackupCreateStatusResponse> => {
     this.validate();
     if (this.errors.length > 0) {
-      return Promise.reject(new Error('invalid usage: ' + this.errors.join(', ')));
+      return Promise.reject(new WeaviateInvalidInputError('invalid usage: ' + this.errors.join(', ')));
     }
     return this.client.get(this._path()) as Promise<BackupCreateStatusResponse>;
   };

src/backup/backupCreator.ts

@@ -1,4 +1,5 @@
 import Connection from '../connection/index.js';
+import { WeaviateInvalidInputError } from '../errors.js';
 import {
   BackupConfig,
   BackupCreateRequest,
@@ -81,7 +82,7 @@ export default class BackupCreator extends CommandBase {
   do = (): Promise<BackupCreateResponse> => {
     this.validate();
     if (this.errors.length > 0) {
-      return Promise.reject(new Error('invalid usage: ' + this.errors.join(', ')));
+      return Promise.reject(new WeaviateInvalidInputError('invalid usage: ' + this.errors.join(', ')));
     }
 
     const payload = {

src/backup/backupGetter.ts

@@ -1,4 +1,5 @@
 import Connection from '../connection/index.js';
+import { WeaviateInvalidInputError } from '../errors.js';
 import { BackupCreateResponse } from '../openapi/types.js';
 import { CommandBase } from '../validation/commandBase.js';
 import { Backend } from './index.js';
@@ -23,7 +24,7 @@ export default class BackupGetter extends CommandBase {
   do = (): Promise<BackupCreateResponse[]> => {
     this.validate();
     if (this.errors.length > 0) {
-      return Promise.reject(new Error('invalid usage: ' + this.errors.join(', ')));
+      return Promise.reject(new WeaviateInvalidInputError('invalid usage: ' + this.errors.join(', ')));
     }
 
     return this.client.get(this._path());

src/backup/backupRestoreStatusGetter.ts

@@ -1,4 +1,5 @@
 import Connection from '../connection/index.js';
+import { WeaviateInvalidInputError } from '../errors.js';
 import { BackupRestoreStatusResponse } from '../openapi/types.js';
 import { CommandBase } from '../validation/commandBase.js';
 import { Backend } from './index.js';
@@ -29,7 +30,7 @@ export default class BackupRestoreStatusGetter extends CommandBase {
   do = (): Promise<BackupRestoreStatusResponse> => {
     this.validate();
     if (this.errors.length > 0) {
-      return Promise.reject(new Error('invalid usage: ' + this.errors.join(', ')));
+      return Promise.reject(new WeaviateInvalidInputError('invalid usage: ' + this.errors.join(', ')));
     }
 
     return this.client.get(this._path());

src/backup/backupRestorer.ts

@@ -1,4 +1,5 @@
 import Connection from '../connection/index.js';
+import { WeaviateInvalidInputError } from '../errors.js';
 import {
   BackupRestoreRequest,
   BackupRestoreResponse,
@@ -81,7 +82,7 @@ export default class BackupRestorer extends CommandBase {
   do = (): Promise<BackupRestoreResponse> => {
     this.validate();
     if (this.errors.length > 0) {
-      return Promise.reject(new Error('invalid usage: ' + this.errors.join(', ')));
+      return Promise.reject(new WeaviateInvalidInputError('invalid usage: ' + this.errors.join(', ')));
     }
 
     const payload = {