webhook

type IWebHook interface {
	Run(ctx context.Context)
	Send(message *Message, dbTx pgx.Tx) error
	ProcessPlainMessage(ctx context.Context, dto PreparedHookDto) error
	SendWebhook(ctx context.Context, url string, payload []byte, sign string) (Result, error)
	GetHistory(ctx context.Context, user models.User, storeUUIDs []uuid.UUID, page, pageSize *uint32) (*storecmn.FindResponseWithPagingFlag[*repo_webhook_send_histories.FindRow], error)
}

type Message struct {
	TxID      uuid.UUID `json:"tx_id"`
	WebhookID uuid.UUID `json:"webhook_id"`
	Type      string    `json:"type"`
	Data      []byte    `json:"data"`
	Delay     int16     `json:"delay"`
	Signature string    `json:"signature"`
}

type PreparedHookDto struct {
	ID            uuid.NullUUID
	TransactionID uuid.UUID
	StoreID       uuid.UUID
	IsManual      bool
	Event         string
	Payload       []byte
	Signature     string
	URL           string
	RetriesCount  int64
}

type Result struct {
	Status             string
	Response           string
	Request            string
	ResponseStatusCode int
}

type StoreWhResponse struct {
	Success bool `json:"success"`
}