Major update, work with new notifications after Decred 0.6.0.

Squashed commit of the following:

commit 9b30cbc
Author: Jon Chappelow <[email protected]>
Date:   Wed Nov 16 17:59:18 2016 -0800

    Make messages debug instead of info, remove TODO.

commit 663005f
Author: Jon Chappelow <[email protected]>
Date:   Wed Nov 16 14:08:16 2016 -0800

    Move code to new files, impove balance alignment.

    Add OnWinningTickets with debug level logging of the hashes.
    Include tx out index in message.

commit 0b6f0fc
Author: Jon Chappelow <[email protected]>
Date:   Wed Nov 16 11:31:37 2016 -0800

    Refactoring, move channels and ntfns to own files.

    Make channels global, which simplifies all the interfaces and structures.

commit cf45c11
Author: Jon Chappelow <[email protected]>
Date:   Tue Nov 15 22:47:18 2016 -0800

    Sort of working again.

commit 3a8a4d0
Author: Jon Chappelow <[email protected]>
Date:   Tue Nov 15 07:22:08 2016 -0800

    This is going to be massive, stop Travis.

commit 5765d09
Author: Jon Chappelow <[email protected]>
Date:   Mon Nov 14 21:15:36 2016 -0800

    Fix up watchedAddrTx.

commit dd639fd
Author: Jon Chappelow <[email protected]>
Date:   Mon Nov 14 10:35:03 2016 -0800

    Begin changes for the new websocket notifications

Author: chappjc

TODO

@@ -82,7 +82,8 @@ type config struct {
 	NoCollectStakeInfo bool `long:"nostakeinfo" description:"Do not collect stake info data (default false)"`
 	PoolValue          bool `short:"p" long:"poolvalue" description:"Collect ticket pool value information (8-9 sec)."`
 
-	WatchAddresses []string `short:"w" long:"watchaddress" description:"Decred address for which to watch for incoming transactions. One per line."`
+	WatchAddresses []string `short:"w" long:"watchaddress" description:"Watched address (receiving). One per line."`
+	//WatchOutpoints []string `short:"o" long:"watchout" description:"Watched outpoint (sending). One per line."`
 
 	SMTPUser   string `long:"smtpuser" description:"SMTP user name"`
 	SMTPPass   string `long:"smtppass" description:"SMTP password"`
@@ -382,5 +383,13 @@ func loadConfig() (*config, error) {
 	log.Debugf("Output folder: %v", cfg.OutFolder)
 	log.Debugf("Log folder: %v", cfg.LogDir)
 
+	// mempool: new transactions, new tickets
+	//cfg.MonitorMempool = cfg.MonitorMempool && !cfg.NoMonitor
+	if cfg.MonitorMempool && cfg.NoMonitor {
+		log.Warn("Both --nomonitor (-e) and --mempool (-m) specified. " +
+			"Not monitoring mempool.")
+		cfg.MonitorMempool = false
+	}
+
 	return &cfg, nil
 }

config.go

@@ -13,9 +13,8 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	"strings"
 	"sync"
-	//"github.com/decred/dcrd/dcrjson"
-	//"github.com/decred/dcrutil"
 )
 
 type fileSaver struct {
@@ -359,20 +358,26 @@ func (s *StakeInfoDataToSummaryStdOut) Store(data *stakeInfoData) error {
 
 	fmt.Println("- Balances (by account)")
 	for acct, balances := range *data.accountBalances {
-		fmt.Printf("\tBalances (%s): \t %10.4f (any), %10.4f (spendable), %10.4f (locked)\n",
-			acct, balances["all"].ToCoin(), balances["spendable"].ToCoin(),
+		padWidth := len("imported") - len(acct) + 5
+		if padWidth < 0 {
+			padWidth = 0
+		}
+		padding := strings.Repeat(" ", padWidth)
+		fmt.Printf("\tBalances (%s):%s%12.4f (any),%12.4f (spendable),%12.4f (locked)\n",
+			acct, padding,
+			balances["all"].ToCoin(), balances["spendable"].ToCoin(),
 			balances["locked"].ToCoin())
 	}
 
 	fmt.Println("- Balances (by type)")
-	fmt.Printf("\tBalances (spendable):  %9.4f (default), %9.4f (all)\n",
+	fmt.Printf("\tBalances (spendable):%12.4f (default),%12.4f (all)\n",
 		data.balances.SpendableDefaultAccount,
 		data.balances.SpendableAllAccounts)
-	fmt.Printf("\tBalances (locked):     %9.4f (default), %9.4f (all), %9.4f (imported)\n",
+	fmt.Printf("\tBalances (locked):   %12.4f (default),%12.4f (all),%12.4f (imported)\n",
 		data.balances.LockedDefaultAccount,
 		data.balances.LockedAllAccounts,
 		data.balances.LockedImportedAccount)
-	fmt.Printf("\tBalances (any):        %9.4f (default), %9.4f (all)\n",
+	fmt.Printf("\tBalances (any):      %12.4f (default),%12.4f (all)\n",
 		data.balances.AllDefaultAcount, data.balances.AllAllAcounts)
 
 	fmt.Println("- Stake Info")

datasaver.go

@@ -0,0 +1,69 @@
+package main
+
+import (
+	"errors"
+	"fmt"
+	"net/smtp"
+	"strconv"
+)
+
+type emailConfig struct {
+	emailAddr                      string
+	smtpUser, smtpPass, smtpServer string
+	smtpPort                       int
+}
+
+// sendEmailWatchRecv Sends an email using the input emailConfig and message
+// string.
+func sendEmailWatchRecv(message string, ecfg *emailConfig) error {
+	// Check for nil pointer emailConfig
+	if ecfg == nil {
+		return errors.New("emailConfig must not be a nil pointer")
+	}
+
+	auth := smtp.PlainAuth(
+		"",
+		ecfg.smtpUser,
+		ecfg.smtpPass,
+		ecfg.smtpServer,
+	)
+
+	// The SMTP server address includes the port
+	addr := ecfg.smtpServer + ":" + strconv.Itoa(ecfg.smtpPort)
+	//log.Debug(addr)
+
+	// Make a header using a map for clarity
+	header := make(map[string]string)
+	header["From"] = ecfg.smtpUser
+	header["To"] = ecfg.emailAddr
+	// TODO: make subject line adjustable or include an amount
+	header["Subject"] = "dcrspy notification"
+	//header["MIME-Version"] = "1.0"
+	//header["Content-Type"] = "text/plain; charset=\"utf-8\""
+	//header["Content-Transfer-Encoding"] = "base64"
+
+	// Build the full message with the header + input message string
+	messageFull := ""
+	for k, v := range header {
+		messageFull += fmt.Sprintf("%s: %s\r\n", k, v)
+	}
+
+	messageFull += "\r\n" + message
+
+	// Send email
+	err := smtp.SendMail(
+		addr,
+		auth,
+		ecfg.smtpUser,            // sender is receiver
+		[]string{ecfg.emailAddr}, // recipients
+		[]byte(messageFull),
+	)
+
+	if err != nil {
+		log.Errorf("Failed to send email: %v", err)
+		return err
+	}
+
+	log.Tracef("Send email to address %v\n", ecfg.emailAddr)
+	return nil
+}

email.go

@@ -12,6 +12,7 @@ import:
 - package: github.com/btcsuite/websocket
 - package: github.com/decred/blake256
 - package: github.com/decred/dcrd
+  version: master
   subpackages:
   - blockchain
   - blockchain/stake
@@ -26,6 +27,7 @@ import:
   - txscript
   - wire
 - package: github.com/decred/dcrrpcclient
+  version: master
 - package: github.com/decred/dcrutil
   subpackages:
   - base58