feat(keto-cli): create DeleteRelationCommand

Author: getlarge

packages/keto-cli/src/app/create-relation.command.ts

@@ -65,6 +65,6 @@ export class CreateRelationCommand extends CommandRunner {
     required: false,
   })
   parseAccessToken(val: string): string | undefined {
-    return val ?? process.env['ORY_KETO_API_KEY'];
+    return val;
   }
 }

packages/keto-cli/src/app/delete-relation.command.spec.ts

@@ -0,0 +1,96 @@
+import { OryRelationshipsService } from '@getlarge/keto-client-wrapper';
+import {
+  createRelationQuery,
+  RelationTuple,
+} from '@getlarge/keto-relations-parser';
+import { Configuration } from '@ory/client';
+import { CommandTestFactory } from 'nest-commander-testing';
+
+import { DeleteRelationCommand } from './delete-relation.command';
+
+class MockOryRelationshipsService {
+  deleteRelationships = jest.fn();
+  configuration = new Configuration({
+    basePath: 'http://localhost',
+    accessToken: '',
+  });
+  get config(): Configuration {
+    return this.configuration;
+  }
+  set config(config: Configuration) {
+    this.configuration = config;
+  }
+}
+
+describe('DeleteRelationCommand', () => {
+  let service: DeleteRelationCommand;
+  let oryRelationshipsService: OryRelationshipsService;
+
+  beforeAll(async () => {
+    const app = await CommandTestFactory.createTestingCommand({
+      imports: [],
+      providers: [
+        {
+          provide: OryRelationshipsService,
+          useClass: MockOryRelationshipsService,
+        },
+        DeleteRelationCommand,
+      ],
+    }).compile();
+
+    service = app.get(DeleteRelationCommand);
+    oryRelationshipsService = app.get(OryRelationshipsService);
+  });
+
+  describe('run', () => {
+    it('should process tuple and delete relationship', async () => {
+      const tuple: RelationTuple = {
+        namespace: 'Group',
+        object: 'admin',
+        relation: 'members',
+        subjectIdOrSet: {
+          namespace: 'User',
+          object: '1',
+        },
+      };
+      const expectedQuery = createRelationQuery(tuple).unwrapOrThrow();
+      oryRelationshipsService.deleteRelationships = jest
+        .fn()
+        .mockResolvedValue({
+          data: {
+            namespace: 'Group',
+            object: 'admin',
+            relation: 'members',
+            subject_set: {
+              relation: '',
+              namespace: 'User',
+              object: '1',
+            },
+          },
+        });
+
+      expect(oryRelationshipsService.config.basePath).toBe('http://localhost');
+      await expect(
+        service.run(
+          [
+            '--tuple',
+            'Group:admin#members@User:1',
+            '--basePath',
+            'http://localhost:4467',
+          ],
+          {
+            tuple: expectedQuery,
+            basePath: 'http://localhost:4467',
+          }
+        )
+      ).resolves.toBeUndefined();
+
+      expect(oryRelationshipsService.config.basePath).toBe(
+        'http://localhost:4467'
+      );
+      expect(oryRelationshipsService.deleteRelationships).toHaveBeenCalledWith(
+        expectedQuery
+      );
+    });
+  });
+});

packages/keto-cli/src/app/delete-relation.command.ts

@@ -0,0 +1,69 @@
+import { OryRelationshipsService } from '@getlarge/keto-client-wrapper';
+import {
+  createRelationQuery,
+  parseRelationTuple,
+} from '@getlarge/keto-relations-parser';
+import { Logger } from '@nestjs/common';
+import { Configuration, RelationQuery } from '@ory/client';
+import { Command, CommandRunner, Option } from 'nest-commander';
+
+interface CommandOptions
+  extends Pick<Configuration, 'basePath' | 'accessToken'> {
+  tuple: RelationQuery;
+}
+
+@Command({ name: 'delete', description: 'Delete relationship on Ory Keto' })
+export class DeleteRelationCommand extends CommandRunner {
+  readonly logger = new Logger(DeleteRelationCommand.name);
+
+  constructor(
+    private readonly oryRelationshipsService: OryRelationshipsService
+  ) {
+    super();
+  }
+
+  async run(passedParams: string[], options: CommandOptions): Promise<void> {
+    const { tuple } = options;
+    if (options.accessToken || options.basePath) {
+      this.oryRelationshipsService.config = new Configuration({
+        ...this.oryRelationshipsService.config,
+        ...options,
+      });
+    }
+    await this.oryRelationshipsService.deleteRelationships(tuple);
+    this.logger.debug('Deleted relation');
+    this.logger.log(tuple);
+  }
+
+  @Option({
+    flags: '-t, --tuple [string]',
+    description: 'Relationship tuple to delete, using Zanzibar notation',
+    required: true,
+  })
+  parseRelationTuple(val: string): RelationQuery {
+    const res = parseRelationTuple(val);
+    if (res.hasError()) {
+      throw res.error;
+    }
+    const relationQuery = createRelationQuery(res.value);
+    return relationQuery.unwrapOrThrow();
+  }
+
+  @Option({
+    flags: '-b, --basePath [string]',
+    description: 'Ory Keto Admin URL',
+    required: false,
+  })
+  parseBasePath(val: string): string | undefined {
+    return val;
+  }
+
+  @Option({
+    flags: '-a, --accessToken [string]',
+    description: 'Ory Keto Access Token',
+    required: false,
+  })
+  parseAccessToken(val: string): string | undefined {
+    return val;
+  }
+}