graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-12-24 18:23:58 +02:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #1400 from akihikodaki/duplicate

Browse source 
Handle inReplyTo property
This commit is contained in:
syuilo 2018-04-05 01:59:10 +09:00 committed by GitHub
commit 15b9bfb471
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/remote/activitypub/create.ts
View file

@ -48,11 +48,6 @@ class Creator {
throw new Error();
}
const mediaIds = 'attachment' in note &&
(await Promise.all(await this.create(resolver, note.attachment)))
.filter(media => media !== null && media.object.$ref === 'driveFiles.files')
.map(({ object }) => object.$id);
const { window } = new JSDOM(note.content);
const mentions = [];
const tags = [];
@ -71,13 +66,27 @@ class Creator {
}
}
const [mediaIds, reply] = await Promise.all([
'attachment' in note && this.create(resolver, note.attachment)
.then(collection => Promise.all(collection))
.then(collection => collection
.filter(media => media !== null && media.object.$ref === 'driveFiles.files')
.map(({ object }: IResult) => object.$id)),
'inReplyTo' in note && this.create(resolver, note.inReplyTo)
.then(collection => Promise.all(collection.map(promise => promise.then(result => {
if (result !== null && result.object.$ref === 'posts') {
throw result.object;
}
}, () => { }))))
.then(() => null, ({ $id }) => Post.findOne({ _id: $id }))
]);
const inserted = await createPost({
channelId: undefined,
index: undefined,
createdAt: new Date(note.published),
mediaIds,
replyId: undefined,
repostId: undefined,
poll: undefined,
text: window.document.body.textContent,
textHtml: note.content && createDOMPurify(window).sanitize(note.content),
@ -87,7 +96,7 @@ class Creator {
geo: undefined,
uri: note.id,
tags
}, null, null, await Promise.all(mentions));
}, reply, null, await Promise.all(mentions));
const promises = [];