diff options
Diffstat (limited to 'lib/gateway/sharder.ml')
| -rw-r--r-- | lib/gateway/sharder.ml | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/gateway/sharder.ml b/lib/gateway/sharder.ml index 71e900d..ba865a9 100644 --- a/lib/gateway/sharder.ml +++ b/lib/gateway/sharder.ml @@ -62,7 +62,7 @@ module Shard = struct | Binary ->
if compress then `Ok (decompress s.content |> Yojson.Safe.from_string)
else `Error "Failed to decompress"
- | Close -> `Close s.content
+ | Close -> `Close s
| op ->
let op = Frame.Opcode.to_string op in
`Error ("Unexpected opcode " ^ op)
@@ -311,13 +311,13 @@ let start ?count ?compress ?large_threshold () = Logs.info (fun m -> m "Connecting to %s" url);
let rec ev_loop (t:Shard.shard Shard.t) =
let step (t:Shard.shard Shard.t) =
- Pipe.read (fst t.state.pipe) >>= fun frame ->
+ Pipe.read (fst t.state.pipe) >>= fun frame ->
begin match Shard.parse ~compress:t.state.compress frame with
| `Ok f ->
Shard.handle_frame ~f t.state >>| fun s ->
t.state <- s
| `Close c ->
- Logs.warn (fun m -> m "Close frame received. Code: %s" c);
+ Logs.warn (fun m -> m "Close frame received. %s" (Frame.show c));
Shard.shutdown t
| `Error e ->
Logs.warn (fun m -> m "Websocket soft error: %s" e);
@@ -379,4 +379,4 @@ let request_guild_members ?query ?limit ~guild sharder = let shutdown_all ?restart sharder =
Deferred.all @@ List.map ~f:(fun t ->
Shard.shutdown ~clean:true ?restart t
- ) sharder.shards
\ No newline at end of file + ) sharder.shards
|