57 lines
		
	
	
		
			1.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			57 lines
		
	
	
		
			1.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| package rpc
 | |
| 
 | |
| import (
 | |
| 	"encoding/json"
 | |
| 	// "sync"
 | |
| 	"testing"
 | |
| 	// "time"
 | |
| )
 | |
| 
 | |
| func TestWeb3Sha3(t *testing.T) {
 | |
| 	jsonstr := `{"jsonrpc":"2.0","method":"web3_sha3","params":["0x68656c6c6f20776f726c64"],"id":64}`
 | |
| 	expected := "0x47173285a8d7341e5e972fc677286384f802f8ef42a5ec5f03bbfa254cb01fad"
 | |
| 
 | |
| 	api := &EthereumApi{}
 | |
| 
 | |
| 	var req RpcRequest
 | |
| 	json.Unmarshal([]byte(jsonstr), &req)
 | |
| 
 | |
| 	var response interface{}
 | |
| 	_ = api.GetRequestReply(&req, &response)
 | |
| 
 | |
| 	if response.(string) != expected {
 | |
| 		t.Errorf("Expected %s got %s", expected, response)
 | |
| 	}
 | |
| }
 | |
| 
 | |
| // func TestFilterClose(t *testing.T) {
 | |
| // 	t.Skip()
 | |
| // 	api := &EthereumApi{
 | |
| // 		logs:     make(map[int]*logFilter),
 | |
| // 		messages: make(map[int]*whisperFilter),
 | |
| // 		quit:     make(chan struct{}),
 | |
| // 	}
 | |
| 
 | |
| // 	filterTickerTime = 1
 | |
| // 	api.logs[0] = &logFilter{}
 | |
| // 	api.messages[0] = &whisperFilter{}
 | |
| // 	var wg sync.WaitGroup
 | |
| // 	wg.Add(1)
 | |
| // 	go api.start()
 | |
| // 	go func() {
 | |
| // 		select {
 | |
| // 		case <-time.After(500 * time.Millisecond):
 | |
| // 			api.stop()
 | |
| // 			wg.Done()
 | |
| // 		}
 | |
| // 	}()
 | |
| // 	wg.Wait()
 | |
| // 	if len(api.logs) != 0 {
 | |
| // 		t.Error("expected logs to be empty")
 | |
| // 	}
 | |
| 
 | |
| // 	if len(api.messages) != 0 {
 | |
| // 		t.Error("expected messages to be empty")
 | |
| // 	}
 | |
| // }
 |