aboutsummaryrefslogtreecommitdiffstats
path: root/utils/websockets.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-10-31 21:20:11 +0800
committerobscuren <geffobscura@gmail.com>2014-10-31 21:20:11 +0800
commit8826e9694c3a8d4f480f0a021d8c02f7f61612c6 (patch)
tree0c628ab800a0f701d0ae9adf5026c3d8a503232e /utils/websockets.go
parentb1c247231b11f313ca0eedff75ea563926d23f68 (diff)
downloadgo-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.go161
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
-}