Skip to content
Snippets Groups Projects
Commit 8ea1a529 authored by Xavier Perret's avatar Xavier Perret
Browse files

fixed translate

parent 474a41a7
Branches
No related tags found
1 merge request!2added file to separate client function from the server
...@@ -97,29 +97,22 @@ func PrintConnection(connection net.Conn, connectionNumber int) { ...@@ -97,29 +97,22 @@ func PrintConnection(connection net.Conn, connectionNumber int) {
fmt.Println("*****************************************") fmt.Println("*****************************************")
} }
// TranslateMessageToAckTransaction translates a message to an ack transaction
// the geniuses who made unmarshable take int as float64
func TranslateMessageToAckTransaction(mess Message) AckTransaction { func TranslateMessageToAckTransaction(mess Message) AckTransaction {
var transactionId string var transactionId string
var amountOfCorrectNode int var amountOfCorrectNode int
var totalNodes int var totalNode int
var err error
var body map[string]interface{} = mess.MessageBody.(map[string]interface{}) var body map[string]interface{} = mess.MessageBody.(map[string]interface{})
transactionId = body["id"].(string) transactionId = body["id"].(string)
amountOfCorrectNode, err = strconv.Atoi(body["amountOfCorrectNode"].(string)) amountOfCorrectNode = int(body["amountOfCorrectNode"].(float64))
if err != nil { totalNode = int(body["totalNodes"].(float64))
fmt.Println("Error while converting amountOfCorrectNode to int", err)
return AckTransaction{}
}
totalNodes, err = strconv.Atoi(body["totalNodes"].(string))
if err != nil {
fmt.Println("Error while converting totalNodes to int", err)
return AckTransaction{}
}
return AckTransaction{ return AckTransaction{
Id: transactionId, Id: transactionId,
AmountOfCorrectNode: amountOfCorrectNode, AmountOfCorrectNode: amountOfCorrectNode,
TotalNodes: totalNodes, TotalNodes: totalNode,
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment