issue.go 31 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238
  1. // Copyright 2014 The Gogs Authors. All rights reserved.
  2. // Use of this source code is governed by a MIT-style
  3. // license that can be found in the LICENSE file.
  4. package repo
  5. import (
  6. "fmt"
  7. "io"
  8. "io/ioutil"
  9. "net/http"
  10. "net/url"
  11. "strings"
  12. "time"
  13. "github.com/Unknwon/com"
  14. "github.com/Unknwon/paginater"
  15. log "gopkg.in/clog.v1"
  16. "github.com/gogits/gogs/models"
  17. "github.com/gogits/gogs/models/errors"
  18. "github.com/gogits/gogs/modules/base"
  19. "github.com/gogits/gogs/modules/context"
  20. "github.com/gogits/gogs/modules/form"
  21. "github.com/gogits/gogs/modules/markdown"
  22. "github.com/gogits/gogs/modules/setting"
  23. )
  24. const (
  25. ISSUES base.TplName = "repo/issue/list"
  26. ISSUE_NEW base.TplName = "repo/issue/new"
  27. ISSUE_VIEW base.TplName = "repo/issue/view"
  28. LABELS base.TplName = "repo/issue/labels"
  29. MILESTONE base.TplName = "repo/issue/milestones"
  30. MILESTONE_NEW base.TplName = "repo/issue/milestone_new"
  31. MILESTONE_EDIT base.TplName = "repo/issue/milestone_edit"
  32. ISSUE_TEMPLATE_KEY = "IssueTemplate"
  33. )
  34. var (
  35. ErrFileTypeForbidden = errors.New("File type is not allowed")
  36. ErrTooManyFiles = errors.New("Maximum number of files to upload exceeded")
  37. IssueTemplateCandidates = []string{
  38. "ISSUE_TEMPLATE.md",
  39. ".gogs/ISSUE_TEMPLATE.md",
  40. ".github/ISSUE_TEMPLATE.md",
  41. }
  42. )
  43. func MustEnableIssues(ctx *context.Context) {
  44. if !ctx.Repo.Repository.EnableIssues {
  45. ctx.Handle(404, "MustEnableIssues", nil)
  46. return
  47. }
  48. if ctx.Repo.Repository.EnableExternalTracker {
  49. ctx.Redirect(ctx.Repo.Repository.ExternalTrackerURL)
  50. return
  51. }
  52. }
  53. func MustAllowPulls(ctx *context.Context) {
  54. if !ctx.Repo.Repository.AllowsPulls() {
  55. ctx.Handle(404, "MustAllowPulls", nil)
  56. return
  57. }
  58. // User can send pull request if owns a forked repository.
  59. if ctx.IsSigned && ctx.User.HasForkedRepo(ctx.Repo.Repository.ID) {
  60. ctx.Repo.PullRequest.Allowed = true
  61. ctx.Repo.PullRequest.HeadInfo = ctx.User.Name + ":" + ctx.Repo.BranchName
  62. }
  63. }
  64. func RetrieveLabels(ctx *context.Context) {
  65. labels, err := models.GetLabelsByRepoID(ctx.Repo.Repository.ID)
  66. if err != nil {
  67. ctx.Handle(500, "RetrieveLabels.GetLabels", err)
  68. return
  69. }
  70. for _, l := range labels {
  71. l.CalOpenIssues()
  72. }
  73. ctx.Data["Labels"] = labels
  74. ctx.Data["NumLabels"] = len(labels)
  75. }
  76. func Issues(ctx *context.Context) {
  77. isPullList := ctx.Params(":type") == "pulls"
  78. if isPullList {
  79. MustAllowPulls(ctx)
  80. if ctx.Written() {
  81. return
  82. }
  83. ctx.Data["Title"] = ctx.Tr("repo.pulls")
  84. ctx.Data["PageIsPullList"] = true
  85. } else {
  86. MustEnableIssues(ctx)
  87. if ctx.Written() {
  88. return
  89. }
  90. ctx.Data["Title"] = ctx.Tr("repo.issues")
  91. ctx.Data["PageIsIssueList"] = true
  92. }
  93. viewType := ctx.Query("type")
  94. sortType := ctx.Query("sort")
  95. types := []string{"assigned", "created_by", "mentioned"}
  96. if !com.IsSliceContainsStr(types, viewType) {
  97. viewType = "all"
  98. }
  99. // Must sign in to see issues about you.
  100. if viewType != "all" && !ctx.IsSigned {
  101. ctx.SetCookie("redirect_to", "/"+url.QueryEscape(setting.AppSubUrl+ctx.Req.RequestURI), 0, setting.AppSubUrl)
  102. ctx.Redirect(setting.AppSubUrl + "/user/login")
  103. return
  104. }
  105. var (
  106. assigneeID = ctx.QueryInt64("assignee")
  107. posterID int64
  108. )
  109. filterMode := models.FILTER_MODE_YOUR_REPOS
  110. switch viewType {
  111. case "assigned":
  112. filterMode = models.FILTER_MODE_ASSIGN
  113. assigneeID = ctx.User.ID
  114. case "created_by":
  115. filterMode = models.FILTER_MODE_CREATE
  116. posterID = ctx.User.ID
  117. case "mentioned":
  118. filterMode = models.FILTER_MODE_MENTION
  119. }
  120. var uid int64 = -1
  121. if ctx.IsSigned {
  122. uid = ctx.User.ID
  123. }
  124. repo := ctx.Repo.Repository
  125. selectLabels := ctx.Query("labels")
  126. milestoneID := ctx.QueryInt64("milestone")
  127. isShowClosed := ctx.Query("state") == "closed"
  128. issueStats := models.GetIssueStats(&models.IssueStatsOptions{
  129. RepoID: repo.ID,
  130. UserID: uid,
  131. Labels: selectLabels,
  132. MilestoneID: milestoneID,
  133. AssigneeID: assigneeID,
  134. FilterMode: filterMode,
  135. IsPull: isPullList,
  136. })
  137. page := ctx.QueryInt("page")
  138. if page <= 1 {
  139. page = 1
  140. }
  141. var total int
  142. if !isShowClosed {
  143. total = int(issueStats.OpenCount)
  144. } else {
  145. total = int(issueStats.ClosedCount)
  146. }
  147. pager := paginater.New(total, setting.UI.IssuePagingNum, page, 5)
  148. ctx.Data["Page"] = pager
  149. issues, err := models.Issues(&models.IssuesOptions{
  150. UserID: uid,
  151. AssigneeID: assigneeID,
  152. RepoID: repo.ID,
  153. PosterID: posterID,
  154. MilestoneID: milestoneID,
  155. Page: pager.Current(),
  156. IsClosed: isShowClosed,
  157. IsMention: filterMode == models.FILTER_MODE_MENTION,
  158. IsPull: isPullList,
  159. Labels: selectLabels,
  160. SortType: sortType,
  161. })
  162. if err != nil {
  163. ctx.Handle(500, "Issues", err)
  164. return
  165. }
  166. // Get issue-user relations.
  167. pairs, err := models.GetIssueUsers(repo.ID, posterID, isShowClosed)
  168. if err != nil {
  169. ctx.Handle(500, "GetIssueUsers", err)
  170. return
  171. }
  172. // Get posters.
  173. for i := range issues {
  174. if !ctx.IsSigned {
  175. issues[i].IsRead = true
  176. continue
  177. }
  178. // Check read status.
  179. idx := models.PairsContains(pairs, issues[i].ID, ctx.User.ID)
  180. if idx > -1 {
  181. issues[i].IsRead = pairs[idx].IsRead
  182. } else {
  183. issues[i].IsRead = true
  184. }
  185. }
  186. ctx.Data["Issues"] = issues
  187. // Get milestones.
  188. ctx.Data["Milestones"], err = models.GetMilestonesByRepoID(repo.ID)
  189. if err != nil {
  190. ctx.Handle(500, "GetAllRepoMilestones", err)
  191. return
  192. }
  193. // Get assignees.
  194. ctx.Data["Assignees"], err = repo.GetAssignees()
  195. if err != nil {
  196. ctx.Handle(500, "GetAssignees", err)
  197. return
  198. }
  199. if viewType == "assigned" {
  200. assigneeID = 0 // Reset ID to prevent unexpected selection of assignee.
  201. }
  202. ctx.Data["IssueStats"] = issueStats
  203. ctx.Data["SelectLabels"] = com.StrTo(selectLabels).MustInt64()
  204. ctx.Data["ViewType"] = viewType
  205. ctx.Data["SortType"] = sortType
  206. ctx.Data["MilestoneID"] = milestoneID
  207. ctx.Data["AssigneeID"] = assigneeID
  208. ctx.Data["IsShowClosed"] = isShowClosed
  209. if isShowClosed {
  210. ctx.Data["State"] = "closed"
  211. } else {
  212. ctx.Data["State"] = "open"
  213. }
  214. ctx.HTML(200, ISSUES)
  215. }
  216. func renderAttachmentSettings(ctx *context.Context) {
  217. ctx.Data["RequireDropzone"] = true
  218. ctx.Data["IsAttachmentEnabled"] = setting.AttachmentEnabled
  219. ctx.Data["AttachmentAllowedTypes"] = setting.AttachmentAllowedTypes
  220. ctx.Data["AttachmentMaxSize"] = setting.AttachmentMaxSize
  221. ctx.Data["AttachmentMaxFiles"] = setting.AttachmentMaxFiles
  222. }
  223. func RetrieveRepoMilestonesAndAssignees(ctx *context.Context, repo *models.Repository) {
  224. var err error
  225. ctx.Data["OpenMilestones"], err = models.GetMilestones(repo.ID, -1, false)
  226. if err != nil {
  227. ctx.Handle(500, "GetMilestones", err)
  228. return
  229. }
  230. ctx.Data["ClosedMilestones"], err = models.GetMilestones(repo.ID, -1, true)
  231. if err != nil {
  232. ctx.Handle(500, "GetMilestones", err)
  233. return
  234. }
  235. ctx.Data["Assignees"], err = repo.GetAssignees()
  236. if err != nil {
  237. ctx.Handle(500, "GetAssignees", err)
  238. return
  239. }
  240. }
  241. func RetrieveRepoMetas(ctx *context.Context, repo *models.Repository) []*models.Label {
  242. if !ctx.Repo.IsWriter() {
  243. return nil
  244. }
  245. labels, err := models.GetLabelsByRepoID(repo.ID)
  246. if err != nil {
  247. ctx.Handle(500, "GetLabelsByRepoID", err)
  248. return nil
  249. }
  250. ctx.Data["Labels"] = labels
  251. RetrieveRepoMilestonesAndAssignees(ctx, repo)
  252. if ctx.Written() {
  253. return nil
  254. }
  255. return labels
  256. }
  257. func getFileContentFromDefaultBranch(ctx *context.Context, filename string) (string, bool) {
  258. var r io.Reader
  259. var bytes []byte
  260. if ctx.Repo.Commit == nil {
  261. var err error
  262. ctx.Repo.Commit, err = ctx.Repo.GitRepo.GetBranchCommit(ctx.Repo.Repository.DefaultBranch)
  263. if err != nil {
  264. return "", false
  265. }
  266. }
  267. entry, err := ctx.Repo.Commit.GetTreeEntryByPath(filename)
  268. if err != nil {
  269. return "", false
  270. }
  271. r, err = entry.Blob().Data()
  272. if err != nil {
  273. return "", false
  274. }
  275. bytes, err = ioutil.ReadAll(r)
  276. if err != nil {
  277. return "", false
  278. }
  279. return string(bytes), true
  280. }
  281. func setTemplateIfExists(ctx *context.Context, ctxDataKey string, possibleFiles []string) {
  282. for _, filename := range possibleFiles {
  283. content, found := getFileContentFromDefaultBranch(ctx, filename)
  284. if found {
  285. ctx.Data[ctxDataKey] = content
  286. return
  287. }
  288. }
  289. }
  290. func NewIssue(ctx *context.Context) {
  291. ctx.Data["Title"] = ctx.Tr("repo.issues.new")
  292. ctx.Data["PageIsIssueList"] = true
  293. ctx.Data["RequireHighlightJS"] = true
  294. ctx.Data["RequireSimpleMDE"] = true
  295. setTemplateIfExists(ctx, ISSUE_TEMPLATE_KEY, IssueTemplateCandidates)
  296. renderAttachmentSettings(ctx)
  297. RetrieveRepoMetas(ctx, ctx.Repo.Repository)
  298. if ctx.Written() {
  299. return
  300. }
  301. ctx.HTML(200, ISSUE_NEW)
  302. }
  303. func ValidateRepoMetas(ctx *context.Context, f form.NewIssue) ([]int64, int64, int64) {
  304. var (
  305. repo = ctx.Repo.Repository
  306. err error
  307. )
  308. labels := RetrieveRepoMetas(ctx, ctx.Repo.Repository)
  309. if ctx.Written() {
  310. return nil, 0, 0
  311. }
  312. if !ctx.Repo.IsWriter() {
  313. return nil, 0, 0
  314. }
  315. // Check labels.
  316. labelIDs := base.StringsToInt64s(strings.Split(f.LabelIDs, ","))
  317. labelIDMark := base.Int64sToMap(labelIDs)
  318. hasSelected := false
  319. for i := range labels {
  320. if labelIDMark[labels[i].ID] {
  321. labels[i].IsChecked = true
  322. hasSelected = true
  323. }
  324. }
  325. ctx.Data["HasSelectedLabel"] = hasSelected
  326. ctx.Data["label_ids"] = f.LabelIDs
  327. ctx.Data["Labels"] = labels
  328. // Check milestone.
  329. milestoneID := f.MilestoneID
  330. if milestoneID > 0 {
  331. ctx.Data["Milestone"], err = repo.GetMilestoneByID(milestoneID)
  332. if err != nil {
  333. ctx.Handle(500, "GetMilestoneByID", err)
  334. return nil, 0, 0
  335. }
  336. ctx.Data["milestone_id"] = milestoneID
  337. }
  338. // Check assignee.
  339. assigneeID := f.AssigneeID
  340. if assigneeID > 0 {
  341. ctx.Data["Assignee"], err = repo.GetAssigneeByID(assigneeID)
  342. if err != nil {
  343. ctx.Handle(500, "GetAssigneeByID", err)
  344. return nil, 0, 0
  345. }
  346. ctx.Data["assignee_id"] = assigneeID
  347. }
  348. return labelIDs, milestoneID, assigneeID
  349. }
  350. func NewIssuePost(ctx *context.Context, f form.NewIssue) {
  351. ctx.Data["Title"] = ctx.Tr("repo.issues.new")
  352. ctx.Data["PageIsIssueList"] = true
  353. ctx.Data["RequireHighlightJS"] = true
  354. ctx.Data["RequireSimpleMDE"] = true
  355. renderAttachmentSettings(ctx)
  356. labelIDs, milestoneID, assigneeID := ValidateRepoMetas(ctx, f)
  357. if ctx.Written() {
  358. return
  359. }
  360. if ctx.HasError() {
  361. ctx.HTML(200, ISSUE_NEW)
  362. return
  363. }
  364. var attachments []string
  365. if setting.AttachmentEnabled {
  366. attachments = f.Files
  367. }
  368. issue := &models.Issue{
  369. RepoID: ctx.Repo.Repository.ID,
  370. Title: f.Title,
  371. PosterID: ctx.User.ID,
  372. Poster: ctx.User,
  373. MilestoneID: milestoneID,
  374. AssigneeID: assigneeID,
  375. Content: f.Content,
  376. }
  377. if err := models.NewIssue(ctx.Repo.Repository, issue, labelIDs, attachments); err != nil {
  378. ctx.Handle(500, "NewIssue", err)
  379. return
  380. }
  381. log.Trace("Issue created: %d/%d", ctx.Repo.Repository.ID, issue.ID)
  382. ctx.Redirect(ctx.Repo.RepoLink + "/issues/" + com.ToStr(issue.Index))
  383. }
  384. func uploadAttachment(ctx *context.Context, allowedTypes []string) {
  385. file, header, err := ctx.Req.FormFile("file")
  386. if err != nil {
  387. ctx.Error(500, fmt.Sprintf("FormFile: %v", err))
  388. return
  389. }
  390. defer file.Close()
  391. buf := make([]byte, 1024)
  392. n, _ := file.Read(buf)
  393. if n > 0 {
  394. buf = buf[:n]
  395. }
  396. fileType := http.DetectContentType(buf)
  397. allowed := false
  398. for _, t := range allowedTypes {
  399. t := strings.Trim(t, " ")
  400. if t == "*/*" || t == fileType {
  401. allowed = true
  402. break
  403. }
  404. }
  405. if !allowed {
  406. ctx.Error(400, ErrFileTypeForbidden.Error())
  407. return
  408. }
  409. attach, err := models.NewAttachment(header.Filename, buf, file)
  410. if err != nil {
  411. ctx.Error(500, fmt.Sprintf("NewAttachment: %v", err))
  412. return
  413. }
  414. log.Trace("New attachment uploaded: %s", attach.UUID)
  415. ctx.JSON(200, map[string]string{
  416. "uuid": attach.UUID,
  417. })
  418. }
  419. func UploadIssueAttachment(ctx *context.Context) {
  420. if !setting.AttachmentEnabled {
  421. ctx.NotFound()
  422. return
  423. }
  424. uploadAttachment(ctx, strings.Split(setting.AttachmentAllowedTypes, ","))
  425. }
  426. func ViewIssue(ctx *context.Context) {
  427. ctx.Data["RequireHighlightJS"] = true
  428. ctx.Data["RequireDropzone"] = true
  429. renderAttachmentSettings(ctx)
  430. index := ctx.ParamsInt64(":index")
  431. if index <= 0 {
  432. ctx.NotFound()
  433. return
  434. }
  435. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.ID, index)
  436. if err != nil {
  437. ctx.NotFoundOrServerError("GetIssueByIndex", errors.IsIssueNotExist, err)
  438. return
  439. }
  440. ctx.Data["Title"] = issue.Title
  441. // Make sure type and URL matches.
  442. if ctx.Params(":type") == "issues" && issue.IsPull {
  443. ctx.Redirect(ctx.Repo.RepoLink + "/pulls/" + com.ToStr(issue.Index))
  444. return
  445. } else if ctx.Params(":type") == "pulls" && !issue.IsPull {
  446. ctx.Redirect(ctx.Repo.RepoLink + "/issues/" + com.ToStr(issue.Index))
  447. return
  448. }
  449. if issue.IsPull {
  450. MustAllowPulls(ctx)
  451. if ctx.Written() {
  452. return
  453. }
  454. ctx.Data["PageIsPullList"] = true
  455. ctx.Data["PageIsPullConversation"] = true
  456. } else {
  457. MustEnableIssues(ctx)
  458. if ctx.Written() {
  459. return
  460. }
  461. ctx.Data["PageIsIssueList"] = true
  462. }
  463. issue.RenderedContent = string(markdown.Render([]byte(issue.Content), ctx.Repo.RepoLink,
  464. ctx.Repo.Repository.ComposeMetas()))
  465. repo := ctx.Repo.Repository
  466. // Get more information if it's a pull request.
  467. if issue.IsPull {
  468. if issue.PullRequest.HasMerged {
  469. ctx.Data["DisableStatusChange"] = issue.PullRequest.HasMerged
  470. PrepareMergedViewPullInfo(ctx, issue)
  471. } else {
  472. PrepareViewPullInfo(ctx, issue)
  473. }
  474. if ctx.Written() {
  475. return
  476. }
  477. }
  478. // Metas.
  479. // Check labels.
  480. labelIDMark := make(map[int64]bool)
  481. for i := range issue.Labels {
  482. labelIDMark[issue.Labels[i].ID] = true
  483. }
  484. labels, err := models.GetLabelsByRepoID(repo.ID)
  485. if err != nil {
  486. ctx.Handle(500, "GetLabelsByRepoID", err)
  487. return
  488. }
  489. hasSelected := false
  490. for i := range labels {
  491. if labelIDMark[labels[i].ID] {
  492. labels[i].IsChecked = true
  493. hasSelected = true
  494. }
  495. }
  496. ctx.Data["HasSelectedLabel"] = hasSelected
  497. ctx.Data["Labels"] = labels
  498. // Check milestone and assignee.
  499. if ctx.Repo.IsWriter() {
  500. RetrieveRepoMilestonesAndAssignees(ctx, repo)
  501. if ctx.Written() {
  502. return
  503. }
  504. }
  505. if ctx.IsSigned {
  506. // Update issue-user.
  507. if err = issue.ReadBy(ctx.User.ID); err != nil {
  508. ctx.Handle(500, "ReadBy", err)
  509. return
  510. }
  511. }
  512. var (
  513. tag models.CommentTag
  514. ok bool
  515. marked = make(map[int64]models.CommentTag)
  516. comment *models.Comment
  517. participants = make([]*models.User, 1, 10)
  518. )
  519. // Render comments and and fetch participants.
  520. participants[0] = issue.Poster
  521. for _, comment = range issue.Comments {
  522. if comment.Type == models.COMMENT_TYPE_COMMENT {
  523. comment.RenderedContent = string(markdown.Render([]byte(comment.Content), ctx.Repo.RepoLink,
  524. ctx.Repo.Repository.ComposeMetas()))
  525. // Check tag.
  526. tag, ok = marked[comment.PosterID]
  527. if ok {
  528. comment.ShowTag = tag
  529. continue
  530. }
  531. if repo.IsOwnedBy(comment.PosterID) ||
  532. (repo.Owner.IsOrganization() && repo.Owner.IsOwnedBy(comment.PosterID)) {
  533. comment.ShowTag = models.COMMENT_TAG_OWNER
  534. } else if comment.Poster.IsWriterOfRepo(repo) {
  535. comment.ShowTag = models.COMMENT_TAG_WRITER
  536. } else if comment.PosterID == issue.PosterID {
  537. comment.ShowTag = models.COMMENT_TAG_POSTER
  538. }
  539. marked[comment.PosterID] = comment.ShowTag
  540. isAdded := false
  541. for j := range participants {
  542. if comment.Poster == participants[j] {
  543. isAdded = true
  544. break
  545. }
  546. }
  547. if !isAdded && !issue.IsPoster(comment.Poster.ID) {
  548. participants = append(participants, comment.Poster)
  549. }
  550. }
  551. }
  552. if issue.IsPull && issue.PullRequest.HasMerged {
  553. pull := issue.PullRequest
  554. ctx.Data["IsPullBranchDeletable"] = pull.BaseRepoID == pull.HeadRepoID &&
  555. ctx.Repo.IsWriter() && ctx.Repo.GitRepo.IsBranchExist(pull.HeadBranch)
  556. deleteBranchUrl := ctx.Repo.RepoLink + "/branches/delete/" + pull.HeadBranch
  557. ctx.Data["DeleteBranchLink"] = fmt.Sprintf("%s?commit=%s&redirect_to=%s", deleteBranchUrl, pull.MergedCommitID, ctx.Data["Link"])
  558. }
  559. ctx.Data["Participants"] = participants
  560. ctx.Data["NumParticipants"] = len(participants)
  561. ctx.Data["Issue"] = issue
  562. ctx.Data["IsIssueOwner"] = ctx.Repo.IsWriter() || (ctx.IsSigned && issue.IsPoster(ctx.User.ID))
  563. ctx.Data["SignInLink"] = setting.AppSubUrl + "/user/login?redirect_to=" + ctx.Data["Link"].(string)
  564. ctx.HTML(200, ISSUE_VIEW)
  565. }
  566. func getActionIssue(ctx *context.Context) *models.Issue {
  567. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.ID, ctx.ParamsInt64(":index"))
  568. if err != nil {
  569. ctx.NotFoundOrServerError("GetIssueByIndex", errors.IsIssueNotExist, err)
  570. return nil
  571. }
  572. return issue
  573. }
  574. func UpdateIssueTitle(ctx *context.Context) {
  575. issue := getActionIssue(ctx)
  576. if ctx.Written() {
  577. return
  578. }
  579. if !ctx.IsSigned || (!issue.IsPoster(ctx.User.ID) && !ctx.Repo.IsWriter()) {
  580. ctx.Error(403)
  581. return
  582. }
  583. title := ctx.QueryTrim("title")
  584. if len(title) == 0 {
  585. ctx.Error(204)
  586. return
  587. }
  588. if err := issue.ChangeTitle(ctx.User, title); err != nil {
  589. ctx.Handle(500, "ChangeTitle", err)
  590. return
  591. }
  592. ctx.JSON(200, map[string]interface{}{
  593. "title": issue.Title,
  594. })
  595. }
  596. func UpdateIssueContent(ctx *context.Context) {
  597. issue := getActionIssue(ctx)
  598. if ctx.Written() {
  599. return
  600. }
  601. if !ctx.IsSigned || (ctx.User.ID != issue.PosterID && !ctx.Repo.IsWriter()) {
  602. ctx.Error(403)
  603. return
  604. }
  605. content := ctx.Query("content")
  606. if err := issue.ChangeContent(ctx.User, content); err != nil {
  607. ctx.Handle(500, "ChangeContent", err)
  608. return
  609. }
  610. ctx.JSON(200, map[string]interface{}{
  611. "content": string(markdown.Render([]byte(issue.Content), ctx.Query("context"), ctx.Repo.Repository.ComposeMetas())),
  612. })
  613. }
  614. func UpdateIssueLabel(ctx *context.Context) {
  615. issue := getActionIssue(ctx)
  616. if ctx.Written() {
  617. return
  618. }
  619. if ctx.Query("action") == "clear" {
  620. if err := issue.ClearLabels(ctx.User); err != nil {
  621. ctx.Handle(500, "ClearLabels", err)
  622. return
  623. }
  624. } else {
  625. isAttach := ctx.Query("action") == "attach"
  626. label, err := models.GetLabelOfRepoByID(ctx.Repo.Repository.ID, ctx.QueryInt64("id"))
  627. if err != nil {
  628. if models.IsErrLabelNotExist(err) {
  629. ctx.Error(404, "GetLabelByID")
  630. } else {
  631. ctx.Handle(500, "GetLabelByID", err)
  632. }
  633. return
  634. }
  635. if isAttach && !issue.HasLabel(label.ID) {
  636. if err = issue.AddLabel(ctx.User, label); err != nil {
  637. ctx.Handle(500, "AddLabel", err)
  638. return
  639. }
  640. } else if !isAttach && issue.HasLabel(label.ID) {
  641. if err = issue.RemoveLabel(ctx.User, label); err != nil {
  642. ctx.Handle(500, "RemoveLabel", err)
  643. return
  644. }
  645. }
  646. }
  647. ctx.JSON(200, map[string]interface{}{
  648. "ok": true,
  649. })
  650. }
  651. func UpdateIssueMilestone(ctx *context.Context) {
  652. issue := getActionIssue(ctx)
  653. if ctx.Written() {
  654. return
  655. }
  656. oldMilestoneID := issue.MilestoneID
  657. milestoneID := ctx.QueryInt64("id")
  658. if oldMilestoneID == milestoneID {
  659. ctx.JSON(200, map[string]interface{}{
  660. "ok": true,
  661. })
  662. return
  663. }
  664. // Not check for invalid milestone id and give responsibility to owners.
  665. issue.MilestoneID = milestoneID
  666. if err := models.ChangeMilestoneAssign(ctx.User, issue, oldMilestoneID); err != nil {
  667. ctx.Handle(500, "ChangeMilestoneAssign", err)
  668. return
  669. }
  670. ctx.JSON(200, map[string]interface{}{
  671. "ok": true,
  672. })
  673. }
  674. func UpdateIssueAssignee(ctx *context.Context) {
  675. issue := getActionIssue(ctx)
  676. if ctx.Written() {
  677. return
  678. }
  679. assigneeID := ctx.QueryInt64("id")
  680. if issue.AssigneeID == assigneeID {
  681. ctx.JSON(200, map[string]interface{}{
  682. "ok": true,
  683. })
  684. return
  685. }
  686. if err := issue.ChangeAssignee(ctx.User, assigneeID); err != nil {
  687. ctx.Handle(500, "ChangeAssignee", err)
  688. return
  689. }
  690. ctx.JSON(200, map[string]interface{}{
  691. "ok": true,
  692. })
  693. }
  694. func NewComment(ctx *context.Context, f form.CreateComment) {
  695. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.ID, ctx.ParamsInt64(":index"))
  696. if err != nil {
  697. ctx.NotFoundOrServerError("GetIssueByIndex", errors.IsIssueNotExist, err)
  698. return
  699. }
  700. var attachments []string
  701. if setting.AttachmentEnabled {
  702. attachments = f.Files
  703. }
  704. if ctx.HasError() {
  705. ctx.Flash.Error(ctx.Data["ErrorMsg"].(string))
  706. ctx.Redirect(fmt.Sprintf("%s/issues/%d", ctx.Repo.RepoLink, issue.Index))
  707. return
  708. }
  709. var comment *models.Comment
  710. defer func() {
  711. // Check if issue admin/poster changes the status of issue.
  712. if (ctx.Repo.IsWriter() || (ctx.IsSigned && issue.IsPoster(ctx.User.ID))) &&
  713. (f.Status == "reopen" || f.Status == "close") &&
  714. !(issue.IsPull && issue.PullRequest.HasMerged) {
  715. // Duplication and conflict check should apply to reopen pull request.
  716. var pr *models.PullRequest
  717. if f.Status == "reopen" && issue.IsPull {
  718. pull := issue.PullRequest
  719. pr, err = models.GetUnmergedPullRequest(pull.HeadRepoID, pull.BaseRepoID, pull.HeadBranch, pull.BaseBranch)
  720. if err != nil {
  721. if !models.IsErrPullRequestNotExist(err) {
  722. ctx.Handle(500, "GetUnmergedPullRequest", err)
  723. return
  724. }
  725. }
  726. // Regenerate patch and test conflict.
  727. if pr == nil {
  728. if err = issue.PullRequest.UpdatePatch(); err != nil {
  729. ctx.Handle(500, "UpdatePatch", err)
  730. return
  731. }
  732. issue.PullRequest.AddToTaskQueue()
  733. }
  734. }
  735. if pr != nil {
  736. ctx.Flash.Info(ctx.Tr("repo.pulls.open_unmerged_pull_exists", pr.Index))
  737. } else {
  738. if err = issue.ChangeStatus(ctx.User, ctx.Repo.Repository, f.Status == "close"); err != nil {
  739. log.Error(4, "ChangeStatus: %v", err)
  740. } else {
  741. log.Trace("Issue [%d] status changed to closed: %v", issue.ID, issue.IsClosed)
  742. }
  743. }
  744. }
  745. // Redirect to comment hashtag if there is any actual content.
  746. typeName := "issues"
  747. if issue.IsPull {
  748. typeName = "pulls"
  749. }
  750. if comment != nil {
  751. ctx.Redirect(fmt.Sprintf("%s/%s/%d#%s", ctx.Repo.RepoLink, typeName, issue.Index, comment.HashTag()))
  752. } else {
  753. ctx.Redirect(fmt.Sprintf("%s/%s/%d", ctx.Repo.RepoLink, typeName, issue.Index))
  754. }
  755. }()
  756. // Fix #321: Allow empty comments, as long as we have attachments.
  757. if len(f.Content) == 0 && len(attachments) == 0 {
  758. return
  759. }
  760. comment, err = models.CreateIssueComment(ctx.User, ctx.Repo.Repository, issue, f.Content, attachments)
  761. if err != nil {
  762. ctx.Handle(500, "CreateIssueComment", err)
  763. return
  764. }
  765. log.Trace("Comment created: %d/%d/%d", ctx.Repo.Repository.ID, issue.ID, comment.ID)
  766. }
  767. func UpdateCommentContent(ctx *context.Context) {
  768. comment, err := models.GetCommentByID(ctx.ParamsInt64(":id"))
  769. if err != nil {
  770. ctx.NotFoundOrServerError("GetCommentByID", models.IsErrCommentNotExist, err)
  771. return
  772. }
  773. if !ctx.IsSigned || (ctx.User.ID != comment.PosterID && !ctx.Repo.IsAdmin()) {
  774. ctx.Error(403)
  775. return
  776. } else if comment.Type != models.COMMENT_TYPE_COMMENT {
  777. ctx.Error(204)
  778. return
  779. }
  780. oldContent := comment.Content
  781. comment.Content = ctx.Query("content")
  782. if len(comment.Content) == 0 {
  783. ctx.JSON(200, map[string]interface{}{
  784. "content": "",
  785. })
  786. return
  787. }
  788. if err = models.UpdateComment(ctx.User, comment, oldContent); err != nil {
  789. ctx.Handle(500, "UpdateComment", err)
  790. return
  791. }
  792. ctx.JSON(200, map[string]interface{}{
  793. "content": string(markdown.Render([]byte(comment.Content), ctx.Query("context"), ctx.Repo.Repository.ComposeMetas())),
  794. })
  795. }
  796. func DeleteComment(ctx *context.Context) {
  797. comment, err := models.GetCommentByID(ctx.ParamsInt64(":id"))
  798. if err != nil {
  799. ctx.NotFoundOrServerError("GetCommentByID", models.IsErrCommentNotExist, err)
  800. return
  801. }
  802. if !ctx.IsSigned || (ctx.User.ID != comment.PosterID && !ctx.Repo.IsAdmin()) {
  803. ctx.Error(403)
  804. return
  805. } else if comment.Type != models.COMMENT_TYPE_COMMENT {
  806. ctx.Error(204)
  807. return
  808. }
  809. if err = models.DeleteCommentByID(ctx.User, comment.ID); err != nil {
  810. ctx.Handle(500, "DeleteCommentByID", err)
  811. return
  812. }
  813. ctx.Status(200)
  814. }
  815. func Labels(ctx *context.Context) {
  816. ctx.Data["Title"] = ctx.Tr("repo.labels")
  817. ctx.Data["PageIsIssueList"] = true
  818. ctx.Data["PageIsLabels"] = true
  819. ctx.Data["RequireMinicolors"] = true
  820. ctx.Data["LabelTemplates"] = models.LabelTemplates
  821. ctx.HTML(200, LABELS)
  822. }
  823. func InitializeLabels(ctx *context.Context, f form.InitializeLabels) {
  824. if ctx.HasError() {
  825. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  826. return
  827. }
  828. list, err := models.GetLabelTemplateFile(f.TemplateName)
  829. if err != nil {
  830. ctx.Flash.Error(ctx.Tr("repo.issues.label_templates.fail_to_load_file", f.TemplateName, err))
  831. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  832. return
  833. }
  834. labels := make([]*models.Label, len(list))
  835. for i := 0; i < len(list); i++ {
  836. labels[i] = &models.Label{
  837. RepoID: ctx.Repo.Repository.ID,
  838. Name: list[i][0],
  839. Color: list[i][1],
  840. }
  841. }
  842. if err := models.NewLabels(labels...); err != nil {
  843. ctx.Handle(500, "NewLabels", err)
  844. return
  845. }
  846. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  847. }
  848. func NewLabel(ctx *context.Context, f form.CreateLabel) {
  849. ctx.Data["Title"] = ctx.Tr("repo.labels")
  850. ctx.Data["PageIsLabels"] = true
  851. if ctx.HasError() {
  852. ctx.Flash.Error(ctx.Data["ErrorMsg"].(string))
  853. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  854. return
  855. }
  856. l := &models.Label{
  857. RepoID: ctx.Repo.Repository.ID,
  858. Name: f.Title,
  859. Color: f.Color,
  860. }
  861. if err := models.NewLabels(l); err != nil {
  862. ctx.Handle(500, "NewLabel", err)
  863. return
  864. }
  865. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  866. }
  867. func UpdateLabel(ctx *context.Context, f form.CreateLabel) {
  868. l, err := models.GetLabelByID(f.ID)
  869. if err != nil {
  870. switch {
  871. case models.IsErrLabelNotExist(err):
  872. ctx.Error(404)
  873. default:
  874. ctx.Handle(500, "UpdateLabel", err)
  875. }
  876. return
  877. }
  878. l.Name = f.Title
  879. l.Color = f.Color
  880. if err := models.UpdateLabel(l); err != nil {
  881. ctx.Handle(500, "UpdateLabel", err)
  882. return
  883. }
  884. ctx.Redirect(ctx.Repo.RepoLink + "/labels")
  885. }
  886. func DeleteLabel(ctx *context.Context) {
  887. if err := models.DeleteLabel(ctx.Repo.Repository.ID, ctx.QueryInt64("id")); err != nil {
  888. ctx.Flash.Error("DeleteLabel: " + err.Error())
  889. } else {
  890. ctx.Flash.Success(ctx.Tr("repo.issues.label_deletion_success"))
  891. }
  892. ctx.JSON(200, map[string]interface{}{
  893. "redirect": ctx.Repo.RepoLink + "/labels",
  894. })
  895. return
  896. }
  897. func Milestones(ctx *context.Context) {
  898. ctx.Data["Title"] = ctx.Tr("repo.milestones")
  899. ctx.Data["PageIsIssueList"] = true
  900. ctx.Data["PageIsMilestones"] = true
  901. isShowClosed := ctx.Query("state") == "closed"
  902. openCount, closedCount := models.MilestoneStats(ctx.Repo.Repository.ID)
  903. ctx.Data["OpenCount"] = openCount
  904. ctx.Data["ClosedCount"] = closedCount
  905. page := ctx.QueryInt("page")
  906. if page <= 1 {
  907. page = 1
  908. }
  909. var total int
  910. if !isShowClosed {
  911. total = int(openCount)
  912. } else {
  913. total = int(closedCount)
  914. }
  915. ctx.Data["Page"] = paginater.New(total, setting.UI.IssuePagingNum, page, 5)
  916. miles, err := models.GetMilestones(ctx.Repo.Repository.ID, page, isShowClosed)
  917. if err != nil {
  918. ctx.Handle(500, "GetMilestones", err)
  919. return
  920. }
  921. for _, m := range miles {
  922. m.RenderedContent = string(markdown.Render([]byte(m.Content), ctx.Repo.RepoLink, ctx.Repo.Repository.ComposeMetas()))
  923. }
  924. ctx.Data["Milestones"] = miles
  925. if isShowClosed {
  926. ctx.Data["State"] = "closed"
  927. } else {
  928. ctx.Data["State"] = "open"
  929. }
  930. ctx.Data["IsShowClosed"] = isShowClosed
  931. ctx.HTML(200, MILESTONE)
  932. }
  933. func NewMilestone(ctx *context.Context) {
  934. ctx.Data["Title"] = ctx.Tr("repo.milestones.new")
  935. ctx.Data["PageIsIssueList"] = true
  936. ctx.Data["PageIsMilestones"] = true
  937. ctx.Data["RequireDatetimepicker"] = true
  938. ctx.Data["DateLang"] = setting.DateLang(ctx.Locale.Language())
  939. ctx.HTML(200, MILESTONE_NEW)
  940. }
  941. func NewMilestonePost(ctx *context.Context, f form.CreateMilestone) {
  942. ctx.Data["Title"] = ctx.Tr("repo.milestones.new")
  943. ctx.Data["PageIsIssueList"] = true
  944. ctx.Data["PageIsMilestones"] = true
  945. ctx.Data["RequireDatetimepicker"] = true
  946. ctx.Data["DateLang"] = setting.DateLang(ctx.Locale.Language())
  947. if ctx.HasError() {
  948. ctx.HTML(200, MILESTONE_NEW)
  949. return
  950. }
  951. if len(f.Deadline) == 0 {
  952. f.Deadline = "9999-12-31"
  953. }
  954. deadline, err := time.ParseInLocation("2006-01-02", f.Deadline, time.Local)
  955. if err != nil {
  956. ctx.Data["Err_Deadline"] = true
  957. ctx.RenderWithErr(ctx.Tr("repo.milestones.invalid_due_date_format"), MILESTONE_NEW, &f)
  958. return
  959. }
  960. if err = models.NewMilestone(&models.Milestone{
  961. RepoID: ctx.Repo.Repository.ID,
  962. Name: f.Title,
  963. Content: f.Content,
  964. Deadline: deadline,
  965. }); err != nil {
  966. ctx.Handle(500, "NewMilestone", err)
  967. return
  968. }
  969. ctx.Flash.Success(ctx.Tr("repo.milestones.create_success", f.Title))
  970. ctx.Redirect(ctx.Repo.RepoLink + "/milestones")
  971. }
  972. func EditMilestone(ctx *context.Context) {
  973. ctx.Data["Title"] = ctx.Tr("repo.milestones.edit")
  974. ctx.Data["PageIsMilestones"] = true
  975. ctx.Data["PageIsEditMilestone"] = true
  976. ctx.Data["RequireDatetimepicker"] = true
  977. ctx.Data["DateLang"] = setting.DateLang(ctx.Locale.Language())
  978. m, err := models.GetMilestoneByRepoID(ctx.Repo.Repository.ID, ctx.ParamsInt64(":id"))
  979. if err != nil {
  980. if models.IsErrMilestoneNotExist(err) {
  981. ctx.Handle(404, "", nil)
  982. } else {
  983. ctx.Handle(500, "GetMilestoneByRepoID", err)
  984. }
  985. return
  986. }
  987. ctx.Data["title"] = m.Name
  988. ctx.Data["content"] = m.Content
  989. if len(m.DeadlineString) > 0 {
  990. ctx.Data["deadline"] = m.DeadlineString
  991. }
  992. ctx.HTML(200, MILESTONE_NEW)
  993. }
  994. func EditMilestonePost(ctx *context.Context, f form.CreateMilestone) {
  995. ctx.Data["Title"] = ctx.Tr("repo.milestones.edit")
  996. ctx.Data["PageIsMilestones"] = true
  997. ctx.Data["PageIsEditMilestone"] = true
  998. ctx.Data["RequireDatetimepicker"] = true
  999. ctx.Data["DateLang"] = setting.DateLang(ctx.Locale.Language())
  1000. if ctx.HasError() {
  1001. ctx.HTML(200, MILESTONE_NEW)
  1002. return
  1003. }
  1004. if len(f.Deadline) == 0 {
  1005. f.Deadline = "9999-12-31"
  1006. }
  1007. deadline, err := time.ParseInLocation("2006-01-02", f.Deadline, time.Local)
  1008. if err != nil {
  1009. ctx.Data["Err_Deadline"] = true
  1010. ctx.RenderWithErr(ctx.Tr("repo.milestones.invalid_due_date_format"), MILESTONE_NEW, &f)
  1011. return
  1012. }
  1013. m, err := models.GetMilestoneByRepoID(ctx.Repo.Repository.ID, ctx.ParamsInt64(":id"))
  1014. if err != nil {
  1015. if models.IsErrMilestoneNotExist(err) {
  1016. ctx.Handle(404, "", nil)
  1017. } else {
  1018. ctx.Handle(500, "GetMilestoneByRepoID", err)
  1019. }
  1020. return
  1021. }
  1022. m.Name = f.Title
  1023. m.Content = f.Content
  1024. m.Deadline = deadline
  1025. if err = models.UpdateMilestone(m); err != nil {
  1026. ctx.Handle(500, "UpdateMilestone", err)
  1027. return
  1028. }
  1029. ctx.Flash.Success(ctx.Tr("repo.milestones.edit_success", m.Name))
  1030. ctx.Redirect(ctx.Repo.RepoLink + "/milestones")
  1031. }
  1032. func ChangeMilestonStatus(ctx *context.Context) {
  1033. m, err := models.GetMilestoneByRepoID(ctx.Repo.Repository.ID, ctx.ParamsInt64(":id"))
  1034. if err != nil {
  1035. if models.IsErrMilestoneNotExist(err) {
  1036. ctx.Handle(404, "", err)
  1037. } else {
  1038. ctx.Handle(500, "GetMilestoneByRepoID", err)
  1039. }
  1040. return
  1041. }
  1042. switch ctx.Params(":action") {
  1043. case "open":
  1044. if m.IsClosed {
  1045. if err = models.ChangeMilestoneStatus(m, false); err != nil {
  1046. ctx.Handle(500, "ChangeMilestoneStatus", err)
  1047. return
  1048. }
  1049. }
  1050. ctx.Redirect(ctx.Repo.RepoLink + "/milestones?state=open")
  1051. case "close":
  1052. if !m.IsClosed {
  1053. m.ClosedDate = time.Now()
  1054. if err = models.ChangeMilestoneStatus(m, true); err != nil {
  1055. ctx.Handle(500, "ChangeMilestoneStatus", err)
  1056. return
  1057. }
  1058. }
  1059. ctx.Redirect(ctx.Repo.RepoLink + "/milestones?state=closed")
  1060. default:
  1061. ctx.Redirect(ctx.Repo.RepoLink + "/milestones")
  1062. }
  1063. }
  1064. func DeleteMilestone(ctx *context.Context) {
  1065. if err := models.DeleteMilestoneOfRepoByID(ctx.Repo.Repository.ID, ctx.QueryInt64("id")); err != nil {
  1066. ctx.Flash.Error("DeleteMilestoneByRepoID: " + err.Error())
  1067. } else {
  1068. ctx.Flash.Success(ctx.Tr("repo.milestones.deletion_success"))
  1069. }
  1070. ctx.JSON(200, map[string]interface{}{
  1071. "redirect": ctx.Repo.RepoLink + "/milestones",
  1072. })
  1073. }