from unittest import TestCase
from unittest.mock import Mock, patch

from samtranslator.model.eventsources.cloudwatchlogs import CloudWatchLogs


class CloudWatchLogsEventSource(TestCase):
    def setUp(self):
        self.logical_id = "LogProcessor"

        self.cloudwatch_logs_event_source = CloudWatchLogs(self.logical_id)
        self.cloudwatch_logs_event_source.LogGroupName = "MyLogGroup"
        self.cloudwatch_logs_event_source.FilterPattern = "Fizbo"

        self.function = Mock()
        self.function.get_runtime_attr = Mock()
        self.function.get_runtime_attr.return_value = "arn:aws:mock"
        self.function.resource_attributes = {}
        self.function.get_passthrough_resource_attributes = Mock()
        self.function.get_passthrough_resource_attributes.return_value = {}

        self.permission = Mock()
        self.permission.logical_id = "LogProcessorPermission"

    @patch("boto3.session.Session.region_name", "ap-southeast-1")
    def test_get_source_arn(self):
        source_arn = self.cloudwatch_logs_event_source.get_source_arn()
        expected_source_arn = {
            "Fn::Sub": [
                "arn:aws:logs:${AWS::Region}:${AWS::AccountId}:log-group:${__LogGroupName__}:*",
                {"__LogGroupName__": "MyLogGroup"},
            ]
        }
        self.assertEqual(source_arn, expected_source_arn)

    def test_get_subscription_filter(self):
        subscription_filter = self.cloudwatch_logs_event_source.get_subscription_filter(self.function, self.permission)
        self.assertEqual(subscription_filter.LogGroupName, "MyLogGroup")
        self.assertEqual(subscription_filter.FilterPattern, "Fizbo")
        self.assertEqual(subscription_filter.DestinationArn, "arn:aws:mock")

    @patch("boto3.session.Session.region_name", "ap-southeast-1")
    def test_to_cloudformation_returns_permission_and_subscription_filter_resources(self):
        resources = self.cloudwatch_logs_event_source.to_cloudformation(function=self.function)
        self.assertEqual(len(resources), 2)
        self.assertEqual(resources[0].resource_type, "AWS::Lambda::Permission")
        self.assertEqual(resources[1].resource_type, "AWS::Logs::SubscriptionFilter")

    def test_to_cloudformation_throws_when_no_function(self):
        self.assertRaises(TypeError, self.cloudwatch_logs_event_source.to_cloudformation)