aboutsummaryrefslogtreecommitdiffstats
path: root/models
diff options
context:
space:
mode:
authorLunny Xiao <xiaolunwen@gmail.com>2019-11-09 04:54:50 +0800
committertechknowlogick <techknowlogick@gitea.io>2019-11-08 15:54:50 -0500
commit016a5d0438e551d4630819683dd6dc4fccb0cb51 (patch)
treebe5adb9e41fdd3e0b1528cca0c9e111ff81b4eb7 /models
parentfb459f2c2c32dda29870731b6dae1452bbab625f (diff)
downloadgitea-016a5d0438e551d4630819683dd6dc4fccb0cb51.tar.gz
gitea-016a5d0438e551d4630819683dd6dc4fccb0cb51.zip
Move some actions to notification/action (#8779)
* Move some actions to notification/action * Fix test * fix test
Diffstat (limited to 'models')
-rw-r--r--models/action.go43
-rw-r--r--models/action_test.go53
-rw-r--r--models/repo.go11
3 files changed, 9 insertions, 98 deletions
diff --git a/models/action.go b/models/action.go
index b651c658d5..ddb82e0f4c 100644
--- a/models/action.go
+++ b/models/action.go
@@ -283,49 +283,6 @@ func (a *Action) GetIssueContent() string {
return issue.Content
}
-func newRepoAction(e Engine, u *User, repo *Repository) (err error) {
- if err = notifyWatchers(e, &Action{
- ActUserID: u.ID,
- ActUser: u,
- OpType: ActionCreateRepo,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- }); err != nil {
- return fmt.Errorf("notify watchers '%d/%d': %v", u.ID, repo.ID, err)
- }
-
- log.Trace("action.newRepoAction: %s/%s", u.Name, repo.Name)
- return err
-}
-
-// NewRepoAction adds new action for creating repository.
-func NewRepoAction(u *User, repo *Repository) (err error) {
- return newRepoAction(x, u, repo)
-}
-
-func renameRepoAction(e Engine, actUser *User, oldRepoName string, repo *Repository) (err error) {
- if err = notifyWatchers(e, &Action{
- ActUserID: actUser.ID,
- ActUser: actUser,
- OpType: ActionRenameRepo,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- Content: oldRepoName,
- }); err != nil {
- return fmt.Errorf("notify watchers: %v", err)
- }
-
- log.Trace("action.renameRepoAction: %s/%s", actUser.Name, repo.Name)
- return nil
-}
-
-// RenameRepoAction adds new action for renaming a repository.
-func RenameRepoAction(actUser *User, oldRepoName string, repo *Repository) error {
- return renameRepoAction(x, actUser, oldRepoName, repo)
-}
-
// PushCommit represents a commit in a push operation.
type PushCommit struct {
Sha1 string
diff --git a/models/action_test.go b/models/action_test.go
index df41556850..5eb89aac21 100644
--- a/models/action_test.go
+++ b/models/action_test.go
@@ -2,7 +2,6 @@ package models
import (
"path"
- "strings"
"testing"
"code.gitea.io/gitea/modules/setting"
@@ -28,58 +27,6 @@ func TestAction_GetRepoLink(t *testing.T) {
assert.Equal(t, expected, action.GetRepoLink())
}
-func TestNewRepoAction(t *testing.T) {
- assert.NoError(t, PrepareTestDatabase())
-
- user := AssertExistsAndLoadBean(t, &User{ID: 2}).(*User)
- repo := AssertExistsAndLoadBean(t, &Repository{OwnerID: user.ID}).(*Repository)
- repo.Owner = user
-
- actionBean := &Action{
- OpType: ActionCreateRepo,
- ActUserID: user.ID,
- RepoID: repo.ID,
- ActUser: user,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- }
-
- AssertNotExistsBean(t, actionBean)
- assert.NoError(t, NewRepoAction(user, repo))
- AssertExistsAndLoadBean(t, actionBean)
- CheckConsistencyFor(t, &Action{})
-}
-
-func TestRenameRepoAction(t *testing.T) {
- assert.NoError(t, PrepareTestDatabase())
-
- user := AssertExistsAndLoadBean(t, &User{ID: 2}).(*User)
- repo := AssertExistsAndLoadBean(t, &Repository{OwnerID: user.ID}).(*Repository)
- repo.Owner = user
-
- oldRepoName := repo.Name
- const newRepoName = "newRepoName"
- repo.Name = newRepoName
- repo.LowerName = strings.ToLower(newRepoName)
-
- actionBean := &Action{
- OpType: ActionRenameRepo,
- ActUserID: user.ID,
- ActUser: user,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- Content: oldRepoName,
- }
- AssertNotExistsBean(t, actionBean)
- assert.NoError(t, RenameRepoAction(user, oldRepoName, repo))
- AssertExistsAndLoadBean(t, actionBean)
-
- _, err := x.ID(repo.ID).Cols("name", "lower_name").Update(repo)
- assert.NoError(t, err)
- CheckConsistencyFor(t, &Action{})
-}
-
func TestPushCommits_ToAPIPayloadCommits(t *testing.T) {
pushCommits := NewPushCommits()
pushCommits.Commits = []*PushCommit{
diff --git a/models/repo.go b/models/repo.go
index 89e579d1ec..e0a93aaebf 100644
--- a/models/repo.go
+++ b/models/repo.go
@@ -1469,8 +1469,15 @@ func createRepository(e *xorm.Session, doer, u *User, repo *Repository) (err err
return fmt.Errorf("watchRepo: %v", err)
}
}
- if err = newRepoAction(e, doer, repo); err != nil {
- return fmt.Errorf("newRepoAction: %v", err)
+ if err = notifyWatchers(e, &Action{
+ ActUserID: doer.ID,
+ ActUser: doer,
+ OpType: ActionCreateRepo,
+ RepoID: repo.ID,
+ Repo: repo,
+ IsPrivate: repo.IsPrivate,
+ }); err != nil {
+ return fmt.Errorf("notify watchers '%d/%d': %v", doer.ID, repo.ID, err)
}
if err = copyDefaultWebhooksToRepo(e, repo.ID); err != nil {