mirror of
https://github.com/PeernetOfficial/core.git
synced 2026-07-16 18:37:51 +01:00
added condition to ensure TAG is not sent and removed debug prints
This commit is contained in:
@@ -274,12 +274,9 @@ func (multi *MultiStore) IngestBlock(header *MultiBlockchainHeader, blockNumber
|
||||
// decode it
|
||||
decoded, status, err := DecodeBlockRaw(raw)
|
||||
if failIfInvalid && err != nil {
|
||||
fmt.Println("---- block invalid -----")
|
||||
return nil, err
|
||||
}
|
||||
|
||||
fmt.Println("updated")
|
||||
|
||||
// store the transferred block in the cache
|
||||
err = multi.WriteBlock(header.PublicKey, header.Version, blockNumber, raw)
|
||||
if err != nil {
|
||||
@@ -293,13 +290,6 @@ func (multi *MultiStore) IngestBlock(header *MultiBlockchainHeader, blockNumber
|
||||
multi.UpdateBlockchainStatistics(header, decoded.RecordsDecoded)
|
||||
}
|
||||
|
||||
for _, recordRaw := range decoded.RecordsRaw {
|
||||
if recordRaw.Type == 0 {
|
||||
fmt.Println("Profile update detected")
|
||||
}
|
||||
}
|
||||
fmt.Println("---------")
|
||||
|
||||
// update the blockchain header
|
||||
multi.WriteBlockchainHeader(header)
|
||||
|
||||
|
||||
@@ -74,6 +74,10 @@ func blockRecordFileToAPI(input blockchain.BlockRecordFile) (output apiFile) {
|
||||
|
||||
case blockchain.TagSharedByCount:
|
||||
output.Metadata = append(output.Metadata, apiFileMetadata{Type: tag.Type, Name: "Shared By Count", Number: tag.Number()})
|
||||
// if a file has 0 peers sharing then do not add it to the list.
|
||||
if tag.Number() == 0 {
|
||||
return apiFile{}
|
||||
}
|
||||
|
||||
case blockchain.TagSharedByGeoIP:
|
||||
output.Metadata = append(output.Metadata, apiFileMetadata{Type: tag.Type, Name: "Shared By GeoIP", Text: tag.Text()})
|
||||
|
||||
Reference in New Issue
Block a user