File tree Expand file tree Collapse file tree 9 files changed +18
-23
lines changed
libs/wai-utilities/src/Network/Wai/Utilities
background-worker/src/Wire Expand file tree Collapse file tree 9 files changed +18
-23
lines changed Original file line number Diff line number Diff line change @@ -92,16 +92,15 @@ data Server = Server
92
92
defaultServer :: String -> Word16 -> Logger -> Server
93
93
defaultServer h p l = Server h p l Nothing
94
94
95
- newSettings :: (MonadIO m ) => Server -> m Settings
96
- newSettings (Server h p l t) = do
97
- pure
98
- $ setHost (fromString h)
99
- . setPort (fromIntegral p)
100
- . setBeforeMainLoop logStart
101
- . setOnOpen (const $ connStart >> pure True )
102
- . setOnClose (const connEnd)
103
- . setTimeout (fromMaybe 300 t)
104
- $ defaultSettings
95
+ newSettings :: Server -> Settings
96
+ newSettings (Server h p l t) =
97
+ setHost (fromString h)
98
+ . setPort (fromIntegral p)
99
+ . setBeforeMainLoop logStart
100
+ . setOnOpen (const $ connStart >> pure True )
101
+ . setOnClose (const connEnd)
102
+ . setTimeout (fromMaybe 300 t)
103
+ $ defaultSettings
105
104
where
106
105
connStart = Prom. incGauge netConnections
107
106
connEnd = Prom. decGauge netConnections
Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ run opts = do
34
34
cleanup = do
35
35
concurrently_ cleanupDeadUserNotifWatcher cleanupBackendNotifPusher
36
36
let server = defaultServer (T. unpack $ opts. backgroundWorker. host) opts. backgroundWorker. port env. logger
37
- settings <- newSettings server
37
+ let settings = newSettings server
38
38
-- Additional cleanup when shutting down via signals.
39
39
runSettingsWithCleanup cleanup settings (servantApp env) Nothing
40
40
Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ run :: Opts -> IO ()
83
83
run opts = withTracer \ tracer -> do
84
84
(app, e) <- mkApp opts
85
85
runAllMigrations e. hasqlPool e. appLogger
86
- s <- Server. newSettings (server e)
86
+ let s = Server. newSettings (server e)
87
87
internalEventListener <-
88
88
Async. async $
89
89
runBrigToIO e $
Original file line number Diff line number Diff line change @@ -92,7 +92,7 @@ run o = lowerCodensity $ do
92
92
mkEnv ext o cassandra g d1 d2 man rnd clk (o ^. Cannon.Options. rabbitmq)
93
93
94
94
void $ Codensity $ Async. withAsync $ runCannon e refreshMetrics
95
- s <- newSettings $ Server (o ^. cannon . host) (o ^. cannon . port) (applog e) (Just idleTimeout)
95
+ let s = newSettings $ Server (o ^. cannon . host) (o ^. cannon . port) (applog e) (Just idleTimeout)
96
96
97
97
otelMiddleWare <- lift newOpenTelemetryWaiMiddleware
98
98
let middleware :: Wai. Middleware
Original file line number Diff line number Diff line change @@ -59,14 +59,12 @@ run :: Opts -> IO ()
59
59
run o = lowerCodensity $ do
60
60
(app, e) <- mkApp o
61
61
void $ Codensity $ Async. withAsync (collectAuthMetrics e. aws. amazonkaEnv)
62
- liftIO $ do
63
- s <-
64
- Server. newSettings $
62
+ let s = Server. newSettings $
65
63
defaultServer
66
64
(unpack . host $ o. cargohold)
67
65
(port o. cargohold)
68
66
e. appLogger
69
- runSettingsWithShutdown s app Nothing
67
+ liftIO $ runSettingsWithShutdown s app Nothing
70
68
71
69
mkApp :: Opts -> Codensity IO (Application , Env )
72
70
mkApp o = Codensity $ \ k ->
Original file line number Diff line number Diff line change @@ -72,9 +72,7 @@ run :: Opts -> IO ()
72
72
run opts = lowerCodensity do
73
73
tracer <- withTracerC
74
74
(app, env) <- mkApp opts
75
- settings' <-
76
- lift $
77
- newSettings $
75
+ let settings' = newSettings $
78
76
defaultServer
79
77
(unpack $ opts. _galley. host)
80
78
(portNumber $ fromIntegral opts. _galley. port)
Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ run opts = withTracer \tracer -> do
72
72
73
73
runClient (env ^. cstate) $
74
74
versionCheck lastSchemaVersion
75
- s <- newSettings $ defaultServer (unpack . host $ opts ^. gundeck) (port $ opts ^. gundeck) logger
75
+ let s = newSettings $ defaultServer (unpack . host $ opts ^. gundeck) (port $ opts ^. gundeck) logger
76
76
let throttleMillis = fromMaybe defSqsThrottleMillis $ opts ^. (settings . sqsThrottleMillis)
77
77
78
78
lst <- Async. async $ Aws. execute (env ^. awsEnv) (Aws. listen throttleMillis (runDirect env . onEvent))
Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ combinedSitemap env = I.servantSitemap Servant.:<|> P.servantSitemap env
51
51
run :: Opts -> IO ()
52
52
run o = do
53
53
e <- createEnv o
54
- s <- newSettings $ defaultServer (o ^. proxy . to (T. unpack . host)) (o ^. proxy . to port) (e ^. applog)
54
+ let s = newSettings $ defaultServer (o ^. proxy . to (T. unpack . host)) (o ^. proxy . to port) (e ^. applog)
55
55
56
56
let metricsMW :: Middleware
57
57
metricsMW = waiPrometheusMiddlewarePaths (routesToPaths @ ProxyAPI <> routesToPaths @ InternalAPI )
Original file line number Diff line number Diff line change @@ -80,7 +80,7 @@ default (ByteString)
80
80
start :: Opts -> IO ()
81
81
start o = do
82
82
e <- newEnv o
83
- s <- Server. newSettings (server e)
83
+ let s = Server. newSettings (server e)
84
84
Server. runSettingsWithShutdown s (requestIdMiddleware e. appLogger defaultRequestIdHeaderName $ servantApp e) Nothing
85
85
where
86
86
server :: Env -> Server. Server
You can’t perform that action at this time.
0 commit comments