(refs #2)Create pull request is available.

src/main/scala/app/CreateRepositoryController.scala

@@ -80,7 +80,9 @@ trait CreateRepositoryControllerBase extends ControllerBase {
 
         val git = Git.open(tmpdir)
         git.add.addFilepattern("README.md").call
-        git.commit.setMessage("Initial commit").call
+        git.commit
+          .setCommitter(new PersonIdent(loginUserName, loginAccount.mailAddress))
+          .setMessage("Initial commit").call
         git.push.call
 
       } finally {

src/main/scala/app/PullRequestsController.scala

@@ -1,26 +1,42 @@
 package app
 
-import util.{FileUtil, JGitUtil, ReferrerAuthenticator}
+import util.{CollaboratorsAuthenticator, FileUtil, JGitUtil, ReferrerAuthenticator}
 import util.Directory._
 import service._
 import org.eclipse.jgit.treewalk.CanonicalTreeParser
 import util.JGitUtil.{DiffInfo, CommitInfo}
 import scala.collection.mutable.ArrayBuffer
 import org.eclipse.jgit.api.Git
-import org.eclipse.jgit.lib.ObjectId
+import jp.sf.amateras.scalatra.forms._
+import util.JGitUtil.DiffInfo
+import scala.Some
+import util.JGitUtil.CommitInfo
 
 class PullRequestsController extends PullRequestsControllerBase
-  with RepositoryService with AccountService with ReferrerAuthenticator
+  with RepositoryService with AccountService with IssuesService with PullRequestService
+  with ReferrerAuthenticator with CollaboratorsAuthenticator
 
 trait PullRequestsControllerBase extends ControllerBase {
-  self: ReferrerAuthenticator with RepositoryService =>
+  self: ReferrerAuthenticator with RepositoryService with IssuesService
+    with PullRequestService with CollaboratorsAuthenticator =>
+
+  val form = mapping(
+    "title"           -> trim(label("Title"  , text(required, maxlength(100)))),
+    "content"         -> trim(label("Content", optional(text()))),
+    "branch"          -> trim(text(required, maxlength(100))),
+    "requestUserName" -> trim(text(required, maxlength(100))),
+    "requestCommitId" -> trim(text(required, maxlength(40)))
+  )(PullRequestForm.apply)
+
+  case class PullRequestForm(title: String, content: Option[String], branch: String,
+                             requestUserName: String, requestCommitId: String)
 
   get("/:owner/:repository/pulls")(referrersOnly { repository =>
     pulls.html.list(repository)
   })
 
   // TODO Replace correct authenticator
-  get("/:owner/:repository/pulls/compare")(referrersOnly { newRepo =>
+  get("/:owner/:repository/pulls/compare")(collaboratorsOnly { newRepo =>
     (newRepo.repository.originUserName, newRepo.repository.originRepositoryName) match {
       case (None,_)|(_, None) => NotFound // TODO BadRequest?
       case (Some(originUserName), Some(originRepositoryName)) => {
@@ -40,7 +56,7 @@ trait PullRequestsControllerBase extends ControllerBase {
   })
 
   // TODO Replace correct authenticator
-  get("/:owner/:repository/pulls/compare/*:*...*")(referrersOnly { repository =>
+  get("/:owner/:repository/pulls/compare/*:*...*")(collaboratorsOnly { repository =>
     if(repository.repository.originUserName.isEmpty || repository.repository.originRepositoryName.isEmpty){
       NotFound // TODO BadRequest?
     } else {
@@ -94,6 +110,29 @@ trait PullRequestsControllerBase extends ControllerBase {
     }
   })
 
+  post("/:owner/:repository/pulls/new", form)(referrersOnly { (form, repository) =>
+    val loginUserName = context.loginAccount.get.userName
+
+    val issueId = createIssue(
+      repository.owner,
+      repository.name,
+      loginUserName,
+      form.title,
+      form.content,
+      None, None)
+
+    createPullRequest(
+      repository.owner,
+      repository.name,
+      issueId,
+      form.branch,
+      form.requestUserName,
+      repository.name,
+      form.requestCommitId)
+
+    redirect(s"/${repository.owner}/${repository.name}/pulls/${issueId}")
+  })
+
   private def withGit[T](oldDir: java.io.File, newDir: java.io.File)(action: (Git, Git) => T): T = {
     val oldGit = Git.open(oldDir)
     val newGit = Git.open(newDir)

src/main/scala/model/PullRequest.scala

@@ -3,21 +3,21 @@ package model
 import scala.slick.driver.H2Driver.simple._
 
 object PullRequests extends Table[PullRequest]("PULL_REQUEST") with IssueTemplate {
-  def pullRequestId = column[Int]("PULL_REQUEST_ID")
   def requestUserName = column[String]("REQUEST_USER_NAME")
   def requestRepositoryName = column[String]("REQUEST_REPOSITORY_NAME")
   def requestCommitId = column[String]("REQUEST_COMMIT_ID")
-  def * = pullRequestId ~ userName ~ repositoryName ~ issueId ~ requestUserName ~ requestRepositoryName ~ requestCommitId <> (PullRequest, PullRequest.unapply _)
+  def originBranch = column[String]("ORIGIN_BRANCH")
+  def * = userName ~ repositoryName ~ issueId ~ originBranch ~ requestUserName ~ requestRepositoryName ~ requestCommitId <> (PullRequest, PullRequest.unapply _)
 
-  def autoinc = userName ~ repositoryName ~ issueId ~ requestUserName ~ requestRepositoryName ~ requestCommitId returning pullRequestId
-  def byPrimaryKey(pullRequestId: Int) = this.pullRequestId is pullRequestId.bind
+  def byPrimaryKey(userName: String, repositoryName: String, issueId: Int) = byIssue(userName, repositoryName, issueId)
+  def byPrimaryKey(userName: Column[String], repositoryName: Column[String], issueId: Column[Int]) = byIssue(userName, repositoryName, issueId)
 }
 
 case class PullRequest(
-  pullRequestId: Int,
   userName: String,
   repositoryName: String,
   issueId: Int,
+  originBranch: String,
   requestUserName: String,
   requestRepositoryName: String,
   requestCommitId: String)

src/main/scala/service/PullRequestService.scala

@@ -0,0 +1,25 @@
+package service
+
+import scala.slick.driver.H2Driver.simple._
+import Database.threadLocalSession
+
+import model._
+
+//import scala.slick.jdbc.{StaticQuery => Q}
+//import Q.interpolation
+
+
+trait PullRequestService {
+
+  def createPullRequest(originUserName: String, originRepositoryName: String, issueId: Int,
+        originBranch: String, requestUserName: String, requestRepositoryName: String, requestCommitId: String): Unit =
+    PullRequests insert (PullRequest(
+      originUserName,
+      originRepositoryName,
+      issueId,
+      originBranch,
+      requestUserName,
+      requestRepositoryName,
+      requestCommitId))
+
+}

src/main/scala/servlet/AutoUpdateListener.scala

@@ -49,6 +49,7 @@ object AutoUpdate {
    * The history of versions. A head of this sequence is the current BitBucket version.
    */
   val versions = Seq(
+    Version(1, 4),
     new Version(1, 3){
       override def update(conn: Connection): Unit = {
         super.update(conn)