From 2ecaf17840beb5bff13bd4e93f113b727150cbd8 Mon Sep 17 00:00:00 2001 From: Xavier Perret <xa.perret@outlook.com> Date: Sun, 30 Oct 2022 14:54:55 +0100 Subject: [PATCH] only debugging now --- app/process-connection/process-connection.go | 23 ++++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/app/process-connection/process-connection.go b/app/process-connection/process-connection.go index 9e8322f..71356b0 100644 --- a/app/process-connection/process-connection.go +++ b/app/process-connection/process-connection.go @@ -200,12 +200,31 @@ func processFakeRequest(conn net.Conn, serverListener net.Listener, serverConfig trans := utilities.TranslateMessageToTransaction(mess) utilities.PrintTransaction(trans) + fakeTrans := Transaction{ + Id: trans.Id, + Sender: utilities.RandomString(), + Receiver: utilities.RandomString(), + Amount: utilities.RandomString(), + } + database := ObjectStorageAPI.ReadDatabaseFromBlobStorage(objectStorage) + database = ObjectStorageAPI.FakeTransaction(trans, fakeTrans, database) + ObjectStorageAPI.WriteDatabaseToBlobStorage(database, objectStorage) } func processVoteRequest(conn net.Conn, serverListener net.Listener, serverConfig Config, objectStorage Blob, mess Message, amIRoot bool) { trans := utilities.TranslateMessageToTransaction(mess) + var transToRate Transaction utilities.PrintTransaction(trans) + + database := ObjectStorageAPI.ReadDatabaseFromBlobStorage(objectStorage) + for _, transactionInDatabase := range database { + if trans.Id == transactionInDatabase.Id { + transToRate = transactionInDatabase + } + } + + vote(serverListener, serverConfig, transToRate, "", objectStorage, amIRoot) } func ProcessClient(conn net.Conn, server net.Listener, objectStorage Blob, serverConfig Config, amIRoot bool, mutex *sync.Mutex) { @@ -237,6 +256,10 @@ func ProcessClient(conn net.Conn, server net.Listener, objectStorage Blob, serve } else if mess.MessageType == "voteRequest" { fmt.Println("Received a request to vote on a given transaction") processVoteRequest(conn, server, serverConfig, objectStorage, mess, amIRoot) + } else if mess.MessageType == "listTransactionsRequest" { + fmt.Println("Received a request to list all transactions") + database := ObjectStorageAPI.ReadDatabaseFromBlobStorage(objectStorage) + utilities.PrintingDatabaseToConsole(database) } else { fmt.Println("Unknown message type") } -- GitLab