[export] refactor sqlite do use Either monad

src/Gargantext/API/Node/Corpus/Export/Utils.hs

@@ -14,14 +14,16 @@ module Gargantext.API.Node.Corpus.Export.Utils
   where
 
 import Control.Exception.Safe qualified as CES
+import Control.Monad.Fail (fail)
 import Data.Aeson qualified as Aeson
 import Data.ByteString.Lazy qualified as BSL
 import Data.HashMap.Strict qualified as HashMap
 import Data.Map.Strict qualified as Map
 import Data.Set qualified as Set
+import Data.Text qualified as T
 import Data.Time.Clock (getCurrentTime, UTCTime)
 import Data.Time.Format.ISO8601 (iso8601ParseM, iso8601Show)
-import Data.Version (parseVersion, showVersion)
+import Data.Version (parseVersion, showVersion, Version)
 import Database.SQLite.Simple qualified as S
 import Gargantext.API.Ngrams.Tools (filterListWithRoot, mapTermListRoot, getRepo)
 import Gargantext.API.Ngrams.Types ( NgramsTerm(..) )
@@ -67,8 +69,7 @@ getContextNgrams cId lId listType nt repo = do
   lIds <- selectNodesWithUsername NodeList userMaster
   let ngs = filterListWithRoot [listType] $ mapTermListRoot [lId] nt repo
   -- TODO HashMap
-  r <- getNgramsByContextOnlyUser cId (lIds <> [lId]) nt (HashMap.keys ngs)
-  pure r
+  getNgramsByContextOnlyUser cId (lIds <> [lId]) nt (HashMap.keys ngs)
 
 
 mkCorpusSQLiteData :: ( CES.MonadMask m
@@ -201,14 +202,17 @@ readCorpusSQLite (CorpusSQLite { _cs_bs }) = withTempSQLiteDir $ \(_fp, _fname,
 
   let (ngrams_errors, ngrams_) = partitionEithers (parseNgrams <$> ngrams)
 
-  -- TODO pure $ do in Either monad
-  case ( readP_to_S parseVersion version
-       , iso8601ParseM created
-       , Aeson.decode corpusHyperdata
-       , Aeson.decode listHyperdata
-       , context_errors
-       , ngrams_errors ) of
-    ([(_csd_version, _)], Just _csd_created, Just _csd_corpus_hyperdata, Just _csd_list_hyperdata, [], []) -> do
+  -- NOTE To make things simpler, use the 'Either Text CorpusSQLData' as a monad
+  --      (there's quire a few things to test here)
+  pure $ do
+    _csd_version <- eParseVersion version
+    _csd_created <- maybeToEither ("Incorrect created: " <> T.pack created) $ iso8601ParseM created
+    _csd_corpus_hyperdata <- first T.pack $ Aeson.eitherDecode corpusHyperdata
+    _csd_list_hyperdata <- first T.pack $ Aeson.eitherDecode listHyperdata
+    
+    unless (null context_errors) $ fail $ "Context errors: " <> show context_errors
+    unless (null ngrams_errors) $ fail $ "Ngrams errors: " <> show ngrams_errors 
+
     let _csd_cId = UnsafeMkNodeId cId
     let _csd_lId = UnsafeMkNodeId lId
 
@@ -220,10 +224,14 @@ readCorpusSQLite (CorpusSQLite { _cs_bs }) = withTempSQLiteDir $ \(_fp, _fname,
     let _csd_stop_context_ngrams = filterNgrams StopTerm ngrams_
     let _csd_candidate_context_ngrams = filterNgrams CandidateTerm ngrams_
     
-      pure $ Right $ CorpusSQLiteData { .. }
-    _ -> pure $ Left "Parse error"
+    pure $ CorpusSQLiteData { .. }
 
   where
+    eParseVersion :: Prelude.String -> Either Text Version
+    eParseVersion v = case readP_to_S parseVersion v of
+      [(v_, _)] -> Right v_
+      _         -> Left ("Incorrect version: " <> T.pack v)
+    
     parseCtx :: (Int, Text, Prelude.String, BSL.ByteString)
              -> Either Text (NodeId, Text, UTCTime, HyperdataDocument)
     parseCtx (ctxId, name, date, hd) =