1 /*
2  *  Make.org Core API
3  *  Copyright (C) 2018 Make.org
4  *
5  * This program is free software: you can redistribute it and/or modify
6  *  it under the terms of the GNU Affero General Public License as
7  *  published by the Free Software Foundation, either version 3 of the
8  *  License, or (at your option) any later version.
9  *
10  *  This program is distributed in the hope that it will be useful,
11  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
12  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  *  GNU Affero General Public License for more details.
14  *
15  *  You should have received a copy of the GNU Affero General Public License
16  *  along with this program.  If not, see <https://www.gnu.org/licenses/>.
17  *
18  */
19 
20 package org.make.api.proposal
21 
22 import akka.actor.typed
23 import akka.actor.typed.receptionist.Receptionist
24 import akka.actor.typed.scaladsl.Behaviors
25 import akka.actor.typed.{ActorRef, Behavior}
26 import org.make.api.kafka.kafkaDispatcher
27 import org.make.api.sessionhistory.SessionHistoryCoordinatorServiceComponent
28 import org.make.api.technical.{ActorSystemHelper, IdGeneratorComponent}
29 import org.make.api.technical.crm.SendMailPublisherServiceComponent
30 import org.make.api.userhistory.UserHistoryCoordinatorServiceComponent
31 import org.make.api.user.PersistentUserProposalsServiceComponent
32 import org.make.api.operation.OperationOfQuestionServiceComponent
33 
34 import scala.concurrent.duration.FiniteDuration
35 
36 object ProposalSupervisor {
37 
38   type ProposalSupervisorDependencies =
39     ProposalIndexerServiceComponent
40       with SendMailPublisherServiceComponent
41       with OperationOfQuestionServiceComponent
42       with PersistentUserProposalsServiceComponent
43       with UserHistoryCoordinatorServiceComponent
44       with SessionHistoryCoordinatorServiceComponent
45       with IdGeneratorComponent
46 
47   val name: String = "proposal"
48   def apply(dependencies: ProposalSupervisorDependencies, lockDuration: FiniteDuration): Behavior[Nothing] = {
49 
50     Behaviors.setup[Nothing] { context =>
51       val proposalCoordinator: ActorRef[ProposalCommand] = ProposalCoordinator(
52         system = context.system,
53         sessionHistoryCoordinatorService = dependencies.sessionHistoryCoordinatorService,
54         lockDuration = lockDuration,
55         idGenerator = dependencies.idGenerator
56       )
57       context.watch(proposalCoordinator)
58       context.system.receptionist ! Receptionist.Register(ProposalCoordinator.Key, proposalCoordinator)
59 
60       context.watch(
61         context.spawn(
62           ActorSystemHelper.superviseWithBackoff(ProposalKafkaProducerBehavior()),
63           ProposalKafkaProducerBehavior.name,
64           typed.Props.empty.withDispatcherFromConfig(kafkaDispatcher)
65         )
66       )
67 
68       context.watch(
69         context.spawn(
70           ActorSystemHelper
71             .superviseWithBackoff(ProposalUserHistoryConsumerBehavior(dependencies.userHistoryCoordinatorService)),
72           ProposalUserHistoryConsumerBehavior.name,
73           typed.Props.empty.withDispatcherFromConfig(kafkaDispatcher)
74         )
75       )
76 
77       context.watch(
78         context.spawn(
79           ActorSystemHelper.superviseWithBackoff(
80             ProposalEmailConsumerActor(
81               dependencies.sendMailPublisherService,
82               dependencies.persistentUserProposalsService
83             )
84           ),
85           ProposalEmailConsumerActor.name,
86           typed.Props.empty.withDispatcherFromConfig(kafkaDispatcher)
87         )
88       )
89 
90       context.watch(
91         context.spawn(
92           ActorSystemHelper.superviseWithBackoff(
93             ProposalConsumerBehavior(dependencies.proposalIndexerService, dependencies.operationOfQuestionService)
94           ),
95           ProposalConsumerBehavior.name,
96           akka.actor.typed.Props.empty.withDispatcherFromConfig(kafkaDispatcher)
97         )
98       )
99 
100       Behaviors.empty
101     }
102   }
103 }