openclaw-voc-skill/claude-code-voc-intelligence/mcp/src/providers/douyin-api.js

const DOUYIN_API_ROOT = 'https://server.fmode.cn/api/voc-social/douyin';
const DOUYIN_APP_BASE_URL = `${DOUYIN_API_ROOT}/app`;
const DOUYIN_SEARCH_PATH = 'search/fetch_general_search_v2';
const DOUYIN_VIDEO_COMMENTS_PATH = 'app/v3/fetch_video_comments';
const DOUYIN_VIDEO_REPLIES_PATH = 'app/v3/fetch_video_comment_replies';

function buildEndpointUrl(baseUrl, endpointPath) {
  return `${String(baseUrl || '').replace(/\/$/, '')}/${String(endpointPath || '').replace(/^\//, '')}`;
}

function buildUrl(baseUrl, path, query = {}) {
  const url = new URL(`${baseUrl.replace(/\/$/, '')}/${path.replace(/^\//, '')}`);
  Object.entries(query).forEach(([key, value]) => {
    if (value !== undefined && value !== null && value !== '') {
      url.searchParams.set(key, String(value));
    }
  });
  return url.toString();
}

function unwrapData(json) {
  if (!json || typeof json !== 'object') return {};
  return json.data?.data || json.data || json;
}

function pickBusinessStatus(json) {
  const topCode = Number(json?.code);
  if (Number.isFinite(topCode) && topCode !== 0 && topCode !== 200) {
    return topCode;
  }
  const nestedCode = Number(json?.data?.status_code);
  if (Number.isFinite(nestedCode) && nestedCode !== 0 && nestedCode !== 200) {
    return nestedCode;
  }
  return 0;
}

function redactSecret(value) {
  return String(value || '')
    .replace(/Bearer\s+[^"'\s,}]+/gi, 'Bearer [REDACTED]')
    .replace(/\bsk-[A-Za-z0-9_-]{6,}\b/g, 'sk-[REDACTED]')
    .replace(/\br:[A-Za-z0-9]{4,}\b/g, 'r:[REDACTED]')
    .replace(/("Authorization"\s*:\s*")([^"]+)(")/gi, '$1[REDACTED]$3')
    .replace(/("api[_-]?token"\s*:\s*")([^"]+)(")/gi, '$1[REDACTED]$3');
}

function isSuccessCode(json) {
  const topCode = Number(json?.code);
  if (Number.isFinite(topCode) && ![0, 200].includes(topCode)) {
    return false;
  }
  const statusCode = Number(json?.data?.status_code);
  if (Number.isFinite(statusCode) && ![0, 200].includes(statusCode)) {
    return false;
  }
  return true;
}

async function requestJson(url, token, { method = 'GET', body } = {}) {
  const response = await fetch(url, {
    method,
    headers: {
      Authorization: `Bearer ${token}`,
      Accept: 'application/json',
      ...(method === 'POST' ? { 'Content-Type': 'application/json' } : {})
    },
    body: body ? JSON.stringify(body) : undefined
  });
  const text = await response.text();
  let json;
  try {
    json = JSON.parse(text);
  } catch {
    json = undefined;
  }
  if (!response.ok || (json && !isSuccessCode(json))) {
    const message = json?.message || json?.msg || json?.data?.msg || json?.data?.message || text || `HTTP ${response.status}`;
    const error = new Error(redactSecret(message));
    error.httpStatus = pickBusinessStatus(json) || response.status || 500;
    error.responseBody = redactSecret(text);
    throw error;
  }
  return { json, data: unwrapData(json), rawText: text };
}

class DouyinApi {
  constructor(options = {}) {
    this.baseUrl = options.baseUrl || process.env.DOUYIN_API_BASE_URL || process.env.VOC_DOUYIN_API_BASE_URL || DOUYIN_API_ROOT;
    this.token = options.token;
  }

  async searchVideos({
    keyword,
    cursor = 0,
    sortType = '0',
    publishTime = '0',
    filterDuration = '0',
    contentType = '0',
    searchId = '',
    backtrace = ''
  }) {
    const url = buildEndpointUrl(this.baseUrl, DOUYIN_SEARCH_PATH);
    return requestJson(url, this.token, {
      method: 'POST',
      body: {
        keyword,
        cursor,
        sort_type: sortType,
        publish_time: publishTime,
        filter_duration: filterDuration,
        content_type: contentType,
        search_id: searchId,
        backtrace
      }
    });
  }

  async getVideoComments({ awemeId, cursor = 0, count = 20 }) {
    const url = new URL(buildEndpointUrl(this.baseUrl, DOUYIN_VIDEO_COMMENTS_PATH));
    url.searchParams.set('aweme_id', String(awemeId));
    url.searchParams.set('cursor', String(cursor));
    url.searchParams.set('count', String(count));
    return requestJson(url, this.token);
  }

  async getCommentReplies({ itemId, commentId, cursor = 0, count = 20 }) {
    const url = new URL(buildEndpointUrl(this.baseUrl, DOUYIN_VIDEO_REPLIES_PATH));
    url.searchParams.set('item_id', String(itemId));
    url.searchParams.set('comment_id', String(commentId));
    url.searchParams.set('cursor', String(cursor));
    url.searchParams.set('count', String(count));
    return requestJson(url, this.token);
  }
}

module.exports = {
  DOUYIN_API_ROOT,
  DOUYIN_APP_BASE_URL,
  DouyinApi
};