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

remove launch parameter

Browse source 
improve failure handling
adjust slack logging
increase file size in string
increase publish timeout to 40 minutes
This commit is contained in:
Niko Storni 2018-06-17 19:50:59 -04:00
parent 920ee956ac
commit ad8a9c3003
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sources/youtubeVideo.go
View file

@ -214,7 +214,7 @@ func (v YoutubeVideo) Sync(daemon *jsonrpc.Client, claimAddress string, amount f
if fi.Size() > 2*1024*1024*1024 { if fi.Size() > 2*1024*1024*1024 {
//delete the video and ignore the error //delete the video and ignore the error
_ = v.delete() _ = v.delete()
return errors.Err("video is bigger than 1GB, skipping for now") return errors.Err("video is bigger than 2GB, skipping for now")
} }
err = v.triggerThumbnailSave() err = v.triggerThumbnailSave()

9
ytsync.go
View file

@ -159,7 +159,7 @@ func (s *Sync) FullCycle() error {
log.Infoln("Waiting for daemon to finish starting...") log.Infoln("Waiting for daemon to finish starting...")
s.daemon = jsonrpc.NewClient("") s.daemon = jsonrpc.NewClient("")
s.daemon.SetRPCTimeout(20 * time.Minute) s.daemon.SetRPCTimeout(40 * time.Minute)
WaitForDaemonStart: WaitForDaemonStart:
for { for {
@ -257,6 +257,7 @@ func (s *Sync) startWorker(workerNum int) {
":5279: read: connection reset by peer", ":5279: read: connection reset by peer",
"no space left on device", "no space left on device",
"NotEnoughFunds", "NotEnoughFunds",
"Cannot publish using channel",
} }
if util.InSliceContains(err.Error(), fatalErrors) || s.StopOnError { if util.InSliceContains(err.Error(), fatalErrors) || s.StopOnError {
s.grp.Stop() s.grp.Stop()
@ -271,15 +272,15 @@ func (s *Sync) startWorker(workerNum int) {
"Error in daemon: Cannot publish empty file", "Error in daemon: Cannot publish empty file",
"Error extracting sts from embedded url response", "Error extracting sts from embedded url response",
"Client.Timeout exceeded while awaiting headers)", "Client.Timeout exceeded while awaiting headers)",
"video is bigger than 1GB, skipping for now", "video is bigger than 2GB, skipping for now",
} }
if util.InSliceContains(err.Error(), errorsNoRetry) { if util.InSliceContains(err.Error(), errorsNoRetry) {
log.Println("This error should not be retried at all") log.Println("This error should not be retried at all")
} else if tryCount < s.MaxTries { } else if tryCount < s.MaxTries {
if strings.Contains(err.Error(), "258: txn-mempool-conflict") || if strings.Contains(err.Error(), "txn-mempool-conflict") ||
strings.Contains(err.Error(), "failed: Not enough funds") || strings.Contains(err.Error(), "failed: Not enough funds") ||
strings.Contains(err.Error(), "Error in daemon: Insufficient funds, please deposit additional LBC") || strings.Contains(err.Error(), "Error in daemon: Insufficient funds, please deposit additional LBC") ||
strings.Contains(err.Error(), "64: too-long-mempool-chain") { strings.Contains(err.Error(), "too-long-mempool-chain") {
log.Println("waiting for a block and refilling addresses before retrying") log.Println("waiting for a block and refilling addresses before retrying")
err = s.walletSetup() err = s.walletSetup()
if err != nil { if err != nil {