1 /*
2  *  Make.org Core API
3  *  Copyright (C) 2020 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.crmTemplates
21 
22 import cats.implicits._
23 import org.make.api.extensions.MakeDBExecutionContextComponent
24 import org.make.api.technical.ShortenedNames
25 import org.make.api.technical.DatabaseTransactions._
26 import org.make.api.technical.ScalikeSupport._
27 import org.make.core.crmTemplate.CrmLanguageTemplate
28 import org.make.core.reference.Language
29 import scalikejdbc._
30 
31 import scala.concurrent.Future
32 
33 trait DefaultPersistentCrmLanguageTemplateServiceComponent extends PersistentCrmLanguageTemplateServiceComponent {
34   this: MakeDBExecutionContextComponent =>
35 
36   override lazy val persistentCrmLanguageTemplateService: PersistentCrmLanguageTemplateService =
37     new DefaultPersistentCrmLanguageTemplateService
38 
39   class DefaultPersistentCrmLanguageTemplateService extends PersistentCrmLanguageTemplateService with ShortenedNames {
40 
41     private val templates = SQLSyntaxSupportFactory[CrmLanguageTemplate]()
42     private val t = templates.syntax
43 
44     override def persist(items: Seq[CrmLanguageTemplate]): Future[Seq[CrmLanguageTemplate]] = {
45       implicit val context: EC = writeExecutionContext
46       Future(NamedDB("WRITE").retryableTx { implicit session =>
47         items.foreach { template =>
48           withSQL { insert.into(templates).namedValues(autoNamedValues(template, templates.column)) }.update()
49         }
50       }).as(items)
51     }
52 
53     override def modify(items: Seq[CrmLanguageTemplate]): Future[Seq[CrmLanguageTemplate]] = {
54       implicit val context: EC = writeExecutionContext
55       Future(NamedDB("WRITE").retryableTx { implicit session =>
56         items.foreach { template =>
57           withSQL {
58             update(templates).set(autoNamedValues(template, templates.column, "id")).where.eq(t.id, template.id)
59           }.update()
60         }
61       }).as(items)
62     }
63 
64     override def list(language: Language): Future[Seq[CrmLanguageTemplate]] = {
65       implicit val context: EC = readExecutionContext
66       Future(NamedDB("READ").retryableTx { implicit session =>
67         withSQL { select.from(templates.as(t)).where.eq(t.language, language) }
68           .map(templates.apply(t.resultName))
69           .list()
70       })
71     }
72 
73     override def all(): Future[Seq[CrmLanguageTemplate]] = {
74       implicit val context: EC = readExecutionContext
75       Future(NamedDB("READ").retryableTx { implicit session =>
76         withSQL { select.from(templates.as(t)) }.map(templates.apply(t.resultName)).list()
77       })
78     }
79   }
80 
81 }