// AMQP
// ====

#include "amqp_common.h"

Term amqp_ack_run(Env e, Term* f, IoWork* w) {
  LapineChannel* chan = (LapineChannel*)(intptr_t)f[0];
  if (chan == NULL || chan->conn == NULL) {
    return io_fail(e, EINVAL, "lapine: invalid channel");
  }
  uint64_t tag = (uint64_t)f[1];
  amqp_rpc_reply_t reply = amqp_basic_ack(chan->conn, chan->channel, tag, 0);
  u32 err = lapine_rpc_error(reply);
  if (err != 0) {
    return io_fail(e, err, "lapine: ack failed");
  }
  return io_tup(e, f[0], io_done(e, term_pak(CID_UNIT, 0)));
}

static void __attribute__((constructor)) amqp_ack_use(void) {
  io_eff(CID_AMQP_ACK, amqp_ack_run, 0);
}