OpenSource/Sharkey
OpenSource/Sharkey
1
0
Fork 0
mirror of https://activitypub.software/TransFem-org/Sharkey.git synced 2024-12-14 10:05:46 +01:00
Code Issues Projects Releases Packages Wiki Activity

fix: attachments not working on FB import

Browse source
This commit is contained in:
Mar0xy 2023-11-22 19:02:43 +01:00
parent d078a72f38
commit 81c36908d9
No known key found for this signature in database
GPG key ID: 56569BBE47D2C828
1 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
packages/backend/src/queue/processors/ImportNotesProcessorService.ts
View file

@ -569,7 +569,7 @@ export class ImportNotesProcessorService {
return;
}
if (!this.isIterable(post.data) || !post.data[0].post) return;
if (!this.isIterable(post.data) || this.isIterable(post.data) && post.data[0].post === undefined) return;
const date = new Date(post.timestamp * 1000);
const title = decodeFBString(post.data[0].post);
@ -583,12 +583,18 @@ export class ImportNotesProcessorService {
return Buffer.from(arr).toString('utf8');
}
if (post.attachments && this.isIterable(post.attachments) && this.isIterable(post.attachments.data)) {
for await (const file of post.attachments.data) {
if (!file.media) return;
const slashdex = file.media.uri.lastIndexOf('/');
const name = file.media.uri.substring(slashdex + 1);
const exists = await this.driveFilesRepository.findOneBy({ name: name, userId: user.id }) ?? await this.driveFilesRepository.findOneBy({ name: `${name}.jpg`, userId: user.id }) ?? await this.driveFilesRepository.findOneBy({ name: `${name}.mp4`, userId: user.id });
if (post.attachments && this.isIterable(post.attachments)) {
const media = [];
for await (const data of post.attachments[0].data) {
if (data.media) {
media.push(data.media);
}
}
for await (const file of media) {
const slashdex = file.uri.lastIndexOf('/');
const name = file.uri.substring(slashdex + 1);
const exists = await this.driveFilesRepository.findOneBy({ name: name, userId: user.id });
if (exists) {
files.push(exists);
}