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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
|
{-# LANGUAGE CPP #-}
{-# LANGUAGE GADTs #-}
{-# LANGUAGE LambdaCase #-}
{-# LANGUAGE NamedFieldPuns #-}
{-# LANGUAGE NondecreasingIndentation #-}
{-# LANGUAGE ViewPatterns #-}
module ToxToXMPP where
import Control.Monad
import Crypto.Tox
import Data.Conduit as C
import qualified Data.Conduit.List as CL
import Data.Dependent.Sum
import Data.Function
import Data.Functor.Identity
import Data.Maybe
import Data.Monoid
import qualified Data.Text as T
;import Data.Text (Text)
import Data.Text.Encoding as T
import Data.Tox.Msg as Tox
import Data.Word
import Data.XML.Types as XML
import EventUtil
import Network.Address
import Network.Tox.Crypto.Transport as Tox hiding (UserStatus (..))
import Network.Tox.NodeId
import Util (unsplitJID)
import XMPPServer as XMPP
available :: StanzaType
available = PresenceStatus { presenceShow = Available
, presencePriority = Nothing
, presenceStatus = []
, presenceWhiteList = []
}
xmppHostname :: PublicKey -> Text
xmppHostname k = T.pack $ show (key2id k) ++ ".tox"
toxUserStatus :: UserStatus -> JabberShow
toxUserStatus Online = Available
toxUserStatus Tox.Away = XMPP.Away
toxUserStatus Busy = DoNotDisturb
toxUserStatus _ = XMPP.Away -- Default, shouldn't occur.
toxToXmpp :: Monad m => SockAddr -> PublicKey -> Text -> ConduitM Tox.CryptoMessage XML.Event m ()
toxToXmpp laddr me theirhost = do
CL.sourceList $ XMPP.greet' "jabber:server" theirhost
let me_u = Nothing
me_h = xmppHostname me
im_from = (Just $ unsplitJID (Nothing, theirhost, Nothing)) -- /from/
im_to = (Just $ unsplitJID
( me_u
-- /to/ should match local address of this node.
, me_h
, Nothing))
let
statelessMessages = \case
Pkt MESSAGE :=> Identity bs ->
xmppInstantMessage "jabber:server" im_from im_to [] bs
Pkt TYPING :=> Identity st -> xmppTyping "jabber:server" im_from im_to st
Pkt NICKNAME :=> Identity bs ->
xmppInstantMessage "jabber:server" im_from im_to
[ attr "style" "font-weight:bold; color:red" ]
("NICKNAME(todo) " <> bs)
toxmsg | msgID toxmsg == M PacketRequest -> return ()
Pkt INVITE_GROUPCHAT :=> Identity ginv -> do
xmppInstantMessage "jabber:server" im_from im_to
[ attr "style" "font-weight:bold; color:red" ]
("INVITE(todo)" <> (T.pack $ show ginv))
xmppInvite "jabber:server" me_h (fromJust im_from) (fromJust im_to) ginv
toxmsg -> do
xmppInstantMessage "jabber:server" im_from im_to
[ attr "style" "font-weight:bold; color:red" ]
(T.pack $ "Unhandled message: " ++ show (msgID toxmsg))
flip fix available $ \loop status -> do
let go (Pkt USERSTATUS :=> Identity st) = do
let status' = status { presenceShow = toxUserStatus st }
xmppPresence "jabber:server" im_from status'
loop status'
go (Pkt STATUSMESSAGE :=> Identity bs) = do
let status' = status { presenceStatus = [("",bs)] }
xmppPresence "jabber:server" im_from status'
loop status'
go (Pkt ONLINE :=> _) = do
xmppPresence "jabber:server" im_from status
loop status
go x = do
statelessMessages x
loop status
await >>= mapM_ go
xmppPresence :: Monad m => Text -> Maybe Text -> StanzaType -> ConduitM i XML.Event m ()
xmppPresence namespace mjid p = do
let ns n = n { nameNamespace = Just namespace }
setFrom = maybe id
(\jid -> (attr "from" jid :) )
mjid
typ Offline = [attr "type" "unavailable"]
typ _ = []
shw ExtendedAway = ["xa"]
shw Chatty = ["chat"]
shw XMPP.Away = ["away"]
shw DoNotDisturb = ["dnd"]
shw _ = []
jabberShow stat =
[ EventBeginElement "{jabber:client}show" []
, EventContent (ContentText stat)
, EventEndElement "{jabber:client}show" ]
C.yield $ EventBeginElement (ns "presence") (setFrom $ typ $ presenceShow p)
mapM_ C.yield $ shw (presenceShow p) >>= jabberShow
forM_ (presencePriority p) $ \prio -> do
C.yield $ EventBeginElement (ns "priority") []
C.yield $ EventContent $ ContentText (T.pack $ show prio)
C.yield $ EventEndElement (ns "priority")
forM_ (presenceStatus p) $ \(lang,txt) -> do
let atts | T.null lang = []
| otherwise = [ ("xml:lang", [ContentText lang]) ]
C.yield $ EventBeginElement (ns "status") atts
C.yield $ EventContent $ ContentText txt
C.yield $ EventEndElement (ns "status")
C.yield $ EventEndElement (ns "presence")
chatRoomJID me cid = T.pack (show cid) <> "@ngc." <> me
xmppInvite :: Monad m => Text -> Text -> Text -> Text -> Invite -> ConduitM i XML.Event m ()
xmppInvite namespace me them to inv =
let ns n = n { nameNamespace = Just namespace }
in mapM_ C.yield
[ EventBeginElement (ns "message")
[ attr "from" (chatRoomJID me $ inviteChatID inv)
, attr "to" to
]
, EventBeginElement "{http://jabber.org/protocol/muc#user}x" []
, EventBeginElement "{http://jabber.org/protocol/muc#user}invite"
[ attr "from" them ]
, EventEndElement "{http://jabber.org/protocol/muc#user}invite"
, EventEndElement "{http://jabber.org/protocol/muc#user}x"
, EventEndElement (ns "message")
]
xmppTyping :: Monad m => Text
-> Maybe Text
-> Maybe Text
-> Bool
-> ConduitM i XML.Event m ()
xmppTyping namespace mfrom mto x =
let ns n = n { nameNamespace = Just namespace }
st = case x of
False -> "{http://jabber.org/protocol/chatstates}active"
True -> "{http://jabber.org/protocol/chatstates}composing"
-- tox-core supports only 0 and 1
-- _ -> "{http://jabber.org/protocol/chatstates}paused"
in mapM_ C.yield
[ EventBeginElement (ns "message")
( maybe id (\t->(attr "from" t:)) mfrom
$ maybe id (\t->(attr "to" t:)) mto
$ [attr "type" "chat" ] )
, EventBeginElement st []
, EventEndElement st
, EventEndElement (ns "message")
]
xmppInstantMessage :: Monad m => Text
-> Maybe Text
-> Maybe Text
-> [(Name, [Content])]
-> Text
-> ConduitM i XML.Event m ()
xmppInstantMessage namespace mfrom mto style text = do
let ns n = n { nameNamespace = Just namespace }
C.yield $ EventBeginElement (ns "message")
( maybe id (\t->(attr "from" t:)) mfrom
$ maybe id (\t->(attr "to" t:)) mto
$ [attr "type" "normal" ] )
C.yield $ EventBeginElement (ns "body") []
C.yield $ EventContent $ ContentText text
C.yield $ EventEndElement (ns "body")
C.yield $ EventBeginElement "{http://jabber.org/protocol/xhtml-im}html" []
C.yield $ EventBeginElement "{http://www.w3.org/1999/xhtml}body" []
C.yield $ EventBeginElement "{http://www.w3.org/1999/xhtml}p" style
C.yield $ EventContent $ ContentText text
C.yield $ EventEndElement "{http://www.w3.org/1999/xhtml}p"
C.yield $ EventEndElement "{http://www.w3.org/1999/xhtml}body"
C.yield $ EventEndElement "{http://jabber.org/protocol/xhtml-im}html"
C.yield $ EventEndElement (ns "message")
|
