Compare commits

..
5 Commits
Author SHA1 Message Date
dimitar bb9c675421 setings page enhanced
gym managment added
2026-03-18 06:23:40 +01:00
dimitar 624cdfc45c role based auth
implemented superadmin -> admin -> traniner
2026-03-18 06:06:01 +01:00
dimitar 16217f46ff schema update 2026-03-18 04:27:08 +01:00
dimitar cc2dbc3423 Merge branch 'adminUI' 2026-03-18 03:57:25 +01:00
dimitar b1d6489c70 css 2026-03-18 03:55:28 +01:00
22 changed files with 1575 additions and 128 deletions

No files matched your search

Binary file not shown.
@@ -4,6 +4,7 @@ import { getDatabase } from "@/lib/database";
import { ensureUserSynced } from "@/lib/sync-user";
import { successResponse } from "@/lib/api/responses";
import { db as rawDb, sql } from "@fitai/database";
import { getUsersByGym, getClientsByGym } from "@/lib/gym-context";
interface UserGrowthPoint {
label: string;
@@ -45,12 +46,36 @@ export async function GET(req: NextRequest) {
const url = new URL(req.url);
const months = parseInt(url.searchParams.get("months") || "6");
const allUsers = await database.getAllUsers();
const allClients = await database.getAllClients();
// Get target gym based on role
const targetGymId =
user.role === "superAdmin"
? (url.searchParams.get("gymId") ?? undefined)
: (user.gymId ?? undefined);
const paymentsRaw = await rawDb.all(
sql`SELECT * FROM payments WHERE status = 'completed' AND paid_at IS NOT NULL`,
);
// Validate gym access for non-superAdmins
if (user.role !== "superAdmin" && !targetGymId) {
return NextResponse.json(
{ error: "Forbidden - No gym assigned" },
{ status: 403 },
);
}
// Get gym-scoped data
const allUsers = targetGymId
? await getUsersByGym(targetGymId)
: await database.getAllUsers();
const allClients = targetGymId
? await getClientsByGym(targetGymId)
: await database.getAllClients();
// For payments, we'd need a similar filter - for now, skip payments if gym-scoped
// TODO: Add getPaymentsByGym when needed
const paymentsRaw = targetGymId
? [] // Skip payments for gym-scoped for now
: await rawDb.all(
sql`SELECT * FROM payments WHERE status = 'completed' AND paid_at IS NOT NULL`,
);
const payments: any[] = paymentsRaw || [];
const now = new Date();
@@ -1,23 +1,39 @@
import { auth } from "@clerk/nextjs/server";
import { NextResponse } from "next/server";
import { NextRequest, NextResponse } from "next/server";
import { getDatabase } from "@/lib/database";
import { ensureUserSynced } from "@/lib/sync-user";
import { successResponse } from "@/lib/api/responses";
import { getAttendanceByGym } from "@/lib/gym-context";
export async function GET(req: Request) {
export async function GET(req: NextRequest) {
try {
const { userId } = await auth();
if (!userId) return new NextResponse("Unauthorized", { status: 401 });
const db = await getDatabase();
const user = await ensureUserSynced(userId, db);
if (!user || (user.role !== "admin" && user.role !== "superAdmin")) {
return new NextResponse("Forbidden", { status: 403 });
}
const attendance = await db.getAllAttendance();
// Get target gym based on role
const url = new URL(req.url);
const targetGymId =
user.role === "superAdmin"
? (url.searchParams.get("gymId") ?? undefined)
: (user.gymId ?? undefined);
// Validate gym access for non-superAdmins
if (user.role !== "superAdmin" && !targetGymId) {
return new NextResponse("Forbidden - No gym assigned", { status: 403 });
}
// Get attendance filtered by gym
const attendance = targetGymId
? await getAttendanceByGym(targetGymId)
: await db.getAllAttendance();
return successResponse({ records: attendance });
} catch (error) {
console.error("Admin attendance error:", error);
+89
View File
@@ -0,0 +1,89 @@
import { NextResponse } from "next/server";
import { auth } from "@clerk/nextjs/server";
import { eq, sql } from "@fitai/database";
import { db, users as usersTable } from "@fitai/database";
import { ensureUserSynced } from "@/lib/sync-user";
import log from "@/lib/logger";
async function ensureGymsTable() {
await db.run(sql`
CREATE TABLE IF NOT EXISTS gyms (
id TEXT PRIMARY KEY,
name TEXT NOT NULL,
location TEXT,
status TEXT NOT NULL CHECK (status IN ('active','inactive')) DEFAULT 'active',
admin_user_id TEXT NOT NULL,
created_at INTEGER NOT NULL,
updated_at INTEGER NOT NULL
)
`);
}
// DELETE /api/gyms/[id]
// Delete a gym (soft delete - mark as inactive)
export async function DELETE(
request: Request,
{ params }: { params: Promise<{ id: string }> },
) {
try {
const { id: gymId } = await params;
const { userId } = await auth();
if (!userId) {
return new NextResponse("Unauthorized", { status: 401 });
}
// Ensure user is synced
const currentUser = await ensureUserSynced(userId, {
getUserById: async (id: string) => {
const row = await db
.select()
.from(usersTable)
.where(eq(usersTable.id, id))
.get();
return row
? {
id: row.id,
email: row.email,
firstName: row.firstName,
lastName: row.lastName,
password: row.password ?? "",
phone: row.phone ?? undefined,
role: row.role,
imageUrl: undefined,
createdAt: new Date(row.createdAt),
updatedAt: new Date(row.updatedAt),
}
: null;
},
} as any);
// Only superAdmin can delete gyms
if (!currentUser || currentUser.role !== "superAdmin") {
return new NextResponse("Forbidden - Only superAdmin can delete gyms", {
status: 403,
});
}
await ensureGymsTable();
// Check if gym exists
const gymRows = await db.all(sql`SELECT * FROM gyms WHERE id = ${gymId}`);
if (gymRows.length === 0) {
return new NextResponse("Gym not found", { status: 404 });
}
// Soft delete - mark as inactive
await db.run(
sql`UPDATE gyms SET status = 'inactive', updated_at = ${Date.now()} WHERE id = ${gymId}`,
);
return NextResponse.json({
success: true,
message: "Gym deleted successfully",
});
} catch (error) {
log.error("Failed to delete gym", error);
return new NextResponse("Internal Server Error", { status: 500 });
}
}
@@ -0,0 +1,105 @@
import { NextResponse } from "next/server";
import { eq, sql } from "@fitai/database";
import { db } from "@fitai/database";
import log from "@/lib/logger";
async function ensureGymsTable() {
await db.run(sql`
CREATE TABLE IF NOT EXISTS gyms (
id TEXT PRIMARY KEY,
name TEXT NOT NULL,
location TEXT,
status TEXT NOT NULL CHECK (status IN ('active','inactive')) DEFAULT 'active',
admin_user_id TEXT NOT NULL,
created_at INTEGER NOT NULL,
updated_at INTEGER NOT NULL
)
`);
}
// GET /api/gyms/[id]/stats
// Get stats for a specific gym
export async function GET(
request: Request,
{ params }: { params: Promise<{ id: string }> },
) {
try {
const { id: gymId } = await params;
await ensureGymsTable();
// Get gym info
const gymRows = await db.all(sql`SELECT * FROM gyms WHERE id = ${gymId}`);
if (gymRows.length === 0) {
return new NextResponse("Gym not found", { status: 404 });
}
const gym = gymRows[0];
// Get user counts
const usersResult = await db.all(
sql`SELECT role, COUNT(*) as count FROM users WHERE gym_id = ${gymId} GROUP BY role`,
);
const userCounts: Record<string, number> = {
admin: 0,
trainer: 0,
client: 0,
};
for (const row of usersResult as any[]) {
if (row.role in userCounts) {
userCounts[row.role] = row.count;
}
}
// Get client stats
const clientsResult = (await db.all(
sql`SELECT
membership_type,
membership_status,
COUNT(*) as count
FROM clients
WHERE user_id IN (SELECT id FROM users WHERE gym_id = ${gymId})
GROUP BY membership_type, membership_status`,
)) as any[];
const membershipStats: Record<string, number> = {
basic: 0,
premium: 0,
vip: 0,
};
const activeClients = clientsResult.filter(
(c: any) => c.membership_status === "active",
);
for (const row of activeClients) {
if (row.membership_type in membershipStats) {
membershipStats[row.membership_type] = row.count;
}
}
// Get recent activity (attendance in last 30 days)
const thirtyDaysAgo = Date.now() - 30 * 24 * 60 * 60 * 1000;
const attendanceResult = (await db.all(
sql`SELECT COUNT(*) as count FROM attendance
WHERE user_id IN (SELECT id FROM users WHERE gym_id = ${gymId})
AND check_in_time > ${thirtyDaysAgo}`,
)) as any[];
const attendanceCount = attendanceResult[0]?.count || 0;
const stats = {
totalUsers: userCounts.admin + userCounts.trainer + userCounts.client,
admins: userCounts.admin,
trainers: userCounts.trainer,
clients: userCounts.client,
membershipStats,
activeClients: activeClients.reduce(
(sum: number, c: any) => sum + c.count,
0,
),
attendanceLast30Days: attendanceCount,
};
return NextResponse.json({ gym, stats });
} catch (error) {
log.error("Failed to get gym stats", error);
return new NextResponse("Internal Server Error", { status: 500 });
}
}
@@ -1,11 +1,14 @@
import { NextRequest, NextResponse } from "next/server";
import { getDatabase } from "../../../../lib/database/index";
import { auth } from "@clerk/nextjs/server";
import log from "@/lib/logger";
import { fitnessProfileSchema } from "@/lib/validation/schemas";
import {
validateRequestBody,
validationErrorResponse,
} from "@/lib/validation/helpers";
import { getFitnessProfilesByGym } from "@/lib/gym-context";
import { ensureUserSynced } from "@/lib/sync-user";
export async function POST(request: NextRequest) {
try {
@@ -63,12 +66,47 @@ export async function POST(request: NextRequest) {
export async function GET(request: NextRequest) {
try {
const db = await getDatabase();
const { searchParams } = new URL(request.url);
const userId = searchParams.get("userId");
// First authenticate
const { userId: clerkUserId } = await auth();
if (!clerkUserId) {
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
}
if (userId) {
const profile = await db.getFitnessProfileByUserId(userId);
const db = await getDatabase();
const currentUser = await ensureUserSynced(clerkUserId, db);
if (!currentUser) {
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
}
const { searchParams } = new URL(request.url);
const targetUserId = searchParams.get("userId");
// If accessing another user's profile, verify gym access
if (targetUserId && targetUserId !== clerkUserId) {
const isStaff =
currentUser.role === "admin" ||
currentUser.role === "superAdmin" ||
currentUser.role === "trainer";
if (!isStaff) {
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
}
// Staff need to verify target user is in same gym
if (currentUser.role !== "superAdmin") {
const targetUser = await db.getUserById(targetUserId);
if (!targetUser || targetUser.gymId !== currentUser.gymId) {
return NextResponse.json(
{ error: "Forbidden - Cannot access users from other gyms" },
{ status: 403 },
);
}
}
}
if (targetUserId) {
const profile = await db.getFitnessProfileByUserId(targetUserId);
if (!profile) {
return NextResponse.json(
{ error: "Profile not found" },
@@ -78,8 +116,28 @@ export async function GET(request: NextRequest) {
return NextResponse.json({ profile });
}
const profiles = await db.getAllFitnessProfiles();
return NextResponse.json({ profiles });
// Staff get gym-scoped profiles
const isStaff =
currentUser.role === "admin" ||
currentUser.role === "superAdmin" ||
currentUser.role === "trainer";
if (isStaff) {
const targetGymId =
currentUser.role === "superAdmin"
? (searchParams.get("gymId") ?? undefined)
: (currentUser.gymId ?? undefined);
const profiles = targetGymId
? await getFitnessProfilesByGym(targetGymId)
: await db.getAllFitnessProfiles();
return NextResponse.json({ profiles });
}
// Regular users only get their own
const profile = await db.getFitnessProfileByUserId(clerkUserId);
return NextResponse.json({ profile: profile ? [profile] : [] });
} catch (error) {
log.error("Failed to get fitness profiles", error);
return NextResponse.json(
+36 -13
View File
@@ -17,6 +17,8 @@ import {
badRequestResponse,
internalErrorResponse,
} from "@/lib/api/responses";
import { getRecommendationsByGym } from "@/lib/gym-context";
import { ensureUserSynced } from "@/lib/sync-user";
export async function GET(request: NextRequest) {
try {
@@ -25,38 +27,59 @@ export async function GET(request: NextRequest) {
return unauthorizedResponse();
}
const db = await getDatabase();
const currentUser = await ensureUserSynced(currentUserId, db);
if (!currentUser) {
return forbiddenResponse("User not found");
}
const { searchParams } = new URL(request.url);
const targetUserId = searchParams.get("userId");
const db = await getDatabase();
// If no userId provided, check if staff and return all recommendations
// If no userId provided, staff gets gym-scoped recommendations
if (!targetUserId) {
const currentUser = await db.getUserById(currentUserId);
const isStaff =
currentUser?.role === "admin" ||
currentUser?.role === "superAdmin" ||
currentUser?.role === "trainer";
currentUser.role === "admin" ||
currentUser.role === "superAdmin" ||
currentUser.role === "trainer";
if (!isStaff) {
return badRequestResponse("User ID is required");
}
const recommendations = await db.getAllRecommendations();
// Get target gym based on role
const targetGymId =
currentUser.role === "superAdmin"
? (searchParams.get("gymId") ?? undefined)
: (currentUser.gymId ?? undefined);
// Get recommendations filtered by gym
const recommendations = targetGymId
? await getRecommendationsByGym(targetGymId)
: await db.getAllRecommendations();
return successResponse({ recommendations });
}
// Check permissions: Users can view their own, Admins/Trainers can view anyone's
const currentUser = await db.getUserById(currentUserId);
// Check permissions: Users can view their own, Admins/Trainers can view anyone's in their gym
const isStaff =
currentUser?.role === "admin" ||
currentUser?.role === "superAdmin" ||
currentUser?.role === "trainer";
currentUser.role === "admin" ||
currentUser.role === "superAdmin" ||
currentUser.role === "trainer";
if (currentUserId !== targetUserId) {
if (!isStaff) {
return forbiddenResponse();
}
// Staff need to verify target user is in same gym
if (currentUser.role !== "superAdmin") {
const targetUser = await db.getUserById(targetUserId);
if (!targetUser || targetUser.gymId !== currentUser.gymId) {
return forbiddenResponse("Cannot access users from other gyms");
}
}
}
let recommendations = await db.getRecommendationsByUserId(targetUserId);
+29 -1
View File
@@ -24,14 +24,42 @@ import {
internalErrorResponse,
badRequestResponse,
} from "@/lib/api/responses";
import { getUsersByGym } from "@/lib/gym-context";
import { ensureUserSynced } from "@/lib/sync-user";
export async function GET(request: NextRequest) {
try {
// First authenticate the user
const { userId: clerkUserId } = await auth();
if (!clerkUserId) {
return unauthorizedResponse();
}
const db = await getDatabase();
const currentUser = await ensureUserSynced(clerkUserId, db);
if (!currentUser) {
return forbiddenResponse("User not found");
}
const { searchParams } = new URL(request.url);
const role = searchParams.get("role");
let users = await db.getAllUsers();
// Get target gym based on role
const targetGymId =
currentUser.role === "superAdmin"
? (searchParams.get("gymId") ?? undefined)
: (currentUser.gymId ?? undefined);
// Validate gym access for non-superAdmins
if (currentUser.role !== "superAdmin" && !targetGymId) {
return forbiddenResponse("No gym assigned");
}
// Get users filtered by gym
let users = targetGymId
? await getUsersByGym(targetGymId)
: await db.getAllUsers();
// Hydrate gymId from raw DB to ensure consistency with writes
const rawUserRows = await rawDb.all(sql`SELECT id, gym_id FROM users`);
+1 -1
View File
@@ -107,7 +107,7 @@
@apply border-border;
}
body {
@apply bg-background text-foreground;
@apply bg-background text-foreground antialiased;
}
}
+32 -14
View File
@@ -14,11 +14,26 @@ import { AnalyticsDashboard } from "@/components/analytics/AnalyticsDashboard";
import { useDashboardStats } from "@/hooks/use-api";
import { useQueryClient } from "@tanstack/react-query";
import { Button } from "@/components/ui/button";
import { useUser } from "@clerk/nextjs";
import { useSearchParams } from "next/navigation";
import { GymSelector } from "@/components/gym/GymSelector";
export default function Home() {
const { data: stats, isLoading, refetch, isFetching } = useDashboardStats();
const { user } = useUser();
const searchParams = useSearchParams();
const gymId = searchParams.get("gymId") ?? undefined;
const {
data: stats,
isLoading,
refetch,
isFetching,
} = useDashboardStats(gymId);
const queryClient = useQueryClient();
// Get user role from metadata
const userRole = (user?.publicMetadata?.role as string) ?? "client";
const handleRefresh = () => {
queryClient.invalidateQueries({ queryKey: ["dashboard-stats"] });
queryClient.invalidateQueries({ queryKey: ["analytics"] });
@@ -40,18 +55,21 @@ export default function Home() {
title="Dashboard"
description="Welcome back! Here's what's happening with your gym today."
actions={
<Button
variant="outline"
size="sm"
onClick={handleRefresh}
disabled={isFetching}
className="gap-2"
>
<RefreshCw
className={`h-4 w-4 ${isFetching ? "animate-spin" : ""}`}
/>
Refresh
</Button>
<div className="flex items-center gap-3">
<GymSelector userRole={userRole} />
<Button
variant="outline"
size="sm"
onClick={handleRefresh}
disabled={isFetching}
className="gap-2"
>
<RefreshCw
className={`h-4 w-4 ${isFetching ? "animate-spin" : ""}`}
/>
Refresh
</Button>
</div>
}
/>
@@ -125,7 +143,7 @@ export default function Home() {
Overview of your gym metrics
</p>
</div>
<AnalyticsDashboard />
<AnalyticsDashboard gymId={gymId} />
</div>
</div>
</div>
+271 -71
View File
@@ -9,6 +9,10 @@ import {
AlertTriangle,
Check,
Loader2,
Trash2,
Users,
CalendarCheck,
TrendingUp,
} from "lucide-react";
import { Button } from "@/components/ui/button";
import { useUser } from "@clerk/nextjs";
@@ -26,6 +30,21 @@ interface Gym {
location?: string | null;
status: "active" | "inactive";
adminUserId: string;
createdAt?: number;
}
interface GymStats {
totalUsers: number;
admins: number;
trainers: number;
clients: number;
membershipStats: {
basic: number;
premium: number;
vip: number;
};
activeClients: number;
attendanceLast30Days: number;
}
export default function SettingsPage() {
@@ -46,6 +65,13 @@ export default function SettingsPage() {
type: "success" | "error";
text: string;
} | null>(null);
// Selected gym for details
const [selectedGym, setSelectedGym] = useState<Gym | null>(null);
const [gymStats, setGymStats] = useState<GymStats | null>(null);
const [statsLoading, setStatsLoading] = useState(false);
const [deletingGym, setDeletingGym] = useState(false);
// Create Gym modal state
const [showCreateGym, setShowCreateGym] = useState(false);
const [gymName, setGymName] = useState("");
@@ -77,11 +103,33 @@ export default function SettingsPage() {
}
};
const fetchGymStats = async (gymId: string) => {
setStatsLoading(true);
try {
const res = await axios.get(`/api/gyms/${gymId}/stats`);
if (res.data?.stats) {
setGymStats(res.data.stats);
}
} catch (error) {
log.error("Failed to fetch gym stats", error);
} finally {
setStatsLoading(false);
}
};
useEffect(() => {
fetchBackups();
fetchGyms();
}, []);
useEffect(() => {
if (selectedGym) {
fetchGymStats(selectedGym.id);
} else {
setGymStats(null);
}
}, [selectedGym]);
const handleCreateBackup = async () => {
setCreatingBackup(true);
setMessage(null);
@@ -111,7 +159,6 @@ export default function SettingsPage() {
try {
await axios.post("/api/admin/backups/restore", { filename });
setMessage({ type: "success", text: "Database restored successfully" });
// Optional: Refresh page or force re-login if session is invalidated
} catch (error) {
log.error("Failed to restore backup", error);
setMessage({ type: "error", text: "Failed to restore backup" });
@@ -135,21 +182,39 @@ export default function SettingsPage() {
return new Date(dateString).toLocaleString();
};
const handleSelectGym = async (gymId: string | null) => {
const handleSelectGym = async (gym: Gym | null) => {
setSelectedGym(gym);
setGymStats(null);
};
const handleDeleteGym = async (gymId: string) => {
if (
!window.confirm(
"Are you sure you want to delete this gym? This action cannot be undone.",
)
) {
return;
}
setDeletingGym(true);
setGymMessage(null);
try {
// Update current user's gym selection
await axios.patch("/api/users/gym", { gymId });
setGymMessage({
type: "success",
text: gymId ? "Gym selected successfully" : "Proceeding without gym",
});
await axios.delete(`/api/gyms/${gymId}`);
setGymMessage({ type: "success", text: "Gym deleted successfully" });
setSelectedGym(null);
setGymStats(null);
fetchGyms();
} catch (error) {
log.error("Failed to set gym", error);
setGymMessage({ type: "error", text: "Failed to set gym" });
log.error("Failed to delete gym", error);
setGymMessage({ type: "error", text: "Failed to delete gym" });
} finally {
setDeletingGym(false);
}
};
const userRole = (user?.publicMetadata?.role as string) ?? "client";
const isSuperAdmin = userRole === "superAdmin";
return (
<div className="space-y-8 p-8">
<div>
@@ -159,7 +224,7 @@ export default function SettingsPage() {
</p>
</div>
{/* Gym Picker */}
{/* Gym Management */}
<div className="bg-white rounded-xl shadow-sm border border-slate-100 p-6">
<div className="flex items-center justify-between mb-6">
<div className="flex items-center gap-3">
@@ -168,10 +233,12 @@ export default function SettingsPage() {
</div>
<div>
<h3 className="text-xl font-bold text-slate-900">
Gym Selection
Gym Management
</h3>
<p className="text-sm text-slate-500">
Select your gym or proceed without a gym
{isSuperAdmin
? "Select a gym to view details, create or delete gyms"
: "Select your gym or proceed without a gym"}
</p>
<p className="text-xs text-blue-600 mt-1">
{user ? (
@@ -180,11 +247,6 @@ export default function SettingsPage() {
<span className="font-medium">
{String(user.publicMetadata?.role ?? "unknown")}
</span>
{" • "}
Gym ID:{" "}
<span className="font-medium">
{String(user.publicMetadata?.gymId ?? "none")}
</span>
</>
) : (
"Loading user metadata..."
@@ -196,6 +258,8 @@ export default function SettingsPage() {
<Button
onClick={fetchGyms}
disabled={gymsLoading}
variant="outline"
size="sm"
className="flex items-center gap-2"
>
{gymsLoading ? (
@@ -203,14 +267,17 @@ export default function SettingsPage() {
) : (
<RefreshCw className="w-4 h-4" />
)}
Refresh Gyms
</Button>
<Button
onClick={() => setShowCreateGym(true)}
className="flex items-center gap-2"
>
Create Gym
Refresh
</Button>
{isSuperAdmin && (
<Button
onClick={() => setShowCreateGym(true)}
size="sm"
className="flex items-center gap-2"
>
Create Gym
</Button>
)}
</div>
</div>
@@ -226,6 +293,7 @@ export default function SettingsPage() {
{gymMessage.text}
</div>
)}
{showCreateGym && (
<div className="fixed inset-0 bg-black bg-opacity-50 flex items-center justify-center z-50">
<div className="bg-white p-6 rounded-lg shadow-lg max-w-md w-full">
@@ -310,59 +378,191 @@ export default function SettingsPage() {
</div>
)}
<div className="grid grid-cols-1 sm:grid-cols-2 lg:grid-cols-3 gap-4">
<div className="border rounded-lg p-4 flex flex-col justify-between">
<div>
<h4 className="font-semibold text-slate-900">
Proceed without gym
</h4>
<p className="text-sm text-slate-600 mt-1">
You can select a gym later.
</p>
</div>
<Button
variant="outline"
className="mt-4"
onClick={() => handleSelectGym(null)}
>
Proceed without gym
</Button>
<div className="grid grid-cols-1 lg:grid-cols-3 gap-6">
{/* Gym List */}
<div className="lg:col-span-1 space-y-4">
<h4 className="font-semibold text-slate-900">Gyms</h4>
{gymsLoading ? (
<div className="flex items-center justify-center p-8 text-slate-500">
<Loader2 className="w-5 h-5 animate-spin mr-2" />
Loading...
</div>
) : gyms.length === 0 ? (
<div className="p-4 text-center text-slate-500">
No active gyms found.
</div>
) : (
<div className="space-y-2 max-h-96 overflow-y-auto">
{gyms.map((gym) => (
<div
key={gym.id}
className={`border rounded-lg p-3 cursor-pointer transition-colors ${
selectedGym?.id === gym.id
? "border-blue-500 bg-blue-50"
: "hover:bg-slate-50"
}`}
onClick={() => handleSelectGym(gym)}
>
<div className="flex items-center justify-between">
<div>
<h5 className="font-medium text-slate-900">
{gym.name}
</h5>
<p className="text-xs text-slate-500">
{gym.location || "No location"}
</p>
</div>
<span
className={`text-xs px-2 py-1 rounded ${
gym.status === "active"
? "bg-green-100 text-green-700"
: "bg-red-100 text-red-700"
}`}
>
{gym.status}
</span>
</div>
</div>
))}
</div>
)}
</div>
{gymsLoading ? (
<div className="col-span-full flex items-center justify-center p-8 text-slate-500">
<Loader2 className="w-5 h-5 animate-spin mr-2" />
Loading gyms...
</div>
) : gyms.length === 0 ? (
<div className="col-span-full p-8 text-center text-slate-500">
No active gyms found.
</div>
) : (
gyms.map((gym) => (
<div
key={gym.id}
className="border rounded-lg p-4 flex flex-col justify-between"
>
<div>
<h4 className="font-semibold text-slate-900">{gym.name}</h4>
<p className="text-sm text-slate-600 mt-1">
{gym.location || "No location provided"}
</p>
{/* Gym Details / Stats */}
<div className="lg:col-span-2">
{selectedGym ? (
<div className="space-y-4">
<div className="flex items-center justify-between">
<h4 className="font-semibold text-slate-900">
{selectedGym.name} - Details
</h4>
{isSuperAdmin && (
<Button
variant="ghost"
size="sm"
className="text-red-600 hover:text-red-700 hover:bg-red-50"
onClick={() => handleDeleteGym(selectedGym.id)}
disabled={deletingGym}
>
{deletingGym ? (
<Loader2 className="w-4 h-4 animate-spin" />
) : (
<Trash2 className="w-4 h-4 mr-1" />
)}
Delete Gym
</Button>
)}
</div>
<Button
variant="default"
className="mt-4"
onClick={() => handleSelectGym(gym.id)}
>
Select this gym
</Button>
{/* Gym Info */}
<div className="grid grid-cols-2 gap-4 p-4 bg-slate-50 rounded-lg">
<div>
<p className="text-xs text-slate-500">Location</p>
<p className="font-medium">
{selectedGym.location || "Not specified"}
</p>
</div>
<div>
<p className="text-xs text-slate-500">Status</p>
<p className="font-medium capitalize">
{selectedGym.status}
</p>
</div>
</div>
{/* Stats */}
{statsLoading ? (
<div className="flex items-center justify-center p-8">
<Loader2 className="w-6 h-6 animate-spin text-slate-400" />
</div>
) : gymStats ? (
<div className="grid grid-cols-2 md:grid-cols-4 gap-4">
<div className="p-4 bg-blue-50 rounded-lg">
<div className="flex items-center gap-2 mb-1">
<Users className="w-4 h-4 text-blue-600" />
<span className="text-xs text-blue-600">
Total Users
</span>
</div>
<p className="text-2xl font-bold text-blue-700">
{gymStats.totalUsers}
</p>
</div>
<div className="p-4 bg-green-50 rounded-lg">
<div className="flex items-center gap-2 mb-1">
<CalendarCheck className="w-4 h-4 text-green-600" />
<span className="text-xs text-green-600">
Active Clients
</span>
</div>
<p className="text-2xl font-bold text-green-700">
{gymStats.activeClients}
</p>
</div>
<div className="p-4 bg-purple-50 rounded-lg">
<div className="flex items-center gap-2 mb-1">
<TrendingUp className="w-4 h-4 text-purple-600" />
<span className="text-xs text-purple-600">
Check-ins (30d)
</span>
</div>
<p className="text-2xl font-bold text-purple-700">
{gymStats.attendanceLast30Days}
</p>
</div>
<div className="p-4 bg-orange-50 rounded-lg">
<div className="flex items-center gap-2 mb-1">
<Users className="w-4 h-4 text-orange-600" />
<span className="text-xs text-orange-600">
Trainers
</span>
</div>
<p className="text-2xl font-bold text-orange-700">
{gymStats.trainers}
</p>
</div>
</div>
) : null}
{/* Membership Distribution */}
{gymStats && (
<div className="mt-4">
<h5 className="text-sm font-medium text-slate-700 mb-2">
Membership Distribution
</h5>
<div className="flex gap-4">
<div className="flex-1 p-3 bg-slate-100 rounded-lg text-center">
<p className="text-2xl font-bold text-slate-700">
{gymStats.membershipStats.basic}
</p>
<p className="text-xs text-slate-500">Basic</p>
</div>
<div className="flex-1 p-3 bg-blue-50 rounded-lg text-center">
<p className="text-2xl font-bold text-blue-700">
{gymStats.membershipStats.premium}
</p>
<p className="text-xs text-blue-500">Premium</p>
</div>
<div className="flex-1 p-3 bg-yellow-50 rounded-lg text-center">
<p className="text-2xl font-bold text-yellow-700">
{gymStats.membershipStats.vip}
</p>
<p className="text-xs text-yellow-600">VIP</p>
</div>
</div>
</div>
)}
</div>
))
)}
) : (
<div className="flex items-center justify-center h-64 bg-slate-50 rounded-lg">
<p className="text-slate-500">Select a gym to view details</p>
</div>
)}
</div>
</div>
</div>
{/* Database Management */}
<div className="bg-white rounded-xl shadow-sm border border-slate-100 p-6">
<div className="flex items-center justify-between mb-6">
<div className="flex items-center gap-3">
+13 -1
View File
@@ -1,17 +1,29 @@
"use client";
import { UserManagement } from "@/components/users/UserManagement";
import { PageHeader } from "@/components/ui/PageHeader";
import { useUser } from "@clerk/nextjs";
import { useSearchParams } from "next/navigation";
import { GymSelector } from "@/components/gym/GymSelector";
export default function UsersPage() {
const { user } = useUser();
const searchParams = useSearchParams();
const userRole = (user?.publicMetadata?.role as string) ?? "client";
const gymId = searchParams.get("gymId") ?? undefined;
return (
<div className="space-y-8">
<PageHeader
title="Users"
description="Manage your gym members, trainers, and administrators"
breadcrumbs={[{ label: "Users", href: "/users" }]}
actions={<GymSelector userRole={userRole} />}
/>
<div className="card-modern">
<UserManagement />
<UserManagement gymId={gymId} />
</div>
</div>
);
@@ -6,8 +6,12 @@ import { RevenueChart } from "@/components/charts/RevenueChart";
import { Card, CardHeader, CardContent } from "@/components/ui/card";
import { useAnalytics } from "@/hooks/use-api";
export function AnalyticsDashboard() {
const { data: analytics, isLoading } = useAnalytics(6);
interface AnalyticsDashboardProps {
gymId?: string;
}
export function AnalyticsDashboard({ gymId }: AnalyticsDashboardProps) {
const { data: analytics, isLoading } = useAnalytics(6, gymId);
const userGrowthData = analytics?.userGrowth ?? [];
const membershipData = analytics?.membershipDistribution ?? [];
@@ -0,0 +1,91 @@
"use client";
import { useRouter, useSearchParams } from "next/navigation";
import { useEffect, useState } from "react";
interface Gym {
id: string;
name: string;
}
interface GymSelectorProps {
currentGymId?: string;
userRole: string;
}
export function GymSelector({ userRole }: GymSelectorProps) {
const router = useRouter();
const searchParams = useSearchParams();
const [gyms, setGyms] = useState<Gym[]>([]);
const [loading, setLoading] = useState(true);
useEffect(() => {
// Only fetch gyms for superAdmin
if (userRole !== "superAdmin") {
setLoading(false);
return;
}
async function fetchGyms() {
try {
const response = await fetch("/api/gyms");
const data = await response.json();
// API returns array directly
if (Array.isArray(data)) {
setGyms(data);
}
} catch (error) {
console.error("Failed to fetch gyms:", error);
} finally {
setLoading(false);
}
}
fetchGyms();
}, [userRole]);
const handleGymChange = (gymId: string) => {
const params = new URLSearchParams(searchParams.toString());
if (gymId === "all") {
params.delete("gymId");
} else {
params.set("gymId", gymId);
}
router.push(`?${params.toString()}`);
};
// Only show for superAdmin
if (userRole !== "superAdmin") {
return null;
}
const selectedGymId = searchParams.get("gymId") ?? "all";
if (loading) {
return (
<div className="flex items-center gap-2">
<div className="h-9 w-40 animate-pulse rounded-md bg-muted" />
</div>
);
}
return (
<div className="flex items-center gap-2">
<select
value={selectedGymId}
onChange={(e) => handleGymChange(e.target.value)}
className="h-9 rounded-md border border-input bg-background px-3 py-1 text-sm shadow-sm transition-colors focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring"
>
<option value="all">All Gyms</option>
{gyms.map((gym) => (
<option key={gym.id} value={gym.id}>
{gym.name}
</option>
))}
</select>
</div>
);
}
@@ -16,7 +16,11 @@ import {
useSendInvitation,
} from "@/hooks/use-api";
export function UserManagement() {
interface UserManagementProps {
gymId?: string;
}
export function UserManagement({ gymId }: UserManagementProps) {
const { user } = useUser();
const [filter, setFilter] = useState<string>("all");
const [selectedUser, setSelectedUser] = useState<User | null>(null);
@@ -38,6 +42,7 @@ export function UserManagement() {
refetch,
} = useUsers({
role: filter !== "all" ? filter : undefined,
gymId,
});
const { data: gyms = [] } = useGyms();
const updateUser = useUpdateUser();
+10 -6
View File
@@ -370,12 +370,16 @@ export interface AnalyticsData {
revenue: { label: string; value: number; color: string }[];
}
export function useAnalytics(months: number = 6) {
export function useAnalytics(months: number = 6, gymId?: string) {
return useQuery({
queryKey: ["analytics", months],
queryFn: () =>
fetchApi<{ data: { analytics: AnalyticsData } }>(
`/api/admin/analytics?months=${months}`,
).then((res) => res.data?.analytics),
queryKey: ["analytics", months, gymId],
queryFn: () => {
const url = gymId
? `/api/admin/analytics?months=${months}&gymId=${gymId}`
: `/api/admin/analytics?months=${months}`;
return fetchApi<{ data: { analytics: AnalyticsData } }>(url).then(
(res) => res.data?.analytics,
);
},
});
}
+231
View File
@@ -0,0 +1,231 @@
import { NextRequest, NextResponse } from "next/server";
import { auth } from "@clerk/nextjs/server";
import { USER_ROLES, type UserRole } from "@fitai/shared";
import { getDatabase } from "../database";
export interface AuthContext {
userId: string;
role: UserRole;
gymId: string | null;
}
export interface AuthResult extends AuthContext {}
/**
* Get the full authentication context including gymId
* Combines Clerk session claims with database lookup for accurate gym assignment
*
* @returns AuthContext with userId, role, and gymId
*
* @example
* const { userId, role, gymId } = await getAuthContext();
* // userId: "user_abc123"
* // role: "admin"
* // gymId: "gym_xyz"
*/
export async function getAuthContext(): Promise<AuthContext> {
const { userId, sessionClaims } = await auth();
if (!userId) {
throw new Error("Unauthorized: No authenticated user");
}
// Get role from Clerk metadata
const role = (sessionClaims?.metadata as { role?: UserRole })?.role;
if (!role || !USER_ROLES.includes(role)) {
throw new Error(`Forbidden: Invalid or missing role - ${role}`);
}
// Get gymId from Clerk metadata or database
let gymId: string | null = null;
// First try Clerk metadata (faster path)
const clerkGymId = (sessionClaims?.metadata as { gymId?: string })?.gymId;
if (clerkGymId) {
gymId = clerkGymId;
} else {
// Fallback to database lookup
try {
const db = await getDatabase();
const user = await db.getUserById(userId);
gymId = user?.gymId ?? null;
} catch (error) {
console.error("Failed to get gymId from database:", error);
gymId = null;
}
}
return { userId, role, gymId };
}
/**
* Middleware to require authentication and optionally check user role
* Enhanced version that also retrieves gymId
*
* @param allowedRoles - Array of roles allowed to access the endpoint (optional)
* @returns Authentication result with userId, role, and gymId, or NextResponse error
*
* @example
* export async function DELETE(request: NextRequest) {
* const authResult = await requireAuth(["admin", "superAdmin"]);
* if (authResult instanceof NextResponse) return authResult;
* const { userId, role, gymId } = authResult;
* // ... proceed with authorized logic
* }
*/
export async function requireAuth(
allowedRoles?: UserRole[],
): Promise<AuthResult | NextResponse> {
try {
const context = await getAuthContext();
// Check if user has required role
if (allowedRoles && allowedRoles.length > 0) {
if (!allowedRoles.includes(context.role)) {
return NextResponse.json(
{
error: `Forbidden - Requires one of: ${allowedRoles.join(", ")}`,
requiredRoles: allowedRoles,
userRole: context.role,
},
{ status: 403 },
);
}
}
return context;
} catch (error) {
const message = error instanceof Error ? error.message : "Unknown error";
if (message.includes("Unauthorized")) {
return NextResponse.json(
{ error: "Unauthorized - Authentication required" },
{ status: 401 },
);
}
if (message.includes("Forbidden")) {
return NextResponse.json({ error: message }, { status: 403 });
}
return NextResponse.json(
{ error: "Internal server error" },
{ status: 500 },
);
}
}
/**
* Require authentication with gym access validation
* Use this for endpoints that need to verify the user can access a specific gym
*
* @param allowedRoles - Roles allowed to access this endpoint
* @param requiredGymId - Gym ID that must be accessed (optional - uses user's gym if not provided)
* @returns AuthResult with full context, or NextResponse error
*
* @example
* // Admin accessing their own gym
* const result = await requireGymAccess(["admin"]);
*
* // SuperAdmin accessing specific gym
* const result = await requireGymAccess(["superAdmin"], "gym_123");
*/
export async function requireGymAccess(
allowedRoles: UserRole[],
requiredGymId?: string,
): Promise<AuthResult | NextResponse> {
const authResult = await requireAuth(allowedRoles);
if (authResult instanceof NextResponse) {
return authResult;
}
const { role, gymId: userGymId } = authResult;
// Determine target gym
const targetGymId = requiredGymId ?? userGymId;
// SuperAdmin can access any gym
if (role === "superAdmin") {
return { ...authResult, gymId: targetGymId };
}
// Other roles must have matching gym
if (!targetGymId) {
return NextResponse.json(
{ error: "Forbidden - User is not assigned to a gym" },
{ status: 403 },
);
}
if (userGymId !== targetGymId) {
return NextResponse.json(
{ error: "Forbidden - Cannot access other gym's data" },
{ status: 403 },
);
}
return { ...authResult, gymId: targetGymId };
}
/**
* Get the target gym ID from request for superAdmin context switching
* SuperAdmins can pass ?gymId to view specific gym data
*
* @param request - NextRequest with query params
* @param userRole - Current user's role
* @param userGymId - Current user's gym ID
* @returns Target gym ID or undefined for superAdmin viewing all
*
* @example
* const targetGymId = getTargetGymId(request, role, gymId);
* // For superAdmin with ?gymId=abc -> "abc"
* // For superAdmin without param -> undefined (all gyms)
* // For admin -> always returns their gymId
*/
export function getTargetGymId(
request: NextRequest,
userRole: UserRole,
userGymId: string | null,
): string | undefined {
// For superAdmin, allow gymId query param for context switching
if (userRole === "superAdmin") {
const queryGymId = request.nextUrl.searchParams.get("gymId");
return queryGymId ?? undefined;
}
// For other roles, they can only access their own gym
return userGymId ?? undefined;
}
/**
* Check if the authenticated user is trying to modify their own account
* Useful for preventing self-deletion or self-demotion
*/
export function isSelfModification(
userId: string,
targetUserId: string,
): boolean {
return userId === targetUserId;
}
/**
* Validate that an admin isn't demoting themselves or deleting their own account
*/
export function preventSelfModification(
userId: string,
targetUserId: string,
action: string,
): NextResponse | undefined {
if (isSelfModification(userId, targetUserId)) {
return NextResponse.json(
{
error: `Cannot ${action} your own account`,
hint: "Ask another administrator to perform this action",
},
{ status: 403 },
);
}
return undefined;
}
+249
View File
@@ -0,0 +1,249 @@
import type { UserRole } from "@fitai/shared";
import { NextResponse } from "next/server";
/**
* Check if a user can access data from a specific gym
*
* @param userRole - The role of the requesting user
* @param userGymId - The gym ID of the requesting user (null for superAdmin)
* @param targetGymId - The gym ID being accessed (undefined means all gyms)
* @returns true if access is allowed
*
* @example
* // SuperAdmin accessing any gym
* canAccessGym("superAdmin", null, "gym_123") // true
*
* // Admin accessing their own gym
* canAccessGym("admin", "gym_abc", "gym_abc") // true
*
* // Admin trying to access other gym
* canAccessGym("admin", "gym_abc", "gym_xyz") // false
*/
export function canAccessGym(
userRole: UserRole,
userGymId: string | null,
targetGymId: string | undefined,
): boolean {
// SuperAdmin can access any gym
if (userRole === "superAdmin") {
return true;
}
// If no target gym specified, allow access to own gym
if (targetGymId === undefined) {
return true;
}
// Non-superAdmins must have a gymId
if (!userGymId) {
return false;
}
// Must match the gym
return userGymId === targetGymId;
}
/**
* Check if a user can manage (create/update/delete) another user
* Based on role hierarchy and gym membership
*
* @param requesterRole - Role of the user making the request
* @param requesterGymId - Gym ID of the requesting user
* @param targetRole - Role of the user being managed
* @param targetGymId - Gym ID of the user being managed
* @returns true if management is allowed
*
* @example
* // SuperAdmin can manage anyone
* canManageUser("superAdmin", null, "admin", "gym_abc") // true
*
* // Admin can manage trainers and clients in their gym
* canManageUser("admin", "gym_abc", "trainer", "gym_abc") // true
* canManageUser("admin", "gym_abc", "client", "gym_abc") // true
*
* // Admin cannot manage users in other gyms
* canManageUser("admin", "gym_abc", "trainer", "gym_xyz") // false
*
* // Trainer can manage clients in their gym
* canManageUser("trainer", "gym_abc", "client", "gym_abc") // true
*/
export function canManageUser(
requesterRole: UserRole,
requesterGymId: string | null,
targetRole: UserRole,
targetGymId: string | null,
): boolean {
// SuperAdmin can manage anyone
if (requesterRole === "superAdmin") {
return true;
}
// Role hierarchy: admin > trainer > client
const roleHierarchy: Record<UserRole, number> = {
superAdmin: 4,
admin: 3,
trainer: 2,
client: 1,
};
const requesterLevel = roleHierarchy[requesterRole];
const targetLevel = roleHierarchy[targetRole];
// Cannot manage users at same or higher level
if (requesterLevel <= targetLevel) {
return false;
}
// Must have gym access
if (!requesterGymId) {
return false;
}
// For admin/trainer, target must be in same gym
if (requesterRole === "admin" || requesterRole === "trainer") {
return requesterGymId === targetGymId;
}
return false;
}
/**
* Check if a trainer can access a specific client's data
* Trainer must be assigned to that client via trainerClients table
*
* @param trainerGymId - Gym ID of the trainer
* @param clientGymId - Gym ID of the client
* @returns true if in same gym
*
* @note In a more complex system, this would query trainerClients table
* For now, we use gym-based access (trainer and client in same gym)
*/
export function canTrainerAccessClient(
trainerGymId: string | null,
clientGymId: string | null,
): boolean {
if (!trainerGymId || !clientGymId) {
return false;
}
return trainerGymId === clientGymId;
}
/**
* Get the roles that a specific role can invite
* Based on role hierarchy
*
* @param role - The role wanting to invite
* @returns Array of roles that can be invited
*
* @example
* getInvitableRoles("superAdmin") // ["admin", "trainer", "client"]
* getInvitableRoles("admin") // ["trainer", "client"]
* getInvitableRoles("trainer") // ["client"]
* getInvitableRoles("client") // []
*/
export function getInvitableRoles(role: UserRole): UserRole[] {
const invitationRules: Record<UserRole, UserRole[]> = {
superAdmin: ["admin", "trainer", "client"],
admin: ["trainer", "client"],
trainer: ["client"],
client: [],
};
return invitationRules[role] ?? [];
}
/**
* Validate gym access and return error response if denied
* Use this in API routes to enforce gym-based access control
*
* @param request - NextRequest for getting query params
* @param userRole - Current user's role
* @param userGymId - Current user's gym ID
* @param targetGymId - Gym being accessed (optional)
* @returns NextResponse if denied, undefined if allowed
*
* @example
* export async function GET(request: NextRequest) {
* const error = await validateGymAccess(request, role, gymId);
* if (error) return error;
* // ... proceed
* }
*/
export function validateGymAccess(
userRole: UserRole,
userGymId: string | null,
targetGymId?: string,
): NextResponse | undefined {
if (!canAccessGym(userRole, userGymId, targetGymId)) {
return NextResponse.json(
{ error: "Forbidden - Cannot access this gym's data" },
{ status: 403 },
);
}
return undefined;
}
/**
* Get filter condition for gym-scoped queries
* Returns appropriate filter based on user role
*
* @param userRole - Current user's role
* @param userGymId - Current user's gym ID
* @returns Filter object or undefined (no filter = all gyms)
*
* @example
* // For superAdmin: returns undefined (no filter)
* getGymFilter("superAdmin", null) // undefined
*
* // For admin: returns { gymId: "gym_abc" }
* getGymFilter("admin", "gym_abc") // { gymId: "gym_abc" }
*/
export function getGymFilter(
userRole: UserRole,
userGymId: string | null,
): { gymId: string } | undefined {
// SuperAdmin sees all gyms
if (userRole === "superAdmin") {
return undefined;
}
// Other roles filtered by their gym
if (userGymId) {
return { gymId: userGymId };
}
// No gym assigned - return filter that matches nothing
return { gymId: "" };
}
/**
* Get all gym IDs a user can access
* SuperAdmin gets all gyms, others get only their own
*
* @param userRole - Current user's role
* @param userGymId - Current user's gym ID
* @param allGymIds - List of all gym IDs in system (for superAdmin)
* @returns Array of accessible gym IDs
*
* @example
* getAccessibleGymIds("admin", "gym_abc", ["gym_abc", "gym_xyz"])
* // Returns: ["gym_abc"]
*
* getAccessibleGymIds("superAdmin", null, ["gym_abc", "gym_xyz"])
* // Returns: ["gym_abc", "gym_xyz"]
*/
export function getAccessibleGymIds(
userRole: UserRole,
userGymId: string | null,
allGymIds: string[],
): string[] {
if (userRole === "superAdmin") {
return allGymIds;
}
if (userGymId) {
return [userGymId];
}
return [];
}
+149
View File
@@ -0,0 +1,149 @@
import { getDatabase } from "@/lib/database";
/**
* Get users filtered by gym ID
*
* @param gymId - Gym ID to filter by (undefined returns all users for superAdmin)
* @returns Array of users in the gym
*/
export async function getUsersByGym(gymId?: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
if (!gymId) {
return allUsers;
}
return allUsers.filter((u) => u.gymId === gymId);
}
/**
* Get clients filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of clients in the gym
*/
export async function getClientsByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
const allClients = await db.getAllClients();
const gymClientUserIds = allUsers
.filter((u) => u.gymId === gymId && u.role === "client")
.map((u) => u.id);
if (gymClientUserIds.length === 0) {
return [];
}
return allClients.filter((c) => gymClientUserIds.includes(c.userId));
}
/**
* Get trainers filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of trainers in the gym
*/
export async function getTrainersByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
return allUsers.filter((u) => u.gymId === gymId && u.role === "trainer");
}
/**
* Get attendance filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of attendance records in the gym
*/
export async function getAttendanceByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
const allAttendance = await db.getAllAttendance();
const gymUserIds = allUsers.filter((u) => u.gymId === gymId).map((u) => u.id);
if (gymUserIds.length === 0) {
return [];
}
return allAttendance.filter((a) => gymUserIds.includes(a.userId));
}
/**
* Get recommendations filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of recommendations in the gym
*/
export async function getRecommendationsByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
const allRecommendations = await db.getAllRecommendations();
const gymUserIds = allUsers.filter((u) => u.gymId === gymId).map((u) => u.id);
if (gymUserIds.length === 0) {
return [];
}
return allRecommendations.filter((r) => gymUserIds.includes(r.userId));
}
/**
* Get fitness profiles filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of fitness profiles in the gym
*/
export async function getFitnessProfilesByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
const allProfiles = await db.getAllFitnessProfiles();
const gymUserIds = allUsers.filter((u) => u.gymId === gymId).map((u) => u.id);
if (gymUserIds.length === 0) {
return [];
}
return allProfiles.filter((p) => gymUserIds.includes(p.userId));
}
/**
* Get fitness goals filtered by gym ID
*
* @param gymId - Gym ID to filter by
* @returns Array of fitness goals in the gym
*/
export async function getFitnessGoalsByGym(gymId: string) {
const db = await getDatabase();
const allUsers = await db.getAllUsers();
const gymUserIds = allUsers.filter((u) => u.gymId === gymId).map((u) => u.id);
if (gymUserIds.length === 0) {
return [];
}
const allGoals: any[] = [];
for (const userId of gymUserIds) {
const goals = await db.getFitnessGoalsByUserId(userId);
allGoals.push(...goals);
}
return allGoals.sort(
(a, b) => new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime(),
);
}
/**
* Get user by ID and check if they belong to a specific gym
*/
export async function getUserGymId(userId: string): Promise<string | null> {
const db = await getDatabase();
const user = await db.getUserById(userId);
return user?.gymId ?? null;
}
@@ -0,0 +1,138 @@
/**
* Migration Script: Fix gym assignments for users without gymId
*
* This script:
* 1. Finds all users with null gymId
* 2. For admins: Assigns them to gym where they are adminUserId
* 3. For trainers: Gets gymId from their trainerClients records
* 4. For clients: Gets gymId from trainerClients or leaves as null for manual review
*
* Run with: node apps/admin/src/lib/migrations/fix-gym-assignments.js
*
* Note: Run this AFTER setting up the database, before starting the app
*/
const Database = require("better-sqlite3");
// Use absolute path to the database - this is where the app stores data
const dbPath = "/home/echo/dev/prototype/apps/admin/data/fitai.db";
function fixGymAssignments() {
console.log("Starting gym assignment migration...\n");
console.log(`Database path: ${dbPath}\n`);
const db = new Database(dbPath);
// Step 1: Find all users without gymId
const usersWithoutGym = db
.prepare(
`
SELECT id, email, role FROM users WHERE gym_id IS NULL
`,
)
.all();
console.log(`Found ${usersWithoutGym.length} users without gymId`);
let adminsFixed = 0;
let trainersFixed = 0;
let clientsFixed = 0;
const unableToFix = [];
for (const user of usersWithoutGym) {
try {
if (user.role === "admin") {
// Find gym where this user is admin
const gym = db
.prepare(
`
SELECT id, name FROM gyms WHERE admin_user_id = ?
`,
)
.get(user.id);
if (gym) {
db.prepare(
`
UPDATE users SET gym_id = ? WHERE id = ?
`,
).run(gym.id, user.id);
console.log(` ✓ Fixed admin ${user.email} -> gym ${gym.name}`);
adminsFixed++;
} else {
unableToFix.push(`Admin ${user.email} (no gym found)`);
}
} else if (user.role === "trainer") {
// Get gym from trainerClients
const tc = db
.prepare(
`
SELECT gym_id FROM trainer_clients WHERE trainer_user_id = ? LIMIT 1
`,
)
.get(user.id);
if (tc) {
db.prepare(
`
UPDATE users SET gym_id = ? WHERE id = ?
`,
).run(tc.gym_id, user.id);
console.log(` ✓ Fixed trainer ${user.email} -> gym ${tc.gym_id}`);
trainersFixed++;
} else {
unableToFix.push(`Trainer ${user.email} (no trainerClients record)`);
}
} else if (user.role === "client") {
// Get gym from trainerClients
const tc = db
.prepare(
`
SELECT gym_id FROM trainer_clients WHERE client_user_id = ? LIMIT 1
`,
)
.get(user.id);
if (tc) {
db.prepare(
`
UPDATE users SET gym_id = ? WHERE id = ?
`,
).run(tc.gym_id, user.id);
console.log(` ✓ Fixed client ${user.email} -> gym ${tc.gym_id}`);
clientsFixed++;
} else {
unableToFix.push(`Client ${user.email} (no trainer assignment)`);
}
}
} catch (error) {
console.error(` ✗ Error fixing user ${user.email}:`, error.message);
unableToFix.push(`User ${user.email} (error: ${error.message})`);
}
}
db.close();
console.log("\n=== Migration Summary ===");
console.log(`Admins fixed: ${adminsFixed}`);
console.log(`Trainers fixed: ${trainersFixed}`);
console.log(`Clients fixed: ${clientsFixed}`);
console.log(`Unable to fix: ${unableToFix.length}`);
if (unableToFix.length > 0) {
console.log("\nUsers requiring manual review:");
unableToFix.forEach((u) => console.log(` - ${u}`));
}
console.log("\nMigration complete!");
}
// Run if called directly
if (require.main === module) {
fixGymAssignments();
}
module.exports = { fixGymAssignments };
+4 -2
View File
@@ -15,8 +15,10 @@ export const passwordSchema = z
export const phoneSchema = z
.string()
.regex(/^\+?[1-9]\d{1,14}$/, "Invalid phone number format")
.optional();
.optional()
.refine((val) => !val || /^\+?[1-9]\d{1,14}$/.test(val), {
message: "Invalid phone number format",
});
export const dateTimeSchema = z.string().datetime("Invalid datetime format");
View File
Whitespace-only changes.