docs(tutorial): use Effect-native SQL and HTTP primitives

[sam-goodwin]

Two tutorial fixes:

tutorial/cloudflare/neon-hyperdrive

Swap the raw pg / mysql2 snippets (wrapped in Effect.promise(async () => …)) for the Effect-native SQL clients.

+import * as Reactivity from "@effect/experimental/Reactivity";
+import * as PgClient from "@effect/sql-pg/PgClient";

   Effect.gen(function* () {
     const hd = yield* Cloudflare.Hyperdrive.bind(Hyperdrive);
+    const sql = yield* PgClient.make({ url: yield* hd.connectionString });

     return {
       fetch: Effect.gen(function* () {
-        const connectionString = yield* hd.connectionString;
-        const rows = yield* Effect.promise(async () => {
-          const client = new Client({ connectionString });
-          await client.connect();
-          try { return (await client.query("SELECT now() as now")).rows; }
-          finally { await client.end().catch(() => {}); }
-        });
+        const rows = yield* sql`SELECT now() as now`;
         return yield* HttpServerResponse.json({ ok: true, rows });
       }),
     };
-  }).pipe(Effect.provide(Cloudflare.HyperdriveConnectionLive)),
+  }).pipe(
+    Effect.provide(Reactivity.layer),
+    Effect.provide(Cloudflare.HyperdriveConnectionLive),
+  ),

Install lines change from pg + @types/pg / mysql2 to @effect/sql-pg / @effect/sql-mysql2 (the underlying driver is bundled). MySQL tab gets the equivalent MysqlClient.make treatment.

tutorial/cloudflare/queue-consumer

• Replace return new Response("ok") with HttpServerResponse.text("ok") (added the missing import).
• Reshape the subscribe handler so Stream.runForEach is the terminal step on stream.pipe(...) rather than wrapping the per-message effect, and drop the redundant Effect.asVoid:

   yield* Cloudflare.messages<QueueMessageBody>(queueResource).subscribe(
     (stream) =>
-      Stream.runForEach(stream, (msg) =>
-        bucket
-          .put(`/queue/${msg.body.id}`, JSON.stringify(msg.body), {
-            httpMetadata: { contentType: "application/json" },
-          })
-          .pipe(Effect.asVoid),
-      ),
+      stream.pipe(
+        Stream.runForEach((msg) =>
+          bucket.put(`/queue/${msg.body.id}`, JSON.stringify(msg.body), {
+            httpMetadata: { contentType: "application/json" },
+          }),
+        ),
+      ),
   );

[alchemy-version-bot]

Install the packages built from this commit:

alchemy

bun add alchemy@https://pkg.ing/alchemy/ac03071

@alchemy.run/better-auth

bun add @alchemy.run/better-auth@https://pkg.ing/@alchemy.run/better-auth/ac03071

@alchemy.run/pr-package

bun add @alchemy.run/pr-package@https://pkg.ing/@alchemy.run/pr-package/ac03071

[alchemy-version-bot]

Website Preview Deployed

URL: https://alchemyeffectwebsite-worker-pr-400-nfqvmp3ylra5rt7a.testing-2b2.workers.dev

Built from commit 669a656.

---

This comment updates automatically with each push.

[sam-goodwin]

You can't yield* hd.connectionString here. PgClient needs to be lazily evaluated (maybe provided as a Layer to the fetch effect)

[sam-goodwin]

Fixed in 25145a3. Replaced PgClient.make({ url: yield* hd.connectionString }) at init with a Layer.unwrapEffect(hd.connectionString.pipe(Effect.map(url => PgClient.layer({ url })))) provided to the fetch effect — connectionString is now read lazily under the request's RuntimeContext.

[sam-goodwin]

This won't work. Perhaps we need PgClient.layer and Layer.unwrap?

[sam-goodwin]

Done — now using PgClient.layer / MysqlClient.layer wrapped in Layer.unwrapEffect, provided to the fetch boundary. See 25145a3.

[sam-goodwin]

Don't use bullet points like this to point of "things to notice". Instead, break the code into diff/delta snippets and explain step by step, drawing the user's attention to the appropriate code

[sam-goodwin]

Restructured in 25145a3: dropped the trailing bullet list and split the section into three delta diff snippets (bind at init → derive SqlLive via Layer.unwrapEffect → query in fetch + provide), each with one prose paragraph drawing attention to the new code.