add unlisten

README.md

@@ -13,8 +13,8 @@ Websocket consumer for the https://dfuse.io API on EOS networks.
 	ga.ReqID = "get-accounts-jsons"
 	ga.StartBlock = -5000
 	ga.Listen = true
-	ga.Data.Account = "accountsjson"
-	ga.Data.ActionName = "set"
+	ga.Data.Accounts = "accountsjson"
+	ga.Data.ActionNames = "set"
 
 	fmt.Println("Sending `get_actions` message")
 	err = client.Send(ga)

actions.go

@@ -13,8 +13,11 @@ type GetActionTraces struct {
 	CommonOut
 
 	Data struct {
+		Receivers        string `json:"receivers,omitempty"`
+		Accounts         string `json:"accounts"`
+		ActionNames      string `json:"action_names,omitempty"`
 		Receiver         string `json:"receiver,omitempty"`
-		Account          string `json:"account"`
+		Account          string `json:"account,omitempty"`
 		ActionName       string `json:"action_name,omitempty"`
 		WithDBOps        bool   `json:"with_dbops"`
 		WithRAMOps       bool   `json:"with_ramops"`

examples/actionload/main.go

@@ -28,8 +28,8 @@ func main() {
 			ga.StartBlock = -10
 			ga.Listen = true
 			ga.WithProgress = 5
-			ga.Data.Account = "eosio.token"
-			ga.Data.ActionName = "transfer"
+			ga.Data.Accounts = "eosio.token"
+			ga.Data.ActionNames = "transfer"
 			ga.Data.WithInlineTraces = true
 
 			fmt.Println("Sending `get_actions` message")

message_test.go

@@ -18,8 +18,8 @@ func Test_GetActions(t *testing.T) {
 	ga.ReqID = "1"
 	ga.StartBlock = -10
 	ga.Listen = true
-	ga.Data.Account = "eosio.token"
-	ga.Data.ActionName = "transfer"
+	ga.Data.Accounts = "eosio.token"
+	ga.Data.ActionNames = "transfer"
 	ga.Data.WithInlineTraces = true
 
 	client.Send(ga)

unlisten.go

@@ -0,0 +1,20 @@
+package eosws
+
+func init() {
+	RegisterOutgoingMessage("unlisten", Unlisten{})
+	RegisterIncomingMessage("unlistened", Unlistened{})
+}
+
+type Unlisten struct {
+	CommonOut
+	Data struct {
+		ReqID string `json:"req_id"`
+	} `json:"data"`
+}
+
+type Unlistened struct {
+	CommonIn
+	Data struct {
+		Success bool `json:"success"`
+	} `json:"data"`
+}