-
-
setJobTitle(e.target.value)}
- className="w-full rounded-lg border border-gray-300 px-4 py-2.5 text-sm focus:border-[#0f1f3d] focus:outline-none focus:ring-2 focus:ring-[#0f1f3d]/20" />
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/pulse360/src/app/(app)/system-admin/page.tsx b/pulse360/src/app/(app)/system-admin/page.tsx
index 1173244..d60f59e 100644
--- a/pulse360/src/app/(app)/system-admin/page.tsx
+++ b/pulse360/src/app/(app)/system-admin/page.tsx
@@ -79,10 +79,10 @@ export default async function SystemAdminDashboard() {
});
const cycleWhere = cycle ? { cycleId: cycle.id } : {};
- const [employees, nominations, reviews, auditLogs, aiLogs] = await Promise.all([
+ const [employees, nominations, reviews, auditLogs, authEvents, aiUsageEvents, aiDecisionEvents] = await Promise.all([
prisma.employee.findMany({
where: { isActive: true, role: { not: "SYSTEM_ADMIN" } },
- select: { id: true, department: { select: { name: true } }, jobGrade: true },
+ select: { id: true, department: { select: { name: true } }, jobGrade: true, gender: true, employmentType: true, conversionHireStatus: true },
}),
prisma.nomination.findMany({
where: cycleWhere,
@@ -107,14 +107,24 @@ export default async function SystemAdminDashboard() {
orderBy: { createdAt: "desc" },
take: 250,
}),
- prisma.auditLog.findMany({
- where: { action: { startsWith: "AI_" }, createdAt: { gte: since } },
+ prisma.authEvent.findMany({
+ where: { createdAt: { gte: since } },
+ orderBy: { createdAt: "desc" },
+ take: 500,
+ }),
+ prisma.aiUsageEvent.findMany({
+ where: { createdAt: { gte: since } },
+ orderBy: { createdAt: "desc" },
+ take: 500,
+ }),
+ prisma.aiHitlDecision.findMany({
+ where: { createdAt: { gte: since } },
orderBy: { createdAt: "desc" },
take: 500,
}),
]);
- const loginEvents = auditLogs.filter((row) => row.action === "LOGIN_SUCCEEDED");
+ const loginEvents = authEvents.filter((row) => row.status === "SUCCESS");
const uniqueLoginUsers = new Set(loginEvents.map((row) => row.actorId).filter(Boolean)).size;
const submittedNominations = nominations.filter((row) => row.submissionStatus === "SUBMITTED").length;
const pendingApprovals = nominations.filter((row) => row.approvalStatus === "PENDING").length;
@@ -124,16 +134,15 @@ export default async function SystemAdminDashboard() {
const missingCommentReviews = reviews.filter((row) =>
row.status === "SUBMITTED" && (!row.doWellComment || !row.improveComment)
).length;
- const aiGenerationLogs = aiLogs.filter((row) => row.action !== "AI_HITL_DECISION");
- const aiDecisionLogs = aiLogs.filter((row) => row.action === "AI_HITL_DECISION");
- const aiSuccesses = aiGenerationLogs.filter((row) => (row.metadata as any)?.status === "success").length;
- const aiStubbed = aiGenerationLogs.filter((row) => (row.metadata as any)?.stub === true).length;
- const aiTokens = aiGenerationLogs.reduce((sum, row) => sum + Number((row.metadata as any)?.totalTokens ?? 0), 0);
- const aiInputTokens = aiGenerationLogs.reduce((sum, row) => sum + Number((row.metadata as any)?.promptTokens ?? 0), 0);
- const aiOutputTokens = aiGenerationLogs.reduce((sum, row) => sum + Number((row.metadata as any)?.completionTokens ?? 0), 0);
- const aiAccepted = aiDecisionLogs.filter((row) => (row.metadata as any)?.decision === "accepted").length;
- const aiEdited = aiDecisionLogs.filter((row) => (row.metadata as any)?.decision === "edited").length;
- const aiDiscarded = aiDecisionLogs.filter((row) => (row.metadata as any)?.decision === "discarded").length;
+ const aiGenerationLogs = aiUsageEvents;
+ const aiSuccesses = aiGenerationLogs.filter((row) => row.status === "SUCCESS").length;
+ const aiStubbed = aiGenerationLogs.filter((row) => row.stub).length;
+ const aiTokens = aiGenerationLogs.reduce((sum, row) => sum + row.totalTokens, 0);
+ const aiInputTokens = aiGenerationLogs.reduce((sum, row) => sum + row.inputTokens, 0);
+ const aiOutputTokens = aiGenerationLogs.reduce((sum, row) => sum + row.outputTokens, 0);
+ const aiAccepted = aiDecisionEvents.filter((row) => row.decision === "ACCEPTED").length;
+ const aiEdited = aiDecisionEvents.filter((row) => row.decision === "EDITED").length;
+ const aiDiscarded = aiDecisionEvents.filter((row) => row.decision === "DISCARDED").length;
const departmentCounts = employees.reduce>((acc, employee) => {
const dept = employee.department.name;
@@ -141,6 +150,18 @@ export default async function SystemAdminDashboard() {
return acc;
}, {});
+ const genderCounts = employees.reduce>((acc, employee) => {
+ const label = employee.gender?.replace(/_/g, " ").toLowerCase().replace(/\b\w/g, (char) => char.toUpperCase()) ?? "Not captured";
+ acc[label] = (acc[label] ?? 0) + 1;
+ return acc;
+ }, {});
+
+ const employmentTypeCounts = employees.reduce>((acc, employee) => {
+ const label = employee.employmentType.replace(/_/g, " ").toLowerCase().replace(/\b\w/g, (char) => char.toUpperCase());
+ acc[label] = (acc[label] ?? 0) + 1;
+ return acc;
+ }, {});
+
const nominationFlows = new Map();
const reviewerMap = new Map }>();
const pendingBySubjectDept = new Map();
@@ -396,6 +417,44 @@ export default async function SystemAdminDashboard() {
))}
+
+
+
+
+ {Object.entries(genderCounts)
+ .sort((a, b) => b[1] - a[1])
+ .map(([gender, count]) => (
+
+
+ {gender}
+ {count}
+
+
+
+ ))}
+
+
+
+
+ {Object.entries(employmentTypeCounts)
+ .sort((a, b) => b[1] - a[1])
+ .map(([type, count]) => (
+
+
+ {type}
+ {count}
+
+
+
+ ))}
+
+
);
}
diff --git a/pulse360/src/app/api/employees/[id]/route.ts b/pulse360/src/app/api/employees/[id]/route.ts
index 747c28f..193be01 100644
--- a/pulse360/src/app/api/employees/[id]/route.ts
+++ b/pulse360/src/app/api/employees/[id]/route.ts
@@ -2,8 +2,13 @@ import { getServerSession } from "next-auth";
import { authOptions } from "@/lib/auth";
import { prisma } from "@/lib/prisma";
import { NextResponse } from "next/server";
+import { writeAuditEvent } from "@/lib/audit";
const HR_MANAGED_ROLES = ["EMPLOYEE", "LINE_MANAGER", "HR_ADMIN"];
+const EMPLOYMENT_TYPES = ["INTERNSHIP", "LEARNERSHIP", "CONTRACT", "PERMANENT"];
+const CONVERSION_HIRE_STATUSES = ["NO", "YES", "PENDING_DECISION", "REVIEWED"];
+const GENDERS = ["WOMAN", "MAN", "NON_BINARY", "OTHER", "PREFER_NOT_TO_SAY"];
+const ETHNICITIES = ["BLACK", "WHITE", "COLOURED", "ASIAN", "INDIAN", "OTHER", "PREFER_NOT_TO_SAY"];
export async function GET(_req: Request, { params }: { params: Promise<{ id: string }> }) {
const session = await getServerSession(authOptions);
@@ -16,6 +21,11 @@ export async function GET(_req: Request, { params }: { params: Promise<{ id: str
});
if (!employee) return NextResponse.json({ error: "Not found" }, { status: 404 });
+ if ((session.user as any).role !== "HR_ADMIN") {
+ const { ethnicity: _ethnicity, ...safeEmployee } = employee;
+ return NextResponse.json(safeEmployee);
+ }
+
return NextResponse.json(employee);
}
@@ -25,15 +35,103 @@ export async function PUT(req: Request, { params }: { params: Promise<{ id: stri
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
}
const { id } = await params;
- const { firstName, lastName, email, jobTitle, role, departmentId, managerId, isActive } = await req.json();
+ const {
+ firstName,
+ lastName,
+ email,
+ jobTitle,
+ jobGrade,
+ employmentType,
+ conversionHireStatus,
+ gender,
+ ethnicity,
+ role,
+ departmentId,
+ managerId,
+ isActive,
+ } = await req.json();
if (!HR_MANAGED_ROLES.includes(role)) {
return NextResponse.json({ error: "This role cannot be managed from HR employee screens" }, { status: 400 });
}
+ if (employmentType && !EMPLOYMENT_TYPES.includes(employmentType)) {
+ return NextResponse.json({ error: "Invalid employment type" }, { status: 400 });
+ }
+ if (conversionHireStatus && !CONVERSION_HIRE_STATUSES.includes(conversionHireStatus)) {
+ return NextResponse.json({ error: "Invalid conversion hire status" }, { status: 400 });
+ }
+ if (gender && !GENDERS.includes(gender)) {
+ return NextResponse.json({ error: "Invalid gender" }, { status: 400 });
+ }
+ if (ethnicity && !ETHNICITIES.includes(ethnicity)) {
+ return NextResponse.json({ error: "Invalid ethnicity" }, { status: 400 });
+ }
+
+ const before = await prisma.employee.findUnique({
+ where: { id: Number(id) },
+ select: {
+ firstName: true,
+ lastName: true,
+ email: true,
+ jobTitle: true,
+ jobGrade: true,
+ employmentType: true,
+ conversionHireStatus: true,
+ gender: true,
+ ethnicity: true,
+ role: true,
+ departmentId: true,
+ managerId: true,
+ isActive: true,
+ },
+ });
const employee = await prisma.employee.update({
where: { id: Number(id) },
- data: { firstName, lastName, email: email.toLowerCase(), jobTitle, role, departmentId, managerId: managerId ?? null, isActive },
+ data: {
+ firstName: firstName.trim(),
+ lastName: lastName.trim(),
+ email: email.toLowerCase().trim(),
+ jobTitle: typeof jobTitle === "string" && jobTitle.trim() ? jobTitle.trim() : null,
+ jobGrade: typeof jobGrade === "string" && jobGrade.trim() ? jobGrade.trim() : null,
+ employmentType: employmentType ?? "PERMANENT",
+ conversionHireStatus: conversionHireStatus ?? "NO",
+ gender: gender || null,
+ ethnicity: ethnicity || null,
+ role,
+ departmentId,
+ managerId: managerId ?? null,
+ isActive,
+ },
});
+ await writeAuditEvent({
+ actorId: Number((session.user as any).id),
+ action: "EMPLOYEE_UPDATED",
+ entityType: "employee",
+ entityId: employee.id,
+ metadata: {
+ changedFields: {
+ firstName: before?.firstName !== employee.firstName,
+ lastName: before?.lastName !== employee.lastName,
+ email: before?.email !== employee.email,
+ jobTitle: before?.jobTitle !== employee.jobTitle,
+ jobGrade: before?.jobGrade !== employee.jobGrade,
+ employmentType: before?.employmentType !== employee.employmentType,
+ conversionHireStatus: before?.conversionHireStatus !== employee.conversionHireStatus,
+ gender: before?.gender !== employee.gender,
+ ethnicity: before?.ethnicity !== employee.ethnicity,
+ role: before?.role !== employee.role,
+ departmentId: before?.departmentId !== employee.departmentId,
+ managerId: before?.managerId !== employee.managerId,
+ isActive: before?.isActive !== employee.isActive,
+ },
+ role: employee.role,
+ departmentId: employee.departmentId,
+ employmentType: employee.employmentType,
+ conversionHireStatus: employee.conversionHireStatus,
+ gender: employee.gender,
+ },
+ }).catch(() => {});
+
return NextResponse.json(employee);
}
diff --git a/pulse360/src/app/api/employees/route.ts b/pulse360/src/app/api/employees/route.ts
index 447cf38..c0f1eef 100644
--- a/pulse360/src/app/api/employees/route.ts
+++ b/pulse360/src/app/api/employees/route.ts
@@ -3,8 +3,13 @@ import { authOptions } from "@/lib/auth";
import { prisma } from "@/lib/prisma";
import { NextResponse } from "next/server";
import bcrypt from "bcryptjs";
+import { writeAuditEvent } from "@/lib/audit";
const HR_MANAGED_ROLES = ["EMPLOYEE", "LINE_MANAGER", "HR_ADMIN"];
+const EMPLOYMENT_TYPES = ["INTERNSHIP", "LEARNERSHIP", "CONTRACT", "PERMANENT"];
+const CONVERSION_HIRE_STATUSES = ["NO", "YES", "PENDING_DECISION", "REVIEWED"];
+const GENDERS = ["WOMAN", "MAN", "NON_BINARY", "OTHER", "PREFER_NOT_TO_SAY"];
+const ETHNICITIES = ["BLACK", "WHITE", "COLOURED", "ASIAN", "INDIAN", "OTHER", "PREFER_NOT_TO_SAY"];
export async function POST(req: Request) {
const session = await getServerSession(authOptions);
@@ -12,7 +17,21 @@ export async function POST(req: Request) {
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
}
- const { firstName, lastName, email, jobTitle, role, departmentId, managerId, isActive } = await req.json();
+ const {
+ firstName,
+ lastName,
+ email,
+ jobTitle,
+ jobGrade,
+ employmentType,
+ conversionHireStatus,
+ gender,
+ ethnicity,
+ role,
+ departmentId,
+ managerId,
+ isActive,
+ } = await req.json();
if (!firstName || !lastName || !email || !departmentId) {
return NextResponse.json({ error: "firstName, lastName, email and departmentId are required" }, { status: 400 });
}
@@ -20,13 +39,54 @@ export async function POST(req: Request) {
if (!HR_MANAGED_ROLES.includes(employeeRole)) {
return NextResponse.json({ error: "This role cannot be managed from HR employee screens" }, { status: 400 });
}
+ if (employmentType && !EMPLOYMENT_TYPES.includes(employmentType)) {
+ return NextResponse.json({ error: "Invalid employment type" }, { status: 400 });
+ }
+ if (conversionHireStatus && !CONVERSION_HIRE_STATUSES.includes(conversionHireStatus)) {
+ return NextResponse.json({ error: "Invalid conversion hire status" }, { status: 400 });
+ }
+ if (gender && !GENDERS.includes(gender)) {
+ return NextResponse.json({ error: "Invalid gender" }, { status: 400 });
+ }
+ if (ethnicity && !ETHNICITIES.includes(ethnicity)) {
+ return NextResponse.json({ error: "Invalid ethnicity" }, { status: 400 });
+ }
const passwordHash = await bcrypt.hash("Pulse360!Employee", 12);
const employee = await prisma.employee.create({
- data: { firstName, lastName, email: email.toLowerCase(), jobTitle, role: employeeRole, departmentId, managerId: managerId ?? null, isActive: isActive ?? true, passwordHash },
+ data: {
+ firstName: firstName.trim(),
+ lastName: lastName.trim(),
+ email: email.toLowerCase().trim(),
+ jobTitle: typeof jobTitle === "string" && jobTitle.trim() ? jobTitle.trim() : null,
+ jobGrade: typeof jobGrade === "string" && jobGrade.trim() ? jobGrade.trim() : null,
+ employmentType: employmentType ?? "PERMANENT",
+ conversionHireStatus: conversionHireStatus ?? "NO",
+ gender: gender || null,
+ ethnicity: ethnicity || null,
+ role: employeeRole,
+ departmentId,
+ managerId: managerId ?? null,
+ isActive: isActive ?? true,
+ passwordHash,
+ },
});
+ await writeAuditEvent({
+ actorId: Number((session.user as any).id),
+ action: "EMPLOYEE_CREATED",
+ entityType: "employee",
+ entityId: employee.id,
+ metadata: {
+ role: employee.role,
+ departmentId: employee.departmentId,
+ employmentType: employee.employmentType,
+ conversionHireStatus: employee.conversionHireStatus,
+ gender: employee.gender,
+ },
+ }).catch(() => {});
+
return NextResponse.json(employee, { status: 201 });
}
diff --git a/pulse360/src/lib/audit.ts b/pulse360/src/lib/audit.ts
index 96adc3c..320cc13 100644
--- a/pulse360/src/lib/audit.ts
+++ b/pulse360/src/lib/audit.ts
@@ -25,6 +25,7 @@ export async function writeAuditEvent({
metadata: metadata ?? {},
},
});
+ await writeEventProjection({ actorId, action, entityType, entityId, metadata }).catch(() => {});
}
export function personAuditSnapshot(person: {
@@ -33,13 +34,195 @@ export function personAuditSnapshot(person: {
lastName: string;
email?: string | null;
jobTitle?: string | null;
- department?: { name: string } | null;
+ department?: { id?: number | null; name: string } | null;
}) {
return {
id: person.id,
name: `${person.firstName} ${person.lastName}`,
email: person.email ?? null,
jobTitle: person.jobTitle ?? null,
+ departmentId: person.department?.id ?? null,
department: person.department?.name ?? null,
};
}
+
+function isRecord(value: unknown): value is Record
{
+ return typeof value === "object" && value !== null && !Array.isArray(value);
+}
+
+function metadataRecord(metadata: Prisma.InputJsonValue | undefined): Record {
+ return isRecord(metadata) ? metadata : {};
+}
+
+function asNumber(value: unknown): number | null {
+ const parsed = Number(value);
+ return Number.isFinite(parsed) ? parsed : null;
+}
+
+function asString(value: unknown): string | null {
+ return typeof value === "string" && value.trim() ? value : null;
+}
+
+function asBoolean(value: unknown): boolean | null {
+ return typeof value === "boolean" ? value : null;
+}
+
+function enumValue(value: unknown, allowed: readonly T[]): T | null {
+ return typeof value === "string" && allowed.includes(value as T) ? (value as T) : null;
+}
+
+function personSnapshot(value: unknown) {
+ return isRecord(value) ? value : {};
+}
+
+function featureFromAction(action: string, metadata: Record) {
+ const fromMetadata = asString(metadata.feature)?.replace(/[-\s]/g, "_").toUpperCase();
+ const feature = fromMetadata ?? ({
+ AI_SUGGEST_COMMENTS: "SUGGEST_COMMENTS",
+ AI_THEME_SUMMARY: "THEME_SUMMARY",
+ AI_IMPROVEMENT_PLAN: "IMPROVEMENT_PLAN",
+ AI_ANALYTICS_REPORT: "ANALYTICS_REPORT",
+ } as Record)[action];
+
+ return enumValue(feature, ["SUGGEST_COMMENTS", "THEME_SUMMARY", "IMPROVEMENT_PLAN", "ANALYTICS_REPORT"] as const);
+}
+
+function decisionFromMetadata(metadata: Record) {
+ const decision = asString(metadata.decision)?.toUpperCase();
+ return enumValue(decision, ["ACCEPTED", "EDITED", "DISCARDED"] as const);
+}
+
+async function writeEventProjection(input: AuditInput) {
+ const metadata = metadataRecord(input.metadata);
+ const actorId = input.actorId ?? null;
+ const entityId = input.entityId ?? null;
+
+ if (input.action === "LOGIN_SUCCEEDED" || input.action === "LOGIN_FAILED") {
+ const role = enumValue(metadata.role, ["SYSTEM_ADMIN", "HR_ADMIN", "LINE_MANAGER", "EMPLOYEE"] as const);
+ await prisma.authEvent.create({
+ data: {
+ actorId,
+ email: asString(metadata.email),
+ role,
+ departmentId: asNumber(metadata.departmentId),
+ departmentName: asString(metadata.department),
+ status: input.action === "LOGIN_SUCCEEDED" ? "SUCCESS" : "FAILURE",
+ failureReason: asString(metadata.reason),
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ return;
+ }
+
+ if ((input.action === "PROFILE_UPDATED" || input.action === "EMPLOYEE_UPDATED") && actorId && entityId) {
+ await prisma.profileEvent.create({
+ data: {
+ actorId,
+ employeeId: entityId,
+ changedFields: (isRecord(metadata.changedFields) ? metadata.changedFields : {}) as Prisma.InputJsonObject,
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ return;
+ }
+
+ if (input.action.startsWith("AI_") && input.action !== "AI_HITL_DECISION") {
+ const feature = featureFromAction(input.action, metadata);
+ if (!feature) return;
+ await prisma.aiUsageEvent.create({
+ data: {
+ actorId,
+ feature,
+ model: asString(metadata.model),
+ status: metadata.status === "error" ? "ERROR" : "SUCCESS",
+ stub: Boolean(metadata.stub),
+ inputTokens: asNumber(metadata.promptTokens) ?? asNumber(metadata.inputTokens) ?? 0,
+ outputTokens: asNumber(metadata.completionTokens) ?? asNumber(metadata.outputTokens) ?? 0,
+ totalTokens: asNumber(metadata.totalTokens) ?? 0,
+ cycleId: asNumber(metadata.cycleId),
+ entityType: input.entityType,
+ entityId,
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ return;
+ }
+
+ if (input.action === "AI_HITL_DECISION") {
+ const feature = featureFromAction(input.action, metadata);
+ const decision = decisionFromMetadata(metadata);
+ if (!feature || !decision) return;
+ await prisma.aiHitlDecision.create({
+ data: {
+ actorId,
+ feature,
+ decision,
+ cycleId: asNumber(metadata.cycleId),
+ entityType: input.entityType,
+ entityId,
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ return;
+ }
+
+ const nominationAction = ({
+ NOMINATION_CREATED: "CREATED",
+ NOMINATION_REMOVED: "REMOVED",
+ NOMINATIONS_SUBMITTED: "SUBMITTED",
+ NOMINATION_APPROVED: "APPROVED",
+ NOMINATION_REJECTED: "REJECTED",
+ NOMINATION_APPROVED_BULK: "BULK_APPROVED",
+ } as Record)[input.action];
+
+ if (nominationAction) {
+ const employee = personSnapshot(metadata.employee);
+ const reviewer = personSnapshot(metadata.reviewer);
+ await prisma.nominationEvent.create({
+ data: {
+ actorId,
+ nominationId: input.action === "NOMINATIONS_SUBMITTED" ? null : entityId,
+ cycleId: asNumber(metadata.cycleId),
+ employeeId: asNumber(employee.id),
+ reviewerId: asNumber(reviewer.id),
+ action: nominationAction as any,
+ previousApprovalStatus: enumValue(metadata.previousApprovalStatus, ["PENDING", "APPROVED", "REJECTED"] as const),
+ approvalStatus: enumValue(metadata.approvalStatus, ["PENDING", "APPROVED", "REJECTED"] as const),
+ submissionStatus: enumValue(metadata.submissionStatus, ["DRAFT", "SUBMITTED"] as const),
+ employeeDepartmentId: asNumber(employee.departmentId),
+ reviewerDepartmentId: asNumber(reviewer.departmentId),
+ employeeDepartmentName: asString(employee.department),
+ reviewerDepartmentName: asString(reviewer.department),
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ return;
+ }
+
+ const reviewAction = ({
+ REVIEW_DRAFT_SAVED: "DRAFT_SAVED",
+ REVIEW_SUBMITTED: "SUBMITTED",
+ } as Record)[input.action];
+
+ if (reviewAction) {
+ const employee = personSnapshot(metadata.employee);
+ const reviewer = personSnapshot(metadata.reviewer);
+ await prisma.reviewEvent.create({
+ data: {
+ actorId,
+ reviewId: entityId,
+ cycleId: asNumber(metadata.cycleId),
+ employeeId: asNumber(employee.id),
+ reviewerId: asNumber(reviewer.id),
+ action: reviewAction as any,
+ status: enumValue(metadata.status, ["DRAFT", "SUBMITTED"] as const),
+ ratingCount: asNumber(metadata.ratingCount) ?? 0,
+ hasDoWellComment: Boolean(metadata.hasDoWellComment),
+ hasImproveComment: Boolean(metadata.hasImproveComment),
+ hasAttentionComment: Boolean(metadata.hasAttentionComment),
+ wouldPickForTeam: asBoolean(metadata.wouldPickForTeam),
+ metadata: metadata as Prisma.InputJsonObject,
+ },
+ });
+ }
+}
diff --git a/pulse360/src/lib/auth.ts b/pulse360/src/lib/auth.ts
index 6900515..ee24053 100644
--- a/pulse360/src/lib/auth.ts
+++ b/pulse360/src/lib/auth.ts
@@ -46,7 +46,7 @@ export const authOptions: NextAuthOptions = {
action: "LOGIN_FAILED",
entityType: "auth",
entityId: employee.id,
- metadata: { email: employee.email, reason: "invalid_password", role: employee.role },
+ metadata: { email: employee.email, reason: "invalid_password", role: employee.role },
}).catch(() => {});
return null;
}
@@ -57,7 +57,9 @@ export const authOptions: NextAuthOptions = {
entityType: "auth",
entityId: employee.id,
metadata: {
+ email: employee.email,
role: employee.role,
+ departmentId: employee.departmentId,
department: employee.department.name,
},
}).catch(() => {});