workspace extends ../common/model/styles.dsl {
    name "New notification system"
    description "New notification system is responsible for  efficient push notifications, rate limiting, audience based notification campaigns and integration with external systems"

    !identifiers hierarchical
    model {

        user = person "User" "Tango user" {
            tags "User"
        }

        liveOps = person "LiveOPS" "LiveOPS" {
            tags "User" "OPS"
        }

        kafka = softwareSystem "Kafka cluster" {
            tags "Kafka"
        }

        lokalise = softwareSystem "Lokalise" {
            tags "External"
            liveOps -> this "Update localisations"
        }

        pushProviders = softwareSystem "pushProviders" {
            tags "External"
            -> user "Send push"
        }

        externalAudienceSystem = softwareSystem "External Audience System" {
            tags "External"
        }

        localisationSystem = softwareSystem "Localisation system" {

            storage = container "Localisation storage" {
                technology "Bucket" 
                tags "Google Cloud Platform - Compute Engine" "Database" "Aerospike" 
            }

            service = container "LocalisationService" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                -> lokalise "Get localisations"
                -> storage "Read/write localisations"
            }
        }

        userSystem = softwareSystem "User profile system" {
            userinfo = container "Userinfo" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"
            }

            -> kafka "Produce updates"
        }

        audienceSystem = softwareSystem "Audience system" {
            audienceService = container "AudienceService" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"
            } 

            externalAudiencesService = container "ExternalAudiencesService" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Consume production events"
                -> externalAudienceSystem "Send updates"
            } 

            audienceIndexer = container "AudienceIndexer" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Consume audience calculations"
                -> audienceService "Resolve audiences per user"

                -> externalAudiencesService "Get external audiences"
            } 
        }

        pushSystem = softwareSystem "Push sending system" {
            rateLimiter = container "PushRateLimiter" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"
            }  


            pusher = container "Pusher" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                -> rateLimiter "Check/update rate limits"
                -> localisationSystem.service "Get locallisations"
                -> userSystem.userinfo "Get user data"
                -> pushProviders "Send Google/Apple/Tango pushes"
            }    
        }

        notificationSystem = softwareSystem "Notification system" {
            rocketpushdelivery = container "Rocketpushdelivery" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Consume updates"
                -> pushSystem.pusher "Send pushes" "GRPC"
            } 

            pushdelivery = container "Pushdelivery" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Consume push requests"
                -> pushSystem.pusher "Send pushes" "Kafka"
            } 

            acme = container "Acme" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Consume acme requests"
                -> userSystem.userinfo "Get push tokens"
                -> pushSystem.pusher "Send pushes" "Kafka"
            } 

            audiencePushService = container "AudiencePushService" {
                tags "Google Cloud Platform - Kubernetes Engine"
                technology "Java"

                kafka -> this "Send audience pushes by audience ID"
                -> audienceSystem.audienceIndexer "Get users by audience"
                -> pushSystem.pusher "Send pushes" "GRPC"
            } 
        }
    }

    views {

        systemLandscape "SystemLandscape" "New notification system" {
            include *
        }

        systemContext localisationSystem "localisationSystemContext" {
            include *
            autoLayout
        }

        systemContext pushSystem "pushSystemContext" {
            include *
            autoLayout
        }

        systemContext audienceSystem "audienceSystemContext" {
            include *
            autoLayout
        }

        systemContext notificationSystem "notificationSystemContext" {
            include *
            autoLayout
        }

        container localisationSystem "localisationSystemContainer" {
            include *
            autoLayout
        }

        container pushSystem "pushSystemContainer" {
            include *
            autoLayout
        }

        container notificationSystem "notificationSystemContainer" {
            include *
            autoLayout
        }

        container audienceSystem "audienceSystemContainer" {
            include *
            autoLayout
        }

        dynamic pushSystem "pushSystem-send-push" {
            autoLayout
            title "Send pushes"
            description "Send pushes with localisation and templating"

            {
                {
                    notificationSystem.pushdelivery -> pushSystem.pusher
                }
                {
                    notificationSystem.acme -> pushSystem.pusher
                }
                {
                    notificationSystem.audiencePushService -> pushSystem.pusher
                }
                {
                    notificationSystem.rocketpushdelivery -> pushSystem.pusher
                }
            }
            pushSystem.pusher -> localisationSystem.service
            pushSystem.pusher -> userSystem.userinfo
            pushSystem.pusher -> pushProviders
            pushProviders -> user
        }

        dynamic notificationSystem "notificationSystem-send-acme" {
            autoLayout
            title "Send acme"
            description "Send guaranteed pushes with localisation and templating"

            kafka -> notificationSystem.acme "Send guaranteed push"
            notificationSystem.acme -> userSystem.userinfo "Get push tokens"
            notificationSystem.acme -> pushSystem.pusher
        }

        dynamic notificationSystem "notificationSystem-send-live-push" {
            autoLayout
            title "Send live pushes"
            description "Send guaranteed pushes with localisation and templating"

            kafka -> notificationSystem.rocketpushdelivery "Send live push"
            notificationSystem.rocketpushdelivery -> pushSystem.pusher
        }

        dynamic notificationSystem "notificationSystem-send-custom-push" {
            autoLayout
            title "Send custom pushes"
            description "Send custom pushes with localisation and templating"

            kafka -> notificationSystem.pushdelivery "Send custom push"
            notificationSystem.pushdelivery -> pushSystem.pusher
        }

        dynamic notificationSystem "notificationSystem-send-audience-push" {
            autoLayout
            title "Send audience pushes"
            description "Send audience pushes with localisation and templating"

            kafka -> notificationSystem.audiencePushService "Send audience pushes by audience ID"
            notificationSystem.audiencePushService -> audienceSystem.audienceIndexer "Get users by audience ID"
            notificationSystem.audiencePushService -> pushSystem.pusher
        }
    }
}