Merge remote-tracking branch 'origin/dev-websockets-node-update' into dev

src/Gargantext/Database/Query/Table/Node/Update.hs

@@ -14,9 +14,11 @@ module Gargantext.Database.Query.Table.Node.Update (Update(..), update)
 
 import Data.Text qualified as DT
 import Database.PostgreSQL.Simple ( Only(Only) )
+import Gargantext.Core.AsyncUpdates.CentralExchange.Types qualified as CE
 import Gargantext.Core.Types (Name)
 import Gargantext.Database.Admin.Types.Node (NodeId, ParentId)
-import Gargantext.Database.Prelude (DBCmd, runPGSQuery)
+import Gargantext.Database.Query.Table.Node (getParentId)
+import Gargantext.Database.Prelude (Cmd, DBCmd, runPGSQuery)
 import Gargantext.Prelude
 
 -- import Data.ByteString
@@ -35,11 +37,25 @@ data Update = Rename NodeId Name
 unOnly :: Only a -> a
 unOnly (Only a) = a
 
--- TODO-ACCESS
-update :: Update -> DBCmd err [Int]
-update (Rename nId name) = map unOnly <$> runPGSQuery "UPDATE nodes SET name=? where id=? returning id"
-                                           (DT.take 255 name,nId)
-update (Move nId pId)    = map unOnly <$> runPGSQuery "UPDATE nodes SET parent_id= ? where id=? returning id"
-                                           (pId, nId)
-
+-- | Prefer this, because it notifies parents of the node change
+update :: Update -> Cmd err [Int]
+update u@(Rename nId _name) = do
+  ret <- update' u
+  mpId <- getParentId nId
+  case mpId of
+    Nothing -> pure ()
+    Just pId -> CE.ce_notify $ CE.UpdateTreeFirstLevel pId
+  return ret
+update u@(Move nId pId) = do
+  mpId <- getParentId nId
+  ret <- update' u
+  case mpId of
+    Nothing -> pure ()
+    Just pId' -> CE.ce_notify $ CE.UpdateTreeFirstLevel pId'
+  CE.ce_notify $ CE.UpdateTreeFirstLevel pId
+  return ret
 
+-- TODO-ACCESS
+update' :: Update -> DBCmd err [Int]
+update' (Rename nId name) = map unOnly <$> runPGSQuery "UPDATE nodes SET name=? where id=? returning id" (DT.take 255 name, nId)
+update' (Move nId pId)    = map unOnly <$> runPGSQuery "UPDATE nodes SET parent_id= ? where id=? returning id" (pId, nId)