aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/server/repositories/user.ts
blob: e571409a42ae8316713f81da92d5b113f8941ce9 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
import { eq } from "drizzle-orm";
import { db, users } from "../db/index.js";
import type { UserPublic, UserRepository } from "./types.js";

export const userRepository: UserRepository = {
	async findByUsername(username) {
		const [user] = await db
			.select({
				id: users.id,
				username: users.username,
				passwordHash: users.passwordHash,
			})
			.from(users)
			.where(eq(users.username, username))
			.limit(1);
		return user;
	},

	async existsByUsername(username) {
		const [user] = await db
			.select({ id: users.id })
			.from(users)
			.where(eq(users.username, username))
			.limit(1);
		return user !== undefined;
	},

	async create(data): Promise<UserPublic> {
		const [newUser] = await db
			.insert(users)
			.values({
				username: data.username,
				passwordHash: data.passwordHash,
			})
			.returning({
				id: users.id,
				username: users.username,
				createdAt: users.createdAt,
			});
		if (!newUser) {
			throw new Error("Failed to create user");
		}
		return newUser;
	},

	async findById(id) {
		const [user] = await db
			.select({
				id: users.id,
				username: users.username,
			})
			.from(users)
			.where(eq(users.id, id))
			.limit(1);
		return user;
	},
};