export async function run({ params, logger, api, connections }) {
const channels = [];
if (params.slackAccessToken) {
try {
const result = await slackClient.conversations.list({
token: params.slackAccessToken,
limit: 1000
});
for (const channel of result.channels) {
channels.push({ label: channel.name, value: channel.id });
}
} catch (error) {
logger.error({ error }, 'Error fetching Slack channels');
throw new Error(error);
}
}
channels.sort((a, b) => a.label.localeCompare(b.label));
return channels;
}
export async function run({ params, logger, api, connections }) {
const channels = [];
if (params.slackAccessToken) {
try {
const result = await slackClient.conversations.list({
token: params.slackAccessToken,
limit: 1000
});
for (const channel of result.channels) {
channels.push({ label: channel.name, value: channel.id });
}
} catch (error) {
logger.error({ error }, 'Error fetching Slack channels');
throw new Error(error);
}
}
channels.sort((a, b) => a.label.localeCompare(b.label));
return channels;
}