Skip to content

Commit c80bf27

Browse files
feat: add users.getAll for admin dashboard
1 parent 671b58d commit c80bf27

3 files changed

Lines changed: 21 additions & 2 deletions

File tree

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "backend",
3-
"version": "0.15.11",
3+
"version": "0.15.12",
44
"description": "PoliNetwork backend server",
55
"private": true,
66
"keywords": [],

package/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@polinetwork/backend",
3-
"version": "0.15.11",
3+
"version": "0.15.12",
44
"description": "Utils to interact with the backend.",
55
"repository": {
66
"type": "git",

src/routers/tg/users.ts

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,25 @@ const s = SCHEMA.TG
1111
const upsertSet = upsertMultipleSetSql(s.users, ["firstName", "lastName", "username", "langCode", "isBot"])
1212

1313
export default createTRPCRouter({
14+
getAll: publicProcedure.query(async () => {
15+
try {
16+
const res = await DB.select().from(s.users)
17+
const decryptedUsers = await Promise.all(res.map((user) => decryptUser(user).catch(() => null)))
18+
19+
return {
20+
users: decryptedUsers.filter((user) => user !== null),
21+
error: null,
22+
}
23+
} catch (error) {
24+
if (error instanceof DecryptError) {
25+
logger.error(error, "error while decrypting a telegram user from table tg.users")
26+
return { error: "DECRYPT_ERROR" }
27+
}
28+
29+
return { error: "INTERNAL_SERVER_ERROR" }
30+
}
31+
}),
32+
1433
get: publicProcedure
1534
.input(z.object({ userId: z.number() }))
1635
.output(

0 commit comments

Comments
 (0)