import { query } from "./_generated/server";
export const getAllUsersWithSubscriptions = query({
handler: async (ctx) => {
const users = await ctx.db.query("users").collect();
const usersWithSubs = await Promise.all(
users.map(async (user) => {
const subscription = await ctx.db
.query("subscriptions")
.withIndex("by_user", (q) => q.eq("userId", user._id))
.first();
return {
_id: user._id,
name: user.name,
email: user.email,
subscription: subscription!,
};
})
);
return usersWithSubs;
},
});
import { query } from "./_generated/server";
export const getAllUsersWithSubscriptions = query({
handler: async (ctx) => {
const users = await ctx.db.query("users").collect();
const usersWithSubs = await Promise.all(
users.map(async (user) => {
const subscription = await ctx.db
.query("subscriptions")
.withIndex("by_user", (q) => q.eq("userId", user._id))
.first();
return {
_id: user._id,
name: user.name,
email: user.email,
subscription: subscription!,
};
})
);
return usersWithSubs;
},
});