Skip to content

Commit

Permalink
Kill the need for join
Browse files Browse the repository at this point in the history
  • Loading branch information
newhoggy committed Jan 19, 2023
1 parent bdb4d2c commit a05ceb0
Showing 1 changed file with 18 additions and 17 deletions.
35 changes: 18 additions & 17 deletions cardano-cli/src/Cardano/CLI/Shelley/Run/Query.hs
Original file line number Diff line number Diff line change
Expand Up @@ -1019,30 +1019,31 @@ runQueryStakePools
-> ExceptT ShelleyQueryCmdError IO ()
runQueryStakePools (AnyConsensusModeParams cModeParams)
network mOutFile = do
SocketPath sockPath <- firstExceptT ShelleyQueryCmdEnvVarSocketErr
$ newExceptT readEnvSocketPath
SocketPath sockPath <- lift readEnvSocketPath & onLeft (throwE . ShelleyQueryCmdEnvVarSocketErr)

let localNodeConnInfo = LocalNodeConnectInfo cModeParams network sockPath

poolIds <- ExceptT . fmap (join . first ShelleyQueryCmdAcquireFailure) $
executeLocalStateQueryExpr localNodeConnInfo Nothing $ runExceptT @ShelleyQueryCmdError $ do
anyE@(AnyCardanoEra era) <- case consensusModeOnly cModeParams of
ByronMode -> return $ AnyCardanoEra ByronEra
ShelleyMode -> return $ AnyCardanoEra ShelleyEra
CardanoMode ->
lift (queryExpr $ QueryCurrentEra CardanoModeIsMultiEra)
& onLeft (throwE . ShelleyQueryCmdUnsupportedNtcVersion)
poolIds <-
( lift $ executeLocalStateQueryExpr localNodeConnInfo Nothing $ runExceptT @ShelleyQueryCmdError $ do
anyE@(AnyCardanoEra era) <- case consensusModeOnly cModeParams of
ByronMode -> return $ AnyCardanoEra ByronEra
ShelleyMode -> return $ AnyCardanoEra ShelleyEra
CardanoMode ->
lift (queryExpr $ QueryCurrentEra CardanoModeIsMultiEra)
& onLeft (throwE . ShelleyQueryCmdUnsupportedNtcVersion)

let cMode = consensusModeOnly cModeParams
let cMode = consensusModeOnly cModeParams

eInMode <- toEraInMode era cMode
& hoistMaybe (ShelleyQueryCmdEraConsensusModeMismatch (AnyConsensusMode cMode) anyE)
eInMode <- toEraInMode era cMode
& hoistMaybe (ShelleyQueryCmdEraConsensusModeMismatch (AnyConsensusMode cMode) anyE)

sbe <- getSbe $ cardanoEraStyle era
sbe <- getSbe $ cardanoEraStyle era

lift (queryExpr (QueryInEra eInMode $ QueryInShelleyBasedEra sbe $ QueryStakePools))
& onLeft (throwE . ShelleyQueryCmdUnsupportedNtcVersion)
& onLeft (throwE . ShelleyQueryCmdEraMismatch)
lift (queryExpr (QueryInEra eInMode $ QueryInShelleyBasedEra sbe $ QueryStakePools))
& onLeft (throwE . ShelleyQueryCmdUnsupportedNtcVersion)
& onLeft (throwE . ShelleyQueryCmdEraMismatch)
) & onLeft (throwE . ShelleyQueryCmdAcquireFailure)
& onLeft throwE

writeStakePools mOutFile poolIds

Expand Down

0 comments on commit a05ceb0

Please sign in to comment.