2 Module : Gargantext.API.Node
3 Description : Server API
4 Copyright : (c) CNRS, 2017-Present
5 License : AGPL + CECILL v3
6 Maintainer : team@gargantext.org
7 Stability : experimental
10 -- TODO-SECURITY: Critical
12 -- TODO-ACCESS: CanGetNode
13 -- TODO-EVENTS: No events as this is a read only query.
16 -------------------------------------------------------------------
17 -- TODO-ACCESS: access by admin only.
18 -- At first let's just have an isAdmin check.
19 -- Later: check userId CanDeleteNodes Nothing
20 -- TODO-EVENTS: DeletedNodes [NodeId]
21 -- {"tag": "DeletedNodes", "nodes": [Int*]}
25 {-# OPTIONS_GHC -fno-warn-orphans #-}
27 {-# LANGUAGE DataKinds #-}
28 {-# LANGUAGE DeriveGeneric #-}
29 {-# LANGUAGE FlexibleContexts #-}
30 {-# LANGUAGE FlexibleInstances #-}
31 {-# LANGUAGE NoImplicitPrelude #-}
32 {-# LANGUAGE OverloadedStrings #-}
33 {-# LANGUAGE RankNTypes #-}
34 {-# LANGUAGE ScopedTypeVariables #-}
35 {-# LANGUAGE TemplateHaskell #-}
36 {-# LANGUAGE TypeOperators #-}
38 module Gargantext.API.Node
41 import Control.Lens ((.~), (?~))
42 import Control.Monad ((>>), forM)
43 import Control.Monad.IO.Class (liftIO)
44 import Data.Aeson (FromJSON, ToJSON)
46 import Data.Monoid (mempty)
48 import Data.Text (Text())
49 import Data.Time (UTCTime)
50 import GHC.Generics (Generic)
51 import Gargantext.API.Auth (withAccess, PathId(..))
52 import Gargantext.API.Metrics
53 import Gargantext.API.Ngrams (TabType(..), TableNgramsApi, apiNgramsTableCorpus, QueryParamR, TODO)
54 import Gargantext.API.Ngrams.NTree (MyTree)
55 import Gargantext.API.Search (SearchDocsAPI, searchDocs)
56 import Gargantext.API.Table
57 import Gargantext.API.Types
58 import Gargantext.Core.Types.Main (Tree, NodeTree, ListType)
59 import Gargantext.Database.Config (nodeTypeId)
60 import Gargantext.Database.Facet (FacetDoc, OrderBy(..))
61 import Gargantext.Database.Node.Children (getChildren)
62 import Gargantext.Database.Schema.Node ( getNodesWithParentId, getNode, getNode', deleteNode, deleteNodes, mkNodeWithParent, JSONB, HasNodeError(..))
63 import Gargantext.Database.Schema.NodeNode (nodeNodesCategory)
64 import Gargantext.Database.Tree (treeDB)
65 import Gargantext.Database.Types.Node
66 import Gargantext.Database.Utils -- (Cmd, CmdM)
67 import Gargantext.Prelude
68 import Gargantext.Prelude.Utils (sha)
69 import Gargantext.Viz.Chart
70 import Gargantext.Viz.Phylo.API (PhyloAPI, phyloAPI)
72 import Servant.Multipart
73 import Servant.Swagger (HasSwagger(toSwagger))
74 import Servant.Swagger.Internal
75 import Test.QuickCheck (elements)
76 import Test.QuickCheck.Arbitrary (Arbitrary, arbitrary)
77 import qualified Gargantext.Database.Node.Update as U (update, Update(..))
80 import qualified Gargantext.Text.List.Learn as Learn
81 import qualified Data.Vector as Vec
85 type NodesAPI = Delete '[JSON] Int
88 -- Be careful: really delete nodes
89 -- Access by admin only
90 nodesAPI :: [NodeId] -> GargServer NodesAPI
91 nodesAPI ids = deleteNodes ids
93 ------------------------------------------------------------------------
94 -- | TODO-ACCESS: access by admin only.
95 -- At first let's just have an isAdmin check.
96 -- Later: CanAccessAnyNode or (CanGetAnyNode, CanPutAnyNode)
97 -- To manage the Users roots
100 -- TODO needs design discussion.
101 type Roots = Get '[JSON] [Node HyperdataAny]
102 :<|> Put '[JSON] Int -- TODO
104 -- | TODO: access by admin only
105 roots :: GargServer Roots
106 roots = (liftIO (putStrLn ( "/user" :: Text)) >> getNodesWithParentId 0 Nothing)
107 :<|> pure (panic "not implemented yet") -- TODO use patch map to update what we need
109 -------------------------------------------------------------------
110 -- | Node API Types management
111 -- TODO-ACCESS : access by users
112 -- No ownership check is needed if we strictly follow the capability model.
114 -- CanGetNode (Node, Children, TableApi, TableNgramsApiGet, PairingApi, ChartApi,
116 -- CanRenameNode (or part of CanEditNode?)
117 -- CanCreateChildren (PostNodeApi)
118 -- CanEditNode / CanPutNode TODO not implemented yet
120 -- CanPatch (TableNgramsApi)
124 type NodeAPI a = Get '[JSON] (Node a)
125 :<|> "rename" :> RenameApi
126 :<|> PostNodeApi -- TODO move to children POST
128 :<|> Delete '[JSON] Int
129 :<|> "children" :> ChildrenApi a
132 :<|> "table" :> TableApi
133 :<|> "ngrams" :> TableNgramsApi
134 -- :<|> "pairing" :> PairingApi
136 :<|> "category" :> CatApi
137 :<|> "search" :> SearchDocsAPI
140 :<|> "metrics" :> ScatterAPI
141 :<|> "chart" :> ChartApi
143 :<|> "tree" :> TreeApi
144 :<|> "phylo" :> PhyloAPI
145 :<|> "add" :> NodeAddAPI
147 -- TODO-ACCESS: check userId CanRenameNode nodeId
148 -- TODO-EVENTS: NodeRenamed RenameNode or re-use some more general NodeEdited...
149 type RenameApi = Summary " Rename Node"
150 :> ReqBody '[JSON] RenameNode
153 type PostNodeApi = Summary " PostNode Node with ParentId as {id}"
154 :> ReqBody '[JSON] PostNode
155 :> Post '[JSON] [NodeId]
157 type ChildrenApi a = Summary " Summary children"
158 :> QueryParam "type" NodeType
159 :> QueryParam "offset" Int
160 :> QueryParam "limit" Int
161 :> Get '[JSON] [Node a]
163 ------------------------------------------------------------------------
164 type NodeNodeAPI a = Get '[JSON] (Node a)
166 nodeNodeAPI :: forall proxy a. (JSONB a, ToJSON a) => proxy a -> UserId -> CorpusId -> NodeId -> GargServer (NodeNodeAPI a)
167 nodeNodeAPI p uId cId nId = withAccess (Proxy :: Proxy (NodeNodeAPI a)) Proxy uId (PathNodeNode cId nId) nodeNodeAPI'
169 nodeNodeAPI' :: GargServer (NodeNodeAPI a)
170 nodeNodeAPI' = getNode nId p
174 ------------------------------------------------------------------------
175 -- TODO: make the NodeId type indexed by `a`, then we no longer need the proxy.
176 nodeAPI :: forall proxy a. (JSONB a, ToJSON a) => proxy a -> UserId -> NodeId -> GargServer (NodeAPI a)
177 nodeAPI p uId id = withAccess (Proxy :: Proxy (NodeAPI a)) Proxy uId (PathNode id) nodeAPI'
179 nodeAPI' :: GargServer (NodeAPI a)
180 nodeAPI' = getNode id p
184 :<|> deleteNodeApi id
185 :<|> getChildren id p
189 :<|> apiNgramsTableCorpus id
190 -- :<|> getPairing id
191 -- :<|> getTableNgramsDoc id
203 -- :<|> postUpload id
205 deleteNodeApi id' = do
207 if _node_typename node == nodeTypeId NodeUser
208 then panic "not allowed" -- TODO add proper Right Management Type
215 ------------------------------------------------------------------------
216 data RenameNode = RenameNode { r_name :: Text }
219 -- TODO unPrefix "r_" FromJSON, ToJSON, ToSchema, adapt frontend.
220 instance FromJSON RenameNode
221 instance ToJSON RenameNode
222 instance ToSchema RenameNode
223 instance Arbitrary RenameNode where
224 arbitrary = elements [RenameNode "test"]
225 ------------------------------------------------------------------------
226 data PostNode = PostNode { pn_name :: Text
227 , pn_typename :: NodeType}
230 -- TODO unPrefix "pn_" FromJSON, ToJSON, ToSchema, adapt frontend.
231 instance FromJSON PostNode
232 instance ToJSON PostNode
233 instance ToSchema PostNode
234 instance Arbitrary PostNode where
235 arbitrary = elements [PostNode "Node test" NodeCorpus]
237 ------------------------------------------------------------------------
238 type CatApi = Summary " To Categorize NodeNodes: 0 for delete, 1/null neutral, 2 favorite"
239 :> ReqBody '[JSON] NodesToCategory
242 data NodesToCategory = NodesToCategory { ntc_nodesId :: [NodeId]
243 , ntc_category :: Int
247 -- TODO unPrefix "ntc_" FromJSON, ToJSON, ToSchema, adapt frontend.
248 instance FromJSON NodesToCategory
249 instance ToJSON NodesToCategory
250 instance ToSchema NodesToCategory
252 catApi :: CorpusId -> GargServer CatApi
255 putCat :: CorpusId -> NodesToCategory -> Cmd err [Int]
256 putCat cId cs' = nodeNodesCategory $ map (\n -> (cId, n, ntc_category cs')) (ntc_nodesId cs')
258 ------------------------------------------------------------------------
259 -- TODO adapt FacetDoc -> ListDoc (and add type of document as column)
260 type PairingApi = Summary " Pairing API"
261 :> QueryParam "view" TabType
262 -- TODO change TabType -> DocType (CorpusId for pairing)
263 :> QueryParam "offset" Int
264 :> QueryParam "limit" Int
265 :> QueryParam "order" OrderBy
266 :> Get '[JSON] [FacetDoc]
268 ------------------------------------------------------------------------
269 type ChartApi = Summary " Chart API"
270 :> QueryParam "from" UTCTime
271 :> QueryParam "to" UTCTime
272 :> Get '[JSON] (ChartMetrics Histo)
274 type PieApi = Summary " Chart API"
275 :> QueryParam "from" UTCTime
276 :> QueryParam "to" UTCTime
277 :> QueryParamR "ngramsType" TabType
278 :> Get '[JSON] (ChartMetrics Histo)
280 type TreeApi = Summary " Tree API"
281 :> QueryParam "from" UTCTime
282 :> QueryParam "to" UTCTime
283 :> QueryParamR "ngramsType" TabType
284 :> QueryParamR "listType" ListType
285 :> Get '[JSON] (ChartMetrics [MyTree])
287 -- Depending on the Type of the Node, we could post
288 -- New documents for a corpus
289 -- New map list terms
290 -- :<|> "process" :> MultipartForm MultipartData :> Post '[JSON] Text
292 -- To launch a query and update the corpus
293 -- :<|> "query" :> Capture "string" Text :> Get '[JSON] Text
295 ------------------------------------------------------------------------
298 NOTE: These instances are not necessary. However, these messages could be part
299 of a display function for NodeError/TreeError.
300 instance HasNodeError ServantErr where
301 _NodeError = prism' mk (const Nothing) -- panic "HasNodeError ServantErr: not a prism")
303 e = "Gargantext NodeError: "
304 mk NoListFound = err404 { errBody = e <> "No list found" }
305 mk NoRootFound = err404 { errBody = e <> "No Root found" }
306 mk NoCorpusFound = err404 { errBody = e <> "No Corpus found" }
307 mk NoUserFound = err404 { errBody = e <> "No User found" }
309 mk MkNode = err500 { errBody = e <> "Cannot mk node" }
310 mk NegativeId = err500 { errBody = e <> "Node with negative Id" }
311 mk UserNoParent = err500 { errBody = e <> "Should not have parent"}
312 mk HasParent = err500 { errBody = e <> "NodeType has parent" }
313 mk NotImplYet = err500 { errBody = e <> "Not implemented yet" }
314 mk ManyParents = err500 { errBody = e <> "Too many parents" }
315 mk ManyNodeUsers = err500 { errBody = e <> "Many userNode/user" }
317 instance HasTreeError ServantErr where
318 _TreeError = prism' mk (const Nothing) -- panic "HasTreeError ServantErr: not a prism")
321 mk NoRoot = err404 { errBody = e <> "Root node not found" }
322 mk EmptyRoot = err500 { errBody = e <> "Root node should not be empty" }
323 mk TooManyRoots = err500 { errBody = e <> "Too many root nodes" }
326 type TreeAPI = Get '[JSON] (Tree NodeTree)
328 treeAPI :: NodeId -> GargServer TreeAPI
331 ------------------------------------------------------------------------
332 -- | Check if the name is less than 255 char
333 rename :: NodeId -> RenameNode -> Cmd err [Int]
334 rename nId (RenameNode name') = U.update (U.Rename nId name')
336 postNode :: HasNodeError err => UserId -> NodeId -> PostNode -> Cmd err [NodeId]
337 postNode uId pId (PostNode nodeName nt) = mkNodeWithParent nt (Just pId) uId nodeName
339 putNode :: NodeId -> Cmd err Int
340 putNode = undefined -- TODO
342 query :: Monad m => Text -> m Text
345 -------------------------------------------------------------
347 data FileType = CSV | PresseRIS
348 deriving (Eq, Show, Generic)
350 instance ToSchema FileType
351 instance Arbitrary FileType
353 arbitrary = elements [CSV, PresseRIS]
354 instance ToParamSchema FileType
356 instance ToParamSchema (MultipartData Mem) where
357 toParamSchema _ = toParamSchema (Proxy :: Proxy TODO)
359 instance FromHttpApiData FileType
361 parseUrlPiece "CSV" = pure CSV
362 parseUrlPiece "PresseRis" = pure PresseRIS
363 parseUrlPiece _ = pure CSV -- TODO error here
366 instance (ToParamSchema a, HasSwagger sub) =>
367 HasSwagger (MultipartForm tag a :> sub) where
369 toSwagger _ = toSwagger (Proxy :: Proxy sub)
374 & schema .~ ParamOther sch
376 & in_ .~ ParamFormData
377 & paramSchema .~ toParamSchema (Proxy :: Proxy a)
379 type NodeAddAPI = "file" :> Summary "Node add API"
382 nodeAddAPI :: NodeId -> GargServer NodeAddAPI
383 nodeAddAPI id = postUpload id
385 type UploadAPI = Summary "Upload file(s) to a corpus"
386 :> MultipartForm Mem (MultipartData Mem)
387 :> QueryParam "fileType" FileType
388 :> Post '[JSON] [Hash]
390 --postUpload :: NodeId -> Maybe FileType -> GargServer UploadAPI
391 --postUpload :: NodeId -> GargServer UploadAPI
392 postUpload :: NodeId -> MultipartData Mem -> Maybe FileType -> Cmd err [Hash]
393 postUpload _ _ Nothing = panic "fileType is a required parameter"
394 postUpload _ multipartData (Just fileType) = do
395 putStrLn $ "File Type: " <> (show fileType)
397 putStrLn ("Inputs:" :: Text)
398 forM (inputs multipartData) $ \input -> do
399 putStrLn $ ("iName " :: Text) <> (iName input)
400 <> ("iValue " :: Text) <> (iValue input)
403 _ <- forM (files multipartData) $ \file -> do
404 let content = fdPayload file
405 putStrLn $ ("XXX " :: Text) <> (fdFileName file)
406 putStrLn $ ("YYY " :: Text) <> cs content
408 -- is <- inputs multipartData
410 pure $ map (sha . cs) is