Compare commits
3 Commits
685a311001
...
1b0f5866a1
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1b0f5866a1 | ||
|
|
159022ef38 | ||
|
|
1a7d13d5b9 |
@@ -0,0 +1,8 @@
|
|||||||
|
-- AlterTable: add deleted_at column to clients
|
||||||
|
ALTER TABLE "clients" ADD COLUMN "deleted_at" TIMESTAMP(3);
|
||||||
|
|
||||||
|
-- AlterTable: add deleted_at column to projects
|
||||||
|
ALTER TABLE "projects" ADD COLUMN "deleted_at" TIMESTAMP(3);
|
||||||
|
|
||||||
|
-- AlterTable: add deleted_at column to time_entries
|
||||||
|
ALTER TABLE "time_entries" ADD COLUMN "deleted_at" TIMESTAMP(3);
|
||||||
@@ -30,6 +30,7 @@ model Client {
|
|||||||
description String? @db.Text
|
description String? @db.Text
|
||||||
createdAt DateTime @default(now()) @map("created_at")
|
createdAt DateTime @default(now()) @map("created_at")
|
||||||
updatedAt DateTime @updatedAt @map("updated_at")
|
updatedAt DateTime @updatedAt @map("updated_at")
|
||||||
|
deletedAt DateTime? @map("deleted_at")
|
||||||
|
|
||||||
userId String @map("user_id") @db.VarChar(255)
|
userId String @map("user_id") @db.VarChar(255)
|
||||||
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
||||||
@@ -47,6 +48,7 @@ model Project {
|
|||||||
color String? @db.VarChar(7) // Hex color code
|
color String? @db.VarChar(7) // Hex color code
|
||||||
createdAt DateTime @default(now()) @map("created_at")
|
createdAt DateTime @default(now()) @map("created_at")
|
||||||
updatedAt DateTime @updatedAt @map("updated_at")
|
updatedAt DateTime @updatedAt @map("updated_at")
|
||||||
|
deletedAt DateTime? @map("deleted_at")
|
||||||
|
|
||||||
userId String @map("user_id") @db.VarChar(255)
|
userId String @map("user_id") @db.VarChar(255)
|
||||||
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
||||||
@@ -69,6 +71,7 @@ model TimeEntry {
|
|||||||
description String? @db.Text
|
description String? @db.Text
|
||||||
createdAt DateTime @default(now()) @map("created_at")
|
createdAt DateTime @default(now()) @map("created_at")
|
||||||
updatedAt DateTime @updatedAt @map("updated_at")
|
updatedAt DateTime @updatedAt @map("updated_at")
|
||||||
|
deletedAt DateTime? @map("deleted_at")
|
||||||
|
|
||||||
userId String @map("user_id") @db.VarChar(255)
|
userId String @map("user_id") @db.VarChar(255)
|
||||||
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
user User @relation(fields: [userId], references: [id], onDelete: Cascade)
|
||||||
|
|||||||
@@ -5,14 +5,14 @@ import type { CreateClientInput, UpdateClientInput } from "../types";
|
|||||||
export class ClientService {
|
export class ClientService {
|
||||||
async findAll(userId: string) {
|
async findAll(userId: string) {
|
||||||
return prisma.client.findMany({
|
return prisma.client.findMany({
|
||||||
where: { userId },
|
where: { userId, deletedAt: null },
|
||||||
orderBy: { name: "asc" },
|
orderBy: { name: "asc" },
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
async findById(id: string, userId: string) {
|
async findById(id: string, userId: string) {
|
||||||
return prisma.client.findFirst({
|
return prisma.client.findFirst({
|
||||||
where: { id, userId },
|
where: { id, userId, deletedAt: null },
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -43,8 +43,9 @@ export class ClientService {
|
|||||||
throw new NotFoundError("Client not found");
|
throw new NotFoundError("Client not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
await prisma.client.delete({
|
await prisma.client.update({
|
||||||
where: { id },
|
where: { id },
|
||||||
|
data: { deletedAt: new Date() },
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -68,7 +68,7 @@ export interface ClientTargetWithBalance {
|
|||||||
export class ClientTargetService {
|
export class ClientTargetService {
|
||||||
async findAll(userId: string): Promise<ClientTargetWithBalance[]> {
|
async findAll(userId: string): Promise<ClientTargetWithBalance[]> {
|
||||||
const targets = await prisma.clientTarget.findMany({
|
const targets = await prisma.clientTarget.findMany({
|
||||||
where: { userId },
|
where: { userId, client: { deletedAt: null } },
|
||||||
include: {
|
include: {
|
||||||
client: { select: { id: true, name: true } },
|
client: { select: { id: true, name: true } },
|
||||||
corrections: { orderBy: { date: 'asc' } },
|
corrections: { orderBy: { date: 'asc' } },
|
||||||
@@ -81,7 +81,7 @@ export class ClientTargetService {
|
|||||||
|
|
||||||
async findById(id: string, userId: string) {
|
async findById(id: string, userId: string) {
|
||||||
return prisma.clientTarget.findFirst({
|
return prisma.clientTarget.findFirst({
|
||||||
where: { id, userId },
|
where: { id, userId, client: { deletedAt: null } },
|
||||||
include: {
|
include: {
|
||||||
client: { select: { id: true, name: true } },
|
client: { select: { id: true, name: true } },
|
||||||
corrections: { orderBy: { date: 'asc' } },
|
corrections: { orderBy: { date: 'asc' } },
|
||||||
@@ -97,8 +97,8 @@ export class ClientTargetService {
|
|||||||
throw new BadRequestError('startDate must be a Monday');
|
throw new BadRequestError('startDate must be a Monday');
|
||||||
}
|
}
|
||||||
|
|
||||||
// Ensure the client belongs to this user
|
// Ensure the client belongs to this user and is not soft-deleted
|
||||||
const client = await prisma.client.findFirst({ where: { id: data.clientId, userId } });
|
const client = await prisma.client.findFirst({ where: { id: data.clientId, userId, deletedAt: null } });
|
||||||
if (!client) {
|
if (!client) {
|
||||||
throw new NotFoundError('Client not found');
|
throw new NotFoundError('Client not found');
|
||||||
}
|
}
|
||||||
@@ -229,6 +229,8 @@ export class ClientTargetService {
|
|||||||
AND p.client_id = ${target.clientId}
|
AND p.client_id = ${target.clientId}
|
||||||
AND te.start_time >= ${periodStart}
|
AND te.start_time >= ${periodStart}
|
||||||
AND te.start_time <= ${periodEnd}
|
AND te.start_time <= ${periodEnd}
|
||||||
|
AND te.deleted_at IS NULL
|
||||||
|
AND p.deleted_at IS NULL
|
||||||
GROUP BY DATE_TRUNC('week', te.start_time AT TIME ZONE 'UTC')
|
GROUP BY DATE_TRUNC('week', te.start_time AT TIME ZONE 'UTC')
|
||||||
`);
|
`);
|
||||||
|
|
||||||
|
|||||||
@@ -7,6 +7,8 @@ export class ProjectService {
|
|||||||
return prisma.project.findMany({
|
return prisma.project.findMany({
|
||||||
where: {
|
where: {
|
||||||
userId,
|
userId,
|
||||||
|
deletedAt: null,
|
||||||
|
client: { deletedAt: null },
|
||||||
...(clientId && { clientId }),
|
...(clientId && { clientId }),
|
||||||
},
|
},
|
||||||
orderBy: { name: "asc" },
|
orderBy: { name: "asc" },
|
||||||
@@ -23,7 +25,12 @@ export class ProjectService {
|
|||||||
|
|
||||||
async findById(id: string, userId: string) {
|
async findById(id: string, userId: string) {
|
||||||
return prisma.project.findFirst({
|
return prisma.project.findFirst({
|
||||||
where: { id, userId },
|
where: {
|
||||||
|
id,
|
||||||
|
userId,
|
||||||
|
deletedAt: null,
|
||||||
|
client: { deletedAt: null },
|
||||||
|
},
|
||||||
include: {
|
include: {
|
||||||
client: {
|
client: {
|
||||||
select: {
|
select: {
|
||||||
@@ -36,9 +43,9 @@ export class ProjectService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async create(userId: string, data: CreateProjectInput) {
|
async create(userId: string, data: CreateProjectInput) {
|
||||||
// Verify the client belongs to the user
|
// Verify the client belongs to the user and is not soft-deleted
|
||||||
const client = await prisma.client.findFirst({
|
const client = await prisma.client.findFirst({
|
||||||
where: { id: data.clientId, userId },
|
where: { id: data.clientId, userId, deletedAt: null },
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!client) {
|
if (!client) {
|
||||||
@@ -70,10 +77,10 @@ export class ProjectService {
|
|||||||
throw new NotFoundError("Project not found");
|
throw new NotFoundError("Project not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
// If clientId is being updated, verify it belongs to the user
|
// If clientId is being updated, verify it belongs to the user and is not soft-deleted
|
||||||
if (data.clientId) {
|
if (data.clientId) {
|
||||||
const client = await prisma.client.findFirst({
|
const client = await prisma.client.findFirst({
|
||||||
where: { id: data.clientId, userId },
|
where: { id: data.clientId, userId, deletedAt: null },
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!client) {
|
if (!client) {
|
||||||
@@ -108,8 +115,9 @@ export class ProjectService {
|
|||||||
throw new NotFoundError("Project not found");
|
throw new NotFoundError("Project not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
await prisma.project.delete({
|
await prisma.project.update({
|
||||||
where: { id },
|
where: { id },
|
||||||
|
data: { deletedAt: new Date() },
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -46,7 +46,11 @@ export class TimeEntryService {
|
|||||||
COUNT(te.id)::bigint AS entry_count
|
COUNT(te.id)::bigint AS entry_count
|
||||||
FROM time_entries te
|
FROM time_entries te
|
||||||
JOIN projects p ON p.id = te.project_id
|
JOIN projects p ON p.id = te.project_id
|
||||||
|
JOIN clients c ON c.id = p.client_id
|
||||||
WHERE te.user_id = ${userId}
|
WHERE te.user_id = ${userId}
|
||||||
|
AND te.deleted_at IS NULL
|
||||||
|
AND p.deleted_at IS NULL
|
||||||
|
AND c.deleted_at IS NULL
|
||||||
${filterClause}
|
${filterClause}
|
||||||
GROUP BY p.id, p.name, p.color
|
GROUP BY p.id, p.name, p.color
|
||||||
ORDER BY total_seconds DESC
|
ORDER BY total_seconds DESC
|
||||||
@@ -69,6 +73,9 @@ export class TimeEntryService {
|
|||||||
JOIN projects p ON p.id = te.project_id
|
JOIN projects p ON p.id = te.project_id
|
||||||
JOIN clients c ON c.id = p.client_id
|
JOIN clients c ON c.id = p.client_id
|
||||||
WHERE te.user_id = ${userId}
|
WHERE te.user_id = ${userId}
|
||||||
|
AND te.deleted_at IS NULL
|
||||||
|
AND p.deleted_at IS NULL
|
||||||
|
AND c.deleted_at IS NULL
|
||||||
${filterClause}
|
${filterClause}
|
||||||
GROUP BY c.id, c.name
|
GROUP BY c.id, c.name
|
||||||
ORDER BY total_seconds DESC
|
ORDER BY total_seconds DESC
|
||||||
@@ -81,7 +88,11 @@ export class TimeEntryService {
|
|||||||
COUNT(te.id)::bigint AS entry_count
|
COUNT(te.id)::bigint AS entry_count
|
||||||
FROM time_entries te
|
FROM time_entries te
|
||||||
JOIN projects p ON p.id = te.project_id
|
JOIN projects p ON p.id = te.project_id
|
||||||
|
JOIN clients c ON c.id = p.client_id
|
||||||
WHERE te.user_id = ${userId}
|
WHERE te.user_id = ${userId}
|
||||||
|
AND te.deleted_at IS NULL
|
||||||
|
AND p.deleted_at IS NULL
|
||||||
|
AND c.deleted_at IS NULL
|
||||||
${filterClause}
|
${filterClause}
|
||||||
`,
|
`,
|
||||||
),
|
),
|
||||||
@@ -125,10 +136,11 @@ export class TimeEntryService {
|
|||||||
|
|
||||||
const where: {
|
const where: {
|
||||||
userId: string;
|
userId: string;
|
||||||
|
deletedAt: null;
|
||||||
startTime?: { gte?: Date; lte?: Date };
|
startTime?: { gte?: Date; lte?: Date };
|
||||||
projectId?: string;
|
projectId?: string;
|
||||||
project?: { clientId?: string };
|
project?: { deletedAt: null; clientId?: string; client: { deletedAt: null } };
|
||||||
} = { userId };
|
} = { userId, deletedAt: null };
|
||||||
|
|
||||||
if (startDate || endDate) {
|
if (startDate || endDate) {
|
||||||
where.startTime = {};
|
where.startTime = {};
|
||||||
@@ -140,9 +152,13 @@ export class TimeEntryService {
|
|||||||
where.projectId = projectId;
|
where.projectId = projectId;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (clientId) {
|
// Always filter out entries whose project or client is soft-deleted,
|
||||||
where.project = { clientId };
|
// merging the optional clientId filter into the project relation filter.
|
||||||
}
|
where.project = {
|
||||||
|
deletedAt: null,
|
||||||
|
client: { deletedAt: null },
|
||||||
|
...(clientId && { clientId }),
|
||||||
|
};
|
||||||
|
|
||||||
const [entries, total] = await Promise.all([
|
const [entries, total] = await Promise.all([
|
||||||
prisma.timeEntry.findMany({
|
prisma.timeEntry.findMany({
|
||||||
@@ -182,7 +198,12 @@ export class TimeEntryService {
|
|||||||
|
|
||||||
async findById(id: string, userId: string) {
|
async findById(id: string, userId: string) {
|
||||||
return prisma.timeEntry.findFirst({
|
return prisma.timeEntry.findFirst({
|
||||||
where: { id, userId },
|
where: {
|
||||||
|
id,
|
||||||
|
userId,
|
||||||
|
deletedAt: null,
|
||||||
|
project: { deletedAt: null, client: { deletedAt: null } },
|
||||||
|
},
|
||||||
include: {
|
include: {
|
||||||
project: {
|
project: {
|
||||||
select: {
|
select: {
|
||||||
@@ -217,9 +238,9 @@ export class TimeEntryService {
|
|||||||
throw new BadRequestError("Break time cannot exceed total duration");
|
throw new BadRequestError("Break time cannot exceed total duration");
|
||||||
}
|
}
|
||||||
|
|
||||||
// Verify the project belongs to the user
|
// Verify the project belongs to the user and is not soft-deleted (nor its client)
|
||||||
const project = await prisma.project.findFirst({
|
const project = await prisma.project.findFirst({
|
||||||
where: { id: data.projectId, userId },
|
where: { id: data.projectId, userId, deletedAt: null, client: { deletedAt: null } },
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!project) {
|
if (!project) {
|
||||||
@@ -288,10 +309,10 @@ export class TimeEntryService {
|
|||||||
throw new BadRequestError("Break time cannot exceed total duration");
|
throw new BadRequestError("Break time cannot exceed total duration");
|
||||||
}
|
}
|
||||||
|
|
||||||
// If project changed, verify it belongs to the user
|
// If project changed, verify it belongs to the user and is not soft-deleted
|
||||||
if (data.projectId && data.projectId !== entry.projectId) {
|
if (data.projectId && data.projectId !== entry.projectId) {
|
||||||
const project = await prisma.project.findFirst({
|
const project = await prisma.project.findFirst({
|
||||||
where: { id: data.projectId, userId },
|
where: { id: data.projectId, userId, deletedAt: null, client: { deletedAt: null } },
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!project) {
|
if (!project) {
|
||||||
@@ -345,8 +366,9 @@ export class TimeEntryService {
|
|||||||
throw new NotFoundError("Time entry not found");
|
throw new NotFoundError("Time entry not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
await prisma.timeEntry.delete({
|
await prisma.timeEntry.update({
|
||||||
where: { id },
|
where: { id },
|
||||||
|
data: { deletedAt: new Date() },
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ export interface Client {
|
|||||||
description: string | null;
|
description: string | null;
|
||||||
createdAt: string;
|
createdAt: string;
|
||||||
updatedAt: string;
|
updatedAt: string;
|
||||||
|
deletedAt: string | null;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface Project {
|
export interface Project {
|
||||||
@@ -22,6 +23,7 @@ export interface Project {
|
|||||||
client: Pick<Client, 'id' | 'name'>;
|
client: Pick<Client, 'id' | 'name'>;
|
||||||
createdAt: string;
|
createdAt: string;
|
||||||
updatedAt: string;
|
updatedAt: string;
|
||||||
|
deletedAt: string | null;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface TimeEntry {
|
export interface TimeEntry {
|
||||||
@@ -36,6 +38,7 @@ export interface TimeEntry {
|
|||||||
};
|
};
|
||||||
createdAt: string;
|
createdAt: string;
|
||||||
updatedAt: string;
|
updatedAt: string;
|
||||||
|
deletedAt: string | null;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface OngoingTimer {
|
export interface OngoingTimer {
|
||||||
|
|||||||
Reference in New Issue
Block a user