cloudflare-tcp-fetcher
Advanced tools
Comparing version 0.9.0 to 0.9.1
@@ -14,3 +14,6 @@ { | ||
"wrangler": "^3.0.0" | ||
}, | ||
"dependencies": { | ||
"cloudflare-tcp-fetcher": "^0.9.0" | ||
} | ||
} |
@@ -1,9 +0,7 @@ | ||
import { fetchUsingTcp } from "../../src/index"; | ||
import { fetchUsingTcp } from "cloudflare-tcp-fetcher"; | ||
export default { | ||
async fetch(request: Request, env: never, ctx: ExecutionContext): Promise<Response> { | ||
const response = await fetchUsingTcp("https://google.com"); | ||
return response; | ||
return fetchUsingTcp("https://google.com"); | ||
}, | ||
}; |
{ | ||
"name": "cloudflare-tcp-fetcher", | ||
"version": "0.9.0", | ||
"version": "0.9.1", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -21,2 +21,4 @@ import { connect } from 'cloudflare:sockets'; | ||
return new Promise((resolve, reject) => { | ||
let resolved = false; | ||
socket.opened.then(async () => { | ||
@@ -60,2 +62,4 @@ const writer = socket.writable.getWriter(); | ||
if(response.bodyData.length >= parseInt(response.headers["content-length"])) { | ||
resolved = true; | ||
resolve(new Response(response.bodyData, { | ||
@@ -78,2 +82,4 @@ status: response.statusCode, | ||
else { | ||
resolved = true; | ||
reject("Reader was finished."); | ||
@@ -84,8 +90,14 @@ } | ||
reader.read().then(handleRead); | ||
}, reject); | ||
}, (reason) => { | ||
resolved = true; | ||
reject(reason); | ||
}); | ||
setTimeout(() => { | ||
socket.close(); | ||
if(!resolved) { | ||
socket.close(); | ||
reject("Connection timed out (>30s)"); | ||
reject("Connection timed out (>30s)"); | ||
} | ||
}, 30000); | ||
@@ -92,0 +104,0 @@ }); |
No README
QualityPackage does not have a README. This may indicate a failed publish or a low quality package.
Found 1 instance in 1 package
102906
1
43
16
1629