From f6fee7e70ae788163416076b3f78d46eb7fa3948 Mon Sep 17 00:00:00 2001 From: Dustin Brickwood Date: Mon, 16 Jul 2018 16:22:43 -0400 Subject: [PATCH] cleaned up code and removed msg type --- shyftRingWalletConn/app.go | 82 +++++--------------------------------- 1 file changed, 9 insertions(+), 73 deletions(-) diff --git a/shyftRingWalletConn/app.go b/shyftRingWalletConn/app.go index 3ff6175115..0da4d787e3 100644 --- a/shyftRingWalletConn/app.go +++ b/shyftRingWalletConn/app.go @@ -12,13 +12,6 @@ import ( "github.com/ethereum/go-ethereum/common/hexutil" ) -type Msg struct { - Message string `json:"message"` - HashedMessage string `json:"hashed_message"` - Signature string `json:"signature"` - Address string `json:"address"` -} - const ( CONN_HOST = "localhost" CONN_PORT = "3333" @@ -69,18 +62,10 @@ func handleRequest(conn net.Conn) { var msgFromClient []byte for { - //var addressOfClient []byte - //var msgFromClient []byte - //var sigFromClient []byte msg, err := conn.Read(buf) if err == nil { - fmt.Println("Message is ", buf[:msg]) - fmt.Println("The old msg buf is ", msgBuf) msgBuf = append(msgBuf, buf[:msg]...) - fmt.Println("THE msgBuf is ") - fmt.Println(msgBuf) - //fmt.Println("Message is ", string(buf[:msg])) } index := bytes.IndexByte(msgBuf, 0x0a) for index != -1 { @@ -88,17 +73,9 @@ func handleRequest(conn net.Conn) { rest := msgBuf[(index + 1):len(msgBuf)] msgBuf = rest index = bytes.IndexByte(msgBuf, 0x0a) - fmt.Println("new msg") - fmt.Println(newMsg) - fmt.Println(string(newMsg[:])) - fmt.Println("prev message ", prevMsg) - fmt.Println((prevMsg == nil)) if prevMsg != nil { - fmt.Println("not nil") s := string(prevMsg[:]) if s == "-- ADDRESS --" { - fmt.Println("the address should be ") - fmt.Println(newMsg) addressOfClient = newMsg } if s == "-- SIGNATURE --" { @@ -109,67 +86,41 @@ func handleRequest(conn net.Conn) { } prevMsg = nil } else { - fmt.Println("nil") prevMsg = newMsg - fmt.Println("prev message is in else block ", prevMsg) - fmt.Println("index ", index) - fmt.Println("msgBuf ", msgBuf) - fmt.Println(bytes.IndexByte(msgBuf, 0x0a)) - } } - if(addressOfClient != nil && signatureFromClient != nil && msgFromClient != nil ){ - fmt.Println("ALL COMPONENTS RECEIVED") - msg := string(msgFromClient[:]) - //new_msg := signHash(msgFromClient) + if addressOfClient != nil && signatureFromClient != nil && msgFromClient != nil { sig := string(signatureFromClient[:]) - addr := string(addressOfClient[:]) - fmt.Println(addr) - fmt.Println(msg) - fmt.Println(sig) + var sigByteArr, error = hexutil.Decode(sig) - var msgByteArr = []byte(msg) - var hexMsg = hexutil.Encode(msgByteArr) - fizz, err2 := hexutil.Decode(hexMsg) - - var sigByteArr, err3 = hexutil.Decode(sig) - if err2 != nil { - fmt.Println("the err2 is ") - fmt.Println(err2) - } - if err3 != nil { - fmt.Println("the err3 is ") - fmt.Println(err3) + if error != nil { + fmt.Println(error) } var sigHex = hexutil.Bytes(sigByteArr) sigHex[64] -= 27 - signedMsgHash := signHash(fizz) + signedMsgHash := signHash(msgFromClient) var rpk, err = crypto.Ecrecover(signedMsgHash, sigHex) if err != nil { - fmt.Println("The error is ") fmt.Println(err) } pubKey := crypto.ToECDSAPub(rpk) recoveredAddr := crypto.PubkeyToAddress(*pubKey) - fmt.Println("the address is ") - //fmt.Println(recoveredAddr) - fmt.Println(recoveredAddr.Hex()) + fmt.Println("ADDRESS IS ::", recoveredAddr.Hex()) } } }() go func() { key, _ := crypto.HexToECDSA(testPrivHex) - //addr := common.HexToAddress(testAddrHex) f_msg := "Hello World" first_message := []byte(f_msg) new_msg2 := crypto.Keccak256(first_message) - fmt.Println("the hash is ", hexutil.Encode(new_msg2)) + fmt.Println("HASH IS ::", hexutil.Encode(new_msg2)) //send_message := append(new_msg2, []byte{byte(10)}...) new_sig , err := crypto.Sign(new_msg2, key) @@ -177,7 +128,7 @@ func handleRequest(conn net.Conn) { fmt.Println("The crypto.Sign err is ", err) } hex_sig := hexutil.Encode(new_sig) - fmt.Println("THE hex sig is ", hex_sig) + fmt.Println("HEX SIG ::", hex_sig) conn.Write([]byte("Broadcasting Message")) conn.Write([]byte("\n")) @@ -186,19 +137,4 @@ func handleRequest(conn net.Conn) { conn.Write(new_sig) conn.Write([]byte("\n")) }() - //conn.Write([]byte{byte(0x0f)}) - - // Send a response back to person contacting us. - - // Close the connection when you're done with it. - //conn.Close() -} - -func intArrToByteArr(foo []int) []byte { - - ret := []byte{} - for _, value := range foo { - ret = append(ret, byte(value)) - } - return ret -} +} \ No newline at end of file