Compare commits
No commits in common. "71ccea85d24e01570e96ab211420582b7a6cf369" and "4e322503cc2cd926d6b01e294c8cb6b6e4c19628" have entirely different histories.
71ccea85d2
...
4e322503cc
Binary file not shown.
@ -1,44 +1,20 @@
|
|||||||
/**
|
/**
|
||||||
* @jest-environment node
|
* @jest-environment node
|
||||||
*/
|
*/
|
||||||
import { POST as checkIn } from "../check-in/route";
|
import { POST as checkIn } from '../check-in/route'
|
||||||
import { POST as checkOut } from "../check-out/route";
|
import { POST as checkOut } from '../check-out/route'
|
||||||
import { GET as history } from "../history/route";
|
import { GET as history } from '../history/route'
|
||||||
import { NextRequest } from "next/server";
|
import { NextRequest } from 'next/server'
|
||||||
|
|
||||||
// Mock dependencies
|
// Mock dependencies
|
||||||
jest.mock("@clerk/nextjs/server", () => ({
|
jest.mock('@clerk/nextjs/server', () => ({
|
||||||
auth: jest.fn(() => Promise.resolve({ userId: "test_user_id" })),
|
auth: jest.fn(() => Promise.resolve({ userId: 'test_user_id' })),
|
||||||
currentUser: jest.fn(() =>
|
currentUser: jest.fn(() => Promise.resolve({ id: 'test_user_id', emailAddresses: [{ emailAddress: 'test@example.com' }] }))
|
||||||
Promise.resolve({
|
}))
|
||||||
id: "test_user_id",
|
|
||||||
emailAddresses: [{ emailAddress: "test@example.com" }],
|
|
||||||
}),
|
|
||||||
),
|
|
||||||
}));
|
|
||||||
|
|
||||||
jest.mock("@/lib/sync-user", () => ({
|
jest.mock('@/lib/sync-user', () => ({
|
||||||
ensureUserSynced: jest.fn(),
|
ensureUserSynced: jest.fn()
|
||||||
}));
|
}))
|
||||||
|
|
||||||
jest.mock("@/lib/geofence", () => ({
|
|
||||||
getUserGymGeofence: jest.fn(() =>
|
|
||||||
Promise.resolve({
|
|
||||||
id: "gym_1",
|
|
||||||
name: "Test Gym",
|
|
||||||
latitude: 1,
|
|
||||||
longitude: 1,
|
|
||||||
geofenceRadiusMeters: 30,
|
|
||||||
geofenceEnabled: true,
|
|
||||||
}),
|
|
||||||
),
|
|
||||||
parseUserLocation: jest.fn(() => ({
|
|
||||||
latitude: 1,
|
|
||||||
longitude: 1,
|
|
||||||
accuracy: 10,
|
|
||||||
})),
|
|
||||||
validateGeofence: jest.fn(() => ({ ok: true })),
|
|
||||||
}));
|
|
||||||
|
|
||||||
const mockDb = {
|
const mockDb = {
|
||||||
checkIn: jest.fn(),
|
checkIn: jest.fn(),
|
||||||
@ -51,128 +27,111 @@ const mockDb = {
|
|||||||
createClient: jest.fn(),
|
createClient: jest.fn(),
|
||||||
getFitnessProfileByUserId: jest.fn(),
|
getFitnessProfileByUserId: jest.fn(),
|
||||||
createFitnessProfile: jest.fn(),
|
createFitnessProfile: jest.fn(),
|
||||||
};
|
}
|
||||||
|
|
||||||
jest.mock("@/lib/database", () => ({
|
jest.mock('@/lib/database', () => ({
|
||||||
getDatabase: jest.fn(() => Promise.resolve(mockDb)),
|
getDatabase: jest.fn(() => Promise.resolve(mockDb))
|
||||||
}));
|
}))
|
||||||
|
|
||||||
describe("Attendance API", () => {
|
describe('Attendance API', () => {
|
||||||
beforeEach(() => {
|
beforeEach(() => {
|
||||||
jest.clearAllMocks();
|
jest.clearAllMocks()
|
||||||
});
|
})
|
||||||
|
|
||||||
describe("POST /api/attendance/check-in", () => {
|
describe('POST /api/attendance/check-in', () => {
|
||||||
it("should successfully check in", async () => {
|
it('should successfully check in', async () => {
|
||||||
mockDb.getUserById.mockResolvedValue({ id: "test_user_id" });
|
mockDb.getUserById.mockResolvedValue({ id: 'test_user_id' })
|
||||||
mockDb.getActiveCheckIn.mockResolvedValue(null);
|
mockDb.getActiveCheckIn.mockResolvedValue(null)
|
||||||
mockDb.checkIn.mockResolvedValue({
|
mockDb.checkIn.mockResolvedValue({
|
||||||
id: "attendance_id",
|
id: 'attendance_id',
|
||||||
userId: "test_user_id",
|
userId: 'test_user_id',
|
||||||
checkInTime: new Date(),
|
checkInTime: new Date(),
|
||||||
type: "gym",
|
type: 'gym'
|
||||||
});
|
})
|
||||||
|
|
||||||
const req = new NextRequest("http://localhost/api/attendance/check-in", {
|
const req = new NextRequest('http://localhost/api/attendance/check-in', {
|
||||||
method: "POST",
|
method: 'POST',
|
||||||
body: JSON.stringify({
|
body: JSON.stringify({ type: 'gym', notes: 'Test check-in' })
|
||||||
type: "gym",
|
})
|
||||||
notes: "Test check-in",
|
|
||||||
location: { latitude: 1, longitude: 1, accuracy: 10 },
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
const res = await checkIn(req);
|
const res = await checkIn(req)
|
||||||
const data = await res.json();
|
const data = await res.json()
|
||||||
|
|
||||||
expect(res.status).toBe(200);
|
expect(res.status).toBe(200)
|
||||||
expect(data.id).toBe("attendance_id");
|
expect(data.id).toBe('attendance_id')
|
||||||
expect(data.userId).toBe("test_user_id");
|
expect(data.userId).toBe('test_user_id')
|
||||||
expect(mockDb.checkIn).toHaveBeenCalledWith(
|
expect(mockDb.checkIn).toHaveBeenCalledWith('test_user_id', 'gym', 'Test check-in')
|
||||||
"test_user_id",
|
})
|
||||||
"gym",
|
|
||||||
"Test check-in",
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("should fail if already checked in", async () => {
|
it('should fail if already checked in', async () => {
|
||||||
mockDb.getUserById.mockResolvedValue({ id: "test_user_id" });
|
mockDb.getUserById.mockResolvedValue({ id: 'test_user_id' })
|
||||||
mockDb.getActiveCheckIn.mockResolvedValue({ id: "existing_id" });
|
mockDb.getActiveCheckIn.mockResolvedValue({ id: 'existing_id' })
|
||||||
|
|
||||||
const req = new NextRequest("http://localhost/api/attendance/check-in", {
|
const req = new NextRequest('http://localhost/api/attendance/check-in', {
|
||||||
method: "POST",
|
method: 'POST',
|
||||||
body: JSON.stringify({
|
body: JSON.stringify({ type: 'gym' })
|
||||||
type: "gym",
|
})
|
||||||
location: { latitude: 1, longitude: 1, accuracy: 10 },
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
const res = await checkIn(req);
|
const res = await checkIn(req)
|
||||||
const text = await res.text();
|
const text = await res.text()
|
||||||
|
|
||||||
expect(res.status).toBe(400);
|
expect(res.status).toBe(400)
|
||||||
expect(text).toBe("Already checked in");
|
expect(text).toBe('Already checked in')
|
||||||
});
|
})
|
||||||
});
|
})
|
||||||
|
|
||||||
describe("POST /api/attendance/check-out", () => {
|
describe('POST /api/attendance/check-out', () => {
|
||||||
it("should successfully check out", async () => {
|
it('should successfully check out', async () => {
|
||||||
mockDb.getActiveCheckIn.mockResolvedValue({ id: "attendance_id" });
|
mockDb.getActiveCheckIn.mockResolvedValue({ id: 'attendance_id' })
|
||||||
mockDb.checkOut.mockResolvedValue({
|
mockDb.checkOut.mockResolvedValue({
|
||||||
id: "attendance_id",
|
id: 'attendance_id',
|
||||||
checkOutTime: new Date(),
|
checkOutTime: new Date()
|
||||||
});
|
})
|
||||||
|
|
||||||
const req = new NextRequest("http://localhost/api/attendance/check-out", {
|
const req = new NextRequest('http://localhost/api/attendance/check-out', {
|
||||||
method: "POST",
|
method: 'POST'
|
||||||
body: JSON.stringify({
|
})
|
||||||
location: { latitude: 1, longitude: 1, accuracy: 10 },
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
const res = await checkOut(req);
|
const res = await checkOut(req)
|
||||||
const data = await res.json();
|
const data = await res.json()
|
||||||
|
|
||||||
expect(res.status).toBe(200);
|
expect(res.status).toBe(200)
|
||||||
expect(data.id).toBe("attendance_id");
|
expect(data.id).toBe('attendance_id')
|
||||||
expect(data.checkOutTime).toBeDefined();
|
expect(data.checkOutTime).toBeDefined()
|
||||||
expect(mockDb.checkOut).toHaveBeenCalledWith("attendance_id");
|
expect(mockDb.checkOut).toHaveBeenCalledWith('attendance_id')
|
||||||
});
|
})
|
||||||
|
|
||||||
it("should fail if not checked in", async () => {
|
it('should fail if not checked in', async () => {
|
||||||
mockDb.getActiveCheckIn.mockResolvedValue(null);
|
mockDb.getActiveCheckIn.mockResolvedValue(null)
|
||||||
|
|
||||||
const req = new NextRequest("http://localhost/api/attendance/check-out", {
|
const req = new NextRequest('http://localhost/api/attendance/check-out', {
|
||||||
method: "POST",
|
method: 'POST'
|
||||||
body: JSON.stringify({
|
})
|
||||||
location: { latitude: 1, longitude: 1, accuracy: 10 },
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
const res = await checkOut(req);
|
const res = await checkOut(req)
|
||||||
const text = await res.text();
|
const text = await res.text()
|
||||||
|
|
||||||
expect(res.status).toBe(404);
|
expect(res.status).toBe(404)
|
||||||
expect(text).toBe("No active check-in found");
|
expect(text).toBe('No active check-in found')
|
||||||
});
|
})
|
||||||
});
|
})
|
||||||
|
|
||||||
describe("GET /api/attendance/history", () => {
|
describe('GET /api/attendance/history', () => {
|
||||||
it("should return attendance history", async () => {
|
it('should return attendance history', async () => {
|
||||||
const historyData = [
|
const historyData = [
|
||||||
{ id: "1", checkInTime: new Date() },
|
{ id: '1', checkInTime: new Date() },
|
||||||
{ id: "2", checkInTime: new Date() },
|
{ id: '2', checkInTime: new Date() }
|
||||||
];
|
]
|
||||||
mockDb.getUserById.mockResolvedValue({ id: "test_user_id" });
|
mockDb.getUserById.mockResolvedValue({ id: 'test_user_id' })
|
||||||
mockDb.getAttendanceHistory.mockResolvedValue(historyData);
|
mockDb.getAttendanceHistory.mockResolvedValue(historyData)
|
||||||
|
|
||||||
const req = new NextRequest("http://localhost/api/attendance/history");
|
const req = new NextRequest('http://localhost/api/attendance/history')
|
||||||
const res = await history(req);
|
const res = await history(req)
|
||||||
const data = await res.json();
|
const data = await res.json()
|
||||||
|
|
||||||
expect(res.status).toBe(200);
|
expect(res.status).toBe(200)
|
||||||
expect(data).toEqual(JSON.parse(JSON.stringify(historyData))); // Handle date serialization
|
expect(data).toEqual(JSON.parse(JSON.stringify(historyData))) // Handle date serialization
|
||||||
expect(mockDb.getAttendanceHistory).toHaveBeenCalledWith("test_user_id");
|
expect(mockDb.getAttendanceHistory).toHaveBeenCalledWith('test_user_id')
|
||||||
});
|
})
|
||||||
});
|
})
|
||||||
});
|
})
|
||||||
|
|||||||
@ -2,12 +2,12 @@ import { auth } from "@clerk/nextjs/server";
|
|||||||
import { NextRequest, NextResponse } from "next/server";
|
import { NextRequest, NextResponse } from "next/server";
|
||||||
import { getDatabase } from "@/lib/database";
|
import { getDatabase } from "@/lib/database";
|
||||||
import { ensureUserSynced } from "@/lib/sync-user";
|
import { ensureUserSynced } from "@/lib/sync-user";
|
||||||
import {
|
|
||||||
getUserGymGeofence,
|
|
||||||
parseUserLocation,
|
|
||||||
validateGeofence,
|
|
||||||
} from "@/lib/geofence";
|
|
||||||
import log from "@/lib/logger";
|
import log from "@/lib/logger";
|
||||||
|
import { checkInSchema } from "@/lib/validation/schemas";
|
||||||
|
import {
|
||||||
|
validateRequestBody,
|
||||||
|
validationErrorResponse,
|
||||||
|
} from "@/lib/validation/helpers";
|
||||||
|
|
||||||
export async function POST(req: NextRequest) {
|
export async function POST(req: NextRequest) {
|
||||||
try {
|
try {
|
||||||
@ -25,26 +25,9 @@ export async function POST(req: NextRequest) {
|
|||||||
return new NextResponse("Already checked in", { status: 400 });
|
return new NextResponse("Already checked in", { status: 400 });
|
||||||
}
|
}
|
||||||
|
|
||||||
const body = await req.json().catch(() => ({}));
|
const body = await req.json();
|
||||||
const { type = "gym", notes } = body;
|
const { type = "gym", notes } = body;
|
||||||
|
|
||||||
const gym = await getUserGymGeofence(userId);
|
|
||||||
if (!gym) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "No gym assigned for this user" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const location = parseUserLocation(body.location);
|
|
||||||
const geofence = validateGeofence(gym, location);
|
|
||||||
if (!geofence.ok) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: geofence.error },
|
|
||||||
{ status: geofence.status },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const attendance = await db.checkIn(userId, type, notes);
|
const attendance = await db.checkIn(userId, type, notes);
|
||||||
return NextResponse.json(attendance);
|
return NextResponse.json(attendance);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
|||||||
@ -1,11 +1,6 @@
|
|||||||
import { auth } from "@clerk/nextjs/server";
|
import { auth } from "@clerk/nextjs/server";
|
||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
import { getDatabase } from "@/lib/database";
|
import { getDatabase } from "@/lib/database";
|
||||||
import {
|
|
||||||
getUserGymGeofence,
|
|
||||||
parseUserLocation,
|
|
||||||
validateGeofence,
|
|
||||||
} from "@/lib/geofence";
|
|
||||||
import log from "@/lib/logger";
|
import log from "@/lib/logger";
|
||||||
|
|
||||||
export async function POST(req: Request) {
|
export async function POST(req: Request) {
|
||||||
@ -20,25 +15,6 @@ export async function POST(req: Request) {
|
|||||||
return new NextResponse("No active check-in found", { status: 404 });
|
return new NextResponse("No active check-in found", { status: 404 });
|
||||||
}
|
}
|
||||||
|
|
||||||
const body = await req.json().catch(() => ({}));
|
|
||||||
|
|
||||||
const gym = await getUserGymGeofence(userId);
|
|
||||||
if (!gym) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "No gym assigned for this user" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const location = parseUserLocation(body.location);
|
|
||||||
const geofence = validateGeofence(gym, location);
|
|
||||||
if (!geofence.ok) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: geofence.error },
|
|
||||||
{ status: geofence.status },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const attendance = await db.checkOut(activeCheckIn.id);
|
const attendance = await db.checkOut(activeCheckIn.id);
|
||||||
return NextResponse.json(attendance);
|
return NextResponse.json(attendance);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
|||||||
@ -18,178 +18,6 @@ async function ensureGymsTable() {
|
|||||||
updated_at INTEGER NOT NULL
|
updated_at INTEGER NOT NULL
|
||||||
)
|
)
|
||||||
`);
|
`);
|
||||||
|
|
||||||
const columns = await db.all(sql`PRAGMA table_info('gyms')`);
|
|
||||||
const columnNames = new Set(
|
|
||||||
(columns as Array<{ name?: string }>)
|
|
||||||
.map((col) => col.name)
|
|
||||||
.filter(Boolean),
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!columnNames.has("latitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN latitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("longitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN longitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("geofence_radius_meters")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_radius_meters REAL NOT NULL DEFAULT 30`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("geofence_enabled")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_enabled INTEGER NOT NULL DEFAULT 1`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// PATCH /api/gyms/[id]
|
|
||||||
// Update gym details and geofence configuration
|
|
||||||
export async function PATCH(
|
|
||||||
request: Request,
|
|
||||||
{ params }: { params: Promise<{ id: string }> },
|
|
||||||
) {
|
|
||||||
try {
|
|
||||||
const { id: gymId } = await params;
|
|
||||||
const { userId } = await auth();
|
|
||||||
|
|
||||||
if (!userId) {
|
|
||||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
|
||||||
}
|
|
||||||
|
|
||||||
const appDb = await getDatabase();
|
|
||||||
const currentUser = await ensureUserSynced(userId, appDb);
|
|
||||||
|
|
||||||
if (
|
|
||||||
!currentUser ||
|
|
||||||
(currentUser.role !== "superAdmin" && currentUser.role !== "admin")
|
|
||||||
) {
|
|
||||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
|
||||||
}
|
|
||||||
|
|
||||||
await ensureGymsTable();
|
|
||||||
|
|
||||||
const existingGym = await db
|
|
||||||
.select()
|
|
||||||
.from(gymsTable)
|
|
||||||
.where(eq(gymsTable.id, gymId))
|
|
||||||
.get();
|
|
||||||
|
|
||||||
if (!existingGym) {
|
|
||||||
return NextResponse.json({ error: "Gym not found" }, { status: 404 });
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
currentUser.role === "admin" &&
|
|
||||||
currentUser.gymId &&
|
|
||||||
currentUser.gymId !== gymId
|
|
||||||
) {
|
|
||||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
|
||||||
}
|
|
||||||
|
|
||||||
const body = await request.json().catch(() => null);
|
|
||||||
if (!body || typeof body !== "object") {
|
|
||||||
return NextResponse.json({ error: "Invalid body" }, { status: 400 });
|
|
||||||
}
|
|
||||||
|
|
||||||
const latitude =
|
|
||||||
body.latitude === undefined || body.latitude === null
|
|
||||||
? null
|
|
||||||
: Number(body.latitude);
|
|
||||||
const longitude =
|
|
||||||
body.longitude === undefined || body.longitude === null
|
|
||||||
? null
|
|
||||||
: Number(body.longitude);
|
|
||||||
const geofenceRadiusMeters =
|
|
||||||
body.geofenceRadiusMeters === undefined ||
|
|
||||||
body.geofenceRadiusMeters === null
|
|
||||||
? 30
|
|
||||||
: Number(body.geofenceRadiusMeters);
|
|
||||||
const geofenceEnabled =
|
|
||||||
body.geofenceEnabled === undefined ? true : Boolean(body.geofenceEnabled);
|
|
||||||
|
|
||||||
if (
|
|
||||||
latitude !== null &&
|
|
||||||
(!Number.isFinite(latitude) || latitude < -90 || latitude > 90)
|
|
||||||
) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "latitude must be between -90 and 90" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
longitude !== null &&
|
|
||||||
(!Number.isFinite(longitude) || longitude < -180 || longitude > 180)
|
|
||||||
) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "longitude must be between -180 and 180" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Number.isFinite(geofenceRadiusMeters) || geofenceRadiusMeters <= 0) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "geofenceRadiusMeters must be a positive number" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
await db.run(sql`
|
|
||||||
UPDATE gyms
|
|
||||||
SET
|
|
||||||
latitude = ${latitude},
|
|
||||||
longitude = ${longitude},
|
|
||||||
geofence_radius_meters = ${geofenceRadiusMeters},
|
|
||||||
geofence_enabled = ${geofenceEnabled ? 1 : 0},
|
|
||||||
updated_at = ${Math.floor(Date.now() / 1000)}
|
|
||||||
WHERE id = ${gymId}
|
|
||||||
`);
|
|
||||||
|
|
||||||
const updatedRows = await db.all(sql`
|
|
||||||
SELECT
|
|
||||||
id,
|
|
||||||
name,
|
|
||||||
location,
|
|
||||||
latitude,
|
|
||||||
longitude,
|
|
||||||
geofence_radius_meters as geofenceRadiusMeters,
|
|
||||||
geofence_enabled as geofenceEnabled,
|
|
||||||
status,
|
|
||||||
admin_user_id as adminUserId,
|
|
||||||
created_at as createdAt,
|
|
||||||
updated_at as updatedAt
|
|
||||||
FROM gyms
|
|
||||||
WHERE id = ${gymId}
|
|
||||||
LIMIT 1
|
|
||||||
`);
|
|
||||||
|
|
||||||
const updated = updatedRows?.[0]
|
|
||||||
? {
|
|
||||||
...updatedRows[0],
|
|
||||||
geofenceEnabled:
|
|
||||||
typeof (updatedRows[0] as { geofenceEnabled?: unknown })
|
|
||||||
.geofenceEnabled === "boolean"
|
|
||||||
? (updatedRows[0] as { geofenceEnabled: boolean }).geofenceEnabled
|
|
||||||
: Boolean(
|
|
||||||
(updatedRows[0] as { geofenceEnabled?: unknown })
|
|
||||||
.geofenceEnabled,
|
|
||||||
),
|
|
||||||
}
|
|
||||||
: null;
|
|
||||||
|
|
||||||
return NextResponse.json(updated);
|
|
||||||
} catch (error) {
|
|
||||||
log.error("Failed to update gym", error);
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "Internal Server Error" },
|
|
||||||
{ status: 500 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// DELETE /api/gyms/[id]
|
// DELETE /api/gyms/[id]
|
||||||
|
|||||||
@ -18,33 +18,6 @@ async function ensureGymsTable() {
|
|||||||
updated_at INTEGER NOT NULL
|
updated_at INTEGER NOT NULL
|
||||||
)
|
)
|
||||||
`);
|
`);
|
||||||
|
|
||||||
const columns = await db.all(sql`PRAGMA table_info('gyms')`);
|
|
||||||
const columnNames = new Set(
|
|
||||||
(columns as Array<{ name?: string }>)
|
|
||||||
.map((col) => col.name)
|
|
||||||
.filter(Boolean),
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!columnNames.has("latitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN latitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("longitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN longitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("geofence_radius_meters")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_radius_meters REAL NOT NULL DEFAULT 30`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columnNames.has("geofence_enabled")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_enabled INTEGER NOT NULL DEFAULT 1`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// GET /api/gyms
|
// GET /api/gyms
|
||||||
@ -68,35 +41,12 @@ export async function GET() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
await ensureGymsTable();
|
await ensureGymsTable();
|
||||||
let rows = (await db.all(sql`
|
let rows = await db
|
||||||
SELECT
|
.select()
|
||||||
id,
|
.from(gymsTable)
|
||||||
name,
|
.where(eq(gymsTable.status, "active"))
|
||||||
location,
|
.orderBy(sql`created_at DESC`)
|
||||||
latitude,
|
.all();
|
||||||
longitude,
|
|
||||||
geofence_radius_meters as geofenceRadiusMeters,
|
|
||||||
geofence_enabled as geofenceEnabled,
|
|
||||||
status,
|
|
||||||
admin_user_id as adminUserId,
|
|
||||||
created_at as createdAt,
|
|
||||||
updated_at as updatedAt
|
|
||||||
FROM gyms
|
|
||||||
WHERE status = 'active'
|
|
||||||
ORDER BY created_at DESC
|
|
||||||
`)) as Array<{
|
|
||||||
id: string;
|
|
||||||
name: string;
|
|
||||||
location: string | null;
|
|
||||||
latitude: number | null;
|
|
||||||
longitude: number | null;
|
|
||||||
geofenceRadiusMeters: number | null;
|
|
||||||
geofenceEnabled: number | boolean | null;
|
|
||||||
status: "active" | "inactive";
|
|
||||||
adminUserId: string;
|
|
||||||
createdAt: number;
|
|
||||||
updatedAt: number;
|
|
||||||
}>;
|
|
||||||
|
|
||||||
if (currentUser.role !== "superAdmin") {
|
if (currentUser.role !== "superAdmin") {
|
||||||
if (!currentUser.gymId) {
|
if (!currentUser.gymId) {
|
||||||
@ -105,15 +55,7 @@ export async function GET() {
|
|||||||
rows = rows.filter((row) => row.id === currentUser.gymId);
|
rows = rows.filter((row) => row.id === currentUser.gymId);
|
||||||
}
|
}
|
||||||
|
|
||||||
return NextResponse.json(
|
return NextResponse.json(rows);
|
||||||
rows.map((row) => ({
|
|
||||||
...row,
|
|
||||||
geofenceEnabled:
|
|
||||||
typeof row.geofenceEnabled === "boolean"
|
|
||||||
? row.geofenceEnabled
|
|
||||||
: Boolean(row.geofenceEnabled),
|
|
||||||
})),
|
|
||||||
);
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
log.error("Failed to get gyms", error);
|
log.error("Failed to get gyms", error);
|
||||||
return new NextResponse("Internal Server Error", { status: 500 });
|
return new NextResponse("Internal Server Error", { status: 500 });
|
||||||
@ -147,21 +89,6 @@ export async function POST(req: Request) {
|
|||||||
|
|
||||||
const name = String(body.name ?? "").trim();
|
const name = String(body.name ?? "").trim();
|
||||||
const location = body.location ? String(body.location).trim() : null;
|
const location = body.location ? String(body.location).trim() : null;
|
||||||
const latitude =
|
|
||||||
body.latitude === undefined || body.latitude === null
|
|
||||||
? null
|
|
||||||
: Number(body.latitude);
|
|
||||||
const longitude =
|
|
||||||
body.longitude === undefined || body.longitude === null
|
|
||||||
? null
|
|
||||||
: Number(body.longitude);
|
|
||||||
const geofenceRadiusMeters =
|
|
||||||
body.geofenceRadiusMeters === undefined ||
|
|
||||||
body.geofenceRadiusMeters === null
|
|
||||||
? 30
|
|
||||||
: Number(body.geofenceRadiusMeters);
|
|
||||||
const geofenceEnabled =
|
|
||||||
body.geofenceEnabled === undefined ? true : Boolean(body.geofenceEnabled);
|
|
||||||
let adminUserId: string | null = body.adminUserId
|
let adminUserId: string | null = body.adminUserId
|
||||||
? String(body.adminUserId)
|
? String(body.adminUserId)
|
||||||
: null;
|
: null;
|
||||||
@ -170,33 +97,6 @@ export async function POST(req: Request) {
|
|||||||
return NextResponse.json({ error: "name is required" }, { status: 400 });
|
return NextResponse.json({ error: "name is required" }, { status: 400 });
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
|
||||||
latitude !== null &&
|
|
||||||
(!Number.isFinite(latitude) || latitude < -90 || latitude > 90)
|
|
||||||
) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "latitude must be between -90 and 90" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
longitude !== null &&
|
|
||||||
(!Number.isFinite(longitude) || longitude < -180 || longitude > 180)
|
|
||||||
) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "longitude must be between -180 and 180" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Number.isFinite(geofenceRadiusMeters) || geofenceRadiusMeters <= 0) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: "geofenceRadiusMeters must be a positive number" },
|
|
||||||
{ status: 400 },
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Enforce admin ownership rules
|
// Enforce admin ownership rules
|
||||||
if (currentUser.role === "admin") {
|
if (currentUser.role === "admin") {
|
||||||
adminUserId = currentUser.id;
|
adminUserId = currentUser.id;
|
||||||
@ -224,33 +124,15 @@ export async function POST(req: Request) {
|
|||||||
const nowTs = new Date();
|
const nowTs = new Date();
|
||||||
|
|
||||||
// Use Drizzle's insert method instead of raw SQL
|
// Use Drizzle's insert method instead of raw SQL
|
||||||
await db.run(sql`
|
await db.insert(gymsTable).values({
|
||||||
INSERT INTO gyms (
|
|
||||||
id,
|
id,
|
||||||
name,
|
name,
|
||||||
location,
|
location: location ?? null,
|
||||||
latitude,
|
status: "active",
|
||||||
longitude,
|
adminUserId: adminUserId!,
|
||||||
geofence_radius_meters,
|
createdAt: nowTs,
|
||||||
geofence_enabled,
|
updatedAt: nowTs,
|
||||||
status,
|
});
|
||||||
admin_user_id,
|
|
||||||
created_at,
|
|
||||||
updated_at
|
|
||||||
) VALUES (
|
|
||||||
${id},
|
|
||||||
${name},
|
|
||||||
${location ?? null},
|
|
||||||
${latitude},
|
|
||||||
${longitude},
|
|
||||||
${geofenceRadiusMeters},
|
|
||||||
${geofenceEnabled ? 1 : 0},
|
|
||||||
${"active"},
|
|
||||||
${adminUserId!},
|
|
||||||
${Math.floor(nowTs.getTime() / 1000)},
|
|
||||||
${Math.floor(nowTs.getTime() / 1000)}
|
|
||||||
)
|
|
||||||
`);
|
|
||||||
|
|
||||||
// Assign the admin to this gym immediately after creation
|
// Assign the admin to this gym immediately after creation
|
||||||
await db
|
await db
|
||||||
@ -258,36 +140,11 @@ export async function POST(req: Request) {
|
|||||||
.set({ gymId: id, updatedAt: nowTs })
|
.set({ gymId: id, updatedAt: nowTs })
|
||||||
.where(eq(usersTable.id, adminUserId!));
|
.where(eq(usersTable.id, adminUserId!));
|
||||||
|
|
||||||
const rowsCreated = await db.all(sql`
|
const created = await db
|
||||||
SELECT
|
.select()
|
||||||
id,
|
.from(gymsTable)
|
||||||
name,
|
.where(eq(gymsTable.id, id))
|
||||||
location,
|
.get();
|
||||||
latitude,
|
|
||||||
longitude,
|
|
||||||
geofence_radius_meters as geofenceRadiusMeters,
|
|
||||||
geofence_enabled as geofenceEnabled,
|
|
||||||
status,
|
|
||||||
admin_user_id as adminUserId,
|
|
||||||
created_at as createdAt,
|
|
||||||
updated_at as updatedAt
|
|
||||||
FROM gyms
|
|
||||||
WHERE id = ${id}
|
|
||||||
LIMIT 1
|
|
||||||
`);
|
|
||||||
const createdRow = rowsCreated?.[0] ?? null;
|
|
||||||
const created = createdRow
|
|
||||||
? {
|
|
||||||
...createdRow,
|
|
||||||
geofenceEnabled:
|
|
||||||
typeof (createdRow as { geofenceEnabled?: unknown })
|
|
||||||
.geofenceEnabled === "boolean"
|
|
||||||
? (createdRow as { geofenceEnabled: boolean }).geofenceEnabled
|
|
||||||
: Boolean(
|
|
||||||
(createdRow as { geofenceEnabled?: unknown }).geofenceEnabled,
|
|
||||||
),
|
|
||||||
}
|
|
||||||
: null;
|
|
||||||
return NextResponse.json(created, { status: 201 });
|
return NextResponse.json(created, { status: 201 });
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
log.error("Failed to create gym", error);
|
log.error("Failed to create gym", error);
|
||||||
|
|||||||
@ -29,10 +29,6 @@ interface Gym {
|
|||||||
id: string;
|
id: string;
|
||||||
name: string;
|
name: string;
|
||||||
location?: string | null;
|
location?: string | null;
|
||||||
latitude?: number | null;
|
|
||||||
longitude?: number | null;
|
|
||||||
geofenceRadiusMeters?: number | null;
|
|
||||||
geofenceEnabled?: boolean;
|
|
||||||
status: "active" | "inactive";
|
status: "active" | "inactive";
|
||||||
adminUserId: string;
|
adminUserId: string;
|
||||||
createdAt?: number;
|
createdAt?: number;
|
||||||
@ -76,11 +72,6 @@ export default function SettingsPage() {
|
|||||||
const [gymStats, setGymStats] = useState<GymStats | null>(null);
|
const [gymStats, setGymStats] = useState<GymStats | null>(null);
|
||||||
const [statsLoading, setStatsLoading] = useState(false);
|
const [statsLoading, setStatsLoading] = useState(false);
|
||||||
const [deletingGym, setDeletingGym] = useState(false);
|
const [deletingGym, setDeletingGym] = useState(false);
|
||||||
const [savingGeofence, setSavingGeofence] = useState(false);
|
|
||||||
const [geofenceLatitude, setGeofenceLatitude] = useState("");
|
|
||||||
const [geofenceLongitude, setGeofenceLongitude] = useState("");
|
|
||||||
const [geofenceRadiusMeters, setGeofenceRadiusMeters] = useState("30");
|
|
||||||
const [geofenceEnabled, setGeofenceEnabled] = useState(true);
|
|
||||||
|
|
||||||
// Create Gym modal state
|
// Create Gym modal state
|
||||||
const [showCreateGym, setShowCreateGym] = useState(false);
|
const [showCreateGym, setShowCreateGym] = useState(false);
|
||||||
@ -195,87 +186,6 @@ export default function SettingsPage() {
|
|||||||
const handleSelectGym = async (gym: Gym | null) => {
|
const handleSelectGym = async (gym: Gym | null) => {
|
||||||
setSelectedGym(gym);
|
setSelectedGym(gym);
|
||||||
setGymStats(null);
|
setGymStats(null);
|
||||||
|
|
||||||
if (gym) {
|
|
||||||
setGeofenceLatitude(
|
|
||||||
gym.latitude !== null && gym.latitude !== undefined
|
|
||||||
? String(gym.latitude)
|
|
||||||
: "",
|
|
||||||
);
|
|
||||||
setGeofenceLongitude(
|
|
||||||
gym.longitude !== null && gym.longitude !== undefined
|
|
||||||
? String(gym.longitude)
|
|
||||||
: "",
|
|
||||||
);
|
|
||||||
setGeofenceRadiusMeters(String(gym.geofenceRadiusMeters ?? 30));
|
|
||||||
setGeofenceEnabled(gym.geofenceEnabled ?? true);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const handleSaveGeofence = async () => {
|
|
||||||
if (!selectedGym) return;
|
|
||||||
|
|
||||||
const latitude =
|
|
||||||
geofenceLatitude.trim() === "" ? null : Number(geofenceLatitude);
|
|
||||||
const longitude =
|
|
||||||
geofenceLongitude.trim() === "" ? null : Number(geofenceLongitude);
|
|
||||||
const radius = Number(geofenceRadiusMeters);
|
|
||||||
|
|
||||||
if (
|
|
||||||
latitude !== null &&
|
|
||||||
(!Number.isFinite(latitude) || latitude < -90 || latitude > 90)
|
|
||||||
) {
|
|
||||||
setGymMessage({
|
|
||||||
type: "error",
|
|
||||||
text: "Latitude must be between -90 and 90",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
longitude !== null &&
|
|
||||||
(!Number.isFinite(longitude) || longitude < -180 || longitude > 180)
|
|
||||||
) {
|
|
||||||
setGymMessage({
|
|
||||||
type: "error",
|
|
||||||
text: "Longitude must be between -180 and 180",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Number.isFinite(radius) || radius <= 0) {
|
|
||||||
setGymMessage({
|
|
||||||
type: "error",
|
|
||||||
text: "Radius must be a positive number",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
setSavingGeofence(true);
|
|
||||||
setGymMessage(null);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const response = await axios.patch(`/api/gyms/${selectedGym.id}`, {
|
|
||||||
latitude,
|
|
||||||
longitude,
|
|
||||||
geofenceRadiusMeters: radius,
|
|
||||||
geofenceEnabled,
|
|
||||||
});
|
|
||||||
setGymMessage({ type: "success", text: "Geofence settings updated" });
|
|
||||||
const updatedGym = response.data as Gym;
|
|
||||||
setSelectedGym(updatedGym);
|
|
||||||
setGyms((prev) =>
|
|
||||||
prev.map((gym) => (gym.id === updatedGym.id ? updatedGym : gym)),
|
|
||||||
);
|
|
||||||
} catch (error) {
|
|
||||||
log.error("Failed to update geofence settings", error);
|
|
||||||
setGymMessage({
|
|
||||||
type: "error",
|
|
||||||
text: "Failed to update geofence settings",
|
|
||||||
});
|
|
||||||
} finally {
|
|
||||||
setSavingGeofence(false);
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
|
|
||||||
const handleDeleteGym = async (gymId: string) => {
|
const handleDeleteGym = async (gymId: string) => {
|
||||||
@ -565,91 +475,6 @@ export default function SettingsPage() {
|
|||||||
{selectedGym.status}
|
{selectedGym.status}
|
||||||
</p>
|
</p>
|
||||||
</div>
|
</div>
|
||||||
<div>
|
|
||||||
<p className="text-xs text-slate-500">Geofence</p>
|
|
||||||
<p className="font-medium">
|
|
||||||
{selectedGym.geofenceEnabled === false
|
|
||||||
? "Disabled"
|
|
||||||
: `${selectedGym.geofenceRadiusMeters ?? 30}m`}
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{/* Geofence Settings */}
|
|
||||||
<div className="p-4 border rounded-lg space-y-3">
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<h5 className="text-sm font-medium text-slate-700">
|
|
||||||
Attendance Geofence
|
|
||||||
</h5>
|
|
||||||
<label className="inline-flex items-center gap-2 text-sm text-slate-700">
|
|
||||||
<input
|
|
||||||
type="checkbox"
|
|
||||||
checked={geofenceEnabled}
|
|
||||||
onChange={(e) => setGeofenceEnabled(e.target.checked)}
|
|
||||||
/>
|
|
||||||
Enabled
|
|
||||||
</label>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div className="grid grid-cols-1 md:grid-cols-3 gap-3">
|
|
||||||
<div>
|
|
||||||
<label className="block text-xs text-slate-500 mb-1">
|
|
||||||
Latitude
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="number"
|
|
||||||
step="any"
|
|
||||||
value={geofenceLatitude}
|
|
||||||
onChange={(e) => setGeofenceLatitude(e.target.value)}
|
|
||||||
className="w-full border border-gray-300 rounded px-3 py-2"
|
|
||||||
placeholder="e.g. 37.7749"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
<div>
|
|
||||||
<label className="block text-xs text-slate-500 mb-1">
|
|
||||||
Longitude
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="number"
|
|
||||||
step="any"
|
|
||||||
value={geofenceLongitude}
|
|
||||||
onChange={(e) => setGeofenceLongitude(e.target.value)}
|
|
||||||
className="w-full border border-gray-300 rounded px-3 py-2"
|
|
||||||
placeholder="e.g. -122.4194"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
<div>
|
|
||||||
<label className="block text-xs text-slate-500 mb-1">
|
|
||||||
Radius (meters)
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="number"
|
|
||||||
min="1"
|
|
||||||
value={geofenceRadiusMeters}
|
|
||||||
onChange={(e) =>
|
|
||||||
setGeofenceRadiusMeters(e.target.value)
|
|
||||||
}
|
|
||||||
className="w-full border border-gray-300 rounded px-3 py-2"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<p className="text-xs text-slate-500">
|
|
||||||
Default radius is 30m and geofence is enabled by default.
|
|
||||||
</p>
|
|
||||||
<Button
|
|
||||||
size="sm"
|
|
||||||
onClick={handleSaveGeofence}
|
|
||||||
disabled={savingGeofence}
|
|
||||||
>
|
|
||||||
{savingGeofence ? (
|
|
||||||
<Loader2 className="w-4 h-4 animate-spin" />
|
|
||||||
) : (
|
|
||||||
"Save Geofence"
|
|
||||||
)}
|
|
||||||
</Button>
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
{/* Stats */}
|
{/* Stats */}
|
||||||
|
|||||||
@ -1,197 +0,0 @@
|
|||||||
import { db, eq, sql, users } from "@fitai/database";
|
|
||||||
|
|
||||||
export const DEFAULT_GEOFENCE_RADIUS_METERS = 30;
|
|
||||||
export const MAX_LOCATION_ACCURACY_METERS = 50;
|
|
||||||
|
|
||||||
export interface UserLocation {
|
|
||||||
latitude: number;
|
|
||||||
longitude: number;
|
|
||||||
accuracy: number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function ensureGymsGeofenceColumns(): Promise<void> {
|
|
||||||
const rows = await db.all(sql`PRAGMA table_info('gyms')`);
|
|
||||||
const columns = new Set(
|
|
||||||
(rows as Array<{ name?: string }>).map((row) => row.name).filter(Boolean),
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!columns.has("latitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN latitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columns.has("longitude")) {
|
|
||||||
await db.run(sql`ALTER TABLE gyms ADD COLUMN longitude REAL`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columns.has("geofence_radius_meters")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_radius_meters REAL NOT NULL DEFAULT 30`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!columns.has("geofence_enabled")) {
|
|
||||||
await db.run(
|
|
||||||
sql`ALTER TABLE gyms ADD COLUMN geofence_enabled INTEGER NOT NULL DEFAULT 1`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
interface GymGeofenceConfig {
|
|
||||||
id: string;
|
|
||||||
name: string;
|
|
||||||
latitude: number | null;
|
|
||||||
longitude: number | null;
|
|
||||||
geofenceRadiusMeters: number | null;
|
|
||||||
geofenceEnabled: boolean | null;
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function getUserGymGeofence(
|
|
||||||
userId: string,
|
|
||||||
): Promise<GymGeofenceConfig | null> {
|
|
||||||
await ensureGymsGeofenceColumns();
|
|
||||||
|
|
||||||
const user = await db.select().from(users).where(eq(users.id, userId)).get();
|
|
||||||
if (!user?.gymId) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
const rows = await db.all(sql`
|
|
||||||
SELECT
|
|
||||||
id,
|
|
||||||
name,
|
|
||||||
latitude,
|
|
||||||
longitude,
|
|
||||||
geofence_radius_meters as geofenceRadiusMeters,
|
|
||||||
geofence_enabled as geofenceEnabled
|
|
||||||
FROM gyms
|
|
||||||
WHERE id = ${user.gymId}
|
|
||||||
LIMIT 1
|
|
||||||
`);
|
|
||||||
const gym = rows?.[0] as
|
|
||||||
| {
|
|
||||||
id: string;
|
|
||||||
name: string;
|
|
||||||
latitude: number | null;
|
|
||||||
longitude: number | null;
|
|
||||||
geofenceRadiusMeters: number | null;
|
|
||||||
geofenceEnabled: number | boolean | null;
|
|
||||||
}
|
|
||||||
| undefined;
|
|
||||||
if (!gym) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
id: gym.id,
|
|
||||||
name: gym.name,
|
|
||||||
latitude: gym.latitude,
|
|
||||||
longitude: gym.longitude,
|
|
||||||
geofenceRadiusMeters: gym.geofenceRadiusMeters,
|
|
||||||
geofenceEnabled:
|
|
||||||
typeof gym.geofenceEnabled === "boolean"
|
|
||||||
? gym.geofenceEnabled
|
|
||||||
: gym.geofenceEnabled === null
|
|
||||||
? null
|
|
||||||
: Boolean(gym.geofenceEnabled),
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
export function parseUserLocation(payload: unknown): UserLocation | null {
|
|
||||||
if (!payload || typeof payload !== "object") {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
const raw = payload as Record<string, unknown>;
|
|
||||||
const latitude = Number(raw.latitude);
|
|
||||||
const longitude = Number(raw.longitude);
|
|
||||||
const accuracy = Number(raw.accuracy);
|
|
||||||
|
|
||||||
if (
|
|
||||||
!Number.isFinite(latitude) ||
|
|
||||||
!Number.isFinite(longitude) ||
|
|
||||||
!Number.isFinite(accuracy)
|
|
||||||
) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return { latitude, longitude, accuracy };
|
|
||||||
}
|
|
||||||
|
|
||||||
export function validateGeofence(
|
|
||||||
gym: GymGeofenceConfig,
|
|
||||||
location: UserLocation | null,
|
|
||||||
): { ok: true } | { ok: false; status: number; error: string } {
|
|
||||||
const geofenceEnabled = gym.geofenceEnabled ?? true;
|
|
||||||
if (!geofenceEnabled) {
|
|
||||||
return { ok: true };
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!location) {
|
|
||||||
return {
|
|
||||||
ok: false,
|
|
||||||
status: 400,
|
|
||||||
error: "Location is required for gym check-in/check-out",
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
if (location.accuracy > MAX_LOCATION_ACCURACY_METERS) {
|
|
||||||
return {
|
|
||||||
ok: false,
|
|
||||||
status: 400,
|
|
||||||
error: `Location accuracy too low (${Math.round(location.accuracy)}m). Move to an open area and try again.`,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
if (gym.latitude === null || gym.longitude === null) {
|
|
||||||
return {
|
|
||||||
ok: false,
|
|
||||||
status: 400,
|
|
||||||
error: "Gym geofence is enabled but gym coordinates are not configured",
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
const radius = gym.geofenceRadiusMeters ?? DEFAULT_GEOFENCE_RADIUS_METERS;
|
|
||||||
const distanceMeters = haversineDistanceMeters(
|
|
||||||
gym.latitude,
|
|
||||||
gym.longitude,
|
|
||||||
location.latitude,
|
|
||||||
location.longitude,
|
|
||||||
);
|
|
||||||
|
|
||||||
if (distanceMeters > radius) {
|
|
||||||
return {
|
|
||||||
ok: false,
|
|
||||||
status: 403,
|
|
||||||
error: `You are outside the gym geofence (${Math.round(distanceMeters)}m away, allowed ${Math.round(radius)}m).`,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
return { ok: true };
|
|
||||||
}
|
|
||||||
|
|
||||||
function haversineDistanceMeters(
|
|
||||||
latitude1: number,
|
|
||||||
longitude1: number,
|
|
||||||
latitude2: number,
|
|
||||||
longitude2: number,
|
|
||||||
): number {
|
|
||||||
const earthRadiusMeters = 6371000;
|
|
||||||
const dLat = toRadians(latitude2 - latitude1);
|
|
||||||
const dLng = toRadians(longitude2 - longitude1);
|
|
||||||
const lat1Rad = toRadians(latitude1);
|
|
||||||
const lat2Rad = toRadians(latitude2);
|
|
||||||
|
|
||||||
const a =
|
|
||||||
Math.sin(dLat / 2) * Math.sin(dLat / 2) +
|
|
||||||
Math.sin(dLng / 2) *
|
|
||||||
Math.sin(dLng / 2) *
|
|
||||||
Math.cos(lat1Rad) *
|
|
||||||
Math.cos(lat2Rad);
|
|
||||||
|
|
||||||
const c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));
|
|
||||||
return earthRadiusMeters * c;
|
|
||||||
}
|
|
||||||
|
|
||||||
function toRadians(degrees: number): number {
|
|
||||||
return (degrees * Math.PI) / 180;
|
|
||||||
}
|
|
||||||
@ -17,8 +17,7 @@
|
|||||||
"infoPlist": {
|
"infoPlist": {
|
||||||
"NSCameraUsageDescription": "This app uses the camera to scan food barcodes and identify nutritional information.",
|
"NSCameraUsageDescription": "This app uses the camera to scan food barcodes and identify nutritional information.",
|
||||||
"NSUserNotificationsUsageDescription": "This app uses notifications to keep you updated on your fitness progress, recommendation approvals, and important reminders.",
|
"NSUserNotificationsUsageDescription": "This app uses notifications to keep you updated on your fitness progress, recommendation approvals, and important reminders.",
|
||||||
"NSMotionUsageDescription": "This app uses motion data to track your daily steps and activity progress.",
|
"NSMotionUsageDescription": "This app uses motion data to track your daily steps and activity progress."
|
||||||
"NSLocationWhenInUseUsageDescription": "This app uses your location to verify you are at your gym when checking in and checking out."
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"android": {
|
"android": {
|
||||||
@ -30,9 +29,7 @@
|
|||||||
"CAMERA",
|
"CAMERA",
|
||||||
"POST_NOTIFICATIONS",
|
"POST_NOTIFICATIONS",
|
||||||
"android.permission.CAMERA",
|
"android.permission.CAMERA",
|
||||||
"android.permission.ACTIVITY_RECOGNITION",
|
"android.permission.ACTIVITY_RECOGNITION"
|
||||||
"android.permission.ACCESS_FINE_LOCATION",
|
|
||||||
"android.permission.ACCESS_COARSE_LOCATION"
|
|
||||||
],
|
],
|
||||||
"package": "com.anonymous.fitai"
|
"package": "com.anonymous.fitai"
|
||||||
},
|
},
|
||||||
@ -43,7 +40,6 @@
|
|||||||
"expo-router",
|
"expo-router",
|
||||||
"expo-font",
|
"expo-font",
|
||||||
"expo-barcode-scanner",
|
"expo-barcode-scanner",
|
||||||
"expo-location",
|
|
||||||
[
|
[
|
||||||
"expo-notifications",
|
"expo-notifications",
|
||||||
{
|
{
|
||||||
|
|||||||
10
apps/mobile/package-lock.json
generated
10
apps/mobile/package-lock.json
generated
@ -29,7 +29,6 @@
|
|||||||
"expo-haptics": "^15.0.7",
|
"expo-haptics": "^15.0.7",
|
||||||
"expo-linear-gradient": "~15.0.7",
|
"expo-linear-gradient": "~15.0.7",
|
||||||
"expo-linking": "~8.0.0",
|
"expo-linking": "~8.0.0",
|
||||||
"expo-location": "~19.0.7",
|
|
||||||
"expo-notifications": "~0.32.0",
|
"expo-notifications": "~0.32.0",
|
||||||
"expo-router": "~6.0.14",
|
"expo-router": "~6.0.14",
|
||||||
"expo-secure-store": "~15.0.7",
|
"expo-secure-store": "~15.0.7",
|
||||||
@ -7465,15 +7464,6 @@
|
|||||||
"react-native": "*"
|
"react-native": "*"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/expo-location": {
|
|
||||||
"version": "19.0.8",
|
|
||||||
"resolved": "https://registry.npmjs.org/expo-location/-/expo-location-19.0.8.tgz",
|
|
||||||
"integrity": "sha512-H/FI75VuJ1coodJbbMu82pf+Zjess8X8Xkiv9Bv58ZgPKS/2ztjC1YO1/XMcGz7+s9DrbLuMIw22dFuP4HqneA==",
|
|
||||||
"license": "MIT",
|
|
||||||
"peerDependencies": {
|
|
||||||
"expo": "*"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/expo-modules-autolinking": {
|
"node_modules/expo-modules-autolinking": {
|
||||||
"version": "3.0.22",
|
"version": "3.0.22",
|
||||||
"resolved": "https://registry.npmjs.org/expo-modules-autolinking/-/expo-modules-autolinking-3.0.22.tgz",
|
"resolved": "https://registry.npmjs.org/expo-modules-autolinking/-/expo-modules-autolinking-3.0.22.tgz",
|
||||||
|
|||||||
@ -35,7 +35,6 @@
|
|||||||
"expo-haptics": "^15.0.7",
|
"expo-haptics": "^15.0.7",
|
||||||
"expo-linear-gradient": "~15.0.7",
|
"expo-linear-gradient": "~15.0.7",
|
||||||
"expo-linking": "~8.0.0",
|
"expo-linking": "~8.0.0",
|
||||||
"expo-location": "~19.0.7",
|
|
||||||
"expo-notifications": "~0.32.0",
|
"expo-notifications": "~0.32.0",
|
||||||
"expo-router": "~6.0.14",
|
"expo-router": "~6.0.14",
|
||||||
"expo-secure-store": "~15.0.7",
|
"expo-secure-store": "~15.0.7",
|
||||||
|
|||||||
@ -9,12 +9,6 @@ export interface Attendance {
|
|||||||
notes?: string;
|
notes?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AttendanceLocationPayload {
|
|
||||||
latitude: number;
|
|
||||||
longitude: number;
|
|
||||||
accuracy: number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const attendanceApi = {
|
export const attendanceApi = {
|
||||||
getHistory: async (token: string): Promise<Attendance[]> => {
|
getHistory: async (token: string): Promise<Attendance[]> => {
|
||||||
try {
|
try {
|
||||||
@ -27,15 +21,11 @@ export const attendanceApi = {
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
checkIn: async (
|
checkIn: async (type: string, token: string): Promise<void> => {
|
||||||
type: string,
|
|
||||||
token: string,
|
|
||||||
location: AttendanceLocationPayload,
|
|
||||||
): Promise<void> => {
|
|
||||||
try {
|
try {
|
||||||
await apiClient.post(
|
await apiClient.post(
|
||||||
API_ENDPOINTS.ATTENDANCE.CHECK_IN,
|
API_ENDPOINTS.ATTENDANCE.CHECK_IN,
|
||||||
{ type, location },
|
{ type },
|
||||||
{ headers: { Authorization: `Bearer ${token}` } },
|
{ headers: { Authorization: `Bearer ${token}` } },
|
||||||
);
|
);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@ -43,14 +33,11 @@ export const attendanceApi = {
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
checkOut: async (
|
checkOut: async (token: string): Promise<void> => {
|
||||||
token: string,
|
|
||||||
location: AttendanceLocationPayload,
|
|
||||||
): Promise<void> => {
|
|
||||||
try {
|
try {
|
||||||
await apiClient.post(
|
await apiClient.post(
|
||||||
API_ENDPOINTS.ATTENDANCE.CHECK_OUT,
|
API_ENDPOINTS.ATTENDANCE.CHECK_OUT,
|
||||||
{ location },
|
{},
|
||||||
{ headers: { Authorization: `Bearer ${token}` } },
|
{ headers: { Authorization: `Bearer ${token}` } },
|
||||||
);
|
);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
|||||||
@ -6,10 +6,6 @@ export interface Gym {
|
|||||||
id: string;
|
id: string;
|
||||||
name: string;
|
name: string;
|
||||||
location?: string;
|
location?: string;
|
||||||
latitude?: number | null;
|
|
||||||
longitude?: number | null;
|
|
||||||
geofenceRadiusMeters?: number;
|
|
||||||
geofenceEnabled?: boolean;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export const gymsApi = {
|
export const gymsApi = {
|
||||||
|
|||||||
@ -10,7 +10,6 @@ import {
|
|||||||
Alert,
|
Alert,
|
||||||
AppState,
|
AppState,
|
||||||
} from "react-native";
|
} from "react-native";
|
||||||
import * as Location from "expo-location";
|
|
||||||
import { useAuth, useUser } from "@clerk/clerk-expo";
|
import { useAuth, useUser } from "@clerk/clerk-expo";
|
||||||
import { useState, useCallback, useEffect, useRef, useMemo } from "react";
|
import { useState, useCallback, useEffect, useRef, useMemo } from "react";
|
||||||
import { useFocusEffect } from "@react-navigation/native";
|
import { useFocusEffect } from "@react-navigation/native";
|
||||||
@ -237,29 +236,11 @@ export default function HomeScreen() {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
const permission = await Location.requestForegroundPermissionsAsync();
|
|
||||||
if (permission.status !== "granted") {
|
|
||||||
Alert.alert(
|
|
||||||
"Location required",
|
|
||||||
"Location access is required to check in and check out.",
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const position = await Location.getCurrentPositionAsync({
|
|
||||||
accuracy: Location.Accuracy.Balanced,
|
|
||||||
});
|
|
||||||
const locationPayload = {
|
|
||||||
latitude: position.coords.latitude,
|
|
||||||
longitude: position.coords.longitude,
|
|
||||||
accuracy: position.coords.accuracy ?? 999,
|
|
||||||
};
|
|
||||||
|
|
||||||
if (activeWorkoutSession) {
|
if (activeWorkoutSession) {
|
||||||
await attendanceApi.checkOut(token, locationPayload);
|
await attendanceApi.checkOut(token);
|
||||||
Alert.alert("Workout logged", "Session ended successfully.");
|
Alert.alert("Workout logged", "Session ended successfully.");
|
||||||
} else {
|
} else {
|
||||||
await attendanceApi.checkIn("gym", token, locationPayload);
|
await attendanceApi.checkIn("gym", token);
|
||||||
Alert.alert("Workout started", "Session started successfully.");
|
Alert.alert("Workout started", "Session started successfully.");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -48,12 +48,6 @@ export const gyms = sqliteTable(
|
|||||||
id: text("id").primaryKey(),
|
id: text("id").primaryKey(),
|
||||||
name: text("name").notNull(),
|
name: text("name").notNull(),
|
||||||
location: text("location"),
|
location: text("location"),
|
||||||
latitude: real("latitude"),
|
|
||||||
longitude: real("longitude"),
|
|
||||||
geofenceRadiusMeters: real("geofence_radius_meters").notNull().default(30),
|
|
||||||
geofenceEnabled: integer("geofence_enabled", { mode: "boolean" })
|
|
||||||
.notNull()
|
|
||||||
.default(true),
|
|
||||||
status: text("status", { enum: ["active", "inactive"] })
|
status: text("status", { enum: ["active", "inactive"] })
|
||||||
.notNull()
|
.notNull()
|
||||||
.default("active"),
|
.default("active"),
|
||||||
|
|||||||
@ -137,10 +137,6 @@ export interface Gym {
|
|||||||
id: string;
|
id: string;
|
||||||
name: string;
|
name: string;
|
||||||
location?: string;
|
location?: string;
|
||||||
latitude?: number;
|
|
||||||
longitude?: number;
|
|
||||||
geofenceRadiusMeters?: number;
|
|
||||||
geofenceEnabled?: boolean;
|
|
||||||
status: GymStatus;
|
status: GymStatus;
|
||||||
adminUserId: string;
|
adminUserId: string;
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user