aboutsummaryrefslogtreecommitdiff
path: root/api/src/modules/users/users.service.ts
diff options
context:
space:
mode:
authorLucas Faria Mendes <lucas.fariamo08@gmail.com>2026-08-16 23:17:42 +0000
committerLucas Faria Mendes <lucas.fariamo08@gmail.com>2026-08-16 23:17:42 +0000
commit375482e654a01615683867e732ac9e458c7cbe74 (patch)
tree12d1b31b8deb6bf8590bcdbc2cfb52dcc553e006 /api/src/modules/users/users.service.ts
parent2c2dfba45357bbd205a59145ae55a2779c911ae0 (diff)
downloadyaba-master.tar.gz
yaba-master.zip
feat: upload yaba srcHEADmaster
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.ts53
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;
+}