summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/endpoints/antennas
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-10-07 17:48:10 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-10-07 17:48:10 +0900
commitfb3338029bdb72543345c9a69cbe5318b5676233 (patch)
tree6afeff8b28dcbb474edbd1e7fbf878c245c57542 /packages/backend/src/server/api/endpoints/antennas
parent2023.10.0-beta.6 (diff)
downloadsharkey-fb3338029bdb72543345c9a69cbe5318b5676233.tar.gz
sharkey-fb3338029bdb72543345c9a69cbe5318b5676233.tar.bz2
sharkey-fb3338029bdb72543345c9a69cbe5318b5676233.zip
refactor
Diffstat (limited to 'packages/backend/src/server/api/endpoints/antennas')
-rw-r--r--packages/backend/src/server/api/endpoints/antennas/notes.ts12
1 files changed, 4 insertions, 8 deletions
diff --git a/packages/backend/src/server/api/endpoints/antennas/notes.ts b/packages/backend/src/server/api/endpoints/antennas/notes.ts
index 63e542cb62..b563f704a8 100644
--- a/packages/backend/src/server/api/endpoints/antennas/notes.ts
+++ b/packages/backend/src/server/api/endpoints/antennas/notes.ts
@@ -86,17 +86,13 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
});
const limit = ps.limit + (ps.untilId ? 1 : 0) + (ps.sinceId ? 1 : 0); // untilIdに指定したものも含まれるため+1
- const noteIdsRes = await this.redisForTimelines.xrevrange(
+
+ const noteIds = await this.redisForTimelines.xrevrange(
`antennaTimeline:${antenna.id}`,
ps.untilId ? this.idService.parse(ps.untilId).date.getTime() : ps.untilDate ?? '+',
ps.sinceId ? this.idService.parse(ps.sinceId).date.getTime() : ps.sinceDate ?? '-',
- 'COUNT', limit);
-
- if (noteIdsRes.length === 0) {
- return [];
- }
-
- const noteIds = noteIdsRes.map(x => x[1][1]).filter(x => x !== ps.untilId && x !== ps.sinceId);
+ 'COUNT', limit,
+ ).then(res => res.map(x => x[1][1]).filter(x => x !== ps.untilId && x !== ps.sinceId));
if (noteIds.length === 0) {
return [];