AI‑ассистент для автоматического создания и оптимизации видео‑обзоров товаров

const express = require('express');
const crypto = require('crypto');
const axios = require('axios');
const app = express();
app.use(express.json());

const WEBHOOK_SECRET = 'YOUR_WEBHOOK_SECRET';
const GA_MEASUREMENT_ID = 'G-XXXXXXX';
const GA_API_SECRET = 'YOUR_GA_API_SECRET';
const YANDEX_COUNTER_ID = '12345678';
const YANDEX_CLIENT_ID = 'YOUR_YANDEX_CLIENT_ID';
const YANDEX_CLIENT_SECRET = 'YOUR_YANDEX_CLIENT_SECRET';

app.post('/api/webhook/video', async (req, res) => {
  const signature = req.headers['x-webhook-signature'];
  const hmac = crypto.createHmac('sha256', WEBHOOK_SECRET);
  hmac.update(JSON.stringify(req.body));
  const digest = hmac.digest('hex');
  if (digest !== signature) return res.status(401).send('Invalid signature');

  const { productId, videoUrl, thumbnailUrl, videoId } = req.body;
  // 1. Update product card
  await axios.post(`https://cms.example.com/api/products/${productId}`, {
    video_src: videoUrl,
    video_thumbnail: thumbnailUrl
  }, { headers: { Authorization: 'Bearer CMS_TOKEN' } });

  // 2. Send to Google Analytics
  await axios.post(`https://www.google-analytics.com/mp/collect?measurement_id=${GA_MEASUREMENT_ID}&api_secret=${GA_API_SECRET}`, {
    client_id: 'client-123',
    events: [{
      name: 'video_view',
      params: { product_id: productId, video_id: videoId }
    }]
  });

  // 3. Send to Yandex Metriа
  const tokenResponse = await axios.post(`https://oauth.yandex.ru/token`, null, {
    params: {
      grant_type: 'client_credentials',
      client_id: YANDEX_CLIENT_ID,
      client_secret: YANDEX_CLIENT_SECRET
    }
  });
  const accessToken = tokenResponse.data.access_token;
  await axios.post(`https://api-metrika.yandex.net/management/v1/metrics/${YANDEX_COUNTER_ID}/events`, {
    name: 'video_view',
    params: { product_id: productId, video_id: videoId }
  }, { headers: { Authorization: `OAuth ${accessToken}` } });

  res.status(200).send('OK');
});

app.listen(3000, () => console.log('Webhook listener running on port 3000'));

import json, requests

# Шаблоны по категориям
TEMPLATES = {
    "electronics": {
        "description": "Review of the latest {product} with focus on performance and battery life.",
        "keywords": "electronics, review, {brand}, battery, performance",
    },
    "fashion": {
        "description": "Stylish look‑book for {product} in {season} collection.",
        "keywords": "fashion, look‑book, {brand}, {season}, style",
    },
}

def build_request(product, category, brand, season=None):
    tpl = TEMPLATES[category]
    desc = tpl["description"].format(product=product, brand=brand, season=season or "")
    keys = tpl["keywords"].format(product=product, brand=brand, season=season or "")
    payload = {
        "model": "gpt-4o-mini",
        "messages": [
            {"role": "system", "content": "You are a video script generator."},
            {"role": "user", "content": f"Description: {desc}\nKeywords: {keys}\nLength: medium"},
        ],
        "max_tokens": 1500,
    }
    return payload

# Пример вызова
request_body = build_request("Smartphone X", "electronics", "TechBrand")
response = requests.post("https://api.openai.com/v1/chat/completions",
                         headers={"Authorization": f"Bearer {API_KEY}"},
                         json=request_body)
print(response.json()["choices"][0]["message"]["content"])