Mailspring/internal_packages/thread-search/lib/search-store.coffee
Juan Tejada 3716706833 feat(thread-search): Add spinner to indicate search in progress
Summary:
- This diff also restructures the search package in a few ways:
  - Rename package to `thread-search` instead of `search-bar`
  - Move SearchQuerySubscription and SearchMailboxPerspective inside
  package. This allows SearchQuerySubscription to have access to
  SearchActions in a clean way and keeps all of the search related code
  in 1 package
  - Remove SearchMailboxPerspetcive from mailbox-perspective.coffee
- Adds temporary spinner while we get a new design for it

Test Plan: - TODO

Reviewers: evan, bengotow

Reviewed By: bengotow

Differential Revision: https://phab.nylas.com/D2868
2016-04-10 16:20:26 -07:00

149 lines
4.4 KiB
CoffeeScript

_ = require 'underscore'
NylasStore = require 'nylas-store'
{Thread,
Contact,
Actions,
ContactStore,
AccountStore,
DatabaseStore,
FocusedPerspectiveStore} = require 'nylas-exports'
SearchActions = require './search-actions'
SearchMailboxPerspective = require './search-mailbox-perspective'
# 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.
class SearchStore extends NylasStore
constructor: ->
@_searchQuery = FocusedPerspectiveStore.current().searchQuery ? ""
@_searchSuggestionsVersion = 1
@_isSearching = false
@_clearResults()
@listenTo FocusedPerspectiveStore, @_onPerspectiveChanged
@listenTo SearchActions.querySubmitted, @_onQuerySubmitted
@listenTo SearchActions.queryChanged, @_onQueryChanged
@listenTo SearchActions.searchBlurred, @_onSearchBlurred
@listenTo SearchActions.searchCompleted, @_onSearchCompleted
query: =>
@_searchQuery
queryPopulated: =>
@_searchQuery and @_searchQuery.trim().length > 0
suggestions: =>
@_suggestions
isSearching: =>
@_isSearching
_onSearchCompleted: =>
@_isSearching = false
@trigger()
_onPerspectiveChanged: =>
@_searchQuery = FocusedPerspectiveStore.current().searchQuery ? ""
@trigger()
_onQueryChanged: (query) =>
@_searchQuery = query
@_compileResults()
_.defer => @_rebuildResults()
_onQuerySubmitted: (query) =>
@_searchQuery = query
current = FocusedPerspectiveStore.current()
if @queryPopulated()
Actions.recordUserEvent("Commit Search Query", {})
@_isSearching = true
@_perspectiveBeforeSearch ?= current
next = new SearchMailboxPerspective(current.accountIds, @_searchQuery.trim())
Actions.focusMailboxPerspective(next)
else if current instanceof SearchMailboxPerspective
if @_perspectiveBeforeSearch
Actions.focusMailboxPerspective(@_perspectiveBeforeSearch)
@_perspectiveBeforeSearch = null
else
Actions.focusDefaultMailboxPerspectiveForAccounts(AccountStore.accounts())
@_clearResults()
_onSearchBlurred: =>
@_clearResults()
_clearResults: =>
@_searchSuggestionsVersion = 1
@_threadResults = []
@_contactResults = []
@_suggestions = []
@trigger()
_rebuildResults: =>
return @_clearResults() unless @queryPopulated()
@_searchSuggestionsVersion += 1
@_fetchThreadResults()
@_fetchContactResults()
_fetchContactResults: =>
version = @_searchSuggestionsVersion
ContactStore.searchContacts(@_searchQuery, limit:10).then (contacts) =>
return unless version is @_searchSuggestionsVersion
@_contactResults = contacts
@_compileResults()
_fetchThreadResults: =>
return if @_fetchingThreadResultsVersion
@_fetchingThreadResultsVersion = @_searchSuggestionsVersion
databaseQuery = DatabaseStore.findAll(Thread)
.where(Thread.attributes.subject.like(@_searchQuery))
.order(Thread.attributes.lastMessageReceivedTimestamp.descending())
.limit(4)
accountIds = FocusedPerspectiveStore.current().accountIds
if accountIds instanceof Array
databaseQuery.where(Thread.attributes.accountId.in(accountIds))
databaseQuery.then (results) =>
# We've fetched the latest thread results - display them!
if @_searchSuggestionsVersion is @_fetchingThreadResultsVersion
@_fetchingThreadResultsVersion = null
@_threadResults = results
@_compileResults()
# We're behind and need to re-run the search for the latest results
else if @_searchSuggestionsVersion > @_fetchingThreadResultsVersion
@_fetchingThreadResultsVersion = null
@_fetchThreadResults()
else
@_fetchingThreadResultsVersion = null
_compileResults: =>
@_suggestions = []
@_suggestions.push
label: "Message Contains: #{@_searchQuery}"
value: @_searchQuery
if @_threadResults.length
@_suggestions.push
divider: 'Threads'
@_suggestions.push({thread}) for thread in @_threadResults
if @_contactResults.length
@_suggestions.push
divider: 'People'
for contact in @_contactResults
@_suggestions.push
contact: contact
value: contact.email
@trigger()
module.exports = new SearchStore()