63 lines
1.4 KiB
Elm
63 lines
1.4 KiB
Elm
module Mastodon.WebSocket
|
|
exposing
|
|
( StreamType(..)
|
|
, WebSocketEvent(..)
|
|
, WebSocketMessage
|
|
, WebSocketPayload(..)
|
|
, subscribeToWebSockets
|
|
)
|
|
|
|
import String.Extra exposing (replaceSlice)
|
|
import WebSocket
|
|
import Mastodon.ApiUrl as ApiUrl
|
|
import Mastodon.Encoder exposing (encodeUrl)
|
|
import Mastodon.Model exposing (..)
|
|
|
|
|
|
type StreamType
|
|
= UserStream
|
|
| LocalPublicStream
|
|
| GlobalPublicStream
|
|
|
|
|
|
type WebSocketEvent
|
|
= StatusUpdateEvent (Result String Status)
|
|
| NotificationEvent (Result String Notification)
|
|
| StatusDeleteEvent (Result String Int)
|
|
| ErrorEvent String
|
|
|
|
|
|
type WebSocketPayload
|
|
= StringPayload String
|
|
| IntPayload Int
|
|
|
|
|
|
type alias WebSocketMessage =
|
|
{ event : String
|
|
, payload : WebSocketPayload
|
|
}
|
|
|
|
|
|
subscribeToWebSockets : Client -> StreamType -> (String -> a) -> Sub a
|
|
subscribeToWebSockets client streamType message =
|
|
let
|
|
type_ =
|
|
case streamType of
|
|
GlobalPublicStream ->
|
|
"public"
|
|
|
|
LocalPublicStream ->
|
|
"public:local"
|
|
|
|
UserStream ->
|
|
"user"
|
|
|
|
url =
|
|
encodeUrl
|
|
(replaceSlice "wss" 0 5 <| client.server ++ ApiUrl.streaming)
|
|
[ ( "access_token", client.token )
|
|
, ( "stream", type_ )
|
|
]
|
|
in
|
|
WebSocket.listen url message
|