fix: error on fatal errors

package.json

@@ -37,7 +37,7 @@
     "typescript": "https://cdn.jsdelivr.net/npm/@tsplus/[email protected]/compiler/typescript.tgz"
   },
   "dependencies": {
-    "@effect-http/client": "^0.22.2",
+    "@effect-http/client": "^0.22.4",
     "@effect/data": "^0.12.2",
     "@effect/io": "~0.25.7",
     "@effect/stream": "~0.21.0",

src/DiscordGateway/DiscordWS.ts

@@ -1,6 +1,12 @@
-import WebSocket from "isomorphic-ws"
-import { LiveWS, Reconnect, WS } from "dfx/DiscordGateway/WS"
+import {
+  LiveWS,
+  Reconnect,
+  WS,
+  WebSocketCloseError,
+  WebSocketError,
+} from "dfx/DiscordGateway/WS"
 import { Log } from "dfx/Log"
+import WebSocket from "isomorphic-ws"
 
 export type Message = Discord.GatewayPayload | Reconnect
 
@@ -45,13 +51,12 @@ const make = Do($ => {
       const socket = $(ws.connect(urlRef, takeOutbound))
       const take = socket.take.map(encoding.decode)
 
-      const run = socket.run
-        .tapError(e => log.info("DiscordWS", "ERROR", e))
-        .retry(Schedule.exponential(Duration.seconds(0.5))) as Effect<
-        never,
-        never,
-        never
-      >
+      const run = socket.run.retry(
+        Schedule.exponential(Duration.seconds(0.5)).whileInput(
+          (_: WebSocketError | WebSocketCloseError) =>
+            _._tag === "WebSocketCloseError" && _.code < 2000,
+        ),
+      )
 
       return {
         run,

src/DiscordGateway/Sharder.ts

@@ -4,6 +4,7 @@ import { DiscordREST } from "dfx/DiscordREST"
 import { LiveRateLimiter, RateLimiter } from "../RateLimit.js"
 import { LiveShard, Shard } from "./Shard.js"
 import { ShardStore } from "./ShardStore.js"
+import { WebSocketCloseError, WebSocketError } from "./WS.js"
 
 const make = Do($ => {
   const store = $(ShardStore)
@@ -55,7 +56,9 @@ const make = Do($ => {
 
   const run = (hub: Hub<Discord.GatewayPayload<Discord.ReceiveEvent>>) =>
     Do($ => {
-      const deferred = $(Deferred.make<never, never>())
+      const deferred = $(
+        Deferred.make<WebSocketError | WebSocketCloseError, never>(),
+      )
       const take = $(takeConfig(config.shardCount ?? gateway.shards))
 
       const spawner = take
@@ -84,7 +87,7 @@ const make = Do($ => {
       return $(
         Effect.allParDiscard(spawners).zipParLeft(deferred.await) as Effect<
           never,
-          never,
+          WebSocketError | WebSocketCloseError,
           never
         >,
       )