How to set up the database with drizzleAdapter + D1 using Hono on Cloudflare Workers

AAruthoth Hey folks, what's up? I'm creating an API with authentication that runs on Clou...

B

bekacru•12/9/24, 3:31 PM

bascailly what you're doing is fine to use at runtime but to use the cli this won't be possible. One thing you could do is mount another endpoint where you call to migrate the schema. And call the migration manually by doing

import { getMigrations } from "better-auth/db";

const { runMigrations, toBeAdded, toBeCreated } = await getMigrations(getAuth(ctx).options);

if (toBeAdded.length || toBeCreated.length) {
    await runMigrations(); //this will add the required schema for D1
}

import { getMigrations } from "better-auth/db";

const { runMigrations, toBeAdded, toBeCreated } = await getMigrations(getAuth(ctx).options);

if (toBeAdded.length || toBeCreated.length) {
    await runMigrations(); //this will add the required schema for D1
}

import { getMigrations } from "better-auth/db";

const { runMigrations, toBeAdded, toBeCreated } = await getMigrations(getAuth(ctx).options);

if (toBeAdded.length || toBeCreated.length) {
    await runMigrations(); //this will add the required schema for D1
}

import { getMigrations } from "better-auth/db";

const { runMigrations, toBeAdded, toBeCreated } = await getMigrations(getAuth(ctx).options);

if (toBeAdded.length || toBeCreated.length) {
    await runMigrations(); //this will add the required schema for D1
}

Bbekacru bascailly what you're doing is fine to use at runtime but to use the cli this wo...

A

AruthothOP•12/9/24, 3:43 PM

Interesting, I did some tests and ended up populating the database manually. I'll test it this way.

A

AruthothOP•12/9/24, 3:45 PM

Except for populating the database, I think I managed to get the authentication flow working.

A

AruthothOP•12/9/24, 3:46 PM

At least I managed to create a new user and retrieve their session using Google.

A

AruthothOP•12/9/24, 4:02 PM

Revisiting the code more carefully, I realized the database is being initialized incorrectly.

A

AruthothOP•12/9/24, 4:04 PM

// new code
import { drizzle } from 'drizzle-orm/d1'

// code...

return betterAuth({
    database: drizzleAdapter(drizzle(c.env.DB), { // add drizzle

// code...

// new code
import { drizzle } from 'drizzle-orm/d1'

// code...

return betterAuth({
    database: drizzleAdapter(drizzle(c.env.DB), { // add drizzle

// code...

// new code
import { drizzle } from 'drizzle-orm/d1'

// code...

return betterAuth({
    database: drizzleAdapter(drizzle(c.env.DB), { // add drizzle

// code...

// new code
import { drizzle } from 'drizzle-orm/d1'

// code...

return betterAuth({
    database: drizzleAdapter(drizzle(c.env.DB), { // add drizzle

// code...

A

AruthothOP•12/9/24, 4:05 PM

It was missing the step of creating the client with Drizzle first.

A

AruthothOP•12/9/24, 4:05 PM

database: drizzleAdapter(c.env.DB, {

database: drizzleAdapter(c.env.DB, {

database: drizzleAdapter(c.env.DB, {

database: drizzleAdapter(c.env.DB, { ->

database: drizzleAdapter(drizzle(c.env.DB), {

database: drizzleAdapter(drizzle(c.env.DB), {

database: drizzleAdapter(drizzle(c.env.DB), {

database: drizzleAdapter(drizzle(c.env.DB), {

A

AruthothOP•12/9/24, 4:06 PM

I also adjusted the middleware for the session

A

AruthothOP•12/9/24, 4:09 PM

import { createMiddleware } from 'hono/factory'

import type { AppBindings } from '@/lib/types'

import { getAuth } from '@/lib/auth'

const userSession = createMiddleware<AppBindings>(async (c, next) => {
  const auth = getAuth(c) // only change <------------------
  const session = await auth.api.getSession({ headers: c.req.raw.headers })

  if (!session) {
    c.set('user', null)
    c.set('session', null)
    return next()
  }

  c.set('user', session.user)
  c.set('session', session.session)
  return next()
})

export default userSession

import { createMiddleware } from 'hono/factory'

import type { AppBindings } from '@/lib/types'

import { getAuth } from '@/lib/auth'

const userSession = createMiddleware<AppBindings>(async (c, next) => {
  const auth = getAuth(c) // only change <------------------
  const session = await auth.api.getSession({ headers: c.req.raw.headers })

  if (!session) {
    c.set('user', null)
    c.set('session', null)
    return next()
  }

  c.set('user', session.user)
  c.set('session', session.session)
  return next()
})

export default userSession

import { createMiddleware } from 'hono/factory'

import type { AppBindings } from '@/lib/types'

import { getAuth } from '@/lib/auth'

const userSession = createMiddleware<AppBindings>(async (c, next) => {
  const auth = getAuth(c) // only change <------------------
  const session = await auth.api.getSession({ headers: c.req.raw.headers })

  if (!session) {
    c.set('user', null)
    c.set('session', null)
    return next()
  }

  c.set('user', session.user)
  c.set('session', session.session)
  return next()
})

export default userSession

import { createMiddleware } from 'hono/factory'

import type { AppBindings } from '@/lib/types'

import { getAuth } from '@/lib/auth'

const userSession = createMiddleware<AppBindings>(async (c, next) => {
  const auth = getAuth(c) // only change <------------------
  const session = await auth.api.getSession({ headers: c.req.raw.headers })

  if (!session) {
    c.set('user', null)
    c.set('session', null)
    return next()
  }

  c.set('user', session.user)
  c.set('session', session.session)
  return next()
})

export default userSession

Vvanderrlay I am also trying to figure this out and have a similar issue. I'm trying to use ...

A

AruthothOP•12/9/24, 4:15 PM

Take a look to see if you're initializing Drizzle incorrectly, just like I did

A

AruthothOP•12/9/24, 4:16 PM

If I initialize it incorrectly, like the first time I did, I only receive a 500 error.

A

AruthothOP•12/9/24, 4:16 PM

A

AruthothOP•12/9/24, 5:08 PM

I forgot to mention, but I also changed this part

app.on(['GET', 'POST'], '/api/auth/**', (c) => getAuth(c).handler(c.req.raw))

app.on(['GET', 'POST'], '/api/auth/**', (c) => getAuth(c).handler(c.req.raw))

app.on(['GET', 'POST'], '/api/auth/**', (c) => getAuth(c).handler(c.req.raw))

app.on(['GET', 'POST'], '/api/auth/**', (c) => getAuth(c).handler(c.req.raw))

A

AruthothOP•12/21/24, 11:16 PM

Look, I'm not sure if there's a more elegant way to do this, but I just created a few types

A

AruthothOP•12/21/24, 11:17 PM

import type { OpenAPIHono, RouteConfig, RouteHandler } from '@hono/zod-openapi'
import type { Env } from 'hono'

import type { getAuth } from '@/lib/auth'

type Auth = ReturnType<typeof getAuth>
type VariableUser = Auth['$Infer']['Session']['user'] | null
type VariableSession = Auth['$Infer']['Session']['session'] | null

export interface AppBindings extends Env {
  Bindings: {
    AUTH_URL: string
    AUTH_SECRET: string
    AUTH_GOOGLE_CLIENT_ID: string
    AUTH_GOOGLE_CLIENT_SECRET: string
    DB: D1Database
  }
  Variables: {
    user: VariableUser
    session: VariableSession
  }
}

export type AppOpenAPI = OpenAPIHono<AppBindings>

export type AppRouteHandler<R extends RouteConfig> = RouteHandler<R, AppBindings>

import type { OpenAPIHono, RouteConfig, RouteHandler } from '@hono/zod-openapi'
import type { Env } from 'hono'

import type { getAuth } from '@/lib/auth'

type Auth = ReturnType<typeof getAuth>
type VariableUser = Auth['$Infer']['Session']['user'] | null
type VariableSession = Auth['$Infer']['Session']['session'] | null

export interface AppBindings extends Env {
  Bindings: {
    AUTH_URL: string
    AUTH_SECRET: string
    AUTH_GOOGLE_CLIENT_ID: string
    AUTH_GOOGLE_CLIENT_SECRET: string
    DB: D1Database
  }
  Variables: {
    user: VariableUser
    session: VariableSession
  }
}

export type AppOpenAPI = OpenAPIHono<AppBindings>

export type AppRouteHandler<R extends RouteConfig> = RouteHandler<R, AppBindings>

import type { OpenAPIHono, RouteConfig, RouteHandler } from '@hono/zod-openapi'
import type { Env } from 'hono'

import type { getAuth } from '@/lib/auth'

type Auth = ReturnType<typeof getAuth>
type VariableUser = Auth['$Infer']['Session']['user'] | null
type VariableSession = Auth['$Infer']['Session']['session'] | null

export interface AppBindings extends Env {
  Bindings: {
    AUTH_URL: string
    AUTH_SECRET: string
    AUTH_GOOGLE_CLIENT_ID: string
    AUTH_GOOGLE_CLIENT_SECRET: string
    DB: D1Database
  }
  Variables: {
    user: VariableUser
    session: VariableSession
  }
}

export type AppOpenAPI = OpenAPIHono<AppBindings>

export type AppRouteHandler<R extends RouteConfig> = RouteHandler<R, AppBindings>

import type { OpenAPIHono, RouteConfig, RouteHandler } from '@hono/zod-openapi'
import type { Env } from 'hono'

import type { getAuth } from '@/lib/auth'

type Auth = ReturnType<typeof getAuth>
type VariableUser = Auth['$Infer']['Session']['user'] | null
type VariableSession = Auth['$Infer']['Session']['session'] | null

export interface AppBindings extends Env {
  Bindings: {
    AUTH_URL: string
    AUTH_SECRET: string
    AUTH_GOOGLE_CLIENT_ID: string
    AUTH_GOOGLE_CLIENT_SECRET: string
    DB: D1Database
  }
  Variables: {
    user: VariableUser
    session: VariableSession
  }
}

export type AppOpenAPI = OpenAPIHono<AppBindings>

export type AppRouteHandler<R extends RouteConfig> = RouteHandler<R, AppBindings>

AAlex Patterson I have been trying this on cloudflare workers the same way and keep getting this...

B

bekacru•2/1/25, 5:36 AM

yeah baseURL should be inferred from a request, if it's not behind a proxy but curious what was the value you provided?

AAruthoth I also adjusted the middleware for the session

W

whistlecube•2/16/25, 11:44 PM

Do you create this middleware in a separate file, and then import it to your Hono app? How do you use it within Hono?

Wwhistlecube Do you create this middleware in a separate file, and then import it to your Hon...

W

whistlecube•2/17/25, 12:11 AM

nvm i got it

W

whistlecube•2/17/25, 12:31 AM

Ok I’m still having trouble, I think the auth instance isn’t persistent across requests. I can sign-in just fine, and accessing the session works, but on the next request using the middleware, I get a null session. How are you protecting your other routes using the middleware?

Wwhistlecube Ok I’m still having trouble, I think the auth instance isn’t persistent across r...

A

AruthothOP•2/23/25, 3:40 PM

Well, I haven't "got to that part yet"

A

AruthothOP•2/23/25, 3:41 PM

I did some initial tests to see what the authentication would be like and left it to finish after I finished the main part of the application

A

AruthothOP•2/23/25, 3:42 PM

I'm using Astro to develop, my middleware is like this for now

A

AruthothOP•2/23/25, 3:43 PM

import { auth } from '@/lib/auth'
import { defineMiddleware, sequence } from 'astro:middleware'

const setSession = defineMiddleware(async (c, next) => {
  const isAuthed = await auth(c).api.getSession({
    headers: c.request.headers,
  })

  if (isAuthed) {
    c.locals.user = isAuthed.user
    c.locals.session = isAuthed.session
  } else {
    c.locals.user = null
    c.locals.session = null
  }

  return next()
})

const protectsRoutes = defineMiddleware(async (c, next) => {
  const noSession = c.locals.user === null || c.locals.session === null
  
  if (noSession && c.url.pathname !== '/') {
    return next(
      new Request('/login', {
        headers: {
          'x-redirect-to': c.url.pathname,
        },
      })
    )
  }

  return next()
})

export const onRequest = sequence(setSession, protectsRoutes)

import { auth } from '@/lib/auth'
import { defineMiddleware, sequence } from 'astro:middleware'

const setSession = defineMiddleware(async (c, next) => {
  const isAuthed = await auth(c).api.getSession({
    headers: c.request.headers,
  })

  if (isAuthed) {
    c.locals.user = isAuthed.user
    c.locals.session = isAuthed.session
  } else {
    c.locals.user = null
    c.locals.session = null
  }

  return next()
})

const protectsRoutes = defineMiddleware(async (c, next) => {
  const noSession = c.locals.user === null || c.locals.session === null
  
  if (noSession && c.url.pathname !== '/') {
    return next(
      new Request('/login', {
        headers: {
          'x-redirect-to': c.url.pathname,
        },
      })
    )
  }

  return next()
})

export const onRequest = sequence(setSession, protectsRoutes)

import { auth } from '@/lib/auth'
import { defineMiddleware, sequence } from 'astro:middleware'

const setSession = defineMiddleware(async (c, next) => {
  const isAuthed = await auth(c).api.getSession({
    headers: c.request.headers,
  })

  if (isAuthed) {
    c.locals.user = isAuthed.user
    c.locals.session = isAuthed.session
  } else {
    c.locals.user = null
    c.locals.session = null
  }

  return next()
})

const protectsRoutes = defineMiddleware(async (c, next) => {
  const noSession = c.locals.user === null || c.locals.session === null
  
  if (noSession && c.url.pathname !== '/') {
    return next(
      new Request('/login', {
        headers: {
          'x-redirect-to': c.url.pathname,
        },
      })
    )
  }

  return next()
})

export const onRequest = sequence(setSession, protectsRoutes)

import { auth } from '@/lib/auth'
import { defineMiddleware, sequence } from 'astro:middleware'

const setSession = defineMiddleware(async (c, next) => {
  const isAuthed = await auth(c).api.getSession({
    headers: c.request.headers,
  })

  if (isAuthed) {
    c.locals.user = isAuthed.user
    c.locals.session = isAuthed.session
  } else {
    c.locals.user = null
    c.locals.session = null
  }

  return next()
})

const protectsRoutes = defineMiddleware(async (c, next) => {
  const noSession = c.locals.user === null || c.locals.session === null
  
  if (noSession && c.url.pathname !== '/') {
    return next(
      new Request('/login', {
        headers: {
          'x-redirect-to': c.url.pathname,
        },
      })
    )
  }

  return next()
})

export const onRequest = sequence(setSession, protectsRoutes)

A

AruthothOP•2/23/25, 3:44 PM

I still need to see how this part still works in astro

A

AruthothOP•2/23/25, 3:46 PM

doing an if for each route I need to reach doesn't seem like an elegant way to solve it, but it's what worked in my test

S

SHAH•3/5/25, 12:44 PM

The auth js package bypasses this type of issue by having the drizzle schema they require in the docs itself so we can copy paste it

How to set up the database with drizzleAdapter + D1 using Hono on Cloudflare Workers

Similar Threads

Similar Threads

Similar Threads