(e Engine, repo *Repository, event HookEventType, p api.Payloader)
| 657 | } |
| 658 | |
| 659 | func prepareWebhooks(e Engine, repo *Repository, event HookEventType, p api.Payloader) error { |
| 660 | webhooks, err := getActiveWebhooksByRepoID(e, repo.ID) |
| 661 | if err != nil { |
| 662 | return errors.Newf("getActiveWebhooksByRepoID [%d]: %v", repo.ID, err) |
| 663 | } |
| 664 | |
| 665 | // check if repo belongs to org and append additional webhooks |
| 666 | if repo.mustOwner(e).IsOrganization() { |
| 667 | // get hooks for org |
| 668 | orgws, err := getActiveWebhooksByOrgID(e, repo.OwnerID) |
| 669 | if err != nil { |
| 670 | return errors.Newf("getActiveWebhooksByOrgID [%d]: %v", repo.OwnerID, err) |
| 671 | } |
| 672 | webhooks = append(webhooks, orgws...) |
| 673 | } |
| 674 | return prepareHookTasks(e, repo, event, p, webhooks) |
| 675 | } |
| 676 | |
| 677 | // PrepareWebhooks adds all active webhooks to task queue. |
| 678 | func PrepareWebhooks(repo *Repository, event HookEventType, p api.Payloader) error { |
no test coverage detected