[실습 가이드] 블로그글쓰기봇 (카톡블로그자동화 Step2)

const bot = BotManager.getCurrentBot();
const URL_REGEX = /(https?:\/\/[^\s]+)/g;

// ✅ 서버 주소 (구글 클라우드 외부 IP)
const API_BASE = "http://35.226.157.200:8000"; 

/* ========= 대화 기억 저장소 (멀티턴) ========= */
const KASYA_MEMORY = {};   
const MAX_TURNS = 10;      
const MEMORY_TIME = 30 * 60 * 1000; 

/* ========= 유틸리티 함수 ========= */
function toStringSafe(val) {
  if (val === undefined || val === null) return '';
  try { return String(val); } catch (_) { return ''; }
}
function nowMs() { return java.lang.System.currentTimeMillis(); }

/* ========= HTTP 통신 (타임아웃 설정) ========= */
function httpGet(url) {
  try {
    var conn = new java.net.URL(url).openConnection();
    conn.setRequestMethod("GET");
    conn.setRequestProperty("Accept", "application/json");
    conn.setConnectTimeout(10000);
    conn.setReadTimeout(60000); 
    conn.connect();
    if (conn.getResponseCode() !== 200) return null;
    var br = new java.io.BufferedReader(new java.io.InputStreamReader(conn.getInputStream(), "UTF-8"));
    var sb = new java.lang.StringBuilder();
    var line;
    while ((line = br.readLine()) !== null) sb.append(line);
    br.close();
    return toStringSafe(sb.toString());
  } catch (err) { return null; }
}

function httpPostJson(url, obj) {
  var conn = null;
  try {
    var payload = JSON.stringify(obj);
    conn = new java.net.URL(url).openConnection();
    conn.setDoOutput(true);
    conn.setRequestMethod("POST");
    conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
    conn.setConnectTimeout(10000);
    conn.setReadTimeout(60000);
    conn.connect();
    var os = conn.getOutputStream();
    var writer = new java.io.OutputStreamWriter(os, "UTF-8");
    writer.write(payload);
    writer.flush(); writer.close();
    if (conn.getResponseCode() !== 200) return null;
    var br = new java.io.BufferedReader(new java.io.InputStreamReader(conn.getInputStream(), "UTF-8"));
    var sb = new java.lang.StringBuilder(); 
    var line;
    while ((line = br.readLine()) !== null) sb.append(line);
    br.close();
    return String(sb.toString());
  } catch (err) { return null; } finally { try{if(conn)conn.disconnect();}catch(_){} }
}

function send(msg, text) {
  App.runOnUiThread(function() { msg.reply(toStringSafe(text)); }, function(_) {});
}

/* ========= 핵심 기능: 도깨비 멀티턴 ========= */
function processKasyaMulti(msg, room, question) {
  var mem = KASYA_MEMORY[room];
  var now = nowMs();
  
  if (!mem || (now - mem.lastTime > MEMORY_TIME) || question.indexOf("초기화") !== -1 || question.indexOf("잊어") !== -1) {
    mem = { history: [], lastTime: now };
    if (question.indexOf("초기화") !== -1 || question.indexOf("잊어") !== -1) {
      KASYA_MEMORY[room] = mem;
      send(msg, "후후, 지난 시나리오는 모두 잊었습니다.");
      return;
    }
  }

  mem.history.push({ role: "user", content: question });
  mem.lastTime = now;

  try {
    var resMulti = httpPostJson(API_BASE + "/kasya_multi", { history: mem.history });
    var json = JSON.parse(resMulti);
    var answer = json.answer || "";
    
    if (answer) {
      send(msg, answer);
      mem.history.push({ role: "assistant", content: answer });
      if (mem.history.length > MAX_TURNS) mem.history = mem.history.slice(-MAX_TURNS);
      KASYA_MEMORY[room] = mem;
    }
  } catch (e) { send(msg, "도깨비 통신 장애 발생 ⚡"); mem.history.pop(); }
}

/* ========= 채팅방 요약 (서기 모드) ========= */
var CHAT_LOG = {};
function pushChat(room, sender, text) {
  if (text.startsWith("@") || text.startsWith("카스야")) return;
  var arr = CHAT_LOG[room] || (CHAT_LOG[room] = []);
  arr.push({ t: nowMs(), sender: sender, text: text });
  if (arr.length > 1000) arr.shift();
}

function summarizeRoom(msg, room) {
  var arr = CHAT_LOG[room] || [];
  var cutoff = nowMs() - 86400000; // 24시간
  var recent = arr.filter(function(x) { return x.t >= cutoff; });
  if (!recent.length) return send(msg, "기록된 대화가 없습니다.");
  
  var transcript = recent.map(function(x) { return x.sender + ": " + x.text; }).join("\n");
  var resRoom = httpPostJson(API_BASE + "/summarize_text", { room: room, window: "24h", transcript: transcript });
  if(resRoom) send(msg, "🕰️ [기록 열람]\n\n" + JSON.parse(resRoom).summary);
}

/* ========= URL 처리 ========= */
function processUrl(msg, url) {
  setTimeout(function() {
    if (/blog\.naver\.com/.test(url)) {
      send(msg, "👹 도깨비가 설화(블로그)를 심사 중입니다...");
      var resBlog = httpGet(API_BASE + "/analyze_blog?url=" + encodeURIComponent(url));
      if(resBlog) send(msg, JSON.parse(resBlog).report);
    } else {
      var resSummary = httpGet(API_BASE + "/summarize?url=" + encodeURIComponent(url));
      if(resSummary) {
        var jsonSum = JSON.parse(resSummary);
        send(msg, "📜 [히든 시나리오]\n**" + jsonSum.title + "**\n\n" + jsonSum.summary);
      }
    }
  }, 1000);
}

/* ========= 메인 리스너 ========= */
bot.addListener(Event.MESSAGE, function (msg) {
  try {
    var content = msg.content.trim();
    var room = msg.room;
    var sender = msg.author.name;

    // [중요] 봇 자신이 보낸 메시지 및 자기 이름 필터링 (무한루프 방지)
    // 아래 "카스봇" 부분을 실제 부계정 프로필 이름으로 꼭 수정하세요!
    if (sender === "카스봇") return; 

    // 0. 대화 로그 저장
    pushChat(room, sender, content);

    // 1. [명령어] 키워드 글쓰기
    if (content.startsWith("카스야 키워드")) {
      var keyword = content.replace("카스야 키워드", "").trim();
      if (!keyword) return send(msg, "키워드를 입력하세요.");
      
      send(msg, "🤖 AI 작가가 '" + keyword + "' 집필 중... (15초 소요)");
      var resKeyword = httpPostJson(API_BASE + "/relay/auto_blog", { keyword: keyword });
      if(resKeyword) {
          var jsonKey = JSON.parse(resKeyword);
          if(jsonKey.status==="ok") send(msg, "✅ 전송 완료!\n제목: " + jsonKey.generated_title + "\n\n집 PC가 곧 처리합니다.");
          else send(msg, "❌ 실패: " + jsonKey.message);
      }
      return;
    }

    // 2. [명령어] 원격 글쓰기
    if (content.startsWith("카스야 원격")) {
      var raw = content.replace("카스야 원격", "").trim();
      var idx = raw.indexOf("/");
      if (idx === -1) return send(msg, "형식: 카스야 원격 제목 / 본문");
      
      send(msg, "📨 중계소로 원고 발송 중...");
      var resRemote = httpPostJson(API_BASE + "/relay/send", { type: "blog", data: { title: raw.substring(0, idx).trim(), content: raw.substring(idx+1).trim() } });
      if(resRemote) send(msg, "✅ 중계소 도착 완료!");
      return;
    }

    // 3. [명령어] 도깨비 대화
    if (content.startsWith("카스야")) {
      processKasyaMulti(msg, room, content.replace("카스야", "").trim());
      return;
    }

    // 4. [명령어] 방 요약
    if (content === "@요약") {
      summarizeRoom(msg, room);
      return;
    }

    // 5. 링크 감지
    var urls = content.match(URL_REGEX);
    if (urls) processUrl(msg, urls[0]);

  } catch (e) {}
});

// [변경 전]
if (content.startsWith("카스야 키워드")) {
  var keyword = content.replace("카스야 키워드", "").trim();

// 👇 [변경 후] 두 곳을 똑같이 바꿔야 합니다!
if (content.startsWith("블로그 써줘")) { // 1. 감지할 단어
  var keyword = content.replace("블로그 써줘", "").trim(); // 2. 내용만 남기기 위해 지울 단어

// [변경 전]
if (content.startsWith("카스야 원격")) {
  var raw = content.replace("카스야 원격", "").trim();

// 👇 [변경 후]
if (content.startsWith("전송")) { 
  var raw = content.replace("전송", "").trim();

// [변경 전]
if (content.startsWith("카스야")) {
  processKasyaMulti(msg, room, content.replace("카스야", "").trim());

// 👇 [변경 후]
if (content.startsWith("자비스")) {
  processKasyaMulti(msg, room, content.replace("자비스", "").trim());

/* ========= 채팅방 요약 (서기 모드) ========= */
function pushChat(room, sender, text) {
  // [변경 전] "카스야"로 시작하는 말은 기록 안 함
  if (text.startsWith("@") || text.startsWith("카스야")) return;

  // 👇 [변경 후] "자비스"로 시작하는 말은 기록 안 함
  if (text.startsWith("@") || text.startsWith("자비스")) return;
  
  // ... (나머지 코드)
}