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 org.make.api.extensions.MakeDBExecutionContextComponent
23 import org.make.api.technical.DatabaseTransactions.RichDatabase
24 import org.make.api.technical.ShortenedNames
25 import org.make.api.user.PersistentCrmSynchroUserService.{CrmSynchroUser, MakeUser}
26 import org.make.core.technical.Pagination
27 import scalikejdbc._
28 import org.make.api.technical.ScalikeSupport._
29 
30 import scala.concurrent.Future
31 
32 trait DefaultPersistentCrmSynchroUserServiceComponent extends PersistentCrmSynchroUserServiceComponent {
33   this: MakeDBExecutionContextComponent =>
34 
35   override lazy val persistentCrmSynchroUserService: PersistentCrmSynchroUserService =
36     new DefaultPersistentCrmSynchroUserService
37 
38   final class DefaultPersistentCrmSynchroUserService extends PersistentCrmSynchroUserService with ShortenedNames {
39 
40     private val synchroUser = SQLSyntaxSupportFactory[MakeUser]()
41     private val u = synchroUser.syntax
42 
43     override def findUsersForCrmSynchro(
44       optIn: Option[Boolean],
45       hardBounce: Option[Boolean],
46       offset: Pagination.Offset,
47       limit: Pagination.Limit
48     ): Future[Seq[CrmSynchroUser]] = {
49       implicit val cxt: EC = readExecutionContext
50       Future(NamedDB("READ").retryableTx { implicit session =>
51         withSQL {
52           select
53             .from(synchroUser.as(u))
54             .where(
55               sqls.toAndConditionOpt(
56                 hardBounce.map(sqls.eq(u.isHardBounce, _)),
57                 optIn.map(sqls.eq(u.optInNewsletter, _)),
58                 Some(sqls.notLike(u.email, "yopmail+%@make.org")),
59                 Some(sqls.notLike(u.email, "%@example.com"))
60               )
61             )
62             .orderBy(u.createdAt.asc, u.email.asc)
63             .limit(limit.extractInt)
64             .offset(offset.extractInt)
65         }.map(synchroUser.apply(u.resultName)).list()
66       })
67     }
68   }
69 }