crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

asset-swapper: Extract method inferQueryParams

Browse Source 
For use in upcoming implementation of indicative quotes.
This commit is contained in:
F. Eugene Aumson
2020-04-14 22:08:23 -04:00
parent 80c8712b2a
commit 33fdfdc8c0
1 changed files with 24 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
packages/asset-swapper/src/utils/quote_requestor.ts
View File

@@ -38,6 +38,29 @@ function assertTakerAddressOrThrow(takerAddress: string | undefined): void {
}
}
function inferQueryParams(
marketOperation: MarketOperation,
makerAssetData: string,
takerAssetData: string,
assetFillAmount: BigNumber,
): { buyToken: string; sellToken: string; buyAmount: string | undefined; sellAmount: string | undefined } {
if (marketOperation === MarketOperation.Buy) {
return {
buyToken: getTokenAddressOrThrow(makerAssetData),
sellToken: getTokenAddressOrThrow(takerAssetData),
buyAmount: assetFillAmount.toString(),
sellAmount: undefined,
};
} else {
return {
buyToken: getTokenAddressOrThrow(makerAssetData),
sellToken: getTokenAddressOrThrow(takerAssetData),
sellAmount: assetFillAmount.toString(),
buyAmount: undefined,
};
}
}
export class QuoteRequestor {
private readonly _rfqtMakerEndpoints: string[];
private readonly _schemaValidator: SchemaValidator = new SchemaValidator();
@@ -56,9 +79,6 @@ export class QuoteRequestor {
const _opts = _.merge({}, constants.DEFAULT_RFQT_REQUEST_OPTS, options);
assertTakerAddressOrThrow(_opts.takerAddress);
const buyToken = getTokenAddressOrThrow(makerAssetData);
const sellToken = getTokenAddressOrThrow(takerAssetData);
// create an array of promises for quote responses, using "undefined"
// as a placeholder for failed requests.
const responsesIfDefined: Array<undefined | AxiosResponse<SignedOrder>> = await Promise.all(
@@ -67,12 +87,8 @@ export class QuoteRequestor {
return await Axios.get<SignedOrder>(`${rfqtMakerEndpoint}/quote`, {
headers: { '0x-api-key': _opts.apiKey },
params: {
sellToken,
buyToken,
buyAmount: marketOperation === MarketOperation.Buy ? assetFillAmount.toString() : undefined,
sellAmount:
marketOperation === MarketOperation.Sell ? assetFillAmount.toString() : undefined,
takerAddress: _opts.takerAddress,
...inferQueryParams(marketOperation, makerAssetData, takerAssetData, assetFillAmount),
},
timeout: _opts.makerEndpointMaxResponseTimeMs,
});