block-accounting/backend/internal/usecase/interactors/transactions/interactor.go

277 lines
7.0 KiB
Go
Raw Normal View History

2024-05-24 17:44:24 +00:00
package transactions
import (
"context"
"encoding/base64"
"encoding/json"
"fmt"
"log/slog"
"time"
"github.com/emochka2007/block-accounting/internal/pkg/ctxmeta"
"github.com/emochka2007/block-accounting/internal/pkg/models"
2024-05-27 21:29:05 +00:00
"github.com/emochka2007/block-accounting/internal/usecase/interactors/chain"
2024-05-24 17:44:24 +00:00
"github.com/emochka2007/block-accounting/internal/usecase/interactors/organizations"
"github.com/emochka2007/block-accounting/internal/usecase/repository/transactions"
"github.com/google/uuid"
)
type ListParams struct {
IDs uuid.UUIDs
OrganizationID uuid.UUID
2024-05-28 22:46:30 +00:00
Pending bool
ReadyToConfirm bool
Limit int64
Cursor string
2024-05-24 17:44:24 +00:00
}
type CreateParams struct {
Tx models.Transaction
OrganizationId uuid.UUID
}
type ConfirmParams struct {
TxID uuid.UUID
OrganizationID uuid.UUID
}
type CancelParams struct {
TxID uuid.UUID
OrganizationID uuid.UUID
Cause string
}
type TransactionsInteractor interface {
List(ctx context.Context, params ListParams) (*ListResult, error)
Create(ctx context.Context, params CreateParams) (*models.Transaction, error)
Confirm(ctx context.Context, params ConfirmParams) (*models.Transaction, error)
Cancel(ctx context.Context, params CancelParams) (*models.Transaction, error)
}
type transactionsInteractor struct {
2024-05-27 21:29:05 +00:00
log *slog.Logger
txRepo transactions.Repository
orgInteractor organizations.OrganizationsInteractor
chainInteractor chain.ChainInteractor
2024-05-24 17:44:24 +00:00
}
func NewTransactionsInteractor(
log *slog.Logger,
txRepo transactions.Repository,
orgInteractor organizations.OrganizationsInteractor,
2024-05-27 21:29:05 +00:00
chainInteractor chain.ChainInteractor,
2024-05-24 17:44:24 +00:00
) TransactionsInteractor {
return &transactionsInteractor{
2024-05-27 21:29:05 +00:00
log: log,
txRepo: txRepo,
orgInteractor: orgInteractor,
chainInteractor: chainInteractor,
2024-05-24 17:44:24 +00:00
}
}
type txsListCursor struct {
Id uuid.UUID `json:"id"`
}
func newTxsListCursor(id ...uuid.UUID) *txsListCursor {
if len(id) > 0 {
return &txsListCursor{id[0]}
}
return new(txsListCursor)
}
func (c *txsListCursor) encode() (string, error) {
data, err := json.Marshal(c)
if err != nil {
return "", fmt.Errorf("couldn't marshal reaction id. %w", err)
}
return base64.StdEncoding.EncodeToString(data), nil
}
func (c *txsListCursor) decode(s string) error {
if c == nil {
return nil
}
token, err := base64.StdEncoding.DecodeString(s)
if err != nil {
return fmt.Errorf("error decode token. %w", err)
}
return json.Unmarshal(token, c)
}
type ListResult struct {
Txs []*models.Transaction
NextCursor string
}
func (i *transactionsInteractor) List(ctx context.Context, params ListParams) (*ListResult, error) {
if params.Limit == 0 {
params.Limit = 50
}
cursor := newTxsListCursor()
if params.Cursor != "" {
if err := cursor.decode(params.Cursor); err != nil {
return nil, fmt.Errorf("error decode cursor value. %w", err) // maybe just log error?
}
}
txs, err := i.txRepo.GetTransactions(ctx, transactions.GetTransactionsParams{
OrganizationId: params.OrganizationID,
Limit: params.Limit,
CursorId: cursor.Id,
2024-05-28 22:46:30 +00:00
Pending: params.Pending,
ReadyToConfirm: params.ReadyToConfirm,
2024-05-24 17:44:24 +00:00
})
if err != nil {
return nil, fmt.Errorf("error fetch transaction from repository. %w", err)
}
var nextCursor string
if len(txs) >= 50 || len(txs) >= int(params.Limit) {
cursor.Id = txs[len(txs)-1].Id
if nextCursor, err = cursor.encode(); err != nil {
return nil, fmt.Errorf("error encode next page token. %w", err) // maybe just log error?
}
}
return &ListResult{
Txs: txs,
NextCursor: nextCursor,
}, nil
}
func (i *transactionsInteractor) Create(
ctx context.Context,
params CreateParams,
) (*models.Transaction, error) {
user, err := ctxmeta.User(ctx)
if err != nil {
return nil, fmt.Errorf("error fetch user from context. %w", err)
}
tx := params.Tx
if tx.Id == uuid.Nil {
tx.Id = uuid.Must(uuid.NewV7())
}
participant, err := i.orgInteractor.Participant(ctx, organizations.ParticipantParams{
ID: user.Id(),
OrganizationID: params.OrganizationId,
ActiveOnly: true,
UsersOnly: true,
})
if err != nil {
return nil, fmt.Errorf("error fetch actor prticipant. %w", err)
}
tx.CreatedBy = participant.GetUser()
tx.CreatedAt = time.Now()
tx.UpdatedAt = tx.CreatedAt
if err = i.txRepo.CreateTransaction(ctx, tx); err != nil {
return nil, fmt.Errorf("error create new tx. %w", err)
}
return &tx, nil
}
func (i *transactionsInteractor) Confirm(ctx context.Context, params ConfirmParams) (*models.Transaction, error) {
user, err := ctxmeta.User(ctx)
if err != nil {
return nil, fmt.Errorf("error fetch user from context. %w", err)
}
participant, err := i.orgInteractor.Participant(ctx, organizations.ParticipantParams{
ID: user.Id(),
OrganizationID: params.OrganizationID,
ActiveOnly: true,
UsersOnly: true,
})
if err != nil {
return nil, fmt.Errorf("error fetch actor prticipant. %w", err)
}
if !participant.IsAdmin() {
return nil, fmt.Errorf("error not enouth rights. %w", organizations.ErrorUnauthorizedAccess)
}
if err := i.txRepo.ConfirmTransaction(ctx, transactions.ConfirmTransactionParams{
TxId: params.TxID,
OrganizationId: params.OrganizationID,
UserId: participant.Id(),
}); err != nil {
return nil, fmt.Errorf("error confirm transaction. %w", err)
}
2024-05-27 21:29:05 +00:00
// TODO confirm tx via chain-api
2024-05-24 17:44:24 +00:00
tx, err := i.txRepo.GetTransactions(ctx, transactions.GetTransactionsParams{
Ids: uuid.UUIDs{params.TxID},
OrganizationId: params.OrganizationID,
Limit: 1,
})
if err != nil {
return nil, fmt.Errorf("error fetch transaction. %w", err)
}
if len(tx) == 0 {
return nil, fmt.Errorf("error tx not found")
}
return tx[0], nil
}
2024-05-27 21:29:05 +00:00
// TODO Execute()
2024-05-24 17:44:24 +00:00
func (i *transactionsInteractor) Cancel(ctx context.Context, params CancelParams) (*models.Transaction, error) {
user, err := ctxmeta.User(ctx)
if err != nil {
return nil, fmt.Errorf("error fetch user from context. %w", err)
}
participant, err := i.orgInteractor.Participant(ctx, organizations.ParticipantParams{
ID: user.Id(),
OrganizationID: params.OrganizationID,
ActiveOnly: true,
UsersOnly: true,
})
if err != nil {
return nil, fmt.Errorf("error fetch actor prticipant. %w", err)
}
if !participant.IsAdmin() {
return nil, fmt.Errorf("error not enouth rights. %w", organizations.ErrorUnauthorizedAccess)
}
if err := i.txRepo.CancelTransaction(ctx, transactions.CancelTransactionParams{
TxId: params.TxID,
OrganizationId: params.OrganizationID,
UserId: participant.Id(),
}); err != nil {
return nil, fmt.Errorf("error confirm transaction. %w", err)
}
tx, err := i.txRepo.GetTransactions(ctx, transactions.GetTransactionsParams{
Ids: uuid.UUIDs{params.TxID},
OrganizationId: params.OrganizationID,
Limit: 1,
})
if err != nil {
return nil, fmt.Errorf("error fetch transaction. %w", err)
}
if len(tx) == 0 {
return nil, fmt.Errorf("error tx not found")
}
return tx[0], nil
}