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.technical.crm
21 
22 import akka.actor.typed.Behavior
23 import grizzled.slf4j.Logging
24 import org.make.api.technical.KafkaProducerBehavior
25 import org.make.core.{DateHelper, MakeSerializable}
26 
27 import java.time.{Instant, ZoneOffset, ZonedDateTime}
28 
29 class MailJetEventProducerBehavior extends KafkaProducerBehavior[MailJetEvent, MailJetEventWrapper] with Logging {
30   override protected val topicKey: String = MailJetEventProducerBehavior.topicKey
31   override protected def wrapEvent(event: MailJetEvent): MailJetEventWrapper = {
32     logger.debug(s"Produce MailJetEvent: ${event.toString}")
33     MailJetEventWrapper(version = MakeSerializable.V1, id = event.email, date = event.time.map { timestamp =>
34       ZonedDateTime.from(Instant.ofEpochMilli(timestamp * 1000).atZone(ZoneOffset.UTC))
35     }.getOrElse(DateHelper.now()), event = event)
36   }
37 }
38 
39 object MailJetEventProducerBehavior {
40   def apply(): Behavior[MailJetEvent] = new MailJetEventProducerBehavior().createBehavior(name)
41 
42   val name: String = "mailjet-events-producer"
43   val topicKey: String = "mailjet-events"
44 }