From aeeebf6f588ec4ce209284101f5406914af5bbe7 Mon Sep 17 00:00:00 2001 From: ycc Date: Thu, 26 Feb 2026 22:08:45 +0100 Subject: [PATCH] add missing server encryption --- client/helpers/bgSendHelper.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/client/helpers/bgSendHelper.go b/client/helpers/bgSendHelper.go index b328844..e9e0298 100644 --- a/client/helpers/bgSendHelper.go +++ b/client/helpers/bgSendHelper.go @@ -9,6 +9,7 @@ import ( "forge.redroom.link/yves/meowlib" "forge.redroom.link/yves/meowlib/client" + "google.golang.org/protobuf/proto" ) const maxRetriesPerServer = 3 @@ -114,7 +115,6 @@ func attemptSendJob(job *client.SendJob) (int, error) { if err != nil { return -1, err } - // Ensure the retries slice is aligned with the servers slice for len(job.Retries) < len(job.Servers) { job.Retries = append(job.Retries, 0) @@ -126,10 +126,19 @@ func attemptSendJob(job *client.SendJob) (int, error) { } for i, srv := range job.Servers { + // Prepare for server + var packedUsrMsg *meowlib.PackedUserMessage + err := proto.Unmarshal(data, packedUsrMsg) + if err != nil { + // todo + return -1, err + } + PackMessageForServer(packedUsrMsg, srv.GetUid()) + if job.Retries[i] >= maxRetriesPerServer { continue // this server is exhausted } - _, err := meowlib.HttpPostMessage(srv.Url, data, timeout) + _, err = meowlib.HttpPostMessage(srv.Url, data, timeout) if err != nil { logger.Warn().Err(err).Str("url", srv.Url).Int("retry", job.Retries[i]+1).Msg("attemptSendJob: POST failed") job.Retries[i]++