Add support for grouping commits by fieldId

sourcenetwork · May 4, 2023 · 13ff861 · 13ff861
1 parent 9b9e688
commit 13ff861
Show file tree

Hide file tree

Showing 2 changed files with 114 additions and 0 deletions.
diff --git a/request/graphql/schema/types/commits.go b/request/graphql/schema/types/commits.go
@@ -162,6 +162,10 @@ var (
 					Value:       "fieldName",
 					Description: commitFieldNameFieldDescription,
 				},
+				"fieldId": &gql.EnumValueConfig{
+					Value:       "fieldId",
+					Description: commitFieldIDFieldDescription,
+				},
 			},
 		},
 	)

diff --git a/tests/integration/query/commits/with_group_test.go b/tests/integration/query/commits/with_group_test.go
@@ -336,3 +336,113 @@ func TestQueryCommitsWithGroupByFieldNameWithChild(t *testing.T) {
 
 	testUtils.ExecuteTestCase(t, []string{"Users"}, test)
 }
+
+func TestQueryCommitsWithGroupByFieldID(t *testing.T) {
+	test := testUtils.TestCase{
+		Description: "Simple all commits query, group by fieldId",
+		Actions: []any{
+			updateUserCollectionSchema(),
+			testUtils.CreateDoc{
+				CollectionID: 0,
+				Doc: `{
+						"name":	"John",
+						"age":	21
+					}`,
+			},
+			testUtils.UpdateDoc{
+				CollectionID: 0,
+				DocID:        0,
+				Doc: `{
+					"age":	22
+				}`,
+			},
+			testUtils.Request{
+				Request: ` {
+						commits(groupBy: [fieldId]) {
+							fieldId
+						}
+					}`,
+				Results: []map[string]any{
+					{
+						"fieldId": "1",
+					},
+					{
+						"fieldId": "2",
+					},
+					{
+						"fieldId": "C",
+					},
+				},
+			},
+		},
+	}
+
+	testUtils.ExecuteTestCase(t, []string{"Users"}, test)
+}
+
+func TestQueryCommitsWithGroupByFieldIDWithChild(t *testing.T) {
+	test := testUtils.TestCase{
+		Description: "Simple all commits query, group by fieldId",
+		Actions: []any{
+			updateUserCollectionSchema(),
+			testUtils.CreateDoc{
+				CollectionID: 0,
+				Doc: `{
+						"name":	"John",
+						"age":	21
+					}`,
+			},
+			testUtils.UpdateDoc{
+				CollectionID: 0,
+				DocID:        0,
+				Doc: `{
+					"age":	22
+				}`,
+			},
+			testUtils.Request{
+				Request: ` {
+						commits(groupBy: [fieldId]) {
+							fieldId
+							_group {
+								height
+							}
+						}
+					}`,
+				Results: []map[string]any{
+					{
+						"fieldId": "1",
+						"_group": []map[string]any{
+							{
+								"height": int64(2),
+							},
+							{
+								"height": int64(1),
+							},
+						},
+					},
+					{
+						"fieldId": "2",
+						"_group": []map[string]any{
+							{
+								"height": int64(1),
+							},
+						},
+					},
+					{
+						"fieldId": "C",
+						"_group": []map[string]any{
+							{
+								"height": int64(2),
+							},
+							{
+								"height": int64(1),
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+
+	testUtils.ExecuteTestCase(t, []string{"Users"}, test)
+}