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
21 
22 import akka.actor.ExtendedActorSystem
23 import akka.actor.typed.ActorSystem
24 import akka.actor.typed.scaladsl.adapter.ClassicActorSystemOps
25 import grizzled.slf4j.Logging
26 import org.make.api.proposal.ProposalSerializers
27 import org.make.api.sessionhistory.SessionHistorySerializers
28 import org.make.api.technical.MakeEventSerializer.allSerializers
29 import org.make.api.technical.job.JobSerializers
30 import org.make.api.technical.security.{SecurityConfigurationExtension, SecurityHelper}
31 import org.make.api.userhistory.UserHistorySerializers
32 import spray.json.{JsObject, JsString, JsValue}
33 import stamina.{Persister, StaminaAkkaSerializer}
34 
35 class MakeEventSerializer(system: ActorSystem[_], serializerName: String)
36     extends StaminaAkkaSerializer(allSerializers(system).toList)
37     with Logging {
38 
39   def this(system: ExtendedActorSystem) = this(system.toTyped, "make-serializer")
40   def this(system: ExtendedActorSystem, serializerName: String) = this(system.toTyped, serializerName)
41 
42   logger.debug(s"Creating make event serializer with name $serializerName")
43 }
44 
45 object MakeEventSerializer {
46   def allSerializers(system: ActorSystem[_]): Seq[Persister[_, _]] = {
47     val conf = SecurityConfigurationExtension(system)
48     ProposalSerializers(conf).serializers ++
49       UserHistorySerializers(conf).serializers ++
50       SessionHistorySerializers(conf).serializers ++
51       JobSerializers.serializers
52   }
53 
54   def setIpAddressAndHash(salt: String)(context: JsObject): JsObject = {
55     val fields: Map[String, JsValue] = context.fields
56     @SuppressWarnings(Array("org.wartremover.warts.AsInstanceOf"))
57     val maybeIp = fields.get("ipAddress").map(_.asInstanceOf[JsString].value)
58     JsObject(
59       fields ++
60         maybeIp.map(ip => "ipAddress" -> JsString(IpAndHash.obfuscateIp(ip))) ++
61         maybeIp.map(ip => "ipAddressHash" -> JsString(SecurityHelper.generateHash(ip, salt)))
62     )
63   }
64 }