| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639 | // Copyright 2014 The Gogs Authors. All rights reserved.// Use of this source code is governed by a MIT-style// license that can be found in the LICENSE file.package modelsimport (	"crypto/tls"	"encoding/json"	"fmt"	"io/ioutil"	"strings"	"time"	"github.com/go-xorm/xorm"	gouuid "github.com/satori/go.uuid"	log "gopkg.in/clog.v1"	api "github.com/gogits/go-gogs-client"	"github.com/gogits/gogs/modules/httplib"	"github.com/gogits/gogs/modules/setting"	"github.com/gogits/gogs/modules/sync")var HookQueue = sync.NewUniqueQueue(setting.Webhook.QueueLength)type HookContentType intconst (	JSON HookContentType = iota + 1	FORM)var hookContentTypes = map[string]HookContentType{	"json": JSON,	"form": FORM,}// ToHookContentType returns HookContentType by given name.func ToHookContentType(name string) HookContentType {	return hookContentTypes[name]}func (t HookContentType) Name() string {	switch t {	case JSON:		return "json"	case FORM:		return "form"	}	return ""}// IsValidHookContentType returns true if given name is a valid hook content type.func IsValidHookContentType(name string) bool {	_, ok := hookContentTypes[name]	return ok}type HookEvents struct {	Create      bool `json:"create"`	Push        bool `json:"push"`	PullRequest bool `json:"pull_request"`}// HookEvent represents events that will delivery hook.type HookEvent struct {	PushOnly       bool `json:"push_only"`	SendEverything bool `json:"send_everything"`	ChooseEvents   bool `json:"choose_events"`	HookEvents `json:"events"`}type HookStatus intconst (	HOOK_STATUS_NONE = iota	HOOK_STATUS_SUCCEED	HOOK_STATUS_FAILED)// Webhook represents a web hook object.type Webhook struct {	ID           int64 `xorm:"pk autoincr"`	RepoID       int64	OrgID        int64	URL          string `xorm:"url TEXT"`	ContentType  HookContentType	Secret       string `xorm:"TEXT"`	Events       string `xorm:"TEXT"`	*HookEvent   `xorm:"-"`	IsSSL        bool `xorm:"is_ssl"`	IsActive     bool	HookTaskType HookTaskType	Meta         string     `xorm:"TEXT"` // store hook-specific attributes	LastStatus   HookStatus // Last delivery status	Created     time.Time `xorm:"-"`	CreatedUnix int64	Updated     time.Time `xorm:"-"`	UpdatedUnix int64}func (w *Webhook) BeforeInsert() {	w.CreatedUnix = time.Now().Unix()	w.UpdatedUnix = w.CreatedUnix}func (w *Webhook) BeforeUpdate() {	w.UpdatedUnix = time.Now().Unix()}func (w *Webhook) AfterSet(colName string, _ xorm.Cell) {	var err error	switch colName {	case "events":		w.HookEvent = &HookEvent{}		if err = json.Unmarshal([]byte(w.Events), w.HookEvent); err != nil {			log.Error(3, "Unmarshal [%d]: %v", w.ID, err)		}	case "created_unix":		w.Created = time.Unix(w.CreatedUnix, 0).Local()	case "updated_unix":		w.Updated = time.Unix(w.UpdatedUnix, 0).Local()	}}func (w *Webhook) GetSlackHook() *SlackMeta {	s := &SlackMeta{}	if err := json.Unmarshal([]byte(w.Meta), s); err != nil {		log.Error(2, "GetSlackHook [%d]: %v", w.ID, err)	}	return s}// History returns history of webhook by given conditions.func (w *Webhook) History(page int) ([]*HookTask, error) {	return HookTasks(w.ID, page)}// UpdateEvent handles conversion from HookEvent to Events.func (w *Webhook) UpdateEvent() error {	data, err := json.Marshal(w.HookEvent)	w.Events = string(data)	return err}// HasCreateEvent returns true if hook enabled create event.func (w *Webhook) HasCreateEvent() bool {	return w.SendEverything ||		(w.ChooseEvents && w.HookEvents.Create)}// HasPushEvent returns true if hook enabled push event.func (w *Webhook) HasPushEvent() bool {	return w.PushOnly || w.SendEverything ||		(w.ChooseEvents && w.HookEvents.Push)}// HasPullRequestEvent returns true if hook enabled pull request event.func (w *Webhook) HasPullRequestEvent() bool {	return w.SendEverything ||		(w.ChooseEvents && w.HookEvents.PullRequest)}func (w *Webhook) EventsArray() []string {	events := make([]string, 0, 3)	if w.HasCreateEvent() {		events = append(events, "create")	}	if w.HasPushEvent() {		events = append(events, "push")	}	if w.HasPullRequestEvent() {		events = append(events, "pull_request")	}	return events}// CreateWebhook creates a new web hook.func CreateWebhook(w *Webhook) error {	_, err := x.Insert(w)	return err}// getWebhook uses argument bean as query condition,// ID must be specified and do not assign unnecessary fields.func getWebhook(bean *Webhook) (*Webhook, error) {	has, err := x.Get(bean)	if err != nil {		return nil, err	} else if !has {		return nil, ErrWebhookNotExist{bean.ID}	}	return bean, nil}// GetWebhookOfRepoByID returns webhook of repository by given ID.func GetWebhookOfRepoByID(repoID, id int64) (*Webhook, error) {	return getWebhook(&Webhook{		ID:     id,		RepoID: repoID,	})}// GetWebhookByOrgID returns webhook of organization by given ID.func GetWebhookByOrgID(orgID, id int64) (*Webhook, error) {	return getWebhook(&Webhook{		ID:    id,		OrgID: orgID,	})}// GetActiveWebhooksByRepoID returns all active webhooks of repository.func GetActiveWebhooksByRepoID(repoID int64) ([]*Webhook, error) {	webhooks := make([]*Webhook, 0, 5)	return webhooks, x.Where("repo_id = ?", repoID).And("is_active = ?", true).Find(&webhooks)}// GetWebhooksByRepoID returns all webhooks of a repository.func GetWebhooksByRepoID(repoID int64) ([]*Webhook, error) {	webhooks := make([]*Webhook, 0, 5)	return webhooks, x.Find(&webhooks, &Webhook{RepoID: repoID})}// UpdateWebhook updates information of webhook.func UpdateWebhook(w *Webhook) error {	_, err := x.Id(w.ID).AllCols().Update(w)	return err}// deleteWebhook uses argument bean as query condition,// ID must be specified and do not assign unnecessary fields.func deleteWebhook(bean *Webhook) (err error) {	sess := x.NewSession()	defer sessionRelease(sess)	if err = sess.Begin(); err != nil {		return err	}	if _, err = sess.Delete(bean); err != nil {		return err	} else if _, err = sess.Delete(&HookTask{HookID: bean.ID}); err != nil {		return err	}	return sess.Commit()}// DeleteWebhookOfRepoByID deletes webhook of repository by given ID.func DeleteWebhookOfRepoByID(repoID, id int64) error {	return deleteWebhook(&Webhook{		ID:     id,		RepoID: repoID,	})}// DeleteWebhookOfOrgByID deletes webhook of organization by given ID.func DeleteWebhookOfOrgByID(orgID, id int64) error {	return deleteWebhook(&Webhook{		ID:    id,		OrgID: orgID,	})}// GetWebhooksByOrgID returns all webhooks for an organization.func GetWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {	err = x.Find(&ws, &Webhook{OrgID: orgID})	return ws, err}// GetActiveWebhooksByOrgID returns all active webhooks for an organization.func GetActiveWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {	err = x.Where("org_id=?", orgID).And("is_active=?", true).Find(&ws)	return ws, err}//   ___ ___                __   ___________              __//  /   |   \  ____   ____ |  | _\__    ___/____    _____|  | __// /    ~    \/  _ \ /  _ \|  |/ / |    |  \__  \  /  ___/  |/ /// \    Y    (  <_> |  <_> )    <  |    |   / __ \_\___ \|    <//  \___|_  / \____/ \____/|__|_ \ |____|  (____  /____  >__|_ \//        \/                    \/              \/     \/     \/type HookTaskType intconst (	GOGS HookTaskType = iota + 1	SLACK	DISCORD)var hookTaskTypes = map[string]HookTaskType{	"gogs":    GOGS,	"slack":   SLACK,	"discord": DISCORD,}// ToHookTaskType returns HookTaskType by given name.func ToHookTaskType(name string) HookTaskType {	return hookTaskTypes[name]}func (t HookTaskType) Name() string {	switch t {	case GOGS:		return "gogs"	case SLACK:		return "slack"	case DISCORD:		return "discord"	}	return ""}// IsValidHookTaskType returns true if given name is a valid hook task type.func IsValidHookTaskType(name string) bool {	_, ok := hookTaskTypes[name]	return ok}type HookEventType stringconst (	HOOK_EVENT_CREATE       HookEventType = "create"	HOOK_EVENT_PUSH         HookEventType = "push"	HOOK_EVENT_PULL_REQUEST HookEventType = "pull_request")// HookRequest represents hook task request information.type HookRequest struct {	Headers map[string]string `json:"headers"`}// HookResponse represents hook task response information.type HookResponse struct {	Status  int               `json:"status"`	Headers map[string]string `json:"headers"`	Body    string            `json:"body"`}// HookTask represents a hook task.type HookTask struct {	ID              int64 `xorm:"pk autoincr"`	RepoID          int64 `xorm:"INDEX"`	HookID          int64	UUID            string	Type            HookTaskType	URL             string `xorm:"TEXT"`	api.Payloader   `xorm:"-"`	PayloadContent  string `xorm:"TEXT"`	ContentType     HookContentType	EventType       HookEventType	IsSSL           bool	IsDelivered     bool	Delivered       int64	DeliveredString string `xorm:"-"`	// History info.	IsSucceed       bool	RequestContent  string        `xorm:"TEXT"`	RequestInfo     *HookRequest  `xorm:"-"`	ResponseContent string        `xorm:"TEXT"`	ResponseInfo    *HookResponse `xorm:"-"`}func (t *HookTask) BeforeUpdate() {	if t.RequestInfo != nil {		t.RequestContent = t.MarshalJSON(t.RequestInfo)	}	if t.ResponseInfo != nil {		t.ResponseContent = t.MarshalJSON(t.ResponseInfo)	}}func (t *HookTask) AfterSet(colName string, _ xorm.Cell) {	var err error	switch colName {	case "delivered":		t.DeliveredString = time.Unix(0, t.Delivered).Format("2006-01-02 15:04:05 MST")	case "request_content":		if len(t.RequestContent) == 0 {			return		}		t.RequestInfo = &HookRequest{}		if err = json.Unmarshal([]byte(t.RequestContent), t.RequestInfo); err != nil {			log.Error(3, "Unmarshal[%d]: %v", t.ID, err)		}	case "response_content":		if len(t.ResponseContent) == 0 {			return		}		t.ResponseInfo = &HookResponse{}		if err = json.Unmarshal([]byte(t.ResponseContent), t.ResponseInfo); err != nil {			log.Error(3, "Unmarshal [%d]: %v", t.ID, err)		}	}}func (t *HookTask) MarshalJSON(v interface{}) string {	p, err := json.Marshal(v)	if err != nil {		log.Error(3, "Marshal [%d]: %v", t.ID, err)	}	return string(p)}// HookTasks returns a list of hook tasks by given conditions.func HookTasks(hookID int64, page int) ([]*HookTask, error) {	tasks := make([]*HookTask, 0, setting.Webhook.PagingNum)	return tasks, x.Limit(setting.Webhook.PagingNum, (page-1)*setting.Webhook.PagingNum).Where("hook_id=?", hookID).Desc("id").Find(&tasks)}// CreateHookTask creates a new hook task,// it handles conversion from Payload to PayloadContent.func CreateHookTask(t *HookTask) error {	data, err := t.Payloader.JSONPayload()	if err != nil {		return err	}	t.UUID = gouuid.NewV4().String()	t.PayloadContent = string(data)	_, err = x.Insert(t)	return err}// UpdateHookTask updates information of hook task.func UpdateHookTask(t *HookTask) error {	_, err := x.Id(t.ID).AllCols().Update(t)	return err}// prepareWebhooks adds list of webhooks to task queue.func prepareWebhooks(repo *Repository, event HookEventType, p api.Payloader, webhooks []*Webhook) (err error) {	if len(webhooks) == 0 {		return nil	}	var payloader api.Payloader	for _, w := range webhooks {		switch event {		case HOOK_EVENT_CREATE:			if !w.HasCreateEvent() {				continue			}		case HOOK_EVENT_PUSH:			if !w.HasPushEvent() {				continue			}		case HOOK_EVENT_PULL_REQUEST:			if !w.HasPullRequestEvent() {				continue			}		}		// Use separate objects so modifcations won't be made on payload on non-Gogs type hooks.		switch w.HookTaskType {		case SLACK:			payloader, err = GetSlackPayload(p, event, w.Meta)			if err != nil {				return fmt.Errorf("GetSlackPayload: %v", err)			}		case DISCORD:			payloader, err = GetDiscordPayload(p, event, w.Meta)			if err != nil {				return fmt.Errorf("GetDiscordPayload: %v", err)			}		default:			p.SetSecret(w.Secret)			payloader = p		}		if err = CreateHookTask(&HookTask{			RepoID:      repo.ID,			HookID:      w.ID,			Type:        w.HookTaskType,			URL:         w.URL,			Payloader:   payloader,			ContentType: w.ContentType,			EventType:   event,			IsSSL:       w.IsSSL,		}); err != nil {			return fmt.Errorf("CreateHookTask: %v", err)		}	}	return nil}// PrepareWebhooks adds all active webhooks to task queue.func PrepareWebhooks(repo *Repository, event HookEventType, p api.Payloader) error {	webhooks, err := GetActiveWebhooksByRepoID(repo.ID)	if err != nil {		return fmt.Errorf("GetActiveWebhooksByRepoID [%d]: %v", repo.ID, err)	}	// check if repo belongs to org and append additional webhooks	if repo.MustOwner().IsOrganization() {		// get hooks for org		orgws, err := GetActiveWebhooksByOrgID(repo.OwnerID)		if err != nil {			return fmt.Errorf("GetActiveWebhooksByOrgID [%d]: %v", repo.OwnerID, err)		}		webhooks = append(webhooks, orgws...)	}	return prepareWebhooks(repo, event, p, webhooks)}// TestWebhook adds the test webhook matches the ID to task queue.func TestWebhook(repo *Repository, event HookEventType, p api.Payloader, webhookID int64) error {	webhook, err := GetWebhookOfRepoByID(repo.ID, webhookID)	if err != nil {		return fmt.Errorf("GetWebhookOfRepoByID [repo_id: %d, id: %d]: %v", repo.ID, webhookID, err)	}	return prepareWebhooks(repo, event, p, []*Webhook{webhook})}func (t *HookTask) deliver() {	t.IsDelivered = true	timeout := time.Duration(setting.Webhook.DeliverTimeout) * time.Second	req := httplib.Post(t.URL).SetTimeout(timeout, timeout).		Header("X-Gogs-Delivery", t.UUID).		Header("X-Gogs-Event", string(t.EventType)).		SetTLSClientConfig(&tls.Config{InsecureSkipVerify: setting.Webhook.SkipTLSVerify})	switch t.ContentType {	case JSON:		req = req.Header("Content-Type", "application/json").Body(t.PayloadContent)	case FORM:		req.Param("payload", t.PayloadContent)	}	// Record delivery information.	t.RequestInfo = &HookRequest{		Headers: map[string]string{},	}	for k, vals := range req.Headers() {		t.RequestInfo.Headers[k] = strings.Join(vals, ",")	}	t.ResponseInfo = &HookResponse{		Headers: map[string]string{},	}	defer func() {		t.Delivered = time.Now().UnixNano()		if t.IsSucceed {			log.Trace("Hook delivered: %s", t.UUID)		} else {			log.Trace("Hook delivery failed: %s", t.UUID)		}		// Update webhook last delivery status.		w, err := GetWebhookOfRepoByID(t.RepoID, t.HookID)		if err != nil {			log.Error(5, "GetWebhookByID: %v", err)			return		}		if t.IsSucceed {			w.LastStatus = HOOK_STATUS_SUCCEED		} else {			w.LastStatus = HOOK_STATUS_FAILED		}		if err = UpdateWebhook(w); err != nil {			log.Error(5, "UpdateWebhook: %v", err)			return		}	}()	resp, err := req.Response()	if err != nil {		t.ResponseInfo.Body = fmt.Sprintf("Delivery: %v", err)		return	}	defer resp.Body.Close()	// Status code is 20x can be seen as succeed.	t.IsSucceed = resp.StatusCode/100 == 2	t.ResponseInfo.Status = resp.StatusCode	for k, vals := range resp.Header {		t.ResponseInfo.Headers[k] = strings.Join(vals, ",")	}	p, err := ioutil.ReadAll(resp.Body)	if err != nil {		t.ResponseInfo.Body = fmt.Sprintf("read body: %s", err)		return	}	t.ResponseInfo.Body = string(p)}// DeliverHooks checks and delivers undelivered hooks.// TODO: shoot more hooks at same time.func DeliverHooks() {	tasks := make([]*HookTask, 0, 10)	x.Where("is_delivered=?", false).Iterate(new(HookTask),		func(idx int, bean interface{}) error {			t := bean.(*HookTask)			t.deliver()			tasks = append(tasks, t)			return nil		})	// Update hook task status.	for _, t := range tasks {		if err := UpdateHookTask(t); err != nil {			log.Error(4, "UpdateHookTask [%d]: %v", t.ID, err)		}	}	// Start listening on new hook requests.	for repoID := range HookQueue.Queue() {		log.Trace("DeliverHooks [repo_id: %v]", repoID)		HookQueue.Remove(repoID)		tasks = make([]*HookTask, 0, 5)		if err := x.Where("repo_id=? AND is_delivered=?", repoID, false).Find(&tasks); err != nil {			log.Error(4, "Get repository [%s] hook tasks: %v", repoID, err)			continue		}		for _, t := range tasks {			t.deliver()			if err := UpdateHookTask(t); err != nil {				log.Error(4, "UpdateHookTask [%d]: %v", t.ID, err)				continue			}		}	}}func InitDeliverHooks() {	go DeliverHooks()}
 |