feat: add import bulk/resume commands

command-snapshot.json

@@ -137,6 +137,14 @@
     ],
     "plugin": "@salesforce/plugin-data"
   },
+  {
+    "alias": [],
+    "command": "data:import:bulk",
+    "flagAliases": [],
+    "flagChars": ["a", "f", "o", "s", "w"],
+    "flags": ["api-version", "async", "file", "flags-dir", "json", "line-ending", "sobject", "target-org", "wait"],
+    "plugin": "@salesforce/plugin-data"
+  },
   {
     "alias": [],
     "command": "data:import:legacy:tree",
@@ -155,6 +163,14 @@
     ],
     "plugin": "@salesforce/plugin-data"
   },
+  {
+    "alias": [],
+    "command": "data:import:resume",
+    "flagAliases": [],
+    "flagChars": ["i", "w"],
+    "flags": ["flags-dir", "job-id", "json", "use-most-recent", "wait"],
+    "plugin": "@salesforce/plugin-data"
+  },
   {
     "alias": ["force:data:tree:import", "data:import:beta:tree"],
     "command": "data:import:tree",

messages/data.import.bulk.md

@@ -0,0 +1,74 @@
+# summary
+
+Bulk import records to an org from a CSV file. Uses Bulk API 2.0.
+
+# description
+
+You can use this command to import millions of records to an org from a CSV file.
+
+All the records in the CSV file must be for the same object, you specify the object being imported via the `--sobject` flag.
+
+More info about how to prepare CSV files:
+https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/datafiles_prepare_csv.htm
+
+# examples
+
+- Import Account records from a CSV-formatted file into an org.
+
+  <%= config.bin %> <%= command.id %> --file accounts.csv --sobject Account --wait 10 --target-org my-scratch
+
+- Import asynchronously; the command immediately returns a job ID that you then pass to the "sf data import resume" command:
+
+  <%= config.bin %> <%= command.id %> --file accounts.csv --sobject Account --async --target-org my-scratch
+
+# flags.async.summary
+
+Run the command asynchronously.
+
+# flags.file.summary
+
+CSV file that contains the fields of the object to import.
+
+# flags.sobject.summary
+
+API name of the Salesforce object, either standard or custom, that you want to import to the org.
+
+# flags.wait.summary
+
+Time to wait for the command to finish, in minutes.
+
+# flags.line-ending.summary
+
+Line ending used in the CSV file. Default value on Windows is `CRLF`; on macOS and Linux it's `LR`.
+
+# export.resume
+
+Run "sf data import resume --job-id %s" to resume the operation.
+
+# error.timeout
+
+The operation timed out after %s minutes.
+
+Run "sf data import resume --job-id %s" to resume it.
+
+# error.failedRecordDetails
+
+Job finished being processed but failed to import %s records.
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"
+
+# error.jobFailed
+
+Job failed to be processed due to:
+%s
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"
+
+# error.jobAborted
+
+Job has been aborted.
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"

messages/data.import.resume.md

@@ -0,0 +1,57 @@
+# summary
+
+Resume a bulk import job that you previously started. Uses Bulk API 2.0.
+
+# description
+
+The command uses the job ID returned by the "sf data import bulk" command or the most recently-run bulk import job.
+
+# examples
+
+- Resume a bulk import job from your default org using an ID:
+
+  <%= config.bin %> <%= command.id %> --job-id 750xx000000005sAAA
+
+- Resume the most recently run bulk import job for an org with alias my-scratch:
+
+  <%= config.bin %> <%= command.id %> --use-most-recent --target-org my-scratch
+
+# flags.use-most-recent.summary
+
+Use the job ID of the bulk import job that was most recently run.
+
+# flags.job-id.summary
+
+Job ID of the bulk import.
+
+# flags.wait.summary
+
+Time to wait for the command to finish, in minutes.
+
+# error.failedRecordDetails
+
+Job finished being processed but failed to import %s records.
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"
+
+# error.timeout
+
+The operation timed out after %s minutes.
+
+Try re-running "sf data import resume --job-id %s" with a bigger wait time.
+
+# error.jobFailed
+
+Job failed to be processed due to:
+%s
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"
+
+# error.jobAborted
+
+Job has been aborted.
+
+To review the details of this job, run:
+sf org open --target-org %s --path "/lightning/setup/AsyncApiJobStatus/page?address=%2F%s"

package.json

@@ -60,7 +60,8 @@
             "description": "Get a single record."
           },
           "import": {
-            "description": "Import data to your org."
+            "description": "Import data to your org.",
+            "external": true
           },
           "query": {
             "description": "Query records."

src/bulkDataRequestCache.ts

@@ -188,6 +188,28 @@ export class BulkUpsertRequestCache extends BulkDataRequestCache {
   }
 }
 
+export class BulkImportRequestCache extends BulkDataRequestCache {
+  public static getDefaultOptions(): TTLConfig.Options {
+    return {
+      isGlobal: true,
+      isState: true,
+      filename: BulkImportRequestCache.getFileName(),
+      stateFolder: Global.SF_STATE_FOLDER,
+      ttl: Duration.days(7),
+    };
+  }
+
+  public static getFileName(): string {
+    return 'bulk-data-import-cache.json';
+  }
+
+  public static async unset(key: string): Promise<void> {
+    const cache = await BulkImportRequestCache.create();
+    cache.unset(key);
+    await cache.write();
+  }
+}
+
 export class BulkExportRequestCache extends TTLConfig<TTLConfig.Options, BulkExportCacheConfig> {
   public static getDefaultOptions(): TTLConfig.Options {
     return {