Scala 2.13 Scalafix: ExplicitNonNullaryApply - Auto-application to () is deprecated

app/controllers/Reindex.scala

@@ -24,7 +24,7 @@ class Reindex(
       if (reindexing) {
         Future.successful(Forbidden)
       } else {
-        ReindexTagsCommand().process.map { result =>
+        ReindexTagsCommand().process().map { result =>
           result.map { count => Ok } getOrElse InternalServerError
         }
       }
@@ -39,7 +39,7 @@ class Reindex(
       if (reindexing) {
         Future.successful(Forbidden)
       } else {
-        ReindexSectionsCommand().process.map { result =>
+        ReindexSectionsCommand().process().map { result =>
           result.map { count => Ok } getOrElse InternalServerError
         }
       }
@@ -54,7 +54,7 @@ class Reindex(
       if (reindexing) {
         Future.successful(Forbidden)
       } else {
-        ReindexPillarsCommand().process.map { result =>
+        ReindexPillarsCommand().process().map { result =>
           result.map { count => Ok } getOrElse InternalServerError
         }
       }

app/controllers/Support.scala

@@ -149,7 +149,7 @@ class Support(
     req.body.asJson.map { json =>
       val sectionId = (json \ "sectionId").as[Long]
 
-      UnexpireSectionContentCommand(sectionId).process.map{ result =>
+      UnexpireSectionContentCommand(sectionId).process().map{ result =>
         result.map(t => Ok("Unexpiry Completed Successfully")) getOrElse BadRequest("Failed to trigger unexpiry")
 
       } recover {
@@ -166,7 +166,7 @@ class Support(
     req.body.asJson.map { json =>
       val sectionId = (json \ "sectionId").as[Long]
 
-      ExpireSectionContentCommand(sectionId).process.map { result =>
+      ExpireSectionContentCommand(sectionId).process().map { result =>
         result.map(t => Ok("Expiry Completed Successfully")) getOrElse BadRequest("Failed to trigger expiry")
       } recover {
         commandErrorAsResult
@@ -211,7 +211,7 @@ class Support(
 
           val updatedTag = tag.copy(parents = tag.parents.filterNot(_.equals(parentId)))
 
-          Some(UpdateTagCommand(DenormalisedTag(updatedTag)).process.map {result =>
+          Some(UpdateTagCommand(DenormalisedTag(updatedTag)).process().map {result =>
             result getOrElse InternalServerError(s"Could not update tag: ${tag.id}")
             danglingParentsCount += 1
           })

app/controllers/TagManagementApi.scala

@@ -43,7 +43,7 @@ class TagManagementApi(
     implicit val username = Option(req.user.email)
 
     req.body.asJson.map { json =>
-      UpdateTagCommand(json.as[DenormalisedTag]).process.map { result =>
+      UpdateTagCommand(json.as[DenormalisedTag]).process().map { result =>
         result.map{t => Ok(Json.toJson(DenormalisedTag(t))) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -57,7 +57,7 @@ class TagManagementApi(
     (APIAuthAction andThen CreateTagPermissionsCheck() andThen CreateTagSpecificPermissionsCheck()).async { req =>
       implicit val username = Option(req.user.email)
       req.body.asJson.map { json =>
-        json.as[CreateTagCommand].process.map { result =>
+        json.as[CreateTagCommand].process().map { result =>
           result.map { t => Ok(Json.toJson(DenormalisedTag(t))) } getOrElse NotFound
         } recover {
           commandErrorAsResult
@@ -129,7 +129,7 @@ class TagManagementApi(
   def createSection() = (APIAuthAction andThen CreateSectionPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[CreateSectionCommand].process.map { result =>
+      json.as[CreateSectionCommand].process().map { result =>
         result.map{t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -142,7 +142,7 @@ class TagManagementApi(
   def updateSection(id: Long) = (APIAuthAction andThen UpdateSectionPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      UpdateSectionCommand(json.as[Section]).process.map { result =>
+      UpdateSectionCommand(json.as[Section]).process().map { result =>
         result.map{ t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -157,7 +157,7 @@ class TagManagementApi(
     req.body.asJson.map { json =>
       val editionName = (json \ "editionName").as[String]
 
-      AddEditionToSectionCommand(id, editionName.toUpperCase).process.map { result =>
+      AddEditionToSectionCommand(id, editionName.toUpperCase).process().map { result =>
         result.map{ t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -169,7 +169,7 @@ class TagManagementApi(
 
   def removeEditionFromSection(id: Long, editionName: String) = (APIAuthAction andThen RemoveEditionFromSectionPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
-    RemoveEditionFromSectionCommand(id, editionName.toUpperCase).process.map {result =>
+    RemoveEditionFromSectionCommand(id, editionName.toUpperCase).process().map {result =>
       result.map{ t => Ok(Json.toJson(t)) } getOrElse NotFound
     } recover {
       commandErrorAsResult
@@ -193,7 +193,7 @@ class TagManagementApi(
   def createPillar() = (APIAuthAction andThen PillarPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[CreatePillarCommand].process.map { result =>
+      json.as[CreatePillarCommand].process().map { result =>
         result.map{t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -206,7 +206,7 @@ class TagManagementApi(
   def updatePillar(id: Long) = (APIAuthAction andThen PillarPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      UpdatePillarCommand(json.as[Pillar]).process.map { result =>
+      UpdatePillarCommand(json.as[Pillar]).process().map { result =>
         result.map { t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -218,7 +218,7 @@ class TagManagementApi(
 
   def deletePillar(id: Long) = (APIAuthAction andThen PillarPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
-    DeletePillarCommand(id).process.map { result =>
+    DeletePillarCommand(id).process().map { result =>
       result.fold[Result](NotFound)(_ => NoContent)
     } recover {
       commandErrorAsResult
@@ -231,7 +231,7 @@ class TagManagementApi(
 
   def checkPathInUse(tagType: String, slug: String, section: Option[Long], tagSubType: Option[String]) = APIAuthAction.async { req =>
     implicit val username = Option(req.user.email)
-    new PathUsageCheck(tagType, slug, section, tagSubType).process.map{ result =>
+    new PathUsageCheck(tagType, slug, section, tagSubType).process().map{ result =>
       result.map{ t => Ok(Json.toJson(t)) } getOrElse BadRequest
     } recover {
       commandErrorAsResult
@@ -242,7 +242,7 @@ class TagManagementApi(
 
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[BatchTagCommand].process.map{ result =>
+      json.as[BatchTagCommand].process().map{ result =>
         result.map{t => NoContent } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -255,7 +255,7 @@ class TagManagementApi(
   def mergeTag = (APIAuthAction andThen MergeTagPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[MergeTagCommand].process.map { result =>
+      json.as[MergeTagCommand].process().map { result =>
         result.map{t => NoContent } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -267,7 +267,7 @@ class TagManagementApi(
 
   def deleteTag(id: Long) = (APIHMACAuthAction andThen DeleteTagPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
-    (DeleteTagCommand(id)).process.map { result =>
+    (DeleteTagCommand(id)).process().map { result =>
       result.map { t => NoContent } getOrElse NotFound
     } recover {
       commandErrorAsResult
@@ -305,7 +305,7 @@ class TagManagementApi(
   def createSponsorship = (APIAuthAction andThen ManageSponsorshipsPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[CreateSponsorshipCommand].process.map { result =>
+      json.as[CreateSponsorshipCommand].process().map { result =>
         result.map{t => Ok(Json.toJson(t)) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -318,7 +318,7 @@ class TagManagementApi(
   def updateSponsorship(id: Long) = (APIAuthAction andThen ManageSponsorshipsPermissionsCheck()).async { req =>
     implicit val username = Option(req.user.email)
     req.body.asJson.map { json =>
-      json.as[UpdateSponsorshipCommand].process.map { result =>
+      json.as[UpdateSponsorshipCommand].process().map { result =>
         result.map{s => Ok(Json.toJson(DenormalisedSponsorship(s))) } getOrElse NotFound
       } recover {
         commandErrorAsResult
@@ -335,7 +335,7 @@ class TagManagementApi(
     val tagSearch: Option[List[Long]] = tagIds.map(_.split(",").toList.filter(_.length > 0).map(_.toLong))
     val sectionSearch: Option[List[Long]] = sectionIds.map(_.split(",").toList.filter(_.length > 0).map(_.toLong))
     new ClashingSponsorshipsFetch(id, tagSearch, sectionSearch, validFrom.map(new DateTime(_)), validTo.map(new DateTime(_)), editionSearch)
-        .process.map { result =>
+        .process().map { result =>
       result.map{ ss => Ok(Json.toJson(ss.map(DenormalisedSponsorship(_)))) } getOrElse BadRequest
     } recover {
       commandErrorAsResult

app/model/command/ReindexPillarsCommand.scala

@@ -8,7 +8,7 @@ case class ReindexPillarsCommand() extends Command {
   override type T = Unit
 
   override def process()(implicit username: Option[String], ec: ExecutionContext): Future[Option[T]] = Future{
-    JobHelper.beginPillarReindex
+    JobHelper.beginPillarReindex()
     Some(())
   }
 }

app/model/command/ReindexSectionsCommand.scala

@@ -8,7 +8,7 @@ case class ReindexSectionsCommand() extends Command {
   override type T = Unit
 
   override def process()(implicit username: Option[String], ec: ExecutionContext): Future[Option[T]] = Future{
-    JobHelper.beginSectionReindex
+    JobHelper.beginSectionReindex()
     Some(())
   }
 }

app/model/command/ReindexTagsCommand.scala

@@ -8,7 +8,7 @@ case class ReindexTagsCommand() extends Command {
   override type T = Unit
 
   override def process()(implicit username: Option[String], ec: ExecutionContext): Future[Option[T]] = Future{
-    JobHelper.beginTagReindex
+    JobHelper.beginTagReindex()
     Some(())
   }
 }

app/model/command/UpdateTagCommand.scala

@@ -62,7 +62,7 @@ case class UpdateTagCommand(denormalisedTag: DenormalisedTag) extends Command wi
     existingTag foreach {(existing) =>
       if (tag.externalReferences != existing.externalReferences) {
         logger.info("Detected references change, triggering reindex")
-        FlexTagReindexCommand(tag).process
+        FlexTagReindexCommand(tag).process()
       }
     }
 

app/model/jobs/Job.scala

@@ -78,7 +78,7 @@ case class Job(
   def rollback = {
     if (rollbackEnabled) {
       val revSteps = steps.reverse
-      revSteps.foreach(step => step.rollbackStep)
+      revSteps.foreach(step => step.rollbackStep())
       jobStatus = JobStatus.rolledback
     }
   }

app/model/jobs/JobHelper.scala

@@ -55,7 +55,7 @@ object JobHelper {
         steps = List(ReindexTags())
         )
       )
-    AppAuditRepository.upsertAppAudit(AppAudit.reindexTags)
+    AppAuditRepository.upsertAppAudit(AppAudit.reindexTags())
   }
 
   def beginSectionReindex()(implicit username: Option[String], ec: ExecutionContext) = {
@@ -69,7 +69,7 @@ object JobHelper {
         steps = List(ReindexSections())
         )
       )
-    AppAuditRepository.upsertAppAudit(AppAudit.reindexSections)
+    AppAuditRepository.upsertAppAudit(AppAudit.reindexSections())
   }
 
   def beginPillarReindex()(implicit username: Option[String], ec: ExecutionContext) = {
@@ -83,7 +83,7 @@ object JobHelper {
         steps = List(ReindexPillars())
       )
     )
-    AppAuditRepository.upsertAppAudit(AppAudit.reindexPillars)
+    AppAuditRepository.upsertAppAudit(AppAudit.reindexPillars())
   }
 
   def beginMergeTag(from: Tag, to: Tag)(implicit username: Option[String], ec: ExecutionContext) = {

app/model/jobs/JobRunner.scala

@@ -36,7 +36,7 @@ class JobRunner @Inject() (lifecycle: ApplicationLifecycle)(implicit ec: Executi
 
   def tryRun() = {
     try {
-      run
+      run()
     } catch {
       case NonFatal(e) => {
         logger.error(s"An unexpected exception occurred in the job runner: ${e.getStackTrace}")
@@ -64,7 +64,7 @@ class JobRunner @Inject() (lifecycle: ApplicationLifecycle)(implicit ec: Executi
             logger.error(s"Background job failed on ${JobRunner.nodeId}. $e")
           }
         } finally {
-          job.checkIfComplete
+          job.checkIfComplete()
           JobRepository.upsertJobIfOwned(job, JobRunner.nodeId)
           JobRepository.unlock(job, JobRunner.nodeId)
         }
@@ -97,6 +97,6 @@ object JobRunner {
 }
 
 class JobRunnerScheduler(runner: JobRunner) extends AbstractScheduledService {
-  override def runOneIteration(): Unit = runner.tryRun
+  override def runOneIteration(): Unit = runner.tryRun()
   override def scheduler(): Scheduler = Scheduler.newFixedDelaySchedule(1, 10, TimeUnit.SECONDS)
 }

app/model/jobs/Step.scala

@@ -26,13 +26,13 @@ trait Step extends Logging {
   // Public methods that wrap the status updates
   def processStep(implicit ec: ExecutionContext) = {
     try {
-      beginProcessing
+      beginProcessing()
       process
-      doneProcessing
+      doneProcessing()
     } catch {
       case NonFatal(e) => {
         logger.error(s"Error thrown during step processing: ${e}")
-        processFailed
+        processFailed()
         throw e // Need to rethrow the exception to inform the job to start a rollback
       }
     }
@@ -41,18 +41,18 @@ trait Step extends Logging {
   def checkStep(implicit ec: ExecutionContext) = {
     attempts += 1
     if (attempts > Step.retryLimit) {
-      checkFailed
+      checkFailed()
       throw TooManyAttempts(s"Too many attempts at checking ${this.`type`}")
     }
 
     try {
       if (check) {
-          checkOk
+          checkOk()
       }
     } catch {
       case NonFatal(e) => {
         logger.error(s"Error thrown during step check: ${e}")
-        checkFailed
+        checkFailed()
         throw e // Need to rethrow the exception to inform the job to start a rollback
       }
     }

app/modules/clustersync/ClusterSynchronisation.scala

@@ -28,7 +28,7 @@ class ClusterSynchronisation @Inject() (lifecycle: ApplicationLifecycle) extends
     AtomicReference[Option[KinesisConsumer]](None)
 
 
-  lifecycle.addStopHook{ () => Future.successful(stop) }
+  lifecycle.addStopHook{ () => Future.successful(stop()) }
   serviceManager.startAsync()
 
   initialise