BA
Better Auth•3d ago
rice

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);
        }
    },
1 Reply
bekacru
bekacru•2d ago
verifications currently only uses the main db. but we should support ss as a default in the near future

Did you find this page helpful?