+static bool display_job_parameters(UAContext *ua, JCR *jcr, JOB *job, const char *verify_list,
+ char *jid, const char *replace, char *client_name)
+{
+ Dmsg1(800, "JobType=%c\n", jcr->get_JobType());
+ switch (jcr->get_JobType()) {
+ char ec1[30];
+ char dt[MAX_TIME_LENGTH];
+ case JT_ADMIN:
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ ua->send_msg(_("Run %s job\n"
+ "JobName: %s\n"
+ "FileSet: %s\n"
+ "Client: %s\n"
+ "Storage: %s\n"
+ "When: %s\n"
+ "Priority: %d\n"),
+ _("Admin"),
+ job->name(),
+ jcr->fileset->name(),
+ NPRT(jcr->client->name()),
+ jcr->wstore?jcr->wstore->name():"*None*",
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->JobPriority);
+ jcr->set_JobLevel(L_FULL);
+ break;
+ case JT_BACKUP:
+ case JT_VERIFY:
+ if (jcr->get_JobType() == JT_BACKUP) {
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ ua->send_msg(_("Run %s job\n"
+ "JobName: %s\n"
+ "Level: %s\n"
+ "Client: %s\n"
+ "FileSet: %s\n"
+ "Pool: %s (From %s)\n"
+ "Storage: %s (From %s)\n"
+ "When: %s\n"
+ "Priority: %d\n"
+ "%s%s%s"),
+ _("Backup"),
+ job->name(),
+ level_to_str(jcr->get_JobLevel()),
+ jcr->client->name(),
+ jcr->fileset->name(),
+ NPRT(jcr->pool->name()), jcr->pool_source,
+ jcr->wstore?jcr->wstore->name():"*None*", jcr->wstore_source,
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->JobPriority,
+ jcr->plugin_options?"Plugin Options: ":"",
+ jcr->plugin_options?jcr->plugin_options:"",
+ jcr->plugin_options?"\n":"");
+ } else { /* JT_VERIFY */
+ const char *Name;
+ if (jcr->verify_job) {
+ Name = jcr->verify_job->name();
+ } else {
+ Name = "";
+ }
+ if (!verify_list) {
+ verify_list = job->WriteVerifyList;
+ }
+ if (!verify_list) {
+ verify_list = "";
+ }
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ ua->send_msg(_("Run %s job\n"
+ "JobName: %s\n"
+ "Level: %s\n"
+ "Client: %s\n"
+ "FileSet: %s\n"
+ "Pool: %s (From %s)\n"
+ "Storage: %s (From %s)\n"
+ "Verify Job: %s\n"
+ "Verify List: %s\n"
+ "When: %s\n"
+ "Priority: %d\n"),
+ _("Verify"),
+ job->name(),
+ level_to_str(jcr->get_JobLevel()),
+ jcr->client->name(),
+ jcr->fileset->name(),
+ NPRT(jcr->pool->name()), jcr->pool_source,
+ jcr->rstore->name(), jcr->rstore_source,
+ Name,
+ verify_list,
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->JobPriority);
+ }
+ break;
+ case JT_RESTORE:
+ if (jcr->RestoreJobId == 0 && !jcr->RestoreBootstrap) {
+ if (jid) {
+ jcr->RestoreJobId = str_to_int64(jid);
+ } else {
+ if (!get_pint(ua, _("Please enter a JobId for restore: "))) {
+ return false;
+ }
+ jcr->RestoreJobId = ua->int64_val;
+ }
+ }
+ jcr->set_JobLevel(L_FULL); /* default level */
+ Dmsg1(800, "JobId to restore=%d\n", jcr->RestoreJobId);
+ if (jcr->RestoreJobId == 0) {
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ /* RegexWhere is take before RestoreWhere */
+ if (jcr->RegexWhere || (job->RegexWhere && !jcr->where)) {
+ ua->send_msg(_("Run Restore job\n"
+ "JobName: f%s\n"
+ "Bootstrap: %s\n"
+ "RegexWhere: %s\n"
+ "Replace: %s\n"
+ "FileSet: %s\n"
+ "Backup Client: %s\n"
+ "Restore Client: %s\n"
+ "Storage: %s\n"
+ "When: %s\n"
+ "Catalog: %s\n"
+ "Priority: %d\n"
+ "Plugin Options: %s\n"),
+ job->name(),
+ NPRT(jcr->RestoreBootstrap),
+ jcr->RegexWhere?jcr->RegexWhere:job->RegexWhere,
+ replace,
+ jcr->fileset->name(),
+ client_name,
+ jcr->client->name(),
+ jcr->rstore->name(),
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->catalog->name(),
+ jcr->JobPriority,
+ NPRT(jcr->plugin_options));
+
+ } else {
+ ua->send_msg(_("Run Restore job\n"
+ "JobName: %s\n"
+ "Bootstrap: %s\n"
+ "Where: %s\n"
+ "Replace: %s\n"
+ "FileSet: %s\n"
+ "Backup Client: %s\n"
+ "Restore Client: %s\n"
+ "Storage: %s\n"
+ "When: %s\n"
+ "Catalog: %s\n"
+ "Priority: %d\n"
+ "Plugin Options: %s\n"),
+ job->name(),
+ NPRT(jcr->RestoreBootstrap),
+ jcr->where?jcr->where:NPRT(job->RestoreWhere),
+ replace,
+ jcr->fileset->name(),
+ client_name,
+ jcr->client->name(),
+ jcr->rstore->name(),
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->catalog->name(),
+ jcr->JobPriority,
+ NPRT(jcr->plugin_options));
+ }
+
+ } else {
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ ua->send_msg(_("Run Restore job\n"
+ "JobName: %s\n"
+ "Bootstrap: %s\n"),
+ job->name(),
+ NPRT(jcr->RestoreBootstrap));
+
+ /* RegexWhere is take before RestoreWhere */
+ if (jcr->RegexWhere || (job->RegexWhere && !jcr->where)) {
+ ua->send_msg(_("RegexWhere: %s\n"),
+ jcr->RegexWhere?jcr->RegexWhere:job->RegexWhere);
+ } else {
+ ua->send_msg(_("Where: %s\n"),
+ jcr->where?jcr->where:NPRT(job->RestoreWhere));
+ }
+
+ ua->send_msg(_("Replace: %s\n"
+ "Client: %s\n"
+ "Storage: %s\n"
+ "JobId: %s\n"
+ "When: %s\n"
+ "Catalog: %s\n"
+ "Priority: %d\n"
+ "Plugin Options: %s\n"),
+ replace,
+ jcr->client->name(),
+ jcr->rstore->name(),
+ jcr->RestoreJobId==0?"*None*":edit_uint64(jcr->RestoreJobId, ec1),
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->catalog->name(),
+ jcr->JobPriority,
+ NPRT(jcr->plugin_options));
+ }
+ break;
+ case JT_COPY:
+ case JT_MIGRATE:
+ char *prt_type;
+ if (jcr->get_JobType() == JT_COPY) {
+ prt_type = _("Run Copy job\n");
+ } else {
+ prt_type = _("Run Migration job\n");
+ }
+ jcr->set_JobLevel(L_FULL); /* default level */
+ if (ua->api) ua->signal(BNET_RUN_CMD);
+ ua->send_msg("%s"
+ "JobName: %s\n"
+ "Bootstrap: %s\n"
+ "Client: %s\n"
+ "FileSet: %s\n"
+ "Pool: %s (From %s)\n"
+ "Read Storage: %s (From %s)\n"
+ "Write Storage: %s (From %s)\n"
+ "JobId: %s\n"
+ "When: %s\n"
+ "Catalog: %s\n"
+ "Priority: %d\n",
+ prt_type,
+ job->name(),
+ NPRT(jcr->RestoreBootstrap),
+ jcr->client->name(),
+ jcr->fileset->name(),
+ NPRT(jcr->pool->name()), jcr->pool_source,
+ jcr->rstore->name(), jcr->rstore_source,
+ jcr->wstore?jcr->wstore->name():"*None*", jcr->wstore_source,
+ jcr->MigrateJobId==0?"*None*":edit_uint64(jcr->MigrateJobId, ec1),
+ bstrutime(dt, sizeof(dt), jcr->sched_time),
+ jcr->catalog->name(),
+ jcr->JobPriority);
+ break;
+ default:
+ ua->error_msg(_("Unknown Job Type=%d\n"), jcr->get_JobType());
+ return false;
+ }
+ return true;
+}
+
+
+static bool scan_command_line_arguments(UAContext *ua, run_ctx &rc)
+{
+ bool kw_ok;
+ int i, j;
+ static const char *kw[] = { /* command line arguments */
+ "job", /* Used in a switch() */
+ "jobid", /* 1 */
+ "client", /* 2 */
+ "fd",
+ "fileset", /* 4 */
+ "level", /* 5 */
+ "storage", /* 6 */
+ "sd", /* 7 */
+ "regexwhere", /* 8 where string as a bregexp */
+ "where", /* 9 */
+ "bootstrap", /* 10 */
+ "replace", /* 11 */
+ "when", /* 12 */
+ "priority", /* 13 */
+ "yes", /* 14 -- if you change this change YES_POS too */
+ "verifyjob", /* 15 */
+ "files", /* 16 number of files to restore */
+ "catalog", /* 17 override catalog */
+ "since", /* 18 since */
+ "cloned", /* 19 cloned */
+ "verifylist", /* 20 verify output list */
+ "migrationjob", /* 21 migration job name */
+ "pool", /* 22 */
+ "backupclient", /* 23 */
+ "restoreclient", /* 24 */
+ "pluginoptions", /* 25 */
+ "spooldata", /* 26 */
+ NULL};
+
+#define YES_POS 14
+
+ rc.catalog_name = NULL;
+ rc.job_name = NULL;
+ rc.pool_name = NULL;
+ rc.store_name = NULL;
+ rc.client_name = NULL;
+ rc.restore_client_name = NULL;
+ rc.fileset_name = NULL;
+ rc.verify_job_name = NULL;
+ rc.previous_job_name = NULL;
+ rc.spool_data_set = 0;
+
+
+ for (i=1; i<ua->argc; i++) {
+ Dmsg2(800, "Doing arg %d = %s\n", i, ua->argk[i]);
+ kw_ok = false;
+ /* Keep looking until we find a good keyword */
+ for (j=0; !kw_ok && kw[j]; j++) {
+ if (strcasecmp(ua->argk[i], kw[j]) == 0) {
+ /* Note, yes and run have no value, so do not fail */
+ if (!ua->argv[i] && j != YES_POS /*yes*/) {
+ ua->send_msg(_("Value missing for keyword %s\n"), ua->argk[i]);
+ return false;
+ }
+ Dmsg1(800, "Got keyword=%s\n", NPRT(kw[j]));
+ switch (j) {
+ case 0: /* job */
+ if (rc.job_name) {
+ ua->send_msg(_("Job name specified twice.\n"));
+ return false;
+ }
+ rc.job_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 1: /* JobId */
+ if (rc.jid && !rc.mod) {
+ ua->send_msg(_("JobId specified twice.\n"));
+ return false;
+ }
+ rc.jid = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 2: /* client */
+ case 3: /* fd */
+ if (rc.client_name) {
+ ua->send_msg(_("Client specified twice.\n"));
+ return false;
+ }
+ rc.client_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 4: /* fileset */
+ if (rc.fileset_name) {
+ ua->send_msg(_("FileSet specified twice.\n"));
+ return false;
+ }
+ rc.fileset_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 5: /* level */
+ if (rc.level_name) {
+ ua->send_msg(_("Level specified twice.\n"));
+ return false;
+ }
+ rc.level_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 6: /* storage */
+ case 7: /* sd */
+ if (rc.store_name) {
+ ua->send_msg(_("Storage specified twice.\n"));
+ return false;
+ }
+ rc.store_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 8: /* regexwhere */
+ if ((rc.regexwhere || rc.where) && !rc.mod) {
+ ua->send_msg(_("RegexWhere or Where specified twice.\n"));
+ return false;
+ }
+ rc.regexwhere = ua->argv[i];
+ if (!acl_access_ok(ua, Where_ACL, rc.regexwhere)) {
+ ua->send_msg(_("No authorization for \"regexwhere\" specification.\n"));
+ return false;
+ }
+ kw_ok = true;
+ break;
+ case 9: /* where */
+ if ((rc.where || rc.regexwhere) && !rc.mod) {
+ ua->send_msg(_("Where or RegexWhere specified twice.\n"));
+ return false;
+ }
+ rc.where = ua->argv[i];
+ if (!acl_access_ok(ua, Where_ACL, rc.where)) {
+ ua->send_msg(_("No authoriztion for \"where\" specification.\n"));
+ return false;
+ }
+ kw_ok = true;
+ break;
+ case 10: /* bootstrap */
+ if (rc.bootstrap && !rc.mod) {
+ ua->send_msg(_("Bootstrap specified twice.\n"));
+ return false;
+ }
+ rc.bootstrap = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 11: /* replace */
+ if (rc.replace && !rc.mod) {
+ ua->send_msg(_("Replace specified twice.\n"));
+ return false;
+ }
+ rc.replace = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 12: /* When */
+ if (rc.when && !rc.mod) {
+ ua->send_msg(_("When specified twice.\n"));
+ return false;
+ }
+ rc.when = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 13: /* Priority */
+ if (rc.Priority && !rc.mod) {
+ ua->send_msg(_("Priority specified twice.\n"));
+ return false;
+ }
+ rc.Priority = atoi(ua->argv[i]);
+ if (rc.Priority <= 0) {
+ ua->send_msg(_("Priority must be positive nonzero setting it to 10.\n"));
+ rc.Priority = 10;
+ }
+ kw_ok = true;
+ break;
+ case 14: /* yes */
+ kw_ok = true;
+ break;
+ case 15: /* Verify Job */
+ if (rc.verify_job_name) {
+ ua->send_msg(_("Verify Job specified twice.\n"));
+ return false;
+ }
+ rc.verify_job_name = ua->argv[i];
+ kw_ok = true;
+ break;
+ case 16: /* files */
+ rc.files = atoi(ua->argv[i]);
+ kw_ok = true;
+ break;
+
+ case 17: /* catalog */
+ rc.catalog_name = ua->argv[i];
+ kw_ok = true;
+ break;
+
+ case 18: /* since */
+ rc.since = ua->argv[i];
+ kw_ok = true;
+ break;
+
+ case 19: /* cloned */
+ rc. cloned = true;
+ kw_ok = true;
+ break;