adds support for tenants activation / deactivation

Author: aliszka

src/batch/journey.test.ts

@@ -544,7 +544,7 @@ describe('multi tenancy', () => {
       });
   });
 
-  it('create Passage classes tenants', () => {
+  it('creates Passage class tenants', () => {
     return client.schema
       .tenantsCreator(passageClassName, tenants)
       .do()
@@ -556,7 +556,7 @@ describe('multi tenancy', () => {
       });
   });
 
-  it('get Passage classes tenants', () => {
+  it('gets Passage class tenants', () => {
     return client.schema
       .tenantsGetter(passageClassName)
       .do()
@@ -568,6 +568,51 @@ describe('multi tenancy', () => {
       });
   });
 
+  it('updates Passage class tenants (deactivates)', () => {
+    return client.schema
+      .tenantsUpdater(passageClassName, [
+        { name: tenants[0].name, activityStatus: 'COLD' },
+        { name: tenants[1].name, activityStatus: 'COLD' },
+      ])
+      .do()
+      .then((res) => {
+        expect(res).toHaveLength(2);
+      })
+      .catch((e) => {
+        throw new Error('it should not have errord ' + e);
+      });
+  });
+
+  it('does not get objects due to inactivity', () => {
+    return client.data
+      .getter()
+      .withClassName(passageClassName)
+      .withTenant(tenants[0].name!)
+      .do()
+      .then(() => {
+        throw new Error('should fail on data get');
+      })
+      .catch((err) => {
+        expect(err.message).toContain('422');
+        expect(err.message).toContain('tenant not active');
+      });
+  });
+
+  it('updates Passage class tenants (activates again)', () => {
+    return client.schema
+      .tenantsUpdater(passageClassName, [
+        { name: tenants[0].name, activityStatus: 'HOT' },
+        { name: tenants[1].name, activityStatus: 'HOT' },
+      ])
+      .do()
+      .then((res) => {
+        expect(res).toHaveLength(2);
+      })
+      .catch((e) => {
+        throw new Error('it should not have errord ' + e);
+      });
+  });
+
   it('should batch import Passage objects', () => {
     const toImport: WeaviateObject[] = [];
     for (let i = 0; i < passageIDs.length; i++) {

src/schema/index.ts

@@ -9,6 +9,7 @@ import ShardUpdater from './shardUpdater';
 import ShardsUpdater from './shardsUpdater';
 import TenantsCreator from './tenantsCreator';
 import TenantsGetter from './tenantsGetter';
+import TenantsUpdater from './tenantsUpdater';
 import TenantsDeleter from './tenantsDeleter';
 import Connection from '../connection';
 import { Tenant } from '../openapi/types';
@@ -25,6 +26,7 @@ export interface Schema {
   shardsUpdater: () => ShardsUpdater;
   tenantsCreator: (className: string, tenants: Array<Tenant>) => TenantsCreator;
   tenantsGetter: (className: string) => TenantsGetter;
+  tenantsUpdater: (className: string, tenants: Array<Tenant>) => TenantsUpdater;
   tenantsDeleter: (className: string, tenants: Array<string>) => TenantsDeleter;
 }
 
@@ -42,6 +44,8 @@ const schema = (client: Connection): Schema => {
     tenantsCreator: (className: string, tenants: Array<Tenant>) =>
       new TenantsCreator(client, className, tenants),
     tenantsGetter: (className: string) => new TenantsGetter(client, className),
+    tenantsUpdater: (className: string, tenants: Array<Tenant>) =>
+      new TenantsUpdater(client, className, tenants),
     tenantsDeleter: (className: string, tenants: Array<string>) =>
       new TenantsDeleter(client, className, tenants),
   };
@@ -56,5 +60,6 @@ export { default as SchemaGetter } from './getter';
 export { default as ShardUpdater } from './shardUpdater';
 export { default as ShardsUpdater } from './shardsUpdater';
 export { default as TenantsCreator } from './tenantsCreator';
+export { default as TenantsUpdater } from './tenantsUpdater';
 export { default as TenantsGetter } from './tenantsGetter';
 export { default as TenantsDeleter } from './tenantsDeleter';

src/schema/tenantsDeleter.ts

@@ -1,7 +1,5 @@
-import { isValidStringProperty } from '../validation/string';
 import Connection from '../connection';
 import { CommandBase } from '../validation/commandBase';
-import { Tenant } from '../openapi/types';
 
 export default class TenantsDeleter extends CommandBase {
   private className: string;

src/schema/tenantsUpdater.ts

@@ -0,0 +1,22 @@
+import Connection from '../connection';
+import { CommandBase } from '../validation/commandBase';
+import { Tenant } from '../openapi/types';
+
+export default class TenantsCreator extends CommandBase {
+  private className: string;
+  private tenants: Array<Tenant>;
+
+  constructor(client: Connection, className: string, tenants: Array<Tenant>) {
+    super(client);
+    this.className = className;
+    this.tenants = tenants;
+  }
+
+  validate = () => {
+    // nothing to validate
+  };
+
+  do = (): Promise<Array<Tenant>> => {
+    return this.client.put(`/schema/${this.className}/tenants`, this.tenants);
+  };
+}