Filter by structured_event_id

MinaProtocol · Jun 6, 2023 · b4c598c · b4c598c
1 parent bcc5ea3
commit b4c598c
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 9 deletions.
diff --git a/graphql_schema.json b/graphql_schema.json
@@ -2039,9 +2039,17 @@
                     "kind": "NON_NULL",
                     "name": null,
                     "ofType": {
-                      "kind": "SCALAR",
-                      "name": "String",
-                      "ofType": null
+                      "kind": "LIST",
+                      "name": null,
+                      "ofType": {
+                        "kind": "NON_NULL",
+                        "name": null,
+                        "ofType": {
+                          "kind": "SCALAR",
+                          "name": "String",
+                          "ofType": null
+                        }
+                      }
                     }
                   },
                   "defaultValue": null

diff --git a/src/lib/integration_test_cloud_engine/kubernetes_network.ml b/src/lib/integration_test_cloud_engine/kubernetes_network.ml
@@ -287,7 +287,7 @@ module Node = struct
     module StartFilteredLog =
     [%graphql
     {|
-      mutation ($filter: String!) @encoders(module: "Encoders"){
+      mutation ($filter: [String!]!) @encoders(module: "Encoders"){
         startFilteredLog(filter: $filter)
       }
     |}]

diff --git a/src/lib/mina_graphql/mina_graphql.ml b/src/lib/mina_graphql/mina_graphql.ml
@@ -2868,10 +2868,10 @@ module Mutations = struct
 
   let start_filtered_log =
     field "startFilteredLog" ~doc:"TODO" ~typ:(non_null string)
-      ~args:Arg.[ arg "filter" ~typ:(non_null string) ]
+      ~args:Arg.[ arg "filter" ~typ:(non_null (list (non_null string))) ]
       ~resolve:(fun { ctx = t; _ } () filter ->
         Mina_lib.start_filtered_log t filter ;
-        filter )
+        "ok" )
 
   let create_account =
     io_field "createAccount"

diff --git a/src/lib/mina_lib/mina_lib.ml b/src/lib/mina_lib/mina_lib.ml
@@ -2033,15 +2033,18 @@ let runtime_config { config = { precomputed_values; _ }; _ } =
 
 let start_filtered_log
     ({ in_memory_reverse_structured_log_messages_for_integration_test; _ } : t)
-    (_ : string) =
+    (structured_log_ids : string list) =
   let handle str =
     let idx, old_messages =
       !in_memory_reverse_structured_log_messages_for_integration_test
     in
     in_memory_reverse_structured_log_messages_for_integration_test :=
       (idx + 1, str :: old_messages)
   in
-  let event_set = (* TODO *) Structured_log_events.Set.empty in
+  let event_set =
+    Structured_log_events.Set.of_list
+    @@ List.map ~f:Structured_log_events.id_of_string structured_log_ids
+  in
   Logger.Consumer_registry.register ~id:Logger.Logger_id.mina
     ~processor:(Logger.Processor.raw_structured_log_events event_set)
     ~transport:(Logger.Transport.raw handle)

diff --git a/src/lib/mina_lib/mina_lib.mli b/src/lib/mina_lib/mina_lib.mli
@@ -196,6 +196,6 @@ val net : t -> Mina_networking.t
 
 val runtime_config : t -> Runtime_config.t
 
-val start_filtered_log : t -> string -> unit
+val start_filtered_log : t -> string list -> unit
 
 val get_filtered_log_entries : t -> int -> string list