diff options
| author | Lucas Faria Mendes <lucas.fariamo08@gmail.com> | 2026-08-16 23:17:42 +0000 |
|---|---|---|
| committer | Lucas Faria Mendes <lucas.fariamo08@gmail.com> | 2026-08-16 23:17:42 +0000 |
| commit | 375482e654a01615683867e732ac9e458c7cbe74 (patch) | |
| tree | 12d1b31b8deb6bf8590bcdbc2cfb52dcc553e006 /api/src/modules/users/users.service.ts | |
| parent | 2c2dfba45357bbd205a59145ae55a2779c911ae0 (diff) | |
| download | yaba-master.tar.gz yaba-master.zip | |
Signed-off-by: Lucas Faria Mendes <lucas.fariamo08@gmail.com>
Diffstat (limited to 'api/src/modules/users/users.service.ts')
| -rw-r--r-- | api/src/modules/users/users.service.ts | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/api/src/modules/users/users.service.ts b/api/src/modules/users/users.service.ts new file mode 100644 index 0000000..a0fda40 --- /dev/null +++ b/api/src/modules/users/users.service.ts @@ -0,0 +1,53 @@ +import { eq } from 'drizzle-orm'; +import { db } from '@/db/client'; +import { users } from '@/db/schema'; +import type { CreateUserInput, UpdateUserInput } from './users.schema'; + +export async function findAllUsers() { + return db.select().from(users); +} + +export async function findUserById(id: number) { + const result = await db.select().from(users).where(eq(users.id, id)).limit(1); + return result[0] ?? null; +} + +export async function createUser(data: CreateUserInput) { + const [created] = await db + .insert(users) + .values({ + name: data.name, + gross_salary: data.gross_salary, + net_salary_override: data.net_salary_override ?? null, + }) + .returning(); + return created; +} + +export async function updateUser(id: number, data: UpdateUserInput) { + const now = new Date().toISOString(); + + const [updated] = await db + .update(users) + .set({ + ...(data.name !== undefined && { name: data.name }), + ...(data.gross_salary !== undefined && { gross_salary: data.gross_salary }), + // Permite setar null explicitamente (para remover o override) + ...(data.net_salary_override !== undefined && { + net_salary_override: data.net_salary_override, + }), + updated_at: now, + }) + .where(eq(users.id, id)) + .returning(); + + return updated ?? null; +} + +export async function deleteUser(id: number) { + const [deleted] = await db + .delete(users) + .where(eq(users.id, id)) + .returning(); + return deleted ?? null; +} |