[helpers] safeSendMessage

This is a variant of 'sendMessage' which creates the queue

haskell-pgmq.cabal

@@ -66,6 +66,7 @@ library
 
     -- Modules exported by the library.
     exposed-modules:  Database.PGMQ
+                    , Database.PGMQ.Helpers
                     , Database.PGMQ.Schema
                     , Database.PGMQ.Simple
                     , Database.PGMQ.Types
@@ -160,7 +161,8 @@ test-suite test-integration
     
     type:             exitcode-stdio-1.0
 
-    other-modules:  Test.Integration.PGMQ.Simple
+    other-modules:  Test.Integration.PGMQ.Helpers
+                  , Test.Integration.PGMQ.Simple
                   , Test.Integration.Utils
         
     build-depends:    base ^>=4.17.2.0

src/Database/PGMQ.hs

@@ -9,10 +9,12 @@ Portability : POSIX
 -}
 
 module Database.PGMQ
-  ( module Database.PGMQ.Simple
+  ( module Database.PGMQ.Helpers
+  , module Database.PGMQ.Simple
   , module Database.PGMQ.Types )
 where
 
    
+import Database.PGMQ.Helpers
 import Database.PGMQ.Simple
 import Database.PGMQ.Types

src/Database/PGMQ/Simple.hs

@@ -249,7 +249,8 @@ sendMessage conn queue msg delay = do
   [PSQL.Only msgId] <- PSQL.query conn [sql| SELECT pgmq.send(?, ?::jsonb, ?) |] (queue, PSQL.Aeson msg, delay)
 
   return msgId
-
+                                       
+                                       
 -- | Sends a batch of messages
 --   https://tembo.io/pgmq/api/sql/functions/#send_batch
 sendMessages :: (SerializableMessage a)

tests/integration-tests.hs

 module Main where
 
+import Test.Integration.PGMQ.Helpers (pgmqHelpersTests)
 import Test.Integration.PGMQ.Simple (pgmqSimpleTests)
 import Test.Tasty
 import Test.Tasty.Hspec
@@ -8,10 +9,12 @@ import Test.Tasty.Hspec
 
 main :: IO ()
 main = do
+  pgmqHelpersSpec <- testSpec "pgmqHelpersTests" pgmqHelpersTests
   pgmqSimpleSpec <- testSpec "pgmqSimpleTests" pgmqSimpleTests
 
   defaultMain $ testGroup "integration tests"
     [
       pgmqSimpleSpec
+    , pgmqHelpersSpec
     ]