Rename Publish to Dispatch

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

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 {

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,
 	})

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,

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,

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,
 	})

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,

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,

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,

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,

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,
 	})

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,

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,
 	})

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 {