Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Emit updated events for communication resources on mark

Browse source
This commit is contained in:
Eli Ribble 2026-05-11 22:17:18 +00:00
parent 633abd19a9
commit d992eee560
No known key found for this signature in database
2 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
platform/communication.go
View file

@ -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
}

5
platform/event/event.go
View file

@ -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: