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

Cleanups

Browse Source
This commit is contained in:
Jazz Turner-Baggs 2025-12-11 21:45:35 -08:00
parent 857d3c4c08
commit d37302c6e1
No known key found for this signature in database
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/chat/conversations/private_v1.nim
View File

@ -97,7 +97,6 @@ proc decrypt*(convo: PrivateV1, enc: EncryptedPayload): Result[seq[byte], ChatEr
prevChainLen: dr.prevChainLen prevChainLen: dr.prevChainLen
) )
copyMem(addr header.dhPublic[0], unsafeAddr dr.dh[0], dr.dh.len) # TODO: Avoid this copy copyMem(addr header.dhPublic[0], unsafeAddr dr.dh[0], dr.dh.len) # TODO: Avoid this copy
debug "DECR WRAP", who=convo.owner.getName(), cipher = shrink(dr.ciphertext[0..8])
convo.doubleratchet.decrypt(header, dr.ciphertext, @[]).mapErr(proc(e: NaxolotlError): ChatError = ChatError(code: errWrapped, context: repr(e) )) convo.doubleratchet.decrypt(header, dr.ciphertext, @[]).mapErr(proc(e: NaxolotlError): ChatError = ChatError(code: errWrapped, context: repr(e) ))
@ -169,7 +168,6 @@ proc encodeFrame*(self: PrivateV1, msg: PrivateV1Frame): (MessageId, EncryptedPa
result = (msgId, self.encrypt(sdsPayload)) result = (msgId, self.encrypt(sdsPayload))
proc sendFrame(self: PrivateV1, ds: WakuClient, proc sendFrame(self: PrivateV1, ds: WakuClient,
msg: PrivateV1Frame): Future[MessageId]{.async.} = msg: PrivateV1Frame): Future[MessageId]{.async.} =
let (msgId, encryptedPayload) = self.encodeFrame(msg) let (msgId, encryptedPayload) = self.encodeFrame(msg)
@ -182,9 +180,6 @@ proc sendFrame(self: PrivateV1, ds: WakuClient,
method id*(self: PrivateV1): string = method id*(self: PrivateV1): string =
return getConvoIdRaw(self.allParticipants(), self.discriminator) return getConvoIdRaw(self.allParticipants(), self.discriminator)
proc handleFrame*[T: ConversationStore](convo: PrivateV1, client: T, proc handleFrame*[T: ConversationStore](convo: PrivateV1, client: T,
encPayload: EncryptedPayload) = encPayload: EncryptedPayload) =
## Dispatcher for Incoming `PrivateV1Frames`. ## Dispatcher for Incoming `PrivateV1Frames`.
@ -254,7 +249,7 @@ proc encryptMessage*(self: PrivateV1, content_frame: Content) : (MessageId, Encr
result = self.encodeFrame(frame) result = self.encodeFrame(frame)
except Exception as e: except Exception as e:
error "Unknown error in PrivateV1:SendMessage" error "Unknown error in PrivateV1:EncryptMessage"
proc initPrivateV1Sender*(sender:Identity, proc initPrivateV1Sender*(sender:Identity,
ds: WakuClient, ds: WakuClient,
@ -272,4 +267,4 @@ proc initPrivateV1Sender*(sender:Identity,
proc initPrivateV1Recipient*(owner:Identity,ds: WakuClient, participant: PublicKey, seedKey: array[32, byte], deliveryAckCb: proc( proc initPrivateV1Recipient*(owner:Identity,ds: WakuClient, participant: PublicKey, seedKey: array[32, byte], deliveryAckCb: proc(
conversation: Conversation, msgId: string): Future[void] {.async.} = nil): PrivateV1 = conversation: Conversation, msgId: string): Future[void] {.async.} = nil): PrivateV1 =
initPrivateV1(owner,ds, participant, seedKey, "default", false, deliveryAckCb) initPrivateV1(owner,ds, participant, seedKey, "default", false, deliveryAckCb)