issue.go 29 KB

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