index.js

import "dotenv/config";

const BASE_URL = "https://api.everytime.kr";
const USER_AGENT =
  "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/143.0.0.0 Safari/537.36";
const BASE_INTERVAL = 600000; // 10분
const JITTER_MAX = 300000; // 최대 5분 랜덤 추가

function getRandomInterval() {
  const jitter = Math.floor(Math.random() * JITTER_MAX);
  return BASE_INTERVAL + jitter;
}

let lastSeenArticleId = null;

async function sendDiscordWebhook(content) {
  const webhookUrl = process.env.DISCORD_WEBHOOK_URL;

  if (!webhookUrl) {
    console.error("❌ DISCORD_WEBHOOK_URL 환경변수가 설정되지 않았습니다.");
    return;
  }

  try {
    const response = await fetch(webhookUrl, {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
      },
      body: JSON.stringify(content),
    });

    if (!response.ok) {
      console.error(`❌ Discord 웹훅 전송 실패: ${response.status}`);
    }
  } catch (error) {
    console.error("❌ Discord 웹훅 에러:", error.message);
  }
}

async function notifyError(error) {
  await sendDiscordWebhook({
    username: "에브리타임 크롤러",
    avatar_url: "https://everytime.kr/favicon.ico",
    embeds: [
      {
        title: "❌ 크롤러 에러 발생",
        description: error.message || String(error),
        color: 0xff0000,
        timestamp: new Date().toISOString(),
      },
    ],
  });
}

async function notifyNewArticles(newArticles, boardId) {
  const embeds = newArticles.map((article) => ({
    title: article.title.substring(0, 256),
    description: article.text.substring(0, 200) + "...",
    url: `https://everytime.kr/${boardId}/v/${article.id}`,
    color: 0x00d4aa,
    footer: {
      text: `📅 ${article.createdAt}`,
    },
  }));

  // 10개씩 청크로 나눠서 전송
  for (let i = 0; i < embeds.length; i += 10) {
    const chunk = embeds.slice(i, i + 10);
    const isFirst = i === 0;

    await sendDiscordWebhook({
      username: "에브리타임 크롤러",
      avatar_url: "https://everytime.kr/favicon.ico",
      content: isFirst ? `🔔 **새 글 ${newArticles.length}개 감지!**` : null,
      embeds: chunk,
    });

    if (i + 10 < embeds.length) {
      await new Promise((r) => setTimeout(r, 500));
    }
  }
}

async function fetchEverytime(endpoint, body) {
  const session = process.env.EVERYTIME_SESSION;

  if (!session) {
    throw new Error(
      "EVERYTIME_SESSION 환경변수가 설정되지 않았습니다. .env 파일을 확인하세요.",
    );
  }

  const response = await fetch(`${BASE_URL}${endpoint}`, {
    method: "POST",
    headers: {
      Accept: "application/json, text/javascript, */*; q=0.01",
      "Accept-Language": "ko-KR,ko;q=0.9,en-US;q=0.8,en;q=0.7",
      "Cache-Control": "no-cache",
      "Content-Type": "application/json",
      Origin: "https://everytime.kr",
      Pragma: "no-cache",
      Referer: "https://everytime.kr/",
      "Sec-CH-UA":
        '"Google Chrome";v="143", "Chromium";v="143", "Not A(Brand";v="24"',
      "Sec-CH-UA-Mobile": "?0",
      "Sec-CH-UA-Platform": '"macOS"',
      "Sec-Fetch-Dest": "empty",
      "Sec-Fetch-Mode": "cors",
      "Sec-Fetch-Site": "same-site",
      "User-Agent": USER_AGENT,
      Cookie: `etsid=${session}`,
    },
    body: JSON.stringify(body),
  });

  if (!response.ok) {
    throw new Error(`HTTP Error: ${response.status} ${response.statusText}`);
  }

  return response.json();
}

async function getBoardArticleList(boardId) {
  return fetchEverytime("/v2/find/board/article/list", {
    mode: "board",
    boardId: boardId,
    isBoardInfoRequired: false,
  });
}

async function checkNewArticles(boardId) {
  try {
    const data = await getBoardArticleList(boardId);

    if (data.status !== "success" || !data.result?.articles?.length) {
      console.log("⚠️ 게시글을 가져오지 못했습니다.");
      return;
    }

    const articles = data.result.articles;
    const latestArticleId = articles[0].id;

    // 첫 실행시 초기화
    if (lastSeenArticleId === null) {
      lastSeenArticleId = latestArticleId;
      console.log(`📌 초기 설정 - 마지막 글 ID: ${latestArticleId}`);
      console.log(`   제목: ${articles[0].title}\n`);
      return;
    }

    // 새 글 감지
    if (latestArticleId !== lastSeenArticleId) {
      const newArticles = articles.filter(
        (article) => article.id > lastSeenArticleId,
      );

      console.log(
        `\n🔔 새 글 ${newArticles.length}개 감지! [${new Date().toLocaleTimeString()}]`,
      );

      await notifyNewArticles(newArticles, boardId);

      lastSeenArticleId = latestArticleId;
    } else {
      process.stdout.write(
        `\r⏳ 새 글 대기 중... [${new Date().toLocaleTimeString()}]`,
      );
    }
  } catch (error) {
    console.error("\n❌ 에러 발생:", error.message);
    await notifyError(error);
  }
}

async function scheduleNext(boardId) {
  const interval = getRandomInterval();
  const minutes = (interval / 60000).toFixed(1);
  console.log(`\n⏰ 다음 크롤링: ${minutes}분 후`);

  setTimeout(async () => {
    await checkNewArticles(boardId);
    scheduleNext(boardId);
  }, interval);
}

async function main() {
  console.log("🚀 Everytime 크롤러 시작...\n");

  const boardId = 418901;

  await checkNewArticles(boardId);
  scheduleNext(boardId);
}

main();