[ISSUE-22] Add skip alert param (default: false)

Author: occidere

src/main/scala/org/occidere/githubwatcher/GithubWatcher.scala

@@ -14,10 +14,11 @@ import scala.util.{Failure, Success, Try}
  */
 object GithubWatcher extends App with GithubWatcherTask with GithubWatcherLogger {
   private val userId = sys.env.getOrElse("gw_user_id", "")
-  sys.env.getOrElse("gw_tasks", "").split(",").map(_.trim)
+  private val skipAlert = sys.env.getOrElse("gw_skip_alert", "false").toBoolean
+  sys.env.getOrElse("gw_tasks", "").split(",").map(_.trim).filterNot(taskName => taskName.isBlank)
     .foreach(task => {
       if (!AVAILABLE_TASKS.contains(task)) logger.warn(s"Unsupported task: $task")
-      else Try(AVAILABLE_TASKS(task).run(userId)) match {
+      else Try(AVAILABLE_TASKS(task).run(userId, skipAlert)) match {
         case Success(_) => logger.info(s"$task Success!")
         case Failure(e) => logger.error(s"$task Failed!", e)
       }

src/main/scala/org/occidere/githubwatcher/task/FollowerWatchTask.scala

@@ -12,7 +12,7 @@ import org.occidere.githubwatcher.vo.FollowerDiff
  */
 object FollowerWatchTask extends Task with GithubWatcherLogger {
 
-  override def run(userId: String): Unit = {
+  override def run(userId: String, skipAlert: Boolean = false): Unit = {
     logger.info(s"User ID: $userId")
 
     // Data from GitHub API
@@ -31,7 +31,7 @@ object FollowerWatchTask extends Task with GithubWatcherLogger {
     logger.info(s"Not changed followers: ${diff.notChangedFollowerLogins.size}")
 
     // Send line message if follower changed
-    if (diff.hasChanged) LineMessengerService.sendFollowerMessage(diff)
+    if (diff.hasChanged && !skipAlert) LineMessengerService.sendFollowerMessage(diff)
 
     // Update DB to latest data including repos
     latestUser.followerLogins = diff.newFollowerLogins ++ diff.notChangedFollowerLogins

src/main/scala/org/occidere/githubwatcher/task/ReactionWatchTask.scala

@@ -14,7 +14,7 @@ import scala.util.{Failure, Success, Try}
  * @since 2020-09-23
  */
 object ReactionWatchTask extends Task with GithubWatcherLogger {
-  override def run(userId: String): Unit = {
+  override def run(userId: String, skipAlert: Boolean = false): Unit = {
     logger.info(s"User ID: $userId")
 
     // Fetch reactions from Issues
@@ -30,7 +30,7 @@ object ReactionWatchTask extends Task with GithubWatcherLogger {
     // Diff & Send line message
     val changedReactions = latestReactions.filter(latest => {
       val diff = ReactionDiff(prevReactions.getOrElse(latest.uniqueKey, copyReactionWithoutCounts(latest)), latest)
-      Try(if (diff.hasChanged) LineMessengerService.sendReactionMessage(diff)) match {
+      Try(if (diff.hasChanged && !skipAlert) LineMessengerService.sendReactionMessage(diff)) match {
         case Failure(e) =>
           logger.error(s"${latest.uniqueKey} process failed (htmlUrl: ${latest.htmlUrl})", e)
           false

src/main/scala/org/occidere/githubwatcher/task/RepositoryWatchTask.scala

@@ -14,7 +14,7 @@ import scala.util.{Failure, Success, Try}
  */
 object RepositoryWatchTask extends Task with GithubWatcherLogger {
 
-  override def run(userId: String): Unit = {
+  override def run(userId: String, skipAlert: Boolean = false): Unit = {
     logger.info(s"User ID: $userId")
 
     // Latest repos from API
@@ -38,7 +38,7 @@ object RepositoryWatchTask extends Task with GithubWatcherLogger {
       logger.info(s"Repo: ${diff.repoName} (changed: ${diff.hasChanged})")
 
       // Send message
-      Try(if (diff.hasChanged) LineMessengerService.sendRepositoryMessage(diff)) match {
+      Try(if (diff.hasChanged && !skipAlert) LineMessengerService.sendRepositoryMessage(diff)) match {
         case Failure(exception) =>
           logger.error(s"${latest.name} process failed", exception)
           false

src/main/scala/org/occidere/githubwatcher/task/Task.scala

@@ -7,5 +7,5 @@ package org.occidere.githubwatcher.task
  * @since 2020-09-22
  */
 trait Task {
-  def run(userId: String): Unit
+  def run(userId: String, skipAlert: Boolean = false): Unit
 }