diff --git a/src/main/scala/gitbucket/core/controller/ControllerBase.scala b/src/main/scala/gitbucket/core/controller/ControllerBase.scala index 107f4f1..94c42f6 100644 --- a/src/main/scala/gitbucket/core/controller/ControllerBase.scala +++ b/src/main/scala/gitbucket/core/controller/ControllerBase.scala @@ -326,12 +326,12 @@ protected def updateImage(userName: String, fileId: Option[String], clearImage: Boolean): Unit = if (clearImage) { - getAccountByUserName(userName).flatMap(_.image).map { image => + getAccountByUserName(userName).flatMap(_.image).foreach { image => new File(getUserUploadDir(userName), FileUtil.checkFilename(image)).delete() updateAvatarImage(userName, None) } } else { - fileId.map { fileId => + fileId.foreach { fileId => val filename = "avatar." + FileUtil.getExtension(session.getAndRemove(Keys.Session.Upload(fileId)).get) val uploadDir = getUserUploadDir(userName) if (!uploadDir.exists) { diff --git a/src/main/scala/gitbucket/core/controller/PullRequestsController.scala b/src/main/scala/gitbucket/core/controller/PullRequestsController.scala index 72bedbd..52e223c 100644 --- a/src/main/scala/gitbucket/core/controller/PullRequestsController.scala +++ b/src/main/scala/gitbucket/core/controller/PullRequestsController.scala @@ -352,10 +352,10 @@ // close issue by commit message if (pullreq.requestBranch == repository.repository.defaultBranch) { - commits.map { commit => + commits.foreach { commit => closeIssuesFromMessage(commit.fullMessage, loginAccount.userName, owner, name).foreach { issueId => - getIssue(repository.owner, repository.name, issueId.toString).map { issue => + getIssue(repository.owner, repository.name, issueId.toString).foreach { issue => callIssuesWebHook("closed", repository, issue, baseUrl, loginAccount) PluginRegistry().getIssueHooks .foreach( @@ -469,7 +469,7 @@ commits.flatten.foreach { commit => closeIssuesFromMessage(commit.fullMessage, loginAccount.userName, owner, name).foreach { issueId => - getIssue(owner, name, issueId.toString).map { issue => + getIssue(owner, name, issueId.toString).foreach { issue => callIssuesWebHook("closed", repository, issue, baseUrl, loginAccount) PluginRegistry().getIssueHooks .foreach(_.closedByCommitComment(issue, repository, commit.fullMessage, loginAccount)) @@ -483,14 +483,14 @@ owner, name ).foreach { issueId => - getIssue(owner, name, issueId.toString).map { issue => + getIssue(owner, name, issueId.toString).foreach { issue => callIssuesWebHook("closed", repository, issue, baseUrl, loginAccount) PluginRegistry().getIssueHooks .foreach(_.closedByCommitComment(issue, repository, issueContent, loginAccount)) } } closeIssuesFromMessage(form.message, loginAccount.userName, owner, name).foreach { issueId => - getIssue(owner, name, issueId.toString).map { issue => + getIssue(owner, name, issueId.toString).foreach { issue => callIssuesWebHook("closed", repository, issue, baseUrl, loginAccount) PluginRegistry().getIssueHooks .foreach(_.closedByCommitComment(issue, repository, issueContent, loginAccount)) @@ -743,7 +743,7 @@ // insert labels if (manageable) { - form.labelNames.map { value => + form.labelNames.foreach { value => val labels = getLabels(owner, name) value.split(",").foreach { labelName => labels.find(_.labelName == labelName).map { label => diff --git a/src/main/scala/gitbucket/core/controller/RepositorySettingsController.scala b/src/main/scala/gitbucket/core/controller/RepositorySettingsController.scala index adfdfc4..0807cd4 100644 --- a/src/main/scala/gitbucket/core/controller/RepositorySettingsController.scala +++ b/src/main/scala/gitbucket/core/controller/RepositorySettingsController.scala @@ -229,7 +229,7 @@ post("/:owner/:repository/settings/collaborators")(ownerOnly { repository => val collaborators = params("collaborators") removeCollaborators(repository.owner, repository.name) - collaborators.split(",").withFilter(_.nonEmpty).map { collaborator => + collaborators.split(",").withFilter(_.nonEmpty).foreach { collaborator => val userName :: role :: Nil = collaborator.split(":").toList addCollaborator(repository.owner, repository.name, userName, role) } diff --git a/src/main/scala/gitbucket/core/controller/RepositoryViewerController.scala b/src/main/scala/gitbucket/core/controller/RepositoryViewerController.scala index ce03dc8..bcc2068 100644 --- a/src/main/scala/gitbucket/core/controller/RepositoryViewerController.scala +++ b/src/main/scala/gitbucket/core/controller/RepositoryViewerController.scala @@ -1066,7 +1066,7 @@ if (branch == repository.repository.defaultBranch) { closeIssuesFromMessage(message, loginAccount.userName, repository.owner, repository.name).foreach { issueId => - getIssue(repository.owner, repository.name, issueId.toString).map { issue => + getIssue(repository.owner, repository.name, issueId.toString).foreach { issue => callIssuesWebHook("closed", repository, issue, baseUrl, loginAccount) PluginRegistry().getIssueHooks .foreach(_.closedByCommitComment(issue, repository, message, loginAccount)) diff --git a/src/main/scala/gitbucket/core/controller/WikiController.scala b/src/main/scala/gitbucket/core/controller/WikiController.scala index 2298971..319f19f 100644 --- a/src/main/scala/gitbucket/core/controller/WikiController.scala +++ b/src/main/scala/gitbucket/core/controller/WikiController.scala @@ -180,7 +180,7 @@ loginAccount, form.message.getOrElse(""), Some(form.id) - ).map { + ).foreach { commitId => updateLastActivityDate(repository.owner, repository.name) recordEditWikiPageActivity( @@ -224,7 +224,7 @@ loginAccount, form.message.getOrElse(""), None - ).map { + ).foreach { commitId => updateLastActivityDate(repository.owner, repository.name) recordCreateWikiPageActivity(repository.owner, repository.name, loginAccount.userName, form.pageName) diff --git a/src/main/scala/gitbucket/core/service/MergeService.scala b/src/main/scala/gitbucket/core/service/MergeService.scala index 0c907ce..3eab6b3 100644 --- a/src/main/scala/gitbucket/core/service/MergeService.scala +++ b/src/main/scala/gitbucket/core/service/MergeService.scala @@ -196,7 +196,7 @@ refUpdate.setNewObjectId(newObjectId) refUpdate.setForceUpdate(force) refUpdate.setRefLogIdent(committer) - refLogMessage.map(refUpdate.setRefLogMessage(_, true)) + refLogMessage.foreach(refUpdate.setRefLogMessage(_, true)) refUpdate.update() } } diff --git a/src/main/scala/gitbucket/core/service/RepositoryService.scala b/src/main/scala/gitbucket/core/service/RepositoryService.scala index 60f2e53..8b15a68 100644 --- a/src/main/scala/gitbucket/core/service/RepositoryService.scala +++ b/src/main/scala/gitbucket/core/service/RepositoryService.scala @@ -67,7 +67,7 @@ getAccountByUserName(newUserName).foreach { account => (Repositories filter { t => t.byRepository(oldUserName, oldRepositoryName) - } firstOption).map { repository => + } firstOption).foreach { repository => Repositories insert repository.copy(userName = newUserName, repositoryName = newRepositoryName) val webHooks = RepositoryWebHooks.filter(_.byRepository(oldUserName, oldRepositoryName)).list diff --git a/src/main/scala/gitbucket/core/service/SystemSettingsService.scala b/src/main/scala/gitbucket/core/service/SystemSettingsService.scala index df9109a..e424762 100644 --- a/src/main/scala/gitbucket/core/service/SystemSettingsService.scala +++ b/src/main/scala/gitbucket/core/service/SystemSettingsService.scala @@ -41,7 +41,7 @@ } props.setProperty(LdapAuthentication, settings.ldapAuthentication.toString) if (settings.ldapAuthentication) { - settings.ldap.map { ldap => + settings.ldap.foreach { ldap => props.setProperty(LdapHost, ldap.host) ldap.port.foreach(x => props.setProperty(LdapPort, x.toString)) ldap.bindDN.foreach(x => props.setProperty(LdapBindDN, x)) @@ -58,11 +58,11 @@ } props.setProperty(OidcAuthentication, settings.oidcAuthentication.toString) if (settings.oidcAuthentication) { - settings.oidc.map { oidc => + settings.oidc.foreach { oidc => props.setProperty(OidcIssuer, oidc.issuer.getValue) props.setProperty(OidcClientId, oidc.clientID.getValue) props.setProperty(OidcClientSecret, oidc.clientSecret.getValue) - oidc.jwsAlgorithm.map { x => + oidc.jwsAlgorithm.foreach { x => props.setProperty(OidcJwsAlgorithm, x.getName) } } diff --git a/src/main/scala/gitbucket/core/servlet/GitRepositoryServlet.scala b/src/main/scala/gitbucket/core/servlet/GitRepositoryServlet.scala index bbfc469..722bf5d 100644 --- a/src/main/scala/gitbucket/core/servlet/GitRepositoryServlet.scala +++ b/src/main/scala/gitbucket/core/servlet/GitRepositoryServlet.scala @@ -296,9 +296,9 @@ createIssueComment(owner, repository, commit) // close issues if (refName(1) == "heads" && branchName == defaultBranch && command.getType == ReceiveCommand.Type.UPDATE) { - getAccountByUserName(pusher).map { pusherAccount => + getAccountByUserName(pusher).foreach { pusherAccount => closeIssuesFromMessage(commit.fullMessage, pusher, owner, repository).foreach { issueId => - getIssue(owner, repository, issueId.toString).map { issue => + getIssue(owner, repository, issueId.toString).foreach { issue => callIssuesWebHook("closed", repositoryInfo, issue, baseUrl, pusherAccount) PluginRegistry().getIssueHooks .foreach(_.closedByCommitComment(issue, repositoryInfo, commit.fullMessage, pusherAccount)) @@ -318,7 +318,7 @@ c.id == pull.commitIdTo }.isDefined) { markMergeAndClosePullRequest(pusher, owner, repository, pull) - getAccountByUserName(pusher).map { pusherAccount => + getAccountByUserName(pusher).foreach { pusherAccount => callPullRequestWebHook("closed", repositoryInfo, pull.issueId, baseUrl, pusherAccount) } } @@ -347,7 +347,7 @@ case ReceiveCommand.Type.CREATE | ReceiveCommand.Type.UPDATE | ReceiveCommand.Type.UPDATE_NONFASTFORWARD => updatePullRequests(owner, repository, branchName) - getAccountByUserName(pusher).map { pusherAccount => + getAccountByUserName(pusher).foreach { pusherAccount => callPullRequestWebHookByRequestBranch( "synchronize", repositoryInfo, @@ -439,7 +439,7 @@ } } - commitIds.map { + commitIds.foreach { case (oldCommitId, newCommitId) => val commits = using(Git.open(Directory.getWikiRepositoryDir(owner, repository))) { git => JGitUtil.getCommitLog(git, oldCommitId, newCommitId).flatMap { commit => diff --git a/src/main/scala/gitbucket/core/util/JGitUtil.scala b/src/main/scala/gitbucket/core/util/JGitUtil.scala index b9f0830..0381fdb 100644 --- a/src/main/scala/gitbucket/core/util/JGitUtil.scala +++ b/src/main/scala/gitbucket/core/util/JGitUtil.scala @@ -390,7 +390,7 @@ lazy val newParentsMap = newCommit.getParents.map(_ -> newCommit).toMap useTreeWalk(newCommit) { walk => while (walk.next) { - rest.remove(walk.getNameString -> walk.getObjectId(0)).map { + rest.remove(walk.getNameString -> walk.getObjectId(0)).foreach { case (tuple, _) => if (newParentsMap.isEmpty) { nextResult +:= tupleAdd(tuple, newCommit) @@ -400,7 +400,7 @@ } } } - rest.values.map { + rest.values.foreach { case (tuple, parentsMap) => val restParentsMap = parentsMap - newCommit if (restParentsMap.isEmpty) {