// 尝试不同的钉钉旧版 API endpoint
const axios = require('axios');

const ACCESS_TOKEN_URL = "https://oapi.dingtalk.com/gettoken";
const UPLOAD_URL = "https://oapi.dingtalk.com/media/upload";
const APP_KEY = "ding4ursdp0l2giat4bj";
const APP_SECRET = "J0gBicjKiIHoKla7WfKKhRs1Tv8L6Xd5UhW3EVQByF16G7Vn7UUcRhP6u-PBCQNo";
const OPEN_CONVERSATION_ID = "cidcjYshXVtKck5LfOO9AqOJg==";
const ROBOT_CODE = "ding4ursdp0l2giat4bj";
const IMAGE_PATH = "C:/Users/ALC/.openclaw/workspace/yahoo_japan_screenshot.jpg";

async function getAccessToken() {
  const response = await axios.get(ACCESS_TOKEN_URL, {
    params: {
      appkey: APP_KEY,
      appsecret: APP_SECRET
    }
  });
  return response.data.access_token;
}

async function uploadMedia(accessToken, filePath, type) {
  const FormData = require('form-data');
  const form = new FormData();
  form.append('media', require('fs').createReadStream(filePath));
  form.append('type', type);

  const response = await axios.post(`${UPLOAD_URL}?access_token=${accessToken}`, form, {
    headers: form.getHeaders()
  });

  return response.data.media_id;
}

// 尝试不同的发送 API
async function trySend(accessToken, url, body) {
  try {
    console.log(`\n尝试: ${url}`);
    console.log(`Body: ${JSON.stringify(body, null, 2)}`);

    const response = await axios.post(url, body);

    console.log(`响应: ${JSON.stringify(response.data, null, 2)}`);

    if (response.data.errcode === 0) {
      console.log('✅ 成功！');
      return true;
    } else {
      console.log(`❌ 失败: ${response.data.errmsg}`);
      return false;
    }
  } catch (err) {
    console.log(`❌ 异常: ${err.response?.data?.errmsg || err.message}`);
    return false;
  }
}

async function main() {
  try {
    const accessToken = await getAccessToken();
    console.log('✓ Access Token 获取成功\n');

    const media_id = await uploadMedia(accessToken, IMAGE_PATH, "image");
    console.log('✓ 媒体上传成功\n');

    // 测试不同的 API endpoint
    const testCases = [
      {
        url: `https://oapi.dingtalk.com/message/send_to_conversation?access_token=${accessToken}`,
        body: {
          msg: {
            msgtype: "image",
            image: { media_id: media_id }
          },
          sender: ROBOT_CODE,
          cid: OPEN_CONVERSATION_ID
        }
      },
      {
        url: `https://oapi.dingtalk.com/message/sendgroupmessage?access_token=${accessToken}`,
        body: {
          msg: {
            msgtype: "image",
            image: { media_id: media_id }
          },
          chatid: OPEN_CONVERSATION_ID
        }
      },
      {
        url: `https://oapi.dingtalk.com/robot/send?access_token=${accessToken}`,
        body: {
          msg: {
            msgtype: "image",
            image: { media_id: media_id }
          },
          webhook: ROBOT_CODE
        }
      },
      {
        url: `https://oapi.dingtalk.com/topapi/message/corpconversation/send?access_token=${accessToken}`,
        body: {
          msg: {
            msgtype: "image",
            image: { media_id: media_id }
          },
          agent_id: ROBOT_CODE,
          userid_list: OPEN_CONVERSATION_ID,
          msg: {
            msgtype: "image",
            image: { media_id: media_id }
          }
        }
      }
    ];

    for (const testCase of testCases) {
      await trySend(accessToken, testCase.url, testCase.body);
      console.log('---');
    }
  } catch (err) {
    console.error('错误:', err.message);
    process.exit(1);
  }
}

main();