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

fix: slack urgent fix for posting

This commit is contained in:
Nevo David 2026-01-17 16:27:02 +07:00
parent 5bfb97e9a4
commit 7eeb1cb044
1 changed files with 120 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

153
libraries/nestjs-libraries/src/integrations/social/slack.provider.ts
View File

@ -137,6 +137,10 @@ export class SlackProvider extends SocialAbstract implements SocialProvider {
postDetails: PostDetails[],
integration: Integration
): Promise<PostResponse[]> {
const [firstPost] = postDetails;
const channel = firstPost.settings.channel;
// Join the channel first
await fetch(`https://slack.com/api/conversations.join`, {
method: 'POST',
headers: {
@ -144,48 +148,131 @@ export class SlackProvider extends SocialAbstract implements SocialProvider {
'Content-Type': 'application/json',
},
body: JSON.stringify({
channel: postDetails[0].settings.channel,
channel,
}),
});
let lastId = '';
for (const post of postDetails) {
const { ts } = await (
await fetch(`https://slack.com/api/chat.postMessage`, {
method: 'POST',
// Post the main message
const { ts, channel: responseChannel } = await (
await fetch(`https://slack.com/api/chat.postMessage`, {
method: 'POST',
headers: {
Authorization: `Bearer ${accessToken}`,
'Content-Type': 'application/json',
},
body: JSON.stringify({
channel,
username: integration.name,
icon_url: integration.picture,
blocks: [
{
type: 'section',
text: {
type: 'mrkdwn',
text: firstPost.message,
},
},
...(firstPost.media?.length
? firstPost.media.map((m) => ({
type: 'image',
image_url: m.path,
alt_text: '',
}))
: []),
],
}),
})
).json();
// Get permalink for the message
const { permalink } = await (
await fetch(
`https://slack.com/api/chat.getPermalink?channel=${responseChannel}&message_ts=${ts}`,
{
method: 'GET',
headers: {
Authorization: `Bearer ${accessToken}`,
'Content-Type': 'application/json',
},
body: JSON.stringify({
channel: postDetails[0].settings.channel,
username: integration.name,
icon_url: integration.picture,
...(lastId ? { thread_ts: lastId } : {}),
blocks: [
{
type: 'section',
text: {
type: 'mrkdwn',
text: post.message,
},
}
)
).json();
return [
{
id: firstPost.id,
postId: ts,
releaseURL: permalink || '',
status: 'posted',
},
];
}
async comment(
id: string,
postId: string,
lastCommentId: string | undefined,
accessToken: string,
postDetails: PostDetails[],
integration: Integration
): Promise<PostResponse[]> {
const [commentPost] = postDetails;
const channel = commentPost.settings.channel;
const threadTs = lastCommentId || postId;
// Post the threaded reply
const { ts, channel: responseChannel } = await (
await fetch(`https://slack.com/api/chat.postMessage`, {
method: 'POST',
headers: {
Authorization: `Bearer ${accessToken}`,
'Content-Type': 'application/json',
},
body: JSON.stringify({
channel,
username: integration.name,
icon_url: integration.picture,
thread_ts: threadTs,
blocks: [
{
type: 'section',
text: {
type: 'mrkdwn',
text: commentPost.message,
},
...(post.media?.length
? post.media.map((m) => ({
type: 'image',
image_url: m.path,
alt_text: '',
}))
: []),
],
}),
})
).json();
},
...(commentPost.media?.length
? commentPost.media.map((m) => ({
type: 'image',
image_url: m.path,
alt_text: '',
}))
: []),
],
}),
})
).json();
lastId = ts;
}
// Get permalink for the comment
const { permalink } = await (
await fetch(
`https://slack.com/api/chat.getPermalink?channel=${responseChannel}&message_ts=${ts}`,
{
method: 'GET',
headers: {
Authorization: `Bearer ${accessToken}`,
},
}
)
).json();
return [];
return [
{
id: commentPost.id,
postId: ts,
releaseURL: permalink || '',
status: 'posted',
},
];
}
async changeProfilePicture(id: string, accessToken: string, url: string) {