rice Posts - Answer Overflow

rice

•Created by rice on 3/31/2025 in #help

How to Force Email-OTP Plugin to Use Redis Instead of PostgreSQL

In my Next.js project, I'm using the email-otp plugin for authentication. The primary database is PostgreSQL, and Redis is set up as a secondary storage. I assumed that sessions and OTP verification would be handled through Redis. However, when attempting to send an OTP, I get this error:

SERVER_ERROR: error: relation "verification" does not exist

SERVER_ERROR: error: relation "verification" does not exist

This implies the plugin is trying to access a verification table in PostgreSQL, which doesn’t exist. I want OTP verification to go through Redis instead. Is it possible to handle verification via Redis, or does it have to use PostgreSQL?
Also, how can I ensure that sessions data is using Redis? Is there a specific config I need to set to enforce this?

const redis = createClient({
  url: process.env.REDIS_URL || 'redis://localhost:6379'
});
await redis.connect();

export interface SecondaryStorage {
    get: (key: string) => Promise<string | null>;
    set: (key: string, value: string, ttl?: number) => Promise<void>;
    delete: (key: string) => Promise<void>;
  }


export const auth = betterAuth({
  appName: "My App",
  database: new Pool({
    connectionString: process.env.DATABASE_URL,
  }),
  trustedOrigins: ["*"],
  secondaryStorage: {
        get: async (key) => {
            const value = await redis.get(key);
            return value ? value : null;
        },
        set: async (key, value, ttl) => {
            if (ttl) await redis.set(key, value, { EX: ttl });
            // or for ioredis:
            // if (ttl) await redis.set(key, value, 'EX', ttl)
            else await redis.set(key, value);
        },
        delete: async (key) => {
            await redis.del(key);
        }
    },

const redis = createClient({
  url: process.env.REDIS_URL || 'redis://localhost:6379'
});
await redis.connect();

export interface SecondaryStorage {
    get: (key: string) => Promise<string | null>;
    set: (key: string, value: string, ttl?: number) => Promise<void>;
    delete: (key: string) => Promise<void>;
  }


export const auth = betterAuth({
  appName: "My App",
  database: new Pool({
    connectionString: process.env.DATABASE_URL,
  }),
  trustedOrigins: ["*"],
  secondaryStorage: {
        get: async (key) => {
            const value = await redis.get(key);
            return value ? value : null;
        },
        set: async (key, value, ttl) => {
            if (ttl) await redis.set(key, value, { EX: ttl });
            // or for ioredis:
            // if (ttl) await redis.set(key, value, 'EX', ttl)
            else await redis.set(key, value);
        },
        delete: async (key) => {
            await redis.del(key);
        }
    },

3 replies

Gaming

Programming