handlers.go

// jeffCoin 3. ROUTINGNODE handlers.go

package routingnode

import (
	"bufio"
	"encoding/json"
	"strings"

	blockchain "github.com/JeffDeCola/jeffCoin/blockchain"
	log "github.com/sirupsen/logrus"
)

// FROM BLOCKCHAIN I/F ***************************************************************************************************

// handleSendBlockchain - SEND-BLOCKCHAIN (SBC)- Sends the blockchain and pendingBlock to another Node
func handleSendBlockchain(rw *bufio.ReadWriter) {

	s := "START  handleSendBlockchain() - SEND-BLOCKCHAIN (SBC)- Sends the blockchain and pendingBlock to another Node"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	// SENT - RESPOND - SEND BLOCKCHAIN
	sendBlockchain := blockchain.GetBlockchain()
	js, _ := json.Marshal(sendBlockchain)
	s = string(js)
	_, err := rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Sent blockchain to another node"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err := rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	// SENT - RESPOND - SEND PendingBlock
	sendPendingBlock := blockchain.GetPendingBlock()
	js, _ = json.Marshal(sendPendingBlock)
	s = string(js)
	_, err = rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Sent pendingBlock to another node"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err = rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	s = "END    handleSendBlockchain() - SEND-BLOCKCHAIN (SBC)- Sends the blockchain and pendingBlock to another Node"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}

// FROM ROUTINGNODE I/F **************************************************************************************************

// handleBroadcastAddNewNode - BROADCAST-ADD-NEW-NODE (BANN) - Adds a Node to the nodeList
func handleBroadcastAddNewNode(rw *bufio.ReadWriter) {

	s := "START  handleBroadcastAddNewNode() - BROADCAST-ADD-NEW-NODE (BANN) - Adds a Node to the nodeList"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	// SENT - RESPOND - SEND NEW NODE
	s = "Please send The New Node so I can append to my nodeList"
	_, err := rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Please send The New Node so I can append to my nodeList"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - RECEIVING NEW NODE
	messageNewNode, err := rw.ReadString('\n')
	checkErr(err)
	messageNewNode = strings.Trim(messageNewNode, "\n ")
	s = "-H rcvd   - NEW NODE: " + messageNewNode
	log.Info("ROUTINGNODE: HDLR  " + s)

	// APPEND
	//newNode := AppendNewNode(messageNewNode)
	_ = AppendNewNode(messageNewNode)
	//js, _ := json.MarshalIndent(newNode, "", "    ")
	//s = "Appended new Node to the NodeList:\n" + string(js)
	//log.Info("ROUTINGNODE: HDLR            " + s)

	// SENT - RESPOND - Appended new Node to the NodeList
	s = "Appended new Node to the NodeList"
	_, err = rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Appended new Node to the NodeList"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err := rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	s = "END    handleBroadcastAddNewNode() - BROADCAST-ADD-NEW-NODE (BANN) - Adds a Node to the nodeList"
	log.Debug("ROUTINGNODE: HDLR     " + s)

}

// handleSendNodeList - SEND-NODELIST (SNL) - Sends the nodeList to another Node
func handleSendNodeList(rw *bufio.ReadWriter) {

	s := "START  handleSendNodeList() - SEND-NODELIST (SNL) - Sends the nodeList to another Node"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	// GET nodeList
	sendNodeList := GetNodeList()

	// SENT - RESPOND - SEND NODELIST
	js, _ := json.Marshal(sendNodeList)
	s = string(js)
	_, err := rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Sent Nodelist to another node"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err := rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	s = "END    handleSendNodeList() - SEND-NODELIST (SNL) - Sends the nodeList to another Node"
	log.Debug("ROUTINGNODE: HDLR     " + s)

}

// handleBroadcastVerifiedBlock - BROADCAST-VERIFIED-BLOCK (BVB) - A Node verified the next block, get block and verify
func handleBroadcastVerifiedBlock(rw *bufio.ReadWriter) {

	s := "START  handleBroadcastVerifiedBlock() - BROADCAST-VERIFIED-BLOCK (BVB) - A Node verified the next block, get block and verify"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	s = "END   handleBroadcastVerifiedBlock() - BROADCAST-VERIFIED-BLOCK (BVB) - A Node verified the next block, get block and verify"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}

// handleBroadcastConsensus - BROADCAST-CONSENSUS (BC) - 51% Consensus reached, get block to add to blockchain
func handleBroadcastConsensus(rw *bufio.ReadWriter) {

	s := "START  handleBroadcastConsensus() - BROADCAST-CONSENSUS (BC) - 51% Consensus reached, get block to add to blockchain"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	s = "END   handleBroadcastConsensus() - BROADCAST-CONSENSUS (BC) - 51% Consensus reached, get block to add to blockchain"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}

// handleBroadcastTransactionRequest - BROADCAST-TRANSACTION-REQUEST (BTR) - Request from a Node to transfer jeffCoins to a jeffCoin Address
func handleBroadcastTransactionRequest(rw *bufio.ReadWriter) {

	s := "START  handleBroadcastTransactionRequest() - BROADCAST-TRANSACTION-REQUEST (BTR) - Request from a Node to transfer jeffCoins to a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	s = "Please enter the txRequestMessageSigned"
	log.Info("ROUTINGNODE: HDLR            " + s)
	returnMessage(s, rw)

	// RECEIVING - TRANSACTION REQUEST
	txRequestMessageSigned, err := rw.ReadString('\n')
	checkErr(err)
	txRequestMessageSigned = strings.Trim(txRequestMessageSigned, "\n ")
	s = "-H rcvd   - TRANSACTION: " + txRequestMessageSigned
	log.Info("ROUTINGNODE: HDLR   " + s)

	// TRANSACTION REQUEST
	status := blockchain.ProcessTxRequestMessage(txRequestMessageSigned)
	s = "The Status is: " + status
	log.Info("ROUTINGNODE: HDLR            " + s)
	returnMessage(s, rw)

	s = "END   handleBroadcastTransactionRequest() - BROADCAST-TRANSACTION-REQUEST (BTR) - Request from a Node to transfer jeffCoins to a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}

// FROM WALLET I/F *******************************************************************************************************

// handleSendAddressBalance - SEND-ADDRESS-BALANCE (SAB) - Sends the jeffCoin balance for a jeffCoin Address
func handleSendAddressBalance(rw *bufio.ReadWriter) {

	s := "START  handleSendAddressBalance() - SEND-ADDRESS-BALANCE (SAB) - Sends the jeffCoin balance for a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	// SENT - RESPOND - SEND NEW NODE
	s = "Please send the jeffCoinAddress you want the balance for"
	_, err := rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Please send the jeffCoinAddress you want the balance for"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - RECEIVING JEFFCOINADDRESS
	jeffCoinAddress, err := rw.ReadString('\n')
	checkErr(err)
	jeffCoinAddress = strings.Trim(jeffCoinAddress, "\n ")
	s = "-H rcvd   - jeffCoinAddress: " + jeffCoinAddress
	log.Info("ROUTINGNODE: HDLR  " + s)

	// GET ADDRESS BALANCE
	theBalance := blockchain.GetAddressBalance(jeffCoinAddress)

	// SENT - RESPOND - SEND BALANCE
	js, _ := json.Marshal(theBalance)
	s = string(js)
	_, err = rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "The balance for address " + jeffCoinAddress + " is " + theBalance
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err := rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	s = "END    handleSendAddressBalance() - SEND-ADDRESS-BALANCE (SAB) - Sends the jeffCoin balance for a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}

// handleTxRequestMessage - TRANSACTION-REQUEST (TR) - Request from Wallet to transfer jeffCoins to a jeffCoin Address
func handleTxRequestMessage(rw *bufio.ReadWriter) {

	s := "START  handleTxRequestMessage() - TRANSACTION-REQUEST (TR) - Request from Wallet to Transfer jeffCoins to a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)

	// SENT - RESPOND - SEND NEW NODE
	s = "Please send the txRequestMessageSigned"
	_, err := rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Please send the txRequestMessageSigned"
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - RECEIVING TRANSACTION REQUEST
	txRequestMessageSigned, err := rw.ReadString('\n')
	checkErr(err)
	txRequestMessageSigned = strings.Trim(txRequestMessageSigned, "\n ")
	s = "-H rcvd   - TX REQUEST MESSAGE SIGNED: (-loglevel trace to display)"
	log.Info("ROUTINGNODE: HDLR  " + s)
	log.Trace("\n\n" + txRequestMessageSigned + "\n\n")

	// BROADCAST TRANSACTION REQUEST TO ALL NODES
	// ???????????????????????????????????????????????

	// PROCESS TRANSACTION REQUEST MESSAGE
	status := blockchain.ProcessTxRequestMessage(txRequestMessageSigned)
	s = "The Status is: " + status
	log.Info("ROUTINGNODE: HDLR            " + s)

	// SENT - RESPOND - Status of transaction request
	s = "Status of transaction request is " + status
	_, err = rw.WriteString(s + "\n")
	checkErr(err)
	err = rw.Flush()
	checkErr(err)
	s = "Status of transaction request is " + status
	log.Info("ROUTINGNODE: HDLR  -H sent   " + s)

	// RCVD - THANK YOU
	msgThankYou, err := rw.ReadString('\n')
	checkErr(err)
	msgThankYou = strings.Trim(msgThankYou, "\n ")
	s = "-H rcvd   - " + msgThankYou
	log.Info("ROUTINGNODE: HDLR  " + s)

	s = "END    handleTxRequestMessage() - TRANSACTION-REQUEST (TR) - Request from Wallet to Transfer jeffCoins to a jeffCoin Address"
	log.Debug("ROUTINGNODE: HDLR     " + s)
}