src/Gargantext/API/Node/Contact.hs

   1 {-|
   2 Module      : Gargantext.API.Node.Contact
   3 Description :
   4 Copyright   : (c) CNRS, 2017-Present
   5 License     : AGPL + CECILL v3
   6 Maintainer  : team@gargantext.org
   7 Stability   : experimental
   8 Portability : POSIX
   9
  10 -}
  11
  12 {-# OPTIONS_GHC -fno-warn-orphans #-}
  13
  14 {-# LANGUAGE ConstraintKinds      #-}
  15 {-# LANGUAGE KindSignatures       #-}
  16 {-# LANGUAGE ScopedTypeVariables  #-}
  17 {-# LANGUAGE TemplateHaskell      #-}
  18 {-# LANGUAGE TypeFamilies         #-}
  19 {-# LANGUAGE TypeOperators        #-}
  20 {-# LANGUAGE UndecidableInstances #-}
  21
  22
  23 module Gargantext.API.Node.Contact
  24       where
  25
  26 import Data.Aeson
  27 import Data.Either (Either(Right))
  28 import Data.Maybe (Maybe(..))
  29 import Data.Swagger
  30 import Data.Text (Text)
  31 import GHC.Generics (Generic)
  32 import Servant
  33 import Servant.Job.Async (JobFunction(..), serveJobsAPI)
  34 import Test.QuickCheck (elements)
  35 import Test.QuickCheck.Arbitrary
  36
  37 import Gargantext.API.Admin.Orchestrator.Types (JobLog(..), AsyncJobs)
  38 import Gargantext.API.Admin.Types (HasSettings)
  39 import Gargantext.API.Node
  40 import Gargantext.API.Prelude (GargServer, simuLogs)
  41 import Gargantext.Core (Lang(..))
  42 import Gargantext.Core.Text.Terms (TermType(..))
  43 import Gargantext.Core.Types.Individu (User(..))
  44 import Gargantext.Database.Action.Flow (flow)
  45 import Gargantext.Database.Action.Flow.Types (FlowCmdM)
  46 import Gargantext.Database.Admin.Types.Hyperdata (HyperdataAnnuaire(..), HyperdataContact)
  47 import Gargantext.Database.Admin.Types.Hyperdata.Contact (hyperdataContact)
  48 import Gargantext.Database.Admin.Types.Node
  49 import Gargantext.Prelude (($), liftBase, (.), printDebug, pure)
  50
  51 ------------------------------------------------------------------------
  52 type API = "contact" :> Summary "Contact endpoint"
  53             :> API_Async
  54           :<|> Capture "contact_id" NodeId
  55             :> NodeNodeAPI HyperdataContact
  56
  57
  58 api :: UserId -> CorpusId -> GargServer API
  59 api uid cid =  (api_async   (RootId (NodeId uid)) cid)
  60           :<|> (nodeNodeAPI (Proxy :: Proxy HyperdataContact) uid cid)
  61
  62 type API_Async = AsyncJobs JobLog '[JSON] AddContactParams JobLog
  63 ------------------------------------------------------------------------
  64 data AddContactParams = AddContactParams         { firstname :: !Text, lastname :: !Text }
  65                       | AddContactParamsAdvanced { firstname :: !Text
  66                                                  , lastname  :: !Text
  67                                                  -- TODO add others fields
  68                                                  }
  69     deriving (Generic)
  70
  71 ----------------------------------------------------------------------
  72 api_async :: User -> NodeId -> GargServer API_Async
  73 api_async u nId =
  74   serveJobsAPI $
  75     JobFunction (\p log ->
  76       let
  77         log' x = do
  78           printDebug "addContact" x
  79           liftBase $ log x
  80       in addContact u nId p (liftBase . log')
  81       )
  82
  83 addContact :: (HasSettings env, FlowCmdM env err m)
  84     => User
  85     -> NodeId
  86     -> AddContactParams
  87     -> (JobLog -> m ())
  88     -> m JobLog
  89 addContact u nId (AddContactParams fn ln) logStatus = do
  90
  91   logStatus JobLog { _scst_succeeded = Just 1
  92                    , _scst_failed    = Just 0
  93                    , _scst_remaining = Just 1
  94                    , _scst_events    = Just []
  95                    }
  96   _ <- flow (Nothing :: Maybe HyperdataAnnuaire) u (Right [nId]) (Multi EN) [[hyperdataContact fn ln]]
  97
  98   pure  JobLog { _scst_succeeded = Just 2
  99                , _scst_failed    = Just 0
 100                , _scst_remaining = Just 0
 101                , _scst_events    = Just []
 102                }
 103 addContact _uId _nId _p logStatus = do
 104   simuLogs logStatus 10
 105
 106 ------------------------------------------------------------------------
 107 -- TODO unPrefix "pn_" FromJSON, ToJSON, ToSchema, adapt frontend.
 108 instance FromJSON  AddContactParams where
 109   parseJSON = genericParseJSON (defaultOptions { sumEncoding = ObjectWithSingleField })
 110
 111 instance ToJSON    AddContactParams where
 112   toJSON = genericToJSON (defaultOptions { sumEncoding = ObjectWithSingleField })
 113
 114 instance ToSchema  AddContactParams
 115 instance Arbitrary AddContactParams where
 116   arbitrary = elements [AddContactParams "Pierre" "Dupont"]
 117
 118 ------------------------------------------------------------------------