diff --git a/packages/api/src/index.js b/packages/api/src/index.js index 1c33415b02..1ef0931dfa 100644 --- a/packages/api/src/index.js +++ b/packages/api/src/index.js @@ -35,7 +35,6 @@ import { } from './middleware/maintenance.js' import { getContext } from './utils/context.js' import { withAuth } from './middleware/auth.js' -import { repl } from './repl.js' const r = new Router(getContext, { onError(req, err, ctx) { @@ -48,10 +47,6 @@ const checkHasDeleteRestriction = true const checkHasPsaAccess = true const checkUcan = true -// Debugging - -r.add('post', '/repl', repl) - // Monitoring r.add('get', '/metrics', withMode(metrics, RO)) r.add('get', '/stats', withMode(getStats, RO), [postCors]) diff --git a/packages/api/src/repl.js b/packages/api/src/repl.js deleted file mode 100644 index e41db28c43..0000000000 --- a/packages/api/src/repl.js +++ /dev/null @@ -1,22 +0,0 @@ -import { JSONResponse } from './utils/json-response.js' -import { HTTPError } from './errors.js' - -/** @type {import('./bindings').Handler} */ -export const repl = async (event, ctx) => { - const { w3up } = ctx - - if (w3up) { - const blob = await event.request.blob() - if (blob.size === 0) { - throw new HTTPError('empty payload', 400) - } - - const car = await w3up.capability.store.add(blob) - - console.log('UPLOADED CAR') - - return new JSONResponse({ ok: true, value: car }) - } else { - throw new HTTPError(`No w3up client`, 500) - } -} diff --git a/packages/api/src/routes/nfts-upload.js b/packages/api/src/routes/nfts-upload.js index c2ab074709..b8bac04214 100644 --- a/packages/api/src/routes/nfts-upload.js +++ b/packages/api/src/routes/nfts-upload.js @@ -181,7 +181,16 @@ export async function uploadCarWithStat( const { w3up } = ctx console.log('UPLOADING CAR') - await w3up.capability.store.add(car) + + // we perform store/add and upload/add concurrently to save time. + await Promise.all([ + w3up.capability.store.add(car), + // We create an upload for each CAR and use it's CID as a shard, which + // will work as expected because `upload/add` merges all shards. + // @ts-expect-error Link types mismatch + w3up.capability.upload.add(stat.rootCid, [stat.cid]), + ]) + console.log('UPLOADED CAR') // register as gateway links to record the CAR CID - we don't have another // way to know the location right now.