cranberry

1
package services
2

3
import (
4
	memorypool "gitverse.ru/IvanTimofeev/cranberry/internal/pool"
5
	pbapi "gitverse.ru/IvanTimofeev/cranberry/pkg/grpc"
6
)
7

8
type PoolService struct {
9
	memorypool *memorypool.MemoryPool
10
}
11

12
func NewPoolService(memorypool *memorypool.MemoryPool) *PoolService {
13
	return &PoolService{
14
		memorypool: memorypool,
15
	}
16
}
17

18
func (ps *PoolService) PutTxToPool(txc *pbapi.TxContainer) error {
19
	// Здесь проверяем, присутствует ли транзакция в пуле
20
	_, ok := ps.memorypool.GetTx(txc.Hash)
21
	if !ok {
22
		// Если нет, то добавляем в пул.
23
		ps.memorypool.PutTx(txc)
24
	}
25
	return nil
26
}
27