Use the same database driver for all postgress (tests and runtime) (#223)

Ideally this should work without issues. 

### Why the exploration
Moving from "pg" to this database driver to "postgres" allows us also to
move from `node_compat=true` flag in favor of `compatibility_flags = [
"nodejs_compat" ]` which allows us to implement open telemetry
distributed traced. ❤️ (Which should come in a different PR once I feel
OK this is good 🙏🏼 )


Queries seem to be working without issues
<details><summary>Queries work</summary>
<p>


![image](https://github.com/user-attachments/assets/98edde27-3c76-4192-ab9d-ed8fb6649cd7)

![image](https://github.com/user-attachments/assets/a7f19292-dff2-4478-bdc1-09819ea4f553)

![image](https://github.com/user-attachments/assets/0e399d26-fdea-4d95-88b8-3ea9188b652b)


</p>
</details>

Author: fforres

package-lock.json

@@ -100,10 +100,9 @@
     "hono": "^3.9.0",
     "mercadopago": "^2.0.9",
     "p-map": "^6.0.0",
-    "pg": "^8.11.5",
     "pino": "^9.2.0",
     "pino-pretty": "^11.2.1",
-    "postgres": "^3.4.3",
+    "postgres": "^3.4.4",
     "react": "^18.2.0",
     "resend": "^3.3.0",
     "slugify": "^1.6.6",

package.json

@@ -96,7 +96,7 @@ export const createGraphqlContext = async ({
 
   const GET_STRIPE_CLIENT = () => getStripeClient(STRIPE_KEY);
   const GET_MERCADOPAGO_CLIENT = getMercadoPagoFetch(MERCADOPAGO_KEY, logger);
-  const DB = await getDb({
+  const DB = getDb({
     neonUrl: DB_URL,
     logger,
   });

src/context.ts

@@ -1,42 +1,34 @@
 import { ExtractTablesWithRelations } from "drizzle-orm";
+import { PgTransaction } from "drizzle-orm/pg-core";
 import {
-  NodePgDatabase,
-  NodePgQueryResultHKT,
+  PostgresJsDatabase,
+  PostgresJsQueryResultHKT,
   drizzle,
-} from "drizzle-orm/node-postgres";
-import { PgTransaction } from "drizzle-orm/pg-core";
-import { Client } from "pg";
+} from "drizzle-orm/postgres-js";
 import { Logger } from "pino";
+import postgres from "postgres";
 
 import * as schema from "./schema";
 
-export type ORM_TYPE = NodePgDatabase<typeof schema>;
+export type ORM_TYPE = PostgresJsDatabase<typeof schema>;
 export type TRANSACTION_HANDLER = PgTransaction<
-  NodePgQueryResultHKT,
+  PostgresJsQueryResultHKT,
   typeof schema,
   ExtractTablesWithRelations<typeof schema>
 >;
 
-export const getDb = async ({
+export const getDb = ({
   neonUrl,
   logger,
 }: {
   neonUrl: string;
   logger: Logger<never>;
 }) => {
-  const client = new Client({
-    connectionString: neonUrl,
-  });
+  const client = postgres(neonUrl);
 
   try {
-    await client.connect();
     const db = drizzle(client, {
       schema,
-      // logger: {
-      //   logQuery(query, params) {
-      //     logger.info(query, params);
-      //   },
-      // },
     });
 
     return db;

src/datasources/db/index.ts

@@ -335,6 +335,10 @@ export const createPaymentIntent = async ({
   });
   const currencyCode = currency?.currency;
 
+  if (!purchaseOrder) {
+    throw new GraphQLError("Orden de compra no encontrada");
+  }
+
   if (purchaseOrder?.userId !== USER.id) {
     throw new GraphQLError("No authorizado");
   }
@@ -343,10 +347,6 @@ export const createPaymentIntent = async ({
     throw new GraphQLError("No encontramos un currency con ese ID");
   }
 
-  if (!purchaseOrder) {
-    throw new GraphQLError("Orden de compra no encontrada");
-  }
-
   if (purchaseOrder.purchaseOrderPaymentStatus === "paid") {
     throw new GraphQLError("Orden de compra ya pagada");
   }

src/schema/purchaseOrder/actions.tsx

@@ -464,9 +464,8 @@ builder.mutationFields((t) => ({
                   default_redirect_url: PURCHASE_CALLBACK_URL,
                 });
 
-              logger.info("Generating payment link for purchase order");
               const { purchaseOrder, ticketsIds } = await createPaymentIntent({
-                DB,
+                DB: trx,
                 USER,
                 purchaseOrderId: createdPurchaseOrder.id,
                 GET_STRIPE_CLIENT,

src/schema/userTickets/mutations.ts

@@ -25,7 +25,7 @@ export const scheduled: ExportedHandlerScheduledHandler<ENV> = async (
 ) => {
   ensureKeys(env, ["DB_URL", "STRIPE_KEY", "MERCADOPAGO_KEY"]);
   const logger = createLogger("purchase_order_payment_sync_cron");
-  const DB = await getDb({
+  const DB = getDb({
     neonUrl: env.DB_URL,
     logger,
   });

workers/purchase_order_payment_sync_cron/scheduled.tsx

@@ -10,7 +10,7 @@ import { ENV } from "./types";
 
 export const importFromSanity = async (env: ENV, logger: Logger<never>) => {
   try {
-    const DB = await getDb({
+    const DB = getDb({
       neonUrl: env.NEON_URL,
       logger,
     });

workers/sanity_asset_importer/importSanity.ts

@@ -32,7 +32,7 @@ export const syncMercadopagoPaymentsAndSubscriptions = async (
   env: ENV,
   logger: Logger<never>,
 ) => {
-  const DB = await getDb({
+  const DB = getDb({
     neonUrl: env.NEON_URL,
     logger,
   });

workers/wall_of_fame_cron/api.mercadopago.ts

@@ -44,7 +44,7 @@ export const getSubscriptions = async (env: ENV) => {
 };
 
 export const syncStripePayments = async (env: ENV) => {
-  const DB = await getDb({ neonUrl: env.NEON_URL, logger: defaultLogger });
+  const DB = getDb({ neonUrl: env.NEON_URL, logger: defaultLogger });
   const stripe = new Stripe(env.ST_KEY);
 
   const results = await stripe.charges.list({ limit: 100 });