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

upd: update limit

Browse source
This commit is contained in:
Mar0xy 2023-11-12 15:37:36 +01:00
parent de9ea4d9f1
commit 2d1e8ee44d
No known key found for this signature in database
GPG key ID: 56569BBE47D2C828
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -98,7 +98,9 @@ export class ImportNotesProcessorService {
return;
}
if (job.data.type === 'Twitter' || file.name.startsWith('twitter') && file.name.endsWith('.zip')) {
const type = job.data.type ?? '';
if (type === 'Twitter' || file.name.startsWith('twitter') && file.name.endsWith('.zip')) {
const [path, cleanup] = await createTempDir();
this.logger.info(`Temp dir is ${path}`);
@ -159,8 +161,8 @@ export class ImportNotesProcessorService {
try {
this.logger.succ(`Unzipping to ${outputPath}`);
ZipReader.withDestinationPath(outputPath).viaBuffer(await fs.promises.readFile(destPath));
const isInstagram = job.data.type === 'Instagram' || fs.existsSync(outputPath + '/instagram_live') || fs.existsSync(outputPath + '/instagram_ads_and_businesses');
const isOutbox = job.data.type === 'Mastodon' || fs.existsSync(outputPath + '/outbox.json');
const isInstagram = type === 'Instagram' || fs.existsSync(outputPath + '/instagram_live') || fs.existsSync(outputPath + '/instagram_ads_and_businesses');
const isOutbox = type === 'Mastodon' || fs.existsSync(outputPath + '/outbox.json');
if (isInstagram) {
const postsJson = fs.readFileSync(outputPath + '/content/posts_1.json', 'utf-8');
const posts = JSON.parse(postsJson);

2
packages/backend/src/server/api/endpoints/i/import-notes.ts
View file

@ -13,7 +13,7 @@ export const meta = {
prohibitMoved: true,
limit: {
duration: ms('1hour'),
max: 1,
max: 5,
},
errors: {