A3.go

package assignment03IBC

import (
	"crypto/sha256"
	"fmt"
	"encoding/gob"
	"net"
	a2 "github.com/rafshamazhar/assignment02IBC"
)
var Quorum int
var chainHead *a2.Block
var storeMap = make(map[string]net.Conn)

func handleConnection(c net.Conn, node string, listeningAddress string){
	if node=="satoshi" {
		//store connection&address
		//receive listening port on c first
		storemap[listeningAddress]=c

		//mine new block
		chainHead = a2.InsertBlock("", "", "Satoshi", 0, chainHead)

		//print address
		log.Println("Satoshi: Client connected at ". c.RemoteAddr())

	} else if node == "others" {
		//others: satoshi->net.conn 
		//which port node is listening to, msg recieve and print
		//read and print msg
		log.Println("Others: Client connected at ". c.RemoteAddr())
	}
}

func StartListening(listeningAddress string, node string) {
	ln, err:= net.Listen("tcp", listeningAddress)
	if err!=nil{
		log.Fatal(err)
	}
	for {
		conn, err:=ln.Accept()
		if err!=nil{
			log.Println(err)
			continue
		}
		go handleConnection(conn, node, listeningAddress)  //storage if satoshi, only print if others
	}
}


//WaitForQuorum()
func WaitForQuorum() {
	if len(storeMap<Quorum){
		//block
	}
}


func SendChainandConnInfo() {

	//blockchain using gob
	next:=""
	for key, val := range storeMap {
		blockchainEnc := gob.NewEncoder(val) //loop through all c conn
		err:= blockchainEnc.Encode(chainHead)
		if err != nil {
			log.Fatal("encode error:", err)
		}
		
		//connection topology
		val <- next
		next=key
	}
	for key, val := range storeMap {
		val<-next
		break
	}
}


func ReceiveChain(connection net.Conn) *Block {

	blockchainDec := gob.NewDecoder(&connection)
	var mychain *Block
	err := blockchainDec.Decode(&mychain)
	if err!=nil{
		log.Fatal("decode error", err)
	}
	return mychain
}


func WriteString(connection net.Conn, listeningAddress string) {
	connection <- listeningAddress
}


func ReadString(connection net.Conn) string {
	buffer:=make([]byte, 4096)
	buffer = <-connection
	return string(buffer)
	}
}