logos-messaging/nim-sds
1
0
Fork 0
mirror of https://github.com/logos-messaging/nim-sds.git synced 2026-01-04 07:03:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: library changes

Browse Source
This commit is contained in:
jm-clius 2025-05-29 12:02:31 +01:00
parent f81262561a
commit e9d299540a
No known key found for this signature in database
GPG Key ID: 5FCD9D5211B952DA
6 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
library/events/json_message_ready_event.nim
View File

@ -2,9 +2,9 @@ import std/json
import ./json_base_event, ../../src/[message] import ./json_base_event, ../../src/[message]
type JsonMessageReadyEvent* = ref object of JsonEvent type JsonMessageReadyEvent* = ref object of JsonEvent
messageId*: MessageID messageId*: SdsMessageID
proc new*(T: type JsonMessageReadyEvent, messageId: MessageID): T = proc new*(T: type JsonMessageReadyEvent, messageId: SdsMessageID): T =
return JsonMessageReadyEvent(eventType: "message_ready", messageId: messageId) return JsonMessageReadyEvent(eventType: "message_ready", messageId: messageId)
method `$`*(jsonMessageReady: JsonMessageReadyEvent): string = method `$`*(jsonMessageReady: JsonMessageReadyEvent): string =

4
library/events/json_message_sent_event.nim
View File

@ -2,9 +2,9 @@ import std/json
import ./json_base_event, ../../src/[message] import ./json_base_event, ../../src/[message]
type JsonMessageSentEvent* = ref object of JsonEvent type JsonMessageSentEvent* = ref object of JsonEvent
messageId*: MessageID messageId*: SdsMessageID
proc new*(T: type JsonMessageSentEvent, messageId: MessageID): T = proc new*(T: type JsonMessageSentEvent, messageId: SdsMessageID): T =
return JsonMessageSentEvent(eventType: "message_sent", messageId: messageId) return JsonMessageSentEvent(eventType: "message_sent", messageId: messageId)
method `$`*(jsonMessageSent: JsonMessageSentEvent): string = method `$`*(jsonMessageSent: JsonMessageSentEvent): string =

8
library/events/json_missing_dependencies_event.nim
View File

@ -2,13 +2,13 @@ import std/json
import ./json_base_event, ../../src/[message] import ./json_base_event, ../../src/[message]
type JsonMissingDependenciesEvent* = ref object of JsonEvent type JsonMissingDependenciesEvent* = ref object of JsonEvent
messageId*: MessageID messageId*: SdsMessageID
missingDeps: seq[MessageID] missingDeps: seq[SdsMessageID]
proc new*( proc new*(
T: type JsonMissingDependenciesEvent, T: type JsonMissingDependenciesEvent,
messageId: MessageID, messageId: SdsMessageID,
missingDeps: seq[MessageID], missingDeps: seq[SdsMessageID],
): T = ): T =
return JsonMissingDependenciesEvent( return JsonMissingDependenciesEvent(
eventType: "missing_dependencies", messageId: messageId, missingDeps: missingDeps eventType: "missing_dependencies", messageId: messageId, missingDeps: missingDeps

6
library/libsds.nim
View File

@ -72,17 +72,17 @@ proc handleRequest(
return RET_OK return RET_OK
proc onMessageReady(ctx: ptr SdsContext): MessageReadyCallback = proc onMessageReady(ctx: ptr SdsContext): MessageReadyCallback =
return proc(messageId: MessageID) {.gcsafe.} = return proc(messageId: SdsMessageID) {.gcsafe.} =
callEventCallback(ctx, "onMessageReady"): callEventCallback(ctx, "onMessageReady"):
$JsonMessageReadyEvent.new(messageId) $JsonMessageReadyEvent.new(messageId)
proc onMessageSent(ctx: ptr SdsContext): MessageSentCallback = proc onMessageSent(ctx: ptr SdsContext): MessageSentCallback =
return proc(messageId: MessageID) {.gcsafe.} = return proc(messageId: SdsMessageID) {.gcsafe.} =
callEventCallback(ctx, "onMessageSent"): callEventCallback(ctx, "onMessageSent"):
$JsonMessageSentEvent.new(messageId) $JsonMessageSentEvent.new(messageId)
proc onMissingDependencies(ctx: ptr SdsContext): MissingDependenciesCallback = proc onMissingDependencies(ctx: ptr SdsContext): MissingDependenciesCallback =
return proc(messageId: MessageID, missingDeps: seq[MessageID]) {.gcsafe.} = return proc(messageId: SdsMessageID, missingDeps: seq[SdsMessageID]) {.gcsafe.} =
callEventCallback(ctx, "onMissingDependencies"): callEventCallback(ctx, "onMissingDependencies"):
$JsonMissingDependenciesEvent.new(messageId, missingDeps) $JsonMissingDependenciesEvent.new(messageId, missingDeps)

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

@ -38,7 +38,7 @@ proc createReliabilityManager(
error "Failed creating ReliabilityManager: Channel ID cannot be empty" error "Failed creating ReliabilityManager: Channel ID cannot be empty"
return err("Failed creating ReliabilityManager: Channel ID cannot be empty") return err("Failed creating ReliabilityManager: Channel ID cannot be empty")
let rm = newReliabilityManager(channelId).valueOr: let rm = newReliabilityManager(some(channelId)).valueOr:
error "Failed creating reliability manager", error = error error "Failed creating reliability manager", error = error
return err("Failed creating reliability manager: " & $error) return err("Failed creating reliability manager: " & $error)

2
library/sds_thread/inter_thread_communication/requests/sds_message_request.nim
View File

@ -16,7 +16,7 @@ type SdsMessageRequest* = object
type SdsUnwrapResponse* = object type SdsUnwrapResponse* = object
message*: seq[byte] message*: seq[byte]
missingDeps*: seq[MessageID] missingDeps*: seq[SdsMessageID]
proc createShared*( proc createShared*(
T: type SdsMessageRequest, T: type SdsMessageRequest,