fork of https://gitlab.com/grom-gleam/grom altered to work with https://fluxer.app
some types shouldn't be public
+13
-22
+7
-13
examples/your_first_bot/src/your_first_bot.gleam
+7
-13
examples/your_first_bot/src/your_first_bot.gleam
···
29
29
30
30
let state = State(client:)
31
31
32
+
let assert Ok(data) = gateway.get_data(client)
33
+
32
34
let gateway_start_result =
33
-
gateway.new(identify, state)
35
+
gateway.new(state, identify, data)
34
36
|> gateway.on_event(do: on_event)
35
37
|> gateway.start
36
38
···
48
50
}
49
51
}
50
52
51
-
fn on_event(
52
-
state: State,
53
-
event: gateway.Event,
54
-
connection: gateway.Connection(State),
55
-
) {
53
+
fn on_event(state: State, event: gateway.Event) {
56
54
case event {
57
55
gateway.ErrorEvent(error) -> {
58
56
logging.log(logging.Warning, string.inspect(error))
59
57
gateway.continue(state)
60
58
}
61
-
gateway.ReadyEvent(ready) -> on_ready(state, ready, connection)
59
+
gateway.ReadyEvent(ready) -> on_ready(state, ready)
62
60
gateway.InteractionCreatedEvent(interaction) ->
63
-
on_interaction_created(state, interaction, connection)
61
+
on_interaction_created(state, interaction)
64
62
_ -> gateway.continue(state)
65
63
}
66
64
}
67
65
68
-
fn on_ready(
69
-
state: State,
70
-
ready: gateway.ReadyMessage,
71
-
connection: gateway.Connection(State),
72
-
) {
66
+
fn on_ready(state: State, ready: gateway.ReadyMessage) {
73
67
logging.log(logging.Info, "Ready!")
74
68
75
69
let global_commands = [
+6
-9
src/grom/gateway.gleam
+6
-9
src/grom/gateway.gleam
···
175
175
176
176
// RECEIVE EVENTS --------------------------------------------------------------
177
177
178
-
pub type ReceivedMessage {
178
+
type ReceivedMessage {
179
179
Hello(HelloMessage)
180
180
Dispatch(sequence: Int, message: DispatchedMessage)
181
181
HeartbeatAcknowledged
···
184
184
InvalidSession(can_reconnect: Bool)
185
185
}
186
186
187
-
pub type HelloMessage {
187
+
type HelloMessage {
188
188
HelloMessage(heartbeat_interval: Duration)
189
189
}
190
190
191
191
// RECEIVED DISPATCH EVENTS ----------------------------------------------------
192
192
193
-
pub type DispatchedMessage {
193
+
type DispatchedMessage {
194
194
Ready(ReadyMessage)
195
195
Resumed
196
196
RateLimited(RateLimitedMessage)
···
877
877
))
878
878
}
879
879
880
-
@internal
881
-
pub fn message_decoder() -> decode.Decoder(ReceivedMessage) {
880
+
fn message_decoder() -> decode.Decoder(ReceivedMessage) {
882
881
use opcode <- decode.field("op", decode.int)
883
882
case opcode {
884
883
0 -> {
···
903
902
}
904
903
}
905
904
906
-
@internal
907
-
pub fn dispatched_message_decoder(
905
+
fn dispatched_message_decoder(
908
906
type_: String,
909
907
) -> decode.Decoder(DispatchedMessage) {
910
908
case type_ {
···
1232
1230
decode.success(RequestGuildMembersRateLimited(guild_id:, nonce:))
1233
1231
}
1234
1232
1235
-
@internal
1236
-
pub fn hello_event_decoder() -> decode.Decoder(HelloMessage) {
1233
+
fn hello_event_decoder() -> decode.Decoder(HelloMessage) {
1237
1234
use heartbeat_interval <- decode.field(
1238
1235
"heartbeat_interval",
1239
1236
time_duration.from_milliseconds_decoder(),