utxodump.go

package main

// local packages
import "github.com/in3rsha/bitcoin-utxo-dump/bitcoin/btcleveldb" // chainstate leveldb decoding functions
import "github.com/in3rsha/bitcoin-utxo-dump/bitcoin/keys"   // bitcoin addresses
import "github.com/in3rsha/bitcoin-utxo-dump/bitcoin/bech32" // segwit bitcoin addresses

import "github.com/syndtr/goleveldb/leveldb" // go get github.com/syndtr/goleveldb/leveldb
import "github.com/syndtr/goleveldb/leveldb/opt" // set no compression when opening leveldb
import "flag"         // command line arguments
import "fmt"
import "os"           // open file for writing
import "os/exec"      // execute shell command (check bitcoin isn't running)
import "os/signal"    // catch interrupt signals CTRL-C to close db connection safely
import "syscall"      // catch kill commands too
import "bufio"        // bulk writing to file
import "encoding/hex" // convert byte slice to hexadecimal
import "strings"      // parsing flags from command line
import "runtime"      // Check OS type for file-handler limitations

func main() {

    // Version
    const Version = "1.0.1"
    
    // Set default chainstate LevelDB and output file
    defaultfolder := fmt.Sprintf("%s/.bitcoin/chainstate/", os.Getenv("HOME")) // %s = string
    defaultfile := "utxodump.csv"
    
    // Command Line Options (Flags)
    chainstate := flag.String("db", defaultfolder, "Location of bitcoin chainstate db.") // chainstate folder
    file := flag.String("o", defaultfile, "Name of file to dump utxo list to.") // output file
    fields := flag.String("f", "count,txid,vout,amount,type,address", "Fields to include in output. [count,txid,vout,height,amount,coinbase,nsize,script,type,address]")
    testnetflag := flag.Bool("testnet", false, "Is the chainstate leveldb for testnet?") // true/false
    verbose := flag.Bool("v", false, "Print utxos as we process them (will be about 3 times slower with this though).")
    version := flag.Bool("version", false, "Print version.")
    p2pkaddresses := flag.Bool("p2pkaddresses", false, "Convert public keys in P2PK locking scripts to addresses also.") // true/false
    nowarnings := flag.Bool("nowarnings", false, "Ignore warnings if bitcoind is running in the background.") // true/false
    quiet := flag.Bool("quiet", false, "Do not display any progress or results.") // true/false
    flag.Parse() // execute command line parsing for all declared flags

    // Check bitcoin isn't running first
    if ! *nowarnings {
		cmd := exec.Command("bitcoin-cli", "getnetworkinfo")
		_, err := cmd.Output()
		if err == nil {
		    fmt.Println("Bitcoin is running. You should shut it down with `bitcoin-cli stop` first. We don't want to access the chainstate LevelDB while Bitcoin is running.")
		    fmt.Println("Note: If you do stop bitcoind, make sure that it won't auto-restart (e.g. if it's running as a systemd service).")
		    
		    // Ask if you want to continue anyway (e.g. if you've copied the chainstate to a new location and bitcoin is still running)
		    reader := bufio.NewReader(os.Stdin)
			fmt.Printf("%s [y/n] (default n): ", "Do you wish to continue anyway?")
			response, _ := reader.ReadString('\n')
			response = strings.ToLower(strings.TrimSpace(response))

			if response != "y" && response != "yes" {
				return
			}
		}
    }
    
    // Check if OS type is Mac OS, then increase ulimit -n to 4096 filehandler during runtime and reset to 1024 at the end
    // Mac OS standard is 1024
    // Linux standard is already 4096 which is also "max" for more edit etc/security/limits.conf
	if runtime.GOOS == "darwin" {
        cmd2 := exec.Command("ulimit", "-n", "4096")
        fmt.Println("setting ulimit 4096\n")
        _, err := cmd2.Output()
        if err != nil {
            fmt.Println("setting new ulimit failed with %s\n", err)
        }
        defer exec.Command("ulimit", "-n", "1024")
	}

    // Show Version
    if *version {
      fmt.Println(Version)
      os.Exit(0)
    }

    // Mainnet or Testnet (for encoding addresses correctly)
    testnet := false
    if *testnetflag == true { // check testnet flag
        testnet = true
    } else { // only check the chainstate path if testnet flag has not been explicitly set to true
        if strings.Contains(*chainstate, "testnet") { // check the chainstate path
            testnet = true
        }
    }

    // Check chainstate LevelDB folder exists
    if _, err := os.Stat(*chainstate); os.IsNotExist(err) {
        fmt.Println("Couldn't find", *chainstate)
        return
    }

    // Select bitcoin chainstate leveldb folder
    // open leveldb without compression to avoid corrupting the database for bitcoin
    opts := &opt.Options{
        Compression: opt.NoCompression,
    }
    // https://bitcoin.stackexchange.com/questions/52257/chainstate-leveldb-corruption-after-reading-from-the-database
    // https://github.com/syndtr/goleveldb/issues/61
    // https://godoc.org/github.com/syndtr/goleveldb/leveldb/opt

    db, err := leveldb.OpenFile(*chainstate, opts) // You have got to dereference the pointer to get the actual value
    if err != nil {
        fmt.Println("Couldn't open LevelDB.")
        fmt.Println(err)
        return
    }
    defer db.Close()

    // Output Fields - build output from flags passed in
    output := map[string]string{} // we will add to this as we go through each utxo in the database
    fieldsAllowed := []string{"count", "txid", "vout", "height", "coinbase", "amount", "nsize", "script", "type", "address"}

    // Create a map of selected fields
    fieldsSelected := map[string]bool{"count":false, "txid":false, "vout":false, "height":false, "coinbase":false, "amount":false, "nsize":false, "script":false, "type":false, "address":false}

    // Check that all the given fields are included in the fieldsAllowed array
    for _, v := range strings.Split(*fields, ",") {
        exists := false
        for _, w := range fieldsAllowed {
            if v == w { // check each field against every element in the fieldsAllowed array
                exists = true
            }
        }
        if exists == false {
            fmt.Printf("'%s' is not a field you can use for the output.\n", v)
            fieldsList := ""
            for _, v := range fieldsAllowed {
                fieldsList += v
                fieldsList += ","
            }
            fieldsList = fieldsList[:len(fieldsList)-1] // remove trailing comma
            fmt.Printf("Choose from the following: %s\n", fieldsList)
            return
        }
        // Set field in fieldsSelected map - helps to determine what and what not to calculate later on (to speed processing up)
        if exists == true {
            fieldsSelected[v] = true
        }
    }

    // Open file to write results to.
    f, err := os.Create(*file) // os.OpenFile("filename.txt", os.O_APPEND, 0666)
    if err != nil {
        panic(err)
    }
    defer f.Close()
    if ! *quiet {
    	fmt.Printf("Processing %s and writing results to %s\n", *chainstate, *file)
    }

    // Create file buffer to speed up writing to the file.
    writer := bufio.NewWriter(f)
    defer writer.Flush() // Flush the bufio buffer to the file before this script ends
	
    // CSV Headers
    csvheader := ""
    for _, v := range strings.Split(*fields, ",") {
        csvheader += v
        csvheader += ","
    } // count,txid,vout,
    csvheader = csvheader[:len(csvheader)-1] // remove trailing ,
    if ! *quiet {
        fmt.Println(csvheader)
    }
    fmt.Fprintln(writer, csvheader) // write to file

    // Stats - keep track of interesting stats as we read through leveldb.
    var totalAmount int64 = 0 // total amount of satoshis
    scriptTypeCount := map[string]int{"p2pk":0, "p2pkh":0, "p2sh":0, "p2ms":0, "p2wpkh":0, "p2wsh":0, "p2tr": 0, "non-standard": 0} // count each script type


    // Declare obfuscateKey (a byte slice)
    var obfuscateKey []byte // obfuscateKey := make([]byte, 0)

    // Iterate over LevelDB keys
    iter := db.NewIterator(nil, nil)
    // NOTE: iter.Release() comes after the iteration (not deferred here)
    // err := iter.Error()
    // fmt.Println(err)

    // Catch signals that interrupt the script so that we can close the database safely (hopefully not corrupting it)
    c := make(chan os.Signal, 1)
    signal.Notify(c, os.Interrupt, syscall.SIGTERM)
    go func() { // goroutine
        <-c // receive from channel
        if ! *quiet {
            fmt.Println("Interrupt signal caught. Shutting down gracefully.")
        }
        // iter.Release() // release database iterator
        db.Close()     // close databse
        writer.Flush() // flush bufio to the file
        f.Close()      // close file
        os.Exit(0)     // exit
    }()

    i := 0
    for iter.Next() {

        key := iter.Key()
        value := iter.Value()

        // first byte in key indicates the type of key we've got for leveldb
        prefix := key[0]

        // obfuscateKey (first key)
        if (prefix == 14) { // 14 = obfuscateKey
            obfuscateKey = value
        }

        // utxo entry
        if (prefix == 67) { // 67 = 0x43 = C = "utxo"

            // ---
            // Key
            // ---

            //      430000155b9869d56c66d9e86e3c01de38e3892a42b99949fe109ac034fff6583900
            //      <><--------------------------------------------------------------><>
            //      /                               |                                  \
            //  type                          txid (little-endian)                      index (varint)

            // txid
            if fieldsSelected["txid"] {
                txidLE := key[1:33] // little-endian byte order

                // txid - reverse byte order
                txid := make([]byte, 0) // create empty byte slice (dont want to mess with txid directly)
                for i := len(txidLE)-1; i >= 0; i-- { // run backwards through the txid slice
                    txid = append(txid, txidLE[i]) // append each byte to the new byte slice
                }
                output["txid"] = hex.EncodeToString(txid) // add to output results map
            }

            // vout
            if fieldsSelected["vout"] {
                index := key[33:]

                // convert varint128 index to an integer
                vout := btcleveldb.Varint128Decode(index)
                output["vout"] = fmt.Sprintf("%d",vout)
            }

            // -----
            // Value
            // -----

            // Only deobfuscate and get data from the Value if something is needed from it (improves speed if you just want the txid:vout)
            if fieldsSelected["type"] || fieldsSelected["height"] || fieldsSelected["coinbase"] || fieldsSelected["amount"] || fieldsSelected["nsize"] || fieldsSelected["script"] || fieldsSelected["address"] {

                // Copy the obfuscateKey ready to extend it
                obfuscateKeyExtended := obfuscateKey[1:] // ignore the first byte, as that just tells you the size of the obfuscateKey

                // Extend the obfuscateKey so it's the same length as the value
                for i, k := len(obfuscateKeyExtended), 0; len(obfuscateKeyExtended) < len(value); i, k = i+1, k+1 {
                    // append each byte of obfuscateKey to the end until it's the same length as the value
                    obfuscateKeyExtended = append(obfuscateKeyExtended, obfuscateKeyExtended[k])
                    // Example
                    //   [8 175 184 95 99 240 37 253 115 181 161 4 33 81 167 111 145 131 0 233 37 232 118 180 123 120 78]
                    //   [8 177 45 206 253 143 135 37 54]                                                                  <- obfuscate key
                    //   [8 177 45 206 253 143 135 37 54 8 177 45 206 253 143 135 37 54 8 177 45 206 253 143 135 37 54]    <- extended
                }

                // XOR the value with the obfuscateKey (xor each byte) to de-obfuscate the value
                var xor []byte // create a byte slice to hold the xor results
                for i := range value {
                    result := value[i] ^ obfuscateKeyExtended[i]
                    xor = append(xor, result)
                }

                // -----
                // Value
                // -----

                //   value: 71a9e87d62de25953e189f706bcf59263f15de1bf6c893bda9b045 <- obfuscated
                //          b12dcefd8f872536b12dcefd8f872536b12dcefd8f872536b12dce <- extended obfuscateKey (XOR)
                //          c0842680ed5900a38f35518de4487c108e3810e6794fb68b189d8b <- deobfuscated
                //          <----><----><><-------------------------------------->
                //           /      |    \                   |
                //      varint   varint   varint          script <- P2PKH/P2SH hash160, P2PK public key, or complete script
                //         |        |     nSize
                //         |        |
                //         |     amount (compressesed)
                //         |
                //         |
                //  100000100001010100110
                //  <------------------> \
                //         height         coinbase

                offset := 0

                // First Varint
                // ------------
                // b98276a2ec7700cbc2986ff9aed6825920aece14aa6f5382ca5580
                // <---->
                varint, bytesRead := btcleveldb.Varint128Read(xor, 0) // start reading at 0
                offset += bytesRead
                varintDecoded := btcleveldb.Varint128Decode(varint)

                if fieldsSelected["height"] || fieldsSelected["coinbase"] {

                    // Height (first bits)
                    height := varintDecoded >> 1 // right-shift to remove last bit
                    output["height"] = fmt.Sprintf("%d", height)

                    // Coinbase (last bit)
                    coinbase := varintDecoded & 1 // AND to extract right-most bit
                    output["coinbase"] = fmt.Sprintf("%d", coinbase)
                }

                // Second Varint
                // -------------
                // b98276a2ec7700cbc2986ff9aed6825920aece14aa6f5382ca5580
                //       <---->
                varint, bytesRead = btcleveldb.Varint128Read(xor, offset) // start after last varint
                offset += bytesRead
                varintDecoded = btcleveldb.Varint128Decode(varint)

                // Amount
                if fieldsSelected["amount"] {
                    amount := btcleveldb.DecompressValue(varintDecoded) // int64
                    output["amount"] = fmt.Sprintf("%d", amount)
                    totalAmount += amount // add to stats
                }

                // Third Varint
                // ------------
                // b98276a2ec7700cbc2986ff9aed6825920aece14aa6f5382ca5580
                //             <>
                //
                // nSize - byte to indicate the type or size of script - helps with compression of the script data
                //  - https://github.com/bitcoin/bitcoin/blob/master/src/compressor.cpp

                //  0  = P2PKH <- hash160 public key
                //  1  = P2SH  <- hash160 script
                //  2  = P2PK 02publickey <- nsize makes up part of the public key in the actual script
                //  3  = P2PK 03publickey
                //  4  = P2PK 04publickey (uncompressed - but has been compressed in to leveldb) y=even
                //  5  = P2PK 04publickey (uncompressed - but has been compressed in to leveldb) y=odd
                //  6+ = [size of the upcoming script] (subtract 6 though to get the actual size in bytes, to account for the previous 5 script types already taken)
                varint, bytesRead = btcleveldb.Varint128Read(xor, offset) // start after last varint
                offset += bytesRead
                nsize := btcleveldb.Varint128Decode(varint) //
                output["nsize"] = fmt.Sprintf("%d", nsize)

                // Script (remaining bytes)
                // ------
                // b98276a2ec7700cbc2986ff9aed6825920aece14aa6f5382ca5580
                //               <-------------------------------------->
                
                // Move offset back a byte if script type is 2, 3, 4, or 5 (because this forms part of the P2PK public key along with the actual script)
                if nsize > 1 && nsize < 6 { // either 2, 3, 4, 5
                    offset--
                }
                
                // Get the remaining bytes
                script := xor[offset:]
                
                // Decompress the public keys from P2PK scripts that were uncompressed originally. They got compressed just for storage in the database.
                // Only decompress if the public key was uncompressed and
                //   * Script field is selected or
                //   * Address field is selected and p2pk addresses are enabled.
                if (nsize == 4 || nsize == 5) && (fieldsSelected["script"] || (fieldsSelected["address"] && *p2pkaddresses)) {
                    script = keys.DecompressPublicKey(script)
                }
                
                if fieldsSelected["script"] {
                    output["script"] = hex.EncodeToString(script)
                }

                // Addresses - Get address from script (if possible), and set script type (P2PK, P2PKH, P2SH, P2MS, P2WPKH, P2WSH or P2TR)
                // ---------
                if fieldsSelected["address"] || fieldsSelected["type"] {

                    var address string // initialize address variable
                    var scriptType string = "non-standard" // initialize script type

					switch {
					
		                // P2PKH
		                case nsize == 0:
		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if testnet == true {
		                            address = keys.Hash160ToAddress(script, []byte{0x6f}) // (m/n)address - testnet addresses have a special prefix
		                        } else {
		                            address = keys.Hash160ToAddress(script, []byte{0x00}) // 1address
		                        }
		                    }
		                    scriptType = "p2pkh"
		                    scriptTypeCount["p2pkh"] += 1

		                // P2SH
		                case nsize == 1:
		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if testnet == true {
		                            address = keys.Hash160ToAddress(script, []byte{0xc4}) // 2address - testnet addresses have a special prefix
		                        } else {
		                            address = keys.Hash160ToAddress(script, []byte{0x05}) // 3address
		                        }
		                    }
		                    scriptType = "p2sh"
		                    scriptTypeCount["p2sh"] += 1

		                // P2PK
		                case 1 < nsize && nsize < 6: // 2, 3, 4, 5
		                    //  2 = P2PK 02publickey <- nsize makes up part of the public key in the actual script (e.g. 02publickey)
		                    //  3 = P2PK 03publickey <- y is odd/even (0x02 = even, 0x03 = odd)
		                    //  4 = P2PK 04publickey (uncompressed)  y = odd  <- actual script uses an uncompressed public key, but it is compressed when stored in this db
		                    //  5 = P2PK 04publickey (uncompressed) y = even

		                    // "The uncompressed pubkeys are compressed when they are added to the db. 0x04 and 0x05 are used to indicate that the key is supposed to be uncompressed and those indicate whether the y value is even or odd so that the full uncompressed key can be retrieved."
		                    //
		                    // if nsize is 4 or 5, you will need to uncompress the public key to get it's full form
		                    // if nsize == 4 || nsize == 5 {
		                    //     // uncompress (4 = y is even, 5 = y is odd)
		                    //     script = decompress(script)
		                    // }

		                    scriptType = "p2pk"
		                    scriptTypeCount["p2pk"] += 1

		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if *p2pkaddresses { // if we want to convert public keys in P2PK scripts to their corresponding addresses (even though they technically don't have addresses)

									// NOTE: These have already been decompressed. They were decompressed when the script data was first encountered.
		                            // Decompress if starts with 0x04 or 0x05
		                            // if (nsize == 4) || (nsize == 5) {
		                            //     script = keys.DecompressPublicKey(script)
		                            // }

		                            if testnet == true {
		                                address = keys.PublicKeyToAddress(script, []byte{0x6f}) // (m/n)address - testnet addresses have a special prefix
		                            } else {
		                                address = keys.PublicKeyToAddress(script, []byte{0x00}) // 1address
		                            }
		                        }
		                    }

		                // P2MS
		                case len(script) > 0 && script[len(script)-1] == 174: // if there is a script and if the last opcode is OP_CHECKMULTISIG (174) (0xae)
		                    scriptType = "p2ms"
		                    scriptTypeCount["p2ms"] += 1

		                // P2WPKH
		                case nsize == 28 && script[0] == 0 && script[1] == 20: // P2WPKH (script type is 28, which means length of script is 22 bytes)
		                    // 315,c016e8dcc608c638196ca97572e04c6c52ccb03a35824185572fe50215b80000,0,551005,3118,0,28,001427dab16cca30628d395ccd2ae417dc1fe8dfa03e
		                    // script  = 0014700d1635c4399d35061c1dabcc4632c30fedadd6
		                    // script  = [0 20 112 13 22 53 196 57 157 53 6 28 29 171 204 70 50 195 15 237 173 214]
		                    // version = [0]
		                    // program =      [112 13 22 53 196 57 157 53 6 28 29 171 204 70 50 195 15 237 173 214]
		                    version := script[0]
		                    program := script[2:]

		                    // bech32 function takes an int array and not a byte array, so convert the array to integers
		                    var programint []int // initialize empty integer array to hold the new one
		                    for _, v := range program {
		                        programint = append(programint, int(v)) // cast every value to an int
		                    }

		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if testnet == true {
		                            address, _ = bech32.SegwitAddrEncode("tb", int(version), programint) // hrp (string), version (int), program ([]int)
		                        } else {
		                            address, _ = bech32.SegwitAddrEncode("bc", int(version), programint) // hrp (string), version (int), program ([]int)
		                        }
		                    }

		                    scriptType = "p2wpkh"
		                    scriptTypeCount["p2wpkh"] += 1

		                // P2WSH
		                case nsize == 40 && script[0] == 0 && script[1] == 32: // P2WSH (script type is 40, which means length of script is 34 bytes; 0x00 means segwit v0)
		                    // 956,1df27448422019c12c38d21c81df5c98c32c19cf7a312e612f78bebf4df20000,1,561890,800000,0,40,00200e7a15ba23949d9c274a1d9f6c9597fa9754fc5b5d7d45fc4369eeb4935c9bfe
		                    version := script[0]
		                    program := script[2:]

		                    var programint []int
		                    for _, v := range program {
		                        programint = append(programint, int(v)) // cast every value to an int
		                    }

		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if testnet == true {
		                            address, _ = bech32.SegwitAddrEncode("tb", int(version), programint) // testnet bech32 addresses start with tb
		                        } else {
		                            address, _ = bech32.SegwitAddrEncode("bc", int(version), programint) // mainnet bech32 addresses start with bc
		                        }
		                    }

		                    scriptType = "p2wsh"
		                    scriptTypeCount["p2wsh"] += 1

		                // P2TR
		                case nsize == 40 && script[0] == 0x51 && script[1] == 32: // P2TR (script type is 40, which means length of script is 34 bytes; 0x51 means segwit v1 = taproot)
		                    // 9608047,bbc2e707dbc68db35dbada9be9d9182e546ee9302dc0a5cdd1a8dc3390483620,0,709635,2003,0,40,5120ef69f6a605817bc88882f88cbfcc60962af933fe1ae24a61069fb60067045963
		                    version := 1
		                    program := script[2:]

		                    var programint []int
		                    for _, v := range program {
		                        programint = append(programint, int(v)) // cast every value to an int
		                    }

		                    if fieldsSelected["address"] { // only work out addresses if they're wanted
		                        if testnet == true {
		                            address, _ = bech32.SegwitAddrEncode("tb", version, programint) // testnet bech32 addresses start with tb
		                        } else {
		                            address, _ = bech32.SegwitAddrEncode("bc", version, programint) // mainnet bech32 addresses start with bc
		                        }
		                    }

		                    scriptType = "p2tr"
		                    scriptTypeCount["p2tr"] += 1

		                // Non-Standard (if the script type hasn't been identified and set then it remains as an unknown "non-standard" script)
		                default:
		                	scriptType = "non-standard"
		                    scriptTypeCount["non-standard"] += 1
		                
		        	} // switch
		        	
		        	// add address and script type to results map
	                output["address"] = address
	                output["type"] = scriptType

                } // if fieldsSelected["address"] || fieldsSelected["type"]

            } // if field from the Value is needed (e.g. -f txid,vout,address)


            // -------
            // Results
            // -------

            // CSV Lines
            output["count"] = fmt.Sprintf("%d",i+1) // convert integer to string (e.g 1 to "1")
            csvline := "" // Build output line from given fields
            // [ ] string builder faster?
            for _, v := range strings.Split(*fields, ",") {
                csvline += output[v]
                csvline += ","
            }
            csvline = csvline[:len(csvline)-1] // remove trailing ,

            // Print Results
            // -------------
            if ! *quiet {
		        if *verbose { // -v flag
		            fmt.Println(csvline) // Print each line.
		            // 1157.76user 176.47system 30:44.64elapsed 72%CPU (0avgtext+0avgdata 55332maxresident)k
		            // 1110.76user 164.97system 29:17.17elapsed 72%CPU (0avgtext+0avgdata 55236maxresident)k (after using packages)
		        } else {
			        if (i > 0 && i % 100000 == 0) {
			            fmt.Printf("%d utxos processed\n", i) // Show progress at intervals.
			        }
		            // 812.18user 16.94system 12:44.04elapsed 108%CPU (0avgtext+0avgdata 55272maxresident)k
		            // 951.03user 27.91system 15:21.35elapsed 106%CPU (0avgtext+0avgdata 55896maxresident)k (after using packages)
		        }
		    }

            // Write to File
            // -------------
            // Write to buffer (use bufio for faster writes)
            fmt.Fprintln(writer, csvline)

            // Increment Count
            i++
        }
    }
    iter.Release() // Do not defer this, want to release iterator before closing database

    // Final Progress Report
    // ---------------------
    if ! *quiet {
		// fmt.Printf("%d utxos saved to: %s\n", i, *file)
		fmt.Println()
		fmt.Printf("Total UTXOs: %d\n", i)

		// Can only show total btc amount if we have requested to get the amount for each entry with the -f fields flag
		if fieldsSelected["amount"] {
		    fmt.Printf("Total BTC:   %.8f\n", float64(totalAmount) / float64(100000000)) // convert satoshis to BTC (float with 8 decimal places)
		}

		// Can only show script type stats if we have requested to get the script type for each entry with the -f fields flag
		if fieldsSelected["type"] {
		    fmt.Println("Script Types:")
		    for k, v := range scriptTypeCount {
		        fmt.Printf(" %-12s %d\n", k, v) // %-12s = left-justify padding
		    }
		}
	}

}