"""Lambda test module."""

import json

from freezegun import freeze_time

from src.logic import publish_review_event


@freeze_time('2012-01-14')
def test_publish_review_event_success(kafka_mock, mock_event):
    """Test publish review event success."""
    publish_review_event(
        mock_event['product_id'],
        mock_event['review_queue_id'],
        mock_event['resolution'],
        mock_event['user_uuid'],
        mock_event.get('note', )
    )
    expected = json.dumps({
        'operation': {
            'type': 'create',
            'timestamp': 1326499200000.0,
            'context': 'approve'
        },
        'payload': {
            'product_id': 1234567,
            'review_queue_id': 10101,
            'user_id': 'abc-123',
            'review_note': 'Test approval'
        }
    }).encode('ascii')
    kafka_mock.assert_messages([{
        'topic': 'event.owsContentReview.review',
        'value': expected,
        'key': b'product_1234567'
    }])