{-# LANGUAGE OverloadedLists #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE RankNTypes #-}

module Database.Bloodhound.ElasticSearch7.Requests
  ( module Reexport,
    openPointInTime,
    closePointInTime,
  )
where

import Data.Aeson
import Database.Bloodhound.Client.Cluster
import Database.Bloodhound.Common.Requests as Reexport
import Database.Bloodhound.ElasticSearch7.Types
import Database.Bloodhound.Internal.Utils.Requests
import Prelude hiding (filter, head)

-- | 'openPointInTime' opens a point in time for an index given an 'IndexName'.
-- Note that the point in time should be closed with 'closePointInTime' as soon
-- as it is no longer needed.
--
-- For more information see
-- <https://www.elastic.co/guide/en/elasticsearch/reference/current/point-in-time-api.html>.
openPointInTime ::
  IndexName ->
  BHRequest StatusDependant (ParsedEsResponse OpenPointInTimeResponse)
openPointInTime :: IndexName
-> BHRequest
     StatusDependant (ParsedEsResponse OpenPointInTimeResponse)
openPointInTime IndexName
indexName =
  BHRequest StatusDependant OpenPointInTimeResponse
-> BHRequest
     StatusDependant (ParsedEsResponse OpenPointInTimeResponse)
forall a parsingContext.
BHRequest parsingContext a
-> BHRequest StatusDependant (ParsedEsResponse a)
withBHResponseParsedEsResponse (BHRequest StatusDependant OpenPointInTimeResponse
 -> BHRequest
      StatusDependant (ParsedEsResponse OpenPointInTimeResponse))
-> BHRequest StatusDependant OpenPointInTimeResponse
-> BHRequest
     StatusDependant (ParsedEsResponse OpenPointInTimeResponse)
forall a b. (a -> b) -> a -> b
$ forall contextualized body.
(ParseBHResponse contextualized, FromJSON body) =>
Endpoint -> ByteString -> BHRequest contextualized body
post @StatusDependant [IndexName -> Text
unIndexName IndexName
indexName, Text
Item Endpoint
"_pit?keep_alive=1m"] ByteString
emptyBody

-- | 'closePointInTime' closes a point in time given a 'ClosePointInTime'.
--
-- For more information see
-- <https://www.elastic.co/guide/en/elasticsearch/reference/current/point-in-time-api.html>.
closePointInTime ::
  ClosePointInTime ->
  BHRequest StatusDependant (ParsedEsResponse ClosePointInTimeResponse)
closePointInTime :: ClosePointInTime
-> BHRequest
     StatusDependant (ParsedEsResponse ClosePointInTimeResponse)
closePointInTime ClosePointInTime
q = do
  BHRequest StatusDependant ClosePointInTimeResponse
-> BHRequest
     StatusDependant (ParsedEsResponse ClosePointInTimeResponse)
forall a parsingContext.
BHRequest parsingContext a
-> BHRequest StatusDependant (ParsedEsResponse a)
withBHResponseParsedEsResponse (BHRequest StatusDependant ClosePointInTimeResponse
 -> BHRequest
      StatusDependant (ParsedEsResponse ClosePointInTimeResponse))
-> BHRequest StatusDependant ClosePointInTimeResponse
-> BHRequest
     StatusDependant (ParsedEsResponse ClosePointInTimeResponse)
forall a b. (a -> b) -> a -> b
$ forall contextualized body.
(ParseBHResponse contextualized, FromJSON body) =>
Endpoint -> ByteString -> BHRequest contextualized body
deleteWithBody @StatusDependant [Text
Item Endpoint
"_pit"] (ClosePointInTime -> ByteString
forall a. ToJSON a => a -> ByteString
encode ClosePointInTime
q)