LBRYCommunity/ytsync
1
0
Fork 0
Code Issues 39 Pull requests 8 Projects Releases 197 Packages Wiki Activity

fix double counting

Browse source 
fix transferred check
This commit is contained in:
Niko Storni 2019-09-25 04:15:16 +02:00
parent 8d56ef852f
commit 2f701a887a
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
manager/ytsync.go
View file

@ -546,7 +546,7 @@ func (s *Sync) updateRemoteDB(claims []jsonrpc.Claim) (total, fixed, removed int
if !claimInDatabase { if !claimInDatabase {
log.Debugf("%s: Published but is not in database (%s - %s)", videoID, c.Name, c.ClaimID) log.Debugf("%s: Published but is not in database (%s - %s)", videoID, c.Name, c.ClaimID)
} }
if s.syncedVideos[videoID].Transferred { if s.syncedVideos[videoID].Transferred && s.publishAddress != c.Address {
log.Debugf("%s: Marked as transferred while in fact it's not (%s - %s). Publish address: %s, expected: %s", videoID, c.Name, c.ClaimID, c.Address, s.publishAddress) log.Debugf("%s: Marked as transferred while in fact it's not (%s - %s). Publish address: %s, expected: %s", videoID, c.Name, c.ClaimID, c.Address, s.publishAddress)
} }
if !claimInDatabase || metadataDiffers || claimIDDiffers || claimNameDiffers || claimMarkedUnpublished { if !claimInDatabase || metadataDiffers || claimIDDiffers || claimNameDiffers || claimMarkedUnpublished {
@ -575,7 +575,6 @@ func (s *Sync) updateRemoteDB(claims []jsonrpc.Claim) (total, fixed, removed int
for vID, sv := range s.syncedVideos { for vID, sv := range s.syncedVideos {
if sv.Transferred { if sv.Transferred {
log.Infof("%s: claim was transferred, ignoring", vID) log.Infof("%s: claim was transferred, ignoring", vID)
count++ //still count them as publishes
continue continue
} }
_, ok := videoIDMap[vID] _, ok := videoIDMap[vID]