FlowAI API - OpenAI-kompatibel

curl -X POST "https://creativeskyline.de/api/flowai/v1/chat/completions" \
  -H "Authorization: Bearer YOUR_API_TOKEN" \
  -H "Accept: application/json" \
  -H "Content-Type: application/json" \
  -d '{"model": "value", "messages": [], "stream": true, "temperature": 0, "max_tokens": 0}'

use Illuminate\Support\Facades\Http;

$response = Http::withToken('YOUR_API_TOKEN')
    ->post('https://creativeskyline.de/api/flowai/v1/chat/completions', [
        'model' => 'value',
        'messages' => [],
        'stream' => true,
        'temperature' => 0,
        'max_tokens' => 0,
    ]);

$data = $response->json();

const response = await fetch('https://creativeskyline.de/api/flowai/v1/chat/completions', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer YOUR_API_TOKEN',
    'Accept': 'application/json',
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    model: 'value',
    messages: [],
    stream: true,
    temperature: 0,
    max_tokens: 0,
  }),
});

const data = await response.json();

import requests

headers = {
    'Authorization': 'Bearer YOUR_API_TOKEN',
    'Accept': 'application/json',
}

payload = {
    'model': 'value',
    'messages': [],
    'stream': True,
    'temperature': 0,
    'max_tokens': 0,
}

response = requests.post(
    'https://creativeskyline.de/api/flowai/v1/chat/completions',
    headers=headers,
    json=payload,
)

data = response.json()

# Das -N-Flag deaktiviert cURLs internen Zeilenpuffer, sodass SSE-Frames live durchlaufen
curl -N -X POST "https://creativeskyline.de/api/flowai/v1/chat/completions" \
  -H "Authorization: Bearer pk_dein_api_key" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "claude",
    "stream": true,
    "messages": [
      { "role": "user", "content": "Erkläre Server-Sent Events in zwei Sätzen." }
    ]
  }'

// PHP Streaming mit HTTP-Stream-Wrapper
$context = stream_context_create([
    'http' => [
        'method' => 'POST',
        'header' => implode("\r\n", [
            'Authorization: Bearer ' . getenv('FLOWAI_API_KEY'),
            'Content-Type: application/json',
            'Accept: text/event-stream',
        ]),
        'content' => json_encode([
            'model' => 'claude',
            'stream' => true,
            'messages' => [['role' => 'user', 'content' => 'Erkläre SSE in zwei Sätzen.']],
        ]),
    ],
]);

$stream = fopen('https://creativeskyline.de/api/flowai/v1/chat/completions', 'r', false, $context);

while (!$feof($stream)) {
    $line = fgets($stream);
    if (str_starts_with($line, 'data: ')) {
        $data = trim(substr($line, 6));
        if ($data === '[DONE]') break;
        $chunk = json_decode($data, true);
        echo $chunk['choices'][0]['delta']['content'] ?? '';
    }
}

fclose($stream);

import OpenAI from "openai";

const client = new OpenAI({
  apiKey: process.env.FLOWAI_API_KEY,
  baseURL: "https://creativeskyline.de/api/flowai/v1",
});

const stream = await client.chat.completions.create({
  model: "claude",
  stream: true,
  messages: [
    { role: "user", content: "Erkläre Server-Sent Events in zwei Sätzen." },
  ],
});

for await (const chunk of stream) {
  process.stdout.write(chunk.choices[0]?.delta?.content ?? "");
}

// Oder mit nativer EventSource (Browser):
// const source = new EventSource('https://creativeskyline.de/api/flowai/v1/chat/completions');
// source.onmessage = (e) => {
//   if (e.data === '[DONE]') { source.close(); return; }
//   const chunk = JSON.parse(e.data);
//   console.log(chunk.choices[0]?.delta?.content ?? '');
// };

from openai import OpenAI

client = OpenAI(
    api_key="pk_dein_api_key",
    base_url="https://creativeskyline.de/api/flowai/v1",
)

# openai-SDK kümmert sich automatisch um SSE-Parsing
with client.chat.completions.stream(
    model="claude",
    messages=[{"role": "user", "content": "Erkläre SSE in zwei Sätzen."}],
) as stream:
    for text in stream.text_stream:
        print(text, end="", flush=True)

# Alternativ mit Requests (manuelles SSE-Parsing)
# import requests
# resp = requests.post(
#     'https://creativeskyline.de/api/flowai/v1/chat/completions',
#     headers={'Authorization': 'Bearer pk_...', 'Accept': 'text/event-stream'},
#     json={'model': 'claude', 'stream': True, 'messages': [...]},
#     stream=True,
# )
# for line in resp.iter_lines():
#     if line.startswith(b'data: '):
#         data = line[6:]
#         if data == b'[DONE]': break
#         chunk = json.loads(data)
#         print(chunk['choices'][0]['delta'].get('content', ''), end='', flush=True)