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
58
59
60
61
62
63
64
65
66
67
68
|
"use server";
import db from "@/db/db";
import { emailLogs } from "@/db/schema/emailLogs";
import { and, asc, count, desc, ilike, or } from "drizzle-orm";
import { type GetEmailLogSchema } from "./validations";
import { getValidFilters } from "@/lib/data-table";
export async function getEmailLogList(input: GetEmailLogSchema) {
const offset = (input.page - 1) * input.perPage;
const advancedWhere = getValidFilters(input.filters) // placeholder for future advanced filter handling
let globalWhere;
if (input.search) {
const s = `%${input.search}%`;
globalWhere = or(
ilike(emailLogs.from, s),
ilike(emailLogs.to, s),
ilike(emailLogs.cc, s),
ilike(emailLogs.subject, s),
);
}
const conditions = [] as any[];
if (advancedWhere && (advancedWhere as any).length !== 0) conditions.push(advancedWhere);
if (globalWhere) conditions.push(globalWhere);
let where: any;
if (conditions.length > 0) {
where = conditions.length > 1 ? and(...conditions) : conditions[0];
}
let orderBy;
try {
orderBy = input.sort.length > 0
? input.sort
.map((item) => {
if (!item || !item.id || typeof item.id !== "string" || !(item.id in emailLogs)) return null;
const col = emailLogs[item.id as keyof typeof emailLogs];
return item.desc ? desc(col as any) : asc(col as any);
})
.filter((v): v is Exclude<typeof v, null> => v !== null)
: [desc(emailLogs.createdAt)];
} catch {
orderBy = [desc(emailLogs.createdAt)];
}
const data = await db
.select()
.from(emailLogs)
.where(where)
.orderBy(...orderBy as any)
.limit(input.perPage)
.offset(offset);
const totalResult = await db
.select({ count: count() })
.from(emailLogs)
.where(where);
const total = totalResult[0]?.count ?? 0;
const pageCount = Math.ceil(total / input.perPage);
return { data, pageCount };
}
|
