feat: add a new pipe command

Author: bitkidd

commands/CredentialsPipe.ts

@@ -0,0 +1,59 @@
+/*
+ * @bitkidd/adonis-credentials
+ *
+ * (c) Chirill Ceban <cc@bitkidd.dev>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+import fs from 'fs'
+import execa from 'execa'
+import { args, BaseCommand, flags } from '@adonisjs/core/build/standalone'
+import { Credentials } from '../src/Credentials'
+
+export default class CredentialsPipe extends BaseCommand {
+  public static commandName = 'credentials:pipe'
+  public static description = 'Read and pipe credentials'
+  public static settings = {
+    loadApp: false,
+    stayAlive: true,
+  }
+
+  @args.string({
+    description: 'Specify an ace command to pipe credentials to',
+  })
+  public command: string
+
+  @flags.string({
+    description: 'Specify an environment for credentials file (default: development)',
+  })
+  public env: string
+
+  public async run(): Promise<void> {
+    const env = this.env || process.env.NODE_ENV || 'development'
+    const [command, ...params] = this.command?.split(' ')
+    const credentialsPath = this.application.resourcesPath('credentials')
+
+    if (!fs.existsSync(`${credentialsPath}/${env}.key`)) {
+      this.logger.error(`Credentials key file for '${env}' environment does not exist`)
+      return
+    }
+
+    if (!fs.existsSync(`${credentialsPath}/${env}.credentials`)) {
+      this.logger.error(`Credentials file for '${env}' environment does not exist`)
+      return
+    }
+
+    const credentials = new Credentials({ env, credentialsPath })
+
+    try {
+      await execa.node(command, [...params], {
+        stdio: 'inherit',
+        env: { ...(credentials.get() as Record<string, string>) },
+      })
+    } catch (error) {
+      console.log(error)
+    }
+  }
+}

package.json

@@ -84,7 +84,8 @@
     "instructionsMd": "./build/instructions.md",
     "commands": [
       "@bitkidd/adonis-credentials/build/commands/CredentialsCreate",
-      "@bitkidd/adonis-credentials/build/commands/CredentialsEdit"
+      "@bitkidd/adonis-credentials/build/commands/CredentialsEdit",
+      "@bitkidd/adonis-credentials/build/commands/CredentialsPipe"
     ]
   },
   "dependencies": {

test/credentials-pipe.spec.ts

@@ -0,0 +1,74 @@
+/*
+ * @bitkidd/adonis-credentials
+ *
+ * (c) Chirill Ceban <cc@bitkidd.dev>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+import 'reflect-metadata'
+
+import test from 'japa'
+import { Kernel } from '@adonisjs/core/build/standalone'
+import { ApplicationContract } from '@ioc:Adonis/Core/Application'
+
+import CredentialsCreate from '../commands/CredentialsCreate'
+import CredentialsPipe from '../commands/CredentialsPipe'
+import { fs, setupApplication } from '../test-helpers'
+
+let app: ApplicationContract
+
+test.group('Command - Credentials Pipe', (group) => {
+  group.beforeEach(async () => {
+    app = await setupApplication()
+    const command = new CredentialsCreate(app, new Kernel(app))
+    await command.run()
+  })
+
+  group.afterEach(async () => {
+    await fs.cleanup()
+  })
+
+  test('should throw an error when credentials key file does not exist', async (assert) => {
+    await fs.remove('resources/credentials/test.key')
+
+    const command = new CredentialsPipe(app, new Kernel(app))
+    command.command = `echo 'test';`
+    await command.run()
+
+    assert.deepStrictEqual(
+      command.ui.testingRenderer.logs.map((log) => ({
+        ...log,
+        message: log.message.replace(/(\[.*?\])/g, '').trim(),
+      })),
+      [
+        {
+          stream: 'stderr',
+          message: `Credentials key file for 'test' environment does not exist`,
+        },
+      ]
+    )
+  })
+
+  test('should throw an error when credentials file does not exist', async (assert) => {
+    await fs.remove('resources/credentials/test.credentials')
+
+    const command = new CredentialsPipe(app, new Kernel(app))
+    command.command = `echo 'test';`
+    await command.run()
+
+    assert.deepStrictEqual(
+      command.ui.testingRenderer.logs.map((log) => ({
+        ...log,
+        message: log.message.replace(/(\[.*?\])/g, '').trim(),
+      })),
+      [
+        {
+          stream: 'stderr',
+          message: `Credentials file for 'test' environment does not exist`,
+        },
+      ]
+    )
+  })
+})