From 33599d888dae9dfc4ace9cf87b1895e731daa485 Mon Sep 17 00:00:00 2001 From: Lily Rose Date: Wed, 18 Jun 2025 00:00:08 +1000 Subject: [PATCH] Remove websocket endpoint --- src/endpoints/data.gleam | 30 ------------------------------ src/spacetraders_sdk.gleam | 2 -- 2 files changed, 32 deletions(-) diff --git a/src/endpoints/data.gleam b/src/endpoints/data.gleam index 27b1621..75ca651 100644 --- a/src/endpoints/data.gleam +++ b/src/endpoints/data.gleam @@ -1,10 +1,5 @@ import gleam/dict.{type Dict} import gleam/dynamic/decode.{type Decoder} -import gleam/erlang/process.{type Subject} -import gleam/http/request -import gleam/option -import gleam/otp/actor -import stratus import utils/api.{type ApiResponse} import utils/auth.{type AgentToken, AgentAuth} @@ -31,28 +26,3 @@ pub fn get_supply_chain( _ -> api.parse_error_response(response) } } - -pub fn get_departure_events( - token: AgentToken, - initial_state: state, - on_message: fn(state, stratus.Message(user)) -> - Result(state, process.ExitReason), - on_close: fn(state) -> Nil, -) -> Result(Subject(stratus.InternalMessage(user)), actor.StartError) { - stratus.websocket( - request: api.get(AgentAuth(token), "/my/socket.io") - |> request.set_body(""), - init: fn() { #(initial_state, option.None) }, - loop: fn(msg, state, conn) { - case on_message(state, msg) { - Ok(state) -> actor.continue(state) - Error(reason) -> { - let _ = stratus.close(conn) - actor.Stop(reason) - } - } - }, - ) - |> stratus.on_close(on_close) - |> stratus.initialize -} diff --git a/src/spacetraders_sdk.gleam b/src/spacetraders_sdk.gleam index f77825b..2dc47d5 100644 --- a/src/spacetraders_sdk.gleam +++ b/src/spacetraders_sdk.gleam @@ -133,8 +133,6 @@ pub const get_shipyard = systems.get_shipyard pub const get_supply_chain = data.get_supply_chain -pub const get_departure_events = data.get_departure_events - pub const get_server_status = global.get_server_status pub const list_error_codes = global.list_error_codes