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