How to Integrate Replit with Kentico

1import os
2import requests
3
4PROJECT_ID = os.environ["KONTENT_PROJECT_ID"]
5DELIVERY_KEY = os.environ["KONTENT_DELIVERY_API_KEY"]
6MANAGEMENT_KEY = os.environ["KONTENT_MANAGEMENT_API_KEY"]
7
8DELIVERY_BASE = f"https://deliver.kontent.ai/{PROJECT_ID}"
9MANAGEMENT_BASE = f"https://manage.kontent.ai/v2/projects/{PROJECT_ID}"
10
11DELIVERY_HEADERS = {"Authorization": f"Bearer {DELIVERY_KEY}"}
12MGMT_HEADERS = {
13    "Authorization": f"Bearer {MANAGEMENT_KEY}",
14    "Content-Type": "application/json"
15}
16
17
18def get_content_items(content_type: str = None, limit: int = 10,
19                      order_by: str = None) -> dict:
20    """Fetch content items from the Delivery API."""
21    params = {"limit": limit, "depth": 1}
22    if content_type:
23        params["system.type"] = content_type
24    if order_by:
25        params["order"] = order_by
26    resp = requests.get(
27        f"{DELIVERY_BASE}/items",
28        params=params,
29        headers=DELIVERY_HEADERS
30    )
31    resp.raise_for_status()
32    return resp.json()
33
34
35def get_content_item_by_codename(codename: str) -> dict:
36    """Fetch a single content item by its codename."""
37    resp = requests.get(
38        f"{DELIVERY_BASE}/items/{codename}",
39        headers=DELIVERY_HEADERS
40    )
41    resp.raise_for_status()
42    return resp.json()
43
44
45def create_content_item(type_codename: str, item_name: str) -> dict:
46    """Create a new content item of a given type via the Management API."""
47    payload = {
48        "name": item_name,
49        "type": {"codename": type_codename}
50    }
51    resp = requests.post(
52        f"{MANAGEMENT_BASE}/items",
53        json=payload,
54        headers=MGMT_HEADERS
55    )
56    resp.raise_for_status()
57    return resp.json()
58
59
60def upsert_language_variant(item_id: str, language: str, elements: list) -> dict:
61    """Upsert a language variant with element values.
62    elements: list of dicts like [{"element": {"codename": "title"}, "value": "Hello"}]
63    """
64    resp = requests.put(
65        f"{MANAGEMENT_BASE}/items/{item_id}/variants/{language}",
66        json={"elements": elements},
67        headers=MGMT_HEADERS
68    )
69    resp.raise_for_status()
70    return resp.json()
71
72
73if __name__ == "__main__":
74    # Fetch latest articles
75    data = get_content_items(content_type="article", limit=5,
76                             order_by="elements.pub_date[desc]")
77    print(f"Found {len(data.get('items', []))} articles:")
78    for item in data.get("items", []):
79        title = item["elements"].get("title", {}).get("value", "(no title)")
80        print(f"  {item['system']['codename']}: {title}")

1const express = require('express');
2const axios = require('axios');
3
4const app = express();
5app.use(express.json());
6
7const PROJECT_ID = process.env.KONTENT_PROJECT_ID;
8const DELIVERY_KEY = process.env.KONTENT_DELIVERY_API_KEY;
9const MANAGEMENT_KEY = process.env.KONTENT_MANAGEMENT_API_KEY;
10
11const DELIVERY_BASE = `https://deliver.kontent.ai/${PROJECT_ID}`;
12const MANAGEMENT_BASE = `https://manage.kontent.ai/v2/projects/${PROJECT_ID}`;
13
14const deliveryHeaders = { Authorization: `Bearer ${DELIVERY_KEY}` };
15const managementHeaders = {
16  Authorization: `Bearer ${MANAGEMENT_KEY}`,
17  'Content-Type': 'application/json'
18};
19
20// List items by content type
21app.get('/content/:type', async (req, res) => {
22  const { type } = req.params;
23  const { limit = 10, order } = req.query;
24  try {
25    const params = { 'system.type': type, limit, depth: 1 };
26    if (order) params.order = order;
27    const { data } = await axios.get(`${DELIVERY_BASE}/items`, {
28      params,
29      headers: deliveryHeaders
30    });
31    res.json({
32      total: data.pagination?.total_count,
33      items: data.items.map(item => ({
34        id: item.system.id,
35        codename: item.system.codename,
36        name: item.system.name,
37        last_modified: item.system.last_modified,
38        elements: item.elements
39      }))
40    });
41  } catch (err) {
42    const status = err.response?.status || 500;
43    res.status(status).json({ error: err.response?.data || err.message });
44  }
45});
46
47// Get a single item by codename
48app.get('/content/item/:codename', async (req, res) => {
49  try {
50    const { data } = await axios.get(
51      `${DELIVERY_BASE}/items/${req.params.codename}`,
52      { headers: deliveryHeaders }
53    );
54    res.json(data.item);
55  } catch (err) {
56    const status = err.response?.status || 500;
57    res.status(status).json({ error: err.response?.data || err.message });
58  }
59});
60
61// Create a new content item (Management API)
62app.post('/content/create', async (req, res) => {
63  const { name, type_codename } = req.body;
64  if (!name || !type_codename) {
65    return res.status(400).json({ error: 'name and type_codename required' });
66  }
67  try {
68    const { data } = await axios.post(
69      `${MANAGEMENT_BASE}/items`,
70      { name, type: { codename: type_codename } },
71      { headers: managementHeaders }
72    );
73    res.json(data);
74  } catch (err) {
75    const status = err.response?.status || 500;
76    res.status(status).json({ error: err.response?.data || err.message });
77  }
78});
79
80app.listen(3000, '0.0.0.0', () => {
81  console.log('Kontent.ai integration server running on port 3000');
82});