app.use('*', async (c, next) => {
const session = await auth(drizzle(c.env.DB)).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();
});
app.on(['POST', 'GET'], '/api/auth/**', (c) =>
auth(drizzle(c.env.DB)).handler(c.req.raw)
);
app.use(
'*',
createMiddleware(
async (c, next) =>
await agentsMiddleware({
options: {
onBeforeConnect: () => {
if (!c.get('user'))
return new Response('Unauthorized', { status: 401 });
},
},
onError: (error) => {
console.error(error);
},
})(c, next)
)
);
app.use('*', async (c, next) => {
const session = await auth(drizzle(c.env.DB)).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();
});
app.on(['POST', 'GET'], '/api/auth/**', (c) =>
auth(drizzle(c.env.DB)).handler(c.req.raw)
);
app.use(
'*',
createMiddleware(
async (c, next) =>
await agentsMiddleware({
options: {
onBeforeConnect: () => {
if (!c.get('user'))
return new Response('Unauthorized', { status: 401 });
},
},
onError: (error) => {
console.error(error);
},
})(c, next)
)
);