bitflyersettlement

Documentation

Index

• func CategorizeResponse(limitedSettlements map[string]settlement.Transaction, ...) (settlement.Transaction, string)
• func CategorizeResponses(limitedSettlements map[string]settlement.Transaction, ...) map[string][]settlement.Transaction
• func CheckPayoutTransactionsStatus(ctx context.Context, limitedTransactions map[string]settlement.Transaction, ...) (map[string][]settlement.Transaction, error)
• func GroupSettlements(settlements *[]settlement.Transaction) map[string][]settlement.Transaction
• func IterateRequest(ctx context.Context, action string, bitflyerClient bitflyer.Client, ...) (map[string][]settlement.Transaction, error)
• func SubmitBulkPayoutTransactions(ctx context.Context, limitedSettlements map[string]settlement.Transaction, ...) (map[string][]settlement.Transaction, error)

Functions

func CategorizeResponse

func CategorizeResponse(
	limitedSettlements map[string]settlement.Transaction,
	groupedByPublisher map[string][]settlement.Transaction,
	payout *bitflyer.WithdrawToDepositIDResponse,
) (settlement.Transaction, string)

CategorizeResponse categorizes a response from bitflyer as pending, complete, failed, or unknown

func CategorizeResponses

func CategorizeResponses(
	limitedSettlements map[string]settlement.Transaction,
	groupedByPublisher map[string][]settlement.Transaction,
	response *[]bitflyer.WithdrawToDepositIDResponse,
) map[string][]settlement.Transaction

CategorizeResponses categorizes the series of responses

func CheckPayoutTransactionsStatus

func CheckPayoutTransactionsStatus(
	ctx context.Context,
	limitedTransactions map[string]settlement.Transaction,
	groupedByPublisher map[string][]settlement.Transaction,
	submittedTransactions map[string][]settlement.Transaction,
	bulkPayoutRequestRequirements bitflyer.WithdrawToDepositIDBulkPayload,
	bitflyerClient bitflyer.Client,
	total int,
	blockProgress int,
) (map[string][]settlement.Transaction, error)

CheckPayoutTransactionsStatus checks the status of given transactions

func GroupSettlements

func GroupSettlements(
	settlements *[]settlement.Transaction,
) map[string][]settlement.Transaction

GroupSettlements groups settlements under a single provider id so that we can impose limits based on price no signing here, just grouping settlements under a single deposit id

func IterateRequest

func IterateRequest(
	ctx context.Context,
	action string,
	bitflyerClient bitflyer.Client,
	bulkPayoutFiles []string,
	sourceFrom string,
	excludeLimited bool,
	dryRun *bitflyer.DryRunOption,
) (map[string][]settlement.Transaction, error)

IterateRequest iterates requests

func SubmitBulkPayoutTransactions

func SubmitBulkPayoutTransactions(
	ctx context.Context,
	limitedSettlements map[string]settlement.Transaction,
	groupedByPublisher map[string][]settlement.Transaction,
	submittedTransactions map[string][]settlement.Transaction,
	bulkPayoutRequestRequirements bitflyer.WithdrawToDepositIDBulkPayload,
	bitflyerClient bitflyer.Client,
	total int,
	blockProgress int,
) (map[string][]settlement.Transaction, error)

SubmitBulkPayoutTransactions submits bulk payout transactions