summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/announcements.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/api/endpoints/announcements.ts')
-rw-r--r--src/server/api/endpoints/announcements.ts42
1 files changed, 42 insertions, 0 deletions
diff --git a/src/server/api/endpoints/announcements.ts b/src/server/api/endpoints/announcements.ts
new file mode 100644
index 0000000000..c6050d6092
--- /dev/null
+++ b/src/server/api/endpoints/announcements.ts
@@ -0,0 +1,42 @@
+import $ from 'cafy';
+import { ID } from '../../../misc/cafy-id';
+import define from '../define';
+import { Announcements, AnnouncementReads } from '../../../models';
+import { makePaginationQuery } from '../common/make-pagination-query';
+
+export const meta = {
+ requireCredential: false,
+
+ params: {
+ limit: {
+ validator: $.optional.num.range(1, 100),
+ default: 10
+ },
+
+ sinceId: {
+ validator: $.optional.type(ID),
+ },
+
+ untilId: {
+ validator: $.optional.type(ID),
+ },
+ }
+};
+
+export default define(meta, async (ps, user) => {
+ const query = makePaginationQuery(Announcements.createQueryBuilder('announcement'), ps.sinceId, ps.untilId);
+
+ const announcements = await query.take(ps.limit!).getMany();
+
+ if (user) {
+ const reads = (await AnnouncementReads.find({
+ userId: user.id
+ })).map(x => x.announcementId);
+
+ for (const announcement of announcements) {
+ (announcement as any).isRead = reads.includes(announcement.id);
+ }
+ }
+
+ return announcements;
+});