mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
Paul NicolasandGitHub
d66040c0eb
* feat(models): add bank bridge models * feat(storage): add bank bridge migrations and functions * feat(engine): add bank bridge workflows * feat(connectors): add plaid bank bridge connector * feat(events): add bank bridge events * feat(api): add bank bridge router * feat(*): bank bridge boilerplate * fix nil pointer crash * add more check when getting link attempts + change enum * fix tests * remove print * fixes after reviews * add specific table for access tokens * fixes after reviews * fix go mod tidy * remove indexes + null default * plaid: add tests * *: add more tests * fix after rebase
87 lines
2.5 KiB
Go
87 lines
2.5 KiB
Go
package client
|
|
|
|
import (
|
|
"encoding/json"
|
|
|
|
"github.com/plaid/plaid-go/v34/plaid"
|
|
)
|
|
|
|
type BaseWebhooks struct {
|
|
WebhookType plaid.WebhookType `json:"webhook_type"`
|
|
WebhookCode string `json:"webhook_code"`
|
|
ItemID string `json:"item_id"`
|
|
Environment string `json:"environment"`
|
|
}
|
|
|
|
func (c *client) BaseWebhookTranslation(body []byte) (BaseWebhooks, error) {
|
|
var webhook BaseWebhooks
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return BaseWebhooks{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
func (c *client) TranslateItemAddResultWebhook(body []byte) (plaid.ItemAddResultWebhook, error) {
|
|
var webhook plaid.ItemAddResultWebhook
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return plaid.ItemAddResultWebhook{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
func (c *client) TranslateSessionFinishedWebhook(body []byte) (plaid.LinkSessionFinishedWebhook, error) {
|
|
var webhook plaid.LinkSessionFinishedWebhook
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return plaid.LinkSessionFinishedWebhook{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
func (c *client) TranslateUserPendingDisconnectWebhook(body []byte) (plaid.PendingDisconnectWebhook, error) {
|
|
var webhook plaid.PendingDisconnectWebhook
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return plaid.PendingDisconnectWebhook{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
func (c *client) TranslateUserPendingExpirationWebhook(body []byte) (plaid.PendingExpirationWebhook, error) {
|
|
var webhook plaid.PendingExpirationWebhook
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return plaid.PendingExpirationWebhook{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
func (c *client) TranslateItemErrorWebhook(body []byte) (plaid.ItemErrorWebhook, error) {
|
|
var webhook plaid.ItemErrorWebhook
|
|
if err := json.Unmarshal(body, &webhook); err != nil {
|
|
return plaid.ItemErrorWebhook{}, err
|
|
}
|
|
return webhook, nil
|
|
}
|
|
|
|
type ErrorWebhook struct {
|
|
ErrorType string `json:"error_type"`
|
|
ErrorCodeReason string `json:"error_code_reason"`
|
|
ErrorMessage string `json:"error_message"`
|
|
DisplayMessage string `json:"display_message"`
|
|
}
|
|
|
|
type SyncUpdatesAvailableWebhook struct {
|
|
BaseWebhooks
|
|
InitialUpdateComplete bool `json:"initial_update_complete"`
|
|
HistoricalUpdateComplete bool `json:"historical_update_complete"`
|
|
}
|
|
|
|
type HistoricalUpdateWebhook struct {
|
|
BaseWebhooks
|
|
NewTransactionsCount int `json:"new_transactions"`
|
|
ErrorWebhook ErrorWebhook `json:"error"`
|
|
}
|
|
|
|
type UserPermissionRevokedWebhook struct {
|
|
BaseWebhooks
|
|
ErrorWebhook ErrorWebhook `json:"error"`
|
|
}
|