import boto3
import json
import uuid

sqs = boto3.client("sqs", region_name="eu-west-1")

# שליחת message
def send_order_event(order_id: str, status: str, amount: float):
    queue_url = "https://sqs.eu-west-1.amazonaws.com/123456789/order-events"

    response = sqs.send_message(
        QueueUrl=queue_url,
        MessageBody=json.dumps({
            "orderId": order_id,
            "status": status,
            "amount": amount,
            "timestamp": datetime.utcnow().isoformat()
        }),
        MessageAttributes={
            "eventType": {
                "DataType": "String",
                "StringValue": f"order.{status}"
            }
        },
        MessageDeduplicationId=f"{order_id}-{status}",  # FIFO only
        MessageGroupId=order_id  # FIFO only — הודעות לאותו order יעובדו בסדר
    )
    return response["MessageId"]

# קריאת messages (polling)
def process_messages():
    queue_url = "https://sqs.eu-west-1.amazonaws.com/123456789/order-events"

    while True:
        response = sqs.receive_message(
            QueueUrl=queue_url,
            MaxNumberOfMessages=10,
            WaitTimeSeconds=20,  # Long polling — חכה עד 20 שניות ל-message
            VisibilityTimeout=300,  # 5 דקות לעיבוד
            MessageAttributeNames=["All"]
        )

        messages = response.get("Messages", [])
        for message in messages:
            try:
                body = json.loads(message["Body"])
                process_order_event(body)

                # מחיקה רק אחרי עיבוד מוצלח
                sqs.delete_message(
                    QueueUrl=queue_url,
                    ReceiptHandle=message["ReceiptHandle"]
                )

            except Exception as e:
                print(f"Failed to process: {e}")
                # לא מוחקים — message יחזור לqueue אחרי VisibilityTimeout
Message Queues — SQS, SNS, Pub/Sub, Event Hub

Message Queues — SQS, SNS, Pub/Sub, Event Hub

Message Queues — SQS, SNS, Pub/Sub, Event Hub
