mirror of
https://github.com/Foundry376/Mailspring.git
synced 2024-09-22 16:26:08 +08:00
98ca7f15bd
Summary: Fixes T3568 The composer windows had the wrong cache in their `ContactStore`s. Since it's VERY expensive to repopulate a ContactStore's cache, we now have a `WindowBridge` that allow you to, with a Promise, invoke methods on the main window instead. (Still need to fix some tests) Test Plan: Fixed tests Reviewers: dillon, bengotow Reviewed By: dillon, bengotow Maniphest Tasks: T3568 Differential Revision: https://phab.nylas.com/D2045
120 lines
3 KiB
CoffeeScript
120 lines
3 KiB
CoffeeScript
Reflux = require 'reflux'
|
|
{Actions,
|
|
Contact,
|
|
Thread,
|
|
DatabaseStore,
|
|
AccountStore,
|
|
ContactStore} = require 'nylas-exports'
|
|
_ = require 'underscore'
|
|
|
|
# Stores should closely match the needs of a particular part of the front end.
|
|
# For example, we might create a "MessageStore" that observes this store
|
|
# for changes in selectedThread, "DatabaseStore" for changes to the underlying database,
|
|
# and vends up the array used for that view.
|
|
|
|
SearchSuggestionStore = Reflux.createStore
|
|
init: ->
|
|
@_query = ""
|
|
@_committedQuery = ""
|
|
@_clearResults()
|
|
|
|
@listenTo Actions.searchQueryChanged, @onSearchQueryChanged
|
|
@listenTo Actions.searchQueryCommitted, @onSearchQueryCommitted
|
|
@listenTo Actions.searchBlurred, @onSearchBlurred
|
|
|
|
onSearchQueryChanged: (query) ->
|
|
@_query = query
|
|
@_rebuildResults()
|
|
|
|
onSearchQueryCommitted: (query) ->
|
|
@_query = query
|
|
@_committedQuery = query
|
|
@_clearResults()
|
|
@trigger()
|
|
|
|
onSearchBlurred: ->
|
|
@_clearResults()
|
|
@trigger()
|
|
|
|
_clearResults: ->
|
|
@_threadResults = null
|
|
@_contactResults = null
|
|
@_suggestions = []
|
|
|
|
_rebuildResults: ->
|
|
{key, val} = @queryKeyAndVal()
|
|
unless key and val
|
|
@_clearResults()
|
|
@trigger(@)
|
|
return
|
|
|
|
ContactStore.searchContacts(val, limit:10).then (results) =>
|
|
@_contactResults = results
|
|
@_rebuildThreadResults()
|
|
@_compileSuggestions()
|
|
|
|
_rebuildThreadResults: ->
|
|
{key, val} = @queryKeyAndVal()
|
|
return @_threadResults = [] unless val
|
|
|
|
# Don't update thread results if a previous query is still running, it'll
|
|
# just make performance even worse. When the old result comes in, re-run
|
|
return if @_threadQueryInFlight
|
|
|
|
@_threadQueryInFlight = true
|
|
DatabaseStore.findAll(Thread)
|
|
.where(Thread.attributes.subject.like(val))
|
|
.where(Thread.attributes.accountId.equal(AccountStore.current().id))
|
|
.order(Thread.attributes.lastMessageReceivedTimestamp.descending())
|
|
.limit(4)
|
|
.then (results) =>
|
|
@_threadQueryInFlight = false
|
|
if val is @queryKeyAndVal().val
|
|
@_threadResults = results
|
|
@_compileSuggestions()
|
|
else
|
|
@_rebuildThreadResults()
|
|
|
|
_compileSuggestions: ->
|
|
{key, val} = @queryKeyAndVal()
|
|
return unless key and val
|
|
|
|
@_suggestions = []
|
|
@_suggestions.push
|
|
label: "Message Contains: #{val}"
|
|
value: [{"all": val}]
|
|
|
|
if @_threadResults?.length
|
|
@_suggestions.push
|
|
divider: 'Threads'
|
|
_.each @_threadResults, (thread) =>
|
|
@_suggestions.push({thread: thread})
|
|
|
|
if @_contactResults?.length
|
|
@_suggestions.push
|
|
divider: 'People'
|
|
_.each @_contactResults, (contact) =>
|
|
@_suggestions.push
|
|
contact: contact
|
|
value: [{"all": contact.email}]
|
|
|
|
@trigger(@)
|
|
|
|
# Exposed Data
|
|
|
|
query: -> @_query
|
|
|
|
queryKeyAndVal: ->
|
|
return {} unless @_query and @_query.length > 0
|
|
term = @_query[0]
|
|
key = Object.keys(term)[0]
|
|
val = term[key]
|
|
{key, val}
|
|
|
|
committedQuery: -> @_committedQuery
|
|
|
|
suggestions: ->
|
|
@_suggestions
|
|
|
|
module.exports = SearchSuggestionStore
|