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
|
{-# LANGUAGE ScopedTypeVariables #-}
{-# LANGUAGE OverloadedStrings #-}
-- | Provides a higher level interface to the rest functions.
-- Preperly writes to the rate-limit loop. Creates separate
-- MVars for each call
module Discord.Internal.Rest
( module Discord.Internal.Types
, RestChanHandle(..)
, Request(..)
, writeRestCall
, startRestThread
, RestCallInternalException(..)
) where
import Prelude hiding (log)
import Data.Aeson (FromJSON, eitherDecode)
import Control.Concurrent.Chan
import Control.Concurrent.MVar
import Control.Concurrent (forkIO, ThreadId)
import qualified Data.ByteString.Lazy as BL
import qualified Data.Text as T
import Discord.Internal.Types
import Discord.Internal.Rest.HTTP
-- | Handle to the Rest 'Chan'
data RestChanHandle = RestChanHandle
{ restHandleChan :: Chan (String, JsonRequest, MVar (Either RestCallInternalException BL.ByteString))
}
-- | Starts the http request thread. Please only call this once
startRestThread :: Auth -> Chan T.Text -> IO (RestChanHandle, ThreadId)
startRestThread auth log = do
c <- newChan
tid <- forkIO $ restLoop auth c log
pure (RestChanHandle c, tid)
-- | Execute a request blocking until a response is received
writeRestCall :: (Request (r a), FromJSON a) => RestChanHandle -> r a -> IO (Either RestCallInternalException a)
writeRestCall c req = do
m <- newEmptyMVar
writeChan (restHandleChan c) (majorRoute req, jsonRequest req, m)
r <- readMVar m
pure $ case eitherDecode <$> r of
Right (Right o) -> Right o
(Right (Left er)) -> Left (RestCallInternalNoParse er (case r of
Right x -> x
Left _ -> ""))
Left e -> Left e
|
