Created
November 24, 2025 07:09
-
-
Save razikallayi/cd38b09edaea383c3336c21a57c8e02c to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/env node | |
| // Channel ID is on the the browser URL.: https://mycompany.slack.com/messages/MYCHANNELID/ | |
| // Pass it as a parameter: node ./delete-slack-messages.js CHANNEL_ID | |
| // CONFIGURATION ####################################################################################################### | |
| const token = 'xoxp-4006768287264...'; | |
| // Legacy tokens are no more supported. | |
| // Please create an app or use an existing Slack App | |
| // Add following scopes in your app from "OAuth & Permissions" | |
| // - channels:history | |
| // - groups:history | |
| // - im:history | |
| // - mpim:history | |
| // - chat:write | |
| // VALIDATION ########################################################################################################## | |
| if (token === 'SLACK TOKEN') { | |
| console.error('Token seems incorrect. Please open the file with an editor and modify the token variable.'); | |
| } | |
| let channel = ''; | |
| if (process.argv[0].indexOf('node') !== -1 && process.argv.length > 2) { | |
| channel = process.argv[2]; | |
| } else if (process.argv.length > 1) { | |
| channel = process.argv[1]; | |
| } else { | |
| console.log('Usage: node ./delete-slack-messages.js CHANNEL_ID'); | |
| process.exit(1); | |
| } | |
| // GLOBALS ############################################################################################################# | |
| const https = require('https') | |
| const historyApiUrl = `/api/conversations.history?channel=${channel}&count=1000&cursor=`; | |
| const deleteApiUrl = '/api/chat.delete'; | |
| const repliesApiUrl = `/api/conversations.replies?channel=${channel}&ts=` | |
| let delay = 300; // Delay between delete operations in milliseconds | |
| // --------------------------------------------------------------------------------------------------------------------- | |
| const sleep = delay => new Promise(r => setTimeout(r, delay)); | |
| const request = (path, data) => new Promise((resolve, reject) => { | |
| const options = { | |
| hostname: 'slack.com', | |
| port : 443, | |
| path : path, | |
| method : data ? 'POST' : 'GET', | |
| headers : { | |
| 'Authorization': `Bearer ${token}`, | |
| 'Content-Type' : 'application/json; charset=utf-8', | |
| 'Accept' : 'application/json' | |
| } | |
| }; | |
| const req = https.request(options, res => { | |
| let body = ''; | |
| res.on('data', chunk => (body += chunk)); | |
| res.on('end', () => resolve(JSON.parse(body))); | |
| }); | |
| req.on('error', reject); | |
| if (data) { | |
| req.write(JSON.stringify(data)); | |
| } | |
| req.end(); | |
| }); | |
| // --------------------------------------------------------------------------------------------------------------------- | |
| async function deleteMessages(threadTs, messages) { | |
| if (messages.length == 0) { | |
| return; | |
| } | |
| const message = messages.shift(); | |
| if (message.thread_ts !== threadTs) { | |
| await fetchAndDeleteMessages(message.thread_ts, ''); // Fetching replies, it will delete main message as well. | |
| } else { | |
| const response = await request(deleteApiUrl, {channel: channel, ts: message.ts}); | |
| if (response.ok === true) { | |
| console.log(message.ts + (threadTs ? ' reply' : '') + ' deleted!'); | |
| } else if (response.ok === false) { | |
| console.log(message.ts + ' could not be deleted! (' + response.error + ')'); | |
| if (response.error === 'ratelimited') { | |
| await sleep(1000); | |
| delay += 100; // If rate limited error caught then we need to increase delay. | |
| messages.unshift(message); | |
| } | |
| } | |
| } | |
| await sleep(delay); | |
| await deleteMessages(threadTs, messages); | |
| } | |
| // --------------------------------------------------------------------------------------------------------------------- | |
| async function fetchAndDeleteMessages(threadTs, cursor) { | |
| const response = await request((threadTs ? repliesApiUrl + threadTs + '&cursor=' : historyApiUrl) + cursor); | |
| if (!response.ok) { | |
| console.error(response.error); | |
| return; | |
| } | |
| if (!response.messages || response.messages.length === 0) { | |
| return; | |
| } | |
| await deleteMessages(threadTs, response.messages); | |
| if (response.has_more) { | |
| await fetchAndDeleteMessages(threadTs, response.response_metadata.next_cursor); | |
| } | |
| } | |
| // --------------------------------------------------------------------------------------------------------------------- | |
| fetchAndDeleteMessages(null, ''); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment