Merge pull request #44 from ShyftNetwork/shyft-ring-wallet-connectivity-v0.01

Shyft ring wallet connectivity v0.01

shyftRingWalletConn/app.go

@@ -0,0 +1,140 @@
+package main
+
+//@NOTE SHYFT main func for api, sets up router and spins up a server
+//to run server 'go run shyftRingWalletConn/*.go'
+import (
+  "net"
+  "fmt"
+  "os"
+	//"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/crypto"
+	"bytes"
+	"github.com/ethereum/go-ethereum/common/hexutil"
+)
+
+const (
+	CONN_HOST = "localhost"
+	CONN_PORT = "3333"
+	CONN_TYPE = "tcp"
+)
+
+var testAddrHex = "14791697260E4c9A71f18484C9f997B308e59325"
+var testPrivHex = "0123456789012345678901234567890123456789012345678901234567890123"
+
+// This gives context to the signed message and prevents signing of transactions.
+func signHash(data []byte) []byte {
+	msg := fmt.Sprintf("\x19Ethereum Signed Message:\n%d%s", len(data), data)
+	return crypto.Keccak256([]byte(msg))
+}
+
+func main() {
+
+	l, err := net.Listen(CONN_TYPE, CONN_HOST+":"+CONN_PORT)
+	if err != nil {
+		fmt.Println("Error listening:", err.Error())
+		os.Exit(1)
+	}
+	defer l.Close()
+
+	for {
+		// Listen for an incoming connection.
+		conn, err := l.Accept()
+		if err != nil {
+			fmt.Println("Error accepting: ", err.Error())
+			os.Exit(1)
+		}
+		// Handle connections in a new goroutine.
+		go handleRequest(conn)
+	}
+}
+
+// Handles incoming requests.
+func handleRequest(conn net.Conn) {
+	// Make a buffer to hold incoming data.
+	// Read the incoming connection into the buffer.
+
+	go func() {
+		buf := make([]byte, 1024)
+		msgBuf := make([]byte, 0)
+		var prevMsg []byte
+		var addressOfClient []byte
+		var signatureFromClient []byte
+		var msgFromClient []byte
+
+		for {
+			msg, err := conn.Read(buf)
+
+			if err == nil {
+				msgBuf = append(msgBuf, buf[:msg]...)
+			}
+			index := bytes.IndexByte(msgBuf, 0x0a)
+			for index != -1 {
+				newMsg := msgBuf[:index]
+				rest := msgBuf[(index + 1):len(msgBuf)]
+				msgBuf = rest
+				index = bytes.IndexByte(msgBuf, 0x0a)
+				if prevMsg != nil {
+					s := string(prevMsg[:])
+					if s == "-- ADDRESS --" {
+						addressOfClient = newMsg
+					}
+					if s == "-- SIGNATURE --" {
+						signatureFromClient = newMsg
+					}
+					if s == "-- MESSAGE --" {
+						msgFromClient = newMsg
+					}
+					prevMsg = nil
+				} else {
+					prevMsg = newMsg
+				}
+			}
+
+			if addressOfClient != nil && signatureFromClient != nil && msgFromClient != nil {
+				sig := string(signatureFromClient[:])
+				var sigByteArr, error = hexutil.Decode(sig)
+
+				if error != nil {
+					fmt.Println(error)
+				}
+
+				var sigHex = hexutil.Bytes(sigByteArr)
+				sigHex[64] -= 27
+
+				signedMsgHash := signHash(msgFromClient)
+
+				var rpk, err = crypto.Ecrecover(signedMsgHash, sigHex)
+				if err != nil {
+					fmt.Println(err)
+				}
+
+				pubKey := crypto.ToECDSAPub(rpk)
+				recoveredAddr := crypto.PubkeyToAddress(*pubKey)
+				fmt.Println("ADDRESS IS ::", recoveredAddr.Hex())
+			}
+		}
+	}()
+	go func() {
+		key, _ := crypto.HexToECDSA(testPrivHex)
+
+		f_msg := "Hello World"
+		first_message := []byte(f_msg)
+		new_msg2 := crypto.Keccak256(first_message)
+		fmt.Println("HASH IS ::", hexutil.Encode(new_msg2))
+
+		//send_message := append(new_msg2, []byte{byte(10)}...)
+		new_sig , err := crypto.Sign(new_msg2, key)
+		if err != nil {
+			fmt.Println("The crypto.Sign err is ", err)
+		}
+		hex_sig := hexutil.Encode(new_sig)
+		fmt.Println("HEX SIG ::", hex_sig)
+
+		conn.Write([]byte("Broadcasting Message"))
+		conn.Write([]byte("\n"))
+		conn.Write([]byte(f_msg))
+		conn.Write([]byte("\n"))
+		conn.Write(new_sig)
+		conn.Write([]byte("\n"))
+	}()
+}