diff options
author | Sam Truzjan <pxqr.sta@gmail.com> | 2013-11-28 15:00:13 +0400 |
---|---|---|
committer | Sam Truzjan <pxqr.sta@gmail.com> | 2013-11-28 15:00:13 +0400 |
commit | 60d21cfefd82995265c00df9136b19fefa8910ac (patch) | |
tree | 4b6392f3dd30d9de981916dc5bd5e3ec5d20cbd0 /src | |
parent | fc3b090ac8dceefd315e6ca16f12d32dca11f580 (diff) |
Get rid of the urlencoded package
* It uses slow String's instead of Text.
* It does not allow to encode infohash and peer ids properly.
* It does not provide API for query string parsing.
So it is better to use http-types package.
Diffstat (limited to 'src')
-rw-r--r-- | src/Data/Torrent.hs | 4 | ||||
-rw-r--r-- | src/Data/Torrent/Progress.hs | 24 | ||||
-rw-r--r-- | src/Network/BitTorrent/Core/PeerId.hs | 11 | ||||
-rw-r--r-- | src/Network/BitTorrent/Tracker/Message.hs | 13 |
4 files changed, 35 insertions, 17 deletions
diff --git a/src/Data/Torrent.hs b/src/Data/Torrent.hs index e4b17c2b..d6227b6f 100644 --- a/src/Data/Torrent.hs +++ b/src/Data/Torrent.hs | |||
@@ -78,6 +78,7 @@ import Data.ByteString as BS | |||
78 | import qualified Data.ByteString.Char8 as BC (pack, unpack) | 78 | import qualified Data.ByteString.Char8 as BC (pack, unpack) |
79 | import qualified Data.ByteString.Lazy as BL | 79 | import qualified Data.ByteString.Lazy as BL |
80 | import Data.Char as Char | 80 | import Data.Char as Char |
81 | import Data.Default | ||
81 | import Data.Hashable as Hashable | 82 | import Data.Hashable as Hashable |
82 | import qualified Data.List as L | 83 | import qualified Data.List as L |
83 | import Data.Maybe | 84 | import Data.Maybe |
@@ -143,8 +144,7 @@ instance Hashable InfoDict where | |||
143 | infoDictionary :: LayoutInfo -> PieceInfo -> Bool -> InfoDict | 144 | infoDictionary :: LayoutInfo -> PieceInfo -> Bool -> InfoDict |
144 | infoDictionary li pinfo private = InfoDict ih li pinfo private | 145 | infoDictionary li pinfo private = InfoDict ih li pinfo private |
145 | where | 146 | where |
146 | ih = hashLazyIH $ encode $ InfoDict fake_ih li pinfo private | 147 | ih = hashLazyIH $ encode $ InfoDict def li pinfo private |
147 | fake_ih = "0123456789012345678901234567890123456789" | ||
148 | 148 | ||
149 | getPrivate :: Get Bool | 149 | getPrivate :: Get Bool |
150 | getPrivate = (Just True ==) <$>? "private" | 150 | getPrivate = (Just True ==) <$>? "private" |
diff --git a/src/Data/Torrent/Progress.hs b/src/Data/Torrent/Progress.hs index d0aa75c6..1a4a68e2 100644 --- a/src/Data/Torrent/Progress.hs +++ b/src/Data/Torrent/Progress.hs | |||
@@ -12,6 +12,7 @@ | |||
12 | -- | 12 | -- |
13 | {-# LANGUAGE TemplateHaskell #-} | 13 | {-# LANGUAGE TemplateHaskell #-} |
14 | {-# LANGUAGE ViewPatterns #-} | 14 | {-# LANGUAGE ViewPatterns #-} |
15 | {-# OPTIONS -fno-warn-orphans #-} | ||
15 | module Data.Torrent.Progress | 16 | module Data.Torrent.Progress |
16 | ( -- * Progress | 17 | ( -- * Progress |
17 | Progress (..) | 18 | Progress (..) |
@@ -36,13 +37,15 @@ module Data.Torrent.Progress | |||
36 | import Control.Applicative | 37 | import Control.Applicative |
37 | import Control.Lens hiding ((%=)) | 38 | import Control.Lens hiding ((%=)) |
38 | import Data.Aeson.TH | 39 | import Data.Aeson.TH |
40 | import Data.ByteString.Lazy.Builder as BS | ||
41 | import Data.ByteString.Lazy.Builder.ASCII as BS | ||
39 | import Data.Default | 42 | import Data.Default |
40 | import Data.List as L | 43 | import Data.List as L |
41 | import Data.Monoid | 44 | import Data.Monoid |
42 | import Data.Serialize as S | 45 | import Data.Serialize as S |
43 | import Data.Ratio | 46 | import Data.Ratio |
44 | import Data.URLEncoded | ||
45 | import Data.Word | 47 | import Data.Word |
48 | import Network.HTTP.Types.QueryLike | ||
46 | import Text.PrettyPrint as PP | 49 | import Text.PrettyPrint as PP |
47 | import Text.PrettyPrint.Class | 50 | import Text.PrettyPrint.Class |
48 | 51 | ||
@@ -89,18 +92,19 @@ instance Monoid Progress where | |||
89 | } | 92 | } |
90 | {-# INLINE mappend #-} | 93 | {-# INLINE mappend #-} |
91 | 94 | ||
92 | instance URLShow Word64 where | 95 | instance QueryValueLike Builder where |
93 | urlShow = show | 96 | toQueryValue = toQueryValue . BS.toLazyByteString |
94 | {-# INLINE urlShow #-} | 97 | |
98 | instance QueryValueLike Word64 where | ||
99 | toQueryValue = toQueryValue . BS.word64Dec | ||
95 | 100 | ||
96 | -- | HTTP Tracker protocol compatible encoding. | 101 | -- | HTTP Tracker protocol compatible encoding. |
97 | instance URLEncode Progress where | 102 | instance QueryLike Progress where |
98 | urlEncode Progress {..} = mconcat | 103 | toQuery Progress {..} = |
99 | [ s "uploaded" %= _uploaded | 104 | [ ("uploaded" , toQueryValue _uploaded) |
100 | , s "left" %= _left | 105 | , ("left" , toQueryValue _left) |
101 | , s "downloaded" %= _downloaded | 106 | , ("downloaded", toQueryValue _downloaded) |
102 | ] | 107 | ] |
103 | where s :: String -> String; s = id; {-# INLINE s #-} | ||
104 | 108 | ||
105 | instance Pretty Progress where | 109 | instance Pretty Progress where |
106 | pretty Progress {..} = | 110 | pretty Progress {..} = |
diff --git a/src/Network/BitTorrent/Core/PeerId.hs b/src/Network/BitTorrent/Core/PeerId.hs index a2b03e92..f5a40f29 100644 --- a/src/Network/BitTorrent/Core/PeerId.hs +++ b/src/Network/BitTorrent/Core/PeerId.hs | |||
@@ -46,12 +46,14 @@ import Data.List as L | |||
46 | import Data.List.Split as L | 46 | import Data.List.Split as L |
47 | import Data.Maybe (fromMaybe, catMaybes) | 47 | import Data.Maybe (fromMaybe, catMaybes) |
48 | import Data.Monoid | 48 | import Data.Monoid |
49 | import Data.Hashable | ||
49 | import Data.Serialize as S | 50 | import Data.Serialize as S |
50 | import Data.String | 51 | import Data.String |
51 | import Data.Time.Clock (getCurrentTime) | 52 | import Data.Time.Clock (getCurrentTime) |
52 | import Data.Time.Format (formatTime) | 53 | import Data.Time.Format (formatTime) |
53 | import Data.URLEncoded | 54 | import Data.URLEncoded |
54 | import Data.Version (Version(Version), versionBranch) | 55 | import Data.Version (Version(Version), versionBranch) |
56 | import Network.HTTP.Types.QueryLike | ||
55 | import System.Entropy (getEntropy) | 57 | import System.Entropy (getEntropy) |
56 | import System.Locale (defaultTimeLocale) | 58 | import System.Locale (defaultTimeLocale) |
57 | import Text.PrettyPrint hiding ((<>)) | 59 | import Text.PrettyPrint hiding ((<>)) |
@@ -70,12 +72,17 @@ newtype PeerId = PeerId { getPeerId :: ByteString } | |||
70 | peerIdLen :: Int | 72 | peerIdLen :: Int |
71 | peerIdLen = 20 | 73 | peerIdLen = 20 |
72 | 74 | ||
75 | instance Hashable PeerId where | ||
76 | hash = hash . getPeerId | ||
77 | {-# INLINE hash #-} | ||
78 | |||
73 | instance Serialize PeerId where | 79 | instance Serialize PeerId where |
74 | put = putByteString . getPeerId | 80 | put = putByteString . getPeerId |
75 | get = PeerId <$> getBytes peerIdLen | 81 | get = PeerId <$> getBytes peerIdLen |
76 | 82 | ||
77 | instance URLShow PeerId where | 83 | instance QueryValueLike PeerId where |
78 | urlShow = BC.unpack . getPeerId | 84 | toQueryValue (PeerId pid) = Just pid |
85 | {-# INLINE toQueryValue #-} | ||
79 | 86 | ||
80 | instance IsString PeerId where | 87 | instance IsString PeerId where |
81 | fromString str | 88 | fromString str |
diff --git a/src/Network/BitTorrent/Tracker/Message.hs b/src/Network/BitTorrent/Tracker/Message.hs index 59ef2027..e5d8b25a 100644 --- a/src/Network/BitTorrent/Tracker/Message.hs +++ b/src/Network/BitTorrent/Tracker/Message.hs | |||
@@ -66,6 +66,7 @@ import Data.Typeable | |||
66 | import Data.URLEncoded as URL | 66 | import Data.URLEncoded as URL |
67 | import Data.Word | 67 | import Data.Word |
68 | import Network | 68 | import Network |
69 | import Network.HTTP.Types.QueryLike | ||
69 | import Network.HTTP.Types.URI hiding (urlEncode) | 70 | import Network.HTTP.Types.URI hiding (urlEncode) |
70 | import Network.Socket | 71 | import Network.Socket |
71 | import Network.URI | 72 | import Network.URI |
@@ -173,15 +174,21 @@ instance URLShow Word32 where | |||
173 | -- | HTTP tracker protocol compatible encoding. | 174 | -- | HTTP tracker protocol compatible encoding. |
174 | instance URLEncode AnnounceQuery where | 175 | instance URLEncode AnnounceQuery where |
175 | urlEncode AnnounceQuery {..} = mconcat | 176 | urlEncode AnnounceQuery {..} = mconcat |
176 | [ s "peer_id" %= reqPeerId | 177 | [ -- s "peer_id" %= reqPeerId |
177 | , s "port" %= reqPort | 178 | s "port" %= reqPort |
178 | , urlEncode reqProgress | 179 | -- , urlEncode reqProgress |
179 | , s "ip" %=? reqIP | 180 | , s "ip" %=? reqIP |
180 | , s "numwant" %=? reqNumWant | 181 | , s "numwant" %=? reqNumWant |
181 | , s "event" %=? reqEvent | 182 | , s "event" %=? reqEvent |
182 | ] | 183 | ] |
183 | where s :: String -> String; s = id; {-# INLINE s #-} | 184 | where s :: String -> String; s = id; {-# INLINE s #-} |
184 | 185 | ||
186 | instance QueryLike AnnounceQuery where | ||
187 | toQuery AnnounceQuery {..} = | ||
188 | [ ("info_hash", toQueryValue reqInfoHash) | ||
189 | , ("peer_id" , toQueryValue reqPeerId) | ||
190 | ] | ||
191 | |||
185 | -- | UDP tracker protocol compatible encoding. | 192 | -- | UDP tracker protocol compatible encoding. |
186 | instance Serialize AnnounceQuery where | 193 | instance Serialize AnnounceQuery where |
187 | put AnnounceQuery {..} = do | 194 | put AnnounceQuery {..} = do |