add stream_list

Author: nikooo777

extras/jsonrpc/daemon.go

@@ -429,6 +429,18 @@ func (d *Client) AddressList(account *string, address *string) (*AddressListResp
 	return response, d.call(response, "address_list", structs.Map(args))
 }
 
+func (d *Client) StreamList(account *string) (*StreamListResponse, error) {
+	response := new(StreamListResponse)
+	err := d.call(response, "stream_list", map[string]interface{}{
+		"account_id":       account,
+		"include_protobuf": true,
+	})
+	if err != nil {
+		return nil, err
+	}
+	return response, nil
+}
+
 func (d *Client) ClaimList(account *string, page uint64, pageSize uint64) (*ClaimListResponse, error) {
 	if page == 0 {
 		return nil, errors.Err("pages start from 1")

extras/jsonrpc/daemon_test.go

@@ -280,6 +280,17 @@ func TestClient_ClaimList(t *testing.T) {
 	prettyPrint(*got)
 }
 
+func TestClient_StreamList(t *testing.T) {
+	_ = os.Setenv("BLOCKCHAIN_NAME", "lbrycrd_regtest")
+	d := NewClient("")
+	got, err := d.StreamList(nil)
+	if err != nil {
+		t.Error(err)
+		return
+	}
+	prettyPrint(*got)
+}
+
 func TestClient_TransactionList(t *testing.T) {
 	_ = os.Setenv("BLOCKCHAIN_NAME", "lbrycrd_regtest")
 	d := NewClient("")

extras/jsonrpc/daemon_types.go

@@ -396,6 +396,8 @@ func (c *Claim) GetStreamSizeByMagic() (streamSize uint64, e error) {
 	return streamSize, nil
 }
 
+type StreamListResponse []Claim
+
 type ClaimListResponse struct {
 	Claims     []Claim `json:"items"`
 	Page       uint64  `json:"page"`