mirror of
https://github.com/i701/sarlink-portal.git
synced 2025-07-03 06:48:21 +00:00
temporary fix for build and remove previous auth related code
This commit is contained in:
@ -1,151 +1,151 @@
|
||||
import { blockDevice } from "@/actions/omada-actions";
|
||||
import prisma from "@/lib/db";
|
||||
import { validateApiKey } from "@/lib/utils";
|
||||
import { addDays, addMonths, isAfter, isWithinInterval } from "date-fns";
|
||||
|
||||
const lastRunTime = new Date();
|
||||
|
||||
export async function GET(request: Request) {
|
||||
try {
|
||||
// Validate API key before proceeding
|
||||
validateApiKey(request);
|
||||
return Response.json({ message: "Request received" });
|
||||
// try {
|
||||
// // Validate API key before proceeding
|
||||
// validateApiKey(request);
|
||||
|
||||
const currentTime = new Date();
|
||||
const hoursSinceLastRun =
|
||||
(currentTime.getTime() - lastRunTime.getTime()) / (1000 * 60 * 60);
|
||||
// const currentTime = new Date();
|
||||
// const hoursSinceLastRun =
|
||||
// (currentTime.getTime() - lastRunTime.getTime()) / (1000 * 60 * 60);
|
||||
|
||||
// Get all active and unblocked devices with their latest payment
|
||||
const devices = await prisma.device.findMany({
|
||||
where: {
|
||||
isActive: true,
|
||||
blocked: false,
|
||||
},
|
||||
include: {
|
||||
payments: true,
|
||||
User: {
|
||||
include: {
|
||||
devices: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
let devicesNeedingNotification = 0;
|
||||
let devicesBlocked = 0;
|
||||
// // Get all active and unblocked devices with their latest payment
|
||||
// const devices = await prisma.device.findMany({
|
||||
// where: {
|
||||
// isActive: true,
|
||||
// blocked: false,
|
||||
// },
|
||||
// include: {
|
||||
// payments: true,
|
||||
// User: {
|
||||
// include: {
|
||||
// devices: true,
|
||||
// },
|
||||
// },
|
||||
// },
|
||||
// });
|
||||
// let devicesNeedingNotification = 0;
|
||||
// let devicesBlocked = 0;
|
||||
|
||||
for (const device of devices) {
|
||||
let expiryDate = new Date();
|
||||
// for (const device of devices) {
|
||||
// let expiryDate = new Date();
|
||||
|
||||
const payment = device.payments[0];
|
||||
expiryDate = addMonths(
|
||||
payment?.paidAt || new Date(),
|
||||
payment?.numberOfMonths || 0,
|
||||
);
|
||||
// const payment = device.payments[0];
|
||||
// expiryDate = addMonths(
|
||||
// payment?.paidAt || new Date(),
|
||||
// payment?.numberOfMonths || 0,
|
||||
// );
|
||||
|
||||
// Calculate notification threshold (5 days before expiry)
|
||||
const notificationThreshold = addDays(expiryDate, -5);
|
||||
// // Calculate notification threshold (5 days before expiry)
|
||||
// const notificationThreshold = addDays(expiryDate, -5);
|
||||
|
||||
const currentDate = new Date();
|
||||
// const currentDate = new Date();
|
||||
|
||||
console.log("device name -> ", device.name);
|
||||
console.log("paid date -> ", device.payments[0]?.paidAt);
|
||||
console.log("no of months paid -> ", device.payments[0]?.numberOfMonths);
|
||||
console.log("calculated expire date -> ", expiryDate);
|
||||
console.log("notification threshold -> ", notificationThreshold);
|
||||
console.log("current date -> ", currentDate);
|
||||
// console.log("device name -> ", device.name);
|
||||
// console.log("paid date -> ", device.payments[0]?.paidAt);
|
||||
// console.log("no of months paid -> ", device.payments[0]?.numberOfMonths);
|
||||
// console.log("calculated expire date -> ", expiryDate);
|
||||
// console.log("notification threshold -> ", notificationThreshold);
|
||||
// console.log("current date -> ", currentDate);
|
||||
|
||||
// Check if device is within notification period
|
||||
if (
|
||||
isWithinInterval(currentDate, {
|
||||
start: notificationThreshold,
|
||||
end: expiryDate,
|
||||
})
|
||||
) {
|
||||
// Device is within 5 days of expiring
|
||||
if (device.User?.phoneNumber) {
|
||||
await sendNotifySms(
|
||||
new Date(expiryDate),
|
||||
device.User?.phoneNumber ?? "",
|
||||
device.name,
|
||||
);
|
||||
devicesNeedingNotification++;
|
||||
}
|
||||
}
|
||||
// // Check if device is within notification period
|
||||
// if (
|
||||
// isWithinInterval(currentDate, {
|
||||
// start: notificationThreshold,
|
||||
// end: expiryDate,
|
||||
// })
|
||||
// ) {
|
||||
// // Device is within 5 days of expiring
|
||||
// if (device.User?.phoneNumber) {
|
||||
// await sendNotifySms(
|
||||
// new Date(expiryDate),
|
||||
// device.User?.phoneNumber ?? "",
|
||||
// device.name,
|
||||
// );
|
||||
// devicesNeedingNotification++;
|
||||
// }
|
||||
// }
|
||||
|
||||
// Check if device has expired
|
||||
if (isAfter(currentDate, expiryDate)) {
|
||||
// Device has expired, block it
|
||||
// TODO: add a reason for blocking
|
||||
await blockDevice({
|
||||
macAddress: device.mac,
|
||||
type: "block",
|
||||
});
|
||||
await prisma.device.update({
|
||||
where: { id: device.id },
|
||||
data: {
|
||||
isActive: false,
|
||||
blocked: true,
|
||||
},
|
||||
});
|
||||
devicesBlocked++;
|
||||
}
|
||||
}
|
||||
// // Check if device has expired
|
||||
// if (isAfter(currentDate, expiryDate)) {
|
||||
// // Device has expired, block it
|
||||
// // TODO: add a reason for blocking
|
||||
// await blockDevice({
|
||||
// macAddress: device.mac,
|
||||
// type: "block",
|
||||
// });
|
||||
// await prisma.device.update({
|
||||
// where: { id: device.id },
|
||||
// data: {
|
||||
// isActive: false,
|
||||
// blocked: true,
|
||||
// },
|
||||
// });
|
||||
// devicesBlocked++;
|
||||
// }
|
||||
// }
|
||||
|
||||
if (hoursSinceLastRun < 24) {
|
||||
return Response.json({
|
||||
totalActiveDevices: devices.length,
|
||||
devicesChecked: {
|
||||
notified: devicesNeedingNotification,
|
||||
blocked: devicesBlocked,
|
||||
},
|
||||
message: "Check was run recently",
|
||||
nextCheckIn: `${Math.round(24 - hoursSinceLastRun)} hours`,
|
||||
});
|
||||
}
|
||||
// if (hoursSinceLastRun < 24) {
|
||||
// return Response.json({
|
||||
// totalActiveDevices: devices.length,
|
||||
// devicesChecked: {
|
||||
// notified: devicesNeedingNotification,
|
||||
// blocked: devicesBlocked,
|
||||
// },
|
||||
// message: "Check was run recently",
|
||||
// nextCheckIn: `${Math.round(24 - hoursSinceLastRun)} hours`,
|
||||
// });
|
||||
// }
|
||||
|
||||
return Response.json({
|
||||
success: true,
|
||||
totalActiveDevices: devices.length,
|
||||
devicesChecked: {
|
||||
notified: devicesNeedingNotification,
|
||||
blocked: devicesBlocked,
|
||||
},
|
||||
runAt: currentTime,
|
||||
});
|
||||
} catch (error) {
|
||||
if (error instanceof Error) {
|
||||
if (error.message === "API key is missing") {
|
||||
return Response.json({ error: "API key is required" }, { status: 401 });
|
||||
}
|
||||
if (error.message === "Invalid API key") {
|
||||
return Response.json({ error: "Invalid API key" }, { status: 403 });
|
||||
}
|
||||
}
|
||||
// return Response.json({
|
||||
// success: true,
|
||||
// totalActiveDevices: devices.length,
|
||||
// devicesChecked: {
|
||||
// notified: devicesNeedingNotification,
|
||||
// blocked: devicesBlocked,
|
||||
// },
|
||||
// runAt: currentTime,
|
||||
// });
|
||||
// } catch (error) {
|
||||
// if (error instanceof Error) {
|
||||
// if (error.message === "API key is missing") {
|
||||
// return Response.json({ error: "API key is required" }, { status: 401 });
|
||||
// }
|
||||
// if (error.message === "Invalid API key") {
|
||||
// return Response.json({ error: "Invalid API key" }, { status: 403 });
|
||||
// }
|
||||
// }
|
||||
|
||||
console.error("Error in device check:", error);
|
||||
return Response.json({ error: "Failed to check devices" }, { status: 500 });
|
||||
}
|
||||
}
|
||||
|
||||
// Mock function - replace with your actual SMS implementation
|
||||
async function sendNotifySms(
|
||||
expireDate: Date,
|
||||
phoneNumber: string,
|
||||
deviceName?: string,
|
||||
) {
|
||||
const respose = await fetch(`${process.env.SMS_API_BASE_URL}/api/sms`, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
Authorization: `Bearer ${process.env.SMS_API_KEY}`,
|
||||
},
|
||||
body: JSON.stringify({
|
||||
check_delivery: false,
|
||||
number: phoneNumber,
|
||||
message: `REMINDER! Your device [${deviceName}] will expire on ${new Date(expireDate)}.`,
|
||||
}),
|
||||
});
|
||||
const data = await respose.json();
|
||||
console.log(data);
|
||||
return data;
|
||||
// Implement your SMS logic here
|
||||
// console.error("Error in device check:", error);
|
||||
// return Response.json({ error: "Failed to check devices" }, { status: 500 });
|
||||
// }
|
||||
// }
|
||||
|
||||
// // Mock function - replace with your actual SMS implementation
|
||||
// async function sendNotifySms(
|
||||
// expireDate: Date,
|
||||
// phoneNumber: string,
|
||||
// deviceName?: string,
|
||||
// ) {
|
||||
// const respose = await fetch(`${process.env.SMS_API_BASE_URL}/api/sms`, {
|
||||
// method: "POST",
|
||||
// headers: {
|
||||
// "Content-Type": "application/json",
|
||||
// Authorization: `Bearer ${process.env.SMS_API_KEY}`,
|
||||
// },
|
||||
// body: JSON.stringify({
|
||||
// check_delivery: false,
|
||||
// number: phoneNumber,
|
||||
// message: `REMINDER! Your device [${deviceName}] will expire on ${new Date(expireDate)}.`,
|
||||
// }),
|
||||
// });
|
||||
// const data = await respose.json();
|
||||
// console.log(data);
|
||||
// return data;
|
||||
//
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user