Krea 2

// npm install @krea-ai/sdk
import { Krea } from "@krea-ai/sdk";

const krea = new Krea({ apiKey: process.env.KREA_API_KEY });

const result = await krea.subscribe("image/krea/krea-2/medium", {
  input: {
    prompt: "a cinematic glass cabin beside a frozen lake at sunrise",
    aspect_ratio: "16:9",
    resolution: "1K",
  },
});

// https://gen.krea.ai/images/80ead844-02a6-467d-ba9e-fcd401bcb9a6.png
console.log(result.data?.urls[0]);

curl -X POST https://api.krea.ai/generate/image/krea/krea-2/medium \
  -H "Authorization: Bearer $KREA_API_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "prompt": "A cinematic product photo of a glass lamp on a marble table",
    "aspect_ratio": "4:5",
    "resolution": "1K",
    "creativity": "medium"
  }'

# Then poll the returned job_id
curl https://api.krea.ai/jobs/<job_id> \
  -H "Authorization: Bearer $KREA_API_TOKEN"

import os
import time
import requests

API_BASE = "https://api.krea.ai"
API_TOKEN = os.environ["KREA_API_TOKEN"]

def wait_for_job(job_id):
    while True:
        response = requests.get(
            f"{API_BASE}/jobs/{job_id}",
            headers={"Authorization": f"Bearer {API_TOKEN}"},
        )
        response.raise_for_status()
        job = response.json()
        if job["status"] == "completed":
            return job
        if job["status"] in ("failed", "cancelled"):
            raise RuntimeError(f"Job {job['status']}")
        time.sleep(3)

response = requests.post(
    f"{API_BASE}/generate/image/krea/krea-2/medium",
    headers={
        "Authorization": f"Bearer {API_TOKEN}",
        "Content-Type": "application/json",
    },
    json={
        "prompt": "A cinematic product photo of a glass lamp on a marble table",
        "aspect_ratio": "4:5",
        "resolution": "1K",
        "creativity": "medium",
    },
)
response.raise_for_status()
job = wait_for_job(response.json()["job_id"])
print(job["result"]["urls"])

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"net/http"
	"os"
	"time"
)

const apiBase = "https://api.krea.ai"

func waitForJob(client *http.Client, jobID, token string) (map[string]any, error) {
	for {
		req, _ := http.NewRequest("GET", fmt.Sprintf("%s/jobs/%s", apiBase, jobID), nil)
		req.Header.Set("Authorization", "Bearer "+token)
		resp, err := client.Do(req)
		if err != nil {
			return nil, err
		}
		var job map[string]any
		json.NewDecoder(resp.Body).Decode(&job)
		resp.Body.Close()
		switch job["status"] {
		case "completed":
			return job, nil
		case "failed", "cancelled":
			return nil, fmt.Errorf("job %s", job["status"])
		}
		time.Sleep(3 * time.Second)
	}
}

func main() {
	token := os.Getenv("KREA_API_TOKEN")
	client := &http.Client{}

	payload, _ := json.Marshal(map[string]any{
		"prompt":       "A cinematic product photo of a glass lamp on a marble table",
		"aspect_ratio": "4:5",
		"resolution":   "1K",
		"creativity":   "medium",
	})

	req, _ := http.NewRequest("POST", apiBase+"/generate/image/krea/krea-2/medium", bytes.NewBuffer(payload))
	req.Header.Set("Authorization", "Bearer "+token)
	req.Header.Set("Content-Type", "application/json")

	resp, _ := client.Do(req)
	var created map[string]any
	json.NewDecoder(resp.Body).Decode(&created)
	resp.Body.Close()

	job, err := waitForJob(client, created["job_id"].(string), token)
	if err != nil {
		panic(err)
	}
	fmt.Println(job["result"])
}