diff --git a/platform/communication.go b/platform/communication.go index 14f20768..14351132 100644 --- a/platform/communication.go +++ b/platform/communication.go @@ -3,14 +3,14 @@ package platform import ( "context" "fmt" + "strconv" "time" "github.com/Gleipnir-Technology/nidus-sync/db" - //"github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/enum" "github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/model" querypublic "github.com/Gleipnir-Technology/nidus-sync/db/query/public" "github.com/Gleipnir-Technology/nidus-sync/lint" - //"github.com/Gleipnir-Technology/jet/postgres" + "github.com/Gleipnir-Technology/nidus-sync/platform/event" ) func CommunicationsForOrganization(ctx context.Context, org_id int64) ([]model.Communication, error) { @@ -63,5 +63,7 @@ func communicationMark(ctx context.Context, user User, comm_id int32, status mod if err := txn.Commit(ctx); err != nil { return fmt.Errorf("commit: %w", err) } + + event.Updated(event.TypeCommunication, user.Organization.ID, strconv.Itoa(int(comm_id))) return nil } diff --git a/platform/event/event.go b/platform/event/event.go index 35963a26..86be20a2 100644 --- a/platform/event/event.go +++ b/platform/event/event.go @@ -89,6 +89,7 @@ type ResourceType int const ( TypeUnknown = iota + TypeCommunication TypeFileCSV TypeNoteAudio TypeNoteImage @@ -151,6 +152,8 @@ func Send(env Envelope) { } func resourceString(t ResourceType) string { switch t { + case TypeCommunication: + return "sync:communication" case TypeFileCSV: return "sync:filecsv" case TypeNoteAudio: @@ -179,6 +182,8 @@ func resourceString(t ResourceType) string { } func makeURI(t ResourceType, id string) string { switch t { + case TypeCommunication: + return config.MakeURLNidus("/api/communication/%s", id) case TypeFileCSV: return config.MakeURLNidus("/api/upload/%s", id) case TypeNoteAudio: