issue.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170
  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. "io"
  9. "io/ioutil"
  10. "net/http"
  11. "net/url"
  12. "strings"
  13. "time"
  14. "github.com/Unknwon/com"
  15. "github.com/gogits/gogs/models"
  16. "github.com/gogits/gogs/modules/auth"
  17. "github.com/gogits/gogs/modules/base"
  18. "github.com/gogits/gogs/modules/log"
  19. "github.com/gogits/gogs/modules/mailer"
  20. "github.com/gogits/gogs/modules/middleware"
  21. "github.com/gogits/gogs/modules/setting"
  22. )
  23. const (
  24. ISSUES base.TplName = "repo/issue/list"
  25. ISSUE_CREATE base.TplName = "repo/issue/create"
  26. ISSUE_VIEW base.TplName = "repo/issue/view"
  27. MILESTONE base.TplName = "repo/issue/milestone"
  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 Issues(ctx *middleware.Context) {
  36. ctx.Data["Title"] = ctx.Tr("repo.issues")
  37. ctx.Data["PageIsIssueList"] = true
  38. viewType := ctx.Query("type")
  39. types := []string{"assigned", "created_by", "mentioned"}
  40. if !com.IsSliceContainsStr(types, viewType) {
  41. viewType = "all"
  42. }
  43. isShowClosed := ctx.Query("state") == "closed"
  44. // Must sign in to see issues about you.
  45. if viewType != "all" && !ctx.IsSigned {
  46. ctx.SetCookie("redirect_to", "/"+url.QueryEscape(setting.AppSubUrl+ctx.Req.RequestURI), 0, setting.AppSubUrl)
  47. ctx.Redirect(setting.AppSubUrl + "/user/login")
  48. return
  49. }
  50. var assigneeId, posterId int64
  51. var filterMode int
  52. switch viewType {
  53. case "assigned":
  54. assigneeId = ctx.User.Id
  55. filterMode = models.FM_ASSIGN
  56. case "created_by":
  57. posterId = ctx.User.Id
  58. filterMode = models.FM_CREATE
  59. case "mentioned":
  60. filterMode = models.FM_MENTION
  61. }
  62. repo := ctx.Repo.Repository
  63. var mid int64
  64. midx := ctx.QueryInt64("milestone")
  65. if midx > 0 {
  66. mile, err := models.GetMilestoneByIndex(repo.Id, midx)
  67. if err != nil {
  68. ctx.Handle(500, "GetMilestoneByIndex: %v", err)
  69. return
  70. }
  71. mid = mile.Id
  72. }
  73. selectLabels := ctx.Query("labels")
  74. labels, err := models.GetLabels(repo.Id)
  75. if err != nil {
  76. ctx.Handle(500, "GetLabels: %v", err)
  77. return
  78. }
  79. for _, l := range labels {
  80. l.CalOpenIssues()
  81. }
  82. ctx.Data["Labels"] = labels
  83. page := ctx.QueryInt("page")
  84. if page <= 1 {
  85. page = 1
  86. } else {
  87. ctx.Data["PreviousPage"] = page - 1
  88. }
  89. if (!isShowClosed && repo.NumOpenIssues > setting.IssuePagingNum*page) ||
  90. (isShowClosed && repo.NumClosedIssues > setting.IssuePagingNum*page) {
  91. ctx.Data["NextPage"] = page + 1
  92. }
  93. // Get issues.
  94. issues, err := models.GetIssues(assigneeId, repo.Id, posterId, mid, page,
  95. isShowClosed, selectLabels, ctx.Query("sortType"))
  96. if err != nil {
  97. ctx.Handle(500, "GetIssues: %v", err)
  98. return
  99. }
  100. // Get issue-user pairs.
  101. pairs, err := models.GetIssueUserPairs(repo.Id, posterId, isShowClosed)
  102. if err != nil {
  103. ctx.Handle(500, "GetIssueUserPairs: %v", err)
  104. return
  105. }
  106. // Get posters.
  107. for i := range issues {
  108. if err = issues[i].GetLabels(); err != nil {
  109. ctx.Handle(500, "GetLabels", fmt.Errorf("[#%d]%v", issues[i].Id, err))
  110. return
  111. }
  112. idx := models.PairsContains(pairs, issues[i].Id, ctx.User.Id)
  113. if filterMode == models.FM_MENTION && (idx == -1 || !pairs[idx].IsMentioned) {
  114. continue
  115. }
  116. if idx > -1 {
  117. issues[i].IsRead = pairs[idx].IsRead
  118. } else {
  119. issues[i].IsRead = true
  120. }
  121. if err = issues[i].GetPoster(); err != nil {
  122. ctx.Handle(500, "GetPoster", fmt.Errorf("[#%d]%v", issues[i].Id, err))
  123. return
  124. }
  125. }
  126. var uid int64 = -1
  127. if ctx.User != nil {
  128. uid = ctx.User.Id
  129. }
  130. issueStats := models.GetIssueStats(repo.Id, uid, isShowClosed, filterMode)
  131. ctx.Data["IssueStats"] = issueStats
  132. ctx.Data["SelectLabels"] = com.StrTo(selectLabels).MustInt64()
  133. ctx.Data["ViewType"] = viewType
  134. ctx.Data["Issues"] = issues
  135. ctx.Data["IsShowClosed"] = isShowClosed
  136. if isShowClosed {
  137. ctx.Data["State"] = "closed"
  138. ctx.Data["ShowCount"] = issueStats.ClosedCount
  139. } else {
  140. ctx.Data["ShowCount"] = issueStats.OpenCount
  141. }
  142. ctx.HTML(200, ISSUES)
  143. }
  144. func CreateIssue(ctx *middleware.Context) {
  145. ctx.Data["Title"] = "Create issue"
  146. ctx.Data["IsRepoToolbarIssues"] = true
  147. ctx.Data["IsRepoToolbarIssuesList"] = false
  148. ctx.Data["AttachmentsEnabled"] = setting.AttachmentEnabled
  149. var err error
  150. // Get all milestones.
  151. ctx.Data["OpenMilestones"], err = models.GetMilestones(ctx.Repo.Repository.Id, false)
  152. if err != nil {
  153. ctx.Handle(500, "issue.ViewIssue(GetMilestones.1): %v", err)
  154. return
  155. }
  156. ctx.Data["ClosedMilestones"], err = models.GetMilestones(ctx.Repo.Repository.Id, true)
  157. if err != nil {
  158. ctx.Handle(500, "issue.ViewIssue(GetMilestones.2): %v", err)
  159. return
  160. }
  161. us, err := ctx.Repo.Repository.GetCollaborators()
  162. if err != nil {
  163. ctx.Handle(500, "issue.CreateIssue(GetCollaborators)", err)
  164. return
  165. }
  166. ctx.Data["AllowedTypes"] = setting.AttachmentAllowedTypes
  167. ctx.Data["Collaborators"] = us
  168. ctx.HTML(200, ISSUE_CREATE)
  169. }
  170. func CreateIssuePost(ctx *middleware.Context, form auth.CreateIssueForm) {
  171. send := func(status int, data interface{}, err error) {
  172. if err != nil {
  173. log.Error(4, "issue.CreateIssuePost(?): %s", err)
  174. ctx.JSON(status, map[string]interface{}{
  175. "ok": false,
  176. "status": status,
  177. "error": err.Error(),
  178. })
  179. } else {
  180. ctx.JSON(status, map[string]interface{}{
  181. "ok": true,
  182. "status": status,
  183. "data": data,
  184. })
  185. }
  186. }
  187. var err error
  188. // Get all milestones.
  189. _, err = models.GetMilestones(ctx.Repo.Repository.Id, false)
  190. if err != nil {
  191. send(500, nil, err)
  192. return
  193. }
  194. _, err = models.GetMilestones(ctx.Repo.Repository.Id, true)
  195. if err != nil {
  196. send(500, nil, err)
  197. return
  198. }
  199. _, err = ctx.Repo.Repository.GetCollaborators()
  200. if err != nil {
  201. send(500, nil, err)
  202. return
  203. }
  204. if ctx.HasError() {
  205. send(400, nil, errors.New(ctx.Flash.ErrorMsg))
  206. return
  207. }
  208. // Only collaborators can assign.
  209. if !ctx.Repo.IsOwner() {
  210. form.AssigneeId = 0
  211. }
  212. issue := &models.Issue{
  213. RepoId: ctx.Repo.Repository.Id,
  214. Index: int64(ctx.Repo.Repository.NumIssues) + 1,
  215. Name: form.IssueName,
  216. PosterId: ctx.User.Id,
  217. MilestoneId: form.MilestoneId,
  218. AssigneeId: form.AssigneeId,
  219. LabelIds: form.Labels,
  220. Content: form.Content,
  221. }
  222. if err := models.NewIssue(issue); err != nil {
  223. send(500, nil, err)
  224. return
  225. } else if err := models.NewIssueUserPairs(ctx.Repo.Repository, issue.Id, ctx.Repo.Owner.Id,
  226. ctx.User.Id, form.AssigneeId); err != nil {
  227. send(500, nil, err)
  228. return
  229. }
  230. if setting.AttachmentEnabled {
  231. uploadFiles(ctx, issue.Id, 0)
  232. }
  233. // Update mentions.
  234. ms := base.MentionPattern.FindAllString(issue.Content, -1)
  235. if len(ms) > 0 {
  236. for i := range ms {
  237. ms[i] = ms[i][1:]
  238. }
  239. if err := models.UpdateMentions(ms, issue.Id); err != nil {
  240. send(500, nil, err)
  241. return
  242. }
  243. }
  244. act := &models.Action{
  245. ActUserID: ctx.User.Id,
  246. ActUserName: ctx.User.Name,
  247. ActEmail: ctx.User.Email,
  248. OpType: models.CREATE_ISSUE,
  249. Content: fmt.Sprintf("%d|%s", issue.Index, issue.Name),
  250. RepoID: ctx.Repo.Repository.Id,
  251. RepoUserName: ctx.Repo.Owner.Name,
  252. RepoName: ctx.Repo.Repository.Name,
  253. RefName: ctx.Repo.BranchName,
  254. IsPrivate: ctx.Repo.Repository.IsPrivate,
  255. }
  256. // Notify watchers.
  257. if err := models.NotifyWatchers(act); err != nil {
  258. send(500, nil, err)
  259. return
  260. }
  261. // Mail watchers and mentions.
  262. if setting.Service.EnableNotifyMail {
  263. tos, err := mailer.SendIssueNotifyMail(ctx.User, ctx.Repo.Owner, ctx.Repo.Repository, issue)
  264. if err != nil {
  265. send(500, nil, err)
  266. return
  267. }
  268. tos = append(tos, ctx.User.LowerName)
  269. newTos := make([]string, 0, len(ms))
  270. for _, m := range ms {
  271. if com.IsSliceContainsStr(tos, m) {
  272. continue
  273. }
  274. newTos = append(newTos, m)
  275. }
  276. if err = mailer.SendIssueMentionMail(ctx.Render, ctx.User, ctx.Repo.Owner,
  277. ctx.Repo.Repository, issue, models.GetUserEmailsByNames(newTos)); err != nil {
  278. send(500, nil, err)
  279. return
  280. }
  281. }
  282. log.Trace("%d Issue created: %d", ctx.Repo.Repository.Id, issue.Id)
  283. send(200, fmt.Sprintf("%s/%s/%s/issues/%d", setting.AppSubUrl, ctx.Params(":username"), ctx.Params(":reponame"), issue.Index), nil)
  284. }
  285. func checkLabels(labels, allLabels []*models.Label) {
  286. for _, l := range labels {
  287. for _, l2 := range allLabels {
  288. if l.Id == l2.Id {
  289. l2.IsChecked = true
  290. break
  291. }
  292. }
  293. }
  294. }
  295. func ViewIssue(ctx *middleware.Context) {
  296. ctx.Data["AttachmentsEnabled"] = setting.AttachmentEnabled
  297. idx := com.StrTo(ctx.Params(":index")).MustInt64()
  298. if idx == 0 {
  299. ctx.Handle(404, "issue.ViewIssue", nil)
  300. return
  301. }
  302. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.Id, idx)
  303. if err != nil {
  304. if err == models.ErrIssueNotExist {
  305. ctx.Handle(404, "issue.ViewIssue(GetIssueByIndex)", err)
  306. } else {
  307. ctx.Handle(500, "issue.ViewIssue(GetIssueByIndex)", err)
  308. }
  309. return
  310. }
  311. // Get labels.
  312. if err = issue.GetLabels(); err != nil {
  313. ctx.Handle(500, "issue.ViewIssue(GetLabels)", err)
  314. return
  315. }
  316. labels, err := models.GetLabels(ctx.Repo.Repository.Id)
  317. if err != nil {
  318. ctx.Handle(500, "issue.ViewIssue(GetLabels.2)", err)
  319. return
  320. }
  321. checkLabels(issue.Labels, labels)
  322. ctx.Data["Labels"] = labels
  323. // Get assigned milestone.
  324. if issue.MilestoneId > 0 {
  325. ctx.Data["Milestone"], err = models.GetMilestoneById(issue.MilestoneId)
  326. if err != nil {
  327. if err == models.ErrMilestoneNotExist {
  328. log.Warn("issue.ViewIssue(GetMilestoneById): %v", err)
  329. } else {
  330. ctx.Handle(500, "issue.ViewIssue(GetMilestoneById)", err)
  331. return
  332. }
  333. }
  334. }
  335. // Get all milestones.
  336. ctx.Data["OpenMilestones"], err = models.GetMilestones(ctx.Repo.Repository.Id, false)
  337. if err != nil {
  338. ctx.Handle(500, "issue.ViewIssue(GetMilestones.1): %v", err)
  339. return
  340. }
  341. ctx.Data["ClosedMilestones"], err = models.GetMilestones(ctx.Repo.Repository.Id, true)
  342. if err != nil {
  343. ctx.Handle(500, "issue.ViewIssue(GetMilestones.2): %v", err)
  344. return
  345. }
  346. // Get all collaborators.
  347. ctx.Data["Collaborators"], err = ctx.Repo.Repository.GetCollaborators()
  348. if err != nil {
  349. ctx.Handle(500, "issue.CreateIssue(GetCollaborators)", err)
  350. return
  351. }
  352. if ctx.IsSigned {
  353. // Update issue-user.
  354. if err = models.UpdateIssueUserPairByRead(ctx.User.Id, issue.Id); err != nil {
  355. ctx.Handle(500, "issue.ViewIssue(UpdateIssueUserPairByRead): %v", err)
  356. return
  357. }
  358. }
  359. // Get poster and Assignee.
  360. if err = issue.GetPoster(); err != nil {
  361. ctx.Handle(500, "issue.ViewIssue(GetPoster): %v", err)
  362. return
  363. } else if err = issue.GetAssignee(); err != nil {
  364. ctx.Handle(500, "issue.ViewIssue(GetAssignee): %v", err)
  365. return
  366. }
  367. issue.RenderedContent = string(base.RenderMarkdown([]byte(issue.Content), ctx.Repo.RepoLink))
  368. // Get comments.
  369. comments, err := models.GetIssueComments(issue.Id)
  370. if err != nil {
  371. ctx.Handle(500, "issue.ViewIssue(GetIssueComments): %v", err)
  372. return
  373. }
  374. // Get posters.
  375. for i := range comments {
  376. u, err := models.GetUserById(comments[i].PosterId)
  377. if err != nil {
  378. ctx.Handle(500, "issue.ViewIssue(GetUserById.2): %v", err)
  379. return
  380. }
  381. comments[i].Poster = u
  382. if comments[i].Type == models.COMMENT_TYPE_COMMENT {
  383. comments[i].Content = string(base.RenderMarkdown([]byte(comments[i].Content), ctx.Repo.RepoLink))
  384. }
  385. }
  386. ctx.Data["AllowedTypes"] = setting.AttachmentAllowedTypes
  387. ctx.Data["Title"] = issue.Name
  388. ctx.Data["Issue"] = issue
  389. ctx.Data["Comments"] = comments
  390. ctx.Data["IsIssueOwner"] = ctx.Repo.IsOwner() || (ctx.IsSigned && issue.PosterId == ctx.User.Id)
  391. ctx.Data["IsRepoToolbarIssues"] = true
  392. ctx.Data["IsRepoToolbarIssuesList"] = false
  393. ctx.HTML(200, ISSUE_VIEW)
  394. }
  395. func UpdateIssue(ctx *middleware.Context, form auth.CreateIssueForm) {
  396. idx := com.StrTo(ctx.Params(":index")).MustInt64()
  397. if idx <= 0 {
  398. ctx.Error(404)
  399. return
  400. }
  401. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.Id, idx)
  402. if err != nil {
  403. if err == models.ErrIssueNotExist {
  404. ctx.Handle(404, "issue.UpdateIssue", err)
  405. } else {
  406. ctx.Handle(500, "issue.UpdateIssue(GetIssueByIndex)", err)
  407. }
  408. return
  409. }
  410. if ctx.User.Id != issue.PosterId && !ctx.Repo.IsOwner() {
  411. ctx.Error(403)
  412. return
  413. }
  414. issue.Name = form.IssueName
  415. //issue.MilestoneId = form.MilestoneId
  416. //issue.AssigneeId = form.AssigneeId
  417. //issue.LabelIds = form.Labels
  418. issue.Content = form.Content
  419. // try get content from text, ignore conflict with preview ajax
  420. if form.Content == "" {
  421. issue.Content = ctx.Query("text")
  422. }
  423. if err = models.UpdateIssue(issue); err != nil {
  424. ctx.Handle(500, "issue.UpdateIssue(UpdateIssue)", err)
  425. return
  426. }
  427. ctx.JSON(200, map[string]interface{}{
  428. "ok": true,
  429. "title": issue.Name,
  430. "content": string(base.RenderMarkdown([]byte(issue.Content), ctx.Repo.RepoLink)),
  431. })
  432. }
  433. func UpdateIssueLabel(ctx *middleware.Context) {
  434. if !ctx.Repo.IsOwner() {
  435. ctx.Error(403)
  436. return
  437. }
  438. idx := com.StrTo(ctx.Params(":index")).MustInt64()
  439. if idx <= 0 {
  440. ctx.Error(404)
  441. return
  442. }
  443. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.Id, idx)
  444. if err != nil {
  445. if err == models.ErrIssueNotExist {
  446. ctx.Handle(404, "issue.UpdateIssueLabel(GetIssueByIndex)", err)
  447. } else {
  448. ctx.Handle(500, "issue.UpdateIssueLabel(GetIssueByIndex)", err)
  449. }
  450. return
  451. }
  452. isAttach := ctx.Query("action") == "attach"
  453. labelStrId := ctx.Query("id")
  454. labelId := com.StrTo(labelStrId).MustInt64()
  455. label, err := models.GetLabelById(labelId)
  456. if err != nil {
  457. if err == models.ErrLabelNotExist {
  458. ctx.Handle(404, "issue.UpdateIssueLabel(GetLabelById)", err)
  459. } else {
  460. ctx.Handle(500, "issue.UpdateIssueLabel(GetLabelById)", err)
  461. }
  462. return
  463. }
  464. isHad := strings.Contains(issue.LabelIds, "$"+labelStrId+"|")
  465. isNeedUpdate := false
  466. if isAttach {
  467. if !isHad {
  468. issue.LabelIds += "$" + labelStrId + "|"
  469. isNeedUpdate = true
  470. }
  471. } else {
  472. if isHad {
  473. issue.LabelIds = strings.Replace(issue.LabelIds, "$"+labelStrId+"|", "", -1)
  474. isNeedUpdate = true
  475. }
  476. }
  477. if isNeedUpdate {
  478. if err = models.UpdateIssue(issue); err != nil {
  479. ctx.Handle(500, "issue.UpdateIssueLabel(UpdateIssue)", err)
  480. return
  481. }
  482. if isAttach {
  483. label.NumIssues++
  484. if issue.IsClosed {
  485. label.NumClosedIssues++
  486. }
  487. } else {
  488. label.NumIssues--
  489. if issue.IsClosed {
  490. label.NumClosedIssues--
  491. }
  492. }
  493. if err = models.UpdateLabel(label); err != nil {
  494. ctx.Handle(500, "issue.UpdateIssueLabel(UpdateLabel)", err)
  495. return
  496. }
  497. }
  498. ctx.JSON(200, map[string]interface{}{
  499. "ok": true,
  500. })
  501. }
  502. func UpdateIssueMilestone(ctx *middleware.Context) {
  503. if !ctx.Repo.IsOwner() {
  504. ctx.Error(403)
  505. return
  506. }
  507. issueId := com.StrTo(ctx.Query("issue")).MustInt64()
  508. if issueId == 0 {
  509. ctx.Error(404)
  510. return
  511. }
  512. issue, err := models.GetIssueById(issueId)
  513. if err != nil {
  514. if err == models.ErrIssueNotExist {
  515. ctx.Handle(404, "issue.UpdateIssueMilestone(GetIssueById)", err)
  516. } else {
  517. ctx.Handle(500, "issue.UpdateIssueMilestone(GetIssueById)", err)
  518. }
  519. return
  520. }
  521. oldMid := issue.MilestoneId
  522. mid := com.StrTo(ctx.Query("milestoneid")).MustInt64()
  523. if oldMid == mid {
  524. ctx.JSON(200, map[string]interface{}{
  525. "ok": true,
  526. })
  527. return
  528. }
  529. // Not check for invalid milestone id and give responsibility to owners.
  530. issue.MilestoneId = mid
  531. if err = models.ChangeMilestoneAssign(oldMid, mid, issue); err != nil {
  532. ctx.Handle(500, "issue.UpdateIssueMilestone(ChangeMilestoneAssign)", err)
  533. return
  534. } else if err = models.UpdateIssue(issue); err != nil {
  535. ctx.Handle(500, "issue.UpdateIssueMilestone(UpdateIssue)", err)
  536. return
  537. }
  538. ctx.JSON(200, map[string]interface{}{
  539. "ok": true,
  540. })
  541. }
  542. func UpdateAssignee(ctx *middleware.Context) {
  543. if !ctx.Repo.IsOwner() {
  544. ctx.Error(403)
  545. return
  546. }
  547. issueId := com.StrTo(ctx.Query("issue")).MustInt64()
  548. if issueId == 0 {
  549. ctx.Error(404)
  550. return
  551. }
  552. issue, err := models.GetIssueById(issueId)
  553. if err != nil {
  554. if err == models.ErrIssueNotExist {
  555. ctx.Handle(404, "GetIssueById", err)
  556. } else {
  557. ctx.Handle(500, "GetIssueById", err)
  558. }
  559. return
  560. }
  561. aid := com.StrTo(ctx.Query("assigneeid")).MustInt64()
  562. // Not check for invalid assignee id and give responsibility to owners.
  563. issue.AssigneeId = aid
  564. if err = models.UpdateIssueUserPairByAssignee(aid, issue.Id); err != nil {
  565. ctx.Handle(500, "UpdateIssueUserPairByAssignee: %v", err)
  566. return
  567. } else if err = models.UpdateIssue(issue); err != nil {
  568. ctx.Handle(500, "UpdateIssue", err)
  569. return
  570. }
  571. ctx.JSON(200, map[string]interface{}{
  572. "ok": true,
  573. })
  574. }
  575. func uploadFiles(ctx *middleware.Context, issueId, commentId int64) {
  576. if !setting.AttachmentEnabled {
  577. return
  578. }
  579. allowedTypes := strings.Split(setting.AttachmentAllowedTypes, "|")
  580. attachments := ctx.Req.MultipartForm.File["attachments"]
  581. if len(attachments) > setting.AttachmentMaxFiles {
  582. ctx.Handle(400, "issue.Comment", ErrTooManyFiles)
  583. return
  584. }
  585. for _, header := range attachments {
  586. file, err := header.Open()
  587. if err != nil {
  588. ctx.Handle(500, "issue.Comment(header.Open)", err)
  589. return
  590. }
  591. defer file.Close()
  592. buf := make([]byte, 1024)
  593. n, _ := file.Read(buf)
  594. if n > 0 {
  595. buf = buf[:n]
  596. }
  597. fileType := http.DetectContentType(buf)
  598. fmt.Println(fileType)
  599. allowed := false
  600. for _, t := range allowedTypes {
  601. t := strings.Trim(t, " ")
  602. if t == "*/*" || t == fileType {
  603. allowed = true
  604. break
  605. }
  606. }
  607. if !allowed {
  608. ctx.Handle(400, "issue.Comment", ErrFileTypeForbidden)
  609. return
  610. }
  611. out, err := ioutil.TempFile(setting.AttachmentPath, "attachment_")
  612. if err != nil {
  613. ctx.Handle(500, "ioutil.TempFile", err)
  614. return
  615. }
  616. defer out.Close()
  617. out.Write(buf)
  618. _, err = io.Copy(out, file)
  619. if err != nil {
  620. ctx.Handle(500, "io.Copy", err)
  621. return
  622. }
  623. _, err = models.CreateAttachment(issueId, commentId, header.Filename, out.Name())
  624. if err != nil {
  625. ctx.Handle(500, "CreateAttachment", err)
  626. return
  627. }
  628. }
  629. }
  630. func Comment(ctx *middleware.Context) {
  631. send := func(status int, data interface{}, err error) {
  632. if err != nil {
  633. log.Error(4, "issue.Comment(?): %s", err)
  634. ctx.JSON(status, map[string]interface{}{
  635. "ok": false,
  636. "status": status,
  637. "error": err.Error(),
  638. })
  639. } else {
  640. ctx.JSON(status, map[string]interface{}{
  641. "ok": true,
  642. "status": status,
  643. "data": data,
  644. })
  645. }
  646. }
  647. index := com.StrTo(ctx.Query("issueIndex")).MustInt64()
  648. if index == 0 {
  649. ctx.Error(404)
  650. return
  651. }
  652. issue, err := models.GetIssueByIndex(ctx.Repo.Repository.Id, index)
  653. if err != nil {
  654. if err == models.ErrIssueNotExist {
  655. send(404, nil, err)
  656. } else {
  657. send(200, nil, err)
  658. }
  659. return
  660. }
  661. // Check if issue owner changes the status of issue.
  662. var newStatus string
  663. if ctx.Repo.IsOwner() || issue.PosterId == ctx.User.Id {
  664. newStatus = ctx.Query("change_status")
  665. }
  666. if len(newStatus) > 0 {
  667. if (strings.Contains(newStatus, "Reopen") && issue.IsClosed) ||
  668. (strings.Contains(newStatus, "Close") && !issue.IsClosed) {
  669. issue.IsClosed = !issue.IsClosed
  670. if err = models.UpdateIssue(issue); err != nil {
  671. send(500, nil, err)
  672. return
  673. } else if err = models.UpdateIssueUserPairsByStatus(issue.Id, issue.IsClosed); err != nil {
  674. send(500, nil, err)
  675. return
  676. }
  677. if err = issue.GetLabels(); err != nil {
  678. send(500, nil, err)
  679. return
  680. }
  681. for _, label := range issue.Labels {
  682. if issue.IsClosed {
  683. label.NumClosedIssues++
  684. } else {
  685. label.NumClosedIssues--
  686. }
  687. if err = models.UpdateLabel(label); err != nil {
  688. send(500, nil, err)
  689. return
  690. }
  691. }
  692. // Change open/closed issue counter for the associated milestone
  693. if issue.MilestoneId > 0 {
  694. if err = models.ChangeMilestoneIssueStats(issue); err != nil {
  695. send(500, nil, err)
  696. }
  697. }
  698. cmtType := models.COMMENT_TYPE_CLOSE
  699. if !issue.IsClosed {
  700. cmtType = models.COMMENT_TYPE_REOPEN
  701. }
  702. if _, err = models.CreateComment(ctx.User.Id, ctx.Repo.Repository.Id, issue.Id, 0, 0, cmtType, "", nil); err != nil {
  703. send(200, nil, err)
  704. return
  705. }
  706. log.Trace("%s Issue(%d) status changed: %v", ctx.Req.RequestURI, issue.Id, !issue.IsClosed)
  707. }
  708. }
  709. var comment *models.Comment
  710. var ms []string
  711. content := ctx.Query("content")
  712. // Fix #321. Allow empty comments, as long as we have attachments.
  713. if len(content) > 0 || len(ctx.Req.MultipartForm.File["attachments"]) > 0 {
  714. switch ctx.Params(":action") {
  715. case "new":
  716. if comment, err = models.CreateComment(ctx.User.Id, ctx.Repo.Repository.Id, issue.Id, 0, 0, models.COMMENT_TYPE_COMMENT, content, nil); err != nil {
  717. send(500, nil, err)
  718. return
  719. }
  720. // Update mentions.
  721. ms = base.MentionPattern.FindAllString(issue.Content, -1)
  722. if len(ms) > 0 {
  723. for i := range ms {
  724. ms[i] = ms[i][1:]
  725. }
  726. if err := models.UpdateMentions(ms, issue.Id); err != nil {
  727. send(500, nil, err)
  728. return
  729. }
  730. }
  731. log.Trace("%s Comment created: %d", ctx.Req.RequestURI, issue.Id)
  732. default:
  733. ctx.Handle(404, "issue.Comment", err)
  734. return
  735. }
  736. }
  737. if comment != nil {
  738. uploadFiles(ctx, issue.Id, comment.Id)
  739. }
  740. // Notify watchers.
  741. act := &models.Action{
  742. ActUserID: ctx.User.Id,
  743. ActUserName: ctx.User.LowerName,
  744. ActEmail: ctx.User.Email,
  745. OpType: models.COMMENT_ISSUE,
  746. Content: fmt.Sprintf("%d|%s", issue.Index, strings.Split(content, "\n")[0]),
  747. RepoID: ctx.Repo.Repository.Id,
  748. RepoUserName: ctx.Repo.Owner.LowerName,
  749. RepoName: ctx.Repo.Repository.LowerName,
  750. IsPrivate: ctx.Repo.Repository.IsPrivate,
  751. }
  752. if err = models.NotifyWatchers(act); err != nil {
  753. send(500, nil, err)
  754. return
  755. }
  756. // Mail watchers and mentions.
  757. if setting.Service.EnableNotifyMail {
  758. issue.Content = content
  759. tos, err := mailer.SendIssueNotifyMail(ctx.User, ctx.Repo.Owner, ctx.Repo.Repository, issue)
  760. if err != nil {
  761. send(500, nil, err)
  762. return
  763. }
  764. tos = append(tos, ctx.User.LowerName)
  765. newTos := make([]string, 0, len(ms))
  766. for _, m := range ms {
  767. if com.IsSliceContainsStr(tos, m) {
  768. continue
  769. }
  770. newTos = append(newTos, m)
  771. }
  772. if err = mailer.SendIssueMentionMail(ctx.Render, ctx.User, ctx.Repo.Owner,
  773. ctx.Repo.Repository, issue, models.GetUserEmailsByNames(newTos)); err != nil {
  774. send(500, nil, err)
  775. return
  776. }
  777. }
  778. send(200, fmt.Sprintf("%s/issues/%d", ctx.Repo.RepoLink, index), nil)
  779. }
  780. func NewLabel(ctx *middleware.Context, form auth.CreateLabelForm) {
  781. if ctx.HasError() {
  782. Issues(ctx)
  783. return
  784. }
  785. l := &models.Label{
  786. RepoId: ctx.Repo.Repository.Id,
  787. Name: form.Title,
  788. Color: form.Color,
  789. }
  790. if err := models.NewLabel(l); err != nil {
  791. ctx.Handle(500, "issue.NewLabel(NewLabel)", err)
  792. return
  793. }
  794. ctx.Redirect(ctx.Repo.RepoLink + "/issues")
  795. }
  796. func UpdateLabel(ctx *middleware.Context, form auth.CreateLabelForm) {
  797. id := com.StrTo(ctx.Query("id")).MustInt64()
  798. if id == 0 {
  799. ctx.Error(404)
  800. return
  801. }
  802. l := &models.Label{
  803. Id: id,
  804. Name: form.Title,
  805. Color: form.Color,
  806. }
  807. if err := models.UpdateLabel(l); err != nil {
  808. ctx.Handle(500, "issue.UpdateLabel(UpdateLabel)", err)
  809. return
  810. }
  811. ctx.Redirect(ctx.Repo.RepoLink + "/issues")
  812. }
  813. func DeleteLabel(ctx *middleware.Context) {
  814. removes := ctx.Query("remove")
  815. if len(strings.TrimSpace(removes)) == 0 {
  816. ctx.JSON(200, map[string]interface{}{
  817. "ok": true,
  818. })
  819. return
  820. }
  821. strIds := strings.Split(removes, ",")
  822. for _, strId := range strIds {
  823. if err := models.DeleteLabel(ctx.Repo.Repository.Id, strId); err != nil {
  824. ctx.Handle(500, "issue.DeleteLabel(DeleteLabel)", err)
  825. return
  826. }
  827. }
  828. ctx.JSON(200, map[string]interface{}{
  829. "ok": true,
  830. })
  831. }
  832. func Milestones(ctx *middleware.Context) {
  833. ctx.Data["Title"] = "Milestones"
  834. ctx.Data["IsRepoToolbarIssues"] = true
  835. ctx.Data["IsRepoToolbarIssuesList"] = true
  836. isShowClosed := ctx.Query("state") == "closed"
  837. miles, err := models.GetMilestones(ctx.Repo.Repository.Id, isShowClosed)
  838. if err != nil {
  839. ctx.Handle(500, "issue.Milestones(GetMilestones)", err)
  840. return
  841. }
  842. for _, m := range miles {
  843. m.RenderedContent = string(base.RenderMarkdown([]byte(m.Content), ctx.Repo.RepoLink))
  844. m.CalOpenIssues()
  845. }
  846. ctx.Data["Milestones"] = miles
  847. if isShowClosed {
  848. ctx.Data["State"] = "closed"
  849. } else {
  850. ctx.Data["State"] = "open"
  851. }
  852. ctx.HTML(200, MILESTONE)
  853. }
  854. func NewMilestone(ctx *middleware.Context) {
  855. ctx.Data["Title"] = "New Milestone"
  856. ctx.Data["IsRepoToolbarIssues"] = true
  857. ctx.Data["IsRepoToolbarIssuesList"] = true
  858. ctx.HTML(200, MILESTONE_NEW)
  859. }
  860. func NewMilestonePost(ctx *middleware.Context, form auth.CreateMilestoneForm) {
  861. ctx.Data["Title"] = "New Milestone"
  862. ctx.Data["IsRepoToolbarIssues"] = true
  863. ctx.Data["IsRepoToolbarIssuesList"] = true
  864. if ctx.HasError() {
  865. ctx.HTML(200, MILESTONE_NEW)
  866. return
  867. }
  868. var deadline time.Time
  869. var err error
  870. if len(form.Deadline) == 0 {
  871. form.Deadline = "12/31/9999"
  872. }
  873. deadline, err = time.Parse("01/02/2006", form.Deadline)
  874. if err != nil {
  875. ctx.Handle(500, "issue.NewMilestonePost(time.Parse)", err)
  876. return
  877. }
  878. mile := &models.Milestone{
  879. RepoId: ctx.Repo.Repository.Id,
  880. Index: int64(ctx.Repo.Repository.NumMilestones) + 1,
  881. Name: form.Title,
  882. Content: form.Content,
  883. Deadline: deadline,
  884. }
  885. if err = models.NewMilestone(mile); err != nil {
  886. ctx.Handle(500, "issue.NewMilestonePost(NewMilestone)", err)
  887. return
  888. }
  889. ctx.Redirect(ctx.Repo.RepoLink + "/issues/milestones")
  890. }
  891. func UpdateMilestone(ctx *middleware.Context) {
  892. ctx.Data["Title"] = "Update Milestone"
  893. ctx.Data["IsRepoToolbarIssues"] = true
  894. ctx.Data["IsRepoToolbarIssuesList"] = true
  895. idx := com.StrTo(ctx.Params(":index")).MustInt64()
  896. if idx == 0 {
  897. ctx.Handle(404, "issue.UpdateMilestone", nil)
  898. return
  899. }
  900. mile, err := models.GetMilestoneByIndex(ctx.Repo.Repository.Id, idx)
  901. if err != nil {
  902. if err == models.ErrMilestoneNotExist {
  903. ctx.Handle(404, "issue.UpdateMilestone(GetMilestoneByIndex)", err)
  904. } else {
  905. ctx.Handle(500, "issue.UpdateMilestone(GetMilestoneByIndex)", err)
  906. }
  907. return
  908. }
  909. action := ctx.Params(":action")
  910. if len(action) > 0 {
  911. switch action {
  912. case "open":
  913. if mile.IsClosed {
  914. if err = models.ChangeMilestoneStatus(mile, false); err != nil {
  915. ctx.Handle(500, "issue.UpdateMilestone(ChangeMilestoneStatus)", err)
  916. return
  917. }
  918. }
  919. case "close":
  920. if !mile.IsClosed {
  921. mile.ClosedDate = time.Now()
  922. if err = models.ChangeMilestoneStatus(mile, true); err != nil {
  923. ctx.Handle(500, "issue.UpdateMilestone(ChangeMilestoneStatus)", err)
  924. return
  925. }
  926. }
  927. case "delete":
  928. if err = models.DeleteMilestone(mile); err != nil {
  929. ctx.Handle(500, "issue.UpdateMilestone(DeleteMilestone)", err)
  930. return
  931. }
  932. }
  933. ctx.Redirect(ctx.Repo.RepoLink + "/issues/milestones")
  934. return
  935. }
  936. mile.DeadlineString = mile.Deadline.UTC().Format("01/02/2006")
  937. if mile.DeadlineString == "12/31/9999" {
  938. mile.DeadlineString = ""
  939. }
  940. ctx.Data["Milestone"] = mile
  941. ctx.HTML(200, MILESTONE_EDIT)
  942. }
  943. func UpdateMilestonePost(ctx *middleware.Context, form auth.CreateMilestoneForm) {
  944. ctx.Data["Title"] = "Update Milestone"
  945. ctx.Data["IsRepoToolbarIssues"] = true
  946. ctx.Data["IsRepoToolbarIssuesList"] = true
  947. idx := com.StrTo(ctx.Params(":index")).MustInt64()
  948. if idx == 0 {
  949. ctx.Handle(404, "issue.UpdateMilestonePost", nil)
  950. return
  951. }
  952. mile, err := models.GetMilestoneByIndex(ctx.Repo.Repository.Id, idx)
  953. if err != nil {
  954. if err == models.ErrMilestoneNotExist {
  955. ctx.Handle(404, "issue.UpdateMilestonePost(GetMilestoneByIndex)", err)
  956. } else {
  957. ctx.Handle(500, "issue.UpdateMilestonePost(GetMilestoneByIndex)", err)
  958. }
  959. return
  960. }
  961. if ctx.HasError() {
  962. ctx.HTML(200, MILESTONE_EDIT)
  963. return
  964. }
  965. var deadline time.Time
  966. if len(form.Deadline) == 0 {
  967. form.Deadline = "12/31/9999"
  968. }
  969. deadline, err = time.Parse("01/02/2006", form.Deadline)
  970. if err != nil {
  971. ctx.Handle(500, "issue.UpdateMilestonePost(time.Parse)", err)
  972. return
  973. }
  974. mile.Name = form.Title
  975. mile.Content = form.Content
  976. mile.Deadline = deadline
  977. if err = models.UpdateMilestone(mile); err != nil {
  978. ctx.Handle(500, "issue.UpdateMilestonePost(UpdateMilestone)", err)
  979. return
  980. }
  981. ctx.Redirect(ctx.Repo.RepoLink + "/issues/milestones")
  982. }
  983. func IssueGetAttachment(ctx *middleware.Context) {
  984. id := com.StrTo(ctx.Params(":id")).MustInt64()
  985. if id == 0 {
  986. ctx.Error(404)
  987. return
  988. }
  989. attachment, err := models.GetAttachmentById(id)
  990. if err != nil {
  991. ctx.Handle(404, "issue.IssueGetAttachment(models.GetAttachmentById)", err)
  992. return
  993. }
  994. // Fix #312. Attachments with , in their name are not handled correctly by Google Chrome.
  995. // We must put the name in " manually.
  996. ctx.ServeFile(attachment.Path, "\""+attachment.Name+"\"")
  997. }
  998. // testing route handler for new issue ui page
  999. // todo : move to Issue() function
  1000. func Issues2(ctx *middleware.Context) {
  1001. ctx.HTML(200, "repo/issue2/list")
  1002. }
  1003. func PullRequest2(ctx *middleware.Context) {
  1004. ctx.HTML(200, "repo/pr2/list")
  1005. }
  1006. func Labels2(ctx *middleware.Context) {
  1007. ctx.HTML(200, "repo/issue2/labels")
  1008. }
  1009. func Milestones2(ctx *middleware.Context) {
  1010. ctx.HTML(200, "repo/milestone2/list")
  1011. }