summaryrefslogtreecommitdiff
path: root/src/Network/KRPC.hs
diff options
context:
space:
mode:
authorSam Truzjan <pxqr.sta@gmail.com>2013-12-19 18:44:22 +0400
committerSam Truzjan <pxqr.sta@gmail.com>2013-12-19 18:44:22 +0400
commit1a8e7be91a81e97c4fbf35758a35973a04cdbcdc (patch)
tree379711bc40e2186ff01b1324ba10387413755219 /src/Network/KRPC.hs
parent7a13eea1ad815411ee7bce4dcaa8a49bdd979356 (diff)
Add TransactionId to KQuery and KResponse
Diffstat (limited to 'src/Network/KRPC.hs')
-rw-r--r--src/Network/KRPC.hs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/Network/KRPC.hs b/src/Network/KRPC.hs
index 8e158f48..2c3a1b48 100644
--- a/src/Network/KRPC.hs
+++ b/src/Network/KRPC.hs
@@ -208,7 +208,7 @@ call :: forall req resp host.
208 (MonadBaseControl IO host, MonadIO host, KRPC req resp) 208 (MonadBaseControl IO host, MonadIO host, KRPC req resp)
209 => SockAddr -> req -> host resp 209 => SockAddr -> req -> host resp
210call addr arg = liftIO $ withRemote $ \sock -> do 210call addr arg = liftIO $ withRemote $ \sock -> do
211 sendMessage (KQuery name (toBEncode arg)) addr sock 211 sendMessage (KQuery (toBEncode arg) name undefined) addr sock
212 getResult sock 212 getResult sock
213 where 213 where
214 Method name = method :: Method req resp 214 Method name = method :: Method req resp
@@ -231,12 +231,12 @@ handler body = (name, newbody)
231 Method name = method :: Method req resp 231 Method name = method :: Method req resp
232 232
233 {-# INLINE newbody #-} 233 {-# INLINE newbody #-}
234 newbody addr q = 234 newbody addr KQuery {..} =
235 case fromBEncode (queryArgs q) of 235 case fromBEncode queryArgs of
236 Left e -> return (Left (ProtocolError (BC.pack e))) 236 Left e -> return (Left (ProtocolError (BC.pack e)))
237 Right a -> do 237 Right a -> do
238 r <- body addr a 238 r <- body addr a
239 return (Right (KResponse (toBEncode r))) 239 return (Right (KResponse (toBEncode r) queryId))
240 240
241sockAddrFamily :: SockAddr -> Family 241sockAddrFamily :: SockAddr -> Family
242sockAddrFamily (SockAddrInet _ _ ) = AF_INET 242sockAddrFamily (SockAddrInet _ _ ) = AF_INET