diff --git a/plugins/analysis/dashboard/fpc_livefeed.go b/plugins/analysis/dashboard/fpc_livefeed.go index 8a80f817467729d801829cafa3bdf72539ffe0f4..5251f36b0b1de94de539c6c80918355e7ae0252e 100644 --- a/plugins/analysis/dashboard/fpc_livefeed.go +++ b/plugins/analysis/dashboard/fpc_livefeed.go @@ -86,31 +86,33 @@ func createFPCUpdate(hb *packet.FPCHeartbeat, recordEvent bool) *FPCUpdate { } } - // check finalized conflicts - if len(hb.Finalized) > 0 { - finalizedConflicts := make([]FPCRecord, len(hb.Finalized)) - i := 0 - for ID, finalOpinion := range hb.Finalized { - recordedConflicts.lock.Lock() - conflictDetail := recordedConflicts.conflictSet[ID].NodesView[nodeID] - conflictDetail.Status = vote.ConvertOpinionToInt32(finalOpinion) - conflicts[ID] = newConflict() - conflicts[ID].NodesView[nodeID] = conflictDetail - recordedConflicts.conflictSet[ID].NodesView[nodeID] = conflictDetail - finalizedConflicts[i] = FPCRecord{ - ConflictID: ID, - NodeID: conflictDetail.NodeID, - Rounds: conflictDetail.Rounds, - Opinions: conflictDetail.Opinions, - Status: conflictDetail.Status, + if recordEvent { + // check finalized conflicts + if len(hb.Finalized) > 0 { + finalizedConflicts := make([]FPCRecord, len(hb.Finalized)) + i := 0 + for ID, finalOpinion := range hb.Finalized { + recordedConflicts.lock.Lock() + conflictDetail := recordedConflicts.conflictSet[ID].NodesView[nodeID] + conflictDetail.Status = vote.ConvertOpinionToInt32(finalOpinion) + conflicts[ID] = newConflict() + conflicts[ID].NodesView[nodeID] = conflictDetail + recordedConflicts.conflictSet[ID].NodesView[nodeID] = conflictDetail + finalizedConflicts[i] = FPCRecord{ + ConflictID: ID, + NodeID: conflictDetail.NodeID, + Rounds: conflictDetail.Rounds, + Opinions: conflictDetail.Opinions, + Status: conflictDetail.Status, + } + recordedConflicts.lock.Unlock() + i++ } - recordedConflicts.lock.Unlock() - i++ - } - err := storeFPCRecords(finalizedConflicts, mongoDB()) - if err != nil { - log.Errorf("Error while writing on MongoDB: %s", err) + err := storeFPCRecords(finalizedConflicts, mongoDB()) + if err != nil { + log.Errorf("Error while writing on MongoDB: %s", err) + } } } diff --git a/plugins/analysis/dashboard/fpc_livefeed_test.go b/plugins/analysis/dashboard/fpc_livefeed_test.go index b012f590698ab244ae3d7f2956c0450cf724d972..e72421b74ac4a384294e9b2849339fcc166e7ca7 100644 --- a/plugins/analysis/dashboard/fpc_livefeed_test.go +++ b/plugins/analysis/dashboard/fpc_livefeed_test.go @@ -30,7 +30,6 @@ func TestCreateFPCUpdate(t *testing.T) { Opinions: []vote.Opinion{vote.Dislike, vote.Like, vote.Dislike}, }}, }, - Finalized: map[string]vote.Opinion{"one": vote.Like}, } // create a matching FPCUpdate @@ -42,7 +41,6 @@ func TestCreateFPCUpdate(t *testing.T) { NodeID: base58OwnID, Rounds: 3, Opinions: []int32{disliked, liked, disliked}, - Status: liked, }, }, },