blob: 3c3946d9c4c6702637411b0d34c01980acbb9211 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
module Message.Service (
DirectMessageService(..),
formatMessage,
) where
import Control.Monad.Reader
import Control.Monad.State
import Data.List
import qualified Data.Text as T
import Data.Time.Format
import Data.Time.LocalTime
import Identity
import Message
import Service
import State
import Storage
data DirectMessageService = DirectMessageService
instance Service DirectMessageService where
type ServicePacket DirectMessageService = DirectMessage
emptyServiceState = DirectMessageService
serviceHandler smsg = do
let msg = fromStored smsg
powner <- asks $ finalOwner . svcPeer
tzone <- liftIO $ getCurrentTimeZone
svcPrint $ formatMessage tzone msg
if | powner `sameIdentity` msgFrom msg
-> do erb <- gets svcLocal
let st = storedStorage erb
erb' <- liftIO $ do
slist <- case find (sameIdentity powner . msgPeer . fromStored) (storedFromSList $ lsMessages $ fromStored erb) of
Just thread -> do thread' <- wrappedStore st (fromStored thread) { msgHead = smsg : msgHead (fromStored thread) }
slistReplaceS thread thread' $ lsMessages $ fromStored erb
Nothing -> slistAdd (emptyDirectThread powner) { msgHead = [smsg] } $ lsMessages $ fromStored erb
wrappedStore st (fromStored erb) { lsMessages = slist }
modify $ \s -> s { svcLocal = erb' }
return Nothing
| otherwise -> do svcPrint "Owner mismatch"
return Nothing
formatMessage :: TimeZone -> DirectMessage -> String
formatMessage tzone msg = concat
[ formatTime defaultTimeLocale "[%H:%M] " $ utcToLocalTime tzone $ zonedTimeToUTC $ msgTime msg
, maybe "<unnamed>" T.unpack $ idName $ msgFrom msg
, ": "
, T.unpack $ msgText msg
]
|