vikunja
/
vikunja
6
43
Fork 72
Code Issues 151 Pull Requests 17 Packages Releases 32 Activity

Add events #777

Merged
konrad merged 47 commits from feature/events into master 2021-02-02 22:48:38 +00:00
Conversation 0 Commits 47 Files Changed 70 +12 -5
3 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 1313f4d2a8 - Show all commits

5
pkg/models/events.go
View File

@ -16,8 +16,11 @@
package models package models
import "code.vikunja.io/api/pkg/user"
type TaskCreatedEvent struct { type TaskCreatedEvent struct {
Task *Task Task *Task
Doer *user.User
} }
func (t *TaskCreatedEvent) TopicName() string { func (t *TaskCreatedEvent) TopicName() string {
@ -25,5 +28,5 @@ func (t *TaskCreatedEvent) TopicName() string {
} }
func (t *TaskCreatedEvent) Message() interface{} { func (t *TaskCreatedEvent) Message() interface{} {
return t.Task return t
} }

6
pkg/models/listeners.go
View File

@ -32,12 +32,12 @@ type SendTaskCreatedNotification struct {
} }
func (s *SendTaskCreatedNotification) Handle(payload message.Payload) (err error) { func (s *SendTaskCreatedNotification) Handle(payload message.Payload) (err error) {
task := &Task{} event := &TaskCreatedEvent{}
err = json.Unmarshal(payload, task) err = json.Unmarshal(payload, event)
if err != nil { if err != nil {
return err return err
} }
log.Debugf("task.created: %v", task) log.Debugf("task.created: %v", event)
return nil return nil
} }

6
pkg/models/tasks.go
View File

@ -829,7 +829,11 @@ func createTask(s *xorm.Session, t *Task, a web.Auth, updateAssignees bool) (err
t.setIdentifier(l) t.setIdentifier(l)
if err := events.Publish(&TaskCreatedEvent{Task: t}); err != nil { err = events.Publish(&TaskCreatedEvent{
Task: t,
Doer: t.CreatedBy,
})
if err != nil {
return err return err
} }