//fastCrypto.cpp
#include <android/log.h>
#include <jni.h>
#include <native-crypto.h>

#define LOG_TAG "crypto_bridge-JNI"

#define LOGD(...) __android_log_print(ANDROID_LOG_DEBUG, LOG_TAG, __VA_ARGS__)

extern "C" {

/*
 * Copyright (c) 2003 Apple Computer, Inc. All rights reserved.
 *
 * @APPLE_LICENSE_HEADER_START@
 *
 * Copyright (c) 1999-2003 Apple Computer, Inc.  All Rights Reserved.
 *
 * This file contains Original Code and/or Modifications of Original Code
 * as defined in and that are subject to the Apple Public Source License
 * Version 2.0 (the 'License'). You may not use this file except in
 * compliance with the License. Please obtain a copy of the License at
 * http://www.opensource.apple.com/apsl/ and read it before using this
 * file.
 *
 * The Original Code and all software distributed under the License are
 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
 * Please see the License for the specific language governing rights and
 * limitations under the License.
 *
 * @APPLE_LICENSE_HEADER_END@
 */

#include <string.h>

JNIEXPORT jint JNICALL
Java_co_airbitz_fastcrypto_MoneroAsyncTask_moneroCoreCreateRequest(JNIEnv *env, jobject thiz, jobject buf, jint height) {
    char *data = (char *) env->GetDirectBufferAddress(buf);
    if (data == nullptr) {
        // Return error code for invalid buffer
        return -1;
    }

    jlong capacity = env->GetDirectBufferCapacity(buf);
    if (capacity < 0) {
        // If 'buf' is not a direct buffer, capacity could be -1;
        // Not expected here since data != nullptr, but just in case
        // Return error code for invalid capacity
        return -2;
    }

    // Safely clamp 'capacity' to SIZE_MAX to avoid overflow in case jlong > size_t
    size_t max_length = (capacity > (jlong) SIZE_MAX)
        ? SIZE_MAX
        : (size_t) capacity;

    size_t length = 0;
    const char *m_body = create_blocks_request(height, &length);
    if (m_body == nullptr) {
        // Return error code for request creation failure
        return -3;
    }


    if (length > max_length) {
        // Return error code for insufficient buffer capacity
        return -4;
    }
       
    memcpy(data, m_body, length);

    return length;
}

JNIEXPORT jstring JNICALL
Java_co_airbitz_fastcrypto_MoneroAsyncTask_extractUtxosFromBlocksResponse(JNIEnv *env, jobject thiz, jobject buf, jstring jsJsonParams) {
    char *data = (char *) env->GetDirectBufferAddress(buf);
    size_t length = (size_t) env->GetDirectBufferCapacity(buf);
    char *szJsonParams = (char *) env->GetStringUTFChars(jsJsonParams, 0);

    char *szResultHex = NULL;
    extract_utxos_from_blocks_response(data, length, szJsonParams, &szResultHex);

    // Free dynamically allocated memory to avoid memory leaks.
    env->ReleaseStringUTFChars(jsJsonParams, szJsonParams);
    
    if (szResultHex == nullptr) {
        return nullptr;
    }

    jstring out = env->NewStringUTF(szResultHex);
    free(szResultHex);

    return out;
}

JNIEXPORT jstring JNICALL
Java_co_airbitz_fastcrypto_MoneroAsyncTask_extractUtxosFromClarityBlocksResponse(JNIEnv *env, jobject thiz, jobject buf, jstring jsJsonParams) {
    char *data = (char *) env->GetDirectBufferAddress(buf);
    size_t length = (size_t) env->GetDirectBufferCapacity(buf);
    char *szJsonParams = (char *) env->GetStringUTFChars(jsJsonParams, 0);

    char *szResultHex = NULL;
    extract_utxos_from_clarity_blocks_response(data, length, szJsonParams, &szResultHex);

    // Free dynamically allocated memory to avoid memory leaks.
    env->ReleaseStringUTFChars(jsJsonParams, szJsonParams);

    if (szResultHex == nullptr) {
        return nullptr;
    }

    jstring out = env->NewStringUTF(szResultHex);
    free(szResultHex);

    return out;
}

JNIEXPORT jstring JNICALL
Java_co_airbitz_fastcrypto_MoneroAsyncTask_getTransactionPoolHashes(JNIEnv *env, jobject thiz, jobject buf) {

    char *data = (char *) env->GetDirectBufferAddress(buf);
    size_t length = (size_t) env->GetDirectBufferCapacity(buf);

    char *szResultHex = NULL;
    get_transaction_pool_hashes(data, length, &szResultHex);
    jstring out = env->NewStringUTF(szResultHex);
    free(szResultHex);

    return out;
}

JNIEXPORT jstring JNICALL
Java_co_airbitz_fastcrypto_MoneroAsyncTask_moneroCoreJNI(JNIEnv *env, jobject thiz,
                                                            jstring jsMethod,
                                                            jstring jsJsonParams) {
    char *szJsonParams = (char *) 0;
    char *szMethod = (char *) 0;

    if (jsMethod) {
        szMethod = (char *) env->GetStringUTFChars(jsMethod, 0);
        if (!szMethod) {
            return env->NewStringUTF("Invalid monero method!");
        }
    }

    if (jsJsonParams) {
        szJsonParams = (char *) env->GetStringUTFChars(jsJsonParams, 0);
        if (!szJsonParams) {
            env->ReleaseStringUTFChars(jsMethod, szMethod);
            return env->NewStringUTF("Invalid monero jsonParams!");
        }
    }

    char *szResultHex = NULL;
    fast_crypto_monero_core(szMethod, szJsonParams, &szResultHex);
    jstring out = env->NewStringUTF(szResultHex);
    free(szResultHex);
    env->ReleaseStringUTFChars(jsJsonParams, szJsonParams);
    env->ReleaseStringUTFChars(jsMethod, szMethod);
    return out;
}

}