fix & examples

Author: andkom

examples/print_balances.php

@@ -0,0 +1,63 @@
+<?php
+
+include '../vendor/autoload.php';
+
+$blockDir = getenv('HOME') . '/Library/Application Support/Bitcoin/blocks';
+
+$reader = new \AndKom\PhpBitcoinBlockchain\BlockFileReader();
+
+// txid:index => balance
+$outputs = [];
+
+// txid:index => address
+$addresses = [];
+
+foreach ($reader->read($blockDir . '/blk00000.dat') as $block) {
+
+    foreach ($block->transactions as $tx) {
+        foreach ($tx->inputs as $in) {
+            if ($in->isCoinbase()) continue;
+
+            $prev = $in->prevTxHash . ':' . $in->prevTxOutIndex;
+            $outputs[$prev] = 0;
+        }
+
+        $txid = $tx->getHash();
+
+        foreach ($tx->outputs as $index => $out) {
+            try {
+                $address = $out->scriptPubKey->getOutputAddress();
+            } catch (\Exception $e) {
+                $address = 'unknown script: ' . $out->scriptPubKey;
+            }
+
+            $output = "$txid:$index";
+
+            if (!isset($outputs[$output])) {
+                $outputs[$output] = 0;
+            }
+
+            $outputs[$output] += $out->value;
+            $addresses[$output] = $address;
+        }
+    }
+}
+
+$balances = [];
+
+foreach ($outputs as $out => $value) {
+    // @todo address may not exists because blocks are unordered
+    $address = $addresses[$out];
+
+    if (!isset($balances[$address])) {
+        $balances[$address] = 0;
+    }
+
+    $balances[$address] += $value;
+}
+
+arsort($balances);
+
+foreach ($balances as $address => $balance) {
+    echo $address . ' => ' . bcdiv($balance, 1e8, 8) . " BTC\n";
+}

examples/print_blocks.php

@@ -0,0 +1,36 @@
+<?php
+
+include '../vendor/autoload.php';
+
+$blockDir = getenv('HOME') . '/Library/Application Support/Bitcoin/blocks';
+
+$reader = new \AndKom\PhpBitcoinBlockchain\BlockFileReader();
+
+foreach ($reader->read($blockDir . '/blk00000.dat') as $block) {
+
+    echo str_repeat('=', 71) . "\n";
+    echo "Block: " . $block->header->getHash() . "\n";
+    echo "Date: " . date('r', $block->header->time) . "\n";
+
+    foreach ($block->transactions as $tx) {
+        echo "\nTX: " . $tx->getHash() . "\n";
+
+        foreach ($tx->inputs as $in) {
+            if ($in->isCoinbase()) {
+                echo "IN: Coinbase\n";
+            } else {
+                echo "IN: " . $in->prevTxHash . ':' . $in->prevTxOutIndex . "\n";
+            }
+        }
+
+        foreach ($tx->outputs as $out) {
+            try {
+                $address = $out->scriptPubKey->getOutputAddress();
+            } catch (\Exception $e) {
+                $address = 'Unable to decode output address.';
+            }
+
+            echo "OUT: " . bcdiv($out->value, 1e8, 8) . " BTC => " . $address . "\n";
+        }
+    }
+}

src/Input.php

@@ -64,4 +64,12 @@ public function serialize(Writer $stream): self
         $stream->writeInt32($this->sequenceNo);
         return $this;
     }
+
+    /**
+     * @return bool
+     */
+    public function isCoinbase(): bool
+    {
+        return $this->prevTxHash == '0000000000000000000000000000000000000000000000000000000000000000';
+    }
 }

src/Transaction.php

@@ -142,18 +142,4 @@ public function getHash(bool $segWit = false): string
         $hash = bin2hex($hash);
         return $hash;
     }
-
-    /**
-     * @return bool
-     */
-    public function isCoinbase(): bool
-    {
-        foreach ($this->inputs as $input) {
-            if ($input->prevTxHash == '0000000000000000000000000000000000000000000000000000000000000000') {
-                return true;
-            }
-        }
-
-        return false;
-    }
 }

tests/BlockTest.php

@@ -43,14 +43,14 @@ public function testParse()
         $this->assertEquals($block->transactions[0]->getHash(), '4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b');
         $this->assertEquals($block->transactions[0]->version, 1);
         $this->assertEquals($block->transactions[0]->inCount, 1);
+        $this->assertEquals($block->transactions[0]->inputs[0]->isCoinbase(), true);
         $this->assertEquals($block->transactions[0]->inputs[0]->prevTxHash, '0000000000000000000000000000000000000000000000000000000000000000');
         $this->assertEquals($block->transactions[0]->inputs[0]->prevTxOutIndex, -1);
         $this->assertEquals($block->transactions[0]->inputs[0]->sequenceNo, -1);
         $this->assertEquals($block->transactions[0]->inputs[0]->scriptSig->getData(), hex2bin('04ffff001d0104455468652054696d65732030332f4a616e2f32303039204368616e63656c6c6f72206f6e206272696e6b206f66207365636f6e64206261696c6f757420666f722062616e6b73'));
         $this->assertEquals($block->transactions[0]->outputs[0]->value, 5000000000);
         $this->assertEquals($block->transactions[0]->outputs[0]->scriptPubKey->getData(), hex2bin('4104678afdb0fe5548271967f1a67130b7105cd6a828e03909a67962e0ea1f61deb649f6bc3f4cef38c4f35504e51ec112de5c384df7ba0b8d578a4c702b6bf11d5fac'));
         $this->assertEquals($block->transactions[0]->lockTime, 0);
-        $this->assertTrue($block->transactions[0]->isCoinbase());
 
         $stream = new Writer();
         $block->serialize($stream);