37 lines
1.3 KiB
Go
37 lines
1.3 KiB
Go
package storage
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/tech/sendico/gateway/tgsettle/storage/model"
|
|
"github.com/tech/sendico/pkg/merrors"
|
|
)
|
|
|
|
var ErrDuplicate = merrors.DataConflict("payment gateway storage: duplicate record")
|
|
|
|
type Repository interface {
|
|
Payments() PaymentsStore
|
|
TelegramConfirmations() TelegramConfirmationsStore
|
|
PendingConfirmations() PendingConfirmationsStore
|
|
}
|
|
|
|
type PaymentsStore interface {
|
|
FindByIdempotencyKey(ctx context.Context, key string) (*model.PaymentRecord, error)
|
|
Upsert(ctx context.Context, record *model.PaymentRecord) error
|
|
}
|
|
|
|
type TelegramConfirmationsStore interface {
|
|
Upsert(ctx context.Context, record *model.TelegramConfirmation) error
|
|
}
|
|
|
|
type PendingConfirmationsStore interface {
|
|
Upsert(ctx context.Context, record *model.PendingConfirmation) error
|
|
FindByRequestID(ctx context.Context, requestID string) (*model.PendingConfirmation, error)
|
|
FindByMessageID(ctx context.Context, messageID string) (*model.PendingConfirmation, error)
|
|
MarkClarified(ctx context.Context, requestID string) error
|
|
AttachMessage(ctx context.Context, requestID string, messageID string) error
|
|
DeleteByRequestID(ctx context.Context, requestID string) error
|
|
ListExpired(ctx context.Context, now time.Time, limit int64) ([]*model.PendingConfirmation, error)
|
|
}
|