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.user
21 
22 import akka.actor.typed.scaladsl.Behaviors
23 import akka.actor.typed.{Behavior, Props}
24 import org.make.api.kafka.kafkaDispatcher
25 import org.make.api.operation.OperationServiceComponent
26 import org.make.api.organisation.{
27   OrganisationConsumerBehavior,
28   OrganisationSearchEngineComponent,
29   OrganisationServiceComponent
30 }
31 import org.make.api.technical.ActorSystemHelper.superviseWithBackoff
32 import org.make.api.technical.crm.SendMailPublisherServiceComponent
33 import org.make.api.technical.elasticsearch.ElasticsearchConfigurationComponent
34 import org.make.api.userhistory.UserHistoryCoordinatorServiceComponent
35 
36 object UserSupervisor {
37 
38   def apply(dependencies: UserSupervisorDependencies): Behavior[Nothing] = {
39     Behaviors.setup[Nothing] { context =>
40       context.watch(context.spawn(UserProducerBehavior(), UserProducerBehavior.name))
41 
42       context.watch(
43         context.spawn(
44           superviseWithBackoff(
45             UserEmailConsumerBehavior(dependencies.userService, dependencies.sendMailPublisherService)
46           ),
47           UserEmailConsumerBehavior.name,
48           Props.empty.withDispatcherFromConfig(kafkaDispatcher)
49         )
50       )
51 
52       context.watch(
53         context.spawn(
54           superviseWithBackoff(
55             UserHistoryConsumerBehavior(dependencies.userHistoryCoordinatorService, dependencies.userService)
56           ),
57           UserHistoryConsumerBehavior.name,
58           Props.empty.withDispatcherFromConfig(kafkaDispatcher)
59         )
60       )
61 
62       context.watch(
63         context.spawn(
64           superviseWithBackoff(UserImageConsumerBehavior(dependencies.userService)),
65           UserImageConsumerBehavior.name,
66           Props.empty.withDispatcherFromConfig(kafkaDispatcher)
67         )
68       )
69 
70       context.spawn(
71         superviseWithBackoff(
72           OrganisationConsumerBehavior(dependencies.organisationService, dependencies.elasticsearchOrganisationAPI)
73         ),
74         OrganisationConsumerBehavior.name,
75         Props.empty.withDispatcherFromConfig(kafkaDispatcher)
76       )
77 
78       Behaviors.empty
79     }
80   }
81 
82   type UserSupervisorDependencies = UserServiceComponent
83     with OperationServiceComponent
84     with OrganisationServiceComponent
85     with OrganisationSearchEngineComponent
86     with ElasticsearchConfigurationComponent
87     with SendMailPublisherServiceComponent
88     with UserServiceComponent
89     with UserHistoryCoordinatorServiceComponent
90 
91   val name: String = "users"
92 }