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.job
21 
22 import org.make.api.technical.job.JobActor.{DefinedJob, EmptyJob}
23 import org.make.api.technical.job.JobEvent._
24 import org.make.core.SprayJsonFormatters
25 import spray.json.DefaultJsonProtocol._
26 
27 import stamina.{V1, V2}
28 import stamina.json.{from, persister, JsonPersister}
29 
30 object JobSerializers extends SprayJsonFormatters {
31 
32   private val jobSerializer: JsonPersister[DefinedJob, V2] =
33     persister[DefinedJob, V2]("job", from[V1].to[V2](job => Map("job" -> job).toJson))
34   private val emptyJobSerializer: JsonPersister[EmptyJob.type, V1] = persister[EmptyJob.type]("empty-job")
35   private val startedSerializer: JsonPersister[Started, V1] = persister[Started]("job-started")
36   private val heartbeatReceivedSerializer: JsonPersister[HeartbeatReceived, V1] =
37     persister[HeartbeatReceived]("job-heartbeat-received")
38   private val progressedSerializer: JsonPersister[Progressed, V1] = persister[Progressed]("job-progressed")
39   private val finishedSerializer: JsonPersister[Finished, V1] = persister[Finished]("job-finished")
40 
41   val serializers: Seq[JsonPersister[_, _]] =
42     Seq(
43       jobSerializer,
44       emptyJobSerializer,
45       startedSerializer,
46       heartbeatReceivedSerializer,
47       progressedSerializer,
48       finishedSerializer
49     )
50 
51 }