aboutsummaryrefslogtreecommitdiffstats
path: root/ethpipe/js_pipe.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-10-31 21:30:08 +0800
committerobscuren <geffobscura@gmail.com>2014-10-31 21:30:08 +0800
commit0ed1a8b50a9b9726cd57a2731d0405f6949c6188 (patch)
tree9f877ecdc89b784cd2820db8ca3f1de6e9c4d3e9 /ethpipe/js_pipe.go
parent8826e9694c3a8d4f480f0a021d8c02f7f61612c6 (diff)
downloadgo-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar.gz
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar.bz2
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar.lz
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar.xz
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.tar.zst
go-tangerine-0ed1a8b50a9b9726cd57a2731d0405f6949c6188.zip
ethpipe => xeth (eXtended ETHereum)
Diffstat (limited to 'ethpipe/js_pipe.go')
-rw-r--r--ethpipe/js_pipe.go264
1 files changed, 0 insertions, 264 deletions
diff --git a/ethpipe/js_pipe.go b/ethpipe/js_pipe.go
deleted file mode 100644
index eb365f007..000000000
--- a/ethpipe/js_pipe.go
+++ /dev/null
@@ -1,264 +0,0 @@
-package ethpipe
-
-import (
- "bytes"
- "encoding/json"
- "sync/atomic"
-
- "github.com/ethereum/go-ethereum/chain"
- "github.com/ethereum/go-ethereum/crypto"
- "github.com/ethereum/go-ethereum/ethstate"
- "github.com/ethereum/go-ethereum/ethutil"
-)
-
-type JSPipe struct {
- *Pipe
-}
-
-func NewJSPipe(eth chain.EthManager) *JSPipe {
- return &JSPipe{New(eth)}
-}
-
-func (self *JSPipe) BlockByHash(strHash string) *JSBlock {
- hash := ethutil.Hex2Bytes(strHash)
- block := self.obj.ChainManager().GetBlock(hash)
-
- return NewJSBlock(block)
-}
-
-func (self *JSPipe) BlockByNumber(num int32) *JSBlock {
- if num == -1 {
- return NewJSBlock(self.obj.ChainManager().CurrentBlock)
- }
-
- return NewJSBlock(self.obj.ChainManager().GetBlockByNumber(uint64(num)))
-}
-
-func (self *JSPipe) Block(v interface{}) *JSBlock {
- if n, ok := v.(int32); ok {
- return self.BlockByNumber(n)
- } else if str, ok := v.(string); ok {
- return self.BlockByHash(str)
- } else if f, ok := v.(float64); ok { // Don't ask ...
- return self.BlockByNumber(int32(f))
- }
-
- return nil
-}
-
-func (self *JSPipe) Key() *JSKey {
- return NewJSKey(self.obj.KeyManager().KeyPair())
-}
-
-func (self *JSPipe) StateObject(addr string) *JSObject {
- object := &Object{self.World().safeGet(ethutil.Hex2Bytes(addr))}
-
- return NewJSObject(object)
-}
-
-func (self *JSPipe) PeerCount() int {
- return self.obj.PeerCount()
-}
-
-func (self *JSPipe) Peers() []JSPeer {
- var peers []JSPeer
- for peer := self.obj.Peers().Front(); peer != nil; peer = peer.Next() {
- p := peer.Value.(chain.Peer)
- // we only want connected peers
- if atomic.LoadInt32(p.Connected()) != 0 {
- peers = append(peers, *NewJSPeer(p))
- }
- }
-
- return peers
-}
-
-func (self *JSPipe) IsMining() bool {
- return self.obj.IsMining()
-}
-
-func (self *JSPipe) IsListening() bool {
- return self.obj.IsListening()
-}
-
-func (self *JSPipe) CoinBase() string {
- return ethutil.Bytes2Hex(self.obj.KeyManager().Address())
-}
-
-func (self *JSPipe) NumberToHuman(balance string) string {
- b := ethutil.Big(balance)
-
- return ethutil.CurrencyToString(b)
-}
-
-func (self *JSPipe) StorageAt(addr, storageAddr string) string {
- storage := self.World().SafeGet(ethutil.Hex2Bytes(addr)).Storage(ethutil.Hex2Bytes(storageAddr))
-
- return ethutil.Bytes2Hex(storage.Bytes())
-}
-
-func (self *JSPipe) BalanceAt(addr string) string {
- return self.World().SafeGet(ethutil.Hex2Bytes(addr)).Balance().String()
-}
-
-func (self *JSPipe) TxCountAt(address string) int {
- return int(self.World().SafeGet(ethutil.Hex2Bytes(address)).Nonce)
-}
-
-func (self *JSPipe) CodeAt(address string) string {
- return ethutil.Bytes2Hex(self.World().SafeGet(ethutil.Hex2Bytes(address)).Code)
-}
-
-func (self *JSPipe) IsContract(address string) bool {
- return len(self.World().SafeGet(ethutil.Hex2Bytes(address)).Code) > 0
-}
-
-func (self *JSPipe) SecretToAddress(key string) string {
- pair, err := crypto.NewKeyPairFromSec(ethutil.Hex2Bytes(key))
- if err != nil {
- return ""
- }
-
- return ethutil.Bytes2Hex(pair.Address())
-}
-
-func (self *JSPipe) Execute(addr, value, gas, price, data string) (string, error) {
- ret, err := self.ExecuteObject(&Object{
- self.World().safeGet(ethutil.Hex2Bytes(addr))},
- ethutil.Hex2Bytes(data),
- ethutil.NewValue(value),
- ethutil.NewValue(gas),
- ethutil.NewValue(price),
- )
-
- return ethutil.Bytes2Hex(ret), err
-}
-
-type KeyVal struct {
- Key string `json:"key"`
- Value string `json:"value"`
-}
-
-func (self *JSPipe) EachStorage(addr string) string {
- var values []KeyVal
- object := self.World().SafeGet(ethutil.Hex2Bytes(addr))
- object.EachStorage(func(name string, value *ethutil.Value) {
- value.Decode()
- values = append(values, KeyVal{ethutil.Bytes2Hex([]byte(name)), ethutil.Bytes2Hex(value.Bytes())})
- })
-
- valuesJson, err := json.Marshal(values)
- if err != nil {
- return ""
- }
-
- return string(valuesJson)
-}
-
-func (self *JSPipe) ToAscii(str string) string {
- padded := ethutil.RightPadBytes([]byte(str), 32)
-
- return "0x" + ethutil.Bytes2Hex(padded)
-}
-
-func (self *JSPipe) FromAscii(str string) string {
- if ethutil.IsHex(str) {
- str = str[2:]
- }
-
- return string(bytes.Trim(ethutil.Hex2Bytes(str), "\x00"))
-}
-
-func (self *JSPipe) FromNumber(str string) string {
- if ethutil.IsHex(str) {
- str = str[2:]
- }
-
- return ethutil.BigD(ethutil.Hex2Bytes(str)).String()
-}
-
-func (self *JSPipe) Transact(key, toStr, valueStr, gasStr, gasPriceStr, codeStr string) (*JSReceipt, error) {
- var hash []byte
- var contractCreation bool
- if len(toStr) == 0 {
- contractCreation = true
- } else {
- // Check if an address is stored by this address
- addr := self.World().Config().Get("NameReg").StorageString(toStr).Bytes()
- if len(addr) > 0 {
- hash = addr
- } else {
- hash = ethutil.Hex2Bytes(toStr)
- }
- }
-
- var keyPair *crypto.KeyPair
- var err error
- if ethutil.IsHex(key) {
- keyPair, err = crypto.NewKeyPairFromSec([]byte(ethutil.Hex2Bytes(key[2:])))
- } else {
- keyPair, err = crypto.NewKeyPairFromSec([]byte(ethutil.Hex2Bytes(key)))
- }
-
- if err != nil {
- return nil, err
- }
-
- var (
- value = ethutil.Big(valueStr)
- gas = ethutil.Big(gasStr)
- gasPrice = ethutil.Big(gasPriceStr)
- data []byte
- tx *chain.Transaction
- )
-
- if ethutil.IsHex(codeStr) {
- data = ethutil.Hex2Bytes(codeStr[2:])
- } else {
- data = ethutil.Hex2Bytes(codeStr)
- }
-
- if contractCreation {
- tx = chain.NewContractCreationTx(value, gas, gasPrice, data)
- } else {
- tx = chain.NewTransactionMessage(hash, value, gas, gasPrice, data)
- }
-
- acc := self.obj.StateManager().TransState().GetOrNewStateObject(keyPair.Address())
- tx.Nonce = acc.Nonce
- acc.Nonce += 1
- self.obj.StateManager().TransState().UpdateStateObject(acc)
-
- tx.Sign(keyPair.PrivateKey)
- self.obj.TxPool().QueueTransaction(tx)
-
- if contractCreation {
- pipelogger.Infof("Contract addr %x", tx.CreationAddress(self.World().State()))
- }
-
- return NewJSReciept(contractCreation, tx.CreationAddress(self.World().State()), tx.Hash(), keyPair.Address()), nil
-}
-
-func (self *JSPipe) PushTx(txStr string) (*JSReceipt, error) {
- tx := chain.NewTransactionFromBytes(ethutil.Hex2Bytes(txStr))
- self.obj.TxPool().QueueTransaction(tx)
- return NewJSReciept(tx.CreatesContract(), tx.CreationAddress(self.World().State()), tx.Hash(), tx.Sender()), nil
-}
-
-func (self *JSPipe) CompileMutan(code string) string {
- data, err := self.Pipe.CompileMutan(code)
- if err != nil {
- return err.Error()
- }
-
- return ethutil.Bytes2Hex(data)
-}
-
-func ToJSMessages(messages ethstate.Messages) *ethutil.List {
- var msgs []JSMessage
- for _, m := range messages {
- msgs = append(msgs, NewJSMessage(m))
- }
-
- return ethutil.NewList(msgs)
-}
generated by cgit v1.2.3 (git 2.25.1) at 2025-03-14 21:37:48 +0800