{-# LANGUAGE OverloadedStrings #-}

module Main where

import Control.Exception
import Database.RethinkDB.NoClash hiding (wait)
import qualified Database.RethinkDB as R
import Criterion.Main
import Control.Monad
import Control.Concurrent.Async

main :: IO ()
main = do
  h <- prepare
  let test name = bench name . nfIO . void . run' h
  let testn n name q = bench (name ++ "-" ++ show n) $ nfIO $ mapM_ wait =<< replicateM n (async $ run' h q)
  defaultMain [
    test "nil" $ expr Null,
    testn 10 "nil" $ expr [Null],
    testn 100 "nil" $ expr [Null],
    testn 1000 "nil" $ expr [Null],
    test "point-get" $ table "bench" # get (num 0)
    ]

prepare :: IO RethinkDBHandle
prepare = do
  h <- fmap (use "bench") $ connect "localhost" 28015 Nothing
  try_ $ run' h $ dbCreate "bench"
  try_ $ run' h $ tableCreate "bench"
  try_ $ run' h $ table "bench" # ex insert ["conflict" := str "replace"] ["id" := num 0]
  return h

try_ :: IO a -> IO (Either SomeException a)
try_ = try