Duplicate records

src/api/client.ts

@@ -325,4 +325,13 @@ export default class Client {
     }
     return this._workflowExecutions;
   }
+
+  get externalContributions() {
+    if (!this._externalContributions) {
+      // @ts-ignore
+      this._externalContributions = new ExternalContributionsApiClient(this.config.external_contributions_url, this.token);
+    }
+
+    return this._externalContributions;
+  }
 }

src/commands/duplicate-records.ts

@@ -10,27 +10,34 @@ interface Arguments extends CommandArguments {
 
 const command = 'duplicate-records';
 const description = 'Duplicate records into new app';
-const builder: CommandBuilder = (yargs) => yargs
-  .option('source', {
-    required: true,
-    alias: 's',
-    type: 'string',
-    description: 'Form ID to pull records from',
-  })
-  .option('destination', {
-    required: true,
-    alias: 'd',
-    type: 'string',
-    description: 'Form ID to add records to',
-  })
-  .strict(false);
+const builder = (yargs) => {
+  yargs
+    .option('origin', {
+      required: true,
+      alias: 'o',
+      type: 'string',
+      description: 'Form ID to pull records from',
+    })
+    .option('destination', {
+      required: true,
+      alias: 'd',
+      type: 'string',
+      description: 'Form ID to add records to',
+    })
+    .option('sql', {
+      alias: 'sql',
+      type: 'string',
+      description: 'SQL query',
+    })
+    .strict(false);
+};
 
-const handler: CommandHandler<Arguments> = async ({
-  endpoint, token, source, destination,
+const handler = async ({
+  endpoint, token, origin, destination, sql,
 }) => {
   const client = createClient(endpoint, token);
 
-  await duplicateRecords(client, source, destination);
+  await duplicateRecords(client, origin, destination, sql);
 };
 
 export default defineCommand({

src/index.ts

@@ -1,5 +1,5 @@
 #!/usr/bin/env node
-
+// @ts-nocheck
 import path from 'path';
 import yargs from 'yargs';
 import { hideBin } from 'yargs/helpers';

src/shared/api.ts

@@ -123,7 +123,7 @@ export async function fetchHistoryRecords(client: Client, params: any) {
   return records;
 }
 
-export async function fetchRecords(client: Client, params: any) {
+export async function fetchRecords(client: Client, params: any): Promise<object[]> {
   const perPage = 5000;
   const records = [];
 
@@ -152,7 +152,7 @@ export async function fetchRecordsBySQL(
   form: Core.Form,
   sql: string,
   where?: string,
-) {
+): Promise<Core.Record[]> {
   console.log('fetching records by sql', sql, where);
 
   const query = where ? `${sql} WHERE ${where}` : sql;
@@ -407,12 +407,7 @@ export async function download(url, outputFileName) {
   });
 }
 
-export async function duplicateRecordsWithMedia(
-  client: Client,
-  records: Record[],
-  form: Form,
-  comment: string,
-) {
+export async function duplicateRecordsWithMedia(client: Client, records: Object[], form: Form, comment: string) {
   const operations = [];
 
   for (const attrs of records) {