github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

fix: add retry logic with exponential backoff to Slack API requests

Browse Source
This commit is contained in:
Simon Larsen
2025-06-16 21:51:21 +01:00
parent 388a842da4
commit 8765bc07ed
1 changed files with 62 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
Common/Server/Utils/Workspace/Slack/Slack.ts
View File

@@ -60,6 +60,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for getting user info:");
@@ -122,6 +126,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/json",
},
{
retries: 3,
exponentialBackoff: true,
},
);
if (result instanceof HTTPErrorResponse) {
@@ -202,6 +210,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for archiving channel:");
@@ -245,6 +257,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for joining channel:");
@@ -301,6 +317,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for inviting user:");
@@ -449,6 +469,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for getting channel info:");
@@ -519,6 +543,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for getting all channels:");
@@ -779,6 +807,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/json",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for sending message:");
@@ -853,6 +885,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for creating channel:");
@@ -1233,6 +1269,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
if (response instanceof HTTPErrorResponse) {
@@ -1297,6 +1337,10 @@ export default class SlackUtil extends WorkspaceBase {
Authorization: `Bearer ${data.authToken}`,
["Content-Type"]: "application/x-www-form-urlencoded",
},
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for getting channel members:");
@@ -1373,17 +1417,25 @@ export default class SlackUtil extends WorkspaceBase {
logger.debug(data);
const apiResult: HTTPResponse<JSONObject> | HTTPErrorResponse | null =
await API.post(data.url, {
blocks: [
{
type: "section",
text: {
type: "mrkdwn",
text: `${data.text}`,
await API.post(
data.url,
{
blocks: [
{
type: "section",
text: {
type: "mrkdwn",
text: `${data.text}`,
},
},
},
],
});
],
},
undefined,
{
retries: 3,
exponentialBackoff: true,
},
);
logger.debug("Response from Slack API for sending message via webhook:");
logger.debug(apiResult);