Merge pull request #11 from neomatrix369/dev-uk-2017

Create api for archiving of ratings for all the accepted talks
nicmarti · Oct 26, 2017 · 79ec878 · 79ec878
2 parents 9e976c3 + b1cfc1f
commit 79ec878
Show file tree

Hide file tree

Showing 4 changed files with 52 additions and 2 deletions.
diff --git a/app/controllers/Attic.scala b/app/controllers/Attic.scala
@@ -93,6 +93,12 @@ object Attic extends SecureCFPController {
       Redirect(routes.Attic.atticHome()).flashing(("success", s"All speakers archived (along with their Q&A)"))
   }
 
+  def doArchiveRatings()= SecuredAction(IsMemberOf("admin")) {
+    implicit request: SecuredRequest[play.api.mvc.AnyContent] =>
+      Rating.archiveTalkRatings()
+      Redirect(routes.Attic.atticHome()).flashing(("success", "Archived ratings (aka mobile votes) for all talks"))
+  }
+
   def deleteInvitedSpeakers() = SecuredAction(IsMemberOf("admin")) {
     implicit request: SecuredRequest[play.api.mvc.AnyContent] =>
       Invitation.deleteAll()
@@ -143,7 +149,7 @@ object Attic extends SecureCFPController {
   // Mobile API
   def deleteRatings()= SecuredAction(IsMemberOf("admin")) {
     implicit request: SecuredRequest[play.api.mvc.AnyContent] =>
-      Rating.attic()
+      Rating.deleteAll()
       Redirect(routes.Attic.atticHome()).flashing(("success", "Deleted mobile votes"))
   }
 }
diff --git a/app/models/Rating.scala b/app/models/Rating.scala
@@ -225,7 +225,7 @@ object Rating {
     BigDecimal(score).setScale(2,RoundingMode.HALF_EVEN).toDouble
   }
 
-  def attic() = Redis.pool.withClient {
+  def deleteAll() = Redis.pool.withClient {
     implicit client =>
       client.del(RATING_KEY)
 
@@ -234,4 +234,42 @@ object Rating {
       allKeys.foreach { key: String => tx.del(key) }
       tx.exec()
   }
+
+  def archiveTalkRatings(): Unit = Redis.pool.withClient {
+    val conferenceCode = ConferenceDescriptor.current().eventCode
+
+    val allAcceptedTalks = Proposal.allProposals().filter(_.state == ProposalState.ACCEPTED)
+    val allRatingsForTalks = allRatings()
+
+    implicit client =>
+      val allRatingsForTalksByTalkId = allAcceptedTalks.flatMap(
+        talk => client.hmget(RATING_KEY, client.smembers(s"$RATING_KEY:ByTalkId:${talk.id}"))
+      )
+
+      val tx = client.multi()
+
+      play.Logger.info(s"Attempting to archive summarised ratings (aka mobile votes) for all talks for $conferenceCode.")
+      allRatingsForTalks.foreach {
+        rating =>
+          tx.hset(s"Archived:$RATING_KEY", rating.id(), Json.toJson(rating).toString())
+          play.Logger.debug(s"Archived:$RATING_KEY:${rating.id()} => ${Json.toJson(rating).toString()}");
+      }
+      play.Logger.info(s"Finished archiving summarised ratings (aka mobile votes - (${allRatingsForTalks.size} of them) for all talks for $conferenceCode.")
+
+      play.Logger.info(s"Attempting to archive individual ratings for all talks for $conferenceCode.")
+
+      allRatingsForTalksByTalkId.foreach {
+        json => {
+          val rating = Json.parse(json).as[Rating]
+          tx.sadd(s"Archived:$RATING_KEY:ByTalkId:${rating.talkId}", rating.id())
+          play.Logger.debug(s"Archived:$RATING_KEY:ByTalkId:${rating.talkId} => ${rating.id()}");
+        }
+      }
+
+      play.Logger.info(s"Deleting summarised and individual talk ratings for all talks for $conferenceCode.")
+      deleteAll()
+
+      tx.exec()
+      play.Logger.debug(s"Finished archiving ratings (aka mobile votes - ${allRatingsForTalksByTalkId.size} of them) for all talks for ${conferenceCode}.")
+  }
 }
diff --git a/app/views/Attic/atticHome.scala.html b/app/views/Attic/atticHome.scala.html
@@ -77,6 +77,11 @@ <h3>Attic backoffice</h3>
                         <button type="submit" class="btn btn-primary">Archive all speakers (along with their Q&A)</button>
                     </form>
 
+                    <form action="@routes.Attic.doArchiveRatings()" method="POST">
+                        <input type="hidden" name="opType" value="prune"/>
+                            <button type="submit" class="btn btn-primary">Archive ratings (aka mobile votes) of all talks</button>
+                    </form>
+
                         <div class="clearfix"></div>
 
                         <div class="col-lg-12 col-md-12">

diff --git a/conf/routes b/conf/routes
@@ -325,6 +325,7 @@ POST          /cfpadmin/attic/deleteGoldenTickets
 POST          /cfpadmin/attic/deleteWishlisted                                  controllers.Attic.deleteWishlist()
 POST          /cfpadmin/attic/deleteFav                                         controllers.Attic.deleteFavoriteTalks()
 POST          /cfpadmin/attic/deleteRatings                                     controllers.Attic.deleteRatings()
+POST          /cfpadmin/attic/doArchiveRatings                                  controllers.Attic.doArchiveRatings()
 
 # Golden ticket admin
 GET           /admin/goldenTickets                                              controllers.GoldenTicketAdminController.showAll()