Build media intelligence into your product.

export MOJITO_AI_BASE_URL="https://ai-dev.mojitofilms.de"
export MOJITO_CREDITS_KEY="mfk_live_replace_with_your_key"

curl -N "$MOJITO_AI_BASE_URL/api/v3/assistant/" \
  -H "Content-Type: application/json" \
  -H "X-Mojito-Credits-Key: $MOJITO_CREDITS_KEY" \
  -d '{
    "prompt": {
      "id": "mojito_assistant",
      "params": {
        "b2b": true,
        "session_id": "website-session-001",
        "action": "assistant",
        "user_message": "Recommend one warm science fiction movie for Friday night.",
        "user_details": {},
        "stream_protocol": "sse-json-v1"
      }
    },
    "system": {},
    "model": {},
    "module": "mojito"
  }'

const response = await fetch(`${baseUrl}/api/v3/assistant/`, {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "X-Mojito-Credits-Key": process.env.MOJITO_CREDITS_KEY
  },
  body: JSON.stringify({
    prompt: {
      id: "mojito_assistant",
      params: {
        b2b: true,
        user_id: "customer-user-123",
        session_id: "customer-user-123-thread-a",
        action: "assistant",
        user_message: "Give me two movies similar to Arrival.",
        stream_protocol: "sse-json-v1"
      }
    },
    system: {},
    model: {},
    module: "mojito"
  })
});

event: moji.event
id: 3
data: {"protocol":"sse-json-v1","sequence":3,"turn_id":"turn_123","type":"entity","subtype":"movie","source":"moji","provider":"tmdb","collection":"movies","index":0,"data":{"item":{"id":152601,"title":"Her","year":2013},"display_text":"Her (2013): warm, thoughtful science fiction with a human center."}}

event: moji.event
id: 1
data: {"protocol":"sse-json-v1","sequence":1,"turn_id":"turn_123","type":"text","subtype":"transcript","source":"user","data":{"content":"Recommend one warm science fiction movie for Friday night."}}

event: moji.event
id: 2
data: {"protocol":"sse-json-v1","sequence":2,"turn_id":"turn_123","type":"text","subtype":"assistant_message.delta","source":"moji","data":{"content":"If you want a softer Friday-night mood, start here."}}

event: moji.event
id: 3
data: {"protocol":"sse-json-v1","sequence":3,"turn_id":"turn_123","type":"text","subtype":"assistant_message.completed","source":"moji","data":{"content":"If you want a softer Friday-night mood, start here."}}

event: moji.event
id: 4
data: {"protocol":"sse-json-v1","sequence":4,"turn_id":"turn_123","type":"entity","subtype":"movie","source":"moji","provider":"tmdb","collection":"movies","index":0,"data":{"item":{"id":152601,"title":"Her","media_type":"movie"},"display_text":"Her (2013): warm, thoughtful science fiction with a human center."}}

event: moji.event
id: 5
data: {"protocol":"sse-json-v1","sequence":5,"turn_id":"turn_123","type":"entity","subtype":"mentioned_movie","source":"moji","provider":"tmdb","collection":"mentioned_movies","index":0,"data":{"item":{"id":329865,"title":"Arrival","media_type":"movie"}}}

event: moji.event
id: 6
data: {"protocol":"sse-json-v1","sequence":6,"turn_id":"turn_123","type":"entity","subtype":"cinema","source":"moji","provider":"mojito_internal","collection":"cinemas","index":0,"data":{"item":{"id":"cinema-6","name":"Cinema 6","address":"Example Street 1"},"display_text":"Cinema 6: a reliable nearby option."}}

event: moji.event
id: 7
data: {"protocol":"sse-json-v1","sequence":7,"turn_id":"turn_123","type":"entity","subtype":"showtime","source":"moji","provider":"movieglu","collection":"showings","index":0,"data":{"item":{"cinema_name":"Cinema 6","title":"Raiders of the Lost Ark","showtimes":[{"start_time":"18:00","end_time":"20:00"}]},"display_text":"Cinema 6: Raiders of the Lost Ark at 18:00."}}

event: moji.event
id: 8
data: {"protocol":"sse-json-v1","sequence":8,"turn_id":"turn_123","type":"entity","subtype":"trailer","source":"moji","provider":"youtube","collection":"trailers","index":0,"data":{"item":{"video_id":"abc123","title":"Her Official Trailer","url":"https://www.youtube.com/watch?v=abc123","thumbnail_url":"https://..."}}}

event: moji.event
id: 9
data: {"protocol":"sse-json-v1","sequence":9,"turn_id":"turn_123","type":"lifecycle","subtype":"response.completed","source":"system","data":{"finish_reason":"complete"}}

event: moji.event
id: 1
data: {"protocol":"sse-json-v1","sequence":1,"turn_id":"turn_456","type":"error","subtype":"upstream_unavailable","source":"system","data":{"code":"upstream_unavailable","message":"The upstream model failed.","recoverable":true,"details":{}}}

event: moji.event
id: 2
data: {"protocol":"sse-json-v1","sequence":2,"turn_id":"turn_456","type":"lifecycle","subtype":"response.completed","source":"system","data":{"finish_reason":"error"}}

import { createParser } from "eventsource-parser";

type MojiEvent = {
  type: string;
  subtype: string;
  data: Record<string, unknown>;
};

const reader = response.body?.getReader();
if (!reader) throw new Error("Missing SSE response body.");

let completed = false;
const decoder = new TextDecoder();
const parser = createParser({
  onEvent(message) {
    if (message.event !== "moji.event" || !message.data) return;
    completed = routeMojiEvent(JSON.parse(message.data)) || completed;
  }
});

while (!completed) {
  const { value, done } = await reader.read();
  if (done) break;
  parser.feed(decoder.decode(value));
}

await reader.cancel();

function routeMojiEvent(event: MojiEvent) {
  if (event.type === "error") {
    showSseError(event.data.message, {
      code: event.data.code,
      recoverable: event.data.recoverable
    });
    return false;
  }

  switch (`${event.type}:${event.subtype}`) {
    case "text:assistant_message.delta":
      appendAssistantText(event.data.content);
      break;
    case "entity:movie":
      renderMovieCard(event.data.item, event.data.display_text);
      break;
    case "entity:cinema":
      renderCinemaCard(event.data.item, event.data.display_text);
      break;
    case "entity:showtime":
      renderShowtimeList(event.data.item);
      break;
    case "entity:trailer":
      renderTrailer(event.data.item);
      break;
    case "lifecycle:response.completed":
      stopLoading(event.data.finish_reason);
      return true;
    default:
      logUnknownMojiEvent(event);
  }

  return false;
}

{
  "success": false,
  "error": {
    "code": "invalid_field",
    "message": "Unsupported stream_protocol.",
    "recoverable": false,
    "details": {
      "field": "stream_protocol",
      "supported": ["sse-json-v1"]
    }
  }
}

const ws = new WebSocket("wss://ai-dev.mojitofilms.de/api/v3/assistant/ws/voice");
ws.binaryType = "arraybuffer";

ws.onopen = () => {
  ws.send(JSON.stringify({
    b2b: true,
    session_id: "website-voice-session-001",
    payment_api_key: mojitoCreditsKey,
    stream_protocol: "ws-json-v1",
    user_language: "en",
    action: "assistant",
    user_details: {}
  }));

  // Text input: client-side STT already produced the user turn.
  ws.send(JSON.stringify({
    type: "text",
    text: "Recommend one tense but fun movie."
  }));

  // Audio input instead:
  // ws.send(audioArrayBuffer);
  // ws.send(JSON.stringify({ type: "end_of_audio" }));
};

ws.onmessage = (event) => {
  if (event.data instanceof ArrayBuffer) {
    const { metadata, pcm } = unpackMojiAudioFrame(event.data);
    routeMojiVoiceEvent(metadata);
    playAssistantVoice(pcm, metadata.data);
    return;
  }

  routeMojiVoiceEvent(JSON.parse(event.data));
};

function routeMojiVoiceEvent(event) {
  if (event.type === "error") {
    showVoiceError(event.data.message, {
      code: event.data.code,
      recoverable: event.data.recoverable
    });
    return;
  }

  switch (`${event.type}:${event.subtype}`) {
    case "lifecycle:prewarm.completed":
      markVoiceSocketReady(event.data.duration_ms);
      break;
    case "text:transcript":
      renderUserTranscript(event.data.content);
      break;
    case "text:assistant_message.delta":
      appendAssistantCaption(event.data.content);
      break;
    case "audio:assistant_phrase":
      updateMojiExpression(event.data.picture_id);
      break;
    case "entity:movie":
      renderMovieCard(event.data.item, event.data.display_text);
      break;
    case "entity:cinema":
      renderCinemaCard(event.data.item, event.data.display_text);
      break;
    case "entity:showtime":
      renderShowtimeList(event.data.item);
      break;
    case "entity:trailer":
      renderTrailer(event.data.item);
      break;
    case "lifecycle:response.completed":
      markConversationComplete(event.data.finish_reason);
      break;
    default:
      logUnknownMojiVoiceEvent(event);
      break;
  }
}

function unpackMojiAudioFrame(buffer) {
  const view = new DataView(buffer);
  const metadataLength = view.getUint32(0, true);
  const metadataBytes = new Uint8Array(buffer, 4, metadataLength);
  const metadata = JSON.parse(new TextDecoder().decode(metadataBytes));
  const pcm = buffer.slice(4 + metadataLength);
  return { metadata, pcm };
}

{
  "success": false,
  "error": {
    "code": "missing_field",
    "message": "B2B requests require either user_id or session_id.",
    "recoverable": false,
    "details": {}
  }
}

curl "https://pay-dev.mojitofilms.com/v1/webhooks/endpoints" \
  -H "Authorization: Bearer $PORTAL_ACCESS_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://example.com/webhooks/mojito",
    "event_subscriptions": ["payment.succeeded", "org.suspended"],
    "description": "Production webhook receiver"
  }'

import crypto from "node:crypto";

export function verifyMojitoSignature({
  rawBody,
  header,
  signingSecret,
  toleranceSeconds = 300
}: {
  rawBody: Buffer;
  header: string;
  signingSecret: string;
  toleranceSeconds?: number;
}) {
  const parts = Object.fromEntries(
    header
      .split(",")
      .map((part) => part.split("=", 2))
      .filter(([key, value]) => key && value)
      .map(([key, value]) => [key.trim(), value.trim()])
  );

  const timestamp = Number(parts.t);
  const signature = parts.v1;

  if (
    !Number.isInteger(timestamp) ||
    typeof signature !== "string" ||
    !/^[a-f0-9]{64}$/i.test(signature)
  ) {
    return false;
  }

  const ageSeconds = Math.abs(Date.now() / 1000 - timestamp);
  if (ageSeconds > toleranceSeconds) {
    return false;
  }

  const signedPayload = Buffer.concat([
    Buffer.from(String(timestamp)),
    Buffer.from("."),
    rawBody
  ]);
  const expected = crypto
    .createHmac("sha256", signingSecret)
    .update(signedPayload)
    .digest("hex");

  const received = Buffer.from(signature, "hex");
  const computed = Buffer.from(expected, "hex");

  return (
    received.length === computed.length &&
    crypto.timingSafeEqual(received, computed)
  );
}

curl "https://pay-dev.mojitofilms.com/v1/invoices?status=paid" \
  -H "Authorization: Bearer $PORTAL_ACCESS_TOKEN"