queue_parser_tx.go

/*---------------------------------------------------------------------------------------------
 *  Copyright (c) IBAX. All rights reserved.
 *  See LICENSE in the project root for license information.
 *--------------------------------------------------------------------------------------------*/

package daemons

import (
	"context"
	"sync/atomic"

	"github.com/IBAX-io/go-ibax/packages/transaction"
)

// QueueParserTx parses transaction from the queue
func QueueParserTx(ctx context.Context, d *daemon) error {
	if atomic.CompareAndSwapUint32(&d.atomic, 0, 1) {
		defer atomic.StoreUint32(&d.atomic, 0)
	} else {
		return nil
	}
	DBLock()
	defer DBUnlock()
	//
	//infoBlock := &sqldb.InfoBlock{}
	//_, err := infoBlock.Get()
	//if err != nil {
	//	d.logger.WithFields(log.Fields{"type": consts.DBError, "error": err}).Error("getting info block")
	//	return err
	//}
	//if infoBlock.BlockId == 0 {
	//	d.logger.Debug("no blocks for parsing")
	//	return nil
	//}

	err := transaction.ProcessTransactionsQueue(nil)
	if err != nil {
		d.logger.WithError(err).Error("parsing transactions")
		return err
	}
	//for {
	//	select {
	//	case attempt := <-transaction.ChanTxAttempt:
	//		if attempt {
	//			err = transaction.ProcessTransactionsAttempt(p.DbTransaction)
	//			if err != nil {
	//				d.logger.WithError(err).Error("parsing transactions attempt")
	//				return err
	//			}
	//		}
	//	default:
	//		return nil
	//	}
	//}
	return nil
}