// node-streaming.js require("dotenv").config(); const RAHYANA_API_KEY = process.env.RAHYANA_API_KEY; const BASE_URL = "https://rahyana.ir/api/v1"; async function streamRahyanaResponse(userMessage) { const response = await fetch(`${BASE_URL}/chat/completions`, { method: "POST", headers: { Authorization: `Bearer ${RAHYANA_API_KEY}`, "Content-Type": "application/json", }, body: JSON.stringify({ model: "gpt-4o-mini", messages: [ { role: "system", content: "شما یک دستیار مفید و دوستانه هستید." }, { role: "user", content: userMessage }, ], stream: true, }), }); if (!response.ok) throw new Error(await response.text()); const reader = response.body.getReader(); const decoder = new TextDecoder("utf-8"); let buffer = ""; while (true) { const { done, value } = await reader.read(); if (done) break; buffer += decoder.decode(value, { stream: true }); const lines = buffer.split("\n"); buffer = lines.pop(); for (const line of lines) { if (!line.startsWith("data:")) continue; const jsonStr = line.slice(5).trim(); if (jsonStr === "[DONE]") return; try { const chunk = JSON.parse(jsonStr); const content = chunk.choices?.[0]?.delta?.content; if (content) process.stdout.write(content); } catch {} } } process.stdout.write("\n"); } streamRahyanaResponse("یک داستان کوتاه درباره یک گربه کنجکاو بنویس.");