[GarGraph] Missing File. GarGraph = Garage à graphs.

src/Gargantext/Database/Triggers.hs

+{-|
+Module      : Gargantext.Database.Triggers
+Description : Triggers configuration
+Copyright   : (c) CNRS, 2017-Present
+License     : AGPL + CECILL v3
+Maintainer  : team@gargantext.org
+Stability   : experimental
+Portability : POSIX
+
+Ngrams by node enable contextual metrics.
+
+-}
+
+{-# LANGUAGE QuasiQuotes       #-}
+{-# LANGUAGE NoImplicitPrelude #-}
+{-# LANGUAGE OverloadedStrings #-}
+{-# LANGUAGE RankNTypes        #-}
+
+module Gargantext.Database.Triggers
+  where
+
+import Database.PostgreSQL.Simple.SqlQQ (sql)
+-- import Database.PostgreSQL.Simple.Types (Values(..), QualifiedIdentifier(..))
+import Gargantext.Database.Config (nodeTypeId)
+import Gargantext.Database.Types.Node -- (ListId, CorpusId, NodeId)
+import Gargantext.Database.Utils (Cmd, runPGSQuery)
+import Gargantext.Prelude
+import qualified Database.PostgreSQL.Simple as DPS
+
+------------------------------------------------------------------------
+
+type MasterListId = ListId
+
+insertOccsUpdates :: UserCorpusId -> MasterListId -> Cmd err [DPS.Only Int]
+insertOccsUpdates cId lId = runPGSQuery query (cId, lId, nodeTypeId NodeList, nodeTypeId NodeDocument)
+  where
+    query :: DPS.Query
+    query = [sql|
+              INSERT INTO node_node_ngrams (node1_id, node2_id, ngrams_id, ngrams_type, weight)
+                SELECT nn.node1_id, lists.id, nnn.ngrams_id, count(*), 1  -- type of score
+                   FROM node_node_ngrams nnn
+                   INNER JOIN nodes_nodes nn    ON nn.node2_id = nnn.node2_id
+                   INNER JOIN nodes       docs  ON docs.id     = nnn.node2_id
+                   INNER JOIN nodes       lists ON lists.parent_id = nn.node1_id
+                  -- WHERE nn.node1_id  = NEW.node1_id -- .node1_id -- corpus_id
+                  WHERE nn.node1_id  = ? -- .node1_id -- corpus_id
+                    AND nnn.node1_id in (?, lists.id)  -- (masterList_id, userLists)
+                    AND lists.typename = ?
+                    AND docs.typename  = ?
+                  GROUP BY nn.node1_id, lists.id, nnn.ngrams_id
+               ON CONFLICT (node1_id, node2_id, ngrams_id, ngrams_type)
+                  DO UPDATE SET weight = excluded.weight +1; -- TOCHECK
+  |]
+
+
+
+triggerOccsUpdates :: CorpusId -> ListId -> Cmd err [DPS.Only Int]
+triggerOccsUpdates cId lId = runPGSQuery query (cId, lId, nodeTypeId NodeList, nodeTypeId NodeDocument)
+  where
+    query :: DPS.Query
+    query = [sql|
+                drop trigger trigger_occs on nodes_nodes;
+                CREATE OR REPLACE FUNCTION occs_update() RETURNS trigger AS
+                  $$
+                      BEGIN
+                      IF TG_OP = 'UPDATE' THEN
+                      INSERT INTO node_node_ngrams (node1_id, node2_id, ngrams_id, ngrams_type, weight)
+                      -- TODO edge_type instead of ngrams_type
+                        SELECT nn.node1_id, lists.id, nnn.ngrams_id, count(*), 1  -- type of score
+                           FROM node_node_ngrams nnn
+                           INNER JOIN nodes_nodes nn    ON nn.node2_id = nnn.node2_id
+                           INNER JOIN nodes       docs  ON docs.id     = nnn.node2_id
+                           INNER JOIN nodes       lists ON lists.parent_id = nn.node1_id
+                          -- WHERE nn.node1_id  = NEW.node1_id -- .node1_id -- corpus_id
+                          WHERE nn.node1_id  = ? -- .node1_id -- corpus_id
+                            AND nnn.node1_id in (?, lists.id)  -- (masterList_id, userLists)
+                            AND lists.typename = ?
+                            AND docs.typename  = ?
+                          GROUP BY nn.node1_id, lists.id, nnn.ngrams_id
+                       ON CONFLICT (node1_id, node2_id, ngrams_id, ngrams_type)
+                          DO UPDATE SET weight = excluded.weight;
+                      END IF;
+                    RETURN NULL;
+                END $$
+                LANGUAGE plpgsql;
+
+                CREATE TRIGGER trigger_occs
+                  AFTER UPDATE ON nodes_nodes
+                  REFERENCING NEW TABLE AS NEW
+                  FOR EACH STATEMENT
+                  EXECUTE PROCEDURE occs_update();
+
+                update nodes_nodes SET node1_id = node1_id;
+  |]
+