mleku/realy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed query bug... opa

Browse Source
This commit is contained in:
mleku
2024-10-25 19:58:18 +01:00
parent 1958658ecb
commit 641aa05dae
36 changed files with 211 additions and 131 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ws/client_test.go
View File

@@ -52,7 +52,7 @@ func TestPublish(t *testing.T) {
mu.Unlock()
// verify the client sent exactly the textNote
var raw []json.RawMessage
if err := websocket.JSON.Receive(conn, &raw); err != nil {
if err := websocket.JSON.Receive(conn, &raw); chk.T(err) {
t.Errorf("websocket.JSON.Receive: %v", err)
}
@@ -76,7 +76,7 @@ func TestPublish(t *testing.T) {
if res, err = okenvelope.NewFrom(eid.Bytes(), true, nil).MarshalJSON(res); chk.E(err) {
t.Fatal(err)
}
if err := websocket.Message.Send(conn, res); err != nil {
if err := websocket.Message.Send(conn, res); chk.T(err) {
t.Errorf("websocket.JSON.Send: %v", err)
}
})
@@ -112,7 +112,7 @@ func TestPublishBlocked(t *testing.T) {
ws := newWebsocketServer(func(conn *websocket.Conn) {
// discard received message; not interested
var raw []json.RawMessage
if err := websocket.JSON.Receive(conn, &raw); err != nil {
if err := websocket.JSON.Receive(conn, &raw); chk.T(err) {
t.Errorf("websocket.JSON.Receive: %v", err)
}
// send back a not ok nip-20 command result
@@ -125,7 +125,7 @@ func TestPublishBlocked(t *testing.T) {
normalize.Msg(normalize.Blocked, "no reason")).MarshalJSON(res); chk.E(err) {
t.Fatal(err)
}
if err := websocket.Message.Send(conn, res); err != nil {
if err := websocket.Message.Send(conn, res); chk.T(err) {
t.Errorf("websocket.JSON.Send: %v", err)
}
// res := []any{"OK", textNote.ID, false, "blocked"}