Temporary patch to 'Unsupported event'

log.go

@@ -129,6 +129,7 @@ func (c *CollapseResultsLogger) Log(results *collapseResults) {
 func (c *CollapseResultsLogger) addTx(mod, event []byte,
 	timestamp time.Time, tag int,
 	txID []byte, sender []byte, logError error) {
+
 	o := c.arena.NewObject()
 
 	o.Set("mod", c.arena.NewStringBytes(mod))

wctl/wctl.go

@@ -120,6 +120,7 @@ type Client struct {
 	// PollTransactions
 	OnTxApplied
 	OnTxGossipError
+	OnTxRejected
 	OnTxFailed
 
 	OnMetrics

wctl/ws_callbacks.go

@@ -112,6 +112,15 @@ type (
 	}
 	OnTxApplied = func(TxApplied)
 
+	TxRejected struct {
+		TxID     [32]byte  `json:"tx_id"`
+		SenderID [32]byte  `json:"sender_id"`
+		Tag      byte      `json:"tag"`
+		Error    string    `json:"error,omitempty"`
+		Time     time.Time `json:"time"`
+	}
+	OnTxRejected = func(TxRejected)
+
 	TxGossipError struct {
 		Error   string    `json:"error"`
 		Time    time.Time `json:"time"`

wctl/ws_tx.go

@@ -25,6 +25,8 @@ func (c *Client) PollTransactions() (func(), error) {
 				err = parseTxGossipError(c, o)
 			case ev == "failed":
 				err = parseTxFailed(c, o)
+			case ev == "rejected":
+				err = parseTxRejected(c, o)
 			default:
 				err = errInvalidEvent(o, ev)
 			}
@@ -81,6 +83,31 @@ func parseTxGossipError(c *Client, v *fastjson.Value) error {
 	return nil
 }
 
+func parseTxRejected(c *Client, v *fastjson.Value) error {
+	var t TxRejected
+
+	if err := jsonHex(v, t.TxID[:], "tx_id"); err != nil {
+		return err
+	}
+
+	if err := jsonHex(v, t.SenderID[:], "sender_id"); err != nil {
+		return err
+	}
+
+	t.Tag = byte(v.GetUint("tag"))
+	t.Error = jsonString(v, "error")
+
+	if err := jsonTime(v, &t.Time, "time"); err != nil {
+		return err
+	}
+
+	if c.OnTxRejected != nil {
+		c.OnTxRejected(t)
+	}
+
+	return nil
+}
+
 func parseTxFailed(c *Client, v *fastjson.Value) error {
 	var t TxFailed