Call Your App over HTTP

curl -X POST "https://<your-app-hostname>" \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer $DYNAMIQ_ACCESS_KEY" \
  -d '{
    "input": {
      "question": "What can you do?"
    },
    "stream": false
  }'

import os
import requests
import json

endpoint = "https://<your-app-hostname>"
token = os.getenv("DYNAMIQ_ACCESS_KEY")  # Generate Access Key in the UI settings

headers = {
    'Content-Type': 'application/json',
    'Authorization': f'Bearer {token}',
}

# Payload: Modify input schema as per the input node schema defined in the UI
payload = {
    "input": {
        "question": "What can you do?"
    },
    "stream": False,
}

# Make a POST request to the deployed endpoint
response = requests.post(endpoint, json=payload,
                         headers=headers, stream=False)

if response.status_code == 200:
    try:
        data = response.json()
        print("Response:", json.dumps(data, indent=4))
    except json.JSONDecodeError as e:
        print(f"Failed to decode JSON response: {e}")
else:
    print(f"""Failed to connect to {endpoint}.
          Status code: {response.status_code}. Response: {response.text}""")

// HTTP Client without Streaming
const endpoint = "https://<your-app-hostname>";
const token = process.env.DYNAMIQ_ACCESS_KEY;  // Access key should be securely stored

const headers = {
  'Content-Type': 'application/json',
  'Authorization': `Bearer ${token}`
};

// Payload: Modify input schema as per the input node schema defined in the UI
const payload = {
  "input": {
    "question": "What can you do?"
  },
  "stream": false
};

async function fetchWithoutStreaming() {
  const response = await fetch(endpoint, {
    method: 'POST',
    headers: headers,
    body: JSON.stringify(payload)
  });

  if (!response.ok) {
    throw new Error(`Failed to connect to ${endpoint}. Status code: ${response.status}. Response: ${await response.text()}`);
  }

  const data = await response.json();
  console.log("Response:", JSON.stringify(data, null, 4));
}

fetchWithoutStreaming();

curl -N -X POST "https://<your-app-hostname>" \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer $DYNAMIQ_ACCESS_KEY" \
  -d '{
    "input": {
      "question": "What can you do?"
    },
    "stream": true
  }'

import os
import requests
import json

endpoint = "https://<your-app-hostname>"
token = os.getenv("DYNAMIQ_ACCESS_KEY")  # Generate Access Key in the UI settings

streaming_event = "data"  # Event name configured in the UI

headers = {
    'Content-Type': 'application/json',
    'Authorization': f'Bearer {token}',
}

# Payload: Modify input schema as per the input node schema defined in the UI
payload = {
    "input": {
        "question": "What can you do?"
    },
    "stream": True,
}

# Make a POST request to the deployed endpoint
response = requests.post(endpoint, json=payload,
                         headers=headers, stream=True)

if response.status_code == 200:

    # consume server-sent events (SSE)
    for line in response.iter_lines(decode_unicode=True):
        if line.startswith("data:"):
            data = line[len("data:"):].strip()
            try:
                json_data = json.loads(data)
                if json_data.get("event") == streaming_event:
                    content = json_data.get("data", {}).get("choices", [{}])[0].get("delta", {}).get("content")
                    if content:
                        print(content, end='')
            except json.JSONDecodeError as e:
                print(f"Invalid JSON format: {data} - Error: {e}")

else:
    print(f"""Failed to connect to {endpoint}.
          Status code: {response.status_code}. Response: {response.text}""")

// HTTP Client with Server-Sent Events (Streaming)
const endpoint = "https://<your-app-hostname>";
const token = process.env.DYNAMIQ_ACCESS_KEY;  // Access key should be securely stored

const streamingEvent = "data";  // Event name configured in the UI

const headers = {
  'Content-Type': 'application/json',
  'Authorization': `Bearer ${token}`
};

// Payload: Modify input schema as per the input node schema defined in the UI
const payload = {
  "input": {
    "question": "What can you do?"
  },
  "stream": true
};

async function fetchWithStreaming() {
  const response = await fetch(endpoint, {
    method: 'POST',
    headers: headers,
    body: JSON.stringify(payload)
  });

  if (!response.ok) {
    throw new Error(`Failed to connect to ${endpoint}. Status code: ${response.status}. Response: ${await response.text()}`);
  }

  const reader = response.body!.getReader();
  const decoder = new TextDecoder();
  let buffer = '';

  while (true) {
    const { done, value } = await reader.read();
    if (done) break;

    buffer += decoder.decode(value, { stream: true });

    // Process complete SSE lines
    const lines = buffer.split('\n');
    buffer = lines.pop() || '';  // Keep the last incomplete line in buffer

    for (const line of lines) {
      if (line.startsWith('data:')) {
        const data = line.substring(5).trim();
        const jsonData = JSON.parse(data);
        if (jsonData.event === streamingEvent) {
          const content = jsonData.data?.choices?.[0]?.delta?.content;
          if (content) {
            console.log(content);
          }
        }
      }
    }
  }
}

fetchWithStreaming();