logos-messaging/nim-sds
1
0
Fork 0
mirror of https://github.com/logos-messaging/nim-sds.git synced 2026-02-26 08:53:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

setting up callbacks

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-16 11:35:42 +03:00
parent 0999f44366
commit 11cd637004
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
library/libsds.nim
View File

@ -148,11 +148,18 @@ proc NewReliabilityManager(
ctx.userData = userData
let appCallbacks = AppCallbacks(
messageReadyCb: onMessageReady(ctx),
messageSentCb: onMessageSent(ctx),
missingDependenciesCb: onMissingDependencies(ctx),
periodicSyncCb: onPeriodicSync(ctx),
)
let retCode = handleRequest(
ctx,
RequestType.LIFECYCLE,
SdsLifecycleRequest.createShared(
SdsLifecycleMsgType.CREATE_RELIABILITY_MANAGER, channelId
SdsLifecycleMsgType.CREATE_RELIABILITY_MANAGER, channelId, appCallbacks
),
callback,
userData,

24
library/sds_thread/inter_thread_communication/requests/sds_lifecycle_request.nim
View File

@ -11,12 +11,17 @@ type SdsLifecycleMsgType* = enum
type SdsLifecycleRequest* = object
operation: SdsLifecycleMsgType
channelId: cstring
appCallbacks: AppCallbacks
proc createShared*(
T: type SdsLifecycleRequest, op: SdsLifecycleMsgType, channelId: cstring = ""
T: type SdsLifecycleRequest,
op: SdsLifecycleMsgType,
channelId: cstring = "",
appCallbacks: AppCallbacks = nil,
): ptr type T =
var ret = createShared(T)
ret[].operation = op
ret[].appCallbacks = appCallbacks
ret[].channelId = channelId.alloc()
return ret
@ -25,7 +30,7 @@ proc destroyShared(self: ptr SdsLifecycleRequest) =
deallocShared(self)
proc createReliabilityManager(
channelIdCStr: cstring
channelIdCStr: cstring, appCallbacks: AppCallbacks = nil
): Future[Result[ReliabilityManager, string]] {.async.} =
let channelId = $channelIdCStr
if channelId.len == 0:
@ -36,15 +41,10 @@ proc createReliabilityManager(
error "Failed creating reliability manager", error = error
return err("Failed creating reliability manager: " & $error)
# TODO: instead of this, create events
#[ rm.onMessageReady = proc(msgId: MessageID) =
nimMessageReadyCallback(rm, msgId)
rm.onMessageSent = proc(msgId: MessageID) =
nimMessageSentCallback(rm, msgId)
rm.onMissingDependencies = proc(msgId: MessageID, deps: seq[MessageID]) =
nimMissingDependenciesCallback(rm, msgId, deps)
rm.onPeriodicSync = proc() =
nimPeriodicSyncCallback(rm) ]#
rm.setCallbacks(
appCallbacks.messageReadyCb, appCallbacks.messageSentCb,
appCallbacks.missingDependenciesCb, appCallbacks.periodicSyncCb,
)
return ok(rm)
@ -56,7 +56,7 @@ proc process*(
case self.operation
of CREATE_RELIABILITY_MANAGER:
rm[] = (await createReliabilityManager(self.channelId)).valueOr:
rm[] = (await createReliabilityManager(self.channelId, self.appCallbacks)).valueOr:
error "CREATE_RELIABILITY_MANAGER failed", error = error
return err("error processing CREATE_RELIABILITY_MANAGER request: " & $error)
of RESET_RELIABILITY_MANAGER: