cli-test(feat): Added datastore CLI commands

packages/cli-test/src/cli/commands/datastore.spec.ts

@@ -0,0 +1,52 @@
+import sinon from 'sinon';
+
+import { mockProcess } from '../../utils/test';
+import { shell } from '../shell';
+import datastore from './datastore';
+
+describe('datastore commands', () => {
+  const sandbox = sinon.createSandbox();
+  let spawnSpy: sinon.SinonStub;
+
+  beforeEach(() => {
+    const process = mockProcess();
+    spawnSpy = sandbox.stub(shell, 'spawnProcess').returns({
+      command: 'something',
+      finished: true,
+      output: 'hi',
+      process,
+    });
+    sandbox.stub(shell, 'checkIfFinished').resolves();
+  });
+  afterEach(() => {
+    sandbox.restore();
+  });
+
+  describe('put method', () => {
+    it('should invoke `datastore put [item details]`', async () => {
+      await datastore.datastorePut({ appPath: '/some/path', putDetails: '{ "datastore": "datastore", "item": { "id": "1"} }' });
+      sandbox.assert.calledWith(
+        spawnSpy,
+        sinon.match(`datastore put '{ "datastore": "datastore", "item": { "id": "1"} }'`),
+      );
+    });
+  });
+  describe('get method', () => {
+    it('should invoke `datastore get <query>`', async () => {
+      await datastore.datastoreGet({ appPath: '/some/path', getQuery: '{ "datastore": "datastore", "id": "1" }' });
+      sandbox.assert.calledWith(spawnSpy, sinon.match(`datastore get '{ "datastore": "datastore", "id": "1" }'`));
+    });
+  });
+  describe('delete method', () => {
+    it('should invoke `datastore delete <query>`', async () => {
+      await datastore.datastoreDelete({ appPath: '/some/path', deleteQuery: '{ "datastore": "datastore", "id": "1" }' });
+      sandbox.assert.calledWith(spawnSpy, sinon.match(`datastore delete '{ "datastore": "datastore", "id": "1" }'`));
+    });
+  });
+  describe('query method', () => {
+    it('should invoke `datastore query [expression]`', async () => {
+      await datastore.datastoreQuery({ appPath: '/some/path', queryExpression: '{ "datastore": "datastore", "expression": "id = :id", "expression_values": {":id": "1"} }' });
+      sandbox.assert.calledWith(spawnSpy, sinon.match(`datastore query '{ "datastore": "datastore", "expression": "id = :id", "expression_values": {":id": "1"} }'`));
+    });
+  });
+});

packages/cli-test/src/cli/commands/datastore.ts

@@ -0,0 +1,82 @@
+import type { ProjectCommandArguments } from '../../types/commands/common_arguments';
+import { SlackCLIProcess } from '../cli-process';
+
+export interface DatastoreCommandArguments {
+  /** @description datastore get <query> */
+  getQuery: string;
+  /** @description datastore put [item details] */
+  putDetails: string;
+  /** @description datastore query [expression] */
+  queryExpression: string;
+  /** @description datastore delete <query> */
+  deleteQuery: string;
+}
+
+/**
+ * `slack datastore put`
+ * @returns command output
+ */
+export const datastorePut = async function datastorePut(
+  args: ProjectCommandArguments & Pick<DatastoreCommandArguments, 'putDetails'>,
+): Promise<string> {
+  const cmd = new SlackCLIProcess(
+    `datastore put '${args.putDetails}'`,
+    args,
+  );
+  const proc = await cmd.execAsync({
+    cwd: args.appPath,
+  });
+  return proc.output;
+};
+
+/**
+ * `slack datastore get`
+ * @returns command output
+ */
+export const datastoreGet = async function datastoreGet(
+  args: ProjectCommandArguments & Pick<DatastoreCommandArguments, 'getQuery'>,
+): Promise<string> {
+  const cmd = new SlackCLIProcess(`datastore get '${args.getQuery}'`, args);
+  const proc = await cmd.execAsync({
+    cwd: args.appPath,
+  });
+  return proc.output;
+};
+
+/**
+ * `slack datastore delete`
+ * @returns command output
+ */
+export const datastoreDelete = async function datastoreDelete(
+  args: ProjectCommandArguments & Pick<DatastoreCommandArguments, 'deleteQuery'>,
+): Promise<string> {
+  const cmd = new SlackCLIProcess(`datastore delete '${args.deleteQuery}'`, args);
+  const proc = await cmd.execAsync({
+    cwd: args.appPath,
+  });
+  return proc.output;
+};
+
+/**
+ * `slack datastore query`
+ * @returns command output
+ */
+export const datastoreQuery = async function datastoreQuery(
+  args: ProjectCommandArguments & Pick<DatastoreCommandArguments, 'queryExpression'>,
+): Promise<string> {
+  const cmd = new SlackCLIProcess(
+    `datastore query '${args.queryExpression}'`,
+    args,
+  );
+  const proc = await cmd.execAsync({
+    cwd: args.appPath,
+  });
+  return proc.output;
+};
+
+export default {
+  datastorePut,
+  datastoreGet,
+  datastoreDelete,
+  datastoreQuery,
+};