Merge remote-tracking branch 'origin/242-dev-phylo-websearch' into dev

src/Gargantext/API/GraphQL/Context.hs

@@ -22,7 +22,8 @@ import Data.Morpheus.Types
   , ResolverM
   , QUERY
   )
-import Data.Text (pack)
+import Data.Text (pack, unpack)
+import qualified Data.Text as Text
 import Data.Time.Format.ISO8601 (iso8601Show)
 import Gargantext.API.Admin.Types (HasSettings)
 import Gargantext.API.Errors.Types ( BackendInternalError )
@@ -94,6 +95,7 @@ data ContextsForNgramsArgs
   = ContextsForNgramsArgs
     { corpus_id    :: Int
     , ngrams_terms :: [Text]
+    , and_logic    :: Text
     } deriving (Generic, GQLType)
 
 data NodeContextCategoryMArgs = NodeContextCategoryMArgs
@@ -123,8 +125,8 @@ resolveNodeContext NodeContextArgs { context_id, node_id } =
 resolveContextsForNgrams
   :: (CmdCommon env)
   => ContextsForNgramsArgs -> GqlM e env [ContextGQL]
-resolveContextsForNgrams ContextsForNgramsArgs { corpus_id, ngrams_terms } =
-  dbContextForNgrams corpus_id ngrams_terms
+resolveContextsForNgrams ContextsForNgramsArgs { corpus_id, ngrams_terms, and_logic } =
+  dbContextForNgrams corpus_id ngrams_terms and_logic
 
 resolveContextNgrams
   :: (CmdCommon env)
@@ -149,9 +151,9 @@ dbNodeContext context_id node_id = do
 -- | Returns list of `ContextGQL` for given ngrams in given corpus id.
 dbContextForNgrams
   :: (CmdCommon env)
-  => Int -> [Text] -> GqlM e env [ContextGQL]
-dbContextForNgrams node_id ngrams_terms = do
-  contextsForNgramsTerms <- lift $ getContextsForNgramsTerms (UnsafeMkNodeId node_id) ngrams_terms
+  => Int -> [Text] -> Text -> GqlM e env [ContextGQL]
+dbContextForNgrams node_id ngrams_terms and_logic = do
+  contextsForNgramsTerms <- lift $ getContextsForNgramsTerms (UnsafeMkNodeId node_id) ngrams_terms ( readMaybe $ unpack $ Text.toTitle and_logic )
   --lift $ printDebug "[dbContextForNgrams] contextsForNgramsTerms" contextsForNgramsTerms
   pure $ toContextGQL <$> contextsForNgramsTerms
 

src/Gargantext/Database/Query/Table/NodeContext.hs

@@ -152,8 +152,53 @@ data ContextForNgramsTerms =
 getContextsForNgramsTerms :: HasNodeError err
                           => NodeId
                           -> [Text]
+                          -> Maybe Bool
                           -> DBCmd err [ContextForNgramsTerms]
-getContextsForNgramsTerms cId ngramsTerms = do
+getContextsForNgramsTerms cId ngramsTerms (Just True) = do
+  let terms_length = length ngramsTerms
+  res <- runPGSQuery query (cId, PGS.In ngramsTerms, terms_length)
+  pure $ (\( _cfnt_nodeId
+           , _cfnt_hash
+           , _cfnt_nodeTypeId
+           , _cfnt_userId
+           , _cfnt_parentId
+           , _cfnt_c_title
+           , _cfnt_date
+           , _cfnt_hyperdata
+           , _cfnt_score
+           , _cfnt_category) -> ContextForNgramsTerms { .. }) <$> res
+  where
+    query :: PGS.Query
+    query = [sql| SELECT t.id, t.hash_id, t.typename, t.user_id, t.parent_id, t.name, t.date, t.hyperdata, t.score, t.category
+                FROM (
+                  SELECT DISTINCT ON (contexts.id)
+                       contexts.id AS id,
+                       hash_id,
+                       typename,
+                       user_id,
+                       parent_id,
+                       name,
+                       date,
+                       hyperdata,
+                       nodes_contexts.score AS score,
+                       nodes_contexts.category AS category --,
+                       -- context_node_ngrams.doc_count AS doc_count
+                    FROM contexts
+                    JOIN context_node_ngrams ON contexts.id = context_node_ngrams.context_id
+                    JOIN nodes_contexts ON contexts.id = nodes_contexts.context_id
+                    JOIN ngrams ON context_node_ngrams.ngrams_id = ngrams.id
+                    WHERE nodes_contexts.node_id = ?
+                     AND ngrams.terms IN ?
+                    GROUP BY
+                      contexts.id,
+                      nodes_contexts.score,
+                      nodes_contexts.category
+                    HAVING COUNT(DISTINCT ngrams.terms) = ?) t
+                   -- ORDER BY t.doc_count DESC
+                   ORDER BY t.score DESC
+                   |]
+
+getContextsForNgramsTerms cId ngramsTerms _ = do
   res <- runPGSQuery query (cId, PGS.In ngramsTerms)
   pure $ (\( _cfnt_nodeId
            , _cfnt_hash