/******************************************************************************
 * Copyright © 2014-2017 The SuperNET Developers.                             *
 *                                                                            *
 * See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at                  *
 * the top-level directory of this distribution for the individual copyright  *
 * holder information and the developer policies on copyright and licensing.  *
 *                                                                            *
 * Unless otherwise agreed in a custom licensing agreement, no part of the    *
 * SuperNET software, including this file may be copied, modified, propagated *
 * or distributed except according to the terms contained in the LICENSE file *
 *                                                                            *
 * Removal or modification of this copyright notice is prohibited.            *
 *                                                                            *
 ******************************************************************************/

//
//  LP_zeroconf.c
//  marketmaker
//

int32_t LP_deposit_addr(char *p2shaddr,uint8_t *script,uint8_t taddr,uint8_t p2shtype,uint32_t timestamp,uint8_t *pubsecp33)
{
    uint8_t elsepub33[33],p2sh_rmd160[20]; int32_t n;
    decode_hex(elsepub33,33,BOTS_BONDPUBKEY33);
    n = bitcoin_performancebond(p2sh_rmd160,script,0,timestamp,pubsecp33,elsepub33);
    bitcoin_address(p2shaddr,taddr,p2shtype,script,n);
    return(n);
}

char *LP_zeroconf_deposit(struct iguana_info *coin,int32_t weeks,double amount,int32_t broadcast)
{
    char p2shaddr[64],*retstr,*hexstr; uint8_t script[512]; int32_t weeki,scriptlen; cJSON *argjson,*retjson,*array,*item,*obj; uint32_t timestamp; bits256 txid,sendtxid; uint64_t amount64;
    if ( strcmp(coin->symbol,"KMD") != 0 )
        return(clonestr("{\"error\":\"zeroconf deposit must be in KMD\"}"));
    if ( amount < 10.0 )
        return(clonestr("{\"error\":\"minimum zeroconf deposit is 10 KMD\"}"));
    if ( weeks < 0 || weeks > 52 )
        return(clonestr("{\"error\":\"weeks must be between 0 and 52\"}"));
    if ( weeks > 0 )
    {
        timestamp = (uint32_t)time(NULL);
        timestamp /= LP_WEEKMULT;
        timestamp += weeks+1;
        timestamp *= LP_WEEKMULT;
        weeki = (timestamp - LP_FIRSTWEEKTIME) / LP_WEEKMULT;
        if ( weeks >= 10000 )
            return(clonestr("{\"error\":\"numweeks must be less than 10000\"}"));
    } else timestamp = (uint32_t)time(NULL) + 300, weeki = 0;
    scriptlen = LP_deposit_addr(p2shaddr,script,coin->taddr,coin->p2shtype,timestamp,G.LP_pubsecp);
    argjson = cJSON_CreateObject();
    array = cJSON_CreateArray();
    item = cJSON_CreateObject();
    jaddnum(item,p2shaddr,amount);
    jaddi(array,item);
    item = cJSON_CreateObject();
    amount64 = (amount * SATOSHIDEN) / 1000;
    amount64 = (amount64 / 10000) * 10000 + weeki;
    jaddnum(item,BOTS_BONDADDRESS,dstr(amount64));
    jaddi(array,item);
    item = cJSON_CreateObject();
    jaddnum(item,coin->smartaddr,0.0001);
    jaddi(array,item);
    jadd(argjson,"outputs",array);
    printf("deposit.(%s)\n",jprint(argjson,0));
    if ( (retstr= LP_withdraw(coin,argjson)) != 0 )
    {
        if ( (retjson= cJSON_Parse(retstr)) != 0 )
        {
            if ( jobj(retjson,"result") != 0 )
                jdelete(retjson,"result");
            jaddstr(retjson,"address",p2shaddr);
            jaddnum(retjson,"expiration",timestamp);
            jaddnum(retjson,"deposit",amount);
            if ( (obj= jobj(retjson,"complete")) != 0 && is_cJSON_True(obj) != 0 && (hexstr= jstr(retjson,"hex")) != 0 )
            {
                txid = jbits256(retjson,"txid");
                if ( broadcast != 0 )
                {
                    if (bits256_nonz(txid) != 0 )
                    {
                        sendtxid = LP_broadcast("deposit","KMD",hexstr,txid);
                        if ( bits256_cmp(sendtxid,txid) != 0 )
                        {
                            jaddstr(retjson,"error","broadcast txid mismatch");
                            jaddbits256(retjson,"broadcast",sendtxid);
                            free(retstr);
                            return(jprint(retjson,1));
                        }
                        else
                        {
                            jaddstr(retjson,"result","success");
                            jaddbits256(retjson,"broadcast",sendtxid);
                            free(retstr);
                            return(jprint(retjson,1));
                        }
                    }
                    else
                    {
                        jaddstr(retjson,"error","couldnt broadcast since no txid created");
                        free(retstr);
                        return(jprint(retjson,1));
                    }
                }
                else
                {
                    jaddstr(retjson,"result","success");
                    free(retstr);
                    return(jprint(retjson,1));
                }
            }
            else
            {
                jaddstr(retjson,"error","couldnt create deposit txid");
                free(retstr);
                return(jprint(retjson,1));
            }
            free_json(retjson);
        }
        free(retstr);
    }
    return(clonestr("{\"error\":\"error with LP_withdraw for zeroconf deposit\"}"));
}

char *LP_zeroconf_claim(struct iguana_info *coin,char *depositaddr,uint32_t expiration)
{
    static void *ctx;
    uint8_t redeemscript[512],userdata[64]; char vinaddr[64],str[65],*signedtx=0; uint32_t timestamp,now,redeemlen; int32_t i,n,height,utxovout,userdatalen; bits256 signedtxid,utxotxid,sendtxid; int64_t sum,destamount,satoshis; cJSON *array,*item,*txids,*retjson;
    if ( ctx == 0 )
        ctx = bitcoin_ctx();
    if ( strcmp(coin->symbol,"KMD") != 0 )
        return(clonestr("{\"error\":\"zeroconf deposit must be in KMD\"}"));
    now = (uint32_t)time(NULL);
    sum = 0;
    txids = cJSON_CreateArray();
    timestamp = (now / LP_WEEKMULT) * LP_WEEKMULT + LP_WEEKMULT;
    while ( timestamp > LP_FIRSTWEEKTIME )
    {
        if ( expiration != 0 )
            timestamp = expiration;
        else timestamp -= LP_WEEKMULT;
        redeemlen = LP_deposit_addr(vinaddr,redeemscript,coin->taddr,coin->p2shtype,timestamp,G.LP_pubsecp);
        if ( strcmp(depositaddr,vinaddr) == 0 )
        {
            printf("found %s at timestamp.%u\n",vinaddr,timestamp);
            if ( (array= LP_listunspent(coin->symbol,vinaddr)) != 0 )
            {
                userdata[0] = 0x51;
                userdatalen = 1;
                utxovout = 0;
                if ( (n= cJSON_GetArraySize(array)) > 0 )
                {
                    for (i=0; i<n; i++)
                    {
                        item = jitem(array,i);
                        satoshis = LP_listunspent_parseitem(coin,&utxotxid,&utxovout,&height,item);
                        if ( (signedtx= basilisk_swap_bobtxspend(&signedtxid,0,"zeroconfclaim",coin->symbol,coin->wiftaddr,coin->taddr,coin->pubtype,coin->p2shtype,coin->isPoS,coin->wiftype,ctx,G.LP_privkey,0,redeemscript,redeemlen,userdata,userdatalen,utxotxid,utxovout,coin->smartaddr,G.LP_pubsecp,0xffffffff,0,&destamount,satoshis-coin->txfee,coin->smartaddr,vinaddr,0,coin->zcash)) != 0 )
                        {
                            sendtxid = LP_broadcast("claim","KMD",signedtx,signedtxid);
                            if ( bits256_cmp(sendtxid,signedtxid) == 0 )
                            {
                                jaddibits256(txids,sendtxid);
                                sum += (satoshis-coin->txfee);
                            }
                            else printf("error sending %s\n",bits256_str(str,signedtxid));
                            free(signedtx);
                        } else printf("error claiming zeroconf deposit %s/v%d %.8f\n",bits256_str(str,utxotxid),utxovout,dstr(satoshis));
                    }
                }
                free_json(array);
                retjson = cJSON_CreateObject();
                jaddstr(retjson,"result","success");
                jaddnum(retjson,"claimed",dstr(sum));
                jadd(retjson,"txids",txids);
                return(jprint(retjson,1));
            }
        }
        if ( expiration != 0 )
            break;
    }
    return(clonestr("{\"error\":\"no zeroconf deposits to claim\"}"));
}

void LP_zeroconf_deposits(struct iguana_info *coin)
{
    cJSON *array,*item,*txjson,*vouts,*v,*sobj; uint32_t timestamp; int32_t i,n,redeemlen,len,numvouts,height,vout,weeki; bits256 txid; char *scriptstr,coinaddr[64],p2shaddr[64]; int64_t satoshis,amount64; uint8_t redeemscript[512],spendscript[512],*pub33;
    if ( (array= LP_listunspent("KMD",BOTS_BONDADDRESS)) != 0 )
    {
        printf("ZEROCONF.(%s)\n",jprint(array,0));
        if ( (n= cJSON_GetArraySize(array)) > 0 )
        {
            for (i=0; i<n; i++)
            {
                item = jitem(array,i);
                amount64 = LP_listunspent_parseitem(coin,&txid,&vout,&height,item);
                printf("amount64 %.8f vout.%d (%s)\n",dstr(amount64),vout,jprint(item,0));
                if ( vout == 1 )
                {
                    weeki = (amount64 % 10000);
                    timestamp = LP_FIRSTWEEKTIME + weeki*LP_WEEKMULT;
                    if ( weeki >= 0 && (txjson= LP_gettx(coin->symbol,txid)) != 0 )
                    {
                        if ( (vouts= jarray(&numvouts,txjson,"vout")) > 0 )
                        {
                            // get pubkey from vout.2
                            v = jitem(vouts,0);
                            satoshis = LP_value_extract(v,0);
                            if ( (sobj= jobj(v,"scriptPubKey")) != 0 )
                            {
                                if ( (scriptstr= jstr(sobj,"hex")) != 0 )
                                {
                                    printf("amount64 %.8f vout.%d (%s) weeki.%d %.8f (%s)\n",dstr(amount64),vout,jprint(v,0),weeki,dstr(satoshis),scriptstr);
                                    len = (int32_t)strlen(scriptstr) >> 1;
                                    if ( len <= sizeof(spendscript)/sizeof(*spendscript) )
                                    {
                                        decode_hex(spendscript,len,scriptstr);
                                        if ( spendscript[11] == 33 )
                                        {
                                            pub33 = &spendscript[12];
                                            redeemlen = LP_deposit_addr(p2shaddr,redeemscript,coin->taddr,coin->p2shtype,timestamp,pub33);
                                            if ( len == redeemlen && (timestamp % LP_WEEKMULT) == 0 )
                                            {
                                                bitcoin_address(coinaddr,coin->taddr,coin->pubtype,pub33,33);
                                                printf("%s -> matched %s script t.%u weeki.%d deposit %.8f\n",coinaddr,p2shaddr,timestamp,(timestamp-LP_FIRSTWEEKTIME)/LP_WEEKMULT,dstr(satoshis));
                                                // add to pubp->credits;
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
        free_json(array);
    }
}

int32_t LP_dynamictrust(bits256 pubkey,int64_t kmdvalue)
{
    struct LP_pubkey_info *pubp;
    if ( (pubp= LP_pubkeyfind(pubkey)) != 0 )
    {
        if ( pubp->bondvalue > pubp->swaps_kmdvalue+kmdvalue )
            return(1);
    }
    return(0);
}