glixir

////
//// glixir - Unified OTP interface for Gleam, now type safe!
//// Bounded, phantom-typed supervisors! No more runtime surprises.
////

import gleam/dynamic.{type Dynamic}
import gleam/dynamic/decode.{type Decoder}
import gleam/erlang/atom.{type Atom}
import gleam/erlang/process.{type Pid, type Subject}
import gleam/list
import gleam/string
import glixir/agent
import glixir/genserver
import glixir/pubsub
import glixir/registry
import glixir/supervisor
import glixir/utils
import logging

// =====================
// PUBLIC TYPE EXPORTS
// =====================

// GENSERVER
pub type GenServer(request, reply) =
  genserver.GenServer(request, reply)

pub type GenServerError =
  genserver.GenServerError

// AGENT
pub type Agent(state) =
  agent.Agent(state)

pub type AgentError =
  agent.AgentError

// REGISTRY - PHANTOM TYPED
pub type Registry(key_type, message_type) =
  registry.Registry(key_type, message_type)

pub type RegistryError =
  registry.RegistryError

pub type RegistryKeys =
  registry.RegistryKeys

pub type KeyEncoder(key_type) =
  registry.KeyEncoder(key_type)

// PUBSUB - PHANTOM TYPED
pub type PubSub(message_type) =
  pubsub.PubSub(message_type)

pub type PubSubError =
  pubsub.PubSubError

pub type MessageEncoder(message_type) =
  pubsub.MessageEncoder(message_type)

pub type MessageDecoder(message_type) =
  pubsub.MessageDecoder(message_type)

// SUPERVISOR - BOUNDED
pub type DynamicSupervisor(child_args, child_reply) =
  supervisor.DynamicSupervisor(child_args, child_reply)

pub type ChildSpec(child_args, child_reply) =
  supervisor.ChildSpec(child_args, child_reply)

pub type StartChildResult(child_reply) =
  supervisor.StartChildResult(child_reply)

pub type RestartStrategy =
  supervisor.RestartStrategy

pub type ChildType =
  supervisor.ChildType

pub type ChildStatus =
  supervisor.ChildStatus

pub type ChildInfo(child_args, child_reply) =
  supervisor.ChildInfo(child_args, child_reply)

pub type SupervisorError =
  supervisor.SupervisorError

pub type ChildOperationError =
  supervisor.ChildOperationError

pub const permanent = supervisor.Permanent

pub const temporary = supervisor.Temporary

pub const transient = supervisor.Transient

pub const worker = supervisor.Worker

pub const supervisor_child = supervisor.SupervisorChild

// Convenience encoders
pub const string_encoder = pubsub.string_encoder

pub const int_encoder = pubsub.int_encoder

pub const string_decoder = pubsub.string_decoder

pub const int_decoder = pubsub.int_decoder

// ============================================================================
// PUBSUB API FUNCTIONS (Fixed)
// ============================================================================

/// Start a phantom-typed PubSub system
pub fn pubsub_start(name: Atom) -> Result(PubSub(message_type), PubSubError) {
  pubsub.start(name)
}

/// Subscribe to a topic with message handling
pub fn pubsub_subscribe(
  pubsub_name: Atom,
  topic: String,
  gleam_module: String,
  gleam_function: String,
) -> Result(Nil, PubSubError) {
  pubsub.subscribe(pubsub_name, topic, gleam_module, gleam_function)
}

pub fn pubsub_subscribe_with_registry_key(
  pubsub_name: Atom,
  topic: String,
  gleam_module: String,
  gleam_function: String,
  registry_key: String,
) -> Result(Nil, PubSubError) {
  pubsub.subscribe_with_registry_key(
    pubsub_name,
    topic,
    gleam_module,
    gleam_function,
    registry_key,
  )
}

/// Broadcast a message to all subscribers
pub fn pubsub_broadcast(
  pubsub_name: Atom,
  topic: String,
  message: message_type,
  encode: MessageEncoder(message_type),
) -> Result(Nil, PubSubError) {
  pubsub.broadcast(pubsub_name, topic, message, encode)
}

/// Unsubscribe from a topic
pub fn pubsub_unsubscribe(
  pubsub_name: Atom,
  topic: String,
) -> Result(Nil, PubSubError) {
  pubsub.unsubscribe(pubsub_name, topic)
}

// =====================
// REGISTRY (NEW PHANTOM-TYPED API)
// =====================

/// Start a phantom-typed unique registry (you must specify key_type, message_type)
pub fn start_registry(
  name: atom.Atom,
) -> Result(Registry(key_type, message_type), RegistryError) {
  registry.start_unique_registry(name)
}

/// Start a registry with specific keys configuration
pub fn start_registry_with_keys(
  name: atom.Atom,
  keys: RegistryKeys,
) -> Result(Registry(key_type, message_type), RegistryError) {
  registry.start_registry(name, keys)
}

/// Register a subject with a typed key (requires key encoder)
pub fn register_subject(
  registry_name: atom.Atom,
  key: key_type,
  subject: Subject(message_type),
  encode_key: KeyEncoder(key_type),
) -> Result(Nil, RegistryError) {
  registry.register_subject(registry_name, key, subject, encode_key)
}

/// Look up a subject by typed key (requires key encoder)
pub fn lookup_subject(
  registry_name: atom.Atom,
  key: key_type,
  encode_key: KeyEncoder(key_type),
) -> Result(Subject(message_type), RegistryError) {
  registry.lookup_subject(registry_name, key, encode_key)
}

/// Unregister a subject by typed key (requires key encoder)
pub fn unregister_subject(
  registry_name: atom.Atom,
  key: key_type,
  encode_key: KeyEncoder(key_type),
) -> Result(Nil, RegistryError) {
  registry.unregister_subject(registry_name, key, encode_key)
}

/// SAFE: Register a subject with string key (no dynamic atom creation)
/// Use this for user-generated keys to avoid atom table exhaustion
pub fn register_subject_string(
  registry_name: atom.Atom,
  key: String,
  subject: Subject(message_type),
) -> Result(Nil, RegistryError) {
  registry.register_subject_string(registry_name, key, subject)
}

/// SAFE: Look up a subject by string key (no dynamic atom creation)
/// Use this for user-generated keys to avoid atom table exhaustion
pub fn lookup_subject_string(
  registry_name: atom.Atom,
  key: String,
) -> Result(Subject(message_type), RegistryError) {
  registry.lookup_subject_string(registry_name, key)
}

/// SAFE: Unregister a subject by string key (no dynamic atom creation)
/// Use this for user-generated keys to avoid atom table exhaustion
pub fn unregister_subject_string(
  registry_name: atom.Atom,
  key: String,
) -> Result(Nil, RegistryError) {
  registry.unregister_subject_string(registry_name, key)
}

// Convenience key encoders
pub const atom_key_encoder = registry.atom_key_encoder

pub const string_key_encoder = registry.string_key_encoder

pub const int_key_encoder = registry.int_key_encoder

pub const user_id_encoder = registry.user_id_encoder

pub const session_key_encoder = registry.session_key_encoder

// Registry configuration constants
pub const unique = registry.Unique

pub const duplicate = registry.Duplicate

// =====================
// SUPERVISOR (NEW BOUNDED API)
// =====================

/// Start an unnamed dynamic supervisor
pub fn start_dynamic_supervisor() -> Result(
  DynamicSupervisor(child_args, child_reply),
  SupervisorError,
) {
  utils.debug_log(logging.Info, "[glixir] Starting unnamed dynamic supervisor")
  supervisor.start_dynamic_supervisor()
}

/// Get all child processes from a dynamic supervisor
pub fn get_all_dynamic_children(
  sup: DynamicSupervisor(child_args, child_reply),
) -> Result(List(process.Subject(child_reply)), String) {
  utils.debug_log(logging.Info, "[glixir] Getting all dynamic children")
  let result = supervisor.get_all_dynamic_children(sup)
  case result {
    Ok(children) ->
      utils.debug_log(
        logging.Info,
        "[glixir] Found "
          <> string.inspect(list.length(children))
          <> " children",
      )
    Error(e) ->
      utils.debug_log(logging.Error, "[glixir] Failed to get children: " <> e)
  }
  result
}

/// Start a named dynamic supervisor (you must always specify child_args, child_reply types)
pub fn start_dynamic_supervisor_named(
  name: atom.Atom,
) -> Result(DynamicSupervisor(child_args, child_reply), SupervisorError) {
  utils.debug_log(
    logging.Info,
    "[glixir] Starting dynamic supervisor: " <> atom.to_string(name),
  )
  case supervisor.start_dynamic_supervisor_named(name) {
    Ok(sup) -> {
      utils.debug_log(
        logging.Info,
        "[glixir] Dynamic supervisor started successfully",
      )
      Ok(sup)
    }
    Error(error) -> {
      utils.debug_log(
        logging.Error,
        "[glixir] Dynamic supervisor start failed: " <> string.inspect(error),
      )
      Error(error)
    }
  }
}

pub fn start_dynamic_supervisor_named_safe(
  name: String,
) -> Result(DynamicSupervisor(child_args, child_reply), SupervisorError) {
  utils.debug_log(
    logging.Info,
    "[glixir] Starting dynamic supervisor: " <> name,
  )
  case supervisor.start_dynamic_supervisor_named_safe(name) {
    Ok(sup) -> {
      utils.debug_log(
        logging.Info,
        "[glixir] Dynamic supervisor started successfully",
      )
      Ok(sup)
    }
    Error(error) -> {
      utils.debug_log(
        logging.Error,
        "[glixir] Dynamic supervisor start failed: " <> string.inspect(error),
      )
      Error(error)
    }
  }
}

/// Build a bounded, type-safe child spec
pub fn child_spec(
  id id: String,
  module module: String,
  function function: String,
  args args: child_args,
  restart restart: RestartStrategy,
  shutdown_timeout shutdown_timeout: Int,
  child_type child_type: ChildType,
) -> ChildSpec(child_args, child_reply) {
  supervisor.child_spec(
    id: id,
    module: module,
    function: function,
    args: args,
    restart: restart,
    shutdown_timeout: shutdown_timeout,
    child_type: child_type,
  )
}

/// Start a child process in the supervisor (requires encoder/decoder)
pub fn start_dynamic_child(
  sup: DynamicSupervisor(child_args, child_reply),
  spec: ChildSpec(child_args, child_reply),
  encode: fn(child_args) -> List(Dynamic),
  decode: fn(Dynamic) -> Result(child_reply, String),
) -> StartChildResult(child_reply) {
  utils.debug_log(logging.Info, "[glixir] Starting child: " <> spec.id)
  let result = supervisor.start_dynamic_child(sup, spec, encode, decode)
  case result {
    supervisor.ChildStarted(_pid, _reply) ->
      utils.debug_log(
        logging.Info,
        "[glixir] Child started successfully: " <> spec.id,
      )
    supervisor.StartChildError(e) ->
      utils.debug_log(
        logging.Error,
        "[glixir] Child start failed: " <> spec.id <> " - " <> e,
      )
  }
  result
}

pub fn terminate_dynamic_child(
  sup: DynamicSupervisor(child_args, child_reply),
  child_pid: Pid,
) -> Result(Nil, String) {
  utils.debug_log(
    logging.Info,
    "[glixir] Terminating child: " <> string.inspect(child_pid),
  )

  let result = supervisor.terminate_dynamic_child(sup, child_pid)

  case result {
    Ok(_) ->
      utils.debug_log(logging.Info, "[glixir] Child terminated successfully")
    Error(e) ->
      utils.debug_log(logging.Error, "[glixir] Child termination failed: " <> e)
  }

  result
}

/// Get all dynamic children of the supervisor
pub fn which_dynamic_children(
  sup: DynamicSupervisor(child_args, child_reply),
) -> List(Dynamic) {
  utils.debug_log(logging.Info, "[glixir] Querying dynamic children")
  supervisor.which_dynamic_children(sup)
}

/// Get the count of dynamic children
pub fn count_dynamic_children(
  sup: DynamicSupervisor(child_args, child_reply),
) -> Result(supervisor.ChildCounts, String) {
  utils.debug_log(logging.Info, "[glixir] Counting dynamic children")
  supervisor.count_dynamic_children(sup)
}

// =====================
// GENSERVER (unchanged, still type safe)
// =====================
pub fn call_genserver(
  server: GenServer(Dynamic, reply),
  request: Dynamic,
  decoder: Decoder(reply),
) -> Result(reply, GenServerError) {
  genserver.call(server, request, decoder)
}

pub fn call_genserver_timeout(
  server: GenServer(Dynamic, reply),
  request: Dynamic,
  timeout: Int,
  decoder: Decoder(reply),
) -> Result(reply, GenServerError) {
  genserver.call_timeout(server, request, timeout, decoder)
}

pub fn cast_genserver(
  server: GenServer(Dynamic, reply),
  request: Dynamic,
) -> Result(Nil, GenServerError) {
  genserver.cast(server, request)
}

pub fn start_genserver(
  module: String,
  args: Dynamic,
) -> Result(GenServer(Dynamic, reply), GenServerError) {
  genserver.start_link(module, args)
}

pub fn start_genserver_named(
  module: String,
  name: atom.Atom,
  args: Dynamic,
) -> Result(GenServer(Dynamic, reply), GenServerError) {
  genserver.start_link_named(module, atom.to_string(name), args)
}

pub fn ping_genserver(
  server: GenServer(Dynamic, reply),
  msg: Dynamic,
  decoder: Decoder(reply),
) -> Result(reply, GenServerError) {
  genserver.call(server, msg, decoder)
}

pub fn get_genserver_state(
  server: GenServer(Dynamic, reply),
  msg: Dynamic,
  decoder: Decoder(reply),
) -> Result(reply, GenServerError) {
  genserver.call(server, msg, decoder)
}

pub fn call_genserver_named(
  name: atom.Atom,
  request: Dynamic,
  decoder: Decoder(reply),
) -> Result(reply, GenServerError) {
  genserver.call_named(name, request, decoder)
}

pub fn cast_genserver_named(
  name: atom.Atom,
  request: Dynamic,
) -> Result(Nil, GenServerError) {
  genserver.cast_named(name, request)
}

pub fn lookup_genserver(
  name: atom.Atom,
) -> Result(GenServer(Dynamic, reply), GenServerError) {
  genserver.lookup_name(name)
}

pub fn stop_genserver(
  server: GenServer(Dynamic, reply),
) -> Result(Nil, GenServerError) {
  genserver.stop(server)
}

pub fn genserver_pid(server: GenServer(Dynamic, reply)) -> Pid {
  genserver.pid(server)
}

// =====================
// AGENT (unchanged, still type safe)
// =====================
pub fn start_agent(state: fn() -> a) -> Result(Agent(a), AgentError) {
  agent.start(state)
}

pub fn get_agent(
  agent: Agent(a),
  fun: fn(a) -> b,
  decoder: Decoder(b),
) -> Result(b, AgentError) {
  agent.get(agent, fun, decoder)
}

pub fn get_agent_timeout(
  agent: Agent(a),
  fun: fn(a) -> b,
  timeout: Int,
  decoder: Decoder(b),
) -> Result(b, AgentError) {
  agent.get_timeout(agent, fun, timeout, decoder)
}

pub fn update_agent(agent: Agent(a), fun: fn(a) -> a) -> Result(Nil, AgentError) {
  agent.update(agent, fun)
}

pub fn cast_agent(agent: Agent(a), fun: fn(a) -> a) -> Nil {
  agent.cast(agent, fun)
}

pub fn get_and_update_agent(
  agent: Agent(a),
  fun: fn(a) -> #(b, a),
  decoder: Decoder(b),
) -> Result(b, AgentError) {
  agent.get_and_update(agent, fun, decoder)
}

pub fn stop_agent(agent: Agent(a), reason: atom.Atom) -> Result(Nil, AgentError) {
  agent.stop(agent, reason)
}

pub fn agent_pid(agent: Agent(a)) -> Pid {
  agent.pid(agent)
}

// =====================
// MAIN
// =====================
pub fn main() {
  logging.configure()
}