105 lines
3.5 KiB
JavaScript
105 lines
3.5 KiB
JavaScript
import { Decimal } from './Decimal.js';
|
|
/**
|
|
* Coerces outbound V2 request data by converting bigint (or number)
|
|
* int64_string fields to strings, matching the wire format expected by the API.
|
|
*
|
|
* Walks the schema tree and only touches fields that are marked as
|
|
* int64_string. All other values are left unchanged.
|
|
*/
|
|
export const coerceV2RequestData = (data, schema) => {
|
|
if (data == null) {
|
|
return data;
|
|
}
|
|
switch (schema.kind) {
|
|
case 'int64_string':
|
|
return typeof data === 'bigint' || typeof data === 'number'
|
|
? String(data)
|
|
: data;
|
|
case 'decimal_string':
|
|
// Duck-type check: Decimal instances have toFixed() and isZero() methods.
|
|
return typeof data.toFixed === 'function' &&
|
|
typeof data.isZero === 'function'
|
|
? data.toString()
|
|
: data;
|
|
case 'object': {
|
|
if (typeof data !== 'object' || Array.isArray(data)) {
|
|
return data;
|
|
}
|
|
const obj = data;
|
|
const result = {};
|
|
for (const key of Object.keys(obj)) {
|
|
const fieldSchema = schema.fields[key];
|
|
result[key] = fieldSchema
|
|
? coerceV2RequestData(obj[key], fieldSchema)
|
|
: obj[key];
|
|
}
|
|
return result;
|
|
}
|
|
case 'array': {
|
|
if (!Array.isArray(data)) {
|
|
return data;
|
|
}
|
|
return data.map((element) => coerceV2RequestData(element, schema.element));
|
|
}
|
|
case 'nullable':
|
|
return coerceV2RequestData(data, schema.inner);
|
|
}
|
|
};
|
|
/**
|
|
* Coerces inbound V2 response data by converting string int64_string fields
|
|
* to bigints, matching the SDK's public type contract.
|
|
*
|
|
* Walks the schema tree and only touches fields that are marked as
|
|
* int64_string. All other values are left unchanged.
|
|
*/
|
|
export const coerceV2ResponseData = (data, schema) => {
|
|
if (data == null) {
|
|
return data;
|
|
}
|
|
switch (schema.kind) {
|
|
case 'int64_string':
|
|
if (typeof data === 'string') {
|
|
try {
|
|
return BigInt(data);
|
|
}
|
|
catch {
|
|
throw new Error(`Failed to coerce int64_string value: expected an integer string, got '${data}'`);
|
|
}
|
|
}
|
|
return data;
|
|
case 'decimal_string':
|
|
if (typeof data === 'string') {
|
|
try {
|
|
return Decimal.from(data);
|
|
}
|
|
catch {
|
|
throw new Error(`Failed to coerce decimal_string value: expected a decimal string, got '${data}'`);
|
|
}
|
|
}
|
|
return data;
|
|
case 'object': {
|
|
if (typeof data !== 'object' || Array.isArray(data)) {
|
|
return data;
|
|
}
|
|
const obj = data;
|
|
for (const key of Object.keys(schema.fields)) {
|
|
if (key in obj) {
|
|
obj[key] = coerceV2ResponseData(obj[key], schema.fields[key]);
|
|
}
|
|
}
|
|
return obj;
|
|
}
|
|
case 'array': {
|
|
if (!Array.isArray(data)) {
|
|
return data;
|
|
}
|
|
for (let i = 0; i < data.length; i++) {
|
|
data[i] = coerceV2ResponseData(data[i], schema.element);
|
|
}
|
|
return data;
|
|
}
|
|
case 'nullable':
|
|
return coerceV2ResponseData(data, schema.inner);
|
|
}
|
|
};
|
|
//# sourceMappingURL=V2Coercion.js.map
|