move init() into create extension

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pg_later"
-version = "0.0.9"
+version = "0.0.10"
 edition = "2021"
 publish = false
 
@@ -18,7 +18,7 @@ pg_test = []
 anyhow = "1.0.72"
 chrono = {version = "0.4.26", features = ["serde"] }
 log = "0.4.19"
-pgmq = "0.14.4"
+pgmq = "0.15.1"
 pgrx = "=0.9.8"
 serde = "1.0.164"
 serde_json = "1.0.99"

README.md

@@ -20,8 +20,6 @@ Initialize the extension's backend:
 
 ```sql
 CREATE EXTENSION pg_later CASCADE;
-
-SELECT pglater.init();
 ```
 
 Execute a SQL query now:

sql/pgmq.sql

@@ -0,0 +1,3 @@
+-- todo: these will become schema qualified when pgmq is moved to its own schema
+select pgmq_create_non_partitioned('pg_later_jobs');
+select pgmq_create_non_partitioned('pg_later_results');    

src/api.rs

@@ -3,23 +3,6 @@
 use pgrx::prelude::*;
 use pgrx::spi::SpiTupleTable;
 
-#[pg_extern]
-fn init() -> Result<bool, spi::Error> {
-    let setup_queries = [
-        "select pgmq_create_non_partitioned('pg_later_jobs')",
-        "select pgmq_create_non_partitioned('pg_later_results')",
-    ];
-    for q in setup_queries {
-        let ran: Result<_, spi::Error> = Spi::connect(|mut c| {
-            let _ = c.update(q, None, None)?;
-            Ok(())
-        });
-
-        ran?
-    }
-    Ok(true)
-}
-
 /// send a query to be executed by the next available worker
 #[pg_extern]
 pub fn exec(query: &str) -> Result<i64, spi::Error> {

src/lib.rs

@@ -8,6 +8,8 @@ mod clf;
 mod executor;
 mod util;
 
+extension_sql_file!("../sql/pgmq.sql");
+
 /// This module is required by `cargo pgrx test` invocations.
 /// It must be visible at the root of your extension crate.
 #[cfg(test)]

tests/integration_test.rs

@@ -33,11 +33,6 @@ async fn test_lifecycle() {
         .await
         .expect("failed to create");
 
-    let _ = sqlx::query("SELECT pglater.init()")
-        .execute(&conn)
-        .await
-        .expect("failed to init");
-
     // simple select case
     let q0 = sqlx::query("SELECT pglater.exec('select 1')")
         .fetch_one(&conn)