jeffemmett
/
postiz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: fix non http requests (sdks)

This commit is contained in:
Nevo David 2025-07-11 19:41:23 +07:00
parent 67147e18a3
commit 2d5f7f9788
3 changed files with 114 additions and 74 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
libraries/nestjs-libraries/src/integrations/social.abstract.ts
View File

@ -31,13 +31,32 @@ export abstract class SocialAbstract {
return undefined;
}
async runInConcurrent<T>(func: (...args: any[]) => Promise<T>) {
const value = await concurrencyService<any>(this.identifier.split('-')[0], async () => {
try {
return await func();
} catch (err) {
return {type: 'error', value: err};
}
});
if (value && value.type === 'error') {
throw value.value;
}
return value;
}
async fetch(
url: string,
options: RequestInit = {},
identifier = '',
totalRetries = 0
): Promise<Response> {
const request = await concurrencyService(this.identifier.split('-')[0], () => fetch(url, options));
const request = await concurrencyService(
this.identifier.split('-')[0],
() => fetch(url, options)
);
if (request.status === 200 || request.status === 201) {
return request;
@ -64,7 +83,10 @@ export abstract class SocialAbstract {
const handleError = this.handleErrors(json || '{}');
if (request.status === 401 && (handleError?.type === 'refresh-token' || !handleError)) {
if (
request.status === 401 &&
(handleError?.type === 'refresh-token' || !handleError)
) {
console.log('refresh token', json);
throw new RefreshToken(
identifier,
@ -74,7 +96,12 @@ export abstract class SocialAbstract {
);
}
throw new BadBody(identifier, json, options.body!, handleError?.value || '');
throw new BadBody(
identifier,
json,
options.body!,
handleError?.value || ''
);
}
checkScopes(required: string[], got: string | string[]) {

93
libraries/nestjs-libraries/src/integrations/social/x.provider.ts
View File

@ -262,9 +262,11 @@ export class XProvider extends SocialAbstract implements SocialProvider {
});
const {
data: { username },
} = await client.v2.me({
'user.fields': 'username',
});
} = await this.runInConcurrent(async () =>
client.v2.me({
'user.fields': 'username',
})
);
// upload everything before, you don't want it to fail between the posts
const uploadAll = (
@ -272,20 +274,22 @@ export class XProvider extends SocialAbstract implements SocialProvider {
postDetails.flatMap((p) =>
p?.media?.flatMap(async (m) => {
return {
id: await client.v1.uploadMedia(
m.path.indexOf('mp4') > -1
? Buffer.from(await readOrFetch(m.path))
: await sharp(await readOrFetch(m.path), {
animated: lookup(m.path) === 'image/gif',
})
.resize({
width: 1000,
id: await this.runInConcurrent(async () =>
client.v1.uploadMedia(
m.path.indexOf('mp4') > -1
? Buffer.from(await readOrFetch(m.path))
: await sharp(await readOrFetch(m.path), {
animated: lookup(m.path) === 'image/gif',
})
.gif()
.toBuffer(),
{
mimeType: lookup(m.path) || '',
}
.resize({
width: 1000,
})
.gif()
.toBuffer(),
{
mimeType: lookup(m.path) || '',
}
)
),
postId: p.id,
};
@ -308,25 +312,28 @@ export class XProvider extends SocialAbstract implements SocialProvider {
const media_ids = (uploadAll[post.id] || []).filter((f) => f);
// @ts-ignore
const { data }: { data: { id: string } } = await client.v2.tweet({
...(!postDetails?.[0]?.settings?.who_can_reply_post ||
postDetails?.[0]?.settings?.who_can_reply_post === 'everyone'
? {}
: {
reply_settings: postDetails?.[0]?.settings?.who_can_reply_post,
}),
...(postDetails?.[0]?.settings?.community
? {
community_id:
postDetails?.[0]?.settings?.community?.split('/').pop() || '',
}
: {}),
text: post.message,
...(media_ids.length ? { media: { media_ids } } : {}),
...(ids.length
? { reply: { in_reply_to_tweet_id: ids[ids.length - 1].postId } }
: {}),
});
const { data }: { data: { id: string } } = await this.runInConcurrent( async () => client.v2.tweet({
...(!postDetails?.[0]?.settings?.who_can_reply_post ||
postDetails?.[0]?.settings?.who_can_reply_post === 'everyone'
? {}
: {
reply_settings:
postDetails?.[0]?.settings?.who_can_reply_post,
}),
...(postDetails?.[0]?.settings?.community
? {
community_id:
postDetails?.[0]?.settings?.community?.split('/').pop() ||
'',
}
: {}),
text: post.message,
...(media_ids.length ? { media: { media_ids } } : {}),
...(ids.length
? { reply: { in_reply_to_tweet_id: ids[ids.length - 1].postId } }
: {}),
})
);
ids.push({
postId: data.id,
@ -337,13 +344,15 @@ export class XProvider extends SocialAbstract implements SocialProvider {
if (postDetails?.[0]?.settings?.active_thread_finisher) {
try {
await client.v2.tweet({
text:
postDetails?.[0]?.settings?.thread_finisher! +
'\n' +
ids[0].releaseURL,
reply: { in_reply_to_tweet_id: ids[ids.length - 1].postId },
});
await this.runInConcurrent(async () =>
client.v2.tweet({
text:
postDetails?.[0]?.settings?.thread_finisher! +
'\n' +
ids[0].releaseURL,
reply: { in_reply_to_tweet_id: ids[ids.length - 1].postId },
})
);
} catch (err) {}
}

62
libraries/nestjs-libraries/src/integrations/social/youtube.provider.ts
View File

@ -153,25 +153,27 @@ export class YoutubeProvider extends SocialAbstract implements SocialProvider {
let all: GaxiosResponse<Schema$Video>;
try {
all = await youtubeClient.videos.insert({
part: ['id', 'snippet', 'status'],
notifySubscribers: true,
requestBody: {
snippet: {
title: settings.title,
description: firstPost?.message,
...(settings?.tags?.length
? { tags: settings.tags.map((p) => p.label) }
: {}),
all = await this.runInConcurrent(async () =>
youtubeClient.videos.insert({
part: ['id', 'snippet', 'status'],
notifySubscribers: true,
requestBody: {
snippet: {
title: settings.title,
description: firstPost?.message,
...(settings?.tags?.length
? { tags: settings.tags.map((p) => p.label) }
: {}),
},
status: {
privacyStatus: settings.type,
},
},
status: {
privacyStatus: settings.type,
media: {
body: response.data,
},
},
media: {
body: response.data,
},
});
})
);
} catch (err: any) {
if (
err.response?.data?.error?.errors?.[0]?.reason === 'failedPrecondition'
@ -215,18 +217,20 @@ export class YoutubeProvider extends SocialAbstract implements SocialProvider {
if (settings?.thumbnail?.path) {
try {
await youtubeClient.thumbnails.set({
videoId: all?.data?.id!,
media: {
body: (
await axios({
url: settings?.thumbnail?.path,
method: 'GET',
responseType: 'stream',
})
).data,
},
});
await this.runInConcurrent(async () =>
youtubeClient.thumbnails.set({
videoId: all?.data?.id!,
media: {
body: (
await axios({
url: settings?.thumbnail?.path,
method: 'GET',
responseType: 'stream',
})
).data,
},
})
);
} catch (err: any) {
if (
err.response?.data?.error?.errors?.[0]?.domain === 'youtube.thumbnail'