fix commander usage

Author: tmacro

libV2/tasks/BaseTask.js

@@ -117,18 +117,20 @@ class BaseTask extends Process {
     }
 
     get schedule() {
-        if (this._program.now) {
+        const opts = this._program.opts();
+        if (opts.now) {
             return Now;
         }
-        if (this._program.schedule) {
-            return this._program.schedule;
+        if (opts.schedule) {
+            return opts.schedule;
         }
         return this._defaultSchedule;
     }
 
     get lag() {
-        if (this._program.lag !== undefined) {
-            return this._program.lag;
+        const opts = this._program.opts();
+        if (opts.lag !== undefined) {
+            return opts.lag;
         }
         return this._defaultLag;
     }

libV2/tasks/DiskUsage.js

@@ -131,15 +131,15 @@ class MonitorDiskUsage extends BaseTask {
     }
 
     get isLeader() {
-        return this._program.leader !== undefined;
+        return this._program.opts().leader !== undefined;
     }
 
     get isManualUnlock() {
-        return this._program.unlock !== undefined;
+        return this._program.opts().unlock !== undefined;
     }
 
     get isManualLock() {
-        return this._program.lock !== undefined;
+        return this._program.opts().lock !== undefined;
     }
 
     async _getUsage(path) {

libV2/tasks/ManualAdjust.js

@@ -26,9 +26,10 @@ class ManualAdjust extends BaseTask {
     }
 
     async _start() {
+        const opts = this._program.opts();
         this._utapiClient = new UtapiClient({
-            host: this._program.host,
-            port: this._program.port,
+            host: opts.host,
+            port: opts.port,
             disableRetryCache: true,
         });
         await super._start();
@@ -42,35 +43,36 @@ class ManualAdjust extends BaseTask {
     async _execute() {
         const timestamp = Date.now();
 
-        const objectDelta = this._program.objects;
-        const sizeDelta = this._program.storage;
+        const opts = this._program.opts();
+        const objectDelta = opts.objects;
+        const sizeDelta = opts.storage;
 
-        if (!this._program.bucket.length && !this._program.account.length && !this._program.user.length) {
+        if (!opts.bucket.length && !opts.account.length && !opts.user.length) {
             throw Error('You must provided at least one of --bucket, --account or --user');
         }
 
         logger.info('writing adjustments');
-        if (this._program.bucket.length) {
+        if (opts.bucket.length) {
             logger.info('adjusting buckets');
             await async.eachSeries(
-                this._program.bucket,
+                opts.bucket,
                 async bucket => this._pushAdjustmentMetric({
                     bucket, objectDelta, sizeDelta, timestamp,
                 }),
             );
         }
 
-        if (this._program.account.length) {
+        if (opts.account.length) {
             logger.info('adjusting accounts');
             await async.eachSeries(
-                this._program.account,
+                opts.account,
                 async account => this._pushAdjustmentMetric({
                     account, objectDelta, sizeDelta, timestamp,
                 }),
             );
         }
 
-        if (this._program.user.length) {
+        if (opts.user.length) {
             logger.info('adjusting users');
             await async.eachSeries(
                 this._program.user,

libV2/tasks/Reindex.js

@@ -158,8 +158,9 @@ class ReindexTask extends BaseTask {
     }
 
     get targetBuckets() {
-        if (this._program.bucket.length) {
-            return this._program.bucket.map(name => ({ name }));
+        const opts = this._program.opts();
+        if (opts.bucket.length) {
+            return opts.bucket.map(name => ({ name }));
         }
         return metadata.listBuckets();
     }