open Piaf
open Shared

type pool = (Query.conn, Caqti_error.t) Caqti_eio.Pool.t

(* This is the main handler function for the GET /posts endpoint. *)
(* It takes a database connection pool and a Piaf request as input. *)
let get_root (db_pool : pool) (request : Request.t) =
  let _coki = Piaf.Cookies.Cookie.parse request.headers in
  (* Use a connection from the pool. Caqti_eio.Pool.use handles acquiring and releasing the connection. *)
  Caqti_eio.Pool.use
    (fun conn ->
       (* Call the get_poasts function from the Query module to fetch posts from the database. *)
       let posts_or_error = Query.get_poasts () conn in
       (* Pattern match on the result of the database query. *)
       match posts_or_error with
       (* If the query is successful, the result is a list of posts. *)
       | Ok posts ->
         (* Map the list of post tuples to a Yojson list. *)
         let json =
           `List
             ((* For each post tuple, create a JSON object. *)
              List.map
                (fun (post : Query.post_summary) ->
                   `Assoc [ "title", `String post.title ])
                posts)
         in
         (* Return a 200 OK response with the JSON body. *)
         Ok (Response.of_string ~body:(Yojson.Safe.to_string json) `OK)
       (* If the query fails, log the error and return a 500 Internal Server Error response. *)
       | Error err ->
         Logs.err (fun m -> m "Database error: %a" Caqti_error.pp err);
         Ok (Response.create `Internal_server_error))
    db_pool
;;

type paget = ?key:string -> Query.conn -> unit -> React.element

let render_conn (page : paget) (db_pool : pool) (_request : Request.t) =
  (* Caqti_eio.Pool.use *)
  (* (fun conn -> *)
  (* let posts_or = Query.get_poasts () conn in *)
  (* match posts_or with *)
  (* | Error err -> *)
  (* Logs.err (fun m -> m "Database error %a" Caqti_error.pp err); *)
  (* Ok (Response.create `Internal_server_error) *)
  (* | Ok _posts -> Ok (page |> ReactDOM.renderToString |> Http.send_raw_html)) *)
  (* db_pool *)
  Caqti_eio.Pool.use
    (fun conn -> Ok (page conn () |> ReactDOM.renderToString |> Http.send_raw_html))
    db_pool
;;

let render page (_db_pool : pool) (_request : Request.t) =
  Ok (page |> ReactDOM.renderToString |> Http.send_raw_html)
;;