feat(keto-cli): add CreateRelationCommand

Author: getlarge

packages/keto-cli/src/app/app.module.ts

@@ -6,6 +6,7 @@ import { Module } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 
 import { CheckPermissionCommand } from './check-permission.command';
+import { CreateRelationCommand } from './create-relation.command';
 import { OryKetoEnvironmentVariables, validate } from './environment-variables';
 
 @Module({
@@ -33,6 +34,6 @@ import { OryKetoEnvironmentVariables, validate } from './environment-variables';
       }),
     }),
   ],
-  providers: [CheckPermissionCommand],
+  providers: [CheckPermissionCommand, CreateRelationCommand],
 })
 export class AppModule {}

packages/keto-cli/src/app/check-permission.command.ts

@@ -25,7 +25,7 @@ export class CheckPermissionCommand extends CommandRunner {
 
   async run(passedParams: string[], options: CommandOptions): Promise<void> {
     const { tuple } = options;
-    if (options.accessToken || options.basePath) {
+    if (options.basePath) {
       this.oryPermissionsService.config = new Configuration({
         ...this.oryPermissionsService.config,
         ...options,

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

@@ -0,0 +1,71 @@
+import { OryRelationshipsService } from '@getlarge/keto-client-wrapper';
+import {
+  createRelationQuery,
+  parseRelationTuple,
+} from '@getlarge/keto-relations-parser';
+import { Logger } from '@nestjs/common';
+import { Configuration, type RelationQuery } from '@ory/client';
+import { Command, CommandRunner, Option } from 'nest-commander';
+
+interface CommandOptions
+  extends Pick<Configuration, 'basePath' | 'accessToken'> {
+  tuple: RelationQuery;
+}
+
+@Command({ name: 'create', description: 'Create relationship on Ory Keto' })
+export class CreateRelationCommand extends CommandRunner {
+  readonly logger = new Logger(CreateRelationCommand.name);
+
+  constructor(
+    private readonly oryRelationshipsService: OryRelationshipsService
+  ) {
+    super();
+  }
+
+  async run(passedParams: string[], options: CommandOptions): Promise<void> {
+    console.log('options', options);
+    const { tuple } = options;
+    if (options.accessToken || options.basePath) {
+      this.oryRelationshipsService.config = new Configuration({
+        ...this.oryRelationshipsService.config,
+        ...options,
+      });
+    }
+    await this.oryRelationshipsService.createRelationship({
+      createRelationshipBody: tuple,
+    });
+    this.logger.debug('Created relation');
+    this.logger.log(tuple);
+  }
+
+  @Option({
+    flags: '-t, --tuple [string]',
+    description: 'Relationship tuple to create, using Zanzibar notation',
+    required: true,
+  })
+  parseRelationTuple(val: string): RelationQuery {
+    const res = parseRelationTuple(val);
+    if (res.hasError()) {
+      throw res.error;
+    }
+    return createRelationQuery(res.value).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 ?? process.env['ORY_KETO_API_KEY'];
+  }
+}