btcmortgage/scripts/btcMortgage.js

(function (EXPORTS) {
    const btcMortgage = EXPORTS;

    //USERS: B: Borrower, L: Lender, C: Coborrower/Collateral provider, T: Trusted banker (us)

    const APP_NAME = "BTCMortgage";
    const APP_IDENTIFIER = "BTC Mortgage";
    // const BANKER_ID = "F6uMddaTDCZgojENbqRnFo5PCknArE7dKz";
    const BANKER_ID = "FPFeL5PXzW9bGosUjQYCxTHSMHidnygvvd";
    const BANKER_PUBKEY = '03EE0FB1868EE7D03BC741B10CD56057769445C7D37703115E428A93236C714E61';

    const CURRENCY = "usd";
    const ALLOWED_DEVIATION = 0.98, //ie, upto 2% of decrease in rate can be accepted in processing stage
        WAIT_TIME = 24 * 60 * 60 * 1000;//24 hrs
    const PERIOD_REGEX = /^[1-9]\d{0,4}(Y|M|D)$/,
        TXID_REGEX = /^[0-9a-f]{64}$/i,
        PERCENT_REGEX = /^(100|\d{1,2}(\.\d{1,8})?)$/,
        VALUE_REGEX = /^\d+(\.\d{1,8})?$/;

    const
        TYPE_LOAN_COLLATERAL_REQUEST = "type_loan_collateral_request",
        TYPE_LOAN_REQUEST = "type_loan_request",
        TYPE_LENDER_RESPONSE = "type_loan_response",
        TYPE_COLLATERAL_LOCK_REQUEST = "type_collateral_lock_request",
        TYPE_COLLATERAL_LOCK_ACK = "type_collateral_lock_ack",
        TYPE_LOAN_CLOSED_ACK = "type_loan_closed_ack",
        TYPE_UNLOCK_COLLATERAL_REQUEST = "type_unlock_collateral_request",
        TYPE_UNLOCK_COLLATERAL_ACK = "type_unlock_collateral_ack",
        TYPE_REFUND_COLLATERAL_REQUEST = "type_refund_collateral_request",
        TYPE_REFUND_COLLATERAL_ACK = "type_refund_collateral_ack",
        TYPE_LIQUATE_COLLATERAL_REQUEST = "type_liquate_collateral_request",
        TYPE_LIQUATE_COLLATERAL_ACK = "type_liquate_collateral_ack",
        TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST = "type_pre_liquidate_collateral_request"

    const POLICIES = {}, LOANS = {};
    const owned_collateral_locks = {};

    const toFixedDecimal = value => parseFloat((value).toFixed(8));

    function encodePeriod(str) {

        if (typeof str != 'string')
            throw "passed value must be string";

        if (PERIOD_REGEX.test(str)) //already in format
            return str;

        let P = '', n = 0;
        str.toLowerCase().replace(/,/g, '').split(" ").forEach(s => {
            if (!isNaN(s))
                n = parseInt(s);
            else switch (s) {
                case "year(s)": case "year": case "years": P += (n + 'Y'); n = 0; break;
                case "month(s)": case "month": case "months": P += (n + 'M'); n = 0; break;
                case "day(s)": case "day": case "days": P += (n + 'D'); n = 0; break;
            }
        });

        if (!PERIOD_REGEX.test(P)) {//not in format: something wrong
            console.error(`encodePeriod('${str}') failed`, P)
            throw "Invalid period";
        }

        return P;
    }

    function decodePeriod(str) {
        if (typeof str != 'string')
            throw "passed value must be string";

        else if (!PERIOD_REGEX.test(str)) //not in format
            throw "Invalid period";

        let n = parseInt(str);
        let v = str[str.length - 1];

        switch (v) {
            case 'Y': return n + " " + (n == 1 ? "year" : "years");
            case 'M': return n + " " + (n == 1 ? "month" : "months");
            case "D": return n + " " + (n == 1 ? "day" : "days");
        }

    }

    const yearDiff = (d1 = null, d2 = null) => {
        d1 = d1 ? new Date(d1) : new Date();
        d2 = d2 ? new Date(d2) : new Date();
        let y = d1.getYear() - d2.getYear(),
            m = d1.getMonth() - d2.getMonth(),
            d = d1.getDate() - d2.getDate()
        return y + m / 12 + d / 365;
    }

    function calcAllowedLoan(collateralQuantity, loan_collateral_ratio) {
        return toFixedDecimal(collateralQuantity * loan_collateral_ratio);
    }

    function calcRequiredCollateral(loanEquivalent, loan_collateral_ratio) {
        return toFixedDecimal(loanEquivalent / loan_collateral_ratio);
    }

    function calcDueAmount(loan_amount, policy_id, open_time, close_time = Date.now()) {
        let policy = POLICIES[policy_id],
            duration = yearDiff(close_time, open_time);
        let interest_amount = loan_amount * policy.interest * duration;
        let due_amount = loan_amount + interest_amount;
        return toFixedDecimal(due_amount);
    }

    function calcRateRatio(current_rate, start_rate) {
        let rate_ratio = 1 + (current_rate - start_rate) / start_rate;
        return toFixedDecimal(rate_ratio);
    }

    function findLocker(coborrower_pubKey, lender_pubKey) {
        return btcOperator.multiSigAddress([coborrower_pubKey, lender_pubKey, BANKER_PUBKEY], 2);
    }

    function extractPubKeyFromSign(sign) {
        return sign.split('.')[0];
    }

    const util = btcMortgage.util = {
        toFixedDecimal,
        encodePeriod, decodePeriod,
        calcAllowedLoan, calcRequiredCollateral, calcDueAmount, calcRateRatio,
        findLocker, extractPubKeyFromSign
    }

    Object.defineProperties(util, {
        USER_DB: {
            get: () => APP_NAME + '#' + floCrypto.toFloID(floDapps.user.id)
        }
    })

    //get BTC rates
    const getRate = btcMortgage.getRate = {};

    getRate["BTC"] = function () {
        return new Promise((resolve, reject) => {
            fetch('https://api.coinlore.net/api/ticker/?id=90').then(response => {
                if (response.ok) {
                    response.json()
                        .then(result => resolve(parseFloat(result[0].price_usd)))
                        .catch(error => reject(error));
                } else
                    reject(response.status);
            }).catch(error => reject(error));
        });
    }

    btcMortgage.init = function () {
        return new Promise((resolve, reject) => {
            initDB().then(result => {
                console.log(result);
                loadOwnedCollateralLocksFromIDB().then(_ => {
                    readPoliciesFromBlockchain().then(policies => {
                        readAllLoans().then(loans => {
                            console.log("Loans", loans);
                            resolve("App initiation successful")
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function initDB() {
        return new Promise((resolve, reject) => {
            let obs = { lastTx: {}, policies: {}, loans: {}, outbox: {}, inbox: {}, owned_collateral_locks: {}, fail_safe: {} }
            compactIDB.initDB(util.USER_DB, obs).then(result => {
                compactIDB.setDefaultDB(util.USER_DB);
                resolve(APP_IDENTIFIER + " user DB initiated");
            }).catch(error => reject(error))
        })
    }

    function loadOwnedCollateralLocksFromIDB() {
        return new Promise((resolve, reject) => {
            compactIDB.readAllData("owned_collateral_locks").then(result => {
                for (let c in result)
                    owned_collateral_locks[c] = result[c];
                resolve(owned_collateral_locks);  //MAYBE: resolve a copy of it?
            }).catch(error => reject(error))
        })
    }

    //function to read all policy from blockchain
    function readPoliciesFromBlockchain() {
        return new Promise((resolve, reject) => {
            const LASTTX_IDB_KEY = "B#" + BANKER_ID
            compactIDB.readData("lastTx", LASTTX_IDB_KEY).then(lastTx => {
                var query_options = { sentOnly: true, tx: true, filter: d => typeof d == 'string' && d.startsWith(APP_IDENTIFIER) };
                if (typeof lastTx == 'number')  //lastTx is tx count (*backward support)
                    query_options.ignoreOld = lastTx;
                else if (typeof lastTx == 'string') //lastTx is txid of last tx
                    query_options.after = lastTx;
                floBlockchainAPI.readData(BANKER_ID, query_options).then(result => {
                    let p = [];
                    for (var i = result.items.length - 1; i >= 0; i--) {
                        let t = result.items[i];
                        if (t.data.startsWith(LOAN_POLICY_IDENTIFIER)) {
                            let policy_id = t.txid,
                                policy_details = parsePolicyData(t.data, t.time);
                            p.push(compactIDB.addData("policies", policy_details, policy_id));
                        }
                    }
                    p.push(compactIDB.writeData("lastTx", result.lastItem, LASTTX_IDB_KEY))
                    Promise.all(p).then(result => {
                        compactIDB.readAllData("policies").then(result => {
                            for (let p in result)
                                POLICIES[p] = result[p];
                            resolve(POLICIES);  //MAYBE: resolve a copy of it?
                        })
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //function to read all loan details of the user
    function readAllLoans() {
        return new Promise((resolve, reject) => {
            let user_floID = floCrypto.toFloID(floDapps.user.id);
            const LASTTX_IDB_KEY = "U#" + user_floID;
            compactIDB.readData("lastTx", LASTTX_IDB_KEY).then(lastTx => {
                var query_options = { tx: true, filter: d => typeof d == 'string' && d.includes(APP_IDENTIFIER) };
                if (typeof lastTx == 'number')  //lastTx is tx count (*backward support)
                    query_options.ignoreOld = lastTx;
                else if (typeof lastTx == 'string') //lastTx is txid of last tx
                    query_options.after = lastTx;
                floBlockchainAPI.readData(user_floID, query_options).then(result => {
                    let p = [];
                    for (var i = result.items.length - 1; i >= 0; i--) {
                        let t = result.items[i];
                        if (t.data.startsWith(LOAN_DETAILS_IDENTIFIER))
                            p.push(validateAndStoreLoanOpenDetails(t));
                        else if (t.data.includes(LOAN_CLOSING_IDENTIFIER))
                            p.push(validateAndStoreLoanCloseDetails(t));
                        else if (t.data.includes(LOAN_FAILURE_IDENTIFIER) && t.senders.has(BANKER_ID)) //Failure data can only be sent by banker
                            p.push(validateAndStoreLoanFailDetails(t));
                    }
                    p.push(compactIDB.writeData("lastTx", result.lastItem, LASTTX_IDB_KEY));
                    Promise.all(p).then(_ => {
                        compactIDB.readAllData("loans").then(result => {
                            for (let l in result)
                                LOANS[l] = result[l];
                            resolve(LOANS);  //MAYBE: resolve a copy of it?
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validateAndStoreLoanOpenDetails(t) {
        return new Promise((resolve, reject) => {
            let loan_id = t.txid,
                loan_details = parseLoanOpenData(t.data, t.txid, t.time);
            floBlockchainAPI.getTx(loan_details.loan_transfer_id).then(transfer_tx => {
                let parsed_loan_transfer = parseLoanTransferData(transfer_tx.floData, transfer_tx.time);
                Object.assign(loan_details, parsed_loan_transfer);
                validateLoanDetails(loan_details).then(result => {
                    compactIDB.addData("loans", loan_details, loan_id)
                        .then(result => resolve(result))
                        .catch(error => reject(error))
                }).catch(_ => resolve(null)) //validation fails, no need to reject DB write
            })
        })
    }

    function validateAndStoreLoanCloseDetails(t) {
        return new Promise((resolve, reject) => {
            let closing_details = parseLoanCloseData(t.data, t.txid, t.time);
            compactIDB.readData("loans", closing_details.loan_id).then(loan_details => {
                if (!loan_details) {
                    console.warn(`Loan#${closing_details.loan_id} not found in local DB`)
                    return resolve(null);
                }
                validateLoanClosing(loan_details, closing_details).then(result => {
                    let loan_id = loan_details.loan_id;
                    Object.assign(loan_details, closing_details);
                    compactIDB.writeData("loans", loan_details, loan_id)
                        .then(result => resolve(result))
                        .catch(error => reject(error))
                }).catch(_ => resolve(null)) //validation fails, no need to reject DB write
            }).catch(error => reject(error))
        })
    }

    function validateAndStoreLoanFailDetails(t) {
        return new Promise((resolve, reject) => {
            if (!t.senders.has(BANKER_ID)) //Data not authorized by banker, abort
                return resolve(null);
            let failure_details = parseLoanFailData(t.data, t.txid, t.time);
            compactIDB.readData("loans", failure_details.loan_id).then(loan_details => {
                if (!loan_details) {
                    console.warn(`Loan#${failure_details.loan_id} not found in local DB`)
                    return resolve(null);
                }
                validateLoanFailure(loan_details, failure_details).then(result => {
                    let loan_id = loan_details.loan_id;
                    Object.assign(loan_details, failure_details);
                    compactIDB.writeData("loans", loan_details, loan_id)
                        .then(result => resolve(result))
                        .catch(error => reject(error))
                }).catch(_ => resolve(null)) //validation fails, no need to reject DB write
            }).catch(error => reject(error))
        })
    }

    //Policy details 
    const LOAN_POLICY_IDENTIFIER = APP_IDENTIFIER + ":Loan policy";
    function stringifyPolicyData(duration, interest, pre_liquidation_threshold, loan_collateral_ratio) {
        pre_liquidation_threshold = (pre_liquidation_threshold === null) ? 'NA' : pre_liquidation_threshold + "%";
        return [
            LOAN_POLICY_IDENTIFIER,
            "Duration:" + decodePeriod(duration),
            "Interest per annum:" + interest + "%",
            "Pre-Liquidation threshold:" + pre_liquidation_threshold,
            "Loan to Collateral ratio:" + loan_collateral_ratio + "%"
        ].join('|');
    }

    btcMortgage.writePolicy = function (banker_privKey, duration, interest, pre_liquidation_threshold, loan_collateral_ratio) {
        return new Promise((resolve, reject) => {
            if (!floCrypto.verifyPrivKey(banker_privKey, BANKER_ID))
                return reject("Invalid private key for banker");
            if (!PERIOD_REGEX.test(duration))
                return reject("Invalid duration, not in format");
            if (!PERCENT_REGEX.test(interest))
                return reject("Invalid interest");
            if (pre_liquidation_threshold !== null && !PERCENT_REGEX.test(pre_liquidation_threshold))
                return reject("Invalid pre_liquidation_threshold");
            if (!PERCENT_REGEX.test(loan_collateral_ratio))
                return reject("Invalid loan_collateral_ratio");
            let policy_text = stringifyPolicyData(duration, interest, pre_liquidation_threshold, loan_collateral_ratio);
            console.log("POLICY TEXT", policy_text);
            floBlockchainAPI.writeData(BANKER_ID, policy_text, banker_privKey, BANKER_ID)
                .then(result => resolve(result))
                .catch(error => reject(error))
        })
    }

    function parsePolicyData(str, tx_time) {
        let splits = str.split('|');
        if (splits[0] !== LOAN_POLICY_IDENTIFIER)
            throw "Invalid Loan Policy data";
        var details = { policy_creation_time: tx_time * 1000 }; //s to ms
        splits.forEach(s => {
            let d = s.split(':');
            switch (d[0]) {
                case "Duration": details.duration = encodePeriod(d[1]); break;
                case "Interest per annum": details.interest = parseFloat(d[1]) / 100; break; //percentage conversion
                case "Pre-Liquidation threshold": details.pre_liquidation_threshold = parseFloat(d[1]) / 100; break; //percentage conversion
                case "Loan to Collateral ratio": details.loan_collateral_ratio = parseFloat(d[1]) / 100; break; //percentage conversion
            }
        });
        return details;
    }

    //Loan details on FLO blockchain

    const LOAN_TRANSFER_IDENTIFIER = APP_IDENTIFIER + ":Loan transfer";
    function stringifyLoanTransferData(borrower_sign, coborrower_sign) {
        return [
            LOAN_TRANSFER_IDENTIFIER,
            "Signature-B:" + borrower_sign,
            "Signature-C:" + coborrower_sign
        ].join('|');
        /*MAYDO: Maybe make it a worded sentence?
            BTC Mortgage: 
            L#${lender_floid} is lending ${loan_amount}USD (ref#${loan_transfer_id}) to B#${borrower_floid}
            inaccoradance with policy#${policy_id} 
            as mortgage on collateral#${collateral_id} (${btc_amount}BTC) provided by C#${coborrower_floid}.
            Signed by B'${borrower_sign} , C'{coborrower_sign} and L'${lender_sign}    
        */
    }

    function parseLoanTransferData(str, tx_time) {
        let splits = str.split('|');
        if (splits[1] !== LOAN_TRANSFER_IDENTIFIER)
            throw "Invalid Loan transfer data";
        var details = { open_time: tx_time * 1000 }; //s to ms
        splits.forEach(s => {
            let d = s.split(':');
            switch (d[0]) {
                case "Signature-B": details.borrower_sign = d[1]; break;
                case "Signature-C": details.coborrower_sign = d[1]; break;
            }
        });
        return details;
    }

    const LOAN_DETAILS_IDENTIFIER = APP_IDENTIFIER + ":Loan details";

    function stringifyLoanOpenData(
        borrower, loan_amount, policy_id, btc_start_rate,
        coborrower, collateral_value, collateral_lock_id,
        lender, loan_transfer_id, lender_sign, loan_opening_process_id
    ) {
        return [
            LOAN_DETAILS_IDENTIFIER,
            "Borrower:" + floCrypto.toFloID(borrower),
            "Amount:" + loan_amount + CURRENCY,
            "Policy:" + policy_id,
            "CoBorrower:" + floCrypto.toFloID(coborrower),
            "CollateralValue:" + collateral_value + "BTC",
            "CollateralLock:" + collateral_lock_id,
            "BTC rate:" + btc_start_rate + "USD",
            "Lender:" + floCrypto.toFloID(lender),
            "TokenTransfer:" + loan_transfer_id,
            "Signature-L:" + lender_sign,
            "LoanOpeningProcessID:" + loan_opening_process_id
        ].join('|');
        /*MAYDO: Maybe make it a worded sentence?
            BTC Mortgage: 
            L#${lender_floid} is lending ${loan_amount}USD (ref#${loan_transfer_id}) to B#${borrower_floid}
            inaccoradance with policy#${policy_id} 
            as mortgage on collateral#${collateral_id} (${btc_amount}BTC) provided by C#${coborrower_floid}.
            Signed by B'${borrower_sign} , C'{coborrower_sign} and L'${lender_sign}    
        */
    }

    function parseLoanOpenData(str, txid, tx_time) {
        let splits = str.split('|');
        if (splits[0] !== LOAN_DETAILS_IDENTIFIER)
            throw "Invalid Loan blockchain data";
        var details = { loan_id: txid, blocktime: tx_time * 1000 }; //s to ms
        splits.forEach(s => {
            let d = s.split(':');
            switch (d[0]) {
                case "Borrower": details.borrower = d[1]; break;
                case "Amount": details.loan_amount = parseFloat(d[1]); break;
                case "Policy": details.policy_id = d[1]; break;
                case "CoBorrower": details.coborrower = d[1]; break;
                case "CollateralValue": details.collateral_value = parseFloat(d[1]); break;
                case "CollateralLock": details.collateral_lock_id = d[1]; break;
                case "BTC price": case "BTC rate": details.btc_start_rate = parseFloat(d[1]); break;
                case "Lender": details.lender = d[1]; break;
                case "TokenTransfer": details.loan_transfer_id = d[1]; break;
                case "Signature-L": details.lender_sign = d[1]; break;
                case "LoanOpeningProcessID": details.loan_opening_process_id = d[1]; break;
            }
        });
        return details;
    }

    const getLoanDetails = btcMortgage.getLoanDetails = function (loan_id) {
        return new Promise((resolve, reject) => {
            floBlockchainAPI.getTx(loan_id).then(tx => {
                let parsed_loan_details = parseLoanOpenData(tx.floData, tx.txid, tx.time);
                floBlockchainAPI.getTx(parsed_loan_details.loan_transfer_id).then(transfer_tx => {
                    let parsed_loan_transfer = parseLoanTransferData(transfer_tx.floData, transfer_tx.time);
                    Object.assign(parsed_loan_details, parsed_loan_transfer);
                    validateLoanDetails(parsed_loan_details)
                        .then(_ => resolve(parsed_loan_details))
                        .catch(error => reject(error))
                })
            }).catch(error => reject(error))
        })
    }

    const validateLoanDetails = btcMortgage.validateLoanDetails = function (loan_details) {
        return new Promise((resolve, reject) => {
            //validate floIDs
            if (!floCrypto.validateFloID(loan_details.borrower))
                return reject("Invalid borrower floID");
            if (!floCrypto.validateFloID(loan_details.coborrower))
                return reject("Invalid coborrower floID");
            if (!floCrypto.validateFloID(loan_details.lender))
                return reject("Invalid lender floID");
            //check policy
            if (!(loan_details.policy_id in POLICIES))
                return reject("Policy not found");
            //verify signatures
            if (!verify_borrowerSign(loan_details.borrower_sign, loan_details.borrower, loan_details.loan_amount, loan_details.policy_id, loan_details.coborrower, loan_details.lender))
                return reject("Invalid borrower signature");
            if (!verify_coborrowerSign(loan_details.coborrower_sign, loan_details.coborrower, loan_details.borrower_sign, loan_details.btc_start_rate, loan_details.collateral_value, loan_details.collateral_lock_id))
                return reject("Invalid coborrower signature");
            if (!verify_lenderSign(loan_details.lender_sign, loan_details.lender, loan_details.coborrower_sign, loan_details.loan_transfer_id))
                return reject("Invalid lender signature");
            validateCollateralLock(loan_details.collateral_lock_id, extractPubKeyFromSign(loan_details.coborrower_sign), extractPubKeyFromSign(loan_details.lender_sign), loan_details.collateral_value).then(result => {
                validateLoanOpenTokenTransfer(loan_details.loan_transfer_id, loan_details.borrower, loan_details.lender, loan_details.loan_amount)
                    .then(result => resolve(true))
                    .catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    const validateCollateralLock = btcMortgage.validateCollateralLock = function (collateral_lock_id, coborrower_pubKey, lender_pubKey, collateral_value) {
        return new Promise((resolve, reject) => {
            btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                if (!collateral_tx.confirmations)
                    return reject("Collateral lock transaction not confirmed yet");
                let locker_id = findLocker(coborrower_pubKey, lender_pubKey).address;
                let locked_amt = collateral_tx.outputs.filter(o => o.address == locker_id).reduce((a, o) => a += o.value, 0);
                if (locked_amt < collateral_value)
                    return reject("Insufficient Collateral locked");
                resolve(true);
            }).catch(error => reject(error))
        })
    }

    const validateLoanOpenTokenTransfer = btcMortgage.validateLoanOpenTokenTransfer = function (loan_transfer_id, borrower, lender, loan_amount) {
        return new Promise((resolve, reject) => {
            floTokenAPI.getTx(loan_transfer_id).then(token_tx => {
                if (token_tx.parsedFloData.type != "transfer" || token_tx.parsedFloData.transferType != "token")
                    return reject("Transaction is not a token transfer");
                if (token_tx.parsedFloData.tokenIdentification != CURRENCY)
                    return reject("Transfered token is not " + CURRENCY);
                if (token_tx.transactionDetails.confirmations == 0)
                    return reject("Transaction not yet confirmed");
                if (token_tx.transactionDetails.receiverAddress != floCrypto.toFloID(borrower))
                    return reject("Receiver is not borrower");
                if (token_tx.transactionDetails.senderAddress != floCrypto.toFloID(lender))
                    return reject("Sender is not lender");
                if (token_tx.parsedFloData.tokenAmount !== loan_amount)
                    return reject("Token amount doesn't match the loan amount");
                resolve(true);
            }).catch(error => reject(error))
        })
    }

    const LOAN_CLOSING_IDENTIFIER = APP_IDENTIFIER + ":Loan closing";
    function stringifyLoanCloseData(loan_id, borrower, closing_sign) {
        return [
            LOAN_CLOSING_IDENTIFIER,
            "Borrower:" + floCrypto.toFloID(borrower),
            "Loan ID:" + loan_id,
            "Signature:" + closing_sign,
        ].join('|');
    }

    function parseLoanCloseData(str, txid, tx_time) {
        let splits = str.split('|');
        if (splits[1] !== LOAN_CLOSING_IDENTIFIER) //splits[0] will be token transfer
            throw "Invalid Loan closing data";
        var details = { close_id: txid, close_time: tx_time * 1000 }; //s to ms
        splits.forEach(s => {
            let d = s.split(':');
            switch (d[0]) {
                case "Borrower": details.borrower = d[1]; break;
                case "Loan ID": details.loan_id = d[1]; break;
                case "Signature": details.closing_sign = d[1]; break;
            }
        });
        return details;
    }

    const getLoanClosing = btcMortgage.getLoanClosing = function (loan_id, closing_txid) {
        return new Promise((resolve, reject) => {
            floBlockchainAPI.getTx(closing_txid).then(tx => {
                let closing_details = parseLoanCloseData(tx.floData, tx.txid, tx.time);
                if (loan_id !== closing_details.loan_id)
                    return reject("Closing doesn't match the loan ID")
                getLoanDetails(closing_details.loan_id).then(loan_details => {
                    validateLoanClosing(loan_details, closing_details)
                        .then(result => resolve(Object.assign(loan_details, closing_details)))
                        .catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    const validateLoanClosing = btcMortgage.validateLoanClosing = function (loan_details, closing_details) {
        return new Promise((resolve, reject) => {
            if (closing_details.loan_id !== loan_details.loan_id)
                return reject("Closing doesn't belong to this loan")
            if (!floCrypto.validateFloID(closing_details.borrower))
                return reject("Invalid borrower floID");
            if (closing_details.borrower != loan_details.borrower)
                return reject("Borrower ID is different");
            if (!verify_closingSign(closing_details.closing_sign, closing_details.borrower, closing_details.loan_id, loan_details.lender_sign))
                return reject("Invalid closing signature");
            validateLoanCloseTokenTransfer(closing_details.close_id, loan_details.borrower, loan_details.lender, loan_details.loan_amount, loan_details.policy_id, loan_details.open_time, closing_details.close_time)
                .then(result => resolve(true))
                .catch(error => reject(error))
        })
    }

    const validateLoanCloseTokenTransfer = btcMortgage.validateLoanCloseTokenTransfer = function (close_id, borrower, lender, loan_amount, policy_id, open_time, close_time) {
        return new Promise((resolve, reject) => {
            floTokenAPI.getTx(close_id).then(token_tx => {
                if (token_tx.parsedFloData.type != "transfer" || token_tx.parsedFloData.transferType != "token")
                    return reject("Transaction is not a token transfer");
                if (token_tx.parsedFloData.tokenIdentification != CURRENCY)
                    return reject("Transfered token is not " + CURRENCY);
                if (token_tx.transactionDetails.confirmations == 0)
                    return reject("Transaction not yet confirmed");
                if (token_tx.transactionDetails.receiverAddress != floCrypto.toFloID(lender))
                    return reject("Receiver is not lender");
                if (token_tx.transactionDetails.senderAddress != floCrypto.toFloID(borrower))
                    return reject("Sender is not borrower");
                let repay_amount = calcDueAmount(loan_amount, policy_id, open_time, close_time);
                if (token_tx.parsedFloData.tokenAmount < repay_amount)
                    return reject("Token amount is less than loan repayment amount");
                resolve(true);
            }).catch(error => reject(error))
        })
    }

    //Loan failure can only be written by Trusted banker (T)
    const LOAN_FAILURE_IDENTIFIER = APP_IDENTIFIER + ":Loan failure";
    function stringifyLoanFailData(loan_id, liquidation_id, btc_liquid_rate, lender, liquidation_sign) {
        return [
            LOAN_FAILURE_IDENTIFIER,
            "Lender:" + floCrypto.toFloID(lender),
            "Loan ID:" + loan_id,
            "Liquidation:" + liquidation_id,
            "BTC rate:" + btc_liquid_rate + "USD",
            "Signature:" + liquidation_sign
        ].join('|');
    }

    function parseLoanFailData(str, txid, tx_time) {
        let splits = str.split('|');
        if (splits[0] !== LOAN_FAILURE_IDENTIFIER) //splits[0] will be token transfer
            throw "Invalid Loan failure data";
        var details = { fail_id: txid, fail_time: tx_time * 1000 }; //s to ms
        splits.forEach(s => {
            let d = s.split(':');
            switch (d[0]) {
                case "Lender": details.lender = d[1]; break;
                case "Loan ID": details.loan_id = d[1]; break;
                case "Liquidation": details.liquidation_id = d[1]; break;
                case "BTC rate": details.btc_liquid_rate = parseFloat(d[1]); break;
                case "Signature": details.liquidation_sign = d[1]; break;
            }
        });
        return details;
    }

    const getLoanFailure = btcMortgage.getLoanFailure = function (loan_id, failure_txid) {
        return new Promise((resolve, reject) => {
            floBlockchainAPI.getTx(failure_txid).then(tx => {
                let failure_details = parseLoanFailData(tx.floData, tx.txid, tx.time);
                if (loan_id !== failure_details.loan_id)
                    return reject("Failure doesn't match the loan ID")
                getLoanDetails(failure_details.loan_id).then(loan_details => {
                    validateLoanFailure(loan_details, failure_details)
                        .then(result => resolve(Object.assign(loan_details, failure_details)))
                        .catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    const validateLoanFailure = btcMortgage.validateLoanFailure = function (loan_details, failure_details) {
        return new Promise((resolve, reject) => {
            if (failure_details.loan_id !== loan_details.loan_id)
                return reject("Failure doesn't belong to this loan")
            if (!floCrypto.validateFloID(failure_details.lender))
                return reject("Invalid lender floID");
            if (failure_details.lender != loan_details.lender)
                return reject("Lender ID is different");
            if (!verify_liquidationSign(failure_details.liquidation_sign, failure_details.lender, failure_details.loan_id, loan_details.lender_sign, failure_details.btc_liquid_rate))
                return reject("Invalid closing signature");
            resolve(true)
        })
    }

    /*Signature and verification */
    function sign_borrower(privKey, loan_amount, policy_id, coborrower, lender) {
        let borrower_floID = floCrypto.toFloID(floDapps.user.id),
            coborrower_floID = floCrypto.toFloID(coborrower),
            lender_floID = floCrypto.toFloID(lender);
        //validate values before signing
        if (!floCrypto.verifyPrivKey(privKey, borrower_floID))
            throw "Invalid Private key for borrower";
        if (typeof loan_amount !== "number" || !VALUE_REGEX.test(loan_amount))
            throw "Invalid loan amount";
        if (!(policy_id in POLICIES))
            throw "Invalid Policy";
        if (!floCrypto.validateFloID(coborrower_floID, true))
            throw "Invalid coborrower floID";
        if (!floCrypto.validateFloID(lender_floID, true))
            throw "Invalid lender floID";
        //sign the value-data
        let timestamp = Date.now();
        let doc_array = [timestamp, borrower_floID, coborrower_floID, lender_floID, loan_amount, policy_id];
        let sign_part = floCrypto.signData(doc_array.join("|"), privKey);
        let pubKey = floCrypto.getPubKeyHex(privKey);
        let borrower_sign = [pubKey, sign_part, timestamp].join(".")
        return borrower_sign;
    }

    function verify_borrowerSign(borrower_sign, borrower, loan_amount, policy_id, coborrower, lender) {
        //split the signature part
        let sign_splits = borrower_sign.split('.');
        let borrower_pubKey = sign_splits[0],
            sign_part = sign_splits[1],
            timestamp = sign_splits[2];
        let borrower_floID = floCrypto.getFloID(borrower_pubKey),
            coborrower_floID = floCrypto.toFloID(coborrower),
            lender_floID = floCrypto.toFloID(lender);
        //validate values
        if (!floCrypto.verifyPubKey(borrower_pubKey, borrower))
            throw "Invalid public key";
        if (typeof loan_amount !== "number" || !VALUE_REGEX.test(loan_amount))
            throw "Invalid loan amount";
        if (!(policy_id in POLICIES))
            throw "Invalid Policy";
        if (!floCrypto.validateFloID(borrower_floID, true))
            throw "Invalid borrower floID";
        if (!floCrypto.validateFloID(coborrower_floID, true))
            throw "Invalid coborrower floID";
        if (!floCrypto.validateFloID(lender_floID, true))
            throw "Invalid lender floID";
        //verify the signature
        let doc_array = [timestamp, borrower_floID, coborrower_floID, lender_floID, loan_amount, policy_id];
        if (floCrypto.verifySign(doc_array.join("|"), sign_part, borrower_pubKey))
            return timestamp;
        else return false;
    }

    function sign_coborrower(privKey, borrower_sign, collateral_rate, collateral_value, collateral_lock_id) {
        let coborrower_floID = floCrypto.toFloID(floDapps.user.id);
        //validate values before signing
        if (!floCrypto.verifyPrivKey(privKey, coborrower_floID))
            throw "Invalid Private key for coborrower";
        if (typeof collateral_rate !== "number" || !VALUE_REGEX.test(collateral_rate))
            throw "Invalid collateral rate";
        if (typeof collateral_value !== "number" || !VALUE_REGEX.test(collateral_value))
            throw "Invalid collateral amount";
        if (typeof collateral_lock_id !== 'string' || !TXID_REGEX.test(collateral_lock_id))
            throw "Invalid collateral lock id";
        //sign the value-data
        let timestamp = Date.now();
        let doc_array = [timestamp, borrower_sign, collateral_rate, collateral_value, collateral_lock_id];
        let sign_part = floCrypto.signData(doc_array.join("|"), privKey);
        let pubKey = floCrypto.getPubKeyHex(privKey);
        let coborrower_sign = [pubKey, sign_part, timestamp].join(".")
        return coborrower_sign;
    }

    function verify_coborrowerSign(coborrower_sign, coborrower, borrower_sign, collateral_rate, collateral_value, collateral_lock_id) {
        //split the signature part
        let sign_splits = coborrower_sign.split('.');
        let coborrower_pubKey = sign_splits[0],
            sign_part = sign_splits[1],
            timestamp = sign_splits[2];
        //validate values
        if (!floCrypto.verifyPubKey(coborrower_pubKey, coborrower))
            throw "Invalid public key";
        if (typeof collateral_rate !== "number" || !VALUE_REGEX.test(collateral_rate))
            throw "Invalid collateral rate";
        if (typeof collateral_value !== "number" || !VALUE_REGEX.test(collateral_value))
            throw "Invalid collateral amount";
        if (typeof collateral_lock_id !== 'string' || !TXID_REGEX.test(collateral_lock_id))
            throw "Invalid collateral lock id";
        //verify the signature
        let doc_array = [timestamp, borrower_sign, collateral_rate, collateral_value, collateral_lock_id];
        if (floCrypto.verifySign(doc_array.join("|"), sign_part, coborrower_pubKey))
            return timestamp;
        else return false;
    }

    function sign_lender(privKey, coborrower_sign, loan_transfer_id) {
        let lender_floID = floCrypto.toFloID(floDapps.user.id);
        //validate values before signing
        if (!floCrypto.verifyPrivKey(privKey, lender_floID))
            throw "Invalid Private key for lender";
        if (typeof loan_transfer_id !== 'string' || !TXID_REGEX.test(loan_transfer_id))
            throw "Invalid token transfer id";
        //sign the value-data
        let timestamp = Date.now();
        let doc_array = [timestamp, coborrower_sign, loan_transfer_id];
        let sign_part = floCrypto.signData(doc_array.join("|"), privKey);
        let pubKey = floCrypto.getPubKeyHex(privKey);
        let lender_sign = [pubKey, sign_part, timestamp].join(".")
        return lender_sign;
    }

    function verify_lenderSign(lender_sign, lender, coborrower_sign, loan_transfer_id) {
        //split the signature part
        let sign_splits = lender_sign.split('.');
        let lender_pubKey = sign_splits[0],
            sign_part = sign_splits[1],
            timestamp = sign_splits[2];
        //validate values
        if (!floCrypto.verifyPubKey(lender_pubKey, lender))
            throw "Invalid public key";
        if (typeof loan_transfer_id !== 'string' || !TXID_REGEX.test(loan_transfer_id))
            throw "Invalid token transfer id";
        //verify the signature
        let doc_array = [timestamp, coborrower_sign, loan_transfer_id];
        if (floCrypto.verifySign(doc_array.join("|"), sign_part, lender_pubKey))
            return timestamp;
        else return false;
    }

    //Signed by borrower when closing the loan
    const CLOSING_IDENTIFIER = "closing";
    function sign_closing(privKey, loan_id, lender_sign) {
        let borrower_floID = floCrypto.toFloID(floDapps.user.id)
        //validate values before signing
        if (!floCrypto.verifyPrivKey(privKey, borrower_floID))
            throw "Invalid Private key for borrower";
        if (typeof loan_id !== 'string' || !TXID_REGEX.test(loan_id))
            throw "Invalid loan id";
        //sign the value-data
        let timestamp = Date.now();
        let doc_array = [timestamp, CLOSING_IDENTIFIER, loan_id, lender_sign];
        let sign_part = floCrypto.signData(doc_array.join("|"), privKey);
        let pubKey = floCrypto.getPubKeyHex(privKey);
        let closing_sign = [pubKey, sign_part, timestamp].join(".")
        return closing_sign;
    }

    function verify_closingSign(closing_sign, borrower, loan_id, lender_sign) {
        //split the signature part
        let sign_splits = closing_sign.split('.');
        let borrower_pubKey = sign_splits[0],
            sign_part = sign_splits[1],
            timestamp = sign_splits[2];
        //validate values
        if (!floCrypto.verifyPubKey(borrower_pubKey, borrower))
            throw "Invalid public key";
        //verify the signature
        let doc_array = [timestamp, CLOSING_IDENTIFIER, loan_id, lender_sign];
        if (floCrypto.verifySign(doc_array.join("|"), sign_part, borrower_pubKey))
            return timestamp;
        else return false;
    }

    //Signed by lender when requesting liquidation
    const LIQUIDATE_IDENTIFIER = "liquidate";
    function sign_liquidation(privKey, loan_id, btc_liquid_rate, lender_sign) {
        let lender_floID = floCrypto.toFloID(floDapps.user.id)
        //validate values before signing
        if (!floCrypto.verifyPrivKey(privKey, lender_floID))
            throw "Invalid Private key for lender";
        if (typeof loan_id !== 'string' || !TXID_REGEX.test(loan_id))
            throw "Invalid loan id";
        //sign the value-data
        let timestamp = Date.now();
        let doc_array = [timestamp, LIQUIDATE_IDENTIFIER, loan_id, lender_sign, btc_liquid_rate];
        let sign_part = floCrypto.signData(doc_array.join("|"), privKey);
        let pubKey = floCrypto.getPubKeyHex(privKey);
        let liquidation_sign = [pubKey, sign_part, timestamp].join(".")
        return liquidation_sign;
    }

    function verify_liquidationSign(liquidation_sign, lender, loan_id, lender_sign, btc_liquid_rate) {
        //split the signature part
        let sign_splits = liquidation_sign.split('.');
        let lender_pubKey = sign_splits[0],
            sign_part = sign_splits[1],
            timestamp = sign_splits[2];
        //validate values
        if (!floCrypto.verifyPubKey(lender_pubKey, lender))
            throw "Invalid public key";
        //verify the signature
        let doc_array = [timestamp, LIQUIDATE_IDENTIFIER, loan_id, lender_sign, btc_liquid_rate];
        if (floCrypto.verifySign(doc_array.join("|"), sign_part, lender_pubKey))
            return timestamp;
        else return false;
    }


    btcMortgage.verify = {
        borrower_sign: verify_borrowerSign,
        coborrower_sign: verify_coborrowerSign,
        lender_sign: verify_lenderSign,
        closing_sign: verify_closingSign,
        liquidation_sign: verify_liquidationSign
    }

    const validateRequest = btcMortgage.validateRequest = {};

    const RequestValidationError = (req_type, message) => ({ req_type, message });

    /*Inbox / Board */

    //list all loan requests
    btcMortgage.listLoanRequests = function (callback = undefined) {
        return new Promise((resolve, reject) => {
            let options = {}
            if (callback instanceof Function)
                options.callback = callback;
            floCloudAPI.requestApplicationData(TYPE_LOAN_REQUEST, options)
                .then(result => resolve(result))
                .catch(error => reject(error))
        })
    }
    //view responses 
    btcMortgage.viewMyInbox = function (callback = undefined) {
        return new Promise((resolve, reject) => {
            let options = { receiverID: floDapps.user.id }
            if (callback instanceof Function)
                options.callback = callback;
            floCloudAPI.requestApplicationData(null, options)   //view all inbox
                .then(result => resolve(result))
                .catch(error => reject(error))
        })
    }

    /*Loan Opening*/

    //1. B: requests collateral from coborrower
    btcMortgage.requestLoanCollateral = function (loan_amount, policy_id, coborrower) {
        return new Promise((resolve, reject) => {
            const borrower = floDapps.user.id;
            //Input validation
            if (typeof loan_amount !== 'number' && loan_amount <= 0)
                return reject("Invalid loan amount: " + loan_amount);
            loan_amount = toFixedDecimal(loan_amount); //decimal allowed upto 8 decimal places
            if (!(policy_id in POLICIES))
                return reject("Invalid policy: " + policy_id);
            if (!floCrypto.validateAddr(coborrower))
                return reject("Invalid coborrower id")
            //request collateral from coborrower
            floCloudAPI.sendApplicationData({
                borrower, coborrower,
                loan_amount, policy_id,
                loan_opening_process_id: floCrypto.randString(12, true)
            }, TYPE_LOAN_COLLATERAL_REQUEST, { receiverID: coborrower })
                .then(result => {
                    compactIDB.addData("outbox", result, result.vectorClock);
                    resolve(result);
                }).catch(error => reject(error))
        })
    }

    function validate_loanCollateral_request(loan_collateral_req_id, borrower, coborrower) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_LOAN_COLLATERAL_REQUEST, { atVectorClock: loan_collateral_req_id, receiverID: coborrower }).then(loan_collateral_req => {
                const { senderID, receiverID, message: { loan_amount, policy_id, loan_opening_process_id }, pubkey } = loan_collateral_req[loan_collateral_req_id];
                if (!loan_collateral_req[loan_collateral_req_id])
                    return reject(RequestValidationError(TYPE_LOAN_REQUEST, "request not found"));
                if (!floCrypto.isSameAddr(senderID, borrower))
                    return reject(RequestValidationError(TYPE_LOAN_COLLATERAL_REQUEST, "sender is not borrower"));
                if (!floCrypto.isSameAddr(receiverID, coborrower))
                    return reject(RequestValidationError(TYPE_LOAN_COLLATERAL_REQUEST, "receiver is not coborrower"));
                if (typeof loan_amount !== 'number' || loan_amount <= 0 || !VALUE_REGEX.test(loan_amount))
                    return reject(RequestValidationError(TYPE_LOAN_COLLATERAL_REQUEST, "Invalid loan amount"));
                if (!(policy_id in POLICIES))
                    return reject(RequestValidationError(TYPE_LOAN_COLLATERAL_REQUEST, "Invalid policy"));
                let result = { loan_amount, policy_id, borrower, coborrower, loan_opening_process_id, borrower_pubKey: pubkey };
                resolve(result);
            }).catch(error => reject(error))
        })
    }

    //2. B: post loan request (with proof of collateral)
    btcMortgage.requestLoan = function (loan_collateral_req_id, borrower) {
        return new Promise((resolve, reject) => {
            const coborrower = floDapps.user.id;
            //validate request
            validate_loanCollateral_request(loan_collateral_req_id, borrower, coborrower).then(({ loan_amount, policy_id, loan_opening_process_id }) => {
                //calculate required collateral
                getRate["BTC"]().then(rate => {
                    let policy = POLICIES[policy_id];
                    let collateral_value = calcRequiredCollateral(loan_amount / rate, policy.loan_collateral_ratio)
                    //check if collateral is available
                    let coborrower_floID = floCrypto.toFloID(coborrower);
                    let coborrower_btcID = btcOperator.convert.legacy2bech(coborrower_floID);
                    btcOperator.getBalance(coborrower_btcID).then(coborrower_balance => {
                        if (coborrower_balance < collateral_value)
                            return reject("Insufficient collateral available");
                        //post request
                        floCloudAPI.sendApplicationData({
                            borrower, coborrower,
                            loan_amount, policy_id, loan_collateral_req_id, loan_opening_process_id,
                            collateral: {
                                rate,
                                btc_id: coborrower_btcID,
                                quantity: collateral_value
                            }
                        }, TYPE_LOAN_REQUEST)
                            .then(result => {
                                compactIDB.addData("outbox", result, result.vectorClock);
                                resolve(result);
                            }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_loan_request(loan_req_id, borrower, coborrower) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_LOAN_REQUEST, { atVectorClock: loan_req_id }).then(loan_req => {
                console.log(loan_req, loan_req_id, loan_req[loan_req_id]);
                const { senderID, message: { loan_collateral_req_id, loan_amount, policy_id, collateral }, pubKey } = loan_req[loan_req_id];
                if (!loan_req[loan_req_id])
                    return reject(RequestValidationError(TYPE_LOAN_REQUEST, "request not found"));
                if (!floCrypto.isSameAddr(coborrower, senderID))
                    return reject(RequestValidationError(TYPE_LOAN_REQUEST, "request not posted by coborrower"))
                if (!floCrypto.isSameAddr(collateral.btc_id, coborrower))
                    return reject(RequestValidationError(TYPE_LOAN_REQUEST, "collateral btc id is not coborrower"));
                validate_loanCollateral_request(loan_collateral_req_id, borrower, coborrower).then(result => {
                    if (result.loan_amount !== loan_amount)
                        return reject(RequestValidationError(TYPE_LOAN_REQUEST, "loan amount mismatch"));
                    if (policy_id !== result.policy_id)
                        return reject(RequestValidationError(TYPE_LOAN_REQUEST, "policy id mismatch"));
                    getRate["BTC"]().then(rate => {
                        if (rate * ALLOWED_DEVIATION > collateral.rate)
                            return reject(RequestValidationError(TYPE_LOAN_REQUEST, "BTC rate has reduced beyond allowed threshold"))
                        let policy = POLICIES[policy_id];
                        let required_collateral = calcRequiredCollateral(loan_amount / collateral.rate, policy.loan_collateral_ratio)
                        if (required_collateral > collateral.quantity)
                            return reject(RequestValidationError(TYPE_LOAN_REQUEST, "Insufficient collateral value"));
                        result.collateral = collateral;
                        result.coborrower_pubKey = pubKey;
                        resolve(result)
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })

    }

    //3. L: respond to loan request
    btcMortgage.respondLoan = function (loan_req_id, borrower, coborrower) {
        return new Promise((resolve, reject) => {
            const lender = floDapps.user.id;
            validate_loan_request(loan_req_id, borrower, coborrower).then(({ loan_amount, borrower, collateral, loan_opening_process_id }) => {
                //check if collateral is available
                btcOperator.getBalance(collateral.btc_id).then(coborrower_balance => {
                    if (coborrower_balance < collateral.quantity)
                        return reject(RequestValidationError(TYPE_LOAN_REQUEST, "Insufficient collateral available"));
                    //check if loan amount (token) is available to lend
                    let lender_floID = floCrypto.toFloID(lender);
                    floTokenAPI.getBalance(lender_floID, CURRENCY).then(lender_tokenBalance => {
                        console.log(lender_tokenBalance, loan_amount);
                        if (lender_tokenBalance < loan_amount)
                            return reject("Insufficient tokens to lend");
                        floCloudAPI.sendApplicationData({
                            lender, borrower, coborrower,
                            loan_amount, collateral,
                            loan_req_id,
                            loan_opening_process_id
                        }, TYPE_LENDER_RESPONSE, { receiverID: borrower })
                            .then(result => {
                                compactIDB.addData("outbox", result, result.vectorClock);
                                resolve(result);
                            }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_lender_response(lender_res_id, borrower, coborrower, lender) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_LENDER_RESPONSE, { atVectorClock: lender_res_id, receiverID: borrower }).then(lender_res => {
                const { senderID, message: { loan_req_id }, pubKey } = lender_res[lender_res_id];
                if (!lender_res[lender_res_id])
                    return reject(RequestValidationError(TYPE_LENDER_RESPONSE, "request not found"));
                if (!floCrypto.isSameAddr(lender, senderID))
                    return reject(RequestValidationError(TYPE_LENDER_RESPONSE, "request not sent by lender"))
                validate_loan_request(loan_req_id, borrower, coborrower).then(result => {
                    let { loan_amount } = result;
                    //check if loan amount (token) is available to lend
                    let lender_floID = floCrypto.toFloID(lender);
                    floTokenAPI.getBalance(lender_floID, CURRENCY).then(lender_tokenBalance => {
                        if (lender_tokenBalance < loan_amount)
                            return reject(RequestValidationError(TYPE_LENDER_RESPONSE, "lender doesn't have sufficient funds to lend"));
                        result.lender = lender;
                        result.lender_pubKey = pubKey;
                        resolve(result);
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //4. B: requests C to lock the collateral 
    btcMortgage.requestCollateralLock = function (lender_res_id, coborrower, lender, privKey) {
        return new Promise((resolve, reject) => {
            const borrower = floDapps.user.id;
            validate_lender_response(lender_res_id, borrower, coborrower, lender).then(({ loan_amount, policy_id, loan_opening_process_id }) => {
                //send request to coborrower for locking the collateral asset
                let borrower_sign = sign_borrower(privKey, loan_amount, policy_id, coborrower, lender);
                floCloudAPI.sendApplicationData({
                    lender, borrower, coborrower,
                    lender_res_id, borrower_sign,
                    loan_opening_process_id
                }, TYPE_COLLATERAL_LOCK_REQUEST, { receiverID: coborrower })
                    .then(result => {
                        compactIDB.addData("outbox", result, result.vectorClock);
                        resolve(result);
                    }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_collateralLock_request(collateral_lock_req_id, borrower, coborrower, lender) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_COLLATERAL_LOCK_REQUEST, { atVectorClock: collateral_lock_req_id, receiverID: coborrower }).then(collateral_lock_req => {
                collateral_lock_req = collateral_lock_req[collateral_lock_req_id];
                if (!collateral_lock_req)
                    return reject(RequestValidationError(TYPE_COLLATERAL_LOCK_REQUEST, "request not found"));
                if (!floCrypto.isSameAddr(borrower, collateral_lock_req.senderID))
                    return reject(RequestValidationError(TYPE_LENDER_RESPONSE, "request not sent by borrower"));
                let { lender_res_id, borrower_sign } = collateral_lock_req.message;
                validate_lender_response(lender_res_id, borrower, coborrower, lender).then(result => {
                    let { loan_amount, policy_id } = result;
                    //verify borrower_sign
                    let borrower_sign_time = verify_borrowerSign(borrower_sign, borrower, loan_amount, policy_id, coborrower, lender)
                    if (!borrower_sign_time) //MAYDO: expire signatures?
                        return reject("Invalid borrower signature");
                    result.borrower_sign = borrower_sign;
                    resolve(result);
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //5. C: locks required collateral in multisig (C, L, T)
    btcMortgage.lockCollateral = function (collateral_lock_req_id, borrower, lender, privKey) {
        return new Promise((resolve, reject) => {
            const coborrower = floDapps.user.id;
            validate_collateralLock_request(collateral_lock_req_id, borrower, coborrower, lender).then(({ borrower_sign, collateral, lender_pubKey, loan_opening_process_id }) => {
                //lock collateral
                lockCollateralInBlockchain(privKey, lender_pubKey, collateral.quantity).then(collateral_txid => {
                    //sign and request lender to finalize
                    let coborrower_sign = sign_coborrower(privKey, borrower_sign, collateral.rate, collateral.quantity, collateral_txid)
                    floCloudAPI.sendApplicationData({
                        borrower, coborrower, lender,
                        collateral_lock_id: collateral_txid,
                        coborrower_sign, collateral_lock_req_id,
                        loan_opening_process_id
                    }, TYPE_COLLATERAL_LOCK_ACK, { receiverID: lender })
                        .then(result => {
                            compactIDB.addData("outbox", result, result.vectorClock);
                            resolve(result);
                        }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function lockCollateralInBlockchain(privKey, lenderPubKey, collateral_value) {
        return new Promise((resolve, reject) => {
            const locker_id = findLocker(floDapps.user.public, lenderPubKey).address;
            let coborrower_floID = floCrypto.toFloID(floDapps.user.id);
            let coborrower_btcID = btcOperator.convert.legacy2bech(coborrower_floID);
            btcOperator.sendTx(coborrower_btcID, privKey, locker_id, collateral_value)
                .then(txid => resolve(txid))
                .catch(error => reject(error))
        })
    }

    function validate_collateralLock_ack(collateral_lock_ack_id, borrower, coborrower, lender) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_COLLATERAL_LOCK_ACK, { atVectorClock: collateral_lock_ack_id, receiverID: lender }).then(collateral_lock_ack => {
                collateral_lock_ack = collateral_lock_ack[collateral_lock_ack_id];
                if (!collateral_lock_ack)
                    return reject(RequestValidationError(TYPE_COLLATERAL_LOCK_REQUEST, "request not found"));
                if (!floCrypto.isSameAddr(coborrower, collateral_lock_ack.senderID))
                    return reject(RequestValidationError(TYPE_LENDER_RESPONSE, "request not sent by coborrower"));
                let { collateral_lock_req_id, coborrower_sign, collateral_lock_id } = collateral_lock_ack.message;
                validate_collateralLock_request(collateral_lock_req_id, borrower, coborrower, lender).then(result => {
                    let { borrower_sign, collateral, lender_pubKey, coborrower_pubKey } = result;
                    let coborrower_sign_time = verify_coborrowerSign(coborrower_sign, coborrower, borrower_sign, collateral.rate, collateral.quantity, collateral_lock_id)
                    if (!coborrower_sign_time) //MAYDO: expire signatures?
                        return reject(RequestValidationError(TYPE_COLLATERAL_LOCK_ACK, "Invalid coborrower signature"));
                    btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                        if (!collateral_tx.confirmations)
                            return reject(RequestValidationError(TYPE_COLLATERAL_LOCK_ACK, "Collateral lock transaction not confirmed yet"));
                        let locker_id = findLocker(coborrower_pubKey, lender_pubKey).address;
                        let locked_amt = collateral_tx.outputs.filter(o => o.address == locker_id).reduce((a, o) => a += o.value, 0);
                        if (locked_amt < collateral.quantity)
                            return reject(RequestValidationError(TYPE_COLLATERAL_LOCK_ACK, "Insufficient Collateral locked"));
                        result.coborrower_sign = coborrower_sign;
                        result.collateral_lock_id = collateral_lock_id;
                        result.collateral_time = collateral_tx.time;
                        resolve(result);
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //6. L: sends loan amount (USD tokens) to B and writes loan details in flo blockchain
    btcMortgage.sendLoanAmount = function (collateral_lock_ack_id, borrower, coborrower, privKey) {
        return new Promise((resolve, reject) => {
            const lender = floDapps.user.id;
            validate_collateralLock_ack(collateral_lock_ack_id, borrower, coborrower, lender).then(result => {
                let { loan_amount, policy_id, collateral, collateral_lock_id, borrower_sign, coborrower_sign, loan_opening_process_id } = result;
                //check if collateral is already used on a different loan
                for (let l in LOANS)
                    if (LOANS[l].collateral_lock_id === collateral_lock_id)
                        return reject(`Collateral already used in a different loan (${l})`);
                if (collateral_lock_id in owned_collateral_locks)
                    return reject("Collateral is being used for a different loan in-process");
                //transfer tokens for loan amount
                let borrower_floID = floCrypto.toFloID(borrower);
                let transfer_appendix = stringifyLoanTransferData(borrower_sign, coborrower_sign);
                floTokenAPI.sendToken(privKey, loan_amount, borrower_floID, "as loan|" + transfer_appendix, CURRENCY).then(token_txid => {
                    //add the collateral lock to owned list
                    owned_collateral_locks[collateral_lock_id] = token_txid;
                    compactIDB.addData("owned_collateral_locks", token_txid, collateral_lock_id);
                    //construct the blockchain data
                    let lender_sign = sign_lender(privKey, coborrower_sign, token_txid);
                    let loan_blockchain_data = stringifyLoanOpenData(
                        borrower, loan_amount, policy_id, collateral.rate,
                        coborrower, collateral.quantity, collateral_lock_id,
                        lender, token_txid, lender_sign, loan_opening_process_id
                    );
                    let receivers = [borrower, coborrower].map(addr => floCrypto.toFloID(addr));
                    //write loan details in blockchain
                    floBlockchainAPI.writeDataMultiple([privKey], loan_blockchain_data, receivers)
                        .then(loan_txid => {
                            resolve(loan_txid)
                        })
                        .catch(error => {
                            compactIDB.writeData("fail_safe", loan_blockchain_data, token_txid); //fail-safe mech if token is transferred but details not added to blockchain. this helps to retry fail-safe
                            reject({ error, fail_safe: token_txid })
                        })
                }).catch(error => reject(error))
            }).catch(error => reject(error))

        })
    }

    //for retrying failsafe
    btcOperator.retryFailSafe = function (fail_safe_id, privKey) {
        return new Promise((resolve, reject) => {
            compactIDB.readData("fail_safe", fail_safe_id).then(fail_safe_data => {
                let { borrower, coborrower } = parseLoanOpenData(fail_safe_data);
                let receivers = [borrower, coborrower].map(addr => floCrypto.toFloID(addr));
                floBlockchainAPI.writeDataMultiple([privKey], fail_safe_data, receivers).then(loan_txid => {
                    compactIDB.removeData("fail_safe", fail_safe_id);   //remove fail safe as data is added to blockchain
                    resolve(loan_txid)
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    /*Loan Closing*/

    //1. B: sends amount (PA + interest) to L (via USD tokens)
    btcMortgage.repayLoan = function (loan_id, privKey) {
        return new Promise((resolve, reject) => {
            getLoanDetails(loan_id).then(loan_details => {
                //calculate repayment amount
                let due_amount = calcDueAmount(loan_details.loan_amount, loan_details.policy_id, loan_details.open_time);
                //repay and close the loan
                let closing_sign = sign_closing(privKey, loan_id, loan_details.lender_sign);
                var closing_data = stringifyLoanCloseData(loan_id, loan_details.borrower, closing_sign);
                let lender_floID = floCrypto.toFloID(loan_details.lender);
                floTokenAPI.sendToken(privKey, due_amount, lender_floID, "as repayment|" + closing_data, CURRENCY).then(closing_txid => {
                    //send message to coborrower as reminder to unlock collateral
                    floCloudAPI.sendApplicationData({ loan_id, closing_txid }, TYPE_LOAN_CLOSED_ACK, { receiverID: loan_details.coborrower })
                        .then(result => {
                            compactIDB.addData("outbox", result, result.vectorClock);
                            resolve(result);
                        }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //2. C: requests L or T to free collateral
    btcMortgage.requestUnlockCollateral = function (loan_id, closing_txid, privKey, toBanker = false) {
        return new Promise((resolve, reject) => {
            let coborrower_pubKey = floDapps.user.public;
            getLoanClosing(loan_id, closing_txid).then(loan_details => {
                //find locker
                let lender_pubKey = extractPubKeyFromSign(loan_details.lender_sign);
                let locker = findLocker(coborrower_pubKey, lender_pubKey)
                //create the tx hex and sign it
                createUnlockCollateralTxHex(locker, loan_details.collateral_lock_id, privKey).then(unlock_tx_hex => {
                    floCloudAPI.sendApplicationData({
                        loan_id, closing_txid, unlock_tx_hex
                    }, TYPE_UNLOCK_COLLATERAL_REQUEST, { receiverID: toBanker ? BANKER_ID : loan_details.lender })
                        .then(result => {
                            compactIDB.addData("outbox", result, result.vectorClock);
                            resolve(result);
                        }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function createUnlockCollateralTxHex(locker, collateral_lock_id, privKey) {
        return new Promise((resolve, reject) => {
            btcOperator.getUTXOs(locker.address).then(utxos => {
                let collateral_utxos = utxos.filter(u => u.txid == collateral_lock_id);
                if (!collateral_utxos.length)
                    return reject("Collateral already unlocked");
                btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                    if (collateral_tx.confirmations == 0)
                        return reject("Collateral not confirmed in blockchain"); //This should not happen, as loan will not be issued until collateral is locked with confirmations
                    let collateral_owner = collateral_tx.inputs[0].address; //this will be coborrower's BTC id
                    //create the tx
                    const tx = coinjs.transaction();
                    //estimate the fee
                    let estimate_tx_size = btcOperator.CONSTANTS.BASE_TX_SIZE;
                    estimate_tx_size += collateral_utxos.length * btcOperator.util.sizePerInput(locker.address, locker.redeemScript)
                    estimate_tx_size += btcOperator.util.sizePerOutput(collateral_owner);
                    btcOperator.util.get_fee_rate().then(fee_rate => {
                        let fee_estimate = fee_rate * estimate_tx_size;
                        //add inputs
                        let total_input_value = 0;
                        collateral_utxos.forEach(u => {
                            //locker is btc bech32 multisig
                            let s = coinjs.script();
                            s.writeBytes(Crypto.util.hexToBytes(locker.redeemScript));
                            s.writeOp(0);
                            s.writeBytes(coinjs.numToBytes(u.value.toFixed(0), 8));
                            script = Crypto.util.bytesToHex(s.buffer);
                            tx.addinput(u.txid, u.vout, script, 0xfffffffd /*sequence*/); //0xfffffffd for Replace-by-fee
                            total_input_value += u.value;
                        });
                        total_input_value = btcOperator.util.Sat_to_BTC(total_input_value); //convert from satoshi to BTC
                        //add output
                        let receiver_amount = total_input_value - fee_estimate;
                        console.debug("FEE calc", total_input_value, fee_estimate, receiver_amount);
                        tx.addoutput(collateral_owner, receiver_amount);
                        tx.sign(privKey, 1 /*sighashtype*/);
                        resolve(tx.serialize())
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //3. L/T: unlock collateral
    btcMortgage.unlockCollateral = function (loan_id, closing_txid, unlock_tx_hex, privKey) {
        return new Promise((resolve, reject) => {
            getLoanClosing(loan_id, closing_txid).then(loan_details => {
                //find locker
                let coborrower_pubKey = extractPubKeyFromSign(loan_details.coborrower_sign);
                let lender_pubKey = extractPubKeyFromSign(loan_details.lender_sign);
                let locker = findLocker(coborrower_pubKey, lender_pubKey)
                //verify and sign the tx
                signUnlockCollateralTxHex(locker, loan_details.collateral_lock_id, unlock_tx_hex, privKey).then(signed_tx_hex => {
                    btcOperator.broadcastTx(signed_tx_hex).then(txid => {
                        floCloudAPI.sendApplicationData({
                            loan_id, closing_txid, unlock_collateral_id: txid
                        }, TYPE_UNLOCK_COLLATERAL_ACK, { receiverID: loan_details.coborrower })
                            .then(result => {
                                compactIDB.addData("outbox", result, result.vectorClock);
                                resolve(result);
                            }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function signUnlockCollateralTxHex(locker, collateral_lock_id, unlock_tx_hex, privKey) {
        return new Promise((resolve, reject) => {
            btcOperator.getUTXOs(locker.address).then(utxos => {
                let collateral_utxos = utxos.filter(u => u.txid == collateral_lock_id);
                if (!collateral_utxos.length)
                    return reject("Collateral already unlocked");
                btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                    if (collateral_tx.confirmations == 0)
                        return reject("Collateral not confirmed in blockchain"); //This should not happen, as loan will not be issued until collateral is locked with confirmations
                    //create the tx
                    let tx = coinjs.transaction().deserialize(unlock_tx_hex);
                    //check inputs
                    if (tx.ins.some(i => i.outpoint.hash !== collateral_lock_id))//vin other than this collateral is present in tx, ABORT
                        return reject("Transaction Hex contains other/non collateral inputs");
                    //sign the tx hex
                    tx.sign(privKey, 1 /*sighashtype*/);
                    resolve(tx.serialize())
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    //Banker involvement when one party fails

    btcMortgage.banker = {};
    btcMortgage.requestBanker = {};

    // C: request T (banker) for collateral refund when lender hasn't dispersed the loan for 24 hrs
    btcMortgage.requestBanker.refundCollateral = function (collateral_lock_ack_id, borrower, lender, privKey) {
        return new Promise((resolve, reject) => {
            const coborrower = floDapps.user.id;
            let coborrower_pubKey = floDapps.user.public;
            validate_collateralLock_ack(collateral_lock_ack_id, borrower, coborrower, lender).then(result => {
                let { lender_pubKey, collateral_lock_id, loan_opening_process_id } = result;
                let locker = findLocker(coborrower_pubKey, lender_pubKey)
                //create the tx hex and sign it
                createUnlockCollateralTxHex(locker, collateral_lock_id, privKey).then(unlock_tx_hex => {
                    floCloudAPI.sendApplicationData({
                        borrower, coborrower, lender,
                        collateral_lock_ack_id, unlock_tx_hex,
                        loan_opening_process_id
                    }, TYPE_REFUND_COLLATERAL_REQUEST)
                        .then(result => {
                            compactIDB.addData("outbox", result, result.vectorClock);
                            resolve(result);
                        }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    // T: verify and refund collateral
    btcMortgage.banker.refundCollateral = function (collateral_refund_req_id, borrower, coborrower, lender, privKey) {
        return new Promise((resolve, reject) => {
            //validate request
            validate_collateralRefund_request(collateral_refund_req_id, borrower, coborrower, lender).then(result => {
                let { unlock_tx_hex, collateral_lock_id, coborrower_pubKey, lender_pubKey } = result;
                let locker = findLocker(coborrower_pubKey, lender_pubKey)
                //verify and sign the tx
                signUnlockCollateralTxHex(locker, collateral_lock_id, unlock_tx_hex, privKey).then(signed_tx_hex => {
                    btcOperator.broadcastTx(signed_tx_hex).then(txid => {
                        floCloudAPI.sendApplicationData({
                            collateral_refund_req_id, refund_collateral_id: txid
                        }, TYPE_REFUND_COLLATERAL_ACK, { receiverID: coborrower })
                            .then(result => {
                                compactIDB.addData("outbox", result, result.vectorClock);
                                resolve(result);
                            }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_collateralRefund_request(collateral_refund_req_id, borrower, coborrower, lender) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_REFUND_COLLATERAL_REQUEST, { atVectorClock: collateral_refund_req_id }).then(collateral_refund_req => {
                collateral_refund_req = collateral_refund_req[collateral_refund_req_id];
                if (!collateral_refund_req)
                    return reject(RequestValidationError(TYPE_REFUND_COLLATERAL_REQUEST, "request not found"));
                if (!floCrypto.isSameAddr(coborrower, collateral_refund_req.senderID))
                    return reject(RequestValidationError(TYPE_REFUND_COLLATERAL_REQUEST, "request not sent by coborrower"));
                let { collateral_lock_ack_id, unlock_tx_hex } = collateral_refund_req.message;
                validate_collateralLock_ack(collateral_lock_ack_id, borrower, coborrower, lender).then(result => {
                    let { collateral_time } = result;
                    let current_time = Date.now();
                    if (current_time - WAIT_TIME > collateral_time)
                        return reject(RequestValidationError(TYPE_REFUND_COLLATERAL_REQUEST, "Still in waiting period"));
                    result.unlock_tx_hex = unlock_tx_hex;
                    resolve(result);
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    // L: request T (banker) to liquidate collateral due to failure of repayment by borrower
    btcMortgage.requestBanker.liquateCollateral = function (loan_id, privKey) {
        return new Promise((resolve, reject) => {
            let lender_pubKey = floDapps.user.public;
            getLoanDetails(loan_id).then(loan_details => {
                //calculate due amount
                let due_amount = calcDueAmount(loan_details.loan_amount, loan_details.policy_id, loan_details.open_time)
                //create tx hex for liquidation and send to banker
                let coborrower_pubKey = extractPubKeyFromSign(loan_details.coborrower_sign);
                getRate["BTC"]().then(rate => {
                    let liquidate_amount = toFixedDecimal(due_amount / rate); //USD to BTC
                    createLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, loan_details.collateral_lock_id, liquidate_amount, privKey).then(txHex => {
                        let liquidation_sign = sign_liquidation(privKey, loan_id, rate, loan_details.lender_sign)
                        floCloudAPI.sendApplicationData({
                            borrower, coborrower, lender,
                            loan_id, liquidation_sign, btc_liquid_rate: rate,
                            liquidate_tx_hex: txHex
                        }, TYPE_LIQUATE_COLLATERAL_REQUEST)
                            .then(result => {
                                compactIDB.addData("outbox", result, result.vectorClock);
                                resolve(result);
                            }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    btcMortgage.banker.liquateCollateral = function (collateral_liquate_req_id, privKey) {
        return new Promise((resolve, reject) => {
            validate_liquateCollateral_request(collateral_liquate_req_id).then(result => {
                let { loan_details, liquidate_tx_hex, btc_liquid_rate, liquidation_sign } = result;
                //calculate due amount
                let due_amount = calcDueAmount(loan_details.loan_amount, loan_details.policy_id, loan_details.open_time)
                //sign btc tx
                let coborrower_pubKey = extractPubKeyFromSign(loan_details.coborrower_sign);
                let lender_pubKey = extractPubKeyFromSign(loan_details.lender_sign);
                getRate["BTC"]().then(cur_rate => {
                    if (cur_rate < btc_liquid_rate * ALLOWED_DEVIATION || cur_rate * ALLOWED_DEVIATION > btc_liquid_rate)
                        return reject(RequestValidationError(TYPE_LIQUATE_COLLATERAL_REQUEST, "BTC rate has reduced beyond allowed threshold"))
                    let liquidate_amount = toFixedDecimal(due_amount / rate); //USD to BTC
                    signLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, loan_details.collateral_lock_id, liquidate_tx_hex, liquidate_amount, privKey).then(signed_tx_hex => {
                        btcOperator.broadcastTx(signed_tx_hex).then(liquidation_id => {
                            //write loan failure data in FLO blockchain
                            let loan_failure_data = stringifyLoanFailData(loan_details.loan_id, liquidation_id, btc_liquid_rate, loan_details.lender, liquidation_sign);
                            let receivers = [loan_details.borrower, loan_details.coborrower, loan_details.lender].map(addr => floCrypto.toFloID(addr));
                            floBlockchainAPI.writeDataMultiple([privKey], loan_failure_data, receivers).then(fail_ack_id => {
                                floCloudAPI.sendApplicationData({
                                    collateral_liquate_req_id, liquidation_id, fail_ack_id
                                }, TYPE_LIQUATE_COLLATERAL_ACK, { receiverID: loan_details.lender })
                                    .then(result => {
                                        compactIDB.addData("outbox", result, result.vectorClock);
                                        resolve(result);
                                    }).catch(error => reject(error))
                            }).catch(error => {
                                compactIDB.writeData("fail_safe", loan_blockchain_data, token_txid); //fail-safe mech if token is transferred but details not added to blockchain. this helps to retry fail-safe
                                reject({ error, fail_safe: token_txid })
                            })
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_liquateCollateral_request(collateral_liquate_req_id) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_LIQUATE_COLLATERAL_REQUEST, { atVectorClock: collateral_liquate_req_id }).then(collateral_liquate_req => {
                collateral_liquate_req = collateral_liquate_req[collateral_liquate_req_id];
                if (!collateral_liquate_req)
                    return reject(RequestValidationError(TYPE_LIQUATE_COLLATERAL_REQUEST, "request not found"));
                let { loan_id, liquidation_sign, btc_liquid_rate, liquidate_tx_hex } = collateral_liquate_req.message;
                getLoanDetails(loan_id).then(loan_details => {
                    if (!floCrypto.isSameAddr(loan_details.lender, collateral_liquate_req.senderID))
                        return reject(RequestValidationError(TYPE_LIQUATE_COLLATERAL_REQUEST, "request not sent by lender"));
                    if (!verify_liquidationSign(liquidation_sign, loan_details.lender, loan_id, loan_details.lender_sign, btc_liquid_rate))
                        return reject("Invalid liquidation signature");
                    checkIfLoanClosedFailed(loan, loan_details.borrower, loan_details.lender).then(result => {
                        if (result) //close/fail loan data found
                            return reject(RequestValidationError(TYPE_LIQUATE_COLLATERAL_REQUEST, "Loan already closed"));
                        else resolve({ loan_details, liquidate_tx_hex, btc_liquid_rate, liquidation_sign });
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    // L: request T (banker) to pre-liquidate collateral when collateral value has dropped to risk threshold
    btcMortgage.requestBanker.preLiquidateCollateral = function (loan_id, privKey) {
        return new Promise((resolve, reject) => {
            let lender_pubKey = floDapps.user.public;
            getLoanDetails(loan_id).then(loan_details => {
                let policy = POLICIES[loan_details.policy_id];
                if (isNaN(policy.pre_liquidation_threshold))
                    return reject("This loan policy doesn't allow pre-liquidation");
                getRate["USD"].then(cur_btc_rate => {
                    if (cur_btc_rate >= loan_details.btc_start_rate)
                        return reject("BTC rate hasn't reduced from the start rate");
                    let current_rate_ratio = calcRateRatio(cur_btc_rate, loan_details.btc_start_rate)
                    if (current_rate_ratio > policy.pre_liquidation_threshold)
                        return reject("BTC rate hasn't dropped beyond threshold");
                    //calculate due amount
                    let due_amount = calcDueAmount(loan_details.loan_amount, loan_details.policy_id, loan_details.open_time)
                    //create tx hex for liquidation and send to banker
                    let coborrower_pubKey = extractPubKeyFromSign(loan_details.coborrower_sign);
                    getRate["BTC"]().then(rate => {
                        let liquidate_amount = toFixedDecimal(due_amount / rate); //USD to BTC
                        createLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, loan_details.collateral_lock_id, liquidate_amount, privKey).then(txHex => {
                            let liquidation_sign = sign_liquidation(privKey, loan_id, rate, loan_details.lender_sign)
                            floCloudAPI.sendApplicationData({
                                loan_id, liquidation_sign,
                                liquidate_tx_hex: txHex
                            }, TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST)
                                .then(result => {
                                    compactIDB.addData("outbox", result, result.vectorClock);
                                    resolve(result);
                                }).catch(error => reject(error))
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    btcMortgage.banker.preLiquidateCollateral = function (collateral_pre_liquidate_req_id, privKey) {
        return new Promise((resolve, reject) => {
            validate_pre_liquidateCollateral_request(collateral_pre_liquidate_req_id).then(result => {
                let { loan_details, liquidate_tx_hex, btc_liquid_rate, liquidation_sign } = result;
                //calculate due amount
                let due_amount = calcDueAmount(loan_details.loan_amount, loan_details.policy_id, loan_details.open_time)
                //sign the btc tx
                let coborrower_pubKey = extractPubKeyFromSign(loan_details.coborrower_sign);
                let lender_pubKey = extractPubKeyFromSign(loan_details.lender_sign);
                getRate["BTC"]().then(rate => {
                    if (cur_rate < btc_liquid_rate * ALLOWED_DEVIATION || cur_rate * ALLOWED_DEVIATION > btc_liquid_rate)
                        return reject(RequestValidationError(TYPE_LIQUATE_COLLATERAL_REQUEST, "BTC rate has reduced beyond allowed threshold"))
                    let liquidate_amount = toFixedDecimal(due_amount / rate); //USD to BTC
                    signLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, loan_details.collateral_lock_id, liquidate_tx_hex, liquidate_amount, privKey).then(signed_tx_hex => {
                        btcOperator.broadcastTx(signed_tx_hex).then(liquidation_id => {
                            //write loan failure data in FLO blockchain
                            let loan_failure_data = stringifyLoanFailData(loan_details.loan_id, liquidation_id, btc_liquid_rate, loan_details.lender, liquidation_sign);
                            let receivers = [loan_details.borrower, loan_details.coborrower, loan_details.lender].map(addr => floCrypto.toFloID(addr));
                            floBlockchainAPI.writeDataMultiple([privKey], loan_failure_data, receivers).then(fail_ack_id => {
                                floCloudAPI.sendApplicationData({
                                    collateral_liquate_req_id, liquidation_id, fail_ack_id
                                }, TYPE_LIQUATE_COLLATERAL_ACK, { receiverID: loan_details.lender })
                                    .then(result => {
                                        compactIDB.addData("outbox", result, result.vectorClock);
                                        resolve(result);
                                    }).catch(error => reject(error))
                            }).catch(error => {
                                compactIDB.writeData("fail_safe", loan_blockchain_data, token_txid); //fail-safe mech if token is transferred but details not added to blockchain. this helps to retry fail-safe
                                reject({ error, fail_safe: token_txid })
                            })
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function validate_pre_liquidateCollateral_request(collateral_pre_liquidate_req_id) {
        return new Promise((resolve, reject) => {
            floCloudAPI.requestApplicationData(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, { atVectorClock: collateral_pre_liquidate_req_id }).then(collateral_pre_liquidate_req => {
                collateral_pre_liquidate_req = collateral_pre_liquidate_req[collateral_pre_liquidate_req_id];
                if (!collateral_pre_liquidate_req)
                    return reject(RequestValidationError(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, "request not found"));
                let { loan_id, liquidation_sign, btc_liquid_rate, liquidate_tx_hex } = collateral_pre_liquidate_req.message;
                getLoanDetails(loan_id).then(loan_details => {
                    if (!floCrypto.isSameAddr(loan_details.lender, collateral_pre_liquidate_req.senderID))
                        return reject(RequestValidationError(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, "request not sent by lender"));
                    if (!verify_liquidationSign(liquidation_sign, loan_details.lender, loan_id, loan_details.lender_sign, btc_liquid_rate))
                        return reject("Invalid liquidation signature");
                    checkIfLoanClosedFailed(loan, loan_details.borrower, loan_details.lender).then(result => {
                        if (result) //close/fail loan data found
                            return reject(RequestValidationError(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, "Loan already closed"));
                        let policy = POLICIES[loan_details.policy_id];
                        if (isNaN(policy.pre_liquidation_threshold))
                            return reject("This loan policy doesn't allow pre-liquidation");
                        getRate["USD"].then(cur_btc_rate => {
                            if (cur_btc_rate >= loan_details.btc_start_rate)
                                return reject(RequestValidationError(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, "BTC rate hasn't reduced from the start rate"));
                            let current_rate_ratio = calcRateRatio(cur_btc_rate, loan_details.btc_start_rate)
                            if (current_rate_ratio > policy.pre_liquidation_threshold)
                                return reject(RequestValidationError(TYPE_PRE_LIQUIDATE_COLLATERAL_REQUEST, "BTC rate hasn't dropped beyond threshold"));
                            resolve({ loan_details, liquidate_tx_hex, btc_liquid_rate, liquidation_sign });
                        }).catch(error => reject(error))
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function createLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, collateral_lock_id, liquidate_amount, privKey) {
        return new Promise((resolve, reject) => {
            //find locker, pubkeys and ids
            let locker = findLocker(coborrower_pubKey, lender_pubKey),
                coborrower_btcID = btcOperator.bech32Address(coborrower_pubKey),
                lender_btcID = btcOperator.bech32Address(lender_pubKey);
            //get collateral utxos
            btcOperator.getUTXOs(locker.address).then(utxos => {
                let collateral_utxos = utxos.filter(u => u.txid == collateral_lock_id);
                if (!collateral_utxos.length)
                    return reject("Collateral already unlocked");
                btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                    if (collateral_tx.confirmations == 0)
                        return reject("Collateral not confirmed in blockchain"); //This should not happen, as loan will not be issued until collateral is locked with confirmations
                    let collateral_owner = collateral_tx.inputs[0].address; //this will be coborrower's BTC id
                    if (!floCrypto.isSameAddr(collateral_owner, coborrower_btcID))
                        return reject("Collateral owner isnt coborrower"); //this should not happen
                    //create the tx
                    const tx = coinjs.transaction();
                    //estimate the fee
                    let estimate_tx_size = btcOperator.CONSTANTS.BASE_TX_SIZE;
                    estimate_tx_size += collateral_utxos.length * btcOperator.util.sizePerInput(locker.address, locker.redeemScript)
                    estimate_tx_size += btcOperator.util.sizePerOutput(collateral_owner) + btcOperator.util.sizePerOutput(lender_btcID);
                    btcOperator.util.get_fee_rate().then(fee_rate => {
                        let fee_estimate = fee_rate * estimate_tx_size;
                        //add inputs
                        let total_input_value = 0;
                        collateral_utxos.forEach(u => {
                            //locker is btc bech32 multisig
                            let s = coinjs.script();
                            s.writeBytes(Crypto.util.hexToBytes(locker.redeemScript));
                            s.writeOp(0);
                            s.writeBytes(coinjs.numToBytes(u.value.toFixed(0), 8));
                            script = Crypto.util.bytesToHex(s.buffer);
                            tx.addinput(u.txid, u.vout, script, 0xfffffffd /*sequence*/); //0xfffffffd for Replace-by-fee
                            total_input_value += u.value;
                        });
                        total_input_value = btcOperator.util.Sat_to_BTC(total_input_value); //convert from satoshi to BTC
                        //add output
                        tx.addoutput(lender_btcID, liquidate_amount - fee_estimate);
                        console.debug("LIQUIDATE", total_input_value, liquidate_amount, fee_estimate)
                        if (liquidate_amount < total_input_value) { //return remaining of collateral to collateral owner(coborrower)
                            let return_amount = total_input_value - liquidate_amount;
                            if (return_amount > btcOperator.CONSTANTS.DUST_AMT) //only if return-part is more than dust
                                tx.addoutput(collateral_owner, return_amount);
                        }
                        tx.sign(privKey, 1 /*sighashtype*/);
                        resolve(tx.serialize())
                    }).catch(error => reject(error))
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function signLiquidateCollateralTxHex(coborrower_pubKey, lender_pubKey, collateral_lock_id, unlock_tx_hex, liquidate_amount, privKey) {
        return new Promise((resolve, reject) => {
            //find locker, pubkeys and ids
            let locker = findLocker(coborrower_pubKey, lender_pubKey),
                coborrower_btcID = btcOperator.bech32Address(coborrower_pubKey),
                lender_btcID = btcOperator.bech32Address(lender_pubKey);
            btcOperator.getUTXOs(locker.address).then(utxos => {
                let collateral_utxos = utxos.filter(u => u.txid == collateral_lock_id);
                if (!collateral_utxos.length)
                    return reject("Collateral already unlocked");
                let total_collateral_value = collateral_utxos.reduce((a, o) => a += o.value, 0);
                total_collateral_value = btcOperator.util.Sat_to_BTC(total_collateral_value);
                btcOperator.getTx(collateral_lock_id).then(collateral_tx => {
                    if (collateral_tx.confirmations == 0)
                        return reject("Collateral not confirmed in blockchain"); //This should not happen, as loan will not be issued until collateral is locked with confirmations
                    //create the tx
                    let tx = coinjs.transaction().deserialize(unlock_tx_hex);
                    //check inputs
                    if (tx.ins.some(i => i.outpoint.hash !== collateral_lock_id))//vin other than this collateral is present in tx, ABORT
                        return reject("Transaction Hex contains other/non collateral inputs");
                    if (tx.ins.length != collateral_utxos.length)
                        return reject("Transaction hex doesn't contain full collateral as input")
                    //check output
                    let return_amount = total_collateral_value - liquidate_amount;
                    if (return_amount > 0) {
                        let return_outpts_amount = tx.outs.filter(o => spendScriptToAddress(o.script) == coborrower_btcID).reduce((a, o) => a += o.value, 0)
                        return_outpts_amount = btcOperator.util.Sat_to_BTC(return_outpts_amount);
                        if (return_outpts_amount < return_amount)
                            return reject("Return value after liquidation is lower")
                    }
                    //sign the tx hex
                    tx.sign(privKey, 1 /*sighashtype*/);
                    resolve(tx.serialize())
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function spendScriptToAddress(script) {
        var address;
        switch (script.chunks[0]) {
            case 0: //bech32, multisig-bech32
                address = btcOperator.util.encodeBech32(Crypto.util.bytesToHex(script.chunks[1]), coinjs.bech32.version, coinjs.bech32.hrp);
                break;
            case 169: //segwit, multisig-segwit
                address = btcOperator.util.encodeLegacy(Crypto.util.bytesToHex(script.chunks[1]), coinjs.multisig);
                break;
            case 118: //legacy
                address = btcOperator.util.encodeLegacy(Crypto.util.bytesToHex(script.chunks[2]), coinjs.pub);
        }
        return address;
    }

    function checkIfLoanClosedFailed(loan_id, borrower, lender) {
        return new Promise((resolve, reject) => {
            //check if loan is closed
            checkIfLoanClosed(loan_id, borrower, lender).then(result => {
                if (result) //loan closed
                    return resolve(result);
                //check if loan has failed
                checkIfLoanFailed(loan_id, borrower).then(result => {
                    if (result) //loan failed
                        return resolve(result);
                    else
                        resolve(false); //loan is active (ie, not closed, not failed)
                }).catch(error => reject(error))
            }).catch(error => reject(error))
        })
    }

    function checkIfLoanClosed(loan_id, borrower, lender) {
        return new Promise((resolve, reject) => {
            var query_options = { sentOnly: true, tx: true, receivers: [floCrypto.toFloID(lender)] };
            let filter = d => {
                if (!d.includes(LOAN_CLOSING_IDENTIFIER))
                    return false;
                let closing_details = parseLoanCloseData(d);
                return closing_details.loan_id === loan_id;
            }
            floBlockchainAPI.getLatestData(borrower, filter, query_options).then(result => {
                if (result.item) {
                    let close_id = result.item.txid
                    getLoanClosing(loan_id, close_id).then(loan_details => {
                        //loan already closed
                        resolve(close_id)
                    }).catch(error => reject(error))
                }
                else resolve(false);
            }).catch(error => reject(error))
        })
    }

    function checkIfLoanFailed(loan_id, borrower) {
        return new Promise((resolve, reject) => {
            //sender is BANKER for this data
            var query_options = { sentOnly: true, tx: true, receivers: [floCrypto.toFloID(borrower)] };
            let filter = d => {
                if (!d.startsWith(LOAN_FAILURE_IDENTIFIER))
                    return false;
                let failure_details = parseLoanFailData(d);
                return failure_details.loan_id === loan_id;
            }
            floBlockchainAPI.getLatestData(BANKER_ID, filter, query_options).then(result => {
                if (result.item) {
                    let fail_id = result.item.txid;
                    getLoanFailure(loan_id, fail_id).then(loan_details => {
                        //loan already failed
                        resolve(fail_id)
                    }).catch(error => reject(error))
                }
                else resolve(false);
            }).catch(error => reject(error))
        })
    }

    btcMortgage.policies = POLICIES;
    btcMortgage.loans = LOANS;
    btcMortgage.banker.id = BANKER_ID;

})(window.btcMortgage = {})