bitflyersettlement

Documentation

Index

• func CategorizeResponse(batchByTransferID map[string]settlement.AggregateTransaction, ...) ([]custodian.Transaction, string)
• func CategorizeResponses(batch []settlement.AggregateTransaction, ...) map[string][]custodian.Transaction
• func CheckPayoutTransactionsStatus(ctx context.Context, batch []settlement.AggregateTransaction, ...) (map[string][]custodian.Transaction, error)
• func GroupSettlements(settlements *[]custodian.Transaction) map[string][]custodian.Transaction
• func IterateRequest(ctx context.Context, action string, bitflyerClient bitflyer.Client, ...) (map[string][]custodian.Transaction, error)
• func SubmitBulkPayoutTransactions(ctx context.Context, batch []settlement.AggregateTransaction, ...) (map[string][]custodian.Transaction, error)
• type PreparedTransactions
  • func PrepareRequests(ctx context.Context, bitflyerClient bitflyer.Client, ...) (*PreparedTransactions, error)

Functions

func CategorizeResponse

func CategorizeResponse(
	batchByTransferID map[string]settlement.AggregateTransaction,
	payout *bitflyer.WithdrawToDepositIDResponse,
) ([]custodian.Transaction, string)

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

func CategorizeResponses

func CategorizeResponses(
	batch []settlement.AggregateTransaction,
	response *[]bitflyer.WithdrawToDepositIDResponse,
) map[string][]custodian.Transaction

CategorizeResponses categorizes the series of responses

func CheckPayoutTransactionsStatus

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

CheckPayoutTransactionsStatus checks the status of given transactions

func GroupSettlements

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

GroupSettlements groups settlements under a single wallet 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,
	prepared PreparedTransactions,
	dryRun *bitflyer.DryRunOption,
) (map[string][]custodian.Transaction, error)

IterateRequest iterates requests

func SubmitBulkPayoutTransactions

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

SubmitBulkPayoutTransactions submits bulk payout transactions

Types

type PreparedTransactions

type PreparedTransactions struct {
	// goes to bitflyer
	AggregateTransactionBatches [][]settlement.AggregateTransaction `json:"aggregateTransactionBatches"`
	// a list of settlements that are not being sent
	NotSubmittedTransactions []custodian.Transaction `json:"notSubmittedTransactions"`
}

PreparedTransactions are the transactions which have been prepared into batches after applying limits, etc

func PrepareRequests

func PrepareRequests(
	ctx context.Context,
	bitflyerClient bitflyer.Client,
	txs []custodian.Transaction,
	excludeLimited bool,
	sourceFrom string,
) (*PreparedTransactions, error)

PrepareRequests prepares requests