//// This module is a wrapper around the erlang [FS](https://fs.n2o.dev/)
//// library. It allows you to create a listener for file change events for any
//// operating system.
////
//// Note: on Linux and BSD, you need `inotify-tools` installed.

import gleam/dynamic
import gleam/erlang/atom.{type Atom}
import gleam/erlang/charlist
import gleam/erlang/process
import gleam/list
import gleam/option.{type Option, None, Some}
import gleam/otp/actor.{type ErlangStartResult}
import gleam/result
import gleam/string

@external(erlang, "filespy_ffi", "identity")
fn coerce(value: a) -> b

/// Phantom type to indicate the Builder has no directories
pub type NoDirectories

/// Phantom type to indicate the Builder has directories
pub type HasDirectories

/// Phantom type to indicate the Builder has no handlers
pub type NoHandler

/// Phantom type to indicate the Builder has a handler
pub type HasHandler

/// Phantom type to indicate the Builder has no initial state
pub type NoInitialState

/// Phantom type to indicate the Builder has an initial state
pub type HasInitialState

/// Possible filesystem events
pub type Event {
  Created
  Modified
  Closed
  Deleted
  Renamed
  Attribute
  Unknown(Atom)
}

/// A filesystem change
pub type Change(custom) {
  Change(path: String, events: List(Event))
  Custom(custom)
}

/// Handler function called when an event is detected
pub type Handler =
  fn(String, Event) -> Nil

/// Handler function used with an actor handler
pub type ActorHandler(a, custom) =
  fn(Change(custom), a) -> actor.Next(Change(custom), a)

/// Opaque builder type to instantiate the listener
///
/// Instantiate it with `new`.
pub opaque type Builder(a, d, h, s, custom) {
  Builder(
    dirs: List(String),
    handler: Option(ActorHandler(a, custom)),
    initializer: Option(fn() -> a),
  )
}

/// Create a new builder
///
/// Use this with the `add_dir` and `handler` functions to configure the
/// watcher
pub fn new() -> Builder(a, NoDirectories, NoHandler, NoInitialState, Nil) {
  Builder(dirs: [], handler: None, initializer: None)
}

/// Add a directory to watch
///
/// # Examples
///
/// ```gleam
/// filespy.new()
/// |> filespy.add_dir("./watched")
/// ```
pub fn add_dir(
  builder: Builder(a, d, h, s, custom),
  directory: String,
) -> Builder(a, HasDirectories, h, s, custom) {
  Builder(initializer: builder.initializer, handler: builder.handler, dirs: [
    directory,
    ..builder.dirs
  ])
}

/// Add multiple directories at once
pub fn add_dirs(
  builder: Builder(a, d, h, s, custom),
  directories: List(String),
) -> Builder(a, HasDirectories, h, s, custom) {
  Builder(
    initializer: builder.initializer,
    handler: builder.handler,
    dirs: list.append(directories, builder.dirs),
  )
}

/// Set the handler
///
/// # Examples
///
/// ```gleam
/// filespy.new()
/// |> filespy.add_dir("./watched")
/// |> filespy.set_handler(fn (path: String, event: filespy.Event) {
///     case event {
///       filespy.Created -> {
///         io.println("File " <> path <> " created")
///       }
///       _ -> {
///         io.println("Something else happened to " <> path)
///       }
///   }
/// })
pub fn set_handler(
  builder: Builder(Nil, d, NoHandler, NoInitialState, custom),
  handler: Handler,
) -> Builder(Nil, d, HasHandler, HasInitialState, custom) {
  let wrapped_handler = fn(event: Change(custom), _state: Nil) -> actor.Next(
    Change(custom),
    Nil,
  ) {
    case event {
      Change(path, events) -> {
        list.each(events, fn(ev) { handler(path, ev) })
      }
      _ -> Nil
    }
    actor.continue(Nil)
  }
  builder
  |> set_actor_handler(wrapped_handler)
  |> set_initial_state(Nil)
}

/// Set the actor handler
///
/// Use this if you want to have a more thorough control over the generated
/// actor. You will also need to set an initial state, with `set_initial_state`.
pub fn set_actor_handler(
  builder: Builder(a, d, NoHandler, s, custom),
  handler: ActorHandler(a, custom),
) -> Builder(a, d, HasHandler, s, custom) {
  Builder(
    initializer: builder.initializer,
    dirs: builder.dirs,
    handler: Some(handler),
  )
}

/// Set the initial state
///
/// Use this if you want to have a more thorough control over the generated
/// actor. You'll only have access to this state if you set your handler with
/// `set_actor_handler`.
pub fn set_initial_state(
  builder: Builder(a, d, h, NoInitialState, custom),
  state: a,
) -> Builder(a, d, h, HasInitialState, custom) {
  Builder(
    dirs: builder.dirs,
    handler: builder.handler,
    initializer: Some(fn() { state }),
  )
}

/// Set the initializer
///
/// Use this if you want to, for example, return a subject in the state. The
/// initializer will run in the actor's `on_init`, so it'll run under the
/// watcher process
pub fn set_initializer(
  builder: Builder(a, d, h, NoInitialState, custom),
  initializer: fn() -> a,
) -> Builder(a, d, h, HasInitialState, custom) {
  Builder(
    dirs: builder.dirs,
    handler: builder.handler,
    initializer: Some(initializer),
  )
}

@external(erlang, "fs", "start_link")
fn fs_start_link(name: Atom, path: String) -> ErlangStartResult

@external(erlang, "fs", "subscribe")
fn fs_subscribe(name: Atom) -> Atom

/// Converts an atom to an event
fn to_event(from: dynamic.Dynamic) -> Result(Event, List(dynamic.DecodeError)) {
  use event <- result.try(atom.from_dynamic(from))

  let created = atom.create_from_string("created")
  let deleted = atom.create_from_string("deleted")
  let modified = atom.create_from_string("modified")
  let closed = atom.create_from_string("closed")
  let renamed = atom.create_from_string("renamed")
  let attrib = atom.create_from_string("attribute")
  let removed = atom.create_from_string("removed")

  case event {
    ev if ev == created -> Ok(Created)
    ev if ev == deleted -> Ok(Deleted)
    ev if ev == modified -> Ok(Modified)
    ev if ev == closed -> Ok(Closed)
    ev if ev == renamed -> Ok(Renamed)
    ev if ev == removed -> Ok(Deleted)
    ev if ev == attrib -> Ok(Attribute)
    other -> Ok(Unknown(other))
  }
}

/// Get a `Selector` which can be used to select for filesystem events.
pub fn selector() -> process.Selector(Change(custom)) {
  let change_selector =
    dynamic.tuple3(
      dynamic.dynamic,
      dynamic.dynamic,
      dynamic.tuple2(
        fn(l) {
          coerce(l)
          |> charlist.to_string
          |> Ok
        },
        dynamic.list(of: to_event),
      ),
    )

  process.new_selector()
  |> process.selecting_anything(fn(event) {
    case change_selector(event) {
      Ok(#(_pid, _, #(path, events))) -> Change(path: path, events: events)
      _ -> Change(path: "", events: [])
    }
  })
}

/// Get an actor `Spec` for the watcher
pub fn spec(
  builder: Builder(a, HasDirectories, HasHandler, HasInitialState, custom),
) -> actor.Spec(a, Change(custom)) {
  let assert Some(handler) = builder.handler
  let assert Some(initializer) = builder.initializer

  actor.Spec(
    init: fn() {
      let #(oks, errs) =
        builder.dirs
        |> list.map(fn(dir) {
          let atom = atom.create_from_string("fs_watcher" <> dir)
          fs_start_link(atom, dir)
          |> result.map(fn(pid) { #(pid, atom) })
        })
        |> result.partition()

      case errs {
        [] -> {
          // all good!
          oks
          |> list.each(fn(res) {
            let #(_pid, atom) = res
            fs_subscribe(atom)
          })
          actor.Ready(initializer(), selector())
        }
        errs -> {
          list.each(oks, fn(res) {
            let #(pid, _atom) = res
            process.kill(pid)
          })
          actor.Failed("Failed to start watcher: " <> string.inspect(errs))
        }
      }
    },
    init_timeout: 5000,
    loop: handler,
  )
}

/// Start an actor which will receive filesystem events
///
/// In order for this to work, you'll need to have set some directories to be
/// watched, with `add_dir`, and set a handler with either `set_handler` or
/// `set_actor_handler` and `set_initial_state`.
pub fn start(
  builder: Builder(a, HasDirectories, HasHandler, HasInitialState, custom),
) -> Result(process.Subject(Change(custom)), actor.StartError) {
  spec(builder)
  |> actor.start_spec
}