Method matchProvidersWithUser

blockproducer/metastate.go:553–693

(tx *types.CreateDatabase)

}

func (s *metaState) matchProvidersWithUser(tx *types.CreateDatabase) (err error) {
	log.Infof("create database: %s", tx.Hash())
	sender, err := crypto.PubKeyHash(tx.Signee)
	if err != nil {
		err = errors.Wrap(err, "matchProviders failed")
		return
	}
	if sender != tx.Owner {
		err = errors.Wrapf(ErrInvalidSender, "match failed with real sender: %s, sender: %s",
			sender, tx.Owner)
		return
	}

	if tx.GasPrice <= 0 {
		err = ErrInvalidGasPrice
		return
	}
	if tx.ResourceMeta.Node <= 0 {
		err = ErrInvalidMinerCount
		return
	}
	minerCount := uint64(tx.ResourceMeta.Node)

	minAdvancePayment := minDeposit(tx.GasPrice, minerCount)

	if tx.AdvancePayment < minAdvancePayment {
		err = ErrInsufficientAdvancePayment
		log.WithError(err).Warningf("tx.AdvancePayment: %d, minAdvancePayment: %d",
			tx.AdvancePayment, minAdvancePayment)
		return
	}

	miners := make(MinerInfos, 0, minerCount)

	for _, m := range tx.ResourceMeta.TargetMiners {
		if po, loaded := s.loadProviderObject(m); !loaded {
			log.WithFields(log.Fields{
				"miner_addr": m,
				"user_addr":  sender,
			}).Error(err)
			err = ErrNoSuchMiner
			continue
		} else {
			miners, err = filterAndAppendMiner(miners, po, tx, sender)
			if err != nil {
				log.Warnf("miner filtered %v", err)
			}
			// if got enough, break
			if uint64(miners.Len()) == minerCount {
				break
			}
		}
	}

	// not enough, find more miner(s)
	if uint64(miners.Len()) < minerCount {
		if uint64(len(tx.ResourceMeta.TargetMiners)) >= minerCount {
			err = errors.Wrapf(err, "miners match target are not enough %d:%d", miners.Len(), minerCount)