Skip to content

Commit 1877a8e

Browse files
committed
add try catch to get video functions
1 parent df24afb commit 1877a8e

File tree

1 file changed

+47
-37
lines changed

1 file changed

+47
-37
lines changed

models/video.ts

+47-37
Original file line numberDiff line numberDiff line change
@@ -78,53 +78,63 @@ export async function getRandomVideos(
7878
page: number,
7979
limit: number
8080
): Promise<Video[]> {
81-
if (page <= 0) {
82-
page = 1;
83-
}
84-
if (limit <= 0) {
85-
limit = 50;
86-
}
87-
const offset = (page - 1) * limit;
88-
89-
const db = getDb();
90-
const res = await db.query(
91-
`select w.*, u.uuid as user_uuid, u.email as user_email, u.nickname as user_name, u.avatar_url as user_avatar from videos as w left join users as u on w.user_uuid = u.uuid::VARCHAR where w.status = 1 order by random() limit $1 offset $2`,
92-
[limit, offset]
93-
);
94-
95-
if (res.rowCount === 0) {
81+
try {
82+
if (page <= 0) {
83+
page = 1;
84+
}
85+
if (limit <= 0) {
86+
limit = 50;
87+
}
88+
const offset = (page - 1) * limit;
89+
90+
const db = getDb();
91+
const res = await db.query(
92+
`select w.*, u.uuid as user_uuid, u.email as user_email, u.nickname as user_name, u.avatar_url as user_avatar from videos as w left join users as u on w.user_uuid = u.uuid::VARCHAR where w.status = 1 order by random() limit $1 offset $2`,
93+
[limit, offset]
94+
);
95+
96+
if (res.rowCount === 0) {
97+
return [];
98+
}
99+
100+
const videos = getVideosFromSqlResult(res);
101+
102+
return videos;
103+
} catch (error) {
104+
console.log("get random videos error", error);
96105
return [];
97106
}
98-
99-
const videos = getVideosFromSqlResult(res);
100-
101-
return videos;
102107
}
103108

104109
export async function getLatestVideos(
105110
page: number,
106111
limit: number
107112
): Promise<Video[]> {
108-
if (page < 1) {
109-
page = 1;
110-
}
111-
if (limit <= 0) {
112-
limit = 50;
113-
}
114-
const offset = (page - 1) * limit;
115-
116-
const db = getDb();
117-
const res = await db.query(
118-
`select w.*, u.uuid as user_uuid, u.email as user_email, u.nickname as user_name, u.avatar_url as user_avatar from videos as w left join users as u on w.user_uuid = u.uuid::VARCHAR where w.status = 1 order by w.created_at desc limit $1 offset $2`,
119-
[limit, offset]
120-
);
121-
if (res.rowCount === 0) {
113+
try {
114+
if (page < 1) {
115+
page = 1;
116+
}
117+
if (limit <= 0) {
118+
limit = 50;
119+
}
120+
const offset = (page - 1) * limit;
121+
122+
const db = getDb();
123+
const res = await db.query(
124+
`select w.*, u.uuid as user_uuid, u.email as user_email, u.nickname as user_name, u.avatar_url as user_avatar from videos as w left join users as u on w.user_uuid = u.uuid::VARCHAR where w.status = 1 order by w.created_at desc limit $1 offset $2`,
125+
[limit, offset]
126+
);
127+
if (res.rowCount === 0) {
128+
return [];
129+
}
130+
131+
const videos = getVideosFromSqlResult(res);
132+
133+
return videos;
134+
} catch (error) {
135+
console.log("get latest videos error", error);
122136
return [];
123137
}
124-
125-
const videos = getVideosFromSqlResult(res);
126-
127-
return videos;
128138
}
129139

130140
export async function getRecommendedVideos(

0 commit comments

Comments
 (0)