@reservoir0x/reservoir-sdk
Advanced tools
Comparing version 0.6.5 to 0.7.0
@@ -104,11 +104,44 @@ var $lPQI4$etherslibutils = require("ethers/lib/utils"); | ||
var $134f7602d1733f79$exports = {}; | ||
$134f7602d1733f79$exports = JSON.parse('{"name":"@reservoir0x/reservoir-sdk","version":"0.6.5","description":"An SDK that can be used in any javascript/typescript context to easily interact with Reservoir liquidity APIs","source":"src/index.ts","main":"dist/index.js","module":"dist/index.module.js","types":"dist/index.d.ts","author":"Reservoir Protocol","license":"MIT","files":["dist"],"scripts":{"clean":"rm -rf dist","version":"yarn version","version:package":"sh ../../scripts/package-version.sh","version:update":"yarn version ${0}; PACKAGE_VERSION=$(yarn version:package); git add -A; git commit -m \\"\uD83C\uDF89 Release client package v$PACKAGE_VERSION\\"; git tag v${PACKAGE_VERSION}-SDK; git push --tags;","syncApi":"node ./sync-api.mjs","changelog":"node ../../scripts/generate-changelog.js package=sdk"},"repository":{"type":"git","url":"https://github.com/reservoirprotocol/reservoir-kit"},"sideEffects":false,"keywords":["nft","reservoir","reservoir-sdk","reservoirkit","protocol","sdk"],"peerDependencies":{"ethers":"^5.6.1"},"dependencies":{"axios":"^0.27.2"},"publishConfig":{"access":"public"},"devDependencies":{"openapi-typescript":"^5.4.1"}}'); | ||
$134f7602d1733f79$exports = JSON.parse('{"name":"@reservoir0x/reservoir-sdk","version":"0.7.0","description":"An SDK that can be used in any javascript/typescript context to easily interact with Reservoir liquidity APIs","source":"src/index.ts","main":"dist/index.js","module":"dist/index.module.js","types":"dist/index.d.ts","author":"Reservoir Protocol","license":"MIT","files":["dist"],"scripts":{"clean":"rm -rf dist","version":"yarn version","version:package":"sh ../../scripts/package-version.sh","version:update":"yarn version ${0}; PACKAGE_VERSION=$(yarn version:package); git add -A; git commit -m \\"\uD83C\uDF89 Release client package v$PACKAGE_VERSION\\"; git tag v${PACKAGE_VERSION}-SDK; git push --tags;","syncApi":"node ./sync-api.mjs","changelog":"node ../../scripts/generate-changelog.js package=sdk"},"repository":{"type":"git","url":"https://github.com/reservoirprotocol/reservoir-kit"},"sideEffects":false,"keywords":["nft","reservoir","reservoir-sdk","reservoirkit","protocol","sdk"],"peerDependencies":{"ethers":"^5.6.1"},"dependencies":{"axios":"^0.27.2"},"publishConfig":{"access":"public"},"devDependencies":{"openapi-typescript":"^5.4.1"}}'); | ||
var $b747246cb5dd2c78$export$243e62d78d3b544d; | ||
(function(LogLevel) { | ||
LogLevel[LogLevel["Verbose"] = 4] = "Verbose"; | ||
LogLevel[LogLevel["Info"] = 3] = "Info"; | ||
LogLevel[LogLevel["Warn"] = 2] = "Warn"; | ||
LogLevel[LogLevel["Error"] = 1] = "Error"; | ||
LogLevel[LogLevel["None"] = 0] = "None"; | ||
})($b747246cb5dd2c78$export$243e62d78d3b544d || ($b747246cb5dd2c78$export$243e62d78d3b544d = {})); | ||
const $b747246cb5dd2c78$export$bef1f36f5486a6a3 = (params, level, currentLevel)=>{ | ||
if (currentLevel >= level) { | ||
const data = params.reduce((params, param, i)=>{ | ||
if ((i + 1) % 2) params.push("\n"); | ||
params.push(param); | ||
return params; | ||
}, []); | ||
switch(level){ | ||
case $b747246cb5dd2c78$export$243e62d78d3b544d.Info: | ||
console.info(...data); | ||
break; | ||
case $b747246cb5dd2c78$export$243e62d78d3b544d.Error: | ||
console.error(...data); | ||
break; | ||
case $b747246cb5dd2c78$export$243e62d78d3b544d.Warn: | ||
console.warn(...data); | ||
break; | ||
default: | ||
console.log(...data); | ||
break; | ||
} | ||
} | ||
}; | ||
async function $350ec40f38382016$export$21ece85d7636deb(request, signer, setState, newJson, expectedPrice) { | ||
var _a, _b, _c; | ||
const client = (0, $3ba04d43fdd1e5a5$export$6bb76d6eba7e258c)(); | ||
try { | ||
let json = newJson; | ||
if (!request.headers) request.headers = {}; | ||
const client = (0, $3ba04d43fdd1e5a5$export$6bb76d6eba7e258c)(); | ||
const currentReservoirChain = client === null || client === void 0 ? void 0 : client.currentChain(); | ||
@@ -120,5 +153,13 @@ if (currentReservoirChain === null || currentReservoirChain === void 0 ? void 0 : currentReservoirChain.baseApiUrl) request.baseURL = currentReservoirChain.baseApiUrl; | ||
if (!json) { | ||
client.log([ | ||
"Execute Steps: Fetching Steps", | ||
request | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
const res = await (0, ($parcel$interopDefault($lPQI4$axios))).request(request); | ||
json = res.data; | ||
if (res.status !== 200) throw json; | ||
client.log([ | ||
"Execute Steps: Steps retrieved", | ||
json | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
} | ||
@@ -137,2 +178,9 @@ // Handle errors | ||
}, 0); | ||
client.log([ | ||
"Execute Steps: checking expected price", | ||
"expected price", | ||
expectedPrice, | ||
"quote", | ||
quote | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
// Check if the user is selling | ||
@@ -173,6 +221,16 @@ let error = null; | ||
// There are no more incomplete steps | ||
if (incompleteStepIndex === -1) return; | ||
if (incompleteStepIndex === -1) { | ||
client.log([ | ||
"Execute Steps: all steps complete" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
return; | ||
} | ||
const step = json.steps[incompleteStepIndex]; | ||
const stepItems = json.steps[incompleteStepIndex].items; | ||
if (!stepItems) return; | ||
if (!stepItems) { | ||
client.log([ | ||
"Execute Steps: skipping step, no items in step" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
return; | ||
} | ||
let { kind: kind } = step; | ||
@@ -182,4 +240,11 @@ let stepItem = stepItems[incompleteStepItemIndex]; | ||
if (!stepItem.data) { | ||
client.log([ | ||
"Execute Steps: step item data is missing, begin polling" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
json = await (0, $8f16fb6674bc87a2$export$f014594cc879f602)(request, (json)=>{ | ||
var _a, _b; | ||
client.log([ | ||
"Execute Steps: step item data is missing, polling", | ||
json | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
const data = json; | ||
@@ -202,2 +267,5 @@ return ((_b = (_a = data === null || data === void 0 ? void 0 : data.steps) === null || _a === void 0 ? void 0 : _a[incompleteStepIndex].items) === null || _b === void 0 ? void 0 : _b[incompleteStepItemIndex].data) ? true : false; | ||
{ | ||
client.log([ | ||
"Execute Steps: Begin transaction step, sending transaction" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
const tx = await signer.sendTransaction(stepData); | ||
@@ -208,3 +276,9 @@ if ((_c = json.steps[incompleteStepIndex].items) === null || _c === void 0 ? void 0 : _c[incompleteStepItemIndex]) stepItem.txHash = tx.hash; | ||
]); | ||
client.log([ | ||
"Execute Steps: Transaction step, waiting on transaction" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
await tx.wait(); | ||
client.log([ | ||
"Execute Steps: Transaction finished, starting to poll for confirmation" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
//Implicitly poll the confirmation url to confirm the transaction went through | ||
@@ -221,6 +295,15 @@ const confirmationUrl = new URL(`${request.baseURL}/transactions/${tx.hash}/synced/v1`); | ||
headers: headers | ||
}, (res)=>res && res.data.synced); | ||
}, (res)=>{ | ||
client.log([ | ||
"Execute Steps: Polling for confirmation", | ||
res | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
return res && res.data.synced; | ||
}); | ||
if (json.steps.slice(incompleteStepIndex + 1).findIndex((step)=>step.kind === "transaction") === -1) //Confirm that on-chain tx has been picked up by the indexer for the last transaction | ||
{ | ||
if (stepItem.txHash && (isSell || isBuy)) { | ||
client.log([ | ||
"Execute Steps: Polling sales to verify transaction was indexed" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
const indexerConfirmationUrl = new URL(`${request.baseURL}/sales/v3`); | ||
@@ -236,2 +319,6 @@ const queryParams = { | ||
}, (res)=>{ | ||
client.log([ | ||
"Execute Steps: Polling sales to check if indexed", | ||
res | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
if (res.status === 200) { | ||
@@ -253,9 +340,20 @@ const data = res.data; | ||
const postData = stepData["post"]; | ||
client.log([ | ||
"Execute Steps: Begin signature step" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
if (signData) { | ||
// Request user signature | ||
if (signData.signatureKind === "eip191") { | ||
client.log([ | ||
"Execute Steps: Signing with eip191" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
if (signData.message.match(/0x[0-9a-fA-F]{64}/)) // If the message represents a hash, we need to convert it to raw bytes first | ||
signature = await signer.signMessage((0, $lPQI4$etherslibutils.arrayify)(signData.message)); | ||
else signature = await signer.signMessage(signData.message); | ||
} else if (signData.signatureKind === "eip712") signature = await signer._signTypedData(signData.domain, signData.types, signData.value); | ||
} else if (signData.signatureKind === "eip712") { | ||
client.log([ | ||
"Execute Steps: Signing with eip712" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
signature = await signer._signTypedData(signData.domain, signData.types, signData.value); | ||
} | ||
if (signature) request.params = { | ||
@@ -267,2 +365,5 @@ ...request.params, | ||
if (postData) { | ||
client.log([ | ||
"Execute Steps: Posting order" | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Verbose); | ||
const postOrderUrl = new URL(`${request.baseURL}${postData.endpoint}`); | ||
@@ -285,3 +386,10 @@ try { | ||
if (res.status > 299 || res.status < 200) throw res.data; | ||
stepItem.orderId = res.data.orderId; | ||
if (res.data.results) stepItem.orderData = res.data.results; | ||
else if (res.data && res.data.orderId) stepItem.orderData = [ | ||
{ | ||
orderId: res.data.orderId, | ||
crossPostingOrderId: res.data.crossPostingOrderId, | ||
orderIndex: res.data.orderIndex || 0 | ||
} | ||
]; | ||
setState([ | ||
@@ -308,4 +416,6 @@ ...json === null || json === void 0 ? void 0 : json.steps | ||
} catch (err) { | ||
const error = new Error(err === null || err === void 0 ? void 0 : err.message); | ||
console.error(error); | ||
client.log([ | ||
"Execute Steps: An error occurred", | ||
err | ||
], (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Error); | ||
throw err; | ||
@@ -416,3 +526,3 @@ } | ||
var _a; | ||
const { id: id , signer: signer , onProgress: onProgress } = data; | ||
const { ids: ids , signer: signer , onProgress: onProgress } = data; | ||
const client = (0, $3ba04d43fdd1e5a5$export$6bb76d6eba7e258c)(); | ||
@@ -422,10 +532,13 @@ const options = data.options || {}; | ||
if (!baseApiUrl) throw new ReferenceError("ReservoirClient missing chain configuration"); | ||
if (ids.length === 0) throw { | ||
message: "No order ids specified" | ||
}; | ||
try { | ||
const params = { | ||
id: id, | ||
...options | ||
}; | ||
await (0, $350ec40f38382016$export$21ece85d7636deb)({ | ||
url: `${baseApiUrl}/execute/cancel/v2`, | ||
params: params | ||
method: "post", | ||
url: `${baseApiUrl}/execute/cancel/v3`, | ||
data: { | ||
orderIds: ids, | ||
...options | ||
} | ||
}, signer, onProgress); | ||
@@ -544,2 +657,4 @@ return true; | ||
$parcel$export($86e1aed4c9e0543e$exports, "request", () => $b3114c59012a233a$export$b5fe3f66a567bec0); | ||
$parcel$export($86e1aed4c9e0543e$exports, "log", () => $b747246cb5dd2c78$export$bef1f36f5486a6a3); | ||
$parcel$export($86e1aed4c9e0543e$exports, "LogLevel", () => $b747246cb5dd2c78$export$243e62d78d3b544d); | ||
@@ -594,4 +709,9 @@ | ||
let $3ba04d43fdd1e5a5$var$_client; | ||
class $3ba04d43fdd1e5a5$export$d0c36b5db6a81704 { | ||
log(message, level = (0, $b747246cb5dd2c78$export$243e62d78d3b544d).Info) { | ||
return (0, $b747246cb5dd2c78$export$bef1f36f5486a6a3)(message, level, this.logLevel); | ||
} | ||
constructor(options){ | ||
@@ -610,2 +730,3 @@ this.utils = { | ||
this.source = options.source; | ||
this.logLevel = options.logLevel !== undefined ? options.logLevel : (0, $b747246cb5dd2c78$export$243e62d78d3b544d).None; | ||
} | ||
@@ -620,2 +741,3 @@ configure(options) { | ||
this.normalizeRoyalties = options.normalizeRoyalties !== undefined ? options.normalizeRoyalties : this.normalizeRoyalties; | ||
this.logLevel = options.logLevel !== undefined ? options.logLevel : (0, $b747246cb5dd2c78$export$243e62d78d3b544d).None; | ||
} | ||
@@ -622,0 +744,0 @@ currentChain() { |
@@ -101,11 +101,44 @@ import {arrayify as $9C8uf$arrayify} from "ethers/lib/utils"; | ||
var $d3dd819ecb91ce83$exports = {}; | ||
$d3dd819ecb91ce83$exports = JSON.parse('{"name":"@reservoir0x/reservoir-sdk","version":"0.6.5","description":"An SDK that can be used in any javascript/typescript context to easily interact with Reservoir liquidity APIs","source":"src/index.ts","main":"dist/index.js","module":"dist/index.module.js","types":"dist/index.d.ts","author":"Reservoir Protocol","license":"MIT","files":["dist"],"scripts":{"clean":"rm -rf dist","version":"yarn version","version:package":"sh ../../scripts/package-version.sh","version:update":"yarn version ${0}; PACKAGE_VERSION=$(yarn version:package); git add -A; git commit -m \\"\uD83C\uDF89 Release client package v$PACKAGE_VERSION\\"; git tag v${PACKAGE_VERSION}-SDK; git push --tags;","syncApi":"node ./sync-api.mjs","changelog":"node ../../scripts/generate-changelog.js package=sdk"},"repository":{"type":"git","url":"https://github.com/reservoirprotocol/reservoir-kit"},"sideEffects":false,"keywords":["nft","reservoir","reservoir-sdk","reservoirkit","protocol","sdk"],"peerDependencies":{"ethers":"^5.6.1"},"dependencies":{"axios":"^0.27.2"},"publishConfig":{"access":"public"},"devDependencies":{"openapi-typescript":"^5.4.1"}}'); | ||
$d3dd819ecb91ce83$exports = JSON.parse('{"name":"@reservoir0x/reservoir-sdk","version":"0.7.0","description":"An SDK that can be used in any javascript/typescript context to easily interact with Reservoir liquidity APIs","source":"src/index.ts","main":"dist/index.js","module":"dist/index.module.js","types":"dist/index.d.ts","author":"Reservoir Protocol","license":"MIT","files":["dist"],"scripts":{"clean":"rm -rf dist","version":"yarn version","version:package":"sh ../../scripts/package-version.sh","version:update":"yarn version ${0}; PACKAGE_VERSION=$(yarn version:package); git add -A; git commit -m \\"\uD83C\uDF89 Release client package v$PACKAGE_VERSION\\"; git tag v${PACKAGE_VERSION}-SDK; git push --tags;","syncApi":"node ./sync-api.mjs","changelog":"node ../../scripts/generate-changelog.js package=sdk"},"repository":{"type":"git","url":"https://github.com/reservoirprotocol/reservoir-kit"},"sideEffects":false,"keywords":["nft","reservoir","reservoir-sdk","reservoirkit","protocol","sdk"],"peerDependencies":{"ethers":"^5.6.1"},"dependencies":{"axios":"^0.27.2"},"publishConfig":{"access":"public"},"devDependencies":{"openapi-typescript":"^5.4.1"}}'); | ||
var $e1b436840b45b1d8$export$243e62d78d3b544d; | ||
(function(LogLevel) { | ||
LogLevel[LogLevel["Verbose"] = 4] = "Verbose"; | ||
LogLevel[LogLevel["Info"] = 3] = "Info"; | ||
LogLevel[LogLevel["Warn"] = 2] = "Warn"; | ||
LogLevel[LogLevel["Error"] = 1] = "Error"; | ||
LogLevel[LogLevel["None"] = 0] = "None"; | ||
})($e1b436840b45b1d8$export$243e62d78d3b544d || ($e1b436840b45b1d8$export$243e62d78d3b544d = {})); | ||
const $e1b436840b45b1d8$export$bef1f36f5486a6a3 = (params, level, currentLevel)=>{ | ||
if (currentLevel >= level) { | ||
const data = params.reduce((params, param, i)=>{ | ||
if ((i + 1) % 2) params.push("\n"); | ||
params.push(param); | ||
return params; | ||
}, []); | ||
switch(level){ | ||
case $e1b436840b45b1d8$export$243e62d78d3b544d.Info: | ||
console.info(...data); | ||
break; | ||
case $e1b436840b45b1d8$export$243e62d78d3b544d.Error: | ||
console.error(...data); | ||
break; | ||
case $e1b436840b45b1d8$export$243e62d78d3b544d.Warn: | ||
console.warn(...data); | ||
break; | ||
default: | ||
console.log(...data); | ||
break; | ||
} | ||
} | ||
}; | ||
async function $13b5a8bc45044506$export$21ece85d7636deb(request, signer, setState, newJson, expectedPrice) { | ||
var _a, _b, _c; | ||
const client = (0, $6496f8ee40d0c4eb$export$6bb76d6eba7e258c)(); | ||
try { | ||
let json = newJson; | ||
if (!request.headers) request.headers = {}; | ||
const client = (0, $6496f8ee40d0c4eb$export$6bb76d6eba7e258c)(); | ||
const currentReservoirChain = client === null || client === void 0 ? void 0 : client.currentChain(); | ||
@@ -117,5 +150,13 @@ if (currentReservoirChain === null || currentReservoirChain === void 0 ? void 0 : currentReservoirChain.baseApiUrl) request.baseURL = currentReservoirChain.baseApiUrl; | ||
if (!json) { | ||
client.log([ | ||
"Execute Steps: Fetching Steps", | ||
request | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
const res = await (0, $9C8uf$axios).request(request); | ||
json = res.data; | ||
if (res.status !== 200) throw json; | ||
client.log([ | ||
"Execute Steps: Steps retrieved", | ||
json | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
} | ||
@@ -134,2 +175,9 @@ // Handle errors | ||
}, 0); | ||
client.log([ | ||
"Execute Steps: checking expected price", | ||
"expected price", | ||
expectedPrice, | ||
"quote", | ||
quote | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
// Check if the user is selling | ||
@@ -170,6 +218,16 @@ let error = null; | ||
// There are no more incomplete steps | ||
if (incompleteStepIndex === -1) return; | ||
if (incompleteStepIndex === -1) { | ||
client.log([ | ||
"Execute Steps: all steps complete" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
return; | ||
} | ||
const step = json.steps[incompleteStepIndex]; | ||
const stepItems = json.steps[incompleteStepIndex].items; | ||
if (!stepItems) return; | ||
if (!stepItems) { | ||
client.log([ | ||
"Execute Steps: skipping step, no items in step" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
return; | ||
} | ||
let { kind: kind } = step; | ||
@@ -179,4 +237,11 @@ let stepItem = stepItems[incompleteStepItemIndex]; | ||
if (!stepItem.data) { | ||
client.log([ | ||
"Execute Steps: step item data is missing, begin polling" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
json = await (0, $8b98f6fc3beebe05$export$f014594cc879f602)(request, (json)=>{ | ||
var _a, _b; | ||
client.log([ | ||
"Execute Steps: step item data is missing, polling", | ||
json | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
const data = json; | ||
@@ -199,2 +264,5 @@ return ((_b = (_a = data === null || data === void 0 ? void 0 : data.steps) === null || _a === void 0 ? void 0 : _a[incompleteStepIndex].items) === null || _b === void 0 ? void 0 : _b[incompleteStepItemIndex].data) ? true : false; | ||
{ | ||
client.log([ | ||
"Execute Steps: Begin transaction step, sending transaction" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
const tx = await signer.sendTransaction(stepData); | ||
@@ -205,3 +273,9 @@ if ((_c = json.steps[incompleteStepIndex].items) === null || _c === void 0 ? void 0 : _c[incompleteStepItemIndex]) stepItem.txHash = tx.hash; | ||
]); | ||
client.log([ | ||
"Execute Steps: Transaction step, waiting on transaction" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
await tx.wait(); | ||
client.log([ | ||
"Execute Steps: Transaction finished, starting to poll for confirmation" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
//Implicitly poll the confirmation url to confirm the transaction went through | ||
@@ -218,6 +292,15 @@ const confirmationUrl = new URL(`${request.baseURL}/transactions/${tx.hash}/synced/v1`); | ||
headers: headers | ||
}, (res)=>res && res.data.synced); | ||
}, (res)=>{ | ||
client.log([ | ||
"Execute Steps: Polling for confirmation", | ||
res | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
return res && res.data.synced; | ||
}); | ||
if (json.steps.slice(incompleteStepIndex + 1).findIndex((step)=>step.kind === "transaction") === -1) //Confirm that on-chain tx has been picked up by the indexer for the last transaction | ||
{ | ||
if (stepItem.txHash && (isSell || isBuy)) { | ||
client.log([ | ||
"Execute Steps: Polling sales to verify transaction was indexed" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
const indexerConfirmationUrl = new URL(`${request.baseURL}/sales/v3`); | ||
@@ -233,2 +316,6 @@ const queryParams = { | ||
}, (res)=>{ | ||
client.log([ | ||
"Execute Steps: Polling sales to check if indexed", | ||
res | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
if (res.status === 200) { | ||
@@ -250,9 +337,20 @@ const data = res.data; | ||
const postData = stepData["post"]; | ||
client.log([ | ||
"Execute Steps: Begin signature step" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
if (signData) { | ||
// Request user signature | ||
if (signData.signatureKind === "eip191") { | ||
client.log([ | ||
"Execute Steps: Signing with eip191" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
if (signData.message.match(/0x[0-9a-fA-F]{64}/)) // If the message represents a hash, we need to convert it to raw bytes first | ||
signature = await signer.signMessage((0, $9C8uf$arrayify)(signData.message)); | ||
else signature = await signer.signMessage(signData.message); | ||
} else if (signData.signatureKind === "eip712") signature = await signer._signTypedData(signData.domain, signData.types, signData.value); | ||
} else if (signData.signatureKind === "eip712") { | ||
client.log([ | ||
"Execute Steps: Signing with eip712" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
signature = await signer._signTypedData(signData.domain, signData.types, signData.value); | ||
} | ||
if (signature) request.params = { | ||
@@ -264,2 +362,5 @@ ...request.params, | ||
if (postData) { | ||
client.log([ | ||
"Execute Steps: Posting order" | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Verbose); | ||
const postOrderUrl = new URL(`${request.baseURL}${postData.endpoint}`); | ||
@@ -282,3 +383,10 @@ try { | ||
if (res.status > 299 || res.status < 200) throw res.data; | ||
stepItem.orderId = res.data.orderId; | ||
if (res.data.results) stepItem.orderData = res.data.results; | ||
else if (res.data && res.data.orderId) stepItem.orderData = [ | ||
{ | ||
orderId: res.data.orderId, | ||
crossPostingOrderId: res.data.crossPostingOrderId, | ||
orderIndex: res.data.orderIndex || 0 | ||
} | ||
]; | ||
setState([ | ||
@@ -305,4 +413,6 @@ ...json === null || json === void 0 ? void 0 : json.steps | ||
} catch (err) { | ||
const error = new Error(err === null || err === void 0 ? void 0 : err.message); | ||
console.error(error); | ||
client.log([ | ||
"Execute Steps: An error occurred", | ||
err | ||
], (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Error); | ||
throw err; | ||
@@ -413,3 +523,3 @@ } | ||
var _a; | ||
const { id: id , signer: signer , onProgress: onProgress } = data; | ||
const { ids: ids , signer: signer , onProgress: onProgress } = data; | ||
const client = (0, $6496f8ee40d0c4eb$export$6bb76d6eba7e258c)(); | ||
@@ -419,10 +529,13 @@ const options = data.options || {}; | ||
if (!baseApiUrl) throw new ReferenceError("ReservoirClient missing chain configuration"); | ||
if (ids.length === 0) throw { | ||
message: "No order ids specified" | ||
}; | ||
try { | ||
const params = { | ||
id: id, | ||
...options | ||
}; | ||
await (0, $13b5a8bc45044506$export$21ece85d7636deb)({ | ||
url: `${baseApiUrl}/execute/cancel/v2`, | ||
params: params | ||
method: "post", | ||
url: `${baseApiUrl}/execute/cancel/v3`, | ||
data: { | ||
orderIds: ids, | ||
...options | ||
} | ||
}, signer, onProgress); | ||
@@ -541,2 +654,4 @@ return true; | ||
$parcel$export($7de07f425a625121$exports, "request", () => $ce40c15ff138f6b7$export$b5fe3f66a567bec0); | ||
$parcel$export($7de07f425a625121$exports, "log", () => $e1b436840b45b1d8$export$bef1f36f5486a6a3); | ||
$parcel$export($7de07f425a625121$exports, "LogLevel", () => $e1b436840b45b1d8$export$243e62d78d3b544d); | ||
@@ -591,4 +706,9 @@ | ||
let $6496f8ee40d0c4eb$var$_client; | ||
class $6496f8ee40d0c4eb$export$d0c36b5db6a81704 { | ||
log(message, level = (0, $e1b436840b45b1d8$export$243e62d78d3b544d).Info) { | ||
return (0, $e1b436840b45b1d8$export$bef1f36f5486a6a3)(message, level, this.logLevel); | ||
} | ||
constructor(options){ | ||
@@ -607,2 +727,3 @@ this.utils = { | ||
this.source = options.source; | ||
this.logLevel = options.logLevel !== undefined ? options.logLevel : (0, $e1b436840b45b1d8$export$243e62d78d3b544d).None; | ||
} | ||
@@ -617,2 +738,3 @@ configure(options) { | ||
this.normalizeRoyalties = options.normalizeRoyalties !== undefined ? options.normalizeRoyalties : this.normalizeRoyalties; | ||
this.logLevel = options.logLevel !== undefined ? options.logLevel : (0, $e1b436840b45b1d8$export$243e62d78d3b544d).None; | ||
} | ||
@@ -652,3 +774,3 @@ currentChain() { | ||
export {$6496f8ee40d0c4eb$export$d0c36b5db6a81704 as ReservoirClient, $6496f8ee40d0c4eb$export$6bb76d6eba7e258c as getClient, $6496f8ee40d0c4eb$export$5d730b7aed1a3eb0 as createClient, $13b5a8bc45044506$export$21ece85d7636deb as executeSteps, $3d06f0c5a9f29ddf$export$dc1827290674c112 as setParams, $8b98f6fc3beebe05$export$d2c70568ef790b87 as pollUntilOk, $8b98f6fc3beebe05$export$f014594cc879f602 as pollUntilHasData, $9c301d2c7b66eaf9$export$feaa73ad8ed3f2b9 as isOpenSeaBanned, $ce40c15ff138f6b7$export$b5fe3f66a567bec0 as request}; | ||
export {$6496f8ee40d0c4eb$export$d0c36b5db6a81704 as ReservoirClient, $6496f8ee40d0c4eb$export$6bb76d6eba7e258c as getClient, $6496f8ee40d0c4eb$export$5d730b7aed1a3eb0 as createClient, $13b5a8bc45044506$export$21ece85d7636deb as executeSteps, $3d06f0c5a9f29ddf$export$dc1827290674c112 as setParams, $8b98f6fc3beebe05$export$d2c70568ef790b87 as pollUntilOk, $8b98f6fc3beebe05$export$f014594cc879f602 as pollUntilHasData, $9c301d2c7b66eaf9$export$feaa73ad8ed3f2b9 as isOpenSeaBanned, $ce40c15ff138f6b7$export$b5fe3f66a567bec0 as request, $e1b436840b45b1d8$export$bef1f36f5486a6a3 as log, $e1b436840b45b1d8$export$243e62d78d3b544d as LogLevel}; | ||
//# sourceMappingURL=index.module.js.map |
{ | ||
"name": "@reservoir0x/reservoir-sdk", | ||
"version": "0.6.5", | ||
"version": "0.7.0", | ||
"description": "An SDK that can be used in any javascript/typescript context to easily interact with Reservoir liquidity APIs", | ||
@@ -5,0 +5,0 @@ "source": "src/index.ts", |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
1400542
10818