// Producer Worker - Send messages to queue
export default {
  async fetch(request, env) {
    const { searchParams } = new URL(request.url);
    const message = searchParams.get('message');
    
    if (!message) {
      return new Response('Missing message parameter', { status: 400 });
    }

    // Send message to queue
    await env.MY_QUEUE.send({
      message: message,
      timestamp: new Date().toISOString(),
      userId: request.headers.get('X-User-ID')
    });

    return new Response('Message sent to queue', { status: 200 });
  }
};

// Consumer Worker - Process messages from queue
export default {
  async queue(batch, env, ctx) {
    for (const message of batch.messages) {
      try {
        // Process the message
        console.log('Processing message:', message.body);
        
        // Simulate some work
        await new Promise(resolve => setTimeout(resolve, 1000));
        
        // Acknowledge the message
        message.ack();
      } catch (error) {
        console.error('Failed to process message:', error);
        message.retry();
      }
    }
  }
};