| Index: messageResponder.js |
| =================================================================== |
| --- a/messageResponder.js |
| +++ b/messageResponder.js |
| @@ -30,6 +30,8 @@ |
| var Filter = filterClasses.Filter; |
| var BlockingFilter = filterClasses.BlockingFilter; |
| var Synchronizer = require("synchronizer").Synchronizer; |
| + var parseFilters = require("filterValidation").parseFilters; |
| + var parseFilter = require("filterValidation").parseFilter; |
| var subscriptionClasses = require("subscriptionClasses"); |
| var Subscription = subscriptionClasses.Subscription; |
| @@ -55,6 +57,23 @@ |
| "subscription": "subscriptions.listen" |
| }; |
| + function sendMessage(type, action, args, page) |
| + { |
| + var pages = page ? [page] : changeListeners.keys(); |
| + for (var i = 0; i < pages.length; i++) |
| + { |
| + var filters = changeListeners.get(pages[i]); |
| + if (filters[type] && filters[type].indexOf(action) >= 0) |
| + { |
| + pages[i].sendMessage({ |
| + type: messageTypes[type], |
| + action: action, |
| + args: args |
| + }); |
| + } |
| + } |
| + } |
| + |
| function onFilterChange(action) |
| { |
| if (action == "load") |
| @@ -85,21 +104,8 @@ |
| else |
| return arg; |
| }); |
| - |
| - var pages = changeListeners.keys(); |
| - for (var i = 0; i < pages.length; i++) |
| - { |
| - var filters = changeListeners.get(pages[i]); |
| - if (filters[type] && filters[type].indexOf(action) >= 0) |
| - { |
| - pages[i].sendMessage({ |
| - type: messageTypes[type], |
| - action: action, |
| - args: args |
| - }); |
| - } |
| - } |
| - }; |
| + sendMessage(type, action, args); |
| + } |
| global.ext.onMessage.addListener(function(message, sender, callback) |
| { |
| @@ -195,12 +201,58 @@ |
| callback(subscription.filters.map(convertFilter)); |
| break; |
| + case "filters.importRaw": |
| + var result = parseFilters(message.text); |
| + var errors = result.errors.filter(function(error) |
| + { |
| + return error.type != "unexpected-filter-list-header"; |
| + }); |
| + |
| + if (errors.length > 0) |
| + { |
| + sendMessage("app", "error", errors, sender.page); |
| + return; |
| + } |
| + |
| + var seenFilter = Object.create(null); |
| + for (var i = 0; i < result.filters.length; i++) |
| + { |
| + var filter = result.filters[i]; |
| + FilterStorage.addFilter(filter); |
| + seenFilter[filter.text] = null; |
| + } |
| + |
| + for (var i = 0; i < FilterStorage.subscriptions.length; i++) |
| + { |
| + var subscription = FilterStorage.subscriptions[i]; |
| + if (!(subscription instanceof SpecialSubscription)) |
| + continue; |
| + |
| + var filters = subscription.filters.slice(); |
| + for (var j = 0; j < filters.length; j++) |
| + { |
| + var filter = filters[j]; |
| + if (/^@@\|\|([^\/:]+)\^\$document$/.test(filter.text)) |
| + continue; |
| + |
| + if (!(filter.text in seenFilter)) |
| + FilterStorage.removeFilter(filter); |
| + } |
| + } |
| + break; |
| case "filters.listen": |
| if (message.filter) |
| listenerFilters.filter = message.filter; |
| else |
| delete listenerFilters.filter; |
| break; |
| + case "filters.parse": |
|
Sebastian Noack
2015/07/14 11:57:24
IMO this should be renamed to "filters.add", repla
saroyanm
2015/07/14 13:22:59
Done.
|
| + var result = parseFilter(message.text); |
| + if (result.error) |
| + sendMessage("app", "error", [result.error.toString()], sender.page); |
| + else |
| + FilterStorage.addFilter(result.filter); |
| + break; |
| case "filters.remove": |
| var filter = Filter.fromText(message.text); |
| var subscription = null; |