setting.go 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585
  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. "encoding/json"
  7. "errors"
  8. "fmt"
  9. "strings"
  10. "time"
  11. "github.com/Unknwon/com"
  12. "github.com/gogits/gogs/models"
  13. "github.com/gogits/gogs/modules/auth"
  14. "github.com/gogits/gogs/modules/base"
  15. "github.com/gogits/gogs/modules/log"
  16. "github.com/gogits/gogs/modules/mailer"
  17. "github.com/gogits/gogs/modules/middleware"
  18. "github.com/gogits/gogs/modules/setting"
  19. )
  20. const (
  21. SETTINGS_OPTIONS base.TplName = "repo/settings/options"
  22. COLLABORATION base.TplName = "repo/settings/collaboration"
  23. HOOKS base.TplName = "repo/settings/hooks"
  24. HOOK_NEW base.TplName = "repo/settings/hook_new"
  25. ORG_HOOK_NEW base.TplName = "org/settings/hook_new"
  26. )
  27. func Settings(ctx *middleware.Context) {
  28. ctx.Data["Title"] = ctx.Tr("repo.settings")
  29. ctx.Data["PageIsSettingsOptions"] = true
  30. ctx.HTML(200, SETTINGS_OPTIONS)
  31. }
  32. func SettingsPost(ctx *middleware.Context, form auth.RepoSettingForm) {
  33. ctx.Data["Title"] = ctx.Tr("repo.settings")
  34. ctx.Data["PageIsSettingsOptions"] = true
  35. switch ctx.Query("action") {
  36. case "update":
  37. if ctx.HasError() {
  38. ctx.HTML(200, SETTINGS_OPTIONS)
  39. return
  40. }
  41. newRepoName := form.RepoName
  42. // Check if repository name has been changed.
  43. if ctx.Repo.Repository.Name != newRepoName {
  44. isExist, err := models.IsRepositoryExist(ctx.Repo.Owner, newRepoName)
  45. if err != nil {
  46. ctx.Handle(500, "IsRepositoryExist", err)
  47. return
  48. } else if isExist {
  49. ctx.Data["Err_RepoName"] = true
  50. ctx.RenderWithErr(ctx.Tr("form.repo_name_been_taken"), SETTINGS_OPTIONS, nil)
  51. return
  52. } else if err = models.ChangeRepositoryName(ctx.Repo.Owner.Name, ctx.Repo.Repository.Name, newRepoName); err != nil {
  53. if err == models.ErrRepoNameIllegal {
  54. ctx.Data["Err_RepoName"] = true
  55. ctx.RenderWithErr(ctx.Tr("form.illegal_repo_name"), SETTINGS_OPTIONS, nil)
  56. } else {
  57. ctx.Handle(500, "ChangeRepositoryName", err)
  58. }
  59. return
  60. }
  61. log.Trace("Repository name changed: %s/%s -> %s", ctx.Repo.Owner.Name, ctx.Repo.Repository.Name, newRepoName)
  62. ctx.Repo.Repository.Name = newRepoName
  63. }
  64. br := form.Branch
  65. if ctx.Repo.GitRepo.IsBranchExist(br) {
  66. ctx.Repo.Repository.DefaultBranch = br
  67. }
  68. ctx.Repo.Repository.Description = form.Description
  69. ctx.Repo.Repository.Website = form.Website
  70. ctx.Repo.Repository.IsPrivate = form.Private
  71. ctx.Repo.Repository.IsGoget = form.GoGet
  72. if err := models.UpdateRepository(ctx.Repo.Repository); err != nil {
  73. ctx.Handle(404, "UpdateRepository", err)
  74. return
  75. }
  76. log.Trace("Repository updated: %s/%s", ctx.Repo.Owner.Name, ctx.Repo.Repository.Name)
  77. if ctx.Repo.Repository.IsMirror {
  78. if form.Interval > 0 {
  79. ctx.Repo.Mirror.Interval = form.Interval
  80. ctx.Repo.Mirror.NextUpdate = time.Now().Add(time.Duration(form.Interval) * time.Hour)
  81. if err := models.UpdateMirror(ctx.Repo.Mirror); err != nil {
  82. log.Error(4, "UpdateMirror: %v", err)
  83. }
  84. }
  85. }
  86. ctx.Flash.Success(ctx.Tr("repo.settings.update_settings_success"))
  87. ctx.Redirect(fmt.Sprintf("/%s/%s/settings", ctx.Repo.Owner.Name, ctx.Repo.Repository.Name))
  88. case "transfer":
  89. if ctx.Repo.Repository.Name != form.RepoName {
  90. ctx.RenderWithErr(ctx.Tr("form.enterred_invalid_repo_name"), SETTINGS_OPTIONS, nil)
  91. return
  92. }
  93. newOwner := ctx.Query("new_owner_name")
  94. isExist, err := models.IsUserExist(newOwner)
  95. if err != nil {
  96. ctx.Handle(500, "IsUserExist", err)
  97. return
  98. } else if !isExist {
  99. ctx.RenderWithErr(ctx.Tr("form.enterred_invalid_owner_name"), SETTINGS_OPTIONS, nil)
  100. return
  101. } else if err = models.TransferOwnership(ctx.Repo.Owner, newOwner, ctx.Repo.Repository); err != nil {
  102. ctx.Handle(500, "TransferOwnership", err)
  103. return
  104. }
  105. log.Trace("Repository transfered: %s/%s -> %s", ctx.Repo.Owner.Name, ctx.Repo.Repository.Name, newOwner)
  106. ctx.Redirect("/")
  107. case "delete":
  108. if ctx.Repo.Repository.Name != form.RepoName {
  109. ctx.RenderWithErr(ctx.Tr("form.enterred_invalid_repo_name"), SETTINGS_OPTIONS, nil)
  110. return
  111. }
  112. if ctx.Repo.Owner.IsOrganization() {
  113. if !ctx.Repo.Owner.IsOrgOwner(ctx.User.Id) {
  114. ctx.Error(404)
  115. return
  116. }
  117. if !ctx.User.ValidtePassword(ctx.Query("password")) {
  118. ctx.RenderWithErr(ctx.Tr("form.enterred_invalid_password"), SETTINGS_OPTIONS, nil)
  119. return
  120. }
  121. } else {
  122. if !ctx.Repo.Owner.ValidtePassword(ctx.Query("password")) {
  123. ctx.RenderWithErr(ctx.Tr("form.enterred_invalid_password"), SETTINGS_OPTIONS, nil)
  124. return
  125. }
  126. }
  127. if err := models.DeleteRepository(ctx.Repo.Owner.Id, ctx.Repo.Repository.Id, ctx.Repo.Owner.Name); err != nil {
  128. ctx.Handle(500, "DeleteRepository", err)
  129. return
  130. }
  131. log.Trace("Repository deleted: %s/%s", ctx.Repo.Owner.Name, ctx.Repo.Repository.Name)
  132. if ctx.Repo.Owner.IsOrganization() {
  133. ctx.Redirect("/org/" + ctx.Repo.Owner.Name + "/dashboard")
  134. } else {
  135. ctx.Redirect("/")
  136. }
  137. }
  138. }
  139. func SettingsCollaboration(ctx *middleware.Context) {
  140. ctx.Data["Title"] = ctx.Tr("repo.settings")
  141. ctx.Data["PageIsSettingsCollaboration"] = true
  142. repoLink := strings.TrimPrefix(ctx.Repo.RepoLink, "/")
  143. if ctx.Req.Method == "POST" {
  144. name := strings.ToLower(ctx.Query("collaborator"))
  145. if len(name) == 0 || ctx.Repo.Owner.LowerName == name {
  146. ctx.Redirect(ctx.Req.URL.Path)
  147. return
  148. }
  149. has, err := models.HasAccess(name, repoLink, models.WRITABLE)
  150. if err != nil {
  151. ctx.Handle(500, "HasAccess", err)
  152. return
  153. } else if has {
  154. ctx.Redirect(ctx.Req.URL.Path)
  155. return
  156. }
  157. u, err := models.GetUserByName(name)
  158. if err != nil {
  159. if err == models.ErrUserNotExist {
  160. ctx.Flash.Error(ctx.Tr("form.user_not_exist"))
  161. ctx.Redirect(ctx.Req.URL.Path)
  162. } else {
  163. ctx.Handle(500, "GetUserByName", err)
  164. }
  165. return
  166. }
  167. if err = models.AddAccess(&models.Access{UserName: name, RepoName: repoLink,
  168. Mode: models.WRITABLE}); err != nil {
  169. ctx.Handle(500, "AddAccess2", err)
  170. return
  171. }
  172. if setting.Service.EnableNotifyMail {
  173. if err = mailer.SendCollaboratorMail(ctx.Render, u, ctx.User, ctx.Repo.Repository); err != nil {
  174. ctx.Handle(500, "SendCollaboratorMail", err)
  175. return
  176. }
  177. }
  178. ctx.Flash.Success(ctx.Tr("repo.settings.add_collaborator_success"))
  179. ctx.Redirect(ctx.Req.URL.Path)
  180. return
  181. }
  182. // Delete collaborator.
  183. remove := strings.ToLower(ctx.Query("remove"))
  184. if len(remove) > 0 && remove != ctx.Repo.Owner.LowerName {
  185. needDelete := true
  186. if ctx.User.IsOrganization() {
  187. // Check if user belongs to a team that has access to this repository.
  188. auth, err := models.GetHighestAuthorize(ctx.Repo.Owner.Id, ctx.User.Id, 0, ctx.Repo.Repository.Id)
  189. if err != nil {
  190. ctx.Handle(500, "GetHighestAuthorize", err)
  191. return
  192. }
  193. if auth > 0 {
  194. needDelete = false
  195. }
  196. }
  197. if needDelete {
  198. if err := models.DeleteAccess(&models.Access{UserName: remove, RepoName: repoLink}); err != nil {
  199. ctx.Handle(500, "DeleteAccess", err)
  200. return
  201. }
  202. }
  203. ctx.Flash.Success(ctx.Tr("repo.settings.remove_collaborator_success"))
  204. ctx.Redirect(ctx.Repo.RepoLink + "/settings/collaboration")
  205. return
  206. }
  207. names, err := models.GetCollaboratorNames(repoLink)
  208. if err != nil {
  209. ctx.Handle(500, "GetCollaborators", err)
  210. return
  211. }
  212. us := make([]*models.User, len(names))
  213. for i, name := range names {
  214. us[i], err = models.GetUserByName(name)
  215. if err != nil {
  216. ctx.Handle(500, "GetUserByName", err)
  217. return
  218. }
  219. }
  220. ctx.Data["Collaborators"] = us
  221. ctx.HTML(200, COLLABORATION)
  222. }
  223. func Webhooks(ctx *middleware.Context) {
  224. ctx.Data["Title"] = ctx.Tr("repo.settings")
  225. ctx.Data["PageIsSettingsHooks"] = true
  226. // Delete web hook.
  227. remove := com.StrTo(ctx.Query("remove")).MustInt64()
  228. if remove > 0 {
  229. if err := models.DeleteWebhook(remove); err != nil {
  230. ctx.Handle(500, "DeleteWebhook", err)
  231. return
  232. }
  233. ctx.Flash.Success(ctx.Tr("repo.settings.remove_hook_success"))
  234. ctx.Redirect(ctx.Repo.RepoLink + "/settings/hooks")
  235. return
  236. }
  237. ws, err := models.GetWebhooksByRepoId(ctx.Repo.Repository.Id)
  238. if err != nil {
  239. ctx.Handle(500, "GetWebhooksByRepoId", err)
  240. return
  241. }
  242. ctx.Data["Webhooks"] = ws
  243. ctx.HTML(200, HOOKS)
  244. }
  245. func renderHookTypes(ctx *middleware.Context) {
  246. ctx.Data["HookTypes"] = []string{"Gogs", "Slack"}
  247. ctx.Data["HookType"] = "Gogs"
  248. }
  249. func WebHooksNew(ctx *middleware.Context) {
  250. ctx.Data["Title"] = ctx.Tr("repo.settings")
  251. ctx.Data["PageIsSettingsHooks"] = true
  252. ctx.Data["PageIsSettingsHooksNew"] = true
  253. ctx.Data["Webhook"] = models.Webhook{HookEvent: &models.HookEvent{}}
  254. renderHookTypes(ctx)
  255. orCtx, err := getOrgRepoCtx(ctx)
  256. if err != nil {
  257. ctx.Handle(500, "WebHooksNew(getOrgRepoCtx)", err)
  258. return
  259. }
  260. ctx.HTML(200, orCtx.NewTemplate)
  261. }
  262. func WebHooksNewPost(ctx *middleware.Context, form auth.NewWebhookForm) {
  263. ctx.Data["Title"] = ctx.Tr("repo.settings")
  264. ctx.Data["PageIsSettingsHooks"] = true
  265. ctx.Data["PageIsSettingsHooksNew"] = true
  266. ctx.Data["Webhook"] = models.Webhook{HookEvent: &models.HookEvent{}}
  267. orCtx, err := getOrgRepoCtx(ctx)
  268. if err != nil {
  269. ctx.Handle(500, "WebHooksNewPost(getOrgRepoCtx)", err)
  270. return
  271. }
  272. if ctx.HasError() {
  273. ctx.HTML(200, orCtx.NewTemplate)
  274. return
  275. }
  276. ct := models.JSON
  277. if form.ContentType == "2" {
  278. ct = models.FORM
  279. }
  280. w := &models.Webhook{
  281. RepoId: orCtx.RepoId,
  282. Url: form.PayloadUrl,
  283. ContentType: ct,
  284. Secret: form.Secret,
  285. HookEvent: &models.HookEvent{
  286. PushOnly: form.PushOnly,
  287. },
  288. IsActive: form.Active,
  289. HookTaskType: models.GOGS,
  290. Meta: "",
  291. OrgId: orCtx.OrgId,
  292. }
  293. if err := w.UpdateEvent(); err != nil {
  294. ctx.Handle(500, "UpdateEvent", err)
  295. return
  296. } else if err := models.CreateWebhook(w); err != nil {
  297. ctx.Handle(500, "CreateWebhook", err)
  298. return
  299. }
  300. ctx.Flash.Success(ctx.Tr("repo.settings.add_hook_success"))
  301. ctx.Redirect(orCtx.Link + "/settings/hooks")
  302. }
  303. func WebHooksEdit(ctx *middleware.Context) {
  304. ctx.Data["Title"] = ctx.Tr("repo.settings")
  305. ctx.Data["PageIsSettingsHooks"] = true
  306. ctx.Data["PageIsSettingsHooksEdit"] = true
  307. hookId := com.StrTo(ctx.Params(":id")).MustInt64()
  308. if hookId == 0 {
  309. ctx.Handle(404, "setting.WebHooksEdit", nil)
  310. return
  311. }
  312. w, err := models.GetWebhookById(hookId)
  313. if err != nil {
  314. if err == models.ErrWebhookNotExist {
  315. ctx.Handle(404, "GetWebhookById", nil)
  316. } else {
  317. ctx.Handle(500, "GetWebhookById", err)
  318. }
  319. return
  320. }
  321. // set data per HookTaskType
  322. switch w.HookTaskType {
  323. case models.SLACK:
  324. {
  325. ctx.Data["SlackHook"] = w.GetSlackHook()
  326. ctx.Data["HookType"] = "Slack"
  327. }
  328. default:
  329. {
  330. ctx.Data["HookType"] = "Gogs"
  331. }
  332. }
  333. w.GetEvent()
  334. ctx.Data["Webhook"] = w
  335. orCtx, err := getOrgRepoCtx(ctx)
  336. if err != nil {
  337. ctx.Handle(500, "WebHooksEdit(getOrgRepoCtx)", err)
  338. return
  339. }
  340. ctx.HTML(200, orCtx.NewTemplate)
  341. }
  342. func WebHooksEditPost(ctx *middleware.Context, form auth.NewWebhookForm) {
  343. ctx.Data["Title"] = ctx.Tr("repo.settings")
  344. ctx.Data["PageIsSettingsHooks"] = true
  345. ctx.Data["PageIsSettingsHooksEdit"] = true
  346. hookId := com.StrTo(ctx.Params(":id")).MustInt64()
  347. if hookId == 0 {
  348. ctx.Handle(404, "setting.WebHooksEditPost", nil)
  349. return
  350. }
  351. w, err := models.GetWebhookById(hookId)
  352. if err != nil {
  353. if err == models.ErrWebhookNotExist {
  354. ctx.Handle(404, "GetWebhookById", nil)
  355. } else {
  356. ctx.Handle(500, "GetWebhookById", err)
  357. }
  358. return
  359. }
  360. w.GetEvent()
  361. ctx.Data["Webhook"] = w
  362. orCtx, err := getOrgRepoCtx(ctx)
  363. if err != nil {
  364. ctx.Handle(500, "WebHooksEditPost(getOrgRepoCtx)", err)
  365. return
  366. }
  367. if ctx.HasError() {
  368. ctx.HTML(200, orCtx.NewTemplate)
  369. return
  370. }
  371. ct := models.JSON
  372. if form.ContentType == "2" {
  373. ct = models.FORM
  374. }
  375. w.Url = form.PayloadUrl
  376. w.ContentType = ct
  377. w.Secret = form.Secret
  378. w.HookEvent = &models.HookEvent{
  379. PushOnly: form.PushOnly,
  380. }
  381. w.IsActive = form.Active
  382. if err := w.UpdateEvent(); err != nil {
  383. ctx.Handle(500, "UpdateEvent", err)
  384. return
  385. } else if err := models.UpdateWebhook(w); err != nil {
  386. ctx.Handle(500, "WebHooksEditPost", err)
  387. return
  388. }
  389. ctx.Flash.Success(ctx.Tr("repo.settings.update_hook_success"))
  390. ctx.Redirect(fmt.Sprintf("%s/settings/hooks/%d", orCtx.Link, hookId))
  391. }
  392. func SlackHooksNewPost(ctx *middleware.Context, form auth.NewSlackHookForm) {
  393. ctx.Data["Title"] = ctx.Tr("repo.settings")
  394. ctx.Data["PageIsSettingsHooks"] = true
  395. ctx.Data["PageIsSettingsHooksNew"] = true
  396. ctx.Data["Webhook"] = models.Webhook{HookEvent: &models.HookEvent{}}
  397. orCtx, err := getOrgRepoCtx(ctx)
  398. if err != nil {
  399. ctx.Handle(500, "SlackHooksNewPost(getOrgRepoCtx)", err)
  400. return
  401. }
  402. if ctx.HasError() {
  403. ctx.HTML(200, orCtx.NewTemplate)
  404. return
  405. }
  406. meta, err := json.Marshal(&models.Slack{
  407. Domain: form.Domain,
  408. Channel: form.Channel,
  409. Token: form.Token,
  410. })
  411. if err != nil {
  412. ctx.Handle(500, "SlackHooksNewPost: JSON marshal failed: ", err)
  413. return
  414. }
  415. w := &models.Webhook{
  416. RepoId: orCtx.RepoId,
  417. Url: models.GetSlackURL(form.Domain, form.Token),
  418. ContentType: models.JSON,
  419. Secret: "",
  420. HookEvent: &models.HookEvent{
  421. PushOnly: form.PushOnly,
  422. },
  423. IsActive: form.Active,
  424. HookTaskType: models.SLACK,
  425. Meta: string(meta),
  426. OrgId: orCtx.OrgId,
  427. }
  428. if err := w.UpdateEvent(); err != nil {
  429. ctx.Handle(500, "UpdateEvent", err)
  430. return
  431. } else if err := models.CreateWebhook(w); err != nil {
  432. ctx.Handle(500, "CreateWebhook", err)
  433. return
  434. }
  435. ctx.Flash.Success(ctx.Tr("repo.settings.add_hook_success"))
  436. ctx.Redirect(orCtx.Link + "/settings/hooks")
  437. }
  438. func SlackHooksEditPost(ctx *middleware.Context, form auth.NewSlackHookForm) {
  439. ctx.Data["Title"] = ctx.Tr("repo.settings")
  440. ctx.Data["PageIsSettingsHooks"] = true
  441. ctx.Data["PageIsSettingsHooksEdit"] = true
  442. hookId := com.StrTo(ctx.Params(":id")).MustInt64()
  443. if hookId == 0 {
  444. ctx.Handle(404, "SlackHooksEditPost(hookId)", nil)
  445. return
  446. }
  447. orCtx, err := getOrgRepoCtx(ctx)
  448. if err != nil {
  449. ctx.Handle(500, "SlackHooksEditPost(getOrgRepoCtx)", err)
  450. return
  451. }
  452. w, err := models.GetWebhookById(hookId)
  453. if err != nil {
  454. if err == models.ErrWebhookNotExist {
  455. ctx.Handle(404, "GetWebhookById", nil)
  456. } else {
  457. ctx.Handle(500, "GetWebhookById", err)
  458. }
  459. return
  460. }
  461. w.GetEvent()
  462. ctx.Data["Webhook"] = w
  463. if ctx.HasError() {
  464. ctx.HTML(200, orCtx.NewTemplate)
  465. return
  466. }
  467. meta, err := json.Marshal(&models.Slack{
  468. Domain: form.Domain,
  469. Channel: form.Channel,
  470. Token: form.Token,
  471. })
  472. if err != nil {
  473. ctx.Handle(500, "SlackHooksNewPost: JSON marshal failed: ", err)
  474. return
  475. }
  476. w.Url = models.GetSlackURL(form.Domain, form.Token)
  477. w.Meta = string(meta)
  478. w.HookEvent = &models.HookEvent{
  479. PushOnly: form.PushOnly,
  480. }
  481. w.IsActive = form.Active
  482. if err := w.UpdateEvent(); err != nil {
  483. ctx.Handle(500, "UpdateEvent", err)
  484. return
  485. } else if err := models.UpdateWebhook(w); err != nil {
  486. ctx.Handle(500, "SlackHooksEditPost", err)
  487. return
  488. }
  489. ctx.Flash.Success(ctx.Tr("repo.settings.update_hook_success"))
  490. ctx.Redirect(fmt.Sprintf("%s/settings/hooks/%d", orCtx.Link, hookId))
  491. }
  492. type OrgRepoCtx struct {
  493. OrgId int64
  494. RepoId int64
  495. Link string
  496. NewTemplate base.TplName
  497. }
  498. // determines whether this is a repo context or organization context
  499. func getOrgRepoCtx(ctx *middleware.Context) (*OrgRepoCtx, error) {
  500. if _, ok := ctx.Data["RepoLink"]; ok {
  501. return &OrgRepoCtx{
  502. OrgId: int64(0),
  503. RepoId: ctx.Repo.Repository.Id,
  504. Link: ctx.Repo.RepoLink,
  505. NewTemplate: HOOK_NEW,
  506. }, nil
  507. } else if _, ok := ctx.Data["OrgLink"]; ok {
  508. return &OrgRepoCtx{
  509. OrgId: ctx.Org.Organization.Id,
  510. RepoId: int64(0),
  511. Link: ctx.Org.OrgLink,
  512. NewTemplate: ORG_HOOK_NEW,
  513. }, nil
  514. } else {
  515. return &OrgRepoCtx{}, errors.New("Unable to set OrgRepo context")
  516. }
  517. }