Me pregunto si alguien podría ayudar a descubrir cómo pasar el cuerpo de una publicación a otro punto final con trabajadores de Cloudflare. Estoy tratando de obtener la publicación de solicitud entrante para publicar en la URL.
const url = 'https://webhook.site/#!/b2f75ce2-7b9e-479a-b6f0-8934a89a3f3d' const body = { results: ['default data to send'], errors: null, msg: 'I sent this to the fetch', } /** * gatherResponse awaits and returns a response body as a string. * Use await gatherResponse(..) in an async function to get the response body * @param {Response} response */ async function gatherResponse(response) { const { headers } = response const contentType = headers.get('content-type') || '' if (contentType.includes('application/json')) { return JSON.stringify(await response.json()) } else if (contentType.includes('application/text')) { return response.text() } else if (contentType.includes('text/html')) { return response.text() } else { return response.text() } } async function handleRequest() { const init = { body: JSON.stringify(body), method: 'POST', headers: { 'content-type': 'application/json;charset=UTF-8', }, } const response = await fetch(url, init) const results = await gatherResponse(response) return new Response(results, init) } addEventListener('fetch', (event) => { return event.respondWith(handleRequest()) })Creé un trabajador en https://tight-art-0743.ctohm.workers.dev/ , que básicamente reenvía el cuerpo de su solicitud POST a un contenedor de solicitud público. Puede verificar qué está recibiendo en: https://requestbin.com/r/en5k768mcp4x9/24tqhPJw86mt2WjKRMbmt75FMH9
addEventListener("fetch", (event) => { event.respondWith( handleRequest(event.request).catch( (err) => new Response(err.stack, { status: 500 }) ) ); }); async function handleRequest(request) { let {method,headers}=request, url=new URL(request.url) // methods other than POST will return early if(method!=='POST') return new Response(`Your request method was ${method}`); const forwardRequest=new Request("https://en5k768mcp4x9.x.pipedream.net/", request) forwardRequest.headers.set('X-Custom-Header','hey!') return fetch(forwardRequest) }Puedes verlo funcionando con una simple solicitud de CURL
curl --location --request POST 'https://tight-art-0743.ctohm.workers.dev/' \ --header 'Content-Type: application/json' \ --data-raw '{"environment": {"name": "Sample Environment Name (required)"}}'Dos cosas que vale la pena señalar, en el código del trabajador:
init , a través del cual los encabezados y el cuerpo originales se reenvían de forma transparente al contenedor de solicitudes, lo que también permite una manipulación adicional del encabezado si es necesario. Otro ejemplo: agreguemos una ruta /csv . Las solicitudes que comienzan con /csv no reenviarán su cuerpo POST. En su lugar, descargarán un archivo adjunto CSV remoto y lo PUBLICARÁN en el contenedor de solicitudes. Nuevamente, no estamos esperando los contenidos CSV reales. Pasamos un identificador al cuerpo de respuesta a la solicitud de reenvío
async function handleRequest(request) { let {method,headers}=request, url=new URL(request.url) if(method!=='POST') return new Response(`Your request method was ${method}`); const forwardRequest=new Request("https://en5k768mcp4x9.x.pipedream.net/",request) if(url.pathname.includes('/csv')) { const remoteSource=`https://cdn.wsform.com/wp-content/uploads/2018/09/country_full.csv`, remoteResponse=await fetch(remoteSource) return fetch(forwardRequest,{body:remoteResponse.body}) } forwardRequest.headers.set('X-Custom-Header','hey!') return fetch(forwardRequest) }Si bien su código debería funcionar teóricamente, el hecho de que esté desenvolviendo la respuesta significa que su trabajador podría cancelarse debido a que se alcanzaron los límites de tiempo, la CPU o la memoria. Por el contrario, cuando se utiliza el enfoque basado en secuencias, la ejecución de su trabajador finaliza tan pronto como devuelve la recuperación de reenvío. Incluso si el POST saliente todavía se está ejecutando, esto no está sujeto a límites de CPU o de tiempo.