2018-02-13 18:47:05 +01:00
|
|
|
package sources
|
|
|
|
|
|
|
|
import (
|
|
|
|
"strings"
|
2018-06-04 16:35:35 +02:00
|
|
|
|
2019-01-11 02:34:34 +01:00
|
|
|
"github.com/lbryio/lbry.go/extras/jsonrpc"
|
2018-10-08 22:19:17 +02:00
|
|
|
"github.com/lbryio/ytsync/namer"
|
2018-02-13 18:47:05 +01:00
|
|
|
)
|
|
|
|
|
2018-07-21 01:56:36 +02:00
|
|
|
type SyncSummary struct {
|
|
|
|
ClaimID string
|
|
|
|
ClaimName string
|
|
|
|
}
|
|
|
|
|
2018-09-18 22:57:25 +02:00
|
|
|
func publishAndRetryExistingNames(daemon *jsonrpc.Client, title, filename string, amount float64, options jsonrpc.PublishOptions, namer *namer.Namer) (*SyncSummary, error) {
|
2018-02-13 18:47:05 +01:00
|
|
|
for {
|
2018-09-18 21:20:34 +02:00
|
|
|
name := namer.GetNextName(title)
|
2018-07-21 01:56:36 +02:00
|
|
|
response, err := daemon.Publish(name, filename, amount, options)
|
2018-09-18 21:20:34 +02:00
|
|
|
if err != nil {
|
|
|
|
if strings.Contains(err.Error(), "failed: Multiple claims (") {
|
2018-02-13 18:47:05 +01:00
|
|
|
continue
|
|
|
|
}
|
2018-07-21 01:56:36 +02:00
|
|
|
return nil, err
|
2018-02-13 18:47:05 +01:00
|
|
|
}
|
2018-09-18 21:20:34 +02:00
|
|
|
return &SyncSummary{ClaimID: response.ClaimID, ClaimName: name}, nil
|
2018-02-13 18:47:05 +01:00
|
|
|
}
|
|
|
|
}
|