/**
 *            ___
 *      |     | |
 *     / \    | |
 *    |--o|===|-|
 *    |---|   |n|
 *   /     \  |o|
 *  | O     | |d|
 *  | N     |=|e|
 *  | S     | | |
 *  |_______| |_|
 *   |@| |@|  | |
 * ___________|_|_
 *
 * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
 *
 * Copyright (c) 2017 XadillaX <i@2333.moe>
 *
 * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
 */
#include "consumer_ack.h"

Nan::Persistent<v8::Function> ONSConsumerACKV8::constructor;

std::string ack_env_v = std::getenv("NODE_ONS_LOG") == NULL ?
        "" : std::getenv("NODE_ONS_LOG");

ONSConsumerACKV8::ONSConsumerACKV8() : inner(NULL), msg_id(NULL)
{
}

ONSConsumerACKV8::~ONSConsumerACKV8()
{
    inner = NULL;

    if(msg_id)
    {
        delete []msg_id;
        msg_id = NULL;
    }
}

void ONSConsumerACKV8::Init()
{
    Nan::HandleScope scope;

    v8::Local<v8::FunctionTemplate> tpl = Nan::New<v8::FunctionTemplate>(New);
    tpl->SetClassName(Nan::New("ONSConsumer").ToLocalChecked());
    tpl->InstanceTemplate()->SetInternalFieldCount(1);

    // set the v8 ack object's prototype `done`
    Nan::SetPrototypeMethod(tpl, "done", Done);

    constructor.Reset(Nan::GetFunction(tpl).ToLocalChecked());
}

NAN_METHOD(ONSConsumerACKV8::New)
{
    ONSConsumerACKV8* obj = new ONSConsumerACKV8();
    obj->Wrap(info.This());

    info.GetReturnValue().Set(info.This());
}

NAN_METHOD(ONSConsumerACKV8::Done)
{
    ONSConsumerACKV8* ack = ObjectWrap::Unwrap<ONSConsumerACKV8>(info.Holder());

    bool succ = true;
    if(info.Length() >= 1)
    {
        succ = (info[0]->IsUndefined() || info[0]->IsNull() || info[0]->ToBoolean()->Value());
    }

    // call v8 ack object's `Ack` function to emit the true `Acker`'s
    // `Ack` function and finish waiting of consume thread
    COMMON_ACTION act = succ ? COMMON_ACTION::SUCCESS : COMMON_ACTION::LATER;
    ack->Ack(act);
}