summaryrefslogtreecommitdiff
path: root/src/remote/activitypub/models/question.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/remote/activitypub/models/question.ts')
-rw-r--r--src/remote/activitypub/models/question.ts13
1 files changed, 10 insertions, 3 deletions
diff --git a/src/remote/activitypub/models/question.ts b/src/remote/activitypub/models/question.ts
index 5c126c3a56..01086a7cf8 100644
--- a/src/remote/activitypub/models/question.ts
+++ b/src/remote/activitypub/models/question.ts
@@ -1,12 +1,19 @@
import config from '../../../config';
import Resolver from '../resolver';
-import { IQuestion } from '../type';
+import { IObject, IQuestion, isQuestion, } from '../type';
import { apLogger } from '../logger';
import { Notes, Polls } from '../../../models';
import { IPoll } from '../../../models/entities/poll';
-export async function extractPollFromQuestion(source: string | IQuestion): Promise<IPoll> {
- const question = typeof source === 'string' ? await new Resolver().resolve(source) as IQuestion : source;
+export async function extractPollFromQuestion(source: string | IObject, resolver?: Resolver): Promise<IPoll> {
+ if (resolver == null) resolver = new Resolver();
+
+ const question = await resolver.resolve(source);
+
+ if (!isQuestion(question)) {
+ throw new Error('invalid type');
+ }
+
const multiple = !question.oneOf;
const expiresAt = question.endTime ? new Date(question.endTime) : null;