Cleanupo
This commit is contained in:
parent
d29beac898
commit
3e0f8f3174
|
@ -32,7 +32,6 @@ var pubsub *gochannel.GoChannel
|
|||
|
||||
type Event interface {
|
||||
TopicName() string
|
||||
Message() interface{}
|
||||
}
|
||||
|
||||
func InitEvents() (err error) {
|
||||
|
@ -75,7 +74,7 @@ func InitEvents() (err error) {
|
|||
}
|
||||
|
||||
func Publish(event Event) error {
|
||||
content, err := json.Marshal(event.Message())
|
||||
content, err := json.Marshal(event)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
|
|
@ -29,10 +29,6 @@ func (t *TaskCreatedEvent) TopicName() string {
|
|||
return "task.created"
|
||||
}
|
||||
|
||||
func (t *TaskCreatedEvent) Message() interface{} {
|
||||
return t
|
||||
}
|
||||
|
||||
type TaskUpdatedEvent struct {
|
||||
Task *Task
|
||||
Doer *user.User
|
||||
|
@ -42,10 +38,6 @@ func (t *TaskUpdatedEvent) TopicName() string {
|
|||
return "task.updated"
|
||||
}
|
||||
|
||||
func (t *TaskUpdatedEvent) Message() interface{} {
|
||||
return t
|
||||
}
|
||||
|
||||
type TaskAssigneeCreatedEvent struct {
|
||||
Task *Task
|
||||
Assignee *user.User
|
||||
|
@ -56,10 +48,6 @@ func (t *TaskAssigneeCreatedEvent) TopicName() string {
|
|||
return "task.assignee.created"
|
||||
}
|
||||
|
||||
func (t *TaskAssigneeCreatedEvent) Message() interface{} {
|
||||
return t
|
||||
}
|
||||
|
||||
type TaskCommentCreatedEvent struct {
|
||||
Task *Task
|
||||
Comment *TaskComment
|
||||
|
@ -69,7 +57,3 @@ type TaskCommentCreatedEvent struct {
|
|||
func (t *TaskCommentCreatedEvent) TopicName() string {
|
||||
return "task.comment.created"
|
||||
}
|
||||
|
||||
func (t *TaskCommentCreatedEvent) Message() interface{} {
|
||||
return t
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue