sync

Documentation

Index

• Constants
• func ArchiveEmailsFromSuccessfulTransactions(mailClient imap.MailClient, archiveMailbox string, ...)
• func CreateEntries(toshlClient toshl.ApiClient, transactions []*types.TransactionInfo, ...) ([]*types.TransactionInfo, []*types.TransactionInfo)
• func CreateInternalCategoryIfAbsent(toshlClient toshl.ApiClient, TxType types.TransactionType) string
• func ExtractTransactionInfoFromMessages(msgs []types.BankMessage) ([]*types.TransactionInfo, int64)
• func GetEmailFromInbox(mailClient imap.MailClient, banks []synctypes.BankDelegate) ([]synctypes.BankMessage, error)
• func GetLastProcessedDate() time.Time
• func GetMappableAccounts(accounts []*toshl.Account) map[string]*toshl.Account
• func Run(ctx context.Context, auth types.Auth) error
• func SendNotifications(auth types.Auth, msg string)
• func SetTimezoneLocale(location string)
• func UpdateLastProcessedDate(failedTxs []*synctypes.TransactionInfo) error

Constants

const OverrideLasProcessedDateEnvName = "OVERRIDE_LAST_PROC_DATE"

Functions

func ArchiveEmailsFromSuccessfulTransactions

func ArchiveEmailsFromSuccessfulTransactions(mailClient imap.MailClient, archiveMailbox string, successfulTransactions []*synctypes.TransactionInfo)

func CreateEntries

func CreateEntries(toshlClient toshl.ApiClient, transactions []*types.TransactionInfo, mappableAccounts map[string]*toshl.Account, internalCategoryIds map[types.TransactionType]string) ([]*types.TransactionInfo, []*types.TransactionInfo)

func CreateInternalCategoryIfAbsent

func CreateInternalCategoryIfAbsent(toshlClient toshl.ApiClient, TxType types.TransactionType) string

func ExtractTransactionInfoFromMessages

func ExtractTransactionInfoFromMessages(msgs []types.BankMessage) ([]*types.TransactionInfo, int64)

func GetEmailFromInbox

func GetEmailFromInbox(mailClient imap.MailClient, banks []synctypes.BankDelegate) ([]synctypes.BankMessage, error)

func GetLastProcessedDate

func GetLastProcessedDate() time.Time

func GetMappableAccounts

func GetMappableAccounts(accounts []*toshl.Account) map[string]*toshl.Account

func Run

func Run(ctx context.Context, auth types.Auth) error

func SendNotifications

func SendNotifications(auth types.Auth, msg string)

func SetTimezoneLocale

func SetTimezoneLocale(location string)

TODO: obtain this from DynamoDB and set a default value

func UpdateLastProcessedDate

func UpdateLastProcessedDate(failedTxs []*synctypes.TransactionInfo) error