webhook.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639
  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 models
  5. import (
  6. "crypto/tls"
  7. "encoding/json"
  8. "fmt"
  9. "io/ioutil"
  10. "strings"
  11. "time"
  12. "github.com/go-xorm/xorm"
  13. gouuid "github.com/satori/go.uuid"
  14. log "gopkg.in/clog.v1"
  15. api "github.com/gogits/go-gogs-client"
  16. "github.com/gogits/gogs/modules/httplib"
  17. "github.com/gogits/gogs/modules/setting"
  18. "github.com/gogits/gogs/modules/sync"
  19. )
  20. var HookQueue = sync.NewUniqueQueue(setting.Webhook.QueueLength)
  21. type HookContentType int
  22. const (
  23. JSON HookContentType = iota + 1
  24. FORM
  25. )
  26. var hookContentTypes = map[string]HookContentType{
  27. "json": JSON,
  28. "form": FORM,
  29. }
  30. // ToHookContentType returns HookContentType by given name.
  31. func ToHookContentType(name string) HookContentType {
  32. return hookContentTypes[name]
  33. }
  34. func (t HookContentType) Name() string {
  35. switch t {
  36. case JSON:
  37. return "json"
  38. case FORM:
  39. return "form"
  40. }
  41. return ""
  42. }
  43. // IsValidHookContentType returns true if given name is a valid hook content type.
  44. func IsValidHookContentType(name string) bool {
  45. _, ok := hookContentTypes[name]
  46. return ok
  47. }
  48. type HookEvents struct {
  49. Create bool `json:"create"`
  50. Push bool `json:"push"`
  51. PullRequest bool `json:"pull_request"`
  52. }
  53. // HookEvent represents events that will delivery hook.
  54. type HookEvent struct {
  55. PushOnly bool `json:"push_only"`
  56. SendEverything bool `json:"send_everything"`
  57. ChooseEvents bool `json:"choose_events"`
  58. HookEvents `json:"events"`
  59. }
  60. type HookStatus int
  61. const (
  62. HOOK_STATUS_NONE = iota
  63. HOOK_STATUS_SUCCEED
  64. HOOK_STATUS_FAILED
  65. )
  66. // Webhook represents a web hook object.
  67. type Webhook struct {
  68. ID int64 `xorm:"pk autoincr"`
  69. RepoID int64
  70. OrgID int64
  71. URL string `xorm:"url TEXT"`
  72. ContentType HookContentType
  73. Secret string `xorm:"TEXT"`
  74. Events string `xorm:"TEXT"`
  75. *HookEvent `xorm:"-"`
  76. IsSSL bool `xorm:"is_ssl"`
  77. IsActive bool
  78. HookTaskType HookTaskType
  79. Meta string `xorm:"TEXT"` // store hook-specific attributes
  80. LastStatus HookStatus // Last delivery status
  81. Created time.Time `xorm:"-"`
  82. CreatedUnix int64
  83. Updated time.Time `xorm:"-"`
  84. UpdatedUnix int64
  85. }
  86. func (w *Webhook) BeforeInsert() {
  87. w.CreatedUnix = time.Now().Unix()
  88. w.UpdatedUnix = w.CreatedUnix
  89. }
  90. func (w *Webhook) BeforeUpdate() {
  91. w.UpdatedUnix = time.Now().Unix()
  92. }
  93. func (w *Webhook) AfterSet(colName string, _ xorm.Cell) {
  94. var err error
  95. switch colName {
  96. case "events":
  97. w.HookEvent = &HookEvent{}
  98. if err = json.Unmarshal([]byte(w.Events), w.HookEvent); err != nil {
  99. log.Error(3, "Unmarshal [%d]: %v", w.ID, err)
  100. }
  101. case "created_unix":
  102. w.Created = time.Unix(w.CreatedUnix, 0).Local()
  103. case "updated_unix":
  104. w.Updated = time.Unix(w.UpdatedUnix, 0).Local()
  105. }
  106. }
  107. func (w *Webhook) GetSlackHook() *SlackMeta {
  108. s := &SlackMeta{}
  109. if err := json.Unmarshal([]byte(w.Meta), s); err != nil {
  110. log.Error(2, "GetSlackHook [%d]: %v", w.ID, err)
  111. }
  112. return s
  113. }
  114. // History returns history of webhook by given conditions.
  115. func (w *Webhook) History(page int) ([]*HookTask, error) {
  116. return HookTasks(w.ID, page)
  117. }
  118. // UpdateEvent handles conversion from HookEvent to Events.
  119. func (w *Webhook) UpdateEvent() error {
  120. data, err := json.Marshal(w.HookEvent)
  121. w.Events = string(data)
  122. return err
  123. }
  124. // HasCreateEvent returns true if hook enabled create event.
  125. func (w *Webhook) HasCreateEvent() bool {
  126. return w.SendEverything ||
  127. (w.ChooseEvents && w.HookEvents.Create)
  128. }
  129. // HasPushEvent returns true if hook enabled push event.
  130. func (w *Webhook) HasPushEvent() bool {
  131. return w.PushOnly || w.SendEverything ||
  132. (w.ChooseEvents && w.HookEvents.Push)
  133. }
  134. // HasPullRequestEvent returns true if hook enabled pull request event.
  135. func (w *Webhook) HasPullRequestEvent() bool {
  136. return w.SendEverything ||
  137. (w.ChooseEvents && w.HookEvents.PullRequest)
  138. }
  139. func (w *Webhook) EventsArray() []string {
  140. events := make([]string, 0, 3)
  141. if w.HasCreateEvent() {
  142. events = append(events, "create")
  143. }
  144. if w.HasPushEvent() {
  145. events = append(events, "push")
  146. }
  147. if w.HasPullRequestEvent() {
  148. events = append(events, "pull_request")
  149. }
  150. return events
  151. }
  152. // CreateWebhook creates a new web hook.
  153. func CreateWebhook(w *Webhook) error {
  154. _, err := x.Insert(w)
  155. return err
  156. }
  157. // getWebhook uses argument bean as query condition,
  158. // ID must be specified and do not assign unnecessary fields.
  159. func getWebhook(bean *Webhook) (*Webhook, error) {
  160. has, err := x.Get(bean)
  161. if err != nil {
  162. return nil, err
  163. } else if !has {
  164. return nil, ErrWebhookNotExist{bean.ID}
  165. }
  166. return bean, nil
  167. }
  168. // GetWebhookOfRepoByID returns webhook of repository by given ID.
  169. func GetWebhookOfRepoByID(repoID, id int64) (*Webhook, error) {
  170. return getWebhook(&Webhook{
  171. ID: id,
  172. RepoID: repoID,
  173. })
  174. }
  175. // GetWebhookByOrgID returns webhook of organization by given ID.
  176. func GetWebhookByOrgID(orgID, id int64) (*Webhook, error) {
  177. return getWebhook(&Webhook{
  178. ID: id,
  179. OrgID: orgID,
  180. })
  181. }
  182. // GetActiveWebhooksByRepoID returns all active webhooks of repository.
  183. func GetActiveWebhooksByRepoID(repoID int64) ([]*Webhook, error) {
  184. webhooks := make([]*Webhook, 0, 5)
  185. return webhooks, x.Where("repo_id = ?", repoID).And("is_active = ?", true).Find(&webhooks)
  186. }
  187. // GetWebhooksByRepoID returns all webhooks of a repository.
  188. func GetWebhooksByRepoID(repoID int64) ([]*Webhook, error) {
  189. webhooks := make([]*Webhook, 0, 5)
  190. return webhooks, x.Find(&webhooks, &Webhook{RepoID: repoID})
  191. }
  192. // UpdateWebhook updates information of webhook.
  193. func UpdateWebhook(w *Webhook) error {
  194. _, err := x.Id(w.ID).AllCols().Update(w)
  195. return err
  196. }
  197. // deleteWebhook uses argument bean as query condition,
  198. // ID must be specified and do not assign unnecessary fields.
  199. func deleteWebhook(bean *Webhook) (err error) {
  200. sess := x.NewSession()
  201. defer sessionRelease(sess)
  202. if err = sess.Begin(); err != nil {
  203. return err
  204. }
  205. if _, err = sess.Delete(bean); err != nil {
  206. return err
  207. } else if _, err = sess.Delete(&HookTask{HookID: bean.ID}); err != nil {
  208. return err
  209. }
  210. return sess.Commit()
  211. }
  212. // DeleteWebhookOfRepoByID deletes webhook of repository by given ID.
  213. func DeleteWebhookOfRepoByID(repoID, id int64) error {
  214. return deleteWebhook(&Webhook{
  215. ID: id,
  216. RepoID: repoID,
  217. })
  218. }
  219. // DeleteWebhookOfOrgByID deletes webhook of organization by given ID.
  220. func DeleteWebhookOfOrgByID(orgID, id int64) error {
  221. return deleteWebhook(&Webhook{
  222. ID: id,
  223. OrgID: orgID,
  224. })
  225. }
  226. // GetWebhooksByOrgID returns all webhooks for an organization.
  227. func GetWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {
  228. err = x.Find(&ws, &Webhook{OrgID: orgID})
  229. return ws, err
  230. }
  231. // GetActiveWebhooksByOrgID returns all active webhooks for an organization.
  232. func GetActiveWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {
  233. err = x.Where("org_id=?", orgID).And("is_active=?", true).Find(&ws)
  234. return ws, err
  235. }
  236. // ___ ___ __ ___________ __
  237. // / | \ ____ ____ | | _\__ ___/____ _____| | __
  238. // / ~ \/ _ \ / _ \| |/ / | | \__ \ / ___/ |/ /
  239. // \ Y ( <_> | <_> ) < | | / __ \_\___ \| <
  240. // \___|_ / \____/ \____/|__|_ \ |____| (____ /____ >__|_ \
  241. // \/ \/ \/ \/ \/
  242. type HookTaskType int
  243. const (
  244. GOGS HookTaskType = iota + 1
  245. SLACK
  246. DISCORD
  247. )
  248. var hookTaskTypes = map[string]HookTaskType{
  249. "gogs": GOGS,
  250. "slack": SLACK,
  251. "discord": DISCORD,
  252. }
  253. // ToHookTaskType returns HookTaskType by given name.
  254. func ToHookTaskType(name string) HookTaskType {
  255. return hookTaskTypes[name]
  256. }
  257. func (t HookTaskType) Name() string {
  258. switch t {
  259. case GOGS:
  260. return "gogs"
  261. case SLACK:
  262. return "slack"
  263. case DISCORD:
  264. return "discord"
  265. }
  266. return ""
  267. }
  268. // IsValidHookTaskType returns true if given name is a valid hook task type.
  269. func IsValidHookTaskType(name string) bool {
  270. _, ok := hookTaskTypes[name]
  271. return ok
  272. }
  273. type HookEventType string
  274. const (
  275. HOOK_EVENT_CREATE HookEventType = "create"
  276. HOOK_EVENT_PUSH HookEventType = "push"
  277. HOOK_EVENT_PULL_REQUEST HookEventType = "pull_request"
  278. )
  279. // HookRequest represents hook task request information.
  280. type HookRequest struct {
  281. Headers map[string]string `json:"headers"`
  282. }
  283. // HookResponse represents hook task response information.
  284. type HookResponse struct {
  285. Status int `json:"status"`
  286. Headers map[string]string `json:"headers"`
  287. Body string `json:"body"`
  288. }
  289. // HookTask represents a hook task.
  290. type HookTask struct {
  291. ID int64 `xorm:"pk autoincr"`
  292. RepoID int64 `xorm:"INDEX"`
  293. HookID int64
  294. UUID string
  295. Type HookTaskType
  296. URL string `xorm:"TEXT"`
  297. api.Payloader `xorm:"-"`
  298. PayloadContent string `xorm:"TEXT"`
  299. ContentType HookContentType
  300. EventType HookEventType
  301. IsSSL bool
  302. IsDelivered bool
  303. Delivered int64
  304. DeliveredString string `xorm:"-"`
  305. // History info.
  306. IsSucceed bool
  307. RequestContent string `xorm:"TEXT"`
  308. RequestInfo *HookRequest `xorm:"-"`
  309. ResponseContent string `xorm:"TEXT"`
  310. ResponseInfo *HookResponse `xorm:"-"`
  311. }
  312. func (t *HookTask) BeforeUpdate() {
  313. if t.RequestInfo != nil {
  314. t.RequestContent = t.MarshalJSON(t.RequestInfo)
  315. }
  316. if t.ResponseInfo != nil {
  317. t.ResponseContent = t.MarshalJSON(t.ResponseInfo)
  318. }
  319. }
  320. func (t *HookTask) AfterSet(colName string, _ xorm.Cell) {
  321. var err error
  322. switch colName {
  323. case "delivered":
  324. t.DeliveredString = time.Unix(0, t.Delivered).Format("2006-01-02 15:04:05 MST")
  325. case "request_content":
  326. if len(t.RequestContent) == 0 {
  327. return
  328. }
  329. t.RequestInfo = &HookRequest{}
  330. if err = json.Unmarshal([]byte(t.RequestContent), t.RequestInfo); err != nil {
  331. log.Error(3, "Unmarshal[%d]: %v", t.ID, err)
  332. }
  333. case "response_content":
  334. if len(t.ResponseContent) == 0 {
  335. return
  336. }
  337. t.ResponseInfo = &HookResponse{}
  338. if err = json.Unmarshal([]byte(t.ResponseContent), t.ResponseInfo); err != nil {
  339. log.Error(3, "Unmarshal [%d]: %v", t.ID, err)
  340. }
  341. }
  342. }
  343. func (t *HookTask) MarshalJSON(v interface{}) string {
  344. p, err := json.Marshal(v)
  345. if err != nil {
  346. log.Error(3, "Marshal [%d]: %v", t.ID, err)
  347. }
  348. return string(p)
  349. }
  350. // HookTasks returns a list of hook tasks by given conditions.
  351. func HookTasks(hookID int64, page int) ([]*HookTask, error) {
  352. tasks := make([]*HookTask, 0, setting.Webhook.PagingNum)
  353. return tasks, x.Limit(setting.Webhook.PagingNum, (page-1)*setting.Webhook.PagingNum).Where("hook_id=?", hookID).Desc("id").Find(&tasks)
  354. }
  355. // CreateHookTask creates a new hook task,
  356. // it handles conversion from Payload to PayloadContent.
  357. func CreateHookTask(t *HookTask) error {
  358. data, err := t.Payloader.JSONPayload()
  359. if err != nil {
  360. return err
  361. }
  362. t.UUID = gouuid.NewV4().String()
  363. t.PayloadContent = string(data)
  364. _, err = x.Insert(t)
  365. return err
  366. }
  367. // UpdateHookTask updates information of hook task.
  368. func UpdateHookTask(t *HookTask) error {
  369. _, err := x.Id(t.ID).AllCols().Update(t)
  370. return err
  371. }
  372. // prepareWebhooks adds list of webhooks to task queue.
  373. func prepareWebhooks(repo *Repository, event HookEventType, p api.Payloader, webhooks []*Webhook) (err error) {
  374. if len(webhooks) == 0 {
  375. return nil
  376. }
  377. var payloader api.Payloader
  378. for _, w := range webhooks {
  379. switch event {
  380. case HOOK_EVENT_CREATE:
  381. if !w.HasCreateEvent() {
  382. continue
  383. }
  384. case HOOK_EVENT_PUSH:
  385. if !w.HasPushEvent() {
  386. continue
  387. }
  388. case HOOK_EVENT_PULL_REQUEST:
  389. if !w.HasPullRequestEvent() {
  390. continue
  391. }
  392. }
  393. // Use separate objects so modifcations won't be made on payload on non-Gogs type hooks.
  394. switch w.HookTaskType {
  395. case SLACK:
  396. payloader, err = GetSlackPayload(p, event, w.Meta)
  397. if err != nil {
  398. return fmt.Errorf("GetSlackPayload: %v", err)
  399. }
  400. case DISCORD:
  401. payloader, err = GetDiscordPayload(p, event, w.Meta)
  402. if err != nil {
  403. return fmt.Errorf("GetDiscordPayload: %v", err)
  404. }
  405. default:
  406. p.SetSecret(w.Secret)
  407. payloader = p
  408. }
  409. if err = CreateHookTask(&HookTask{
  410. RepoID: repo.ID,
  411. HookID: w.ID,
  412. Type: w.HookTaskType,
  413. URL: w.URL,
  414. Payloader: payloader,
  415. ContentType: w.ContentType,
  416. EventType: event,
  417. IsSSL: w.IsSSL,
  418. }); err != nil {
  419. return fmt.Errorf("CreateHookTask: %v", err)
  420. }
  421. }
  422. return nil
  423. }
  424. // PrepareWebhooks adds all active webhooks to task queue.
  425. func PrepareWebhooks(repo *Repository, event HookEventType, p api.Payloader) error {
  426. webhooks, err := GetActiveWebhooksByRepoID(repo.ID)
  427. if err != nil {
  428. return fmt.Errorf("GetActiveWebhooksByRepoID [%d]: %v", repo.ID, err)
  429. }
  430. // check if repo belongs to org and append additional webhooks
  431. if repo.MustOwner().IsOrganization() {
  432. // get hooks for org
  433. orgws, err := GetActiveWebhooksByOrgID(repo.OwnerID)
  434. if err != nil {
  435. return fmt.Errorf("GetActiveWebhooksByOrgID [%d]: %v", repo.OwnerID, err)
  436. }
  437. webhooks = append(webhooks, orgws...)
  438. }
  439. return prepareWebhooks(repo, event, p, webhooks)
  440. }
  441. // TestWebhook adds the test webhook matches the ID to task queue.
  442. func TestWebhook(repo *Repository, event HookEventType, p api.Payloader, webhookID int64) error {
  443. webhook, err := GetWebhookOfRepoByID(repo.ID, webhookID)
  444. if err != nil {
  445. return fmt.Errorf("GetWebhookOfRepoByID [repo_id: %d, id: %d]: %v", repo.ID, webhookID, err)
  446. }
  447. return prepareWebhooks(repo, event, p, []*Webhook{webhook})
  448. }
  449. func (t *HookTask) deliver() {
  450. t.IsDelivered = true
  451. timeout := time.Duration(setting.Webhook.DeliverTimeout) * time.Second
  452. req := httplib.Post(t.URL).SetTimeout(timeout, timeout).
  453. Header("X-Gogs-Delivery", t.UUID).
  454. Header("X-Gogs-Event", string(t.EventType)).
  455. SetTLSClientConfig(&tls.Config{InsecureSkipVerify: setting.Webhook.SkipTLSVerify})
  456. switch t.ContentType {
  457. case JSON:
  458. req = req.Header("Content-Type", "application/json").Body(t.PayloadContent)
  459. case FORM:
  460. req.Param("payload", t.PayloadContent)
  461. }
  462. // Record delivery information.
  463. t.RequestInfo = &HookRequest{
  464. Headers: map[string]string{},
  465. }
  466. for k, vals := range req.Headers() {
  467. t.RequestInfo.Headers[k] = strings.Join(vals, ",")
  468. }
  469. t.ResponseInfo = &HookResponse{
  470. Headers: map[string]string{},
  471. }
  472. defer func() {
  473. t.Delivered = time.Now().UnixNano()
  474. if t.IsSucceed {
  475. log.Trace("Hook delivered: %s", t.UUID)
  476. } else {
  477. log.Trace("Hook delivery failed: %s", t.UUID)
  478. }
  479. // Update webhook last delivery status.
  480. w, err := GetWebhookOfRepoByID(t.RepoID, t.HookID)
  481. if err != nil {
  482. log.Error(5, "GetWebhookByID: %v", err)
  483. return
  484. }
  485. if t.IsSucceed {
  486. w.LastStatus = HOOK_STATUS_SUCCEED
  487. } else {
  488. w.LastStatus = HOOK_STATUS_FAILED
  489. }
  490. if err = UpdateWebhook(w); err != nil {
  491. log.Error(5, "UpdateWebhook: %v", err)
  492. return
  493. }
  494. }()
  495. resp, err := req.Response()
  496. if err != nil {
  497. t.ResponseInfo.Body = fmt.Sprintf("Delivery: %v", err)
  498. return
  499. }
  500. defer resp.Body.Close()
  501. // Status code is 20x can be seen as succeed.
  502. t.IsSucceed = resp.StatusCode/100 == 2
  503. t.ResponseInfo.Status = resp.StatusCode
  504. for k, vals := range resp.Header {
  505. t.ResponseInfo.Headers[k] = strings.Join(vals, ",")
  506. }
  507. p, err := ioutil.ReadAll(resp.Body)
  508. if err != nil {
  509. t.ResponseInfo.Body = fmt.Sprintf("read body: %s", err)
  510. return
  511. }
  512. t.ResponseInfo.Body = string(p)
  513. }
  514. // DeliverHooks checks and delivers undelivered hooks.
  515. // TODO: shoot more hooks at same time.
  516. func DeliverHooks() {
  517. tasks := make([]*HookTask, 0, 10)
  518. x.Where("is_delivered=?", false).Iterate(new(HookTask),
  519. func(idx int, bean interface{}) error {
  520. t := bean.(*HookTask)
  521. t.deliver()
  522. tasks = append(tasks, t)
  523. return nil
  524. })
  525. // Update hook task status.
  526. for _, t := range tasks {
  527. if err := UpdateHookTask(t); err != nil {
  528. log.Error(4, "UpdateHookTask [%d]: %v", t.ID, err)
  529. }
  530. }
  531. // Start listening on new hook requests.
  532. for repoID := range HookQueue.Queue() {
  533. log.Trace("DeliverHooks [repo_id: %v]", repoID)
  534. HookQueue.Remove(repoID)
  535. tasks = make([]*HookTask, 0, 5)
  536. if err := x.Where("repo_id=? AND is_delivered=?", repoID, false).Find(&tasks); err != nil {
  537. log.Error(4, "Get repository [%s] hook tasks: %v", repoID, err)
  538. continue
  539. }
  540. for _, t := range tasks {
  541. t.deliver()
  542. if err := UpdateHookTask(t); err != nil {
  543. log.Error(4, "UpdateHookTask [%d]: %v", t.ID, err)
  544. continue
  545. }
  546. }
  547. }
  548. }
  549. func InitDeliverHooks() {
  550. go DeliverHooks()
  551. }