// Mattermost plugin module implements client behavior.

import { resolveTimerTimeoutMs } from "openclaw/plugin-sdk/number-runtime";

import { readResponseTextLimited } from "openclaw/plugin-sdk/provider-http";

import {

readProviderJsonResponse,

readResponseTextLimited,

} from "openclaw/plugin-sdk/provider-http";

import { readResponseWithLimit } from "openclaw/plugin-sdk/response-limit-runtime";

import { sleep } from "openclaw/plugin-sdk/runtime-env";

import {

fetchWithSsrFGuard,

import { z } from "zod";

const MATTERMOST_ERROR_BODY_LIMIT_BYTES = 8 * 1024;

// Mattermost REST control-plane JSON (posts, users, channels, file-upload

// results) stays well under a megabyte; cap successful JSON the same way the

// shared provider path is capped so an untrusted/self-hosted homeserver cannot

// stream an unbounded body into the runtime before parsing.

// Non-JSON success bodies are a rare fallback (the API is JSON-first); keep a

// generous text budget but still bound it instead of buffering the whole stream.

const MATTERMOST_TEXT_RESPONSE_LIMIT_BYTES = 64 * 1024;

const NULL_BODY_STATUSES = new Set([101, 204, 205, 304]);

export type MattermostFetch = (input: RequestInfo | URL, init?: RequestInit) => Promise<Response>;

return `${normalized}/api/v4${suffix}`;

}

async function readMattermostSuccessText(res: Response, path: string): Promise<string> {

const bytes = await readResponseWithLimit(res, MATTERMOST_TEXT_RESPONSE_LIMIT_BYTES, {

onOverflow: ({ maxBytes }) =>

new Error(`Mattermost API ${path}: text response exceeds ${maxBytes} bytes`),

});

return new TextDecoder().decode(bytes);

}

export async function readMattermostError(res: Response): Promise<string> {

const contentType = res.headers.get("content-type") ?? "";

if (!res.body) {

const contentType = res.headers.get("content-type") ?? "";

if (contentType.includes("application/json")) {

return (await res.json()) as T;

return await readProviderJsonResponse<T>(res, `Mattermost API ${path}`);

}

return (await res.text()) as T;

return (await readMattermostSuccessText(res, path)) as T;

};

return { baseUrl, apiBaseUrl, token, request, fetchImpl };

const detail = await readMattermostError(res);

throw new Error(`Mattermost API ${res.status} ${res.statusText}: ${detail || "unknown error"}`);

}

const data = (await res.json()) as { file_infos?: MattermostFileInfo[] };

const data = await readProviderJsonResponse<{ file_infos?: MattermostFileInfo[] }>(

res,

"Mattermost API /files",

);

const info = data.file_infos?.[0];

if (!info?.id) {

throw new Error("Mattermost file upload failed");