test

clightning/clightning.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/rand"
 	"encoding/hex"
+	"encoding/json"
 	"errors"
 	"fmt"
 	log2 "log"
@@ -426,12 +427,32 @@ func (cl *ClightningClient) OnRPCCommand(event *glightning.RpcCommandEvent) (*gl
 		ok, err := cl.liquidWallet.Ping()
 		if err != nil || !ok {
 			log.Infof("trying to send command %s, but failed to connect: %v", event.Cmd.MethodName, err)
-			return event.ReturnError("liquid_unavailable", -1)
+			return cl.ReturnError("liquid_unavailable", -1)
 		}
 	}
 	return event.Continue(), nil
 }
 
+func (cl *ClightningClient) ReturnError(errMsg string, errCode int) (*glightning.RpcCommandResponse, error) {
+	type ErrResp struct {
+		Message string `json:"message"`
+		Code    int    `json:"code"`
+	}
+	result := &struct {
+		Result ErrResp `json:"error"`
+	}{
+		Result: ErrResp{errMsg, errCode},
+	}
+	marshaled, err := json.Marshal(result)
+	if err != nil {
+		return nil, err
+	}
+	marshaled = append(marshaled, []byte("\n\n")...)
+	return &glightning.RpcCommandResponse{
+		ReturnObj: marshaled,
+	}, nil
+}
+
 // AddMessageHandler adds a listener for incoming peermessages
 func (cl *ClightningClient) AddMessageHandler(f func(peerId string, msgType string, payload []byte) error) {
 	cl.msgHandlers = append(cl.msgHandlers, f)