File size: 2,631 Bytes
7107f0b |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 |
package rpc
import (
"context"
"testing"
"time"
)
func TestHTTPAll(t *testing.T) {
const targetURL = "https://nodejs.org/dist/index.json"
rpc, err := New(context.Background(), "http://localhost:6800/jsonrpc", "", time.Second, &DummyNotifier{})
if err != nil {
t.Fatal(err)
}
defer rpc.Close()
g, err := rpc.AddURI([]string{targetURL})
if err != nil {
t.Fatal(err)
}
println(g)
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
if _, err = rpc.PauseAll(); err != nil {
t.Error(err)
}
if _, err = rpc.TellStatus(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetURIs(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetFiles(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetPeers(g); err != nil {
t.Error(err)
}
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
if _, err = rpc.TellWaiting(0, 1); err != nil {
t.Error(err)
}
if _, err = rpc.TellStopped(0, 1); err != nil {
t.Error(err)
}
if _, err = rpc.GetOption(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetGlobalOption(); err != nil {
t.Error(err)
}
if _, err = rpc.GetGlobalStat(); err != nil {
t.Error(err)
}
if _, err = rpc.GetSessionInfo(); err != nil {
t.Error(err)
}
if _, err = rpc.Remove(g); err != nil {
t.Error(err)
}
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
}
func TestWebsocketAll(t *testing.T) {
const targetURL = "https://nodejs.org/dist/index.json"
rpc, err := New(context.Background(), "ws://localhost:6800/jsonrpc", "", time.Second, &DummyNotifier{})
if err != nil {
t.Fatal(err)
}
defer rpc.Close()
g, err := rpc.AddURI([]string{targetURL})
if err != nil {
t.Fatal(err)
}
println(g)
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
if _, err = rpc.PauseAll(); err != nil {
t.Error(err)
}
if _, err = rpc.TellStatus(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetURIs(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetFiles(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetPeers(g); err != nil {
t.Error(err)
}
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
if _, err = rpc.TellWaiting(0, 1); err != nil {
t.Error(err)
}
if _, err = rpc.TellStopped(0, 1); err != nil {
t.Error(err)
}
if _, err = rpc.GetOption(g); err != nil {
t.Error(err)
}
if _, err = rpc.GetGlobalOption(); err != nil {
t.Error(err)
}
if _, err = rpc.GetGlobalStat(); err != nil {
t.Error(err)
}
if _, err = rpc.GetSessionInfo(); err != nil {
t.Error(err)
}
if _, err = rpc.Remove(g); err != nil {
t.Error(err)
}
if _, err = rpc.TellActive(); err != nil {
t.Error(err)
}
}
|