From 8de81194bd3d4102eb1da8c009d0b2368c71618c Mon Sep 17 00:00:00 2001 From: kolaente Date: Tue, 2 Feb 2021 19:47:33 +0100 Subject: [PATCH] Rename Publish to Dispatch --- pkg/events/events.go | 2 +- pkg/initialize/init.go | 2 +- pkg/models/list.go | 6 +++--- pkg/models/list_team.go | 2 +- pkg/models/list_users.go | 2 +- pkg/models/namespace.go | 6 +++--- pkg/models/namespace_team.go | 2 +- pkg/models/namespace_users.go | 2 +- pkg/models/task_assignees.go | 2 +- pkg/models/task_comments.go | 2 +- pkg/models/tasks.go | 6 +++--- pkg/models/team_members.go | 2 +- pkg/models/teams.go | 4 ++-- pkg/user/user_create.go | 2 +- 14 files changed, 21 insertions(+), 21 deletions(-) diff --git a/pkg/events/events.go b/pkg/events/events.go index 6852b596f..c554dfefb 100644 --- a/pkg/events/events.go +++ b/pkg/events/events.go @@ -78,7 +78,7 @@ func InitEvents() (err error) { return router.Run(context.Background()) } -func Publish(event Event) error { +func Dispatch(event Event) error { if isUnderTest { dispatchedTestEvents = append(dispatchedTestEvents, event) return nil diff --git a/pkg/initialize/init.go b/pkg/initialize/init.go index f805d182d..26582b95c 100644 --- a/pkg/initialize/init.go +++ b/pkg/initialize/init.go @@ -97,7 +97,7 @@ func FullInit() { log.Fatal(err.Error()) } - err = events.Publish(&BootedEvent{ + err = events.Dispatch(&BootedEvent{ BootedAt: time.Now(), }) if err != nil { diff --git a/pkg/models/list.go b/pkg/models/list.go index 318a94701..0064103d6 100644 --- a/pkg/models/list.go +++ b/pkg/models/list.go @@ -546,7 +546,7 @@ func (l *List) Update(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&ListUpdatedEvent{ + return events.Dispatch(&ListUpdatedEvent{ List: l, Doer: a, }) @@ -611,7 +611,7 @@ func (l *List) Create(s *xorm.Session, a web.Auth) (err error) { return } - return events.Publish(&ListCreatedEvent{ + return events.Dispatch(&ListCreatedEvent{ List: l, Doer: a, }) @@ -643,7 +643,7 @@ func (l *List) Delete(s *xorm.Session, a web.Auth) (err error) { return } - return events.Publish(&ListDeletedEvent{ + return events.Dispatch(&ListDeletedEvent{ List: l, Doer: a, }) diff --git a/pkg/models/list_team.go b/pkg/models/list_team.go index 63e0d7e94..f0611f84e 100644 --- a/pkg/models/list_team.go +++ b/pkg/models/list_team.go @@ -106,7 +106,7 @@ func (tl *TeamList) Create(s *xorm.Session, a web.Auth) (err error) { return err } - err = events.Publish(&ListSharedWithTeamEvent{ + err = events.Dispatch(&ListSharedWithTeamEvent{ List: l, Team: team, Doer: a, diff --git a/pkg/models/list_users.go b/pkg/models/list_users.go index a17304b48..5131eb074 100644 --- a/pkg/models/list_users.go +++ b/pkg/models/list_users.go @@ -113,7 +113,7 @@ func (lu *ListUser) Create(s *xorm.Session, a web.Auth) (err error) { return err } - err = events.Publish(&ListSharedWithUserEvent{ + err = events.Dispatch(&ListSharedWithUserEvent{ List: l, User: u, Doer: a, diff --git a/pkg/models/namespace.go b/pkg/models/namespace.go index d46a2817c..cd1197077 100644 --- a/pkg/models/namespace.go +++ b/pkg/models/namespace.go @@ -478,7 +478,7 @@ func (n *Namespace) Create(s *xorm.Session, a web.Auth) (err error) { return err } - err = events.Publish(&NamespaceCreatedEvent{ + err = events.Dispatch(&NamespaceCreatedEvent{ Namespace: n, Doer: a, }) @@ -550,7 +550,7 @@ func (n *Namespace) Delete(s *xorm.Session, a web.Auth) (err error) { return } - return events.Publish(&NamespaceDeletedEvent{ + return events.Dispatch(&NamespaceDeletedEvent{ Namespace: n, Doer: a, }) @@ -617,7 +617,7 @@ func (n *Namespace) Update(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&NamespaceUpdatedEvent{ + return events.Dispatch(&NamespaceUpdatedEvent{ Namespace: n, Doer: a, }) diff --git a/pkg/models/namespace_team.go b/pkg/models/namespace_team.go index fffd0ebb7..d18c70824 100644 --- a/pkg/models/namespace_team.go +++ b/pkg/models/namespace_team.go @@ -101,7 +101,7 @@ func (tn *TeamNamespace) Create(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&NamespaceSharedWithTeamEvent{ + return events.Dispatch(&NamespaceSharedWithTeamEvent{ Namespace: namespace, Team: team, Doer: a, diff --git a/pkg/models/namespace_users.go b/pkg/models/namespace_users.go index fea0741fd..33f4e3ac4 100644 --- a/pkg/models/namespace_users.go +++ b/pkg/models/namespace_users.go @@ -110,7 +110,7 @@ func (nu *NamespaceUser) Create(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&NamespaceSharedWithUserEvent{ + return events.Dispatch(&NamespaceSharedWithUserEvent{ Namespace: n, User: user, Doer: a, diff --git a/pkg/models/task_assignees.go b/pkg/models/task_assignees.go index 8419c9e7a..ee8e90166 100644 --- a/pkg/models/task_assignees.go +++ b/pkg/models/task_assignees.go @@ -224,7 +224,7 @@ func (t *Task) addNewAssigneeByID(s *xorm.Session, newAssigneeID int64, list *Li return err } - err = events.Publish(&TaskAssigneeCreatedEvent{ + err = events.Dispatch(&TaskAssigneeCreatedEvent{ Task: t, Assignee: newAssignee, Doer: auth, diff --git a/pkg/models/task_comments.go b/pkg/models/task_comments.go index 2070af81b..4dac977e9 100644 --- a/pkg/models/task_comments.go +++ b/pkg/models/task_comments.go @@ -72,7 +72,7 @@ func (tc *TaskComment) Create(s *xorm.Session, a web.Auth) (err error) { return } - err = events.Publish(&TaskCommentCreatedEvent{ + err = events.Dispatch(&TaskCommentCreatedEvent{ Task: &task, Comment: tc, Doer: a, diff --git a/pkg/models/tasks.go b/pkg/models/tasks.go index b668ff15b..85a33f275 100644 --- a/pkg/models/tasks.go +++ b/pkg/models/tasks.go @@ -826,7 +826,7 @@ func createTask(s *xorm.Session, t *Task, a web.Auth, updateAssignees bool) (err t.setIdentifier(l) - err = events.Publish(&TaskCreatedEvent{ + err = events.Dispatch(&TaskCreatedEvent{ Task: t, Doer: a, }) @@ -1034,7 +1034,7 @@ func (t *Task) Update(s *xorm.Session, a web.Auth) (err error) { } t.Updated = nt.Updated - err = events.Publish(&TaskUpdatedEvent{ + err = events.Dispatch(&TaskUpdatedEvent{ Task: t, Doer: a, }) @@ -1191,7 +1191,7 @@ func (t *Task) Delete(s *xorm.Session, a web.Auth) (err error) { return err } - err = events.Publish(&TaskDeletedEvent{ + err = events.Dispatch(&TaskDeletedEvent{ Task: t, Doer: a, }) diff --git a/pkg/models/team_members.go b/pkg/models/team_members.go index ad79f8b96..962d90a9f 100644 --- a/pkg/models/team_members.go +++ b/pkg/models/team_members.go @@ -69,7 +69,7 @@ func (tm *TeamMember) Create(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&TeamMemberAddedEvent{ + return events.Dispatch(&TeamMemberAddedEvent{ Team: team, Member: user, Doer: a, diff --git a/pkg/models/teams.go b/pkg/models/teams.go index 4ffcff8d2..487d310d8 100644 --- a/pkg/models/teams.go +++ b/pkg/models/teams.go @@ -270,7 +270,7 @@ func (t *Team) Create(s *xorm.Session, a web.Auth) (err error) { return err } - return events.Publish(&TeamCreatedEvent{ + return events.Dispatch(&TeamCreatedEvent{ Team: t, Doer: a, }) @@ -313,7 +313,7 @@ func (t *Team) Delete(s *xorm.Session, a web.Auth) (err error) { return } - return events.Publish(&TeamDeletedEvent{ + return events.Dispatch(&TeamDeletedEvent{ Team: t, Doer: a, }) diff --git a/pkg/user/user_create.go b/pkg/user/user_create.go index d74bccfed..bc865d8da 100644 --- a/pkg/user/user_create.go +++ b/pkg/user/user_create.go @@ -76,7 +76,7 @@ func CreateUser(s *xorm.Session, user *User) (newUser *User, err error) { return nil, err } - err = events.Publish(&UserCreatedEvent{ + err = events.Dispatch(&UserCreatedEvent{ User: newUserOut, }) if err != nil {