import axios from 'axios';

const { data: result } = await axios.post('https://apick.app/rest/llm/chat', {
  model: 'meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo',
  system: '당신은 친절한 한국어 요리 도우미입니다. 재료와 조리 순서를 간결하게 구분해 답하세요.',
  content: '오늘 저녁 뭐 먹을지 추천해줘. 집에 계란·밥·김치만 있어.',
}, {
  headers: { 'CL_AUTH_KEY': process.env.API_KEY },
});

console.log(result.data.message.content);
            

import axios from 'axios';

async function askStream(history, userText, onChunk) {
  history.push({ role: 'user', content: userText });

  const res = await axios.post('https://apick.app/rest/llm/chat', {
    model: 'meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo',
    system: '당신은 친절한 한국어 상담 챗봇입니다. 핵심 답변과 다음 행동을 짧게 안내하세요.',
    messages: history,
    stream: true,
    compact: { strategy: 'sliding_window', window_pairs: 10 },
  }, {
    headers: { 'CL_AUTH_KEY': process.env.API_KEY },
    responseType: 'stream',
  });

  let buf = '', event = '', full = '', done = null;
  for await (const chunk of res.data) {
    buf += chunk.toString('utf8');
    const frames = buf.split('\n\n'); buf = frames.pop();
    for (const frame of frames) {
      for (const line of frame.split('\n')) {
        if (line.startsWith('event: ')) event = line.slice(7).trim();
        else if (line.startsWith('data: ')) {
          const payload = JSON.parse(line.slice(6));
          if (event === 'data') {
            const delta = payload.delta ?? payload.content ?? '';
            full += delta; onChunk(delta);
          } else if (event === 'done') done = payload;
        }
      }
    }
  }
  return { text: full, next: done?.compacted_messages || history, cost: done?.cost };
}
            

import axios from 'axios';

const API_BASE = 'https://apick.app/rest/llm/chat';

export class Chatbot {
  constructor({
    apiKey,
    model       = 'meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo',
    system      = '당신은 친절한 한국어 상담 챗봇입니다. 핵심 답변과 다음 행동을 짧게 안내하세요.',
    windowPairs = 10,
    maxTokens   = 512,
    speed       = 'fast',
  } = {}) {
    this.cfg = { apiKey, model, system, windowPairs, maxTokens, speed };
    this.history = [];
    this.totalCost = 0;
  }

  async _post(body, retryLeft = 1) {
    try {
      const { data: result } = await axios.post(API_BASE, body, {
        headers: { 'CL_AUTH_KEY': this.cfg.apiKey },
        timeout: 60000,
      });
      return result;
    } catch (e) {
      const status = e.response?.status;
      if (status === 400) throw new Error('요청 오류 (입력 확인 필요)');
      if (status === 402) throw new Error('포인트 부족 — 충전 필요');
      if (retryLeft > 0 && (!status || status >= 500)) {
        await new Promise(r => setTimeout(r, 500 + Math.random() * 500));
        return this._post(body, retryLeft - 1);
      }
      throw e;
    }
  }

  async ask(userText) {
    this.history.push({ role: 'user', content: userText });
    const result = await this._post({
      model: this.cfg.model,
      system: this.cfg.system,
      messages: this.history,
      compact: { strategy: 'sliding_window', window_pairs: this.cfg.windowPairs },
      max_tokens:  this.cfg.maxTokens,
      speed: this.cfg.speed,
    });
    this.history = result.data.compacted_messages;
    this.totalCost += result.api.cost || 0;
    return result.data.message.content;
  }

  reset() { this.history = []; }
  getCost() { return this.totalCost; }
}

// 사용 예시
const bot = new Chatbot({ apiKey: process.env.API_KEY });
console.log(await bot.ask('내 이름은 지훈이야.'));
console.log(await bot.ask('내 이름 기억해?'));
console.log('누적 비용:', bot.getCost(), '포인트');