import { Result$Ok, Result$Error } from "./gleam.mjs";

export async function send_int(queue, body) {
  try {
    await queue.send(body);
    return Result$Ok(undefined);
  } catch (error) {
    return Result$Error(`${error}`);
  }
}

export async function send_string(queue, body) {
  try {
    await queue.send(body);
    return Result$Ok(undefined);
  } catch (error) {
    return Result$Error(`${error}`);
  }
}

export function messages(batch) {
  return batch.messages ?? [];
}

export function body(message) {
  return message.body;
}

export function retry(message) {
  message.retry();
}

export function ack(message) {
  message.ack();
}