X-Git-Url: http://gitweb.michael.orlitzky.com/?p=dead%2Fhalcyon.git;a=blobdiff_plain;f=src%2FTwitter%2FHttp.hs;h=e3bb9fcc96ea3b90c2077b977a06d6cadb904063;hp=3b834859f37fcdbeeec0892588024da794238d60;hb=d7c6b5499c0969b6e488d9fc583f93bbb4e3d4c7;hpb=d721869c5e7395c021cc79f40720bdb275d613d2 diff --git a/src/Twitter/Http.hs b/src/Twitter/Http.hs index 3b83485..e3bb9fc 100644 --- a/src/Twitter/Http.hs +++ b/src/Twitter/Http.hs @@ -1,21 +1,27 @@ -module Twitter.Http +module Twitter.Http ( + get_user_new_statuses, + get_user_timeline, + http_get ) where -import qualified Data.ByteString.Lazy as B -import qualified Data.ByteString.Char8 as BC -import qualified Data.Conduit as C -import Data.Conduit.Binary (sinkLbs) -import Network.HTTP.Conduit +import qualified Data.ByteString.Lazy as B ( ByteString ) +import qualified Data.ByteString.Char8 as BC ( pack ) +import Network.HTTP.Client ( + httpLbs, + newManager, + parseUrl, + responseBody ) +import Network.HTTP.Client.TLS ( tlsManagerSettings ) import Web.Authenticate.OAuth ( OAuth(..), Credential, newCredential, newOAuth, - signOAuth) + signOAuth ) -import Configuration +import Configuration ( Cfg(..) ) --- |The API URL of username's timeline. +-- | The API URL of username's timeline. -- -- See, -- @@ -32,13 +38,6 @@ user_timeline_url username = "&include_rts=true&", "count=10" ] -status_url :: Integer -> String -status_url status_id = - concat [ "https://api.twitter.com/", - "1.1/", - "statuses/", - "show.json?id=", - (show status_id) ] -- | Given username's last status id, constructs the API URL for -- username's new statuses. Essentially, 'user_timeline_url' with a @@ -50,11 +49,6 @@ user_new_statuses_url username last_status_id = url = user_timeline_url username since_id = show last_status_id -get_status :: Cfg -> Integer -> IO B.ByteString -get_status cfg status_id = do - let uri = status_url status_id - http_get cfg uri - -- | Return's username's timeline. get_user_timeline :: Cfg -> String -> IO B.ByteString @@ -74,13 +68,11 @@ get_user_new_statuses cfg username last_status_id = do -- | Retrieve a URL, or crash. http_get :: Cfg -> String -> IO B.ByteString http_get cfg url = do - manager <- newManager def + manager <- newManager tlsManagerSettings request <- parseUrl url - - C.runResourceT $ do - signed_request <- signOAuth oauth credential request - response <- http signed_request manager - responseBody response C.$$+- sinkLbs + signed_request <- signOAuth oauth credential request + response <- httpLbs signed_request manager + return $ responseBody response where consumer_key' = BC.pack (consumer_key cfg)