ytsync/manager/transfer.go

package manager

import (
	"fmt"
	"github.com/lbryio/lbry.go/extras/errors"
	"github.com/lbryio/lbry.go/extras/jsonrpc"
	"github.com/lbryio/lbry.go/extras/util"
	"github.com/lbryio/ytsync/sdk"
	log "github.com/sirupsen/logrus"
	"strconv"
)

func waitConfirmations(s *Sync) error {
	allConfirmed := false
waiting:
	for !allConfirmed {
		utxolist, err := s.daemon.UTXOList(nil)
		if err != nil {
			return err
		} else if utxolist == nil {
			return errors.Err("no response")
		}

		for _, utxo := range *utxolist {
			if utxo.Confirmations <= 0 {
				err = s.waitForNewBlock()
				if err != nil {
					return err
				}
				continue waiting
			}
		}
		allConfirmed = true
	}
	return nil
}

func abandonSupports(s *Sync) (float64, error) {
	totalPages := uint64(1)
	var allSupports []jsonrpc.Claim
	for page := uint64(1); page <= totalPages; page++ {
		supports, err := s.daemon.SupportList(nil, page, 50)
		if err != nil {
			return 0, errors.Prefix("cannot list claims", err)
		}
		allSupports = append(allSupports, (*supports).Items...)
		totalPages = (*supports).TotalPages
	}
	alreadyAbandoned := make(map[string]bool, len(allSupports))
	totalAbandoned := 0.0
	for _, support := range allSupports {
		_, ok := alreadyAbandoned[support.ClaimID]
		if ok {
			continue
		}
		supportOnTransferredClaim := support.Address == s.publishAddress
		if supportOnTransferredClaim {
			continue
		}
		alreadyAbandoned[support.ClaimID] = true
		summary, err := s.daemon.SupportAbandon(&support.ClaimID, nil, nil, nil, nil)
		if err != nil {
			return totalAbandoned, errors.Err(err)
		}
		if len(summary.Outputs) < 1 {
			return totalAbandoned, errors.Err("error abandoning supports: no outputs while abandoning %s", support.ClaimID)
		}
		outputAmount, err := strconv.ParseFloat(summary.Outputs[0].Amount, 64)
		if err != nil {
			return totalAbandoned, errors.Err(err)
		}
		totalAbandoned += outputAmount
		log.Infof("Abandoned supports of %.4f LBC for claim %s", outputAmount, support.ClaimID)
	}
	return totalAbandoned, nil
}

func transferVideos(s *Sync) error {
	cleanTransfer := true
	for _, video := range s.syncedVideos {
		if !video.Published || video.Transferred || video.MetadataVersion != LatestMetadataVersion {
			log.Debugf("skipping video: %s", video.VideoID)
			continue
		}

		//Todo - Wait for prior sync to see that the publish is confirmed in lbrycrd?
		c, err := s.daemon.ClaimSearch(nil, &video.ClaimID, nil, nil)
		if err != nil {
			return errors.Err(err)
		}
		if len(c.Claims) == 0 {
			return errors.Err("cannot transfer: no claim found for this video")
		} else if len(c.Claims) > 1 {
			return errors.Err("cannot transfer: too many claims. claimID: %s", video.ClaimID)
		}

		streamUpdateOptions := jsonrpc.StreamUpdateOptions{
			StreamCreateOptions: &jsonrpc.StreamCreateOptions{
				ClaimCreateOptions: jsonrpc.ClaimCreateOptions{ClaimAddress: &s.publishAddress},
			},
			Bid: util.PtrToString("0.009"), // Todo - Dont hardcode
		}

		videoStatus := sdk.VideoStatus{
			ChannelID:     s.YoutubeChannelID,
			VideoID:       video.VideoID,
			ClaimID:       video.ClaimID,
			ClaimName:     video.ClaimName,
			Status:        VideoStatusPublished,
			IsTransferred: util.PtrToBool(true),
		}

		result, updateError := s.daemon.StreamUpdate(video.ClaimID, streamUpdateOptions)
		if updateError != nil {
			cleanTransfer = false
			videoStatus.FailureReason = updateError.Error()
			videoStatus.Status = VideoStatusTranferFailed
			videoStatus.IsTransferred = util.PtrToBool(false)
		} else {
			videoStatus.IsTransferred = util.PtrToBool(len(result.Outputs) != 0)
		}
		log.Infof("TRANSFERRED %t", *videoStatus.IsTransferred)
		statusErr := s.APIConfig.MarkVideoStatus(videoStatus)
		if statusErr != nil {
			return errors.Prefix(statusErr.Error(), updateError)
		}
		if updateError != nil {
			return errors.Err(updateError)
		}
	}
	// Todo - Transfer Channel as last step and post back to remote db that channel is transferred.
	//Transfer channel
	if !cleanTransfer {
		return errors.Err("A video has failed to transfer for the channel...skipping channel transfer")
	}
	return nil
}

func transferChannel(s *Sync) error {
	channelClaim, err := s.daemon.ClaimSearch(nil, &s.lbryChannelID, nil, nil)
	if err != nil {
		return errors.Err(err)
	}
	if channelClaim == nil || len(channelClaim.Claims) == 0 {
		return errors.Err("There is no channel claim for channel %s", s.LbryChannelName)
	}
	if channelClaim.Claims[0].Address == s.publishAddress {
		return nil
	}
	updateOptions := jsonrpc.ChannelUpdateOptions{
		Bid: util.PtrToString(fmt.Sprintf("%.6f", channelClaimAmount-0.002)),
		ChannelCreateOptions: jsonrpc.ChannelCreateOptions{
			ClaimCreateOptions: jsonrpc.ClaimCreateOptions{
				ClaimAddress: &s.publishAddress,
			},
		},
	}
	result, err := s.daemon.ChannelUpdate(s.lbryChannelID, updateOptions)
	if err != nil {
		return errors.Err(err)
	}
	log.Infof("TRANSFERRED %t", len(result.Outputs) != 0)

	return errors.Err(err)
}