@@ -17,7 +17,7 @@ import Effectful.Fail
17
17
import Effectful.FileSystem
18
18
import Effectful.Log (Log , runLog )
19
19
import Effectful.PostgreSQL.Transact.Effect
20
- import Effectful.Reader.Static ( Reader )
20
+ import Effectful.Prometheus
21
21
import Effectful.Reader.Static qualified as Reader
22
22
import Effectful.State.Static.Shared (State )
23
23
import Effectful.State.Static.Shared qualified as State
@@ -26,7 +26,6 @@ import Effectful.Trace (Trace)
26
26
import Effectful.Trace qualified as Trace
27
27
import GHC.Conc
28
28
import GHC.Generics (Generic )
29
- import GHC.Records
30
29
import Log qualified
31
30
import Log.Backend.StandardOutput qualified as Log
32
31
import Monitor.Tracing.Zipkin (Zipkin (.. ))
@@ -97,23 +96,25 @@ main = Log.withStdOutLogger $ \logger -> do
97
96
pure $ Trace. runTrace zipkin. zipkinTracer
98
97
else pure Trace. runNoTrace
99
98
result <-
100
- runEff
101
- . runTrace
102
- . runErrorNoCallStack
103
- . State. evalState (mempty @ (Set (Namespace , PackageName , Version )))
104
- . withUnliftStrategy (ConcUnlift Ephemeral Unlimited )
105
- . runDB env. pool
106
- . runFailIO
107
- . runTime
108
- . runPoolboy (poolboySettingsWith capabilities)
109
- . ( case env. features. blobStoreImpl of
99
+ runOptions cliArgs
100
+ & Reader. runReader env
101
+ & runLog " flora-cli" logger Log. LogTrace
102
+ & runFileSystem
103
+ & ( case env. features. blobStoreImpl of
110
104
Just (BlobStoreFS fp) -> runBlobStoreFS fp
111
105
_ -> runBlobStorePure
112
106
)
113
- . runFileSystem
114
- . runLog " flora-cli" logger Log. LogTrace
115
- . Reader. runReader env
116
- $ runOptions cliArgs
107
+ & runPoolboy (poolboySettingsWith capabilities)
108
+ & runTime
109
+ & runFailIO
110
+ & runDB env. pool
111
+ & withUnliftStrategy (ConcUnlift Ephemeral Unlimited )
112
+ & State. evalState (mempty @ (Set (Namespace , PackageName , Version )))
113
+ & runErrorNoCallStack
114
+ & runTrace
115
+ & runPrometheusMetrics env. metrics
116
+ & runEff
117
+
117
118
case result of
118
119
Right _ -> pure ()
119
120
Left errors ->
@@ -195,12 +196,10 @@ runOptions
195
196
, Error (NonEmpty AdvisoryImportError ) :> es
196
197
, Fail :> es
197
198
, FileSystem :> es
198
- , HasField " metrics" r Metrics
199
- , HasField " mltp" r MLTP
200
199
, IOE :> es
201
200
, Log :> es
201
+ , Metrics AppMetrics :> es
202
202
, Poolboy :> es
203
- , Reader r :> es
204
203
, State (Set (Namespace , PackageName , Version )) :> es
205
204
, Time :> es
206
205
, Trace :> es
@@ -248,12 +247,10 @@ provisionRepository name url description = Update.upsertPackageIndex name url de
248
247
importFolderOfCabalFiles
249
248
:: ( DB :> es
250
249
, FileSystem :> es
251
- , HasField " metrics" r Metrics
252
- , HasField " mltp" r MLTP
253
250
, IOE :> es
254
251
, Log :> es
252
+ , Metrics AppMetrics :> es
255
253
, Poolboy :> es
256
- , Reader r :> es
257
254
, State (Set (Namespace , PackageName , Version )) :> es
258
255
, Time :> es
259
256
)
@@ -270,12 +267,10 @@ importFolderOfCabalFiles path repository = do
270
267
271
268
importIndex
272
269
:: ( DB :> es
273
- , HasField " metrics" r Metrics
274
- , HasField " mltp" r MLTP
275
270
, IOE :> es
276
271
, Log :> es
272
+ , Metrics AppMetrics :> es
277
273
, Poolboy :> es
278
- , Reader r :> es
279
274
, State (Set (Namespace , PackageName , Version )) :> es
280
275
, Time :> es
281
276
)
0 commit comments