From 80eea77953ab5f1f12e1a01f1930b72c360a5c76 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 16:37:32 +0100 Subject: [PATCH 01/12] Use MixedCase constant names See https://github.com/golang/go/wiki/CodeReviewComments#mixed-caps --- models/action.go | 52 +++++++++---------- models/issue.go | 30 +++++------ models/issue_comment.go | 16 +++--- models/pull.go | 50 +++++++++--------- models/webhook.go | 20 +++---- models/webhook_slack.go | 24 ++++----- routers/api/v1/repo/hook.go | 12 ++--- routers/repo/pull.go | 2 +- routers/repo/webhook.go | 2 +- .../go-gitea/go-sdk/gitea/repo_hook.go | 18 +++---- 10 files changed, 113 insertions(+), 113 deletions(-) diff --git a/models/action.go b/models/action.go index 055bc4b29..96dd2d768 100644 --- a/models/action.go +++ b/models/action.go @@ -27,21 +27,21 @@ import ( type ActionType int const ( - ACTION_CREATE_REPO ActionType = iota + 1 // 1 - ACTION_RENAME_REPO // 2 - ACTION_STAR_REPO // 3 - ACTION_WATCH_REPO // 4 - ACTION_COMMIT_REPO // 5 - ACTION_CREATE_ISSUE // 6 - ACTION_CREATE_PULL_REQUEST // 7 - ACTION_TRANSFER_REPO // 8 - ACTION_PUSH_TAG // 9 - ACTION_COMMENT_ISSUE // 10 - ACTION_MERGE_PULL_REQUEST // 11 - ACTION_CLOSE_ISSUE // 12 - ACTION_REOPEN_ISSUE // 13 - ACTION_CLOSE_PULL_REQUEST // 14 - ACTION_REOPEN_PULL_REQUEST // 15 + ActionCreateRepo ActionType = iota + 1 // 1 + ActionRenameRepo // 2 + ActionStarRepo // 3 + ActionWatchRepo // 4 + ActionCommitRepo // 5 + ActionCreateIssue // 6 + ActionCreatePullRequest // 7 + ActionTransferRepo // 8 + ActionPushTag // 9 + ActionCommentIssue // 10 + ActionMergePullRequest // 11 + ActionCloseIssue // 12 + ActionReopenIssue // 13 + ActionClosePullRequest // 14 + ActionReopenPullRequest // 15 ) var ( @@ -176,7 +176,7 @@ func newRepoAction(e Engine, u *User, repo *Repository) (err error) { if err = notifyWatchers(e, &Action{ ActUserID: u.ID, ActUserName: u.Name, - OpType: ACTION_CREATE_REPO, + OpType: ActionCreateRepo, RepoID: repo.ID, RepoUserName: repo.Owner.Name, RepoName: repo.Name, @@ -198,7 +198,7 @@ func renameRepoAction(e Engine, actUser *User, oldRepoName string, repo *Reposit if err = notifyWatchers(e, &Action{ ActUserID: actUser.ID, ActUserName: actUser.Name, - OpType: ACTION_RENAME_REPO, + OpType: ActionRenameRepo, RepoID: repo.ID, RepoUserName: repo.Owner.Name, RepoName: repo.Name, @@ -454,10 +454,10 @@ func CommitRepoAction(opts CommitRepoActionOptions) error { } isNewBranch := false - opType := ACTION_COMMIT_REPO + opType := ActionCommitRepo // Check it's tag push or branch. if strings.HasPrefix(opts.RefFullName, git.TAG_PREFIX) { - opType = ACTION_PUSH_TAG + opType = ActionPushTag opts.Commits = &PushCommits{} } else { // if not the first commit, set the compare URL. @@ -503,8 +503,8 @@ func CommitRepoAction(opts CommitRepoActionOptions) error { apiPusher := pusher.APIFormat() apiRepo := repo.APIFormat(nil) switch opType { - case ACTION_COMMIT_REPO: // Push - if err = PrepareWebhooks(repo, HOOK_EVENT_PUSH, &api.PushPayload{ + case ActionCommitRepo: // Push + if err = PrepareWebhooks(repo, HookEventPush, &api.PushPayload{ Ref: opts.RefFullName, Before: opts.OldCommitID, After: opts.NewCommitID, @@ -518,7 +518,7 @@ func CommitRepoAction(opts CommitRepoActionOptions) error { } if isNewBranch { - return PrepareWebhooks(repo, HOOK_EVENT_CREATE, &api.CreatePayload{ + return PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{ Ref: refName, RefType: "branch", Repo: apiRepo, @@ -526,8 +526,8 @@ func CommitRepoAction(opts CommitRepoActionOptions) error { }) } - case ACTION_PUSH_TAG: // Create - return PrepareWebhooks(repo, HOOK_EVENT_CREATE, &api.CreatePayload{ + case ActionPushTag: // Create + return PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{ Ref: refName, RefType: "tag", Repo: apiRepo, @@ -542,7 +542,7 @@ func transferRepoAction(e Engine, doer, oldOwner *User, repo *Repository) (err e if err = notifyWatchers(e, &Action{ ActUserID: doer.ID, ActUserName: doer.Name, - OpType: ACTION_TRANSFER_REPO, + OpType: ActionTransferRepo, RepoID: repo.ID, RepoUserName: repo.Owner.Name, RepoName: repo.Name, @@ -572,7 +572,7 @@ func mergePullRequestAction(e Engine, doer *User, repo *Repository, issue *Issue return notifyWatchers(e, &Action{ ActUserID: doer.ID, ActUserName: doer.Name, - OpType: ACTION_MERGE_PULL_REQUEST, + OpType: ActionMergePullRequest, Content: fmt.Sprintf("%d|%s", issue.Index, issue.Title), RepoID: repo.ID, RepoUserName: repo.Owner.Name, diff --git a/models/issue.go b/models/issue.go index b63ff48fe..06b8183a4 100644 --- a/models/issue.go +++ b/models/issue.go @@ -239,8 +239,8 @@ func (issue *Issue) sendLabelUpdatedWebhook(doer *User) { log.Error(4, "LoadIssue: %v", err) return } - err = PrepareWebhooks(issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_LABEL_UPDATED, + err = PrepareWebhooks(issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueLabelUpdated, Index: issue.Index, PullRequest: issue.PullRequest.APIFormat(), Repository: issue.Repo.APIFormat(nil), @@ -343,8 +343,8 @@ func (issue *Issue) ClearLabels(doer *User) (err error) { log.Error(4, "LoadIssue: %v", err) return } - err = PrepareWebhooks(issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_LABEL_CLEARED, + err = PrepareWebhooks(issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueLabelCleared, Index: issue.Index, PullRequest: issue.PullRequest.APIFormat(), Repository: issue.Repo.APIFormat(nil), @@ -471,11 +471,11 @@ func (issue *Issue) ChangeStatus(doer *User, repo *Repository, isClosed bool) (e Sender: doer.APIFormat(), } if isClosed { - apiPullRequest.Action = api.HOOK_ISSUE_CLOSED + apiPullRequest.Action = api.HookIssueClosed } else { - apiPullRequest.Action = api.HOOK_ISSUE_REOPENED + apiPullRequest.Action = api.HookIssueReopened } - err = PrepareWebhooks(repo, HOOK_EVENT_PULL_REQUEST, apiPullRequest) + err = PrepareWebhooks(repo, HookEventPullRequest, apiPullRequest) } if err != nil { log.Error(4, "PrepareWebhooks [is_pull: %v, is_closed: %v]: %v", issue.IsPull, isClosed, err) @@ -495,8 +495,8 @@ func (issue *Issue) ChangeTitle(doer *User, title string) (err error) { if issue.IsPull { issue.PullRequest.Issue = issue - err = PrepareWebhooks(issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_EDITED, + err = PrepareWebhooks(issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Title: &api.ChangesFromPayload{ @@ -526,8 +526,8 @@ func (issue *Issue) ChangeContent(doer *User, content string) (err error) { if issue.IsPull { issue.PullRequest.Issue = issue - err = PrepareWebhooks(issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_EDITED, + err = PrepareWebhooks(issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Body: &api.ChangesFromPayload{ @@ -571,11 +571,11 @@ func (issue *Issue) ChangeAssignee(doer *User, assigneeID int64) (err error) { Sender: doer.APIFormat(), } if isRemoveAssignee { - apiPullRequest.Action = api.HOOK_ISSUE_UNASSIGNED + apiPullRequest.Action = api.HookIssueUnassigned } else { - apiPullRequest.Action = api.HOOK_ISSUE_ASSIGNED + apiPullRequest.Action = api.HookIssueAssigned } - err = PrepareWebhooks(issue.Repo, HOOK_EVENT_PULL_REQUEST, apiPullRequest) + err = PrepareWebhooks(issue.Repo, HookEventPullRequest, apiPullRequest) } if err != nil { log.Error(4, "PrepareWebhooks [is_pull: %v, remove_assignee: %v]: %v", issue.IsPull, isRemoveAssignee, err) @@ -714,7 +714,7 @@ func NewIssue(repo *Repository, issue *Issue, labelIDs []int64, uuids []string) if err = NotifyWatchers(&Action{ ActUserID: issue.Poster.ID, ActUserName: issue.Poster.Name, - OpType: ACTION_CREATE_ISSUE, + OpType: ActionCreateIssue, Content: fmt.Sprintf("%d|%s", issue.Index, issue.Title), RepoID: repo.ID, RepoUserName: repo.Owner.Name, diff --git a/models/issue_comment.go b/models/issue_comment.go index d75b42cd3..b8ab8c23e 100644 --- a/models/issue_comment.go +++ b/models/issue_comment.go @@ -144,11 +144,11 @@ func (cmt *Comment) MailParticipants(opType ActionType, issue *Issue) (err error } switch opType { - case ACTION_COMMENT_ISSUE: + case ActionCommentIssue: issue.Content = cmt.Content - case ACTION_CLOSE_ISSUE: + case ActionCloseIssue: issue.Content = fmt.Sprintf("Closed #%d", issue.Index) - case ACTION_REOPEN_ISSUE: + case ActionReopenIssue: issue.Content = fmt.Sprintf("Reopened #%d", issue.Index) } if err = mailIssueCommentToParticipants(issue, cmt.Poster, mentions); err != nil { @@ -188,7 +188,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err // Check comment type. switch opts.Type { case COMMENT_TYPE_COMMENT: - act.OpType = ACTION_COMMENT_ISSUE + act.OpType = ActionCommentIssue if _, err = e.Exec("UPDATE `issue` SET num_comments=num_comments+1 WHERE id=?", opts.Issue.ID); err != nil { return nil, err @@ -217,9 +217,9 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err } case COMMENT_TYPE_REOPEN: - act.OpType = ACTION_REOPEN_ISSUE + act.OpType = ActionReopenIssue if opts.Issue.IsPull { - act.OpType = ACTION_REOPEN_PULL_REQUEST + act.OpType = ActionReopenPullRequest } if opts.Issue.IsPull { @@ -232,9 +232,9 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err } case COMMENT_TYPE_CLOSE: - act.OpType = ACTION_CLOSE_ISSUE + act.OpType = ActionCloseIssue if opts.Issue.IsPull { - act.OpType = ACTION_CLOSE_PULL_REQUEST + act.OpType = ActionClosePullRequest } if opts.Issue.IsPull { diff --git a/models/pull.go b/models/pull.go index 600360f76..2437c040d 100644 --- a/models/pull.go +++ b/models/pull.go @@ -26,16 +26,16 @@ var PullRequestQueue = sync.NewUniqueQueue(setting.Repository.PullRequestQueueLe type PullRequestType int const ( - PULL_REQUEST_GITEA PullRequestType = iota - PULL_REQUEST_GIT + PullRequestGitea PullRequestType = iota + PullRequestGit ) type PullRequestStatus int const ( - PULL_REQUEST_STATUS_CONFLICT PullRequestStatus = iota - PULL_REQUEST_STATUS_CHECKING - PULL_REQUEST_STATUS_MERGEABLE + PullRequestStatusConflict PullRequestStatus = iota + PullRequestStatusChecking + PullRequestStatusMergeable ) // PullRequest represents relation between pull request and repositories. @@ -129,8 +129,8 @@ func (pr *PullRequest) APIFormat() *api.PullRequest { HasMerged: pr.HasMerged, } - if pr.Status != PULL_REQUEST_STATUS_CHECKING { - mergeable := pr.Status != PULL_REQUEST_STATUS_CONFLICT + if pr.Status != PullRequestStatusChecking { + mergeable := pr.Status != PullRequestStatusConflict apiPullRequest.Mergeable = &mergeable } if pr.HasMerged { @@ -168,12 +168,12 @@ func (pr *PullRequest) GetBaseRepo() (err error) { // IsChecking returns true if this pull request is still checking conflict. func (pr *PullRequest) IsChecking() bool { - return pr.Status == PULL_REQUEST_STATUS_CHECKING + return pr.Status == PullRequestStatusChecking } // CanAutoMerge returns true if this pull request can be merged automatically. func (pr *PullRequest) CanAutoMerge() bool { - return pr.Status == PULL_REQUEST_STATUS_MERGEABLE + return pr.Status == PullRequestStatusMergeable } // Merge merges pull request to base repository. @@ -285,8 +285,8 @@ func (pr *PullRequest) Merge(doer *User, baseGitRepo *git.Repository) (err error log.Error(4, "LoadAttributes: %v", err) return nil } - if err = PrepareWebhooks(pr.Issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_CLOSED, + if err = PrepareWebhooks(pr.Issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueClosed, Index: pr.Index, PullRequest: pr.APIFormat(), Repository: pr.Issue.Repo.APIFormat(nil), @@ -323,7 +323,7 @@ func (pr *PullRequest) Merge(doer *User, baseGitRepo *git.Repository) (err error Pusher: pr.HeadRepo.MustOwner().APIFormat(), Sender: doer.APIFormat(), } - if err = PrepareWebhooks(pr.BaseRepo, HOOK_EVENT_PUSH, p); err != nil { + if err = PrepareWebhooks(pr.BaseRepo, HookEventPush, p); err != nil { return fmt.Errorf("PrepareWebhooks: %v", err) } return nil @@ -367,7 +367,7 @@ func (pr *PullRequest) testPatch() (err error) { return fmt.Errorf("UpdateLocalCopy: %v", err) } - pr.Status = PULL_REQUEST_STATUS_CHECKING + pr.Status = PullRequestStatusChecking _, stderr, err := process.ExecDir(-1, pr.BaseRepo.LocalCopyPath(), fmt.Sprintf("testPatch (git apply --check): %d", pr.BaseRepo.ID), "git", "apply", "--check", patchPath) @@ -376,7 +376,7 @@ func (pr *PullRequest) testPatch() (err error) { if strings.Contains(stderr, patchConflicts[i]) { log.Trace("PullRequest[%d].testPatch (apply): has conflit", pr.ID) fmt.Println(stderr) - pr.Status = PULL_REQUEST_STATUS_CONFLICT + pr.Status = PullRequestStatusConflict return nil } } @@ -414,8 +414,8 @@ func NewPullRequest(repo *Repository, pull *Issue, labelIDs []int64, uuids []str return fmt.Errorf("testPatch: %v", err) } // No conflict appears after test means mergeable. - if pr.Status == PULL_REQUEST_STATUS_CHECKING { - pr.Status = PULL_REQUEST_STATUS_MERGEABLE + if pr.Status == PullRequestStatusChecking { + pr.Status = PullRequestStatusMergeable } pr.IssueID = pull.ID @@ -430,7 +430,7 @@ func NewPullRequest(repo *Repository, pull *Issue, labelIDs []int64, uuids []str if err = NotifyWatchers(&Action{ ActUserID: pull.Poster.ID, ActUserName: pull.Poster.Name, - OpType: ACTION_CREATE_PULL_REQUEST, + OpType: ActionCreatePullRequest, Content: fmt.Sprintf("%d|%s", pull.Index, pull.Title), RepoID: repo.ID, RepoUserName: repo.Owner.Name, @@ -444,8 +444,8 @@ func NewPullRequest(repo *Repository, pull *Issue, labelIDs []int64, uuids []str pr.Issue = pull pull.PullRequest = pr - if err = PrepareWebhooks(repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_OPENED, + if err = PrepareWebhooks(repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueOpened, Index: pull.Index, PullRequest: pr.APIFormat(), Repository: repo.APIFormat(nil), @@ -618,7 +618,7 @@ func (pr *PullRequest) PushToBaseRepo() (err error) { // AddToTaskQueue adds itself to pull request test task queue. func (pr *PullRequest) AddToTaskQueue() { go PullRequestQueue.AddFunc(pr.ID, func() { - pr.Status = PULL_REQUEST_STATUS_CHECKING + pr.Status = PullRequestStatusChecking if err := pr.UpdateCols("status"); err != nil { log.Error(5, "AddToTaskQueue.UpdateCols[%d].(add to queue): %v", pr.ID, err) } @@ -693,8 +693,8 @@ func AddTestPullRequestTask(doer *User, repoID int64, branch string, isSync bool log.Error(4, "LoadAttributes: %v", err) continue } - if err = PrepareWebhooks(pr.Issue.Repo, HOOK_EVENT_PULL_REQUEST, &api.PullRequestPayload{ - Action: api.HOOK_ISSUE_SYNCHRONIZED, + if err = PrepareWebhooks(pr.Issue.Repo, HookEventPullRequest, &api.PullRequestPayload{ + Action: api.HookIssueSynchronized, Index: pr.Issue.Index, PullRequest: pr.Issue.PullRequest.APIFormat(), Repository: pr.Issue.Repo.APIFormat(nil), @@ -733,8 +733,8 @@ func ChangeUsernameInPullRequests(oldUserName, newUserName string) error { // and set to be either conflict or mergeable. func (pr *PullRequest) checkAndUpdateStatus() { // Status is not changed to conflict means mergeable. - if pr.Status == PULL_REQUEST_STATUS_CHECKING { - pr.Status = PULL_REQUEST_STATUS_MERGEABLE + if pr.Status == PullRequestStatusChecking { + pr.Status = PullRequestStatusMergeable } // Make sure there is no waiting test to process before levaing the checking status. @@ -750,7 +750,7 @@ func (pr *PullRequest) checkAndUpdateStatus() { func TestPullRequests() { prs := make([]*PullRequest, 0, 10) x.Iterate(PullRequest{ - Status: PULL_REQUEST_STATUS_CHECKING, + Status: PullRequestStatusChecking, }, func(idx int, bean interface{}) error { pr := bean.(*PullRequest) diff --git a/models/webhook.go b/models/webhook.go index 3255f7904..bffddb359 100644 --- a/models/webhook.go +++ b/models/webhook.go @@ -77,8 +77,8 @@ type HookStatus int const ( HOOK_STATUS_NONE = iota - HOOK_STATUS_SUCCEED - HOOK_STATUS_FAILED + HookStatusSucceed + HookStatusFail ) // Webhook represents a web hook object. @@ -323,9 +323,9 @@ func IsValidHookTaskType(name string) bool { type HookEventType string const ( - HOOK_EVENT_CREATE HookEventType = "create" - HOOK_EVENT_PUSH HookEventType = "push" - HOOK_EVENT_PULL_REQUEST HookEventType = "pull_request" + HookEventCreate HookEventType = "create" + HookEventPush HookEventType = "push" + HookEventPullRequest HookEventType = "pull_request" ) // HookRequest represents hook task request information. @@ -459,15 +459,15 @@ func PrepareWebhooks(repo *Repository, event HookEventType, p api.Payloader) err var payloader api.Payloader for _, w := range ws { switch event { - case HOOK_EVENT_CREATE: + case HookEventCreate: if !w.HasCreateEvent() { continue } - case HOOK_EVENT_PUSH: + case HookEventPush: if !w.HasPushEvent() { continue } - case HOOK_EVENT_PULL_REQUEST: + case HookEventPullRequest: if !w.HasPullRequestEvent() { continue } @@ -544,9 +544,9 @@ func (t *HookTask) deliver() { return } if t.IsSucceed { - w.LastStatus = HOOK_STATUS_SUCCEED + w.LastStatus = HookStatusSucceed } else { - w.LastStatus = HOOK_STATUS_FAILED + w.LastStatus = HookStatusFail } if err = UpdateWebhook(w); err != nil { log.Error(5, "UpdateWebhook: %v", err) diff --git a/models/webhook_slack.go b/models/webhook_slack.go index ddc2008a3..51b3373e8 100644 --- a/models/webhook_slack.go +++ b/models/webhook_slack.go @@ -139,32 +139,32 @@ func getSlackPullRequestPayload(p *api.PullRequestPayload, slack *SlackMeta) (*S fmt.Sprintf("#%d %s", p.Index, p.PullRequest.Title)) var text, title, attachmentText string switch p.Action { - case api.HOOK_ISSUE_OPENED: + case api.HookIssueOpened: text = fmt.Sprintf("[%s] Pull request submitted by %s", p.Repository.FullName, senderLink) title = titleLink attachmentText = SlackTextFormatter(p.PullRequest.Body) - case api.HOOK_ISSUE_CLOSED: + case api.HookIssueClosed: if p.PullRequest.HasMerged { text = fmt.Sprintf("[%s] Pull request merged: %s by %s", p.Repository.FullName, titleLink, senderLink) } else { text = fmt.Sprintf("[%s] Pull request closed: %s by %s", p.Repository.FullName, titleLink, senderLink) } - case api.HOOK_ISSUE_REOPENED: + case api.HookIssueReopened: text = fmt.Sprintf("[%s] Pull request re-opened: %s by %s", p.Repository.FullName, titleLink, senderLink) - case api.HOOK_ISSUE_EDITED: + case api.HookIssueEdited: text = fmt.Sprintf("[%s] Pull request edited: %s by %s", p.Repository.FullName, titleLink, senderLink) attachmentText = SlackTextFormatter(p.PullRequest.Body) - case api.HOOK_ISSUE_ASSIGNED: + case api.HookIssueAssigned: text = fmt.Sprintf("[%s] Pull request assigned to %s: %s by %s", p.Repository.FullName, SlackLinkFormatter(setting.AppUrl+p.PullRequest.Assignee.UserName, p.PullRequest.Assignee.UserName), titleLink, senderLink) - case api.HOOK_ISSUE_UNASSIGNED: + case api.HookIssueUnassigned: text = fmt.Sprintf("[%s] Pull request unassigned: %s by %s", p.Repository.FullName, titleLink, senderLink) - case api.HOOK_ISSUE_LABEL_UPDATED: + case api.HookIssueLabelUpdated: text = fmt.Sprintf("[%s] Pull request labels updated: %s by %s", p.Repository.FullName, titleLink, senderLink) - case api.HOOK_ISSUE_LABEL_CLEARED: + case api.HookIssueLabelCleared: text = fmt.Sprintf("[%s] Pull request labels cleared: %s by %s", p.Repository.FullName, titleLink, senderLink) - case api.HOOK_ISSUE_SYNCHRONIZED: + case api.HookIssueSynchronized: text = fmt.Sprintf("[%s] Pull request synchronized: %s by %s", p.Repository.FullName, titleLink, senderLink) } @@ -190,11 +190,11 @@ func GetSlackPayload(p api.Payloader, event HookEventType, meta string) (*SlackP } switch event { - case HOOK_EVENT_CREATE: + case HookEventCreate: return getSlackCreatePayload(p.(*api.CreatePayload), slack) - case HOOK_EVENT_PUSH: + case HookEventPush: return getSlackPushPayload(p.(*api.PushPayload), slack) - case HOOK_EVENT_PULL_REQUEST: + case HookEventPullRequest: return getSlackPullRequestPayload(p.(*api.PullRequestPayload), slack) } diff --git a/routers/api/v1/repo/hook.go b/routers/api/v1/repo/hook.go index 3d0bb80a7..32fe41155 100644 --- a/routers/api/v1/repo/hook.go +++ b/routers/api/v1/repo/hook.go @@ -59,9 +59,9 @@ func CreateHook(ctx *context.APIContext, form api.CreateHookOption) { HookEvent: &models.HookEvent{ ChooseEvents: true, HookEvents: models.HookEvents{ - Create: com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_CREATE)), - Push: com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PUSH)), - PullRequest: com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PULL_REQUEST)), + Create: com.IsSliceContainsStr(form.Events, string(models.HookEventCreate)), + Push: com.IsSliceContainsStr(form.Events, string(models.HookEventPush)), + PullRequest: com.IsSliceContainsStr(form.Events, string(models.HookEventPullRequest)), }, }, IsActive: form.Active, @@ -145,9 +145,9 @@ func EditHook(ctx *context.APIContext, form api.EditHookOption) { w.PushOnly = false w.SendEverything = false w.ChooseEvents = true - w.Create = com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_CREATE)) - w.Push = com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PUSH)) - w.PullRequest = com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PULL_REQUEST)) + w.Create = com.IsSliceContainsStr(form.Events, string(models.HookEventCreate)) + w.Push = com.IsSliceContainsStr(form.Events, string(models.HookEventPush)) + w.PullRequest = com.IsSliceContainsStr(form.Events, string(models.HookEventPullRequest)) if err = w.UpdateEvent(); err != nil { ctx.Error(500, "UpdateEvent", err) return diff --git a/routers/repo/pull.go b/routers/repo/pull.go index 0fdffad2d..1a5b1dd9e 100644 --- a/routers/repo/pull.go +++ b/routers/repo/pull.go @@ -687,7 +687,7 @@ func CompareAndPullRequestPost(ctx *context.Context, form auth.CreateIssueForm) HeadRepo: headRepo, BaseRepo: repo, MergeBase: prInfo.MergeBase, - Type: models.PULL_REQUEST_GITEA, + Type: models.PullRequestGitea, } // FIXME: check error in the case two people send pull request at almost same time, give nice error prompt // instead of 500. diff --git a/routers/repo/webhook.go b/routers/repo/webhook.go index 3cb6d1d27..c9d15bef0 100644 --- a/routers/repo/webhook.go +++ b/routers/repo/webhook.go @@ -383,7 +383,7 @@ func TestWebhook(ctx *context.Context) { Pusher: apiUser, Sender: apiUser, } - if err := models.PrepareWebhooks(ctx.Repo.Repository, models.HOOK_EVENT_PUSH, p); err != nil { + if err := models.PrepareWebhooks(ctx.Repo.Repository, models.HookEventPush, p); err != nil { ctx.Flash.Error("PrepareWebhooks: " + err.Error()) ctx.Status(500) } else { diff --git a/vendor/github.com/go-gitea/go-sdk/gitea/repo_hook.go b/vendor/github.com/go-gitea/go-sdk/gitea/repo_hook.go index 7f71bea1f..01cb25421 100644 --- a/vendor/github.com/go-gitea/go-sdk/gitea/repo_hook.go +++ b/vendor/github.com/go-gitea/go-sdk/gitea/repo_hook.go @@ -198,15 +198,15 @@ func (p *PushPayload) Branch() string { type HookIssueAction string const ( - HOOK_ISSUE_OPENED HookIssueAction = "opened" - HOOK_ISSUE_CLOSED HookIssueAction = "closed" - HOOK_ISSUE_REOPENED HookIssueAction = "reopened" - HOOK_ISSUE_EDITED HookIssueAction = "edited" - HOOK_ISSUE_ASSIGNED HookIssueAction = "assigned" - HOOK_ISSUE_UNASSIGNED HookIssueAction = "unassigned" - HOOK_ISSUE_LABEL_UPDATED HookIssueAction = "label_updated" - HOOK_ISSUE_LABEL_CLEARED HookIssueAction = "label_cleared" - HOOK_ISSUE_SYNCHRONIZED HookIssueAction = "synchronized" + HookIssueOpened HookIssueAction = "opened" + HookIssueClosed HookIssueAction = "closed" + HookIssueReopened HookIssueAction = "reopened" + HookIssueEdited HookIssueAction = "edited" + HookIssueAssigned HookIssueAction = "assigned" + HookIssueUnassigned HookIssueAction = "unassigned" + HookIssueLabelUpdated HookIssueAction = "label_updated" + HookIssueLabelCleared HookIssueAction = "label_cleared" + HookIssueSynchronized HookIssueAction = "synchronized" ) type ChangesFromPayload struct { From 0b62aeb495c9c1daf816a754a0e4abbf8c62c2c0 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:08:21 +0100 Subject: [PATCH 02/12] More MixedCase consts --- models/webhook.go | 2 +- routers/repo/setting.go | 4 ++-- routers/repo/webhook.go | 8 ++++---- vendor/github.com/go-gitea/git/hook.go | 4 ++-- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/models/webhook.go b/models/webhook.go index bffddb359..4b5501715 100644 --- a/models/webhook.go +++ b/models/webhook.go @@ -76,7 +76,7 @@ type HookEvent struct { type HookStatus int const ( - HOOK_STATUS_NONE = iota + HookStatusNone = iota HookStatusSucceed HookStatusFail ) diff --git a/routers/repo/setting.go b/routers/repo/setting.go index eab02e52f..a97f8f71f 100644 --- a/routers/repo/setting.go +++ b/routers/repo/setting.go @@ -22,7 +22,7 @@ const ( SETTINGS_OPTIONS base.TplName = "repo/settings/options" COLLABORATION base.TplName = "repo/settings/collaboration" GITHOOKS base.TplName = "repo/settings/githooks" - GITHOOK_EDIT base.TplName = "repo/settings/githook_edit" + GithookEdit base.TplName = "repo/settings/githook_edit" DEPLOY_KEYS base.TplName = "repo/settings/deploy_keys" ) @@ -425,7 +425,7 @@ func GitHooksEdit(ctx *context.Context) { return } ctx.Data["Hook"] = hook - ctx.HTML(200, GITHOOK_EDIT) + ctx.HTML(200, GithookEdit) } func GitHooksEditPost(ctx *context.Context) { diff --git a/routers/repo/webhook.go b/routers/repo/webhook.go index c9d15bef0..918c34016 100644 --- a/routers/repo/webhook.go +++ b/routers/repo/webhook.go @@ -24,8 +24,8 @@ import ( const ( HOOKS base.TplName = "repo/settings/hooks" - HOOK_NEW base.TplName = "repo/settings/hook_new" - ORG_HOOK_NEW base.TplName = "org/settings/hook_new" + HookNew base.TplName = "repo/settings/hook_new" + ORG_HookNew base.TplName = "org/settings/hook_new" ) func Webhooks(ctx *context.Context) { @@ -57,7 +57,7 @@ func getOrgRepoCtx(ctx *context.Context) (*OrgRepoCtx, error) { return &OrgRepoCtx{ RepoID: ctx.Repo.Repository.ID, Link: ctx.Repo.RepoLink, - NewTemplate: HOOK_NEW, + NewTemplate: HookNew, }, nil } @@ -65,7 +65,7 @@ func getOrgRepoCtx(ctx *context.Context) (*OrgRepoCtx, error) { return &OrgRepoCtx{ OrgID: ctx.Org.Organization.ID, Link: ctx.Org.OrgLink, - NewTemplate: ORG_HOOK_NEW, + NewTemplate: ORG_HookNew, }, nil } diff --git a/vendor/github.com/go-gitea/git/hook.go b/vendor/github.com/go-gitea/git/hook.go index 20da99392..086bf7126 100644 --- a/vendor/github.com/go-gitea/git/hook.go +++ b/vendor/github.com/go-gitea/git/hook.go @@ -102,13 +102,13 @@ func ListHooks(repoPath string) (_ []*Hook, err error) { } const ( - HOOK_PATH_UPDATE = "hooks/update" + HookPathUpdate = "hooks/update" ) // SetUpdateHook writes given content to update hook of the reposiotry. func SetUpdateHook(repoPath, content string) (err error) { log("Setting update hook: %s", repoPath) - hookPath := path.Join(repoPath, HOOK_PATH_UPDATE) + hookPath := path.Join(repoPath, HookPathUpdate) if com.IsExist(hookPath) { err = os.Remove(hookPath) } else { From f388661bda8097b5ff01548e6153c566690c9b5e Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:20:37 +0100 Subject: [PATCH 03/12] ACCESS_MODE_* -> AccessMode* --- cmd/serve.go | 14 ++++++------- models/access.go | 38 ++++++++++++++++++------------------ models/issue.go | 2 +- models/org.go | 2 +- models/org_team.go | 2 +- models/repo.go | 4 ++-- models/repo_collaboration.go | 10 +++++----- models/ssh_key.go | 6 +++--- models/user.go | 6 +++--- modules/context/org.go | 2 +- modules/context/repo.go | 12 ++++++------ routers/api/v1/api.go | 2 +- routers/api/v1/repo/repo.go | 4 ++-- routers/org/teams.go | 6 +++--- routers/repo/http.go | 8 ++++---- 15 files changed, 59 insertions(+), 59 deletions(-) diff --git a/cmd/serve.go b/cmd/serve.go index eaaeeb7bc..4e99ebe5f 100644 --- a/cmd/serve.go +++ b/cmd/serve.go @@ -64,9 +64,9 @@ func parseCmd(cmd string) (string, string) { var ( allowedCommands = map[string]models.AccessMode{ - "git-upload-pack": models.ACCESS_MODE_READ, - "git-upload-archive": models.ACCESS_MODE_READ, - "git-receive-pack": models.ACCESS_MODE_WRITE, + "git-upload-pack": models.AccessModeRead, + "git-upload-archive": models.AccessModeRead, + "git-receive-pack": models.AccessModeWrite, } ) @@ -191,7 +191,7 @@ func runServ(c *cli.Context) error { } // Prohibit push to mirror repositories. - if requestedMode > models.ACCESS_MODE_READ && repo.IsMirror { + if requestedMode > models.AccessModeRead && repo.IsMirror { fail("mirror repository is read-only", "") } @@ -200,7 +200,7 @@ func runServ(c *cli.Context) error { keyID int64 user *models.User ) - if requestedMode == models.ACCESS_MODE_WRITE || repo.IsPrivate { + if requestedMode == models.AccessModeWrite || repo.IsPrivate { keys := strings.Split(c.Args()[0], "-") if len(keys) != 2 { fail("Key ID format error", "Invalid key argument: %s", c.Args()[0]) @@ -243,7 +243,7 @@ func runServ(c *cli.Context) error { fail("Internal error", "Fail to check access: %v", err) } else if mode < requestedMode { clientMessage := accessDenied - if mode >= models.ACCESS_MODE_READ { + if mode >= models.AccessModeRead { clientMessage = "You do not have sufficient authorization for this action" } fail(clientMessage, @@ -276,7 +276,7 @@ func runServ(c *cli.Context) error { fail("Internal error", "Failed to execute git command: %v", err) } - if requestedMode == models.ACCESS_MODE_WRITE { + if requestedMode == models.AccessModeWrite { handleUpdateTask(uuid, user, repoUser, reponame, isWiki) } diff --git a/models/access.go b/models/access.go index e46819f2d..fa3642cf5 100644 --- a/models/access.go +++ b/models/access.go @@ -13,22 +13,22 @@ import ( type AccessMode int const ( - ACCESS_MODE_NONE AccessMode = iota // 0 - ACCESS_MODE_READ // 1 - ACCESS_MODE_WRITE // 2 - ACCESS_MODE_ADMIN // 3 - ACCESS_MODE_OWNER // 4 + AccessModeNone AccessMode = iota // 0 + AccessModeRead // 1 + AccessModeWrite // 2 + AccessModeAdmin // 3 + AccessModeOwner // 4 ) func (mode AccessMode) String() string { switch mode { - case ACCESS_MODE_READ: + case AccessModeRead: return "read" - case ACCESS_MODE_WRITE: + case AccessModeWrite: return "write" - case ACCESS_MODE_ADMIN: + case AccessModeAdmin: return "admin" - case ACCESS_MODE_OWNER: + case AccessModeOwner: return "owner" default: return "none" @@ -39,11 +39,11 @@ func (mode AccessMode) String() string { func ParseAccessMode(permission string) AccessMode { switch permission { case "write": - return ACCESS_MODE_WRITE + return AccessModeWrite case "admin": - return ACCESS_MODE_ADMIN + return AccessModeAdmin default: - return ACCESS_MODE_READ + return AccessModeRead } } @@ -58,9 +58,9 @@ type Access struct { } func accessLevel(e Engine, u *User, repo *Repository) (AccessMode, error) { - mode := ACCESS_MODE_NONE + mode := AccessModeNone if !repo.IsPrivate { - mode = ACCESS_MODE_READ + mode = AccessModeRead } if u == nil { @@ -68,7 +68,7 @@ func accessLevel(e Engine, u *User, repo *Repository) (AccessMode, error) { } if u.ID == repo.OwnerID { - return ACCESS_MODE_OWNER, nil + return AccessModeOwner, nil } a := &Access{UserID: u.ID, RepoID: repo.ID} @@ -135,7 +135,7 @@ func (user *User) GetAccessibleRepositories(limit int) (repos []*Repository, _ e } func maxAccessMode(modes ...AccessMode) AccessMode { - max := ACCESS_MODE_NONE + max := AccessModeNone for _, mode := range modes { if mode > max { max = mode @@ -146,9 +146,9 @@ func maxAccessMode(modes ...AccessMode) AccessMode { // FIXME: do corss-comparison so reduce deletions and additions to the minimum? func (repo *Repository) refreshAccesses(e Engine, accessMap map[int64]AccessMode) (err error) { - minMode := ACCESS_MODE_READ + minMode := AccessModeRead if !repo.IsPrivate { - minMode = ACCESS_MODE_WRITE + minMode = AccessModeWrite } newAccesses := make([]Access, 0, len(accessMap)) @@ -212,7 +212,7 @@ func (repo *Repository) recalculateTeamAccesses(e Engine, ignTeamID int64) (err // Owner team gets owner access, and skip for teams that do not // have relations with repository. if t.IsOwnerTeam() { - t.Authorize = ACCESS_MODE_OWNER + t.Authorize = AccessModeOwner } else if !t.hasRepository(e, repo.ID) { continue } diff --git a/models/issue.go b/models/issue.go index 06b8183a4..a331883c4 100644 --- a/models/issue.go +++ b/models/issue.go @@ -624,7 +624,7 @@ func newIssue(e *xorm.Session, opts NewIssueOptions) (err error) { // Assume assignee is invalid and drop silently. opts.Issue.AssigneeID = 0 if assignee != nil { - valid, err := hasAccess(e, assignee, opts.Repo, ACCESS_MODE_WRITE) + valid, err := hasAccess(e, assignee, opts.Repo, AccessModeWrite) if err != nil { return fmt.Errorf("hasAccess [user_id: %d, repo_id: %d]: %v", assignee.ID, opts.Repo.ID, err) } diff --git a/models/org.go b/models/org.go index ec5408185..42470dce7 100644 --- a/models/org.go +++ b/models/org.go @@ -141,7 +141,7 @@ func CreateOrganization(org, owner *User) (err error) { OrgID: org.ID, LowerName: strings.ToLower(OWNER_TEAM), Name: OWNER_TEAM, - Authorize: ACCESS_MODE_OWNER, + Authorize: AccessModeOwner, NumMembers: 1, } if _, err = sess.Insert(t); err != nil { diff --git a/models/org_team.go b/models/org_team.go index 07a90e08f..b0796248a 100644 --- a/models/org_team.go +++ b/models/org_team.go @@ -155,7 +155,7 @@ func (t *Team) removeRepository(e Engine, repo *Repository, recalculate bool) (e return fmt.Errorf("get team members: %v", err) } for _, u := range t.Members { - has, err := hasAccess(e, u, repo, ACCESS_MODE_READ) + has, err := hasAccess(e, u, repo, AccessModeRead) if err != nil { return err } else if has { diff --git a/models/repo.go b/models/repo.go index 6ae7d9a25..bf34e97d0 100644 --- a/models/repo.go +++ b/models/repo.go @@ -334,7 +334,7 @@ func (repo *Repository) getAssignees(e Engine) (_ []*User, err error) { } accesses := make([]*Access, 0, 10) - if err = e.Where("repo_id = ? AND mode >= ?", repo.ID, ACCESS_MODE_WRITE).Find(&accesses); err != nil { + if err = e.Where("repo_id = ? AND mode >= ?", repo.ID, AccessModeWrite).Find(&accesses); err != nil { return nil, err } @@ -418,7 +418,7 @@ func (repo *Repository) ComposeCompareURL(oldCommitID, newCommitID string) strin } func (repo *Repository) HasAccess(u *User) bool { - has, _ := HasAccess(u, repo, ACCESS_MODE_READ) + has, _ := HasAccess(u, repo, AccessModeRead) return has } diff --git a/models/repo_collaboration.go b/models/repo_collaboration.go index f4b23f9eb..214aa2a01 100644 --- a/models/repo_collaboration.go +++ b/models/repo_collaboration.go @@ -18,11 +18,11 @@ type Collaboration struct { func (c *Collaboration) ModeI18nKey() string { switch c.Mode { - case ACCESS_MODE_READ: + case AccessModeRead: return "repo.settings.collaboration.read" - case ACCESS_MODE_WRITE: + case AccessModeWrite: return "repo.settings.collaboration.write" - case ACCESS_MODE_ADMIN: + case AccessModeAdmin: return "repo.settings.collaboration.admin" default: return "repo.settings.collaboration.undefined" @@ -42,7 +42,7 @@ func (repo *Repository) AddCollaborator(u *User) error { } else if has { return nil } - collaboration.Mode = ACCESS_MODE_WRITE + collaboration.Mode = AccessModeWrite sess := x.NewSession() defer sessionRelease(sess) @@ -105,7 +105,7 @@ func (repo *Repository) GetCollaborators() ([]*Collaborator, error) { // ChangeCollaborationAccessMode sets new access mode for the collaboration. func (repo *Repository) ChangeCollaborationAccessMode(uid int64, mode AccessMode) error { // Discard invalid input - if mode <= ACCESS_MODE_NONE || mode > ACCESS_MODE_OWNER { + if mode <= AccessModeNone || mode > AccessModeOwner { return nil } diff --git a/models/ssh_key.go b/models/ssh_key.go index 77adce9f3..08483b83d 100644 --- a/models/ssh_key.go +++ b/models/ssh_key.go @@ -415,7 +415,7 @@ func AddPublicKey(ownerID int64, name, content string) (*PublicKey, error) { OwnerID: ownerID, Name: name, Content: content, - Mode: ACCESS_MODE_WRITE, + Mode: AccessModeWrite, Type: KEY_TYPE_USER, } if err = addKey(sess, key); err != nil { @@ -642,7 +642,7 @@ func AddDeployKey(repoID int64, name, content string) (*DeployKey, error) { pkey := &PublicKey{ Content: content, - Mode: ACCESS_MODE_READ, + Mode: AccessModeRead, Type: KEY_TYPE_DEPLOY, } has, err := x.Get(pkey) @@ -720,7 +720,7 @@ func DeleteDeployKey(doer *User, id int64) error { if err != nil { return fmt.Errorf("GetRepositoryByID: %v", err) } - yes, err := HasAccess(doer, repo, ACCESS_MODE_ADMIN) + yes, err := HasAccess(doer, repo, AccessModeAdmin) if err != nil { return fmt.Errorf("HasAccess: %v", err) } else if !yes { diff --git a/models/user.go b/models/user.go index ffa2f6440..dcb2311cf 100644 --- a/models/user.go +++ b/models/user.go @@ -375,7 +375,7 @@ func (u *User) DeleteAvatar() error { // IsAdminOfRepo returns true if user has admin or higher access of repository. func (u *User) IsAdminOfRepo(repo *Repository) bool { - has, err := HasAccess(u, repo, ACCESS_MODE_ADMIN) + has, err := HasAccess(u, repo, AccessModeAdmin) if err != nil { log.Error(3, "HasAccess: %v", err) } @@ -384,7 +384,7 @@ func (u *User) IsAdminOfRepo(repo *Repository) bool { // IsWriterOfRepo returns true if user has write access to given repository. func (u *User) IsWriterOfRepo(repo *Repository) bool { - has, err := HasAccess(u, repo, ACCESS_MODE_WRITE) + has, err := HasAccess(u, repo, AccessModeWrite) if err != nil { log.Error(3, "HasAccess: %v", err) } @@ -886,7 +886,7 @@ func GetUserByID(id int64) (*User, error) { // GetAssigneeByID returns the user with write access of repository by given ID. func GetAssigneeByID(repo *Repository, userID int64) (*User, error) { - has, err := HasAccess(&User{ID: userID}, repo, ACCESS_MODE_WRITE) + has, err := HasAccess(&User{ID: userID}, repo, AccessModeWrite) if err != nil { return nil, err } else if !has { diff --git a/modules/context/org.go b/modules/context/org.go index 3804e210e..acf83ff14 100644 --- a/modules/context/org.go +++ b/modules/context/org.go @@ -136,7 +136,7 @@ func HandleOrgAssignment(ctx *Context, args ...bool) { return } - ctx.Org.IsTeamAdmin = ctx.Org.Team.IsOwnerTeam() || ctx.Org.Team.Authorize >= models.ACCESS_MODE_ADMIN + ctx.Org.IsTeamAdmin = ctx.Org.Team.IsOwnerTeam() || ctx.Org.Team.Authorize >= models.AccessModeAdmin ctx.Data["IsTeamAdmin"] = ctx.Org.IsTeamAdmin if requireTeamAdmin && !ctx.Org.IsTeamAdmin { ctx.Handle(404, "OrgAssignment", err) diff --git a/modules/context/repo.go b/modules/context/repo.go index 8dadf3a1e..0212aece9 100644 --- a/modules/context/repo.go +++ b/modules/context/repo.go @@ -51,22 +51,22 @@ type Repository struct { // IsOwner returns true if current user is the owner of repository. func (r *Repository) IsOwner() bool { - return r.AccessMode >= models.ACCESS_MODE_OWNER + return r.AccessMode >= models.AccessModeOwner } // IsAdmin returns true if current user has admin or higher access of repository. func (r *Repository) IsAdmin() bool { - return r.AccessMode >= models.ACCESS_MODE_ADMIN + return r.AccessMode >= models.AccessModeAdmin } // IsWriter returns true if current user has write or higher access of repository. func (r *Repository) IsWriter() bool { - return r.AccessMode >= models.ACCESS_MODE_WRITE + return r.AccessMode >= models.AccessModeWrite } // HasAccess returns true if the current user has at least read access for this repository func (r *Repository) HasAccess() bool { - return r.AccessMode >= models.ACCESS_MODE_READ + return r.AccessMode >= models.AccessModeRead } // CanEnableEditor returns true if repository is editable and user has proper access level. @@ -192,7 +192,7 @@ func RepoAssignment(args ...bool) macaron.Handler { // Admin has super access. if ctx.IsSigned && ctx.User.IsAdmin { - ctx.Repo.AccessMode = models.ACCESS_MODE_OWNER + ctx.Repo.AccessMode = models.AccessModeOwner } else { mode, err := models.AccessLevel(ctx.User, repo) if err != nil { @@ -203,7 +203,7 @@ func RepoAssignment(args ...bool) macaron.Handler { } // Check access. - if ctx.Repo.AccessMode == models.ACCESS_MODE_NONE { + if ctx.Repo.AccessMode == models.AccessModeNone { if ctx.Query("go-get") == "1" { earlyResponseForGoGetMeta(ctx) return diff --git a/routers/api/v1/api.go b/routers/api/v1/api.go index 2deafa23c..e8db9cb8e 100644 --- a/routers/api/v1/api.go +++ b/routers/api/v1/api.go @@ -63,7 +63,7 @@ func repoAssignment() macaron.Handler { } if ctx.IsSigned && ctx.User.IsAdmin { - ctx.Repo.AccessMode = models.ACCESS_MODE_OWNER + ctx.Repo.AccessMode = models.AccessModeOwner } else { mode, err := models.AccessLevel(ctx.User, repo) if err != nil { diff --git a/routers/api/v1/repo/repo.go b/routers/api/v1/repo/repo.go index 0b28ee0f9..3aa8995c7 100644 --- a/routers/api/v1/repo/repo.go +++ b/routers/api/v1/repo/repo.go @@ -99,8 +99,8 @@ func ListMyRepos(ctx *context.APIContext) { for repo, access := range accessibleRepos { repos[i] = repo.APIFormat(&api.Permission{ - Admin: access >= models.ACCESS_MODE_ADMIN, - Push: access >= models.ACCESS_MODE_WRITE, + Admin: access >= models.AccessModeAdmin, + Push: access >= models.AccessModeWrite, Pull: true, }) i++ diff --git a/routers/org/teams.go b/routers/org/teams.go index c6636aa83..c2097935a 100644 --- a/routers/org/teams.go +++ b/routers/org/teams.go @@ -226,11 +226,11 @@ func EditTeamPost(ctx *context.Context, form auth.CreateTeamForm) { var auth models.AccessMode switch form.Permission { case "read": - auth = models.ACCESS_MODE_READ + auth = models.AccessModeRead case "write": - auth = models.ACCESS_MODE_WRITE + auth = models.AccessModeWrite case "admin": - auth = models.ACCESS_MODE_ADMIN + auth = models.AccessModeAdmin default: ctx.Error(401) return diff --git a/routers/repo/http.go b/routers/repo/http.go index 529dc3d34..5a3d331fd 100644 --- a/routers/repo/http.go +++ b/routers/repo/http.go @@ -133,9 +133,9 @@ func HTTP(ctx *context.Context) { } if !isPublicPull { - var tp = models.ACCESS_MODE_WRITE + var tp = models.AccessModeWrite if isPull { - tp = models.ACCESS_MODE_READ + tp = models.AccessModeRead } has, err := models.HasAccess(authUser, repo, tp) @@ -143,8 +143,8 @@ func HTTP(ctx *context.Context) { ctx.Handle(http.StatusInternalServerError, "HasAccess", err) return } else if !has { - if tp == models.ACCESS_MODE_READ { - has, err = models.HasAccess(authUser, repo, models.ACCESS_MODE_WRITE) + if tp == models.AccessModeRead { + has, err = models.HasAccess(authUser, repo, models.AccessModeWrite) if err != nil { ctx.Handle(http.StatusInternalServerError, "HasAccess2", err) return From f6a11e0de1ab950b42679d6be9dc0f3ac86c3399 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:24:59 +0100 Subject: [PATCH 04/12] More MixedCase consts --- models/admin.go | 6 ++--- models/git_diff.go | 58 ++++++++++++++++++++--------------------- models/git_diff_test.go | 4 +-- models/issue.go | 26 +++++++++--------- routers/repo/issue.go | 10 +++---- routers/user/home.go | 8 +++--- 6 files changed, 56 insertions(+), 56 deletions(-) diff --git a/models/admin.go b/models/admin.go index 3f17c2fda..dab92863a 100644 --- a/models/admin.go +++ b/models/admin.go @@ -22,7 +22,7 @@ import ( type NoticeType int const ( - NOTICE_REPOSITORY NoticeType = iota + 1 + NoticeRepository NoticeType = iota + 1 ) // Notice represents a system notice for admin. @@ -65,9 +65,9 @@ func CreateNotice(tp NoticeType, desc string) error { return err } -// CreateRepositoryNotice creates new system notice with type NOTICE_REPOSITORY. +// CreateRepositoryNotice creates new system notice with type NoticeRepository. func CreateRepositoryNotice(desc string) error { - return CreateNotice(NOTICE_REPOSITORY, desc) + return CreateNotice(NoticeRepository, desc) } // RemoveAllWithNotice removes all directories in given path and diff --git a/models/git_diff.go b/models/git_diff.go index 704a4a382..ffe9d9e81 100644 --- a/models/git_diff.go +++ b/models/git_diff.go @@ -31,18 +31,18 @@ import ( type DiffLineType uint8 const ( - DIFF_LINE_PLAIN DiffLineType = iota + 1 - DIFF_LINE_ADD - DIFF_LINE_DEL + DiffLinePlain DiffLineType = iota + 1 + DiffLineAdd + DiffLineDel DIFF_LINE_SECTION ) type DiffFileType uint8 const ( - DIFF_FILE_ADD DiffFileType = iota + 1 - DIFF_FILE_CHANGE - DIFF_FILE_DEL + DiffFileAdd DiffFileType = iota + 1 + DiffFileChange + DiffFileDel DIFF_FILE_RENAME ) @@ -73,19 +73,19 @@ func diffToHTML(diffs []diffmatchpatch.Diff, lineType DiffLineType) template.HTM // Reproduce signs which are cutted for inline diff before. switch lineType { - case DIFF_LINE_ADD: + case DiffLineAdd: buf.WriteByte('+') - case DIFF_LINE_DEL: + case DiffLineDel: buf.WriteByte('-') } for i := range diffs { switch { - case diffs[i].Type == diffmatchpatch.DiffInsert && lineType == DIFF_LINE_ADD: + case diffs[i].Type == diffmatchpatch.DiffInsert && lineType == DiffLineAdd: buf.Write(addedCodePrefix) buf.WriteString(html.EscapeString(diffs[i].Text)) buf.Write(codeTagSuffix) - case diffs[i].Type == diffmatchpatch.DiffDelete && lineType == DIFF_LINE_DEL: + case diffs[i].Type == diffmatchpatch.DiffDelete && lineType == DiffLineDel: buf.Write(removedCodePrefix) buf.WriteString(html.EscapeString(diffs[i].Text)) buf.Write(codeTagSuffix) @@ -109,9 +109,9 @@ func (diffSection *DiffSection) GetLine(lineType DiffLineType, idx int) *DiffLin LOOP: for _, diffLine := range diffSection.Lines { switch diffLine.Type { - case DIFF_LINE_ADD: + case DiffLineAdd: addCount++ - case DIFF_LINE_DEL: + case DiffLineDel: delCount++ default: if matchDiffLine != nil { @@ -123,11 +123,11 @@ LOOP: } switch lineType { - case DIFF_LINE_DEL: + case DiffLineDel: if diffLine.RightIdx == 0 && diffLine.LeftIdx == idx-difference { matchDiffLine = diffLine } - case DIFF_LINE_ADD: + case DiffLineAdd: if diffLine.LeftIdx == 0 && diffLine.RightIdx == idx+difference { matchDiffLine = diffLine } @@ -159,15 +159,15 @@ func (diffSection *DiffSection) GetComputedInlineDiffFor(diffLine *DiffLine) tem // try to find equivalent diff line. ignore, otherwise switch diffLine.Type { - case DIFF_LINE_ADD: - compareDiffLine = diffSection.GetLine(DIFF_LINE_DEL, diffLine.RightIdx) + case DiffLineAdd: + compareDiffLine = diffSection.GetLine(DiffLineDel, diffLine.RightIdx) if compareDiffLine == nil { return template.HTML(html.EscapeString(diffLine.Content)) } diff1 = compareDiffLine.Content diff2 = diffLine.Content - case DIFF_LINE_DEL: - compareDiffLine = diffSection.GetLine(DIFF_LINE_ADD, diffLine.LeftIdx) + case DiffLineDel: + compareDiffLine = diffSection.GetLine(DiffLineAdd, diffLine.LeftIdx) if compareDiffLine == nil { return template.HTML(html.EscapeString(diffLine.Content)) } @@ -264,7 +264,7 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* switch { case line[0] == ' ': - diffLine := &DiffLine{Type: DIFF_LINE_PLAIN, Content: line, LeftIdx: leftLine, RightIdx: rightLine} + diffLine := &DiffLine{Type: DiffLinePlain, Content: line, LeftIdx: leftLine, RightIdx: rightLine} leftLine++ rightLine++ curSection.Lines = append(curSection.Lines, diffLine) @@ -289,14 +289,14 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* case line[0] == '+': curFile.Addition++ diff.TotalAddition++ - diffLine := &DiffLine{Type: DIFF_LINE_ADD, Content: line, RightIdx: rightLine} + diffLine := &DiffLine{Type: DiffLineAdd, Content: line, RightIdx: rightLine} rightLine++ curSection.Lines = append(curSection.Lines, diffLine) continue case line[0] == '-': curFile.Deletion++ diff.TotalDeletion++ - diffLine := &DiffLine{Type: DIFF_LINE_DEL, Content: line, LeftIdx: leftLine} + diffLine := &DiffLine{Type: DiffLineDel, Content: line, LeftIdx: leftLine} if leftLine > 0 { leftLine++ } @@ -330,7 +330,7 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* curFile = &DiffFile{ Name: a, Index: len(diff.Files) + 1, - Type: DIFF_FILE_CHANGE, + Type: DiffFileChange, Sections: make([]*DiffSection, 0, 10), } diff.Files = append(diff.Files, curFile) @@ -354,13 +354,13 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* switch { case strings.HasPrefix(line, "new file"): - curFile.Type = DIFF_FILE_ADD + curFile.Type = DiffFileAdd curFile.IsCreated = true case strings.HasPrefix(line, "deleted"): - curFile.Type = DIFF_FILE_DEL + curFile.Type = DiffFileDel curFile.IsDeleted = true case strings.HasPrefix(line, "index"): - curFile.Type = DIFF_FILE_CHANGE + curFile.Type = DiffFileChange case strings.HasPrefix(line, "similarity index 100%"): curFile.Type = DIFF_FILE_RENAME curFile.IsRenamed = true @@ -459,8 +459,8 @@ func GetDiffRange(repoPath, beforeCommitID, afterCommitID string, maxLines, maxL type RawDiffType string const ( - RAW_DIFF_NORMAL RawDiffType = "diff" - RAW_DIFF_PATCH RawDiffType = "patch" + RawDiffNormal RawDiffType = "diff" + RawDiffPatch RawDiffType = "patch" ) // GetRawDiff dumps diff results of repository in given commit ID to io.Writer. @@ -478,14 +478,14 @@ func GetRawDiff(repoPath, commitID string, diffType RawDiffType, writer io.Write var cmd *exec.Cmd switch diffType { - case RAW_DIFF_NORMAL: + case RawDiffNormal: if commit.ParentCount() == 0 { cmd = exec.Command("git", "show", commitID) } else { c, _ := commit.Parent(0) cmd = exec.Command("git", "diff", "-M", c.ID.String(), commitID) } - case RAW_DIFF_PATCH: + case RawDiffPatch: if commit.ParentCount() == 0 { cmd = exec.Command("git", "format-patch", "--no-signature", "--stdout", "--root", commitID) } else { diff --git a/models/git_diff_test.go b/models/git_diff_test.go index 7f390adb3..cf98f6539 100644 --- a/models/git_diff_test.go +++ b/models/git_diff_test.go @@ -24,12 +24,12 @@ func TestDiffToHTML(t *testing.T) { dmp.Diff{dmp.DiffInsert, "bar"}, dmp.Diff{dmp.DiffDelete, " baz"}, dmp.Diff{dmp.DiffEqual, " biz"}, - }, DIFF_LINE_ADD)) + }, DiffLineAdd)) assertEqual(t, "-foo bar biz", diffToHTML([]dmp.Diff{ dmp.Diff{dmp.DiffEqual, "foo "}, dmp.Diff{dmp.DiffDelete, "bar"}, dmp.Diff{dmp.DiffInsert, " baz"}, dmp.Diff{dmp.DiffEqual, " biz"}, - }, DIFF_LINE_DEL)) + }, DiffLineDel)) } diff --git a/models/issue.go b/models/issue.go index a331883c4..6078f53f2 100644 --- a/models/issue.go +++ b/models/issue.go @@ -1005,9 +1005,9 @@ func GetIssueUserPairsByMode(uid, rid int64, isClosed bool, page, filterMode int } switch filterMode { - case FM_ASSIGN: + case FilterModeAssign: sess.And("is_assigned=?", true) - case FM_CREATE: + case FilterModeCreate: sess.And("is_poster=?", true) default: return ius, nil @@ -1070,10 +1070,10 @@ type IssueStats struct { // Filter modes. const ( - FM_ALL = iota - FM_ASSIGN - FM_CREATE - FM_MENTION + FilterModeAll = iota + FilterModeAssign + FilterModeCreate + FilterModeMention ) func parseCountResult(results []map[string][]byte) int64 { @@ -1122,7 +1122,7 @@ func GetIssueStats(opts *IssueStatsOptions) *IssueStats { } switch opts.FilterMode { - case FM_ALL, FM_ASSIGN: + case FilterModeAll, FilterModeAssign: stats.OpenCount, _ = countSession(opts). And("is_closed = ?", false). Count(&Issue{}) @@ -1130,7 +1130,7 @@ func GetIssueStats(opts *IssueStatsOptions) *IssueStats { stats.ClosedCount, _ = countSession(opts). And("is_closed = ?", true). Count(&Issue{}) - case FM_CREATE: + case FilterModeCreate: stats.OpenCount, _ = countSession(opts). And("poster_id = ?", opts.UserID). And("is_closed = ?", false). @@ -1140,7 +1140,7 @@ func GetIssueStats(opts *IssueStatsOptions) *IssueStats { And("poster_id = ?", opts.UserID). And("is_closed = ?", true). Count(&Issue{}) - case FM_MENTION: + case FilterModeMention: stats.OpenCount, _ = countSession(opts). Join("INNER", "issue_user", "issue.id = issue_user.issue_id"). And("issue_user.uid = ?", opts.UserID). @@ -1186,10 +1186,10 @@ func GetUserIssueStats(repoID, uid int64, repoIDs []int64, filterMode int, isPul closedCountSession := countSession(true, isPull, repoID, repoIDs) switch filterMode { - case FM_ASSIGN: + case FilterModeAssign: openCountSession.And("assignee_id = ?", uid) closedCountSession.And("assignee_id = ?", uid) - case FM_CREATE: + case FilterModeCreate: openCountSession.And("poster_id = ?", uid) closedCountSession.And("poster_id = ?", uid) } @@ -1214,10 +1214,10 @@ func GetRepoIssueStats(repoID, uid int64, filterMode int, isPull bool) (numOpen closedCountSession := countSession(true, isPull, repoID) switch filterMode { - case FM_ASSIGN: + case FilterModeAssign: openCountSession.And("assignee_id = ?", uid) closedCountSession.And("assignee_id = ?", uid) - case FM_CREATE: + case FilterModeCreate: openCountSession.And("poster_id = ?", uid) closedCountSession.And("poster_id = ?", uid) } diff --git a/routers/repo/issue.go b/routers/repo/issue.go index 8e8328c7e..9dff643ea 100644 --- a/routers/repo/issue.go +++ b/routers/repo/issue.go @@ -126,16 +126,16 @@ func Issues(ctx *context.Context) { assigneeID = ctx.QueryInt64("assignee") posterID int64 ) - filterMode := models.FM_ALL + filterMode := models.FilterModeAll switch viewType { case "assigned": - filterMode = models.FM_ASSIGN + filterMode = models.FilterModeAssign assigneeID = ctx.User.ID case "created_by": - filterMode = models.FM_CREATE + filterMode = models.FilterModeCreate posterID = ctx.User.ID case "mentioned": - filterMode = models.FM_MENTION + filterMode = models.FilterModeMention } var uid int64 = -1 @@ -179,7 +179,7 @@ func Issues(ctx *context.Context) { MilestoneID: milestoneID, Page: pager.Current(), IsClosed: isShowClosed, - IsMention: filterMode == models.FM_MENTION, + IsMention: filterMode == models.FilterModeMention, IsPull: isPullList, Labels: selectLabels, SortType: sortType, diff --git a/routers/user/home.go b/routers/user/home.go index fb079546e..bc22d86ea 100644 --- a/routers/user/home.go +++ b/routers/user/home.go @@ -172,7 +172,7 @@ func Issues(ctx *context.Context) { var ( viewType string sortType = ctx.Query("sort") - filterMode = models.FM_ALL + filterMode = models.FilterModeAll assigneeID int64 posterID int64 ) @@ -187,10 +187,10 @@ func Issues(ctx *context.Context) { switch viewType { case "assigned": - filterMode = models.FM_ASSIGN + filterMode = models.FilterModeAssign assigneeID = ctxUser.ID case "created_by": - filterMode = models.FM_CREATE + filterMode = models.FilterModeCreate posterID = ctxUser.ID } } @@ -235,7 +235,7 @@ func Issues(ctx *context.Context) { allCount += repo.NumOpenIssues } - if filterMode != models.FM_ALL { + if filterMode != models.FilterModeAll { // Calculate repository issue count with filter mode. numOpen, numClosed := repo.IssueStats(ctxUser.ID, filterMode, isPullList) repo.NumOpenIssues, repo.NumClosedIssues = int(numOpen), int(numClosed) From 60c82a87805821ad6eaf5aeb58a3a266b56a30ff Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:30:04 +0100 Subject: [PATCH 05/12] More... --- models/issue_comment.go | 22 ++++++++++---------- models/login_source.go | 30 ++++++++++++++-------------- models/mail.go | 12 +++++------ models/user.go | 4 ++-- routers/admin/auths.go | 10 +++++----- routers/admin/users.go | 2 +- routers/api/v1/admin/user.go | 2 +- routers/api/v1/repo/issue_comment.go | 2 +- routers/repo/issue.go | 10 +++++----- 9 files changed, 47 insertions(+), 47 deletions(-) diff --git a/models/issue_comment.go b/models/issue_comment.go index b8ab8c23e..124314ef3 100644 --- a/models/issue_comment.go +++ b/models/issue_comment.go @@ -23,8 +23,8 @@ type CommentType int const ( // Plain comment, can be associated with a commit (CommitID > 0) and a line (LineNum > 0) - COMMENT_TYPE_COMMENT CommentType = iota - COMMENT_TYPE_REOPEN + CommentTypeComment CommentType = iota + CommentTypeReopen COMMENT_TYPE_CLOSE // References. @@ -32,7 +32,7 @@ const ( // Reference from a commit (not part of a pull request) COMMENT_TYPE_COMMIT_REF // Reference from a comment - COMMENT_TYPE_COMMENT_REF + CommentTypeComment_REF // Reference from a pull request COMMENT_TYPE_PULL_REF ) @@ -40,9 +40,9 @@ const ( type CommentTag int const ( - COMMENT_TAG_NONE CommentTag = iota - COMMENT_TAG_POSTER - COMMENT_TAG_WRITER + CommentTagNone CommentTag = iota + CommentTagPoster + CommentTagWriter COMMENT_TAG_OWNER ) @@ -187,7 +187,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err // Check comment type. switch opts.Type { - case COMMENT_TYPE_COMMENT: + case CommentTypeComment: act.OpType = ActionCommentIssue if _, err = e.Exec("UPDATE `issue` SET num_comments=num_comments+1 WHERE id=?", opts.Issue.ID); err != nil { @@ -216,7 +216,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err } } - case COMMENT_TYPE_REOPEN: + case CommentTypeReopen: act.OpType = ActionReopenIssue if opts.Issue.IsPull { act.OpType = ActionReopenPullRequest @@ -262,7 +262,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err func createStatusComment(e *xorm.Session, doer *User, repo *Repository, issue *Issue) (*Comment, error) { cmtType := COMMENT_TYPE_CLOSE if !issue.IsClosed { - cmtType = COMMENT_TYPE_REOPEN + cmtType = CommentTypeReopen } return createComment(e, &CreateCommentOptions{ Type: cmtType, @@ -304,7 +304,7 @@ func CreateComment(opts *CreateCommentOptions) (comment *Comment, err error) { // CreateIssueComment creates a plain issue comment. func CreateIssueComment(doer *User, repo *Repository, issue *Issue, content string, attachments []string) (*Comment, error) { return CreateComment(&CreateCommentOptions{ - Type: COMMENT_TYPE_COMMENT, + Type: CommentTypeComment, Doer: doer, Repo: repo, Issue: issue, @@ -403,7 +403,7 @@ func DeleteCommentByID(id int64) error { return err } - if comment.Type == COMMENT_TYPE_COMMENT { + if comment.Type == CommentTypeComment { if _, err = sess.Exec("UPDATE `issue` SET num_comments = num_comments - 1 WHERE id = ?", comment.IssueID); err != nil { return err } diff --git a/models/login_source.go b/models/login_source.go index c9a0c7376..20cd89899 100644 --- a/models/login_source.go +++ b/models/login_source.go @@ -28,16 +28,16 @@ type LoginType int // Note: new type must append to the end of list to maintain compatibility. const ( - LOGIN_NOTYPE LoginType = iota - LOGIN_PLAIN // 1 - LOGIN_LDAP // 2 + LoginNotype LoginType = iota + LoginPlain // 1 + LoginLdap // 2 LOGIN_SMTP // 3 LOGIN_PAM // 4 LOGIN_DLDAP // 5 ) var LoginNames = map[LoginType]string{ - LOGIN_LDAP: "LDAP (via BindDN)", + LoginLdap: "LDAP (via BindDN)", LOGIN_DLDAP: "LDAP (simple auth)", // Via direct bind LOGIN_SMTP: "SMTP", LOGIN_PAM: "PAM", @@ -139,7 +139,7 @@ func (source *LoginSource) BeforeSet(colName string, val xorm.Cell) { switch colName { case "type": switch LoginType(Cell2Int64(val)) { - case LOGIN_LDAP, LOGIN_DLDAP: + case LoginLdap, LOGIN_DLDAP: source.Cfg = new(LDAPConfig) case LOGIN_SMTP: source.Cfg = new(SMTPConfig) @@ -165,7 +165,7 @@ func (source *LoginSource) TypeName() string { } func (source *LoginSource) IsLDAP() bool { - return source.Type == LOGIN_LDAP + return source.Type == LoginLdap } func (source *LoginSource) IsDLDAP() bool { @@ -188,7 +188,7 @@ func (source *LoginSource) HasTLS() bool { func (source *LoginSource) UseTLS() bool { switch source.Type { - case LOGIN_LDAP, LOGIN_DLDAP: + case LoginLdap, LOGIN_DLDAP: return source.LDAP().SecurityProtocol != ldap.SECURITY_PROTOCOL_UNENCRYPTED case LOGIN_SMTP: return source.SMTP().TLS @@ -199,7 +199,7 @@ func (source *LoginSource) UseTLS() bool { func (source *LoginSource) SkipVerify() bool { switch source.Type { - case LOGIN_LDAP, LOGIN_DLDAP: + case LoginLdap, LOGIN_DLDAP: return source.LDAP().SkipVerify case LOGIN_SMTP: return source.SMTP().SkipVerify @@ -358,11 +358,11 @@ func (auth *smtpLoginAuth) Next(fromServer []byte, more bool) ([]byte, error) { } const ( - SMTP_PLAIN = "PLAIN" - SMTP_LOGIN = "LOGIN" + SmtpPlain = "PLAIN" + SmtpLogin = "LOGIN" ) -var SMTPAuths = []string{SMTP_PLAIN, SMTP_LOGIN} +var SMTPAuths = []string{SmtpPlain, SmtpLogin} func SMTPAuth(a smtp.Auth, cfg *SMTPConfig) error { c, err := smtp.Dial(fmt.Sprintf("%s:%d", cfg.Host, cfg.Port)) @@ -411,9 +411,9 @@ func LoginViaSMTP(user *User, login, password string, sourceID int64, cfg *SMTPC } var auth smtp.Auth - if cfg.Auth == SMTP_PLAIN { + if cfg.Auth == SmtpPlain { auth = smtp.PlainAuth("", login, password, cfg.Host) - } else if cfg.Auth == SMTP_LOGIN { + } else if cfg.Auth == SmtpLogin { auth = &smtpLoginAuth{login, password} } else { return nil, errors.New("Unsupported SMTP auth type") @@ -493,7 +493,7 @@ func ExternalUserLogin(user *User, login, password string, source *LoginSource, } switch source.Type { - case LOGIN_LDAP, LOGIN_DLDAP: + case LoginLdap, LOGIN_DLDAP: return LoginViaLDAP(user, login, password, source, autoRegister) case LOGIN_SMTP: return LoginViaSMTP(user, login, password, source.ID, source.Cfg.(*SMTPConfig), autoRegister) @@ -520,7 +520,7 @@ func UserSignIn(username, passowrd string) (*User, error) { if hasUser { switch user.LoginType { - case LOGIN_NOTYPE, LOGIN_PLAIN: + case LoginNotype, LoginPlain: if user.ValidatePassword(passowrd) { return user, nil } diff --git a/models/mail.go b/models/mail.go index df5fd789b..77856553c 100644 --- a/models/mail.go +++ b/models/mail.go @@ -20,9 +20,9 @@ import ( ) const ( - MAIL_AUTH_ACTIVATE base.TplName = "auth/activate" - MAIL_AUTH_ACTIVATE_EMAIL base.TplName = "auth/activate_email" - MAIL_AUTH_RESET_PASSWORD base.TplName = "auth/reset_passwd" + MailAuthActivate base.TplName = "auth/activate" + MailAuthActivateEmail base.TplName = "auth/activate_email" + MailAuthResetPassword base.TplName = "auth/reset_passwd" MAIL_AUTH_REGISTER_NOTIFY base.TplName = "auth/register_notify" MAIL_ISSUE_COMMENT base.TplName = "issue/comment" @@ -77,11 +77,11 @@ func SendUserMail(c *macaron.Context, u *User, tpl base.TplName, code, subject, } func SendActivateAccountMail(c *macaron.Context, u *User) { - SendUserMail(c, u, MAIL_AUTH_ACTIVATE, u.GenerateActivateCode(), c.Tr("mail.activate_account"), "activate account") + SendUserMail(c, u, MailAuthActivate, u.GenerateActivateCode(), c.Tr("mail.activate_account"), "activate account") } func SendResetPasswordMail(c *macaron.Context, u *User) { - SendUserMail(c, u, MAIL_AUTH_RESET_PASSWORD, u.GenerateActivateCode(), c.Tr("mail.reset_password"), "reset password") + SendUserMail(c, u, MailAuthResetPassword, u.GenerateActivateCode(), c.Tr("mail.reset_password"), "reset password") } // SendActivateAccountMail sends confirmation email. @@ -92,7 +92,7 @@ func SendActivateEmailMail(c *macaron.Context, u *User, email *EmailAddress) { "Code": u.GenerateEmailActivateCode(email.Email), "Email": email.Email, } - body, err := mailRender.HTMLString(string(MAIL_AUTH_ACTIVATE_EMAIL), data) + body, err := mailRender.HTMLString(string(MailAuthActivateEmail), data) if err != nil { log.Error(3, "HTMLString: %v", err) return diff --git a/models/user.go b/models/user.go index dcb2311cf..ba41a392c 100644 --- a/models/user.go +++ b/models/user.go @@ -140,9 +140,9 @@ func (u *User) APIFormat() *api.User { } } -// returns true if user login type is LOGIN_PLAIN. +// returns true if user login type is LoginPlain. func (u *User) IsLocal() bool { - return u.LoginType <= LOGIN_PLAIN + return u.LoginType <= LoginPlain } // HasForkedRepo checks if user has already forked a repository with given ID. diff --git a/routers/admin/auths.go b/routers/admin/auths.go index dcd9a225a..44fe0ee9f 100644 --- a/routers/admin/auths.go +++ b/routers/admin/auths.go @@ -48,7 +48,7 @@ type dropdownItem struct { var ( authSources = []dropdownItem{ - {models.LoginNames[models.LOGIN_LDAP], models.LOGIN_LDAP}, + {models.LoginNames[models.LoginLdap], models.LoginLdap}, {models.LoginNames[models.LOGIN_DLDAP], models.LOGIN_DLDAP}, {models.LoginNames[models.LOGIN_SMTP], models.LOGIN_SMTP}, {models.LoginNames[models.LOGIN_PAM], models.LOGIN_PAM}, @@ -65,8 +65,8 @@ func NewAuthSource(ctx *context.Context) { ctx.Data["PageIsAdmin"] = true ctx.Data["PageIsAdminAuthentications"] = true - ctx.Data["type"] = models.LOGIN_LDAP - ctx.Data["CurrentTypeName"] = models.LoginNames[models.LOGIN_LDAP] + ctx.Data["type"] = models.LoginLdap + ctx.Data["CurrentTypeName"] = models.LoginNames[models.LoginLdap] ctx.Data["CurrentSecurityProtocol"] = models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_UNENCRYPTED] ctx.Data["smtp_auth"] = "PLAIN" ctx.Data["is_active"] = true @@ -125,7 +125,7 @@ func NewAuthSourcePost(ctx *context.Context, form auth.AuthenticationForm) { hasTLS := false var config core.Conversion switch models.LoginType(form.Type) { - case models.LOGIN_LDAP, models.LOGIN_DLDAP: + case models.LoginLdap, models.LOGIN_DLDAP: config = parseLDAPConfig(form) hasTLS = ldap.SecurityProtocol(form.SecurityProtocol) > ldap.SECURITY_PROTOCOL_UNENCRYPTED case models.LOGIN_SMTP: @@ -208,7 +208,7 @@ func EditAuthSourcePost(ctx *context.Context, form auth.AuthenticationForm) { var config core.Conversion switch models.LoginType(form.Type) { - case models.LOGIN_LDAP, models.LOGIN_DLDAP: + case models.LoginLdap, models.LOGIN_DLDAP: config = parseLDAPConfig(form) case models.LOGIN_SMTP: config = parseSMTPConfig(form) diff --git a/routers/admin/users.go b/routers/admin/users.go index 0eaa3c995..404d5ec3b 100644 --- a/routers/admin/users.go +++ b/routers/admin/users.go @@ -81,7 +81,7 @@ func NewUserPost(ctx *context.Context, form auth.AdminCrateUserForm) { Email: form.Email, Passwd: form.Password, IsActive: true, - LoginType: models.LOGIN_PLAIN, + LoginType: models.LoginPlain, } if len(form.LoginType) > 0 { diff --git a/routers/api/v1/admin/user.go b/routers/api/v1/admin/user.go index 1234dbf0c..5e9f763ee 100644 --- a/routers/api/v1/admin/user.go +++ b/routers/api/v1/admin/user.go @@ -42,7 +42,7 @@ func CreateUser(ctx *context.APIContext, form api.CreateUserOption) { Email: form.Email, Passwd: form.Password, IsActive: true, - LoginType: models.LOGIN_PLAIN, + LoginType: models.LoginPlain, } parseLoginSource(ctx, u, form.SourceID, form.LoginName) diff --git a/routers/api/v1/repo/issue_comment.go b/routers/api/v1/repo/issue_comment.go index 28751008d..11e236144 100644 --- a/routers/api/v1/repo/issue_comment.go +++ b/routers/api/v1/repo/issue_comment.go @@ -68,7 +68,7 @@ func EditIssueComment(ctx *context.APIContext, form api.EditIssueCommentOption) if !ctx.IsSigned || (ctx.User.ID != comment.PosterID && !ctx.Repo.IsAdmin()) { ctx.Status(403) return - } else if comment.Type != models.COMMENT_TYPE_COMMENT { + } else if comment.Type != models.CommentTypeComment { ctx.Status(204) return } diff --git a/routers/repo/issue.go b/routers/repo/issue.go index 9dff643ea..d3a91c84c 100644 --- a/routers/repo/issue.go +++ b/routers/repo/issue.go @@ -599,7 +599,7 @@ func ViewIssue(ctx *context.Context) { // Render comments and and fetch participants. participants[0] = issue.Poster for _, comment = range issue.Comments { - if comment.Type == models.COMMENT_TYPE_COMMENT { + if comment.Type == models.CommentTypeComment { comment.RenderedContent = string(markdown.Render([]byte(comment.Content), ctx.Repo.RepoLink, ctx.Repo.Repository.ComposeMetas())) @@ -614,9 +614,9 @@ func ViewIssue(ctx *context.Context) { (repo.Owner.IsOrganization() && repo.Owner.IsOwnedBy(comment.PosterID)) { comment.ShowTag = models.COMMENT_TAG_OWNER } else if comment.Poster.IsWriterOfRepo(repo) { - comment.ShowTag = models.COMMENT_TAG_WRITER + comment.ShowTag = models.CommentTagWriter } else if comment.PosterID == issue.PosterID { - comment.ShowTag = models.COMMENT_TAG_POSTER + comment.ShowTag = models.CommentTagPoster } marked[comment.PosterID] = comment.ShowTag @@ -892,7 +892,7 @@ func UpdateCommentContent(ctx *context.Context) { if !ctx.IsSigned || (ctx.User.ID != comment.PosterID && !ctx.Repo.IsAdmin()) { ctx.Error(403) return - } else if comment.Type != models.COMMENT_TYPE_COMMENT { + } else if comment.Type != models.CommentTypeComment { ctx.Error(204) return } @@ -924,7 +924,7 @@ func DeleteComment(ctx *context.Context) { if !ctx.IsSigned || (ctx.User.ID != comment.PosterID && !ctx.Repo.IsAdmin()) { ctx.Error(403) return - } else if comment.Type != models.COMMENT_TYPE_COMMENT { + } else if comment.Type != models.CommentTypeComment { ctx.Error(204) return } From f14232d2e982b7e6021df1b3c001269fa652632f Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:33:03 +0100 Subject: [PATCH 06/12] This one I overlooked before --- models/git_diff.go | 8 ++++---- models/repo.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/models/git_diff.go b/models/git_diff.go index ffe9d9e81..8c1b47ab6 100644 --- a/models/git_diff.go +++ b/models/git_diff.go @@ -34,7 +34,7 @@ const ( DiffLinePlain DiffLineType = iota + 1 DiffLineAdd DiffLineDel - DIFF_LINE_SECTION + DiffLineSection ) type DiffFileType uint8 @@ -43,7 +43,7 @@ const ( DiffFileAdd DiffFileType = iota + 1 DiffFileChange DiffFileDel - DIFF_FILE_RENAME + DiffFileRename ) type DiffLine struct { @@ -273,7 +273,7 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* curSection = &DiffSection{} curFile.Sections = append(curFile.Sections, curSection) ss := strings.Split(line, "@@") - diffLine := &DiffLine{Type: DIFF_LINE_SECTION, Content: line} + diffLine := &DiffLine{Type: DiffLineSection, Content: line} curSection.Lines = append(curSection.Lines, diffLine) // Parse line number. @@ -362,7 +362,7 @@ func ParsePatch(maxLines, maxLineCharacteres, maxFiles int, reader io.Reader) (* case strings.HasPrefix(line, "index"): curFile.Type = DiffFileChange case strings.HasPrefix(line, "similarity index 100%"): - curFile.Type = DIFF_FILE_RENAME + curFile.Type = DiffFileRename curFile.IsRenamed = true curFile.OldName = curFile.Name curFile.Name = b diff --git a/models/repo.go b/models/repo.go index bf34e97d0..5c5af32f4 100644 --- a/models/repo.go +++ b/models/repo.go @@ -35,7 +35,7 @@ import ( ) const ( - _TPL_UPDATE_HOOK = "#!/usr/bin/env %s\n%s update $1 $2 $3 --config='%s'\n" + tplUpdateHook = "#!/usr/bin/env %s\n%s update $1 $2 $3 --config='%s'\n" ) var repoWorkingPool = sync.NewExclusivePool() @@ -706,7 +706,7 @@ func cleanUpMigrateGitConfig(configPath string) error { func createUpdateHook(repoPath string) error { return git.SetUpdateHook(repoPath, - fmt.Sprintf(_TPL_UPDATE_HOOK, setting.ScriptType, "\""+setting.AppPath+"\"", setting.CustomConf)) + fmt.Sprintf(tplUpdateHook, setting.ScriptType, "\""+setting.AppPath+"\"", setting.CustomConf)) } // Finish migrating repository and/or wiki with things that don't need to be done for mirrors. From 64196d40361098568e6944e1b79bda5fe1e4ac06 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:35:34 +0100 Subject: [PATCH 07/12] More overlooks --- models/issue_comment.go | 18 +++++++++--------- routers/repo/issue.go | 2 +- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/models/issue_comment.go b/models/issue_comment.go index 124314ef3..5ea6369ab 100644 --- a/models/issue_comment.go +++ b/models/issue_comment.go @@ -25,16 +25,16 @@ const ( // Plain comment, can be associated with a commit (CommitID > 0) and a line (LineNum > 0) CommentTypeComment CommentType = iota CommentTypeReopen - COMMENT_TYPE_CLOSE + CommentTypeClose // References. - COMMENT_TYPE_ISSUE_REF + CommentTypeIssueRef // Reference from a commit (not part of a pull request) - COMMENT_TYPE_COMMIT_REF + CommentTypeCommitRef // Reference from a comment CommentTypeComment_REF // Reference from a pull request - COMMENT_TYPE_PULL_REF + CommentTypePullRef ) type CommentTag int @@ -43,7 +43,7 @@ const ( CommentTagNone CommentTag = iota CommentTagPoster CommentTagWriter - COMMENT_TAG_OWNER + CommentTagOwner ) // Comment represents a comment in commit and issue page. @@ -231,7 +231,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err return nil, err } - case COMMENT_TYPE_CLOSE: + case CommentTypeClose: act.OpType = ActionCloseIssue if opts.Issue.IsPull { act.OpType = ActionClosePullRequest @@ -260,7 +260,7 @@ func createComment(e *xorm.Session, opts *CreateCommentOptions) (_ *Comment, err } func createStatusComment(e *xorm.Session, doer *User, repo *Repository, issue *Issue) (*Comment, error) { - cmtType := COMMENT_TYPE_CLOSE + cmtType := CommentTypeClose if !issue.IsClosed { cmtType = CommentTypeReopen } @@ -321,7 +321,7 @@ func CreateRefComment(doer *User, repo *Repository, issue *Issue, content, commi // Check if same reference from same commit has already existed. has, err := x.Get(&Comment{ - Type: COMMENT_TYPE_COMMIT_REF, + Type: CommentTypeCommitRef, IssueID: issue.ID, CommitSHA: commitSHA, }) @@ -332,7 +332,7 @@ func CreateRefComment(doer *User, repo *Repository, issue *Issue, content, commi } _, err = CreateComment(&CreateCommentOptions{ - Type: COMMENT_TYPE_COMMIT_REF, + Type: CommentTypeCommitRef, Doer: doer, Repo: repo, Issue: issue, diff --git a/routers/repo/issue.go b/routers/repo/issue.go index d3a91c84c..df647a631 100644 --- a/routers/repo/issue.go +++ b/routers/repo/issue.go @@ -612,7 +612,7 @@ func ViewIssue(ctx *context.Context) { if repo.IsOwnedBy(comment.PosterID) || (repo.Owner.IsOrganization() && repo.Owner.IsOwnedBy(comment.PosterID)) { - comment.ShowTag = models.COMMENT_TAG_OWNER + comment.ShowTag = models.CommentTagOwner } else if comment.Poster.IsWriterOfRepo(repo) { comment.ShowTag = models.CommentTagWriter } else if comment.PosterID == issue.PosterID { From 7612b5ec40955a5a0b4d281645e33a86d1632f70 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:37:28 +0100 Subject: [PATCH 08/12] More mixage --- models/login_source.go | 44 +++++++++++++++++++++--------------------- routers/admin/auths.go | 18 ++++++++--------- 2 files changed, 31 insertions(+), 31 deletions(-) diff --git a/models/login_source.go b/models/login_source.go index 20cd89899..3140d35c5 100644 --- a/models/login_source.go +++ b/models/login_source.go @@ -31,16 +31,16 @@ const ( LoginNotype LoginType = iota LoginPlain // 1 LoginLdap // 2 - LOGIN_SMTP // 3 - LOGIN_PAM // 4 - LOGIN_DLDAP // 5 + LoginSmtp // 3 + LoginPam // 4 + LoginDldap // 5 ) var LoginNames = map[LoginType]string{ LoginLdap: "LDAP (via BindDN)", - LOGIN_DLDAP: "LDAP (simple auth)", // Via direct bind - LOGIN_SMTP: "SMTP", - LOGIN_PAM: "PAM", + LoginDldap: "LDAP (simple auth)", // Via direct bind + LoginSmtp: "SMTP", + LoginPam: "PAM", } var SecurityProtocolNames = map[ldap.SecurityProtocol]string{ @@ -139,11 +139,11 @@ func (source *LoginSource) BeforeSet(colName string, val xorm.Cell) { switch colName { case "type": switch LoginType(Cell2Int64(val)) { - case LoginLdap, LOGIN_DLDAP: + case LoginLdap, LoginDldap: source.Cfg = new(LDAPConfig) - case LOGIN_SMTP: + case LoginSmtp: source.Cfg = new(SMTPConfig) - case LOGIN_PAM: + case LoginPam: source.Cfg = new(PAMConfig) default: panic("unrecognized login source type: " + com.ToStr(*val)) @@ -169,15 +169,15 @@ func (source *LoginSource) IsLDAP() bool { } func (source *LoginSource) IsDLDAP() bool { - return source.Type == LOGIN_DLDAP + return source.Type == LoginDldap } func (source *LoginSource) IsSMTP() bool { - return source.Type == LOGIN_SMTP + return source.Type == LoginSmtp } func (source *LoginSource) IsPAM() bool { - return source.Type == LOGIN_PAM + return source.Type == LoginPam } func (source *LoginSource) HasTLS() bool { @@ -188,9 +188,9 @@ func (source *LoginSource) HasTLS() bool { func (source *LoginSource) UseTLS() bool { switch source.Type { - case LoginLdap, LOGIN_DLDAP: + case LoginLdap, LoginDldap: return source.LDAP().SecurityProtocol != ldap.SECURITY_PROTOCOL_UNENCRYPTED - case LOGIN_SMTP: + case LoginSmtp: return source.SMTP().TLS } @@ -199,9 +199,9 @@ func (source *LoginSource) UseTLS() bool { func (source *LoginSource) SkipVerify() bool { switch source.Type { - case LoginLdap, LOGIN_DLDAP: + case LoginLdap, LoginDldap: return source.LDAP().SkipVerify - case LOGIN_SMTP: + case LoginSmtp: return source.SMTP().SkipVerify } @@ -293,7 +293,7 @@ func composeFullName(firstname, surname, username string) string { // LoginViaLDAP queries if login/password is valid against the LDAP directory pool, // and create a local user if success when enabled. func LoginViaLDAP(user *User, login, passowrd string, source *LoginSource, autoRegister bool) (*User, error) { - username, fn, sn, mail, isAdmin, succeed := source.Cfg.(*LDAPConfig).SearchEntry(login, passowrd, source.Type == LOGIN_DLDAP) + username, fn, sn, mail, isAdmin, succeed := source.Cfg.(*LDAPConfig).SearchEntry(login, passowrd, source.Type == LoginDldap) if !succeed { // User not in LDAP, do nothing return nil, ErrUserNotExist{0, login} @@ -445,7 +445,7 @@ func LoginViaSMTP(user *User, login, password string, sourceID int64, cfg *SMTPC Name: strings.ToLower(username), Email: login, Passwd: password, - LoginType: LOGIN_SMTP, + LoginType: LoginSmtp, LoginSource: sourceID, LoginName: login, IsActive: true, @@ -479,7 +479,7 @@ func LoginViaPAM(user *User, login, password string, sourceID int64, cfg *PAMCon Name: login, Email: login, Passwd: password, - LoginType: LOGIN_PAM, + LoginType: LoginPam, LoginSource: sourceID, LoginName: login, IsActive: true, @@ -493,11 +493,11 @@ func ExternalUserLogin(user *User, login, password string, source *LoginSource, } switch source.Type { - case LoginLdap, LOGIN_DLDAP: + case LoginLdap, LoginDldap: return LoginViaLDAP(user, login, password, source, autoRegister) - case LOGIN_SMTP: + case LoginSmtp: return LoginViaSMTP(user, login, password, source.ID, source.Cfg.(*SMTPConfig), autoRegister) - case LOGIN_PAM: + case LoginPam: return LoginViaPAM(user, login, password, source.ID, source.Cfg.(*PAMConfig), autoRegister) } diff --git a/routers/admin/auths.go b/routers/admin/auths.go index 44fe0ee9f..7fbd1296a 100644 --- a/routers/admin/auths.go +++ b/routers/admin/auths.go @@ -49,9 +49,9 @@ type dropdownItem struct { var ( authSources = []dropdownItem{ {models.LoginNames[models.LoginLdap], models.LoginLdap}, - {models.LoginNames[models.LOGIN_DLDAP], models.LOGIN_DLDAP}, - {models.LoginNames[models.LOGIN_SMTP], models.LOGIN_SMTP}, - {models.LoginNames[models.LOGIN_PAM], models.LOGIN_PAM}, + {models.LoginNames[models.LoginDldap], models.LoginDldap}, + {models.LoginNames[models.LoginSmtp], models.LoginSmtp}, + {models.LoginNames[models.LoginPam], models.LoginPam}, } securityProtocols = []dropdownItem{ {models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_UNENCRYPTED], ldap.SECURITY_PROTOCOL_UNENCRYPTED}, @@ -125,13 +125,13 @@ func NewAuthSourcePost(ctx *context.Context, form auth.AuthenticationForm) { hasTLS := false var config core.Conversion switch models.LoginType(form.Type) { - case models.LoginLdap, models.LOGIN_DLDAP: + case models.LoginLdap, models.LoginDldap: config = parseLDAPConfig(form) hasTLS = ldap.SecurityProtocol(form.SecurityProtocol) > ldap.SECURITY_PROTOCOL_UNENCRYPTED - case models.LOGIN_SMTP: + case models.LoginSmtp: config = parseSMTPConfig(form) hasTLS = true - case models.LOGIN_PAM: + case models.LoginPam: config = &models.PAMConfig{ ServiceName: form.PAMServiceName, } @@ -208,11 +208,11 @@ func EditAuthSourcePost(ctx *context.Context, form auth.AuthenticationForm) { var config core.Conversion switch models.LoginType(form.Type) { - case models.LoginLdap, models.LOGIN_DLDAP: + case models.LoginLdap, models.LoginDldap: config = parseLDAPConfig(form) - case models.LOGIN_SMTP: + case models.LoginSmtp: config = parseSMTPConfig(form) - case models.LOGIN_PAM: + case models.LoginPam: config = &models.PAMConfig{ ServiceName: form.PAMServiceName, } From 05fd9d3f096e53bcf80b73345d6fa567fbf017e6 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:38:43 +0100 Subject: [PATCH 09/12] Security protocols --- models/login_source.go | 10 +++++----- modules/auth/ldap/ldap.go | 10 +++++----- routers/admin/auths.go | 10 +++++----- 3 files changed, 15 insertions(+), 15 deletions(-) diff --git a/models/login_source.go b/models/login_source.go index 3140d35c5..f3d4b2b96 100644 --- a/models/login_source.go +++ b/models/login_source.go @@ -44,9 +44,9 @@ var LoginNames = map[LoginType]string{ } var SecurityProtocolNames = map[ldap.SecurityProtocol]string{ - ldap.SECURITY_PROTOCOL_UNENCRYPTED: "Unencrypted", - ldap.SECURITY_PROTOCOL_LDAPS: "LDAPS", - ldap.SECURITY_PROTOCOL_START_TLS: "StartTLS", + ldap.SecurityProtocolUnencrypted: "Unencrypted", + ldap.SecurityProtocolLdaps: "LDAPS", + ldap.SecurityProtocolStartTls: "StartTLS", } // Ensure structs implemented interface. @@ -182,14 +182,14 @@ func (source *LoginSource) IsPAM() bool { func (source *LoginSource) HasTLS() bool { return ((source.IsLDAP() || source.IsDLDAP()) && - source.LDAP().SecurityProtocol > ldap.SECURITY_PROTOCOL_UNENCRYPTED) || + source.LDAP().SecurityProtocol > ldap.SecurityProtocolUnencrypted) || source.IsSMTP() } func (source *LoginSource) UseTLS() bool { switch source.Type { case LoginLdap, LoginDldap: - return source.LDAP().SecurityProtocol != ldap.SECURITY_PROTOCOL_UNENCRYPTED + return source.LDAP().SecurityProtocol != ldap.SecurityProtocolUnencrypted case LoginSmtp: return source.SMTP().TLS } diff --git a/modules/auth/ldap/ldap.go b/modules/auth/ldap/ldap.go index b110fe623..361ca5817 100644 --- a/modules/auth/ldap/ldap.go +++ b/modules/auth/ldap/ldap.go @@ -20,9 +20,9 @@ type SecurityProtocol int // Note: new type must be added at the end of list to maintain compatibility. const ( - SECURITY_PROTOCOL_UNENCRYPTED SecurityProtocol = iota - SECURITY_PROTOCOL_LDAPS - SECURITY_PROTOCOL_START_TLS + SecurityProtocolUnencrypted SecurityProtocol = iota + SecurityProtocolLdaps + SecurityProtocolStartTls ) // Basic LDAP authentication service @@ -118,7 +118,7 @@ func dial(ls *Source) (*ldap.Conn, error) { ServerName: ls.Host, InsecureSkipVerify: ls.SkipVerify, } - if ls.SecurityProtocol == SECURITY_PROTOCOL_LDAPS { + if ls.SecurityProtocol == SecurityProtocolLdaps { return ldap.DialTLS("tcp", fmt.Sprintf("%s:%d", ls.Host, ls.Port), tlsCfg) } @@ -127,7 +127,7 @@ func dial(ls *Source) (*ldap.Conn, error) { return nil, fmt.Errorf("Dial: %v", err) } - if ls.SecurityProtocol == SECURITY_PROTOCOL_START_TLS { + if ls.SecurityProtocol == SecurityProtocolStartTls { if err = conn.StartTLS(tlsCfg); err != nil { conn.Close() return nil, fmt.Errorf("StartTLS: %v", err) diff --git a/routers/admin/auths.go b/routers/admin/auths.go index 7fbd1296a..39c028ee0 100644 --- a/routers/admin/auths.go +++ b/routers/admin/auths.go @@ -54,9 +54,9 @@ var ( {models.LoginNames[models.LoginPam], models.LoginPam}, } securityProtocols = []dropdownItem{ - {models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_UNENCRYPTED], ldap.SECURITY_PROTOCOL_UNENCRYPTED}, - {models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_LDAPS], ldap.SECURITY_PROTOCOL_LDAPS}, - {models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_START_TLS], ldap.SECURITY_PROTOCOL_START_TLS}, + {models.SecurityProtocolNames[ldap.SecurityProtocolUnencrypted], ldap.SecurityProtocolUnencrypted}, + {models.SecurityProtocolNames[ldap.SecurityProtocolLdaps], ldap.SecurityProtocolLdaps}, + {models.SecurityProtocolNames[ldap.SecurityProtocolStartTls], ldap.SecurityProtocolStartTls}, } ) @@ -67,7 +67,7 @@ func NewAuthSource(ctx *context.Context) { ctx.Data["type"] = models.LoginLdap ctx.Data["CurrentTypeName"] = models.LoginNames[models.LoginLdap] - ctx.Data["CurrentSecurityProtocol"] = models.SecurityProtocolNames[ldap.SECURITY_PROTOCOL_UNENCRYPTED] + ctx.Data["CurrentSecurityProtocol"] = models.SecurityProtocolNames[ldap.SecurityProtocolUnencrypted] ctx.Data["smtp_auth"] = "PLAIN" ctx.Data["is_active"] = true ctx.Data["AuthSources"] = authSources @@ -127,7 +127,7 @@ func NewAuthSourcePost(ctx *context.Context, form auth.AuthenticationForm) { switch models.LoginType(form.Type) { case models.LoginLdap, models.LoginDldap: config = parseLDAPConfig(form) - hasTLS = ldap.SecurityProtocol(form.SecurityProtocol) > ldap.SECURITY_PROTOCOL_UNENCRYPTED + hasTLS = ldap.SecurityProtocol(form.SecurityProtocol) > ldap.SecurityProtocolUnencrypted case models.LoginSmtp: config = parseSMTPConfig(form) hasTLS = true From b3828e38a5fbb92a92bae11e1e126b87fbad09c8 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:41:28 +0100 Subject: [PATCH 10/12] more --- models/mail.go | 16 ++++++++-------- models/repo.go | 18 +++++++++--------- models/repo_mirror.go | 6 +++--- 3 files changed, 20 insertions(+), 20 deletions(-) diff --git a/models/mail.go b/models/mail.go index 77856553c..04e571ae5 100644 --- a/models/mail.go +++ b/models/mail.go @@ -23,12 +23,12 @@ const ( MailAuthActivate base.TplName = "auth/activate" MailAuthActivateEmail base.TplName = "auth/activate_email" MailAuthResetPassword base.TplName = "auth/reset_passwd" - MAIL_AUTH_REGISTER_NOTIFY base.TplName = "auth/register_notify" + MailAuthRegisterNotify base.TplName = "auth/register_notify" - MAIL_ISSUE_COMMENT base.TplName = "issue/comment" - MAIL_ISSUE_MENTION base.TplName = "issue/mention" + MailIssueComment base.TplName = "issue/comment" + MailIssueMention base.TplName = "issue/mention" - MAIL_NOTIFY_COLLABORATOR base.TplName = "notify/collaborator" + MailNotifyCollaborator base.TplName = "notify/collaborator" ) type MailRender interface { @@ -109,7 +109,7 @@ func SendRegisterNotifyMail(c *macaron.Context, u *User) { data := map[string]interface{}{ "Username": u.DisplayName(), } - body, err := mailRender.HTMLString(string(MAIL_AUTH_REGISTER_NOTIFY), data) + body, err := mailRender.HTMLString(string(MailAuthRegisterNotify), data) if err != nil { log.Error(3, "HTMLString: %v", err) return @@ -131,7 +131,7 @@ func SendCollaboratorMail(u, doer *User, repo *Repository) { "RepoName": repoName, "Link": repo.HTMLURL(), } - body, err := mailRender.HTMLString(string(MAIL_NOTIFY_COLLABORATOR), data) + body, err := mailRender.HTMLString(string(MailNotifyCollaborator), data) if err != nil { log.Error(3, "HTMLString: %v", err) return @@ -171,7 +171,7 @@ func SendIssueCommentMail(issue *Issue, doer *User, tos []string) { return } - mailer.SendAsync(composeIssueMessage(issue, doer, MAIL_ISSUE_COMMENT, tos, "issue comment")) + mailer.SendAsync(composeIssueMessage(issue, doer, MailIssueComment, tos, "issue comment")) } // SendIssueMentionMail composes and sends issue mention emails to target receivers. @@ -179,5 +179,5 @@ func SendIssueMentionMail(issue *Issue, doer *User, tos []string) { if len(tos) == 0 { return } - mailer.SendAsync(composeIssueMessage(issue, doer, MAIL_ISSUE_MENTION, tos, "issue mention")) + mailer.SendAsync(composeIssueMessage(issue, doer, MailIssueMention, tos, "issue mention")) } diff --git a/models/repo.go b/models/repo.go index 5c5af32f4..edf5de932 100644 --- a/models/repo.go +++ b/models/repo.go @@ -1613,18 +1613,18 @@ func RewriteRepositoryUpdateHook() error { var taskStatusTable = sync.NewStatusTable() const ( - _MIRROR_UPDATE = "mirror_update" - _GIT_FSCK = "git_fsck" - _CHECK_REPOs = "check_repos" + mirrorUpdate = "mirror_update" + gitFsck = "git_fsck" + checkRepos = "check_repos" ) // GitFsck calls 'git fsck' to check repository health. func GitFsck() { - if taskStatusTable.IsRunning(_GIT_FSCK) { + if taskStatusTable.IsRunning(gitFsck) { return } - taskStatusTable.Start(_GIT_FSCK) - defer taskStatusTable.Stop(_GIT_FSCK) + taskStatusTable.Start(gitFsck) + defer taskStatusTable.Stop(gitFsck) log.Trace("Doing: GitFsck") @@ -1686,11 +1686,11 @@ func repoStatsCheck(checker *repoChecker) { } func CheckRepoStats() { - if taskStatusTable.IsRunning(_CHECK_REPOs) { + if taskStatusTable.IsRunning(checkRepos) { return } - taskStatusTable.Start(_CHECK_REPOs) - defer taskStatusTable.Stop(_CHECK_REPOs) + taskStatusTable.Start(checkRepos) + defer taskStatusTable.Stop(checkRepos) log.Trace("Doing: CheckRepoStats") diff --git a/models/repo_mirror.go b/models/repo_mirror.go index 9688f579a..c598f82bf 100644 --- a/models/repo_mirror.go +++ b/models/repo_mirror.go @@ -191,11 +191,11 @@ func DeleteMirrorByRepoID(repoID int64) error { // MirrorUpdate checks and updates mirror repositories. func MirrorUpdate() { - if taskStatusTable.IsRunning(_MIRROR_UPDATE) { + if taskStatusTable.IsRunning(mirrorUpdate) { return } - taskStatusTable.Start(_MIRROR_UPDATE) - defer taskStatusTable.Stop(_MIRROR_UPDATE) + taskStatusTable.Start(mirrorUpdate) + defer taskStatusTable.Stop(mirrorUpdate) log.Trace("Doing: MirrorUpdate") From aadd7dcdc317c5e1665318b537162749514ac212 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:53:22 +0100 Subject: [PATCH 11/12] And others --- cmd/serve.go | 2 +- models/org.go | 2 +- models/ssh_key.go | 14 +++++++------- models/user.go | 6 +++--- models/webhook.go | 16 ++++++++-------- routers/admin/orgs.go | 2 +- routers/admin/users.go | 2 +- routers/api/v1/admin/org.go | 2 +- routers/api/v1/user/user.go | 2 +- routers/home.go | 4 ++-- routers/org/org.go | 2 +- routers/repo/webhook.go | 14 +++++++------- 12 files changed, 34 insertions(+), 34 deletions(-) diff --git a/cmd/serve.go b/cmd/serve.go index 4e99ebe5f..dee7ca16d 100644 --- a/cmd/serve.go +++ b/cmd/serve.go @@ -213,7 +213,7 @@ func runServ(c *cli.Context) error { keyID = key.ID // Check deploy key or user key. - if key.Type == models.KEY_TYPE_DEPLOY { + if key.Type == models.KeyTypeDeploy { if key.Mode < requestedMode { fail("Key permission denied", "Cannot push with deployment key: %d", key.ID) } diff --git a/models/org.go b/models/org.go index 42470dce7..9583e2092 100644 --- a/models/org.go +++ b/models/org.go @@ -170,7 +170,7 @@ func GetOrgByName(name string) (*User, error) { } u := &User{ LowerName: strings.ToLower(name), - Type: USER_TYPE_ORGANIZATION, + Type: UserTypeOrganization, } has, err := x.Get(u) if err != nil { diff --git a/models/ssh_key.go b/models/ssh_key.go index 08483b83d..932361c00 100644 --- a/models/ssh_key.go +++ b/models/ssh_key.go @@ -29,7 +29,7 @@ import ( ) const ( - _TPL_PUBLICK_KEY = `command="%s serv key-%d --config='%s'",no-port-forwarding,no-X11-forwarding,no-agent-forwarding,no-pty %s` + "\n" + tplPublicKey = `command="%s serv key-%d --config='%s'",no-port-forwarding,no-X11-forwarding,no-agent-forwarding,no-pty %s` + "\n" ) var sshOpLocker sync.Mutex @@ -37,8 +37,8 @@ var sshOpLocker sync.Mutex type KeyType int const ( - KEY_TYPE_USER = iota + 1 - KEY_TYPE_DEPLOY + KeyTypeUser = iota + 1 + KeyTypeDeploy ) // PublicKey represents a user or deploy SSH public key. @@ -85,7 +85,7 @@ func (k *PublicKey) OmitEmail() string { // AuthorizedString returns formatted public key string for authorized_keys file. func (key *PublicKey) AuthorizedString() string { - return fmt.Sprintf(_TPL_PUBLICK_KEY, setting.AppPath, key.ID, setting.CustomConf, key.Content) + return fmt.Sprintf(tplPublicKey, setting.AppPath, key.ID, setting.CustomConf, key.Content) } func extractTypeFromBase64Key(key string) (string, error) { @@ -352,7 +352,7 @@ func appendAuthorizedKeysToFile(keys ...*PublicKey) error { func checkKeyContent(content string) error { has, err := x.Get(&PublicKey{ Content: content, - Type: KEY_TYPE_USER, + Type: KeyTypeUser, }) if err != nil { return err @@ -416,7 +416,7 @@ func AddPublicKey(ownerID int64, name, content string) (*PublicKey, error) { Name: name, Content: content, Mode: AccessModeWrite, - Type: KEY_TYPE_USER, + Type: KeyTypeUser, } if err = addKey(sess, key); err != nil { return nil, fmt.Errorf("addKey: %v", err) @@ -643,7 +643,7 @@ func AddDeployKey(repoID int64, name, content string) (*DeployKey, error) { pkey := &PublicKey{ Content: content, Mode: AccessModeRead, - Type: KEY_TYPE_DEPLOY, + Type: KeyTypeDeploy, } has, err := x.Get(pkey) if err != nil { diff --git a/models/user.go b/models/user.go index ba41a392c..3870bdeb5 100644 --- a/models/user.go +++ b/models/user.go @@ -37,8 +37,8 @@ import ( type UserType int const ( - USER_TYPE_INDIVIDUAL UserType = iota // Historic reason to make it starts at 0. - USER_TYPE_ORGANIZATION + UserTypeIndividual UserType = iota // Historic reason to make it starts at 0. + UserTypeOrganization ) var ( @@ -393,7 +393,7 @@ func (u *User) IsWriterOfRepo(repo *Repository) bool { // IsOrganization returns true if user is actually a organization. func (u *User) IsOrganization() bool { - return u.Type == USER_TYPE_ORGANIZATION + return u.Type == UserTypeOrganization } // IsUserOrgOwner returns true if user is in the owner team of given organization. diff --git a/models/webhook.go b/models/webhook.go index 4b5501715..25c9326e7 100644 --- a/models/webhook.go +++ b/models/webhook.go @@ -28,13 +28,13 @@ var HookQueue = sync.NewUniqueQueue(setting.Webhook.QueueLength) type HookContentType int const ( - JSON HookContentType = iota + 1 - FORM + ContentTypeJson HookContentType = iota + 1 + ContentTypeForm ) var hookContentTypes = map[string]HookContentType{ - "json": JSON, - "form": FORM, + "json": ContentTypeJson, + "form": ContentTypeForm, } // ToHookContentType returns HookContentType by given name. @@ -44,9 +44,9 @@ func ToHookContentType(name string) HookContentType { func (t HookContentType) Name() string { switch t { - case JSON: + case ContentTypeJson: return "json" - case FORM: + case ContentTypeForm: return "form" } return "" @@ -511,9 +511,9 @@ func (t *HookTask) deliver() { SetTLSClientConfig(&tls.Config{InsecureSkipVerify: setting.Webhook.SkipTLSVerify}) switch t.ContentType { - case JSON: + case ContentTypeJson: req = req.Header("Content-Type", "application/json").Body(t.PayloadContent) - case FORM: + case ContentTypeForm: req.Param("payload", t.PayloadContent) } diff --git a/routers/admin/orgs.go b/routers/admin/orgs.go index efda1e516..4d56797c7 100644 --- a/routers/admin/orgs.go +++ b/routers/admin/orgs.go @@ -22,7 +22,7 @@ func Organizations(ctx *context.Context) { ctx.Data["PageIsAdminOrganizations"] = true routers.RenderUserSearch(ctx, &routers.UserSearchOptions{ - Type: models.USER_TYPE_ORGANIZATION, + Type: models.UserTypeOrganization, Counter: models.CountOrganizations, Ranger: models.Organizations, PageSize: setting.UI.Admin.OrgPagingNum, diff --git a/routers/admin/users.go b/routers/admin/users.go index 404d5ec3b..445fb0021 100644 --- a/routers/admin/users.go +++ b/routers/admin/users.go @@ -30,7 +30,7 @@ func Users(ctx *context.Context) { ctx.Data["PageIsAdminUsers"] = true routers.RenderUserSearch(ctx, &routers.UserSearchOptions{ - Type: models.USER_TYPE_INDIVIDUAL, + Type: models.UserTypeIndividual, Counter: models.CountUsers, Ranger: models.Users, PageSize: setting.UI.Admin.UserPagingNum, diff --git a/routers/api/v1/admin/org.go b/routers/api/v1/admin/org.go index 1deaa34b4..b764f7a81 100644 --- a/routers/api/v1/admin/org.go +++ b/routers/api/v1/admin/org.go @@ -27,7 +27,7 @@ func CreateOrg(ctx *context.APIContext, form api.CreateOrgOption) { Website: form.Website, Location: form.Location, IsActive: true, - Type: models.USER_TYPE_ORGANIZATION, + Type: models.UserTypeOrganization, } if err := models.CreateOrganization(org, u); err != nil { if models.IsErrUserAlreadyExist(err) || diff --git a/routers/api/v1/user/user.go b/routers/api/v1/user/user.go index e7322d725..92ad7c81e 100644 --- a/routers/api/v1/user/user.go +++ b/routers/api/v1/user/user.go @@ -16,7 +16,7 @@ import ( func Search(ctx *context.APIContext) { opts := &models.SearchUserOptions{ Keyword: ctx.Query("q"), - Type: models.USER_TYPE_INDIVIDUAL, + Type: models.UserTypeIndividual, PageSize: com.StrTo(ctx.Query("limit")).MustInt(), } if opts.PageSize == 0 { diff --git a/routers/home.go b/routers/home.go index 10e75269b..2dd223b74 100644 --- a/routers/home.go +++ b/routers/home.go @@ -172,7 +172,7 @@ func ExploreUsers(ctx *context.Context) { ctx.Data["PageIsExploreUsers"] = true RenderUserSearch(ctx, &UserSearchOptions{ - Type: models.USER_TYPE_INDIVIDUAL, + Type: models.UserTypeIndividual, Counter: models.CountUsers, Ranger: models.Users, PageSize: setting.UI.ExplorePagingNum, @@ -187,7 +187,7 @@ func ExploreOrganizations(ctx *context.Context) { ctx.Data["PageIsExploreOrganizations"] = true RenderUserSearch(ctx, &UserSearchOptions{ - Type: models.USER_TYPE_ORGANIZATION, + Type: models.UserTypeOrganization, Counter: models.CountOrganizations, Ranger: models.Organizations, PageSize: setting.UI.ExplorePagingNum, diff --git a/routers/org/org.go b/routers/org/org.go index 156ccb3ee..f937ac70d 100644 --- a/routers/org/org.go +++ b/routers/org/org.go @@ -33,7 +33,7 @@ func CreatePost(ctx *context.Context, form auth.CreateOrgForm) { org := &models.User{ Name: form.OrgName, IsActive: true, - Type: models.USER_TYPE_ORGANIZATION, + Type: models.UserTypeOrganization, } if err := models.CreateOrganization(org, ctx.User); err != nil { diff --git a/routers/repo/webhook.go b/routers/repo/webhook.go index 918c34016..d18008b52 100644 --- a/routers/repo/webhook.go +++ b/routers/repo/webhook.go @@ -134,9 +134,9 @@ func WebHooksNewPost(ctx *context.Context, form auth.NewWebhookForm) { return } - contentType := models.JSON - if models.HookContentType(form.ContentType) == models.FORM { - contentType = models.FORM + contentType := models.ContentTypeJson + if models.HookContentType(form.ContentType) == models.ContentTypeForm { + contentType = models.ContentTypeForm } w := &models.Webhook{ @@ -192,7 +192,7 @@ func SlackHooksNewPost(ctx *context.Context, form auth.NewSlackHookForm) { w := &models.Webhook{ RepoID: orCtx.RepoID, URL: form.PayloadURL, - ContentType: models.JSON, + ContentType: models.ContentTypeJson, HookEvent: ParseHookEvent(form.WebhookForm), IsActive: form.Active, HookTaskType: models.SLACK, @@ -281,9 +281,9 @@ func WebHooksEditPost(ctx *context.Context, form auth.NewWebhookForm) { return } - contentType := models.JSON - if models.HookContentType(form.ContentType) == models.FORM { - contentType = models.FORM + contentType := models.ContentTypeJson + if models.HookContentType(form.ContentType) == models.ContentTypeForm { + contentType = models.ContentTypeForm } w.URL = form.PayloadURL From b7bf9dfd285a5d64bfcd6a3148c646f03984e594 Mon Sep 17 00:00:00 2001 From: Sandro Santilli Date: Mon, 7 Nov 2016 17:55:31 +0100 Subject: [PATCH 12/12] more --- modules/auth/user_form.go | 4 ++-- routers/org/setting.go | 2 +- routers/user/setting.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/auth/user_form.go b/modules/auth/user_form.go index 7bd6c7b9b..09ef53db8 100644 --- a/modules/auth/user_form.go +++ b/modules/auth/user_form.go @@ -101,8 +101,8 @@ func (f *UpdateProfileForm) Validate(ctx *macaron.Context, errs binding.Errors) } const ( - AVATAR_LOCAL string = "local" - AVATAR_BYMAIL string = "bymail" + AvatarLocal string = "local" + AvatarByMail string = "bymail" ) type AvatarForm struct { diff --git a/routers/org/setting.go b/routers/org/setting.go index 216977923..70d5e3e20 100644 --- a/routers/org/setting.go +++ b/routers/org/setting.go @@ -84,7 +84,7 @@ func SettingsPost(ctx *context.Context, form auth.UpdateOrgSettingForm) { } func SettingsAvatar(ctx *context.Context, form auth.AvatarForm) { - form.Source = auth.AVATAR_LOCAL + form.Source = auth.AvatarLocal if err := user.UpdateAvatarSetting(ctx, form, ctx.Org.Organization); err != nil { ctx.Flash.Error(err.Error()) } else { diff --git a/routers/user/setting.go b/routers/user/setting.go index 35763ab48..4d698bc2a 100644 --- a/routers/user/setting.go +++ b/routers/user/setting.go @@ -104,7 +104,7 @@ func SettingsPost(ctx *context.Context, form auth.UpdateProfileForm) { // FIXME: limit size. func UpdateAvatarSetting(ctx *context.Context, form auth.AvatarForm, ctxUser *models.User) error { - ctxUser.UseCustomAvatar = form.Source == auth.AVATAR_LOCAL + ctxUser.UseCustomAvatar = form.Source == auth.AvatarLocal if len(form.Gravatar) > 0 { ctxUser.Avatar = base.EncodeMD5(form.Gravatar) ctxUser.AvatarEmail = form.Gravatar