rsvim_core 0.1.3-alpha.2

//! Messages that are sent to [`JsRuntime`](crate::js::JsRuntime).

use crate::buf::BufferId;
use crate::js::TaskId;
use crate::js::TimerId;
use crate::prelude::*;
use crate::ui::tree::NodeId;
use compact_str::CompactString;
use tokio::sync::mpsc::UnboundedSender;
use tokio::time::Instant;

#[derive(Debug)]
/// Message sent to [`JsRuntime`](crate::js::JsRuntime).
pub enum JsMessage {
  /// Event loop notify Js runtime to shutdown this thread.
  TimeoutResp(TimeoutResp),

  /// Event loop send ex command to js runtime to run.
  ExCommandReq(ExCommandReq),

  /// Master send js runtime the result of load import
  LoadImportResp(LoadImportResp),

  /// Master send js runtime the result of tick again
  TickAgainResp,

  /// Master send js runtime the result of fs open
  FsOpenResp(FsOpenResp),

  /// Master send js runtime the result of fs read
  FsReadResp(FsReadResp),

  /// Master send js runtime the result of fs read_file
  FsReadFileResp(FsReadFileResp),

  /// Master send js runtime the result of fs read_text_file
  FsReadTextFileResp(FsReadTextFileResp),

  /// Master send js runtime the result of fs write
  FsWriteResp(FsWriteResp),

  /// Master send js runtime the result of load tree-sitter parser.
  LoadTreeSitterParserResp(LoadTreeSitterParserResp),
}

#[derive(Debug)]
pub struct TimeoutResp {
  pub timer_id: TimerId,
  pub expire_at: Instant,
  pub delay: u32,
  pub repeated: bool,
}

#[derive(Debug)]
pub struct ExCommandReq {
  pub payload: CompactString,
  pub current_buf_id: BufferId,
  pub current_win_id: NodeId,
}

#[derive(Debug)]
pub struct LoadImportResp {
  pub task_id: TaskId,

  // type: `ModuleSource`
  pub maybe_source: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct FsOpenResp {
  pub task_id: TaskId,

  // type: `usize`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct FsReadResp {
  pub task_id: TaskId,

  // type: `Vec<u8>`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct FsReadFileResp {
  pub task_id: TaskId,

  // type: `Vec<u8>`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct FsReadTextFileResp {
  pub task_id: TaskId,

  // type: `Vec<u8>`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct FsWriteResp {
  pub task_id: TaskId,

  // type: `usize`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

#[derive(Debug)]
pub struct LoadTreeSitterParserResp {
  pub task_id: TaskId,

  // type: `Vec<String>`
  pub maybe_result: Option<TheResult<Vec<u8>>>,
}

/// Send js message in sync/blocking way, with tokio's "current_runtime".
pub fn send_to_jsrt(master_tx: UnboundedSender<JsMessage>, message: JsMessage) {
  master_tx.send(message).unwrap();
}