@@ -150,24 +150,24 @@ runLogKickOff
150150 -> Thrift. KickOff
151151 -> GleanServerLog
152152 -> IO ()
153- runLogKickOff cmd env Thrift. KickOff { .. } log =
154- runLogRepo cmd env kickOff_repo $ log <> schemaId
153+ runLogKickOff cmd env kickOff log =
154+ runLogRepo cmd env kickOff . kickOff_repo $ log <> schemaId
155155 where
156156 schemaId = maybe mempty Logger. SetSchemaId $
157- HashMap. lookup " glean.schema_id" kickOff_properties
157+ HashMap. lookup " glean.schema_id" kickOff . kickOff_properties
158158
159159runLogQueryFacts
160160 :: Text
161161 -> Database. Env
162162 -> Thrift. Repo
163163 -> Thrift. UserQueryFacts
164164 -> GleanServerLog -> IO ()
165- runLogQueryFacts cmd env repo Thrift. UserQueryFacts { .. } log =
165+ runLogQueryFacts cmd env repo queryFacts log =
166166 runLogRepo cmd env repo $ log
167- <> maybe mempty logQueryOptions userQueryFacts_options
168- <> maybe mempty logQueryClientInfo userQueryFacts_client_info
167+ <> maybe mempty logQueryOptions queryFacts . userQueryFacts_options
168+ <> maybe mempty logQueryClientInfo queryFacts . userQueryFacts_client_info
169169 <> maybe mempty (Logger. SetSchemaId . Thrift. unSchemaId)
170- userQueryFacts_schema_id
170+ queryFacts . userQueryFacts_schema_id
171171
172172runLogQuery
173173 :: Text
@@ -176,21 +176,21 @@ runLogQuery
176176 -> Thrift. UserQuery
177177 -> GleanServerLog
178178 -> IO ()
179- runLogQuery cmd env repo Thrift. UserQuery { .. } log = do
179+ runLogQuery cmd env repo query log = do
180180 runLogRepo cmd env repo $ mconcat
181181 [ log
182182 , Logger. SetQuery
183183 (Text. decodeUtf8With Text. lenientDecode $
184- if ByteString. length userQuery_query > 1024
185- then " [truncated] " <> ByteString. take 1024 userQuery_query
186- else userQuery_query)
187- , Logger. SetPredicate userQuery_predicate
184+ if ByteString. length query . userQuery_query > 1024
185+ then " [truncated] " <> ByteString. take 1024 query . userQuery_query
186+ else query . userQuery_query)
187+ , Logger. SetPredicate query . userQuery_predicate
188188 , maybe mempty (Logger. SetPredicateVersion . fromIntegral )
189- userQuery_predicate_version
189+ query . userQuery_predicate_version
190190 , maybe mempty (Logger. SetSchemaId . Thrift. unSchemaId)
191- userQuery_schema_id
192- , maybe mempty logQueryOptions userQuery_options
193- , maybe mempty logQueryClientInfo userQuery_client_info
191+ query . userQuery_schema_id
192+ , maybe mempty logQueryOptions query . userQuery_options
193+ , maybe mempty logQueryClientInfo query . userQuery_client_info
194194 ]
195195
196196runLogQueryBatch
@@ -200,24 +200,24 @@ runLogQueryBatch
200200 -> Thrift. UserQueryBatch
201201 -> GleanServerLog
202202 -> IO ()
203- runLogQueryBatch cmd env repo Thrift. UserQueryBatch { .. } log =
203+ runLogQueryBatch cmd env repo batch log =
204204 runLogRepo cmd env repo $ mconcat
205205 [ log
206- , Logger. SetQuery $ case userQueryBatch_queries of
206+ , Logger. SetQuery $ case batch . userQueryBatch_queries of
207207 [] -> " 0 batched queries"
208208 q: rest -> Text. unlines $
209209 Text. decodeUtf8With Text. lenientDecode q :
210210 [" + " <> showt n <> " batched queries"
211211 | let n = length rest
212212 , n > 1
213213 ]
214- , Logger. SetPredicate userQueryBatch_predicate
214+ , Logger. SetPredicate batch . userQueryBatch_predicate
215215 , maybe mempty (Logger. SetPredicateVersion . fromIntegral )
216- userQueryBatch_predicate_version
216+ batch . userQueryBatch_predicate_version
217217 , maybe mempty (Logger. SetSchemaId . Thrift. unSchemaId)
218- userQueryBatch_schema_id
219- , maybe mempty logQueryOptions userQueryBatch_options
220- , maybe mempty logQueryClientInfo userQueryBatch_client_info
218+ batch . userQueryBatch_schema_id
219+ , maybe mempty logQueryOptions batch . userQueryBatch_options
220+ , maybe mempty logQueryClientInfo batch . userQueryBatch_client_info
221221 ]
222222
223223runLogEnqueueBatch
@@ -226,40 +226,40 @@ runLogEnqueueBatch
226226 -> Thrift. ComputedBatch
227227 -> GleanServerLog
228228 -> IO ()
229- runLogEnqueueBatch cmd env Thrift. ComputedBatch { .. } log =
230- let ! Thrift. Batch { .. } = computedBatch_batch in
231- runLogRepo cmd env computedBatch_repo $ mconcat
229+ runLogEnqueueBatch cmd env computedBatch log =
230+ let ! batch = computedBatch . computedBatch_batch in
231+ runLogRepo cmd env computedBatch . computedBatch_repo $ mconcat
232232 [ log
233- , Logger. SetBatchFactsSize $ ByteString. length batch_facts
233+ , Logger. SetBatchFactsSize $ ByteString. length batch . batch_facts
234234 , Logger. SetBatchFactsCount $ fromIntegral $
235- Thrift. batch_count computedBatch_batch
236- , Logger. SetBatchOwnedSize $ batchOwnedSize batch_owned
237- , Logger. SetBatchDependenciesSize $ batchDependenciesSize batch_dependencies
235+ Thrift. batch_count batch
236+ , Logger. SetBatchOwnedSize $ batchOwnedSize batch . batch_owned
237+ , Logger. SetBatchDependenciesSize $ batchDependenciesSize batch . batch_dependencies
238238 ]
239239
240240logQueryOptions :: Thrift. UserQueryOptions -> GleanServerLog
241- logQueryOptions Thrift. UserQueryOptions { .. } = mconcat
242- [ Logger. SetNoBase64Binary userQueryOptions_no_base64_binary
243- , Logger. SetExpandResults userQueryOptions_expand_results
244- , Logger. SetRecursive userQueryOptions_recursive
241+ logQueryOptions opts = mconcat
242+ [ Logger. SetNoBase64Binary opts . userQueryOptions_no_base64_binary
243+ , Logger. SetExpandResults opts . userQueryOptions_expand_results
244+ , Logger. SetRecursive opts . userQueryOptions_recursive
245245 , maybe mempty (Logger. SetMaxResults . fromIntegral )
246- userQueryOptions_max_results
247- , Logger. SetSyntax $ case userQueryOptions_syntax of
246+ opts . userQueryOptions_max_results
247+ , Logger. SetSyntax $ case opts . userQueryOptions_syntax of
248248 Thrift. QuerySyntax_JSON -> " JSON"
249249 Thrift. QuerySyntax_ANGLE -> " Angle"
250250 , maybe mempty
251251 ( Logger. SetRequestContinuationSize
252252 . ByteString. length
253253 . Thrift. userQueryCont_continuation
254254 )
255- userQueryOptions_continuation
255+ opts . userQueryOptions_continuation
256256 ]
257257
258258logQueryClientInfo :: Thrift. UserQueryClientInfo -> GleanServerLog
259- logQueryClientInfo Thrift. UserQueryClientInfo { .. } = mconcat
260- [ maybe mempty Logger. SetClientUnixname userQueryClientInfo_unixname
261- , Logger. SetClientApplication userQueryClientInfo_application
262- , Logger. SetClientName userQueryClientInfo_name
259+ logQueryClientInfo info = mconcat
260+ [ maybe mempty Logger. SetClientUnixname info . userQueryClientInfo_unixname
261+ , Logger. SetClientApplication info . userQueryClientInfo_application
262+ , Logger. SetClientName info . userQueryClientInfo_name
263263 ]
264264
265265logQueryResultsOrException
@@ -271,44 +271,44 @@ logQueryResultsOrException results = mconcat
271271 ]
272272
273273logQueryResults :: Thrift. UserQueryResults -> GleanServerLog
274- logQueryResults it@ Thrift. UserQueryResults { .. } = mconcat
274+ logQueryResults it = mconcat
275275 [ Logger. SetResults $ countQueryResults it
276- , Logger. SetTruncated (isJust userQueryResults_continuation)
277- , maybe mempty logQueryStats userQueryResults_stats
278- , maybe mempty Logger. SetType userQueryResults_type
276+ , Logger. SetTruncated (isJust it . userQueryResults_continuation)
277+ , maybe mempty logQueryStats it . userQueryResults_stats
278+ , maybe mempty Logger. SetType it . userQueryResults_type
279279 , maybe mempty
280280 ( Logger. SetResponseContinuationSize
281281 . ByteString. length
282282 . Thrift. userQueryCont_continuation
283283 )
284- userQueryResults_continuation
284+ it . userQueryResults_continuation
285285 ]
286286
287287countQueryResults :: Thrift. UserQueryResults -> Int
288- countQueryResults Thrift. UserQueryResults { .. } =
289- case userQueryResults_results of
288+ countQueryResults results =
289+ case results . userQueryResults_results of
290290 Thrift. UserQueryEncodedResults_bin bin ->
291291 Map. size (Thrift. userQueryResultsBin_facts bin)
292292 Thrift. UserQueryEncodedResults_json json ->
293293 length (Thrift. userQueryResultsJSON_facts json)
294294 Thrift. UserQueryEncodedResults_compact compact ->
295295 length (Thrift. userQueryResultsCompact_facts compact)
296296 _ ->
297- length userQueryResults_facts
297+ length results . userQueryResults_facts
298298
299299logQueryStats :: Thrift. UserQueryStats -> GleanServerLog
300- logQueryStats Thrift. UserQueryStats { .. } = mconcat
301- [ Logger. SetResults (fromIntegral userQueryStats_result_count)
302- , Logger. SetFacts (fromIntegral userQueryStats_num_facts)
303- , Logger. SetFullScans (showRef <$> userQueryStats_full_scans)
300+ logQueryStats stats = mconcat
301+ [ Logger. SetResults (fromIntegral stats . userQueryStats_result_count)
302+ , Logger. SetFacts (fromIntegral stats . userQueryStats_num_facts)
303+ , Logger. SetFullScans (showRef <$> stats . userQueryStats_full_scans)
304304 , maybe mempty (Logger. SetBytecodeSize . fromIntegral )
305- userQueryStats_bytecode_size
305+ stats . userQueryStats_bytecode_size
306306 , maybe mempty (Logger. SetCompileTimeUs . fromIntegral . (`quot` 1000 ))
307- userQueryStats_compile_time_ns
307+ stats . userQueryStats_compile_time_ns
308308 , maybe mempty (Logger. SetExecuteTimeUs . fromIntegral . (`quot` 1000 ))
309- userQueryStats_execute_time_ns
309+ stats . userQueryStats_execute_time_ns
310310 , maybe mempty (Logger. SetQueryResultBytes . fromIntegral )
311- userQueryStats_result_bytes
311+ stats . userQueryStats_result_bytes
312312 ]
313313
314314runLogDerivePredicate
@@ -318,13 +318,13 @@ runLogDerivePredicate
318318 -> Thrift. DerivePredicateQuery
319319 -> GleanServerLog
320320 -> IO ()
321- runLogDerivePredicate cmd env repo Thrift. DerivePredicateQuery { .. } log =
321+ runLogDerivePredicate cmd env repo query log =
322322 runLogRepo cmd env repo $ mconcat
323323 [ log
324- , Logger. SetPredicate derivePredicateQuery_predicate
324+ , Logger. SetPredicate query . derivePredicateQuery_predicate
325325 , maybe mempty (Logger. SetPredicateVersion . fromIntegral )
326- derivePredicateQuery_predicate_version
327- , maybe mempty logQueryClientInfo derivePredicateQuery_client_info
326+ query . derivePredicateQuery_predicate_version
327+ , maybe mempty logQueryClientInfo query . derivePredicateQuery_client_info
328328 ]
329329
330330runLogDerivationResult
@@ -334,18 +334,18 @@ runLogDerivationResult
334334 -> Thrift. DerivePredicateQuery
335335 -> Either (DiffTimePoints , SomeException ) Thrift. UserQueryStats
336336 -> IO ()
337- runLogDerivationResult env log repo Thrift. DerivePredicateQuery { .. } res = do
337+ runLogDerivationResult env log repo query res = do
338338 log res
339339 runLogRepo " deriveStored(completed)" env repo $ mconcat
340- [ Logger. SetPredicate derivePredicateQuery_predicate
340+ [ Logger. SetPredicate query . derivePredicateQuery_predicate
341341 , maybe mempty (Logger. SetPredicateVersion . fromIntegral )
342- derivePredicateQuery_predicate_version
343- , maybe mempty logQueryClientInfo derivePredicateQuery_client_info
342+ query . derivePredicateQuery_predicate_version
343+ , maybe mempty logQueryClientInfo query . derivePredicateQuery_client_info
344344 , case res of
345345 Left (_,err) -> failureLog err
346346 Right stats -> successLog <> logQueryStats stats
347347 , timeLog $ toDiffSeconds $ case res of
348348 Left (duration, _) -> duration
349- Right Thrift. UserQueryStats { .. } ->
350- nanoseconds (fromIntegral userQueryStats_elapsed_ns)
349+ Right stats ->
350+ nanoseconds (fromIntegral stats . userQueryStats_elapsed_ns)
351351 ]
0 commit comments