logos-messaging/sds-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/sds-go-bindings.git synced 2026-01-02 14:13:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

parsing message ready event

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-16 12:20:11 +03:00
parent 94fe0d4919
commit 53419ac819
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 37 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
sds/sds.go
View File

@ -138,6 +138,7 @@ import (
)
const requestTimeout = 30 * time.Second
const EventChanBufferSize = 1024
//export GoCallback
func GoCallback(ret C.int, msg *C.char, len C.size_t, resp unsafe.Pointer) {
@ -155,6 +156,7 @@ func GoCallback(ret C.int, msg *C.char, len C.size_t, resp unsafe.Pointer) {
type ReliabilityManager struct {
rmCtx unsafe.Pointer
channelId string
MsgReadyChan chan MessageID
}
func NewReliabilityManager(channelId string) (*ReliabilityManager, error) {
@ -181,6 +183,8 @@ func NewReliabilityManager(channelId string) (*ReliabilityManager, error) {
rm.rmCtx = C.cGoNewReliabilityManager(cChannelId, resp)
wg.Wait()
rm.MsgReadyChan = make(chan MessageID, EventChanBufferSize)
C.cGoSetEventCallback(rm.rmCtx)
registerReliabilityManager(rm)
@ -233,7 +237,14 @@ type jsonEvent struct {
EventType string `json:"eventType"`
}
type msgReady struct {
MessageId MessageID `json:"messageId"`
}
func (rm *ReliabilityManager) OnEvent(eventStr string) {
fmt.Println("------------------- received event: ", eventStr)
jsonEvent := jsonEvent{}
err := json.Unmarshal([]byte(eventStr), &jsonEvent)
if err != nil {
@ -243,10 +254,30 @@ func (rm *ReliabilityManager) OnEvent(eventStr string) {
}
switch jsonEvent.EventType {
case "event 1":
fmt.Println("-------- received event 1")
case "event 2":
fmt.Println("-------- received event 1")
case "message_ready":
rm.parseMessageReadyEvent(eventStr)
case "message_sent":
fmt.Println("-------- received event 2")
case "missing_dependencies":
fmt.Println("-------- received event 3")
case "periodic_sync":
fmt.Println("-------- received event 4")
}
}
func (rm *ReliabilityManager) parseMessageReadyEvent(eventStr string) {
msgReady := msgReady{}
err := json.Unmarshal([]byte(eventStr), &msgReady)
if err != nil {
Error("could not parse message ready event %v", err)
}
select {
case rm.MsgReadyChan <- msgReady.MessageId:
default:
Warn("Can't deliver message ready event, MsgReadyChan is full")
}
}