mirror of
https://github.com/Foundry376/Mailspring.git
synced 2025-01-05 07:35:34 +08:00
fix(notifications): make notifications clickable
This commit is contained in:
parent
3983269004
commit
b52077c1c3
1 changed files with 30 additions and 21 deletions
|
@ -10,32 +10,44 @@ module.exports =
|
|||
@unlisteners = []
|
||||
@unlisteners.push Actions.didPassivelyReceiveNewModels.listen(@_onNewMailReceived, @)
|
||||
@activationTime = Date.now()
|
||||
@stack = []
|
||||
@stackProcessTimer = null
|
||||
|
||||
deactivate: ->
|
||||
fn() for fn in @unlisteners
|
||||
|
||||
serialize: ->
|
||||
|
||||
_notifyMessage: (msg) ->
|
||||
body = msg.subject
|
||||
_notifyAll: ->
|
||||
new Notification("#{@stack.length} Unread Messages", {
|
||||
tag: 'unread-update'
|
||||
})
|
||||
@stack = []
|
||||
|
||||
_notifyOne: ({message, thread}) ->
|
||||
body = message.subject
|
||||
if not body or body.length is 0
|
||||
body = msg.snippet
|
||||
from = msg.from[0]?.displayName() ? "Unknown"
|
||||
body = message.snippet
|
||||
from = message.from[0]?.displayName() ? "Unknown"
|
||||
|
||||
notif = new Notification(from, {
|
||||
body: body
|
||||
tag: 'unread-update'
|
||||
})
|
||||
|
||||
notif.onclick = =>
|
||||
atom.displayWindow()
|
||||
Actions.focusCategory(CategoryStore.getStandardCategory("inbox"))
|
||||
Actions.setFocus(collection: 'thread', item: @threads[msg.threadId])
|
||||
Actions.setFocus(collection: 'thread', item: thread)
|
||||
|
||||
_notifyMessages: (msgs) ->
|
||||
_notifyMessages: ->
|
||||
if @stack.length > 5
|
||||
@_notifyAll()
|
||||
else if @stack.length > 0
|
||||
@_notifyOne(@stack.pop())
|
||||
|
||||
return if msgs.length is 0
|
||||
@_notifyMessage(msgs.pop())
|
||||
setTimeout (=> @_notifyMessages msgs), 2000
|
||||
@stackProcessTimer = null
|
||||
if @stack.length > 0
|
||||
@stackProcessTimer = setTimeout(( => @_notifyMessages()), 2000)
|
||||
|
||||
_onNewMailReceived: (incoming) ->
|
||||
new Promise (resolve, reject) =>
|
||||
|
@ -59,13 +71,12 @@ module.exports =
|
|||
#
|
||||
# Note we may receive multiple unread msgs for the same thread.
|
||||
# Using a map and ?= to avoid repeating work.
|
||||
@threads = {}
|
||||
threads = {}
|
||||
for msg in newUnread
|
||||
@threads[msg.threadId] ?= _.findWhere(incomingThreads, {id: msg.threadId})
|
||||
@threads[msg.threadId] ?= DatabaseStore.find(Thread, msg.threadId)
|
||||
|
||||
Promise.props(@threads).then (threads) =>
|
||||
threads[msg.threadId] ?= _.findWhere(incomingThreads, {id: msg.threadId})
|
||||
threads[msg.threadId] ?= DatabaseStore.find(Thread, msg.threadId)
|
||||
|
||||
Promise.props(threads).then (threads) =>
|
||||
# Filter new unread messages to just the ones in the inbox
|
||||
newUnreadInInbox = _.filter newUnread, (msg) ->
|
||||
threads[msg.threadId]?.hasCategoryName('inbox')
|
||||
|
@ -73,11 +84,9 @@ module.exports =
|
|||
return resolve() if newUnreadInInbox.length is 0
|
||||
atom.playSound('new_mail.ogg')
|
||||
|
||||
if newUnreadInInbox.length < 5
|
||||
@_notifyMessages(newUnreadInInbox)
|
||||
else
|
||||
new Notification("#{newUnreadInInbox.length} Unread Messages", {
|
||||
tag: 'unread-update'
|
||||
})
|
||||
for msg in newUnreadInInbox
|
||||
@stack.push({message: msg, thread: threads[msg.threadId]})
|
||||
if not @stackProcessTimer
|
||||
@_notifyMessages()
|
||||
|
||||
resolve()
|
||||
|
|
Loading…
Reference in a new issue