package gui

import (
	"time"

	"github.com/p9c/p9/pkg/btcjson"

	"github.com/p9c/p9/pkg/qu"
)

// Watcher keeps the chain and wallet and rpc clients connected
func (wg *WalletGUI) Watcher() qu.C {
	var e error
	I.Ln("starting up watcher")
	quit := qu.T()
	// start things up first
	if !wg.node.Running() {
		D.Ln("watcher starting node")
		wg.node.Start()
	}
	if wg.ChainClient == nil {
		D.Ln("chain client is not initialized")
		var e error
		if e = wg.chainClient(); E.Chk(e) {
		}
	}
	if !wg.wallet.Running() {
		D.Ln("watcher starting wallet")
		wg.wallet.Start()
		D.Ln("now we can open the wallet")
		if e = wg.writeWalletCookie(); E.Chk(e) {
		}
	}
	if wg.WalletClient == nil || wg.WalletClient.Disconnected() {
	allOut:
		for {
			if e = wg.walletClient(); !E.Chk(e) {
			out:
				for {
					// keep trying until shutdown or the wallet client connects
					I.Ln("attempting to get blockchain info from wallet")
					var bci *btcjson.GetBlockChainInfoResult
					if bci, e = wg.WalletClient.GetBlockChainInfo(); E.Chk(e) {
						select {
						case <-time.After(time.Second):
							continue
						case <-wg.quit:
							return nil
						}
					}
					D.S(bci)
					break out
				}
			}
			wg.unlockPassword.Wipe()
			select {
			case <-time.After(time.Second):
				break allOut
			case <-wg.quit:
				return nil
			}
		}
	}
	go func() {
		
		watchTick := time.NewTicker(time.Second)
		var e error
	totalOut:
		for {
		disconnected:
			for {
				D.Ln("top of watcher loop")
				select {
				case <-watchTick.C:
					if e = wg.Advertise(); E.Chk(e) {
					}
					if !wg.node.Running() {
						D.Ln("watcher starting node")
						wg.node.Start()
					}
					if wg.ChainClient.Disconnected() {
						if e = wg.chainClient(); E.Chk(e) {
							continue
						}
					}
					if !wg.wallet.Running() {
						D.Ln("watcher starting wallet")
						wg.wallet.Start()
					}
					if wg.WalletClient == nil {
						D.Ln("wallet client is not initialized")
						if e = wg.walletClient(); E.Chk(e) {
							continue
							// } else {
							// 	break disconnected
						}
					}
					if wg.WalletClient.Disconnected() {
						if e = wg.WalletClient.Connect(1); D.Chk(e) {
							continue
							// } else {
							// 	break disconnected
						}
					} else {
						D.Ln(
							"chain, chainclient, wallet and client are now connected",
							wg.node.Running(),
							!wg.ChainClient.Disconnected(),
							wg.wallet.Running(),
							!wg.WalletClient.Disconnected(),
						)
						wg.updateChainBlock()
						wg.processWalletBlockNotification()
						break disconnected
					}
				case <-quit.Wait():
					break totalOut
				case <-wg.quit.Wait():
					break totalOut
				}
			}
			if wg.cx.Config.Controller.True() {
				if wg.ChainClient != nil {
					if e = wg.ChainClient.SetGenerate(
						wg.cx.Config.Controller.True(),
						wg.cx.Config.GenThreads.V(),
					); !E.Chk(e) {
					}
				}
			}
		connected:
			for {
				select {
				case <-watchTick.C:
					if !wg.wallet.Running() {
						D.Ln(">>>>>>>>>>>>>>>>>>>>>>>>>>>>> wallet not running, breaking out")
						break connected
					}
					if wg.WalletClient == nil || wg.WalletClient.Disconnected() {
						D.Ln(">>>>>>>>>>>>>>>>>>>>>>>>>>>>> wallet client disconnected, breaking out")
						break connected
					}
				case <-quit.Wait():
					break totalOut
				case <-wg.quit.Wait():
					break totalOut
				}
			}
		}
		D.Ln("shutting down watcher")
		if wg.WalletClient != nil {
			wg.WalletClient.Disconnect()
			wg.WalletClient.Shutdown()
		}
		wg.wallet.Stop()
	}()
	return quit
}