//////////////////////////////////////////////////////////////////////////////// // // Copyright 2006 - 2014, Paul Beckingham, Federico Hernandez. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included // in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL // THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE // SOFTWARE. // // http://www.opensource.org/licenses/mit-license.php // //////////////////////////////////////////////////////////////////////////////// #include // TODO Remove #include #include #include #include #include #include #include #include #include extern Context context; //////////////////////////////////////////////////////////////////////////////// // Const iterator that can be derefenced into a Task by domSource. static Task dummy; Task& contextTask = dummy; //////////////////////////////////////////////////////////////////////////////// bool domSource (const std::string& identifier, Variant& value) { std::string stringValue = context.dom.get (identifier, contextTask); if (stringValue != identifier) { value = Variant (stringValue); return true; } return false; } //////////////////////////////////////////////////////////////////////////////// Filter::Filter () : _startCount (0) , _endCount (0) { } //////////////////////////////////////////////////////////////////////////////// Filter::~Filter () { } //////////////////////////////////////////////////////////////////////////////// // Take an input set of tasks and filter into a subset. void Filter::subset (const std::vector & input, std::vector & output) { context.timer_filter.start (); _startCount = (int) input.size (); if (context.config.getBoolean ("debug")) { Tree* t = context.parser.tree (); if (t) context.debug (t->dump ()); } std::string filterExpr = context.parser.getFilterExpression (); if (filterExpr.length ()) { Eval eval; eval.addSource (namedDates); eval.addSource (domSource); // Debug output from Eval during compilation is useful. During evaluation // it is mostly noise. eval.debug (context.config.getBoolean ("debug")); eval.compileExpression (filterExpr); eval.debug (false); std::vector ::const_iterator task; for (task = input.begin (); task != input.end (); ++task) { // Set up context for any DOM references. contextTask = *task; Variant var; eval.evaluateCompiledExpression (var); if (var.get_bool ()) output.push_back (*task); } } else output = input; _endCount = (int) output.size (); context.debug (format ("Filtered {1} tasks --> {2} tasks [list subset]", _startCount, _endCount)); context.timer_filter.stop (); } //////////////////////////////////////////////////////////////////////////////// // Take the set of all tasks and filter into a subset. void Filter::subset (std::vector & output) { context.timer_filter.start (); if (context.config.getBoolean ("debug")) { Tree* t = context.parser.tree (); if (t) context.debug (t->dump ()); } bool shortcut = false; std::string filterExpr = context.parser.getFilterExpression (); if (filterExpr.length ()) { context.timer_filter.stop (); const std::vector & pending = context.tdb2.pending.get_tasks (); context.timer_filter.start (); _startCount = (int) pending.size (); Eval eval; eval.addSource (namedDates); eval.addSource (domSource); // Debug output from Eval during compilation is useful. During evaluation // it is mostly noise. eval.debug (context.config.getBoolean ("debug")); eval.compileExpression (filterExpr); eval.debug (false); output.clear (); std::vector ::const_iterator task; for (task = pending.begin (); task != pending.end (); ++task) { // Set up context for any DOM references. contextTask = *task; Variant var; eval.evaluateCompiledExpression (var); if (var.get_bool ()) output.push_back (*task); } shortcut = pendingOnly (); if (! shortcut) { context.timer_filter.stop (); const std::vector & completed = context.tdb2.completed.get_tasks (); // TODO Optional context.timer_filter.start (); _startCount += (int) completed.size (); for (task = completed.begin (); task != completed.end (); ++task) { // Set up context for any DOM references. contextTask = *task; Variant var; eval.evaluateCompiledExpression (var); if (var.get_bool ()) output.push_back (*task); } } } else { safety (); context.timer_filter.stop (); const std::vector & pending = context.tdb2.pending.get_tasks (); const std::vector & completed = context.tdb2.completed.get_tasks (); context.timer_filter.start (); std::vector ::const_iterator task; for (task = pending.begin (); task != pending.end (); ++task) output.push_back (*task); for (task = completed.begin (); task != completed.end (); ++task) output.push_back (*task); } _endCount = (int) output.size (); context.debug (format ("Filtered {1} tasks --> {2} tasks [{3}]", _startCount, _endCount, (shortcut ? "pending only" : "all tasks"))); context.timer_filter.stop (); } //////////////////////////////////////////////////////////////////////////////// // If the filter contains the restriction "status:pending", as the first filter // term, then completed.data does not need to be loaded. bool Filter::pendingOnly () { Tree* tree = context.parser.tree (); // If the filter starts with "status:pending", the completed.data does not // need to be accessed.. if (tree->_branches.size () > 0 && tree->_branches[0]->attribute ("name") == "status" && tree->_branches[0]->attribute ("value") == "pending") { context.debug ("Filter::pendingOnly - skipping completed.data (status:pending first)"); return true; } // Shortcut: If the filter contains no 'or' or 'xor' operators, IDs and no UUIDs. int countId = 0; int countUUID = 0; int countOr = 0; int countXor = 0; std::vector ::iterator i; for (i = tree->_branches.begin (); i != tree->_branches.end (); ++i) { if ((*i)->hasTag ("OP")) { if ((*i)->attribute ("canonical") == "or") ++countOr; if ((*i)->attribute ("canonical") == "xor") ++countXor; } else if ((*i)->hasTag ("ID")) ++countId; else if ((*i)->hasTag ("UUID")) ++countUUID; } if (countOr == 0 && countXor == 0 && countUUID == 0 && countId > 0) { context.debug ("Filter::pendingOnly - skipping completed.data (IDs, no OR, no XOR, no UUID)"); return true; } return false; } //////////////////////////////////////////////////////////////////////////////// // Disaster avoidance mechanism. If a WRITECMD has no filter, then it can cause // all tasks to be modified. This is usually not intended. void Filter::safety () { Tree* tree = context.parser.tree (); std::vector ::iterator i; for (i = tree->_branches.begin (); i != tree->_branches.end (); ++i) { if ((*i)->hasTag ("WRITECMD")) { if (context.parser.getFilterExpression () == "") { // If user is willing to be asked, this can be avoided. if (context.config.getBoolean ("confirmation") && confirm (STRING_TASK_SAFETY_VALVE)) return; // Sounds the alarm. throw std::string (STRING_TASK_SAFETY_FAIL); } // Nothing to see here. Move along. return; } } } ////////////////////////////////////////////////////////////////////////////////