From 068ccf1c0fb6d386e9417dc762f65d72fb977fd2 Mon Sep 17 00:00:00 2001 From: Anthony Woods Date: Tue, 17 Mar 2015 23:07:08 +0800 Subject: [PATCH 1/3] fixes 1606 emit OrgCreated event when new org created. --- pkg/services/sqlstore/user.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/services/sqlstore/user.go b/pkg/services/sqlstore/user.go index 81d4067bf5e..4dc289aa04d 100644 --- a/pkg/services/sqlstore/user.go +++ b/pkg/services/sqlstore/user.go @@ -55,7 +55,11 @@ func getOrgIdForNewUser(userEmail string, sess *session) (int64, error) { if _, err := sess.Insert(&org); err != nil { return 0, err } - + sess.publishAfterCommit(&events.OrgCreated{ + Timestamp: org.Created, + Id: org.Id, + Name: org.Name, + }) return org.Id, nil } From 6a09a7c3982f5ddab398eeefc3d14c5b5396d305 Mon Sep 17 00:00:00 2001 From: Anthony Woods Date: Tue, 17 Mar 2015 23:07:08 +0800 Subject: [PATCH 2/3] fixes #1606 emit OrgCreated event when new org created. --- pkg/services/sqlstore/user.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/services/sqlstore/user.go b/pkg/services/sqlstore/user.go index 81d4067bf5e..4dc289aa04d 100644 --- a/pkg/services/sqlstore/user.go +++ b/pkg/services/sqlstore/user.go @@ -55,7 +55,11 @@ func getOrgIdForNewUser(userEmail string, sess *session) (int64, error) { if _, err := sess.Insert(&org); err != nil { return 0, err } - + sess.publishAfterCommit(&events.OrgCreated{ + Timestamp: org.Created, + Id: org.Id, + Name: org.Name, + }) return org.Id, nil } From bce62c49d04ca6e3e48b1100a993186e6033130d Mon Sep 17 00:00:00 2001 From: Anthony Woods Date: Tue, 17 Mar 2015 23:10:49 +0800 Subject: [PATCH 3/3] fixes #1606 --- pkg/services/sqlstore/user.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/services/sqlstore/user.go b/pkg/services/sqlstore/user.go index 4dc289aa04d..de4ad70164f 100644 --- a/pkg/services/sqlstore/user.go +++ b/pkg/services/sqlstore/user.go @@ -55,11 +55,13 @@ func getOrgIdForNewUser(userEmail string, sess *session) (int64, error) { if _, err := sess.Insert(&org); err != nil { return 0, err } + sess.publishAfterCommit(&events.OrgCreated{ Timestamp: org.Created, Id: org.Id, Name: org.Name, }) + return org.Id, nil }