-
Notifications
You must be signed in to change notification settings - Fork 1
/
chat.gleam
75 lines (66 loc) · 1.91 KB
/
chat.gleam
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
import gleam/dynamic.{type Decoder}
import gleam/io
import gleam/option.{type Option}
import gleam/result
import gleam/json.{type DecodeError, type Json}
import gleam/http/response.{type Response}
import gleam/http/request
import glitch/api/client.{type Client}
import glitch/api/api_response
import glitch/extended/json_ext
pub type Message {
Message(message_id: String, is_sent: Bool)
}
fn message_decoder() -> Decoder(Message) {
dynamic.decode2(
Message,
dynamic.field("message_id", dynamic.string),
dynamic.field("is_sent", dynamic.bool),
)
}
pub fn message_from_json(json_string: String) -> Result(Message, DecodeError) {
json.decode(json_string, message_decoder())
}
pub type SendMessageRequest {
SendMessageRequest(
broadcaster_id: String,
sender_id: String,
message: String,
reply_parent_message_id: Option(String),
)
}
fn send_message_request_to_json(request: SendMessageRequest) -> Json {
json.object([
#("broadcaster_id", json.string(request.broadcaster_id)),
#("sender_id", json.string(request.sender_id)),
#("message", json.string(request.message)),
#(
"reply_parent_message_id",
json_ext.option(request.reply_parent_message_id, json.string),
),
])
}
pub type SendMessageError {
DecodeError(DecodeError)
RequestError
}
pub fn send_message(
client: Client,
request: SendMessageRequest,
) -> Result(Response(List(Message)), SendMessageError) {
let body = send_message_request_to_json(request)
io.println(json.to_string(body))
let request =
request.new()
|> request.set_body(send_message_request_to_json(request))
|> request.set_path("chat/messages")
use response <- result.try(
client
|> client.post(request)
|> result.replace_error(RequestError),
)
response
|> response.try_map(api_response.from_json(_, message_decoder()))
|> result.try(api_response.get_data_from_response)
|> result.map_error(DecodeError)
}