From 91a5e2f1fdf961938029251384cbff59d6dca68c Mon Sep 17 00:00:00 2001 From: Tommaso Piazza Date: Tue, 19 Jun 2018 15:18:31 +0200 Subject: [PATCH] Complete lts11.13 transition --- src/Caches/Local/Downloading.hs | 10 +++++----- src/Caches/S3/Downloading.hs | 4 ++-- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/src/Caches/Local/Downloading.hs b/src/Caches/Local/Downloading.hs index 10df94f..79e037c 100644 --- a/src/Caches/Local/Downloading.hs +++ b/src/Caches/Local/Downloading.hs @@ -6,7 +6,7 @@ import Control.Monad.Except import Control.Monad.Trans.Resource (runResourceT) import qualified Data.ByteString.Lazy as LBS import Data.Carthage.TargetPlatform -import qualified Data.Conduit as C (($$)) +import qualified Data.Conduit as C (runConduit, (.|)) import qualified Data.Conduit.Binary as C (sinkLbs, sourceFile) import Data.Romefile import System.Directory @@ -37,7 +37,7 @@ getFrameworkFromLocalCache lCacheDir platform = do frameworkExistsInLocalCache <- liftIO . doesFileExist $ frameworkLocalCachePath prefix if frameworkExistsInLocalCache - then liftIO . runResourceT $ C.sourceFile (frameworkLocalCachePath prefix) C.$$ C.sinkLbs + then liftIO . runResourceT . C.runConduit $ C.sourceFile (frameworkLocalCachePath prefix) C..| C.sinkLbs else throwError $ "Error: could not find " <> fwn <> " in local cache at : " <> frameworkLocalCachePath prefix where frameworkLocalCachePath cPrefix = lCacheDir cPrefix remoteFrameworkUploadPath @@ -57,7 +57,7 @@ getVersionFileFromLocalCache lCacheDir versionFileExistsInLocalCache <- liftIO . doesFileExist $ versionFileLocalCachePath if versionFileExistsInLocalCache - then liftIO . runResourceT $ C.sourceFile versionFileLocalCachePath C.$$ C.sinkLbs + then liftIO . runResourceT . C.runConduit $ C.sourceFile versionFileLocalCachePath C..| C.sinkLbs else throwError $ "Error: could not find " <> versionFileName <> " in local cache at : " <> versionFileLocalCachePath where versionFileName = versionFileNameForGitRepoName $ fst gitRepoNameAndVersion @@ -84,7 +84,7 @@ getBcsymbolmapFromLocalCache lCacheDir let finalBcsymbolmapLocalPath = bcsymbolmapLocalCachePath prefix bcSymbolmapExistsInLocalCache <- liftIO . doesFileExist $ finalBcsymbolmapLocalPath if bcSymbolmapExistsInLocalCache - then liftIO . runResourceT $ C.sourceFile finalBcsymbolmapLocalPath C.$$ C.sinkLbs + then liftIO . runResourceT . C.runConduit $ C.sourceFile finalBcsymbolmapLocalPath C..| C.sinkLbs else throwError $ "Error: could not find " <> bcsymbolmapName <> " in local cache at : " <> finalBcsymbolmapLocalPath where remoteBcsymbolmapUploadPath = remoteBcsymbolmapPath dwarfUUID platform reverseRomeMap f version @@ -109,7 +109,7 @@ getDSYMFromLocalCache lCacheDir let finalDSYMLocalPath = dSYMLocalCachePath prefix dSYMExistsInLocalCache <- liftIO . doesFileExist $ finalDSYMLocalPath if dSYMExistsInLocalCache - then liftIO . runResourceT $ C.sourceFile finalDSYMLocalPath C.$$ C.sinkLbs + then liftIO . runResourceT . C.runConduit $ C.sourceFile finalDSYMLocalPath C..| C.sinkLbs else throwError $ "Error: could not find " <> dSYMName <> " in local cache at : " <> finalDSYMLocalPath where dSYMLocalCachePath cPrefix = lCacheDir cPrefix remotedSYMUploadPath diff --git a/src/Caches/S3/Downloading.hs b/src/Caches/S3/Downloading.hs index 066c235..4592151 100644 --- a/src/Caches/S3/Downloading.hs +++ b/src/Caches/S3/Downloading.hs @@ -10,7 +10,7 @@ import qualified Data.ByteString as BS import qualified Data.ByteString.Lazy as LBS import Data.Carthage.TargetPlatform import qualified Data.Conduit as C (ConduitT, await, yield, - (=$=)) + (.|)) import qualified Data.Conduit.Binary as C (sinkLbs) import Data.Either (lefts) import Data.Maybe (fromMaybe) @@ -228,7 +228,7 @@ downloadBinary s3BucketName objectRemotePath objectName = do where objectKey = S3.ObjectKey . T.pack $ objectRemotePath - sink verbose totalLength = if verbose then printProgress objectName totalLength C.=$= C.sinkLbs else C.sinkLbs + sink verbose totalLength = if verbose then printProgress objectName totalLength C..| C.sinkLbs else C.sinkLbs printProgress :: MonadIO m => String -> Int -> C.ConduitT BS.ByteString BS.ByteString m () printProgress objName totalLength = loop totalLength 0 0