Spaces:
Running
Running
File size: 3,155 Bytes
fb4d8fe | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 | import type { WebClient } from "@slack/web-api";
import { createSlackWebClient } from "./client.js";
export type SlackScopesResult = {
ok: boolean;
scopes?: string[];
source?: string;
error?: string;
};
type SlackScopesSource = "auth.scopes" | "apps.permissions.info";
function isRecord(value: unknown): value is Record<string, unknown> {
return Boolean(value) && typeof value === "object" && !Array.isArray(value);
}
function collectScopes(value: unknown, into: string[]) {
if (!value) {
return;
}
if (Array.isArray(value)) {
for (const entry of value) {
if (typeof entry === "string" && entry.trim()) {
into.push(entry.trim());
}
}
return;
}
if (typeof value === "string") {
const raw = value.trim();
if (!raw) {
return;
}
const parts = raw.split(/[,\s]+/).map((part) => part.trim());
for (const part of parts) {
if (part) {
into.push(part);
}
}
return;
}
if (!isRecord(value)) {
return;
}
for (const entry of Object.values(value)) {
if (Array.isArray(entry) || typeof entry === "string") {
collectScopes(entry, into);
}
}
}
function normalizeScopes(scopes: string[]) {
return Array.from(new Set(scopes.map((scope) => scope.trim()).filter(Boolean))).toSorted();
}
function extractScopes(payload: unknown): string[] {
if (!isRecord(payload)) {
return [];
}
const scopes: string[] = [];
collectScopes(payload.scopes, scopes);
collectScopes(payload.scope, scopes);
if (isRecord(payload.info)) {
collectScopes(payload.info.scopes, scopes);
collectScopes(payload.info.scope, scopes);
collectScopes((payload.info as { user_scopes?: unknown }).user_scopes, scopes);
collectScopes((payload.info as { bot_scopes?: unknown }).bot_scopes, scopes);
}
return normalizeScopes(scopes);
}
function readError(payload: unknown): string | undefined {
if (!isRecord(payload)) {
return undefined;
}
const error = payload.error;
return typeof error === "string" && error.trim() ? error.trim() : undefined;
}
async function callSlack(
client: WebClient,
method: SlackScopesSource,
): Promise<Record<string, unknown> | null> {
try {
const result = await client.apiCall(method);
return isRecord(result) ? result : null;
} catch (err) {
return {
ok: false,
error: err instanceof Error ? err.message : String(err),
};
}
}
export async function fetchSlackScopes(
token: string,
timeoutMs: number,
): Promise<SlackScopesResult> {
const client = createSlackWebClient(token, { timeout: timeoutMs });
const attempts: SlackScopesSource[] = ["auth.scopes", "apps.permissions.info"];
const errors: string[] = [];
for (const method of attempts) {
const result = await callSlack(client, method);
const scopes = extractScopes(result);
if (scopes.length > 0) {
return { ok: true, scopes, source: method };
}
const error = readError(result);
if (error) {
errors.push(`${method}: ${error}`);
}
}
return {
ok: false,
error: errors.length > 0 ? errors.join(" | ") : "no scopes returned",
};
}
|