Skip to content

haskell-gargantext
haskell-gargantext
Commit 640a4549 authored by Alexandre Delanoë's avatar Alexandre Delanoë
Browse files
Options

[READ] Code clean

parent ccf15753
Pipeline #3598 failed with stage
    in 74 minutes
    Show whitespace changes
    Inline Side-by-side
    Showing with 39 additions and 60 deletions
    src/Gargantext/Core/NodeStory.hs
    View file @ 640a4549
    ......@@ -70,7 +70,6 @@ module Gargantext.Core.NodeStory
    , nse_archive_saver_immediate
    , nse_var
    , unNodeStory
    , getNodeArchiveHistory
    , getNodesArchiveHistory
    , Archive(..)
    , initArchive
    ......@@ -94,37 +93,37 @@ module Gargantext.Core.NodeStory
    where
    -- import Debug.Trace (traceShow)
    import Control.Debounce (mkDebounce, defaultDebounceSettings, debounceFreq, debounceAction)
    import Codec.Serialise.Class
    import Control.Concurrent (MVar(), newMVar, modifyMVar_)
    import Control.Debounce (mkDebounce, defaultDebounceSettings, debounceFreq, debounceAction)
    import Control.Exception (catch, throw, SomeException(..))
    import Control.Lens (makeLenses, Getter, (^.), (.~), (%~), _Just, at, traverse, view)
    import Control.Monad.Except
    import Control.Monad.Reader
    import Data.Aeson hiding ((.=), decode)
    import Data.ByteString.Char8 (hPutStrLn)
    import Data.HashMap.Strict (HashMap)
    import Data.Map.Strict (Map)
    import Data.Maybe (catMaybes)
    import Data.Monoid
    import Data.Pool (Pool, withResource)
    import Data.Profunctor.Product.TH (makeAdaptorAndInstance)
    import Data.Semigroup
    import Database.PostgreSQL.Simple.SqlQQ (sql)
    import Database.PostgreSQL.Simple.FromField (FromField(fromField), fromJSONField)
    import Data.Profunctor.Product.TH (makeAdaptorAndInstance)
    import Database.PostgreSQL.Simple.SqlQQ (sql)
    import Database.PostgreSQL.Simple.Types (Values(..), QualifiedIdentifier(..))
    import GHC.Generics (Generic)
    import Data.HashMap.Strict (HashMap)
    import qualified Data.HashMap.Strict as HashMap
    import Gargantext.Database.Schema.Ngrams (NgramsType)
    import Gargantext.API.Ngrams.Types
    import Gargantext.Core.Types (ListId, NodeId(..), NodeType)
    import Gargantext.Core.Utils.Prefix (unPrefix)
    import Gargantext.Database.Admin.Config (nodeTypeId)
    import Gargantext.Database.Prelude (CmdM', HasConnectionPool(..), HasConfig)
    import Gargantext.Database.Query.Table.Node.Error (HasNodeError())
    import Gargantext.Database.Schema.Ngrams (NgramsType)
    import Gargantext.Prelude
    import Opaleye (DefaultFromField(..), SqlJsonb, fromPGSFromField)
    import Database.PostgreSQL.Simple.Types (Values(..), QualifiedIdentifier(..))
    import System.IO (stderr)
    import qualified Data.HashMap.Strict as HashMap
    import qualified Data.Map.Strict as Map
    import qualified Data.Map.Strict.Patch as PM
    import qualified Data.Set as Set
    ......@@ -258,8 +257,6 @@ initNodeListStoryMock = NodeStory $ Map.singleton nodeListId archive
    ]
    ------------------------------------------------------------------------
    ------------------------------------------------------------------------
    -- | Lenses at the bottom of the file because Template Haskell would reorder order of execution in others cases
    makeLenses ''NodeStoryEnv
    ......@@ -293,7 +290,8 @@ type ArchiveList = Archive NgramsState' NgramsStatePatch'
    -- DB stuff
    runPGSExecute :: (PGS.ToRow q) => PGS.Connection -> PGS.Query -> q -> IO Int64
    runPGSExecute :: (PGS.ToRow q)
    => PGS.Connection -> PGS.Query -> q -> IO Int64
    runPGSExecute c qs a = catch (PGS.execute c qs a) printError
    where
    printError (SomeException e) = do
    ......@@ -301,7 +299,8 @@ runPGSExecute c qs a = catch (PGS.execute c qs a) printError
    _ <- panic $ Text.pack $ show e
    throw (SomeException e)
    runPGSExecuteMany :: (PGS.ToRow q) => PGS.Connection -> PGS.Query -> [q] -> IO Int64
    runPGSExecuteMany :: (PGS.ToRow q)
    => PGS.Connection -> PGS.Query -> [q] -> IO Int64
    runPGSExecuteMany c qs a = catch (PGS.executeMany c qs a) printError
    where
    printError (SomeException e) = do
    ......@@ -309,7 +308,8 @@ runPGSExecuteMany c qs a = catch (PGS.executeMany c qs a) printError
    _ <- panic $ Text.pack $ show e
    throw (SomeException e)
    runPGSQuery :: (PGS.FromRow r, PGS.ToRow q) => PGS.Connection -> PGS.Query -> q -> IO [r]
    runPGSQuery :: (PGS.FromRow r, PGS.ToRow q)
    => PGS.Connection -> PGS.Query -> q -> IO [r]
    runPGSQuery c q a = catch (PGS.query c q a) printError
    where
    printError (SomeException e) = do
    ......@@ -319,22 +319,26 @@ runPGSQuery c q a = catch (PGS.query c q a) printError
    runPGSAdvisoryLock :: PGS.Connection -> Int -> IO ()
    runPGSAdvisoryLock c id = do
    _ <- runPGSQuery c [sql| SELECT pg_advisory_lock(?) |] (PGS.Only id) :: IO [PGS.Only ()]
    _ <- runPGSQuery c [sql| SELECT pg_advisory_lock(?) |]
    (PGS.Only id) :: IO [PGS.Only ()]
    pure ()
    runPGSAdvisoryUnlock :: PGS.Connection -> Int -> IO ()
    runPGSAdvisoryUnlock c id = do
    _ <- runPGSQuery c [sql| SELECT pg_advisory_unlock(?) |] (PGS.Only id) :: IO [PGS.Only Bool]
    _ <- runPGSQuery c [sql| SELECT pg_advisory_unlock(?) |]
    (PGS.Only id) :: IO [PGS.Only Bool]
    pure ()
    runPGSAdvisoryXactLock :: PGS.Connection -> Int -> IO ()
    runPGSAdvisoryXactLock c id = do
    _ <- runPGSQuery c [sql| SELECT pg_advisory_xact_lock(?) |] (PGS.Only id) :: IO [PGS.Only ()]
    _ <- runPGSQuery c [sql| SELECT pg_advisory_xact_lock(?) |]
    (PGS.Only id) :: IO [PGS.Only ()]
    pure ()
    nodeExists :: PGS.Connection -> NodeId -> IO Bool
    nodeExists c nId = (== [PGS.Only True])
    <$> runPGSQuery c [sql| SELECT true FROM nodes WHERE id = ? LIMIT 1 |] (PGS.Only nId)
    <$> runPGSQuery c [sql| SELECT true FROM nodes WHERE id = ? LIMIT 1 |]
    (PGS.Only nId)
    getNodesIdWithType :: PGS.Connection -> NodeType -> IO [NodeId]
    getNodesIdWithType c nt = do
    ......@@ -345,44 +349,22 @@ getNodesIdWithType c nt = do
    query = [sql| SELECT id FROM nodes WHERE typename = ? |]
    -- nodeStoryTable :: Table NodeStoryRead NodeStoryWrite
    -- nodeStoryTable =
    -- Table "node_stories"
    -- ( pNodeStory NodeStoryDB { node_id = tableField "node_id"
    -- , version = tableField "version"
    -- , ngrams_type_id = tableField "ngrams_type_id"
    -- , ngrams_id = tableField "ngrams_id"
    -- , ngrams_repo_element = tableField "ngrams_repo_element"
    -- } )
    -- nodeStoryArchiveTable :: Table NodeStoryArchiveRead NodeStoryArchiveWrite
    -- nodeStoryArchiveTable =
    -- Table "node_story_archive_history"
    -- ( pNodeArchiveStory NodeStoryArchiveDB { a_node_id = tableField "node_id"
    -- , archive = tableField "archive" } )
    -- nodeStorySelect :: Select NodeStoryRead
    -- nodeStorySelect = selectTable nodeStoryTable
    -- NOTE "first patch in the _a_history list is the most recent"
    getNodeArchiveHistory :: PGS.Connection -> NodeId -> IO [NgramsStatePatch']
    getNodeArchiveHistory c nodeId = do
    as <- runPGSQuery c query (PGS.Only nodeId) :: IO [(TableNgrams.NgramsType, NgramsTerm, NgramsPatch)]
    pure $ (\(ngramsType, terms, patch) -> fst $ PM.singleton ngramsType (NgramsTablePatch $ fst $ PM.singleton terms patch)) <$> as
    where
    query :: PGS.Query
    query = [sql| SELECT ngrams_type_id, terms, patch
    FROM node_story_archive_history
    JOIN ngrams ON ngrams.id = ngrams_id
    WHERE node_id = ?
    ORDER BY (version, node_story_archive_history.id) DESC |]
    -- getNodesArchiveHistory :: PGS.Connection -> [NodeId] -> IO [(Int, NgramsStatePatch')]
    getNodesArchiveHistory :: PGS.Connection -> [NodeId] -> IO [(NodeId, (Map NgramsType [HashMap NgramsTerm NgramsPatch]))]
    -- /!\ This function is using an hard coded parameter
    -- which depends on the Ngrams List Flow
    -- Version > 5 is hard coded because by default
    -- first version of history of manual change is 6
    getNodesArchiveHistory :: PGS.Connection
    -> [NodeId]
    -> IO [(NodeId, (Map NgramsType [HashMap NgramsTerm NgramsPatch]))]
    getNodesArchiveHistory c nodesId = do
    as <- runPGSQuery c query (PGS.Only $ Values fields nodesId) :: IO [(Int, TableNgrams.NgramsType, NgramsTerm, NgramsPatch)]
    pure $ map (\(nId, ngramsType, terms, patch) -> (NodeId nId, Map.singleton ngramsType [HashMap.singleton terms patch])) as
    as <- runPGSQuery c query (PGS.Only $ Values fields nodesId)
    :: IO [(Int, TableNgrams.NgramsType, NgramsTerm, NgramsPatch)]
    pure $ map (\(nId, ngramsType, terms, patch)
    -> ( NodeId nId
    , Map.singleton ngramsType [HashMap.singleton terms patch]
    )
    ) as
    where
    fields = [QualifiedIdentifier Nothing "int4"]
    ......@@ -396,9 +378,6 @@ getNodesArchiveHistory c nodesId = do
    ORDER BY (version, node_story_archive_history.id) DESC
    |]
    -- Version > 5 is hard coded because by default
    -- first version of history of manual change is 6
    ngramsIdQuery :: PGS.Query
    ngramsIdQuery = [sql| SELECT id FROM ngrams WHERE terms = ? |]
    ......
    Markdown is supported
    0% or
    You are about to add 0 people to the discussion. Proceed with caution.
    Finish editing this message first!
    Please register or to comment