#!/usr/bin/php
<?php
require_once('common.php');

/*
function fatal($string) {
	die("fatal:$string\n");
}

function checksetarray($base, $keys) {
        foreach ($keys as $key) {
                if (!isset($base[$key])) return false;
        }

        return true;
}

require('vendor/autoload.php');
require('secret.php');

require('db.php');
 */
//use BitWasp\Bitcoin\Transaction\TransactionFactory;

/*
$insert_address = "INSERT INTO addresses ( address, address_desc, wallet_id, address_path ) VALUES ( ?, ?, ?, ? )";
$select_address_id = "SELECT address_id FROM addresses WHERE address= ?";
$insert_scriptpubkey = "INSERT INTO scriptpubkeys ( scriptpubkey, scriptpubkey_asm, address_id ) VALUES ( ?, ?, ? )";
$select_scriptpubkey_id = "SELECT scriptpubkey_id FROM scriptpubkeys WHERE scriptpubkey = ?";
$insert_txo = "INSERT INTO txos ( txo_value, scriptpubkey_id, create_tx_id, create_txo_index, destroy_tx_id, destroy_txo_index ) VALUES ( ?, ?, ?, ?, ?, ? )";
$select_txo_id = "SELECT txo_id FROM txos WHERE create_tx_id = ? AND create_txo_index = ?";
 */

function get_txid_id($txid) {
	db_direct('LOCK TABLES txids WRITE');
	$txid_id = db_single_field('SELECT txid_id FROM txids WHERE txid = ?', $txid);
	if (!$txid_id) {
		db_exec('INSERT INTO txids ( txid ) VALUES ( ? )', $txid);
		$txid_id = db_last_insert_id();
	}
	db_direct('UNLOCK TABLES');

	return $txid_id;
}

function scan_vin($no, $vin, $txid_id) {
	$address = $vin['prevout']['scriptPubKey']['address'];
	$scriptpubkey_id = get_scriptpubkey_id(hex2bin($vin['prevout']['scriptPubKey']['hex']), $address);
	$prev_txid_id = get_txid_id($vin['txid']);
	db_exec('INSERT INTO txos ( txo_value, scriptpubkey_id, create_txid_id, create_txo_index, destroy_txid_id, destroy_txo_index ) VALUES ( ?, ?, ?, ?, ?, ? ) ON DUPLICATE KEY UPDATE destroy_txid_id = ?, destroy_txo_index = ?', $vin['prevout']['value'], $scriptpubkey_id, $prev_txid_id, $vin['vout'], $txid_id, $no, $txid_id, $no);
}

function scan_vout($no, $vout, $txid_id) {
	$address = isset($vout['scriptPubKey']['address'])?$vout['scriptPubKey']['address']:'';
	$scriptpubkey_id = get_scriptpubkey_id(hex2bin($vout['scriptPubKey']['hex']), $address);

	db_direct('LOCK TABLES txos WRITE');
	$txo_id = db_single_field('SELECT txo_id FROM txos WHERE create_txid_id = ? AND create_txo_index = ?', $txid_id, $vout['n']);
	if (!$txo_id) db_exec('INSERT INTO txos ( txo_value, scriptpubkey_id, create_txid_id, create_txo_index, destroy_txid_id, destroy_txo_index ) VALUES ( ?, ?, ?, ?, ?, ? )', $vout['value'], $scriptpubkey_id, $txid_id, $vout['n'], NULL, NULL);
	db_direct('UNLOCK TABLES');
}

function scan_transaction($txinfo) {
	$txid_id = get_txid_id($txinfo['tx_hash']);
	$tx_id = db_single_field("SELECT tx_id FROM txs WHERE txid_id = ?", $txid_id);
	$tx = rpc_bitcoin('getrawtransaction', $txinfo['tx_hash'], 2);
	if (!$tx_id) { /* this transaction is new */
		echo("  * {$txinfo['tx_hash']}\n");
		foreach ($tx['vin'] as $no => $vin) {
			if (!isset($vin['prevout'])) continue;
			scan_vin($no, $vin, $txid_id);
		}
		foreach ($tx['vout'] as $no => $vout) {
			scan_vout($no, $vout, $txid_id);
		}
	}

	$merkle = rpc_electrum('blockchain.transaction.get_merkle', $txinfo['tx_hash'], $txinfo['height']);

	db_exec('INSERT INTO txs ( txid_id, tx_fee, tx_blocktime, tx_height, tx_pos ) VALUES ( ?, ?, FROM_UNIXTIME( ? ), ?, ? ) ON DUPLICATE KEY UPDATE tx_blocktime = FROM_UNIXTIME( ? ), tx_height = ?, tx_pos = ?', $txid_id, (isset($tx['fee'])?$tx['fee']:0), $tx['blocktime'], $merkle['block_height'], $merkle['pos'], $tx['blocktime'], $merkle['block_height'], $merkle['pos']);
}

function scan_scriptpubkey_info($scriptpubkey_info) {
	$scriptpubkey_status = rpc_electrum('blockchain.scripthash.subscribe', $scriptpubkey_info['reverse_scriptpubkey_hash']);
	if ($scriptpubkey_info['scriptpubkey_status'] == $scriptpubkey_status) {
		//echo("MATCH!\n");
		return $scriptpubkey_status == ''?0:1;
	} //else echo("FAIL! \"$scriptpubkey_status\" \"{$scriptpubkey_info['scriptpubkey_status']}\"\n");

	$txinfos = rpc_electrum('blockchain.scripthash.get_history', $scriptpubkey_info['reverse_scriptpubkey_hash']);

	foreach ($txinfos as $txinfo) {
		scan_transaction($txinfo);
	}

	db_exec("UPDATE scriptpubkeys SET scriptpubkey_status = ? WHERE scriptpubkey_id = ?",
		compute_scripthash_status($scriptpubkey_info['scriptpubkey_id']),
		$scriptpubkey_info['scriptpubkey_id']);

	return count($txinfos)?1:0;
}

function scan_scriptpubkey($scriptpubkey_id) {
	$scriptpubkey_info = db_single_row('SELECT * FROM scriptpubkeys WHERE scriptpubkey_id = ?',
		$scriptpubkey_id);

	return scan_scriptpubkey_info($scriptpubkey_info);
	/*
	$scriptpubkey_status = rpc_electrum('blockchain.scripthash.subscribe', $scriptpubkey_info['reverse_scriptpubkey_hash']);
	if ($scriptpubkey_info['scriptpubkey_status'] == $scriptpubkey_status) {
		//echo("MATCH!\n");
		return $scriptpubkey_status == ''?0:1;
	} else echo("FAIL! \"$scriptpubkey_status\" \"{$scriptpubkey_info['scriptpubkey_status']}\"\n");

	$txinfos = rpc_electrum('blockchain.scripthash.get_history', $scriptpubkey_info['reverse_scriptpubkey_hash']);

	foreach ($txinfos as $txinfo) {
		scan_transaction($txinfo);
	}

	db_exec("UPDATE scriptpubkeys SET scriptpubkey_status = ? WHERE scriptpubkey_id = ?",
		compute_scripthash_status($scriptpubkey_info['scriptpubkey_id']),
		$scriptpubkey_info['scriptpubkey_id']);

	return count($txinfos)?1:0;
	 */
}

$wallets = db_query(<<<EOQ
SELECT walletpath_id, path_id, owners, wallet_desc, walletpath_desc, leaf,
	gap_limit, xpub, root, COUNT(scriptpubkey_id) count_scriptpubkey_ids, MAX(idx) + 1 max_idx_plus_one
FROM wallets
JOIN walletpaths USING (wallet_id)
JOIN (
	SELECT wallet_id, GROUP_CONCAT(owner_name) owners
	FROM owners
	JOIN owners2wallets USING (owner_id)
	WHERE owner_id = 1
	GROUP BY wallet_id
) AS tmp USING (wallet_id)
LEFT JOIN scriptpubkeys USING (walletpath_id)
LEFT JOIN paths USING (path_id)
LEFT JOIN xpubs USING (xpub_id)
GROUP BY walletpath_id
ORDER BY wallet_id, walletpath_id
EOQ);

while (($wallet = mysqli_fetch_assoc($wallets))) {
	if ($wallet['path_id']) {
		$gap = 0;
		$idx = 0;
		echo("Scanning {$wallet['wallet_desc']} / {$wallet['walletpath_desc']} ({$wallet['owners']})\n");
		// use addresses that already are in the DB as computing them is much slower
		// but only if the list of addresses in the DB Is complete
		if ($wallet['count_scriptpubkey_ids'] == $wallet['max_idx_plus_one']) {
			$scriptpubkey_infos = db_query('SELECT * FROM scriptpubkeys WHERE walletpath_id = ? ORDER BY idx', $wallet['walletpath_id']);
			while (($scriptpubkey_info = mysqli_fetch_assoc($scriptpubkey_infos))) {
				echo("- {$scriptpubkey_info['address']}\n");
				if (scan_scriptpubkey_info($scriptpubkey_info)) $gap = 0;
				else $gap++;
				$idx++;
			}
		}
		if ($gap == $wallet['gap_limit']) continue;
		$parsedXPUB = getParsedXPUB($wallet['xpub']);
		while ($gap < $wallet['gap_limit']) {
			$address = getAddressFast($parsedXPUB, $wallet['leaf'].$idx);
			$scriptpubkey_id = get_scriptpubkey_id(getScriptPubKey($address), $address);
			db_exec('UPDATE scriptpubkeys SET walletpath_id = ?, idx = ? WHERE scriptpubkey_id = ?',
				$wallet['walletpath_id'], $idx, $scriptpubkey_id);

			echo("- $address\n");
			if (scan_scriptpubkey($scriptpubkey_id)) $gap = 0;
			else $gap++;

			$idx++;
		}
	} else {
		echo("Scanning {$wallet['wallet_desc']} ({$wallet['owners']})\n");
		$scriptpubkeys = db_query("SELECT * FROM scriptpubkeys WHERE walletpath_id = {$wallet['walletpath_id']}");
		while (($scriptpubkey = mysqli_fetch_assoc($scriptpubkeys))) {
			echo("- {$scriptpubkey['address']}\n");
			scan_scriptpubkey($scriptpubkey['scriptpubkey_id']);
		}
	}
}
?>