npm install -g wrangler

wrangler --version

wrangler login

mkdir smart-analyzer-worker
cd smart-analyzer-worker
npm init -y

name = "smart-analyzer"
main = "src/index.js"
compatibility_date = "2026-02-28"
 
[vars]
ENVIRONMENT = "production"

mkdir src

export default {
  async fetch(request, env, ctx) {
    // معالجة CORS لطلبات المتصفح
    if (request.method === 'OPTIONS') {
      return new Response(null, {
        headers: {
          'Access-Control-Allow-Origin': '*',
          'Access-Control-Allow-Methods': 'POST, OPTIONS',
          'Access-Control-Allow-Headers': 'Content-Type',
        },
      });
    }
 
    // قبول طلبات POST فقط
    if (request.method !== 'POST') {
      return new Response('Method not allowed', { status: 405 });
    }
 
    try {
      const { text } = await request.json();
 
      if (!text || text.trim().length === 0) {
        return new Response(
          JSON.stringify({ error: 'النص مطلوب' }),
          { status: 400, headers: { 'Content-Type': 'application/json' } }
        );
      }
 
      return new Response(
        JSON.stringify({
          message: 'Worker يعمل!',
          textLength: text.length,
        }),
        {
          headers: {
            'Content-Type': 'application/json',
            'Access-Control-Allow-Origin': '*',
          },
        }
      );
    } catch (error) {
      return new Response(
        JSON.stringify({ error: 'JSON غير صالح' }),
        { status: 400, headers: { 'Content-Type': 'application/json' } }
      );
    }
  },
};

wrangler dev

curl -X POST http://localhost:8787 \
  -H "Content-Type: application/json" \
  -d '{"text":"مرحباً بالعالم!"}'

wrangler secret put ANTHROPIC_API_KEY

async function analyzeWithClaude(text, apiKey) {
  const response = await fetch('https://api.anthropic.com/v1/messages', {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'x-api-key': apiKey,
      'anthropic-version': '2023-06-01',
    },
    body: JSON.stringify({
      model: 'claude-3-5-sonnet-20241022',
      max_tokens: 1024,
      messages: [
        {
          role: 'user',
          content: \`حلل النص التالي وقدم:
1. المشاعر (إيجابية/سلبية/محايدة مع نسبة الثقة)
2. أهم 3 مواضيع رئيسية
3. ملخص مختصر (جملتان كحد أقصى)
4. توصية للمحتوى (ما الإجراء الذي يجب اتخاذه)
 
النص: "\${text}"
 
أرجع إجابتك كـ JSON صالح بهذا الهيكل:
{
  "sentiment": {"label": "positive", "confidence": 0.85},
  "topics": ["موضوع1", "موضوع2", "موضوع3"],
  "summary": "ملخصك هنا",
  "recommendation": "توصيتك هنا"
}\`,
        },
      ],
    }),
  });
 
  if (!response.ok) {
    throw new Error(\`خطأ في Claude API: \${response.status}\`);
  }
 
  const data = await response.json();
  const content = data.content[0].text;
 
  // استخراج JSON من رد Claude
  const jsonMatch = content.match(/\{[\s\S]*\}/);
  if (!jsonMatch) {
    throw new Error('فشل تحليل رد Claude');
  }
 
  return JSON.parse(jsonMatch[0]);
}
 
export default {
  async fetch(request, env, ctx) {
    if (request.method === 'OPTIONS') {
      return new Response(null, {
        headers: {
          'Access-Control-Allow-Origin': '*',
          'Access-Control-Allow-Methods': 'POST, OPTIONS',
          'Access-Control-Allow-Headers': 'Content-Type',
        },
      });
    }
 
    if (request.method !== 'POST') {
      return new Response('Method not allowed', { status: 405 });
    }
 
    try {
      const { text } = await request.json();
 
      if (!text || text.trim().length === 0) {
        return new Response(
          JSON.stringify({ error: 'النص مطلوب' }),
          { status: 400, headers: { 'Content-Type': 'application/json' } }
        );
      }
 
      // تحديد طول النص لمنع إساءة الاستخدام
      if (text.length > 10000) {
        return new Response(
          JSON.stringify({ error: 'النص طويل جداً (الحد الأقصى 10,000 حرف)' }),
          { status: 400, headers: { 'Content-Type': 'application/json' } }
        );
      }
 
      const analysis = await analyzeWithClaude(text, env.ANTHROPIC_API_KEY);
 
      return new Response(
        JSON.stringify({
          success: true,
          analysis,
          processedAt: new Date().toISOString(),
        }),
        {
          headers: {
            'Content-Type': 'application/json',
            'Access-Control-Allow-Origin': '*',
          },
        }
      );
    } catch (error) {
      console.error('خطأ:', error);
      return new Response(
        JSON.stringify({
          error: 'فشل التحليل',
          message: error.message,
        }),
        {
          status: 500,
          headers: { 'Content-Type': 'application/json' },
        }
      );
    }
  },
};

wrangler dev

curl -X POST http://localhost:8787 \
  -H "Content-Type: application/json" \
  -d '{
    "text": "الميزات الجديدة للذكاء الاصطناعي في منتجنا لاقت استقبالاً رائعاً. العملاء يبلغون عن زيادة في الإنتاجية بنسبة 40٪ والتعليقات كانت إيجابية للغاية. هذا يؤكد صحة اتجاهنا الاستراتيجي."
  }'

wrangler deploy

// في أعلى Worker الخاص بك
const RATE_LIMIT = 10; // طلبات في الدقيقة
const rateLimitMap = new Map();
 
function checkRateLimit(ip) {
  const now = Date.now();
  const windowStart = now - 60000; // نافذة دقيقة واحدة
 
  if (!rateLimitMap.has(ip)) {
    rateLimitMap.set(ip, [now]);
    return true;
  }
 
  const requests = rateLimitMap.get(ip).filter(time => time > windowStart);
  requests.push(now);
  rateLimitMap.set(ip, requests);
 
  return requests.length <= RATE_LIMIT;
}
 
// في معالج fetch الخاص بك، قبل المعالجة:
const clientIP = request.headers.get('CF-Connecting-IP') || 'unknown';
if (!checkRateLimit(clientIP)) {
  return new Response(
    JSON.stringify({ error: 'تجاوزت حد المعدل. حاول مرة أخرى لاحقاً.' }),
    { status: 429, headers: { 'Content-Type': 'application/json' } }
  );
}

// لمهام التحليل الطويلة
return new Response(stream, {
  headers: { 'Content-Type': 'text/event-stream' }
});

const cache = caches.default;
const cacheKey = new Request(request.url, request);
let response = await cache.match(cacheKey);
 
if (!response) {
  response = await analyzeWithClaude(text, env.ANTHROPIC_API_KEY);
  ctx.waitUntil(cache.put(cacheKey, response.clone()));
}

model: 'claude-3-5-haiku-20241022' // أسرع وأرخص