mirror of
https://github.com/Foundry376/Mailspring.git
synced 2024-09-23 00:36:50 +08:00
af67597f0b
Summary: Originally, this was going to be a totally independent package, but I wasn't able to isolate the functionality and get it tied in to the delta-stream consumption. Here's how it currently works: - The preferences package has a new tab which allows you to edit mail filters. Filters are saved in a new core store, and a new stock component (ScenarioEditor) renders the editor. The editor takes a set of templates that define a value space, and outputs a valid set of values. - A new MailFilterProcessor takes messages and creates tasks to apply the actions from the MailFiltersStore. - The worker-sync package now uses the MailFilterProcessor to apply filters /before/ it calls didPassivelyReceiveNewModels, so filtrs are applied before any notifications are created. - A new task, ReprocessMailFiltersTask allows you to run filters on all of your existing mail. It leverages the existing TaskQueue architecture to: a) resume where it left off if you quit midway, b) be queryable (for status) from all windows and c) cancelable. The TaskQueue is a bit strange because it runs performLocal and performRemote very differently, and I had to use `performRemote`. (todo refactor soon.) This diff also changes the EditableList a bit to behave like a controlled component and render focused / unfocused states. Test Plan: Run tests, only for actual filter processing atm. Reviewers: juan, evan Reviewed By: evan Differential Revision: https://phab.nylas.com/D2379
51 lines
2.1 KiB
CoffeeScript
51 lines
2.1 KiB
CoffeeScript
QuerySubscriptionPool = require '../../src/flux/models/query-subscription-pool'
|
|
DatabaseStore = require '../../src/flux/stores/database-store'
|
|
Label = require '../../src/flux/models/label'
|
|
|
|
describe "QuerySubscriptionPool", ->
|
|
beforeEach ->
|
|
@query = DatabaseStore.findAll(Label)
|
|
@queryKey = @query.sql()
|
|
QuerySubscriptionPool._subscriptions = {}
|
|
|
|
describe "add", ->
|
|
it "should add a new subscription with the callback", ->
|
|
callback = jasmine.createSpy('callback')
|
|
QuerySubscriptionPool.add(@query, {}, callback)
|
|
expect(QuerySubscriptionPool._subscriptions[@queryKey]).toBeDefined()
|
|
|
|
subscription = QuerySubscriptionPool._subscriptions[@queryKey]
|
|
expect(subscription.hasCallback(callback)).toBe(true)
|
|
|
|
it "should yield database changes to the subscription", ->
|
|
callback = jasmine.createSpy('callback')
|
|
QuerySubscriptionPool.add(@query, {}, callback)
|
|
subscription = QuerySubscriptionPool._subscriptions[@queryKey]
|
|
spyOn(subscription, 'applyChangeRecord')
|
|
|
|
record = {objectType: 'whateves'}
|
|
QuerySubscriptionPool._onChange(record)
|
|
expect(subscription.applyChangeRecord).toHaveBeenCalledWith(record)
|
|
|
|
describe "unsubscribe", ->
|
|
it "should return an unsubscribe method", ->
|
|
expect(QuerySubscriptionPool.add(@query, {}, -> ) instanceof Function).toBe(true)
|
|
|
|
it "should remove the callback from the subscription", ->
|
|
cb = ->
|
|
|
|
unsub = QuerySubscriptionPool.add(@query, {}, cb)
|
|
subscription = QuerySubscriptionPool._subscriptions[@queryKey]
|
|
|
|
expect(subscription.hasCallback(cb)).toBe(true)
|
|
unsub()
|
|
expect(subscription.hasCallback(cb)).toBe(false)
|
|
|
|
it "should wait before removing th subscription to make sure it's not reused", ->
|
|
unsub = QuerySubscriptionPool.add(@query, {}, -> )
|
|
expect(QuerySubscriptionPool._subscriptions[@queryKey]).toBeDefined()
|
|
unsub()
|
|
expect(QuerySubscriptionPool._subscriptions[@queryKey]).toBeDefined()
|
|
advanceClock()
|
|
expect(QuerySubscriptionPool._subscriptions[@queryKey]).toBeUndefined()
|