From a4cd689697c764b61c808d306c3f1c66f0c03ab8 Mon Sep 17 00:00:00 2001 From: Bryan Ashby Date: Sat, 2 Jan 2016 18:35:13 -0700 Subject: [PATCH] Updated new scan WIP --- core/new_scan.js | 93 ++++++++++++++++++++++++++++++++++++------------ 1 file changed, 71 insertions(+), 22 deletions(-) diff --git a/core/new_scan.js b/core/new_scan.js index 222abce9..cc855b34 100644 --- a/core/new_scan.js +++ b/core/new_scan.js @@ -5,6 +5,7 @@ var msgArea = require('./message_area.js'); var Message = require('./message.js'); var MenuModule = require('./menu_module.js').MenuModule; +var ViewController = require('../core/view_controller.js').ViewController; var async = require('async'); @@ -21,8 +22,8 @@ exports.getModule = NewScanModule; * * Update message ID when reading (this should be working!) * * New scan all areas * * User configurable new scan: Area selection (avail from messages area) - * - * + * * Add status TL/VM (either/both should update if present) + * * */ @@ -33,14 +34,36 @@ function NewScanModule(options) { var self = this; var config = this.menuConfig.config; - this.currentStep = 'privateMail'; + this.currentStep = 'messageAreas'; + this.currentScanAux = 0; // Message.WellKnownAreaNames.Private - this.newScanMessageArea = function(areaName, cb) { + + this.newScanMessageArea = function(cb) { + var availMsgAreas = msgArea.getAvailableMessageAreas( { includePrivate : true } ); + var currentArea = availMsgAreas[self.currentScanAux]; + + // + // Scan and update index until we find something. If results are found, + // we'll goto the list module & show them. + // async.waterfall( [ + function checkAndUpdateIndex(callback) { + // Advance to next area if possible + if(availMsgAreas.length >= self.currentScanAux + 1) { + self.currentScanAux += 1; + callback(null); + } else { + callback(new Error('No more areas')); + } + }, + function updateStatus(callback) { + // :TODO: Update status text + callback(null); + }, function newScanAreaAndGetMessages(callback) { msgArea.getNewMessagesInAreaForUser( - self.client.user.userId, areaName, function msgs(err, msgList) { + self.client.user.userId, currentArea.name, function msgs(err, msgList) { callback(err, msgList); } ); @@ -49,52 +72,78 @@ function NewScanModule(options) { if(msgList && msgList.length > 0) { var nextModuleOpts = { extraArgs: { - messageAreaName : areaName, + messageAreaName : currentArea.name, messageList : msgList, } }; self.gotoMenu(config.newScanMessageList || 'newScanMessageList', nextModuleOpts); } else { - callback(null); + self.newScanMessageArea(cb); } } ], - function complete(err) { - cb(err); - } + cb ); }; + } require('util').inherits(NewScanModule, MenuModule); NewScanModule.prototype.getSaveState = function() { return { - currentStep : this.currentStep, + currentStep : this.currentStep, + currentScanAux : this.currentScanAux, }; }; NewScanModule.prototype.restoreSavedState = function(savedState) { - this.currentStep = savedState.currentStep; + this.currentStep = savedState.currentStep; + this.currentScanAux = savedState.currentScanAux; }; NewScanModule.prototype.mciReady = function(mciData, cb) { - var self = this; + var self = this; + var vc = self.viewControllers.allViews = new ViewController( { client : self.client } ); // :TODO: display scan step/etc. - switch(this.currentStep) { - case 'privateMail' : - self.currentStep = 'finished'; - self.newScanMessageArea(Message.WellKnownAreaNames.Private, cb); - break; - - default : - cb(null); - } + async.series( + [ + function callParentMciReady(callback) { + NewScanModule.super_.prototype.mciReady.call(self, mciData, callback); + }, + function loadFromConfig(callback) { + var loadOpts = { + callingMenu : self, + mciMap : mciData.menu, + noInput : true, + }; + vc.loadFromMenuConfig(loadOpts, callback); + }, + function performCurrentStepScan(callback) { + switch(self.currentStep) { + case 'messageAreas' : + self.newScanMessageArea(function scanComplete(err) { + callback(null); // finished + }); + break; + + default : + callback(null); + } + } + ], + function complete(err) { + if(err) { + self.client.log.error( { error : err.toString() }, 'Error during new scan'); + } + cb(err); + } + ); }; /*