diff options
author | obscuren <geffobscura@gmail.com> | 2014-10-31 21:20:11 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-10-31 21:20:11 +0800 |
commit | 8826e9694c3a8d4f480f0a021d8c02f7f61612c6 (patch) | |
tree | 0c628ab800a0f701d0ae9adf5026c3d8a503232e /utils/websockets.go | |
parent | b1c247231b11f313ca0eedff75ea563926d23f68 (diff) | |
download | go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar.gz go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar.bz2 go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar.lz go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar.xz go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.tar.zst go-tangerine-8826e9694c3a8d4f480f0a021d8c02f7f61612c6.zip |
Moved utils to cmd
Diffstat (limited to 'utils/websockets.go')
-rw-r--r-- | utils/websockets.go | 161 |
1 files changed, 0 insertions, 161 deletions
diff --git a/utils/websockets.go b/utils/websockets.go deleted file mode 100644 index 7bda805ac..000000000 --- a/utils/websockets.go +++ /dev/null @@ -1,161 +0,0 @@ -package utils - -import ( - "github.com/ethereum/go-ethereum" - "github.com/ethereum/go-ethereum/ethpipe" - "github.com/ethereum/go-ethereum/ethutil" - "github.com/ethereum/go-ethereum/websocket" -) - -func args(v ...interface{}) []interface{} { - return v -} - -type WebSocketServer struct { - ethereum *eth.Ethereum - filterCallbacks map[int][]int -} - -func NewWebSocketServer(eth *eth.Ethereum) *WebSocketServer { - return &WebSocketServer{eth, make(map[int][]int)} -} - -func (self *WebSocketServer) Serv() { - pipe := ethpipe.NewJSPipe(self.ethereum) - - wsServ := websocket.NewServer("/eth", ":40404") - wsServ.MessageFunc(func(c *websocket.Client, msg *websocket.Message) { - switch msg.Call { - case "compile": - data := ethutil.NewValue(msg.Args) - bcode, err := ethutil.Compile(data.Get(0).Str(), false) - if err != nil { - c.Write(args(nil, err.Error()), msg.Seed) - } - - code := ethutil.Bytes2Hex(bcode) - c.Write(args(code, nil), msg.Seed) - case "getBlockByNumber": - args := msg.Arguments() - - block := pipe.BlockByNumber(int32(args.Get(0).Uint())) - c.Write(block, msg.Seed) - - case "getKey": - c.Write(pipe.Key().PrivateKey, msg.Seed) - case "transact": - if mp, ok := msg.Args[0].(map[string]interface{}); ok { - object := mapToTxParams(mp) - c.Write( - args(pipe.Transact(object["from"], object["to"], object["value"], object["gas"], object["gasPrice"], object["data"])), - msg.Seed, - ) - - } - case "getCoinBase": - c.Write(pipe.CoinBase(), msg.Seed) - - case "getIsListening": - c.Write(pipe.IsListening(), msg.Seed) - - case "getIsMining": - c.Write(pipe.IsMining(), msg.Seed) - - case "getPeerCoint": - c.Write(pipe.PeerCount(), msg.Seed) - - case "getCountAt": - args := msg.Arguments() - - c.Write(pipe.TxCountAt(args.Get(0).Str()), msg.Seed) - - case "getCodeAt": - args := msg.Arguments() - - c.Write(len(pipe.CodeAt(args.Get(0).Str())), msg.Seed) - - case "getBlockByHash": - args := msg.Arguments() - - c.Write(pipe.BlockByHash(args.Get(0).Str()), msg.Seed) - - case "getStorageAt": - args := msg.Arguments() - - c.Write(pipe.StorageAt(args.Get(0).Str(), args.Get(1).Str()), msg.Seed) - - case "getBalanceAt": - args := msg.Arguments() - - c.Write(pipe.BalanceAt(args.Get(0).Str()), msg.Seed) - - case "getSecretToAddress": - args := msg.Arguments() - - c.Write(pipe.SecretToAddress(args.Get(0).Str()), msg.Seed) - - case "newFilter": - case "newFilterString": - case "messages": - // TODO - } - - }) - - wsServ.Listen() -} - -func StartWebSockets(eth *eth.Ethereum) { - sock := NewWebSocketServer(eth) - go sock.Serv() -} - -// TODO This is starting to become a generic method. Move to utils -func mapToTxParams(object map[string]interface{}) map[string]string { - // Default values - if object["from"] == nil { - object["from"] = "" - } - if object["to"] == nil { - object["to"] = "" - } - if object["value"] == nil { - object["value"] = "" - } - if object["gas"] == nil { - object["gas"] = "" - } - if object["gasPrice"] == nil { - object["gasPrice"] = "" - } - - var dataStr string - var data []string - if str, ok := object["data"].(string); ok { - data = []string{str} - } - - for _, str := range data { - if ethutil.IsHex(str) { - str = str[2:] - - if len(str) != 64 { - str = ethutil.LeftPadString(str, 64) - } - } else { - str = ethutil.Bytes2Hex(ethutil.LeftPadBytes(ethutil.Big(str).Bytes(), 32)) - } - - dataStr += str - } - object["data"] = dataStr - - conv := make(map[string]string) - for key, value := range object { - if v, ok := value.(string); ok { - conv[key] = v - } - } - - return conv -} |