96 lines
3.2 KiB
Go
96 lines
3.2 KiB
Go
package helpers
|
|
|
|
import (
|
|
"forge.redroom.link/yves/meowlib"
|
|
"forge.redroom.link/yves/meowlib/client"
|
|
)
|
|
|
|
func PackMessageForServer(packedMsg *meowlib.PackedUserMessage, srvuid string) ([]byte, string, error) {
|
|
// Get the message server
|
|
srv, err := client.GetConfig().GetIdentity().MessageServers.LoadServer(srvuid)
|
|
if err != nil {
|
|
return nil, "messageBuildPostprocess : LoadServer", err
|
|
}
|
|
// Creating Server message for transporting the user message
|
|
toServerMessage := srv.BuildToServerMessageFromUserMessage(packedMsg)
|
|
data, err := srv.ProcessOutboundMessage(toServerMessage)
|
|
if err != nil {
|
|
return nil, "messageBuildPostprocess : ProcessOutboundMessage", err
|
|
}
|
|
return data, "", nil
|
|
|
|
}
|
|
|
|
func CreateStorePackUserMessageForServer(message string, srvuid string, peer_uid string, replyToUid string, filelist []string) ([]byte, string, error) {
|
|
usermessage, errtxt, err := CreateAndStoreUserMessage(message, peer_uid, replyToUid, filelist)
|
|
if err != nil {
|
|
return nil, errtxt, err
|
|
}
|
|
return PackMessageForServer(usermessage, srvuid)
|
|
}
|
|
|
|
func CreateAndStoreUserMessage(message string, peer_uid string, replyToUid string, filelist []string) (*meowlib.PackedUserMessage, string, error) {
|
|
peer := client.GetConfig().GetIdentity().Peers.GetFromUid(peer_uid)
|
|
|
|
// Creating User message
|
|
usermessage, err := peer.BuildSimpleUserMessage([]byte(message))
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : BuildSimpleUserMessage", err
|
|
}
|
|
for _, file := range filelist {
|
|
err = usermessage.AddFile(file, client.GetConfig().Chunksize)
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : AddFile", err
|
|
}
|
|
}
|
|
usermessage.Status.AnswerToUuid = replyToUid
|
|
|
|
// Store message
|
|
err = peer.StoreMessage(usermessage, nil)
|
|
if err != nil {
|
|
return nil, "messageBuildPostprocess : StoreMessage", err
|
|
}
|
|
|
|
// Prepare cyphered + packed user message
|
|
packedMsg, err := peer.ProcessOutboundUserMessage(usermessage)
|
|
if err != nil {
|
|
return nil, "messageBuildPostprocess : ProcessOutboundUserMessage", err
|
|
}
|
|
|
|
return packedMsg, "", nil
|
|
}
|
|
|
|
func BuildAckMessage(messageUid string, srvuid string, peer_uid string, received int64, processed int64) ([]byte, string, error) {
|
|
|
|
peer := client.GetConfig().GetIdentity().Peers.GetFromUid(peer_uid)
|
|
srv, err := client.GetConfig().GetIdentity().MessageServers.LoadServer(srvuid)
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : LoadServer", err
|
|
}
|
|
// Creating User message
|
|
usermessage, err := peer.BuildSimpleUserMessage(nil)
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : BuildSimpleUserMessage", err
|
|
}
|
|
usermessage.Status.Uuid = messageUid
|
|
usermessage.Status.Received = uint64(received)
|
|
usermessage.Status.Processed = uint64(processed)
|
|
// Prepare cyphered + packed user message
|
|
packedMsg, err := peer.ProcessOutboundUserMessage(usermessage)
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : ProcessOutboundUserMessage", err
|
|
}
|
|
// Creating Server message for transporting the user message
|
|
toServerMessage := srv.BuildToServerMessageFromUserMessage(packedMsg)
|
|
data, err := srv.ProcessOutboundMessage(toServerMessage)
|
|
if err != nil {
|
|
return nil, "PrepareServerMessage : ProcessOutboundMessage", err
|
|
}
|
|
|
|
return data, "", nil
|
|
}
|
|
|
|
func ReadAckMessageResponse() {
|
|
//! update the status in message store
|
|
}
|