{-| Module : Gargantext.Text.Parsers Description : All parsers of Gargantext in one file. Copyright : (c) CNRS, 2017 License : AGPL + CECILL v3 Maintainer : team@gargantext.org Stability : experimental Portability : POSIX Gargantext enables analyzing semi-structured text that should be parsed in order to be analyzed. The parsers suppose we know the format of the Text (TextFormat data type) according to which the right parser is chosen among the list of available parsers. This module mainly describe how to add a new parser to Gargantext, please follow the types. -} {-# LANGUAGE NoImplicitPrelude #-} {-# LANGUAGE PackageImports #-} {-# LANGUAGE OverloadedStrings #-} module Gargantext.Text.Parsers (parse, FileFormat(..), clean, parseDocs) where import "zip" Codec.Archive.Zip (withArchive, getEntry, getEntries) import Control.Concurrent.Async as CCA (mapConcurrently) import Control.Monad (join) import qualified Data.ByteString.Char8 as DBC import Data.Attoparsec.ByteString (parseOnly, Parser) import Data.Either(Either(..)) import Data.Either.Extra (partitionEithers) import Data.List (concat) import Data.List (lookup) import Data.Ord() import Data.String (String()) import Data.String() import Data.Text (Text) import Data.Text.Encoding (decodeUtf8) import Data.Time (UTCTime(..)) import Data.Tuple.Extra (both, first, second) import System.FilePath (FilePath(), takeExtension) import qualified Data.ByteString as DB import qualified Data.Map as DM import qualified Data.Text as DT import qualified Data.Time as DT import Gargantext.Core (Lang(..)) import Gargantext.Prelude import Gargantext.Database.Types.Node (HyperdataDocument(..)) import qualified Gargantext.Text.Parsers.WOS as WOS import qualified Gargantext.Text.Parsers.RIS as RIS import Gargantext.Text.Parsers.RIS.Presse (presseEnrich) import Gargantext.Text.Parsers.Date (parseDate) import Gargantext.Text.Parsers.CSV (parseHal) import Gargantext.Text.Terms.Stop (detectLang) ------------------------------------------------------------------------ type ParseError = String --type Field = Text --type Document = DM.Map Field Text --type FilesParsed = DM.Map FilePath FileParsed --data FileParsed = FileParsed { _fileParsed_errors :: Maybe ParseError -- , _fileParsed_result :: [Document] -- } deriving (Show) -- | According to the format of Input file, -- different parser are available. data FileFormat = WOS | RIS | RisPresse | CsvGargV3 | CsvHalFormat deriving (Show) -- Implemented (ISI Format) -- | DOC -- Not Implemented / import Pandoc -- | ODT -- Not Implemented / import Pandoc -- | PDF -- Not Implemented / pdftotext and import Pandoc ? -- | XML -- Not Implemented / see : -- -- > http://chrisdone.com/posts/fast-haskell-c-parsing-xml -- TODO: to debug maybe add the filepath in error message -- | Parse file into documents -- TODO manage errors here parseDocs :: FileFormat -> FilePath -> IO [HyperdataDocument] parseDocs CsvHalFormat p = parseHal p parseDocs RisPresse p = join $ mapM (toDoc RIS) <$> snd <$> enrichWith presseEnrich <$> parse' RIS p parseDocs WOS p = join $ mapM (toDoc WOS) <$> snd <$> enrichWith (map (first WOS.keys)) <$> parse' WOS p parseDocs ff p = join $ mapM (toDoc ff) <$> snd <$> parse ff p type Year = Int type Month = Int type Day = Int -- | Parse date to Ints -- TODO add hours, minutes and seconds parseDate' :: Lang -> Maybe Text -> IO (Maybe UTCTime, (Maybe Year, Maybe Month, Maybe Day)) parseDate' _ Nothing = pure (Nothing, (Nothing, Nothing, Nothing)) parseDate' l (Just txt) = do utcTime <- parseDate l txt let (UTCTime day _) = utcTime let (y,m,d) = DT.toGregorian day pure (Just utcTime, (Just (fromIntegral y), Just m,Just d)) toDoc :: FileFormat -> [(Text, Text)] -> IO HyperdataDocument -- TODO use language for RIS toDoc ff d = do let abstract = lookup "abstract" d let lang = maybe EN identity (join $ detectLang <$> (fmap (DT.take 50) abstract)) let dateToParse = DT.replace "-" " " <$> lookup "PY" d <> Just " " <> lookup "publication_date" d (utcTime, (pub_year, pub_month, pub_day)) <- parseDate' lang dateToParse pure $ HyperdataDocument (Just $ DT.pack $ show ff) (lookup "doi" d) (lookup "URL" d) Nothing Nothing Nothing (lookup "title" d) Nothing (lookup "authors" d) (lookup "source" d) (lookup "abstract" d) (fmap (DT.pack . show) utcTime) (pub_year) (pub_month) (pub_day) Nothing Nothing Nothing (Just $ (DT.pack . show) lang) parse :: FileFormat -> FilePath -> IO ([ParseError], [[(Text, Text)]]) parse ff fp = enrichWith identity <$> parse' ff fp enrichWith :: ([(DB.ByteString, DB.ByteString)] -> [(DB.ByteString, DB.ByteString)]) -> (a, [[[(DB.ByteString, DB.ByteString)]]]) -> (a, [[(Text, Text)]]) enrichWith f = second (map both' . map f . concat) where both' = map (both decodeUtf8) parse' :: FileFormat -> FilePath -> IO ([ParseError], [[[(DB.ByteString, DB.ByteString)]]]) parse' format path = do files <- case takeExtension path of ".zip" -> openZip path _ -> pure <$> clean <$> DB.readFile path partitionEithers <$> mapConcurrently (runParser format) files -- | withParser: -- According to the format of the text, choose the right parser. -- TODO withParser :: FileFormat -> Parser [Document] withParser :: FileFormat -> Parser [[(DB.ByteString, DB.ByteString)]] withParser WOS = WOS.parser withParser RIS = RIS.parser --withParser ODT = odtParser --withParser XML = xmlParser withParser _ = panic "[ERROR] Parser not implemented yet" runParser :: FileFormat -> DB.ByteString -> IO (Either String [[(DB.ByteString, DB.ByteString)]]) runParser format text = pure $ parseOnly (withParser format) text openZip :: FilePath -> IO [DB.ByteString] openZip fp = do entries <- withArchive fp (DM.keys <$> getEntries) bs <- mapConcurrently (\s -> withArchive fp (getEntry s)) entries pure bs clean :: DB.ByteString -> DB.ByteString clean txt = DBC.map clean' txt where clean' '’' = '\'' clean' '\r' = ' ' clean' c = c