Skip to content

Commit

Permalink
db-sync: Minor formatting fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
erikd committed Jan 18, 2021
1 parent 316f939 commit d2f4a23
Showing 1 changed file with 16 additions and 14 deletions.
30 changes: 16 additions & 14 deletions cardano-db-sync/src/Cardano/DbSync.hs
Expand Up @@ -176,17 +176,19 @@ runDbSyncNodeNodeClient env ledgerVar iomgr trce plugin codecConfig (SocketPath
clientSubscriptionParams
(dbSyncProtocols trce env plugin queryVar ledgerVar)
where
clientSubscriptionParams = ClientSubscriptionParams {
cspAddress = Snocket.localAddressFromPath socketPath,
cspConnectionAttemptDelay = Nothing,
cspErrorPolicies = networkErrorPolicies <> consensusErrorPolicy (Proxy @CardanoBlock)
clientSubscriptionParams =
ClientSubscriptionParams
{ cspAddress = Snocket.localAddressFromPath socketPath
, cspConnectionAttemptDelay = Nothing
, cspErrorPolicies = networkErrorPolicies <> consensusErrorPolicy (Proxy @CardanoBlock)
}

networkSubscriptionTracers = NetworkSubscriptionTracers {
nsMuxTracer = muxTracer,
nsHandshakeTracer = handshakeTracer,
nsErrorPolicyTracer = errorPolicyTracer,
nsSubscriptionTracer = subscriptionTracer
networkSubscriptionTracers =
NetworkSubscriptionTracers
{ nsMuxTracer = muxTracer
, nsHandshakeTracer = handshakeTracer
, nsErrorPolicyTracer = errorPolicyTracer
, nsSubscriptionTracer = subscriptionTracer
}

errorPolicyTracer :: Tracer IO (WithAddr LocalAddress ErrorPolicyTrace)
Expand Down Expand Up @@ -214,11 +216,11 @@ dbSyncProtocols
-> ConnectionId LocalAddress
-> NodeToClientProtocols 'InitiatorMode BSL.ByteString IO () Void
dbSyncProtocols trce env plugin queryVar ledgerVar _version codecs _connectionId =
NodeToClientProtocols {
localChainSyncProtocol = localChainSyncPtcl
, localTxSubmissionProtocol = dummylocalTxSubmit
, localStateQueryProtocol = localStateQuery
}
NodeToClientProtocols
{ localChainSyncProtocol = localChainSyncPtcl
, localTxSubmissionProtocol = dummylocalTxSubmit
, localStateQueryProtocol = localStateQuery
}
where
localChainSyncTracer :: Tracer IO (TraceSendRecv (ChainSync CardanoBlock(Point CardanoBlock) (Tip CardanoBlock)))
localChainSyncTracer = toLogObject $ appendName "ChainSync" trce
Expand Down

0 comments on commit d2f4a23

Please sign in to comment.