feat: support query list

Author: Teajey

go/client/sock/client.go

@@ -23,19 +23,28 @@ type GetSingleRequest struct {
 	OrderDesc bool   `msgpack:"order_desc,omitempty"`
 }
 
+type QuerySingleRequest struct {
+	Name      string         `msgpack:"name"`
+	Query     map[string]any `msgpack:"query"`
+	SortKey   string         `msgpack:"sort_key,omitempty"`
+	OrderDesc bool           `msgpack:"order_desc,omitempty"`
+	Intersect bool           `msgpack:"intersect"`
+}
+
 type GetListRequest struct {
 	SortKey   string `msgpack:"sort_key,omitempty"`
 	OrderDesc bool   `msgpack:"order_desc,omitempty"`
 	Offset    uint   `msgpack:"offset,omitempty"`
 	Limit     uint   `msgpack:"limit,omitempty"`
 }
 
-type QuerySingleRequest struct {
-	Name      string         `msgpack:"name"`
+type QueryListRequest struct {
 	Query     map[string]any `msgpack:"query"`
 	SortKey   string         `msgpack:"sort_key,omitempty"`
 	OrderDesc bool           `msgpack:"order_desc,omitempty"`
-	Intersect bool           `msgpack:"intersect"`
+	Offset    uint           `msgpack:"offset,omitempty"`
+	Limit     uint           `msgpack:"limit,omitempty"`
+	Intersect bool           `msgpack:"intersect,omitempty"`
 }
 
 type singleResponse struct {
@@ -153,3 +162,7 @@ func (c *Client) QuerySingle(req QuerySingleRequest) (*singleResponse, error) {
 func (c *Client) GetList(req GetListRequest) ([]listResponse, error) {
 	return c.runListRequest(req, "ListGet")
 }
+
+func (c *Client) QueryList(req QueryListRequest) ([]listResponse, error) {
+	return c.runListRequest(req, "ListQuery")
+}

go/client/sock/test/client_test.go

@@ -73,3 +73,17 @@ func TestGetList(t *testing.T) {
 		t.Fatalf("Unexpected response length: %d", respLen)
 	}
 }
+
+func TestQueryList(t *testing.T) {
+	client := sock.NewClient("/tmp/custard")
+	resp, err := client.QueryList(sock.QueryListRequest{
+		Query: map[string]any{"tags": []string{"code"}},
+	})
+	if err != nil {
+		t.Fatalf("Request failed: %s", err)
+	}
+	respLen := len(resp)
+	if respLen != 5 {
+		t.Fatalf("Unexpected response length: %d", respLen)
+	}
+}