defido
commented
2 years ago Here is a working script that works with m3u8 video files & range
interface Env {
KEMAL: KEMAL
}
function parseRange(encoded: string | null): undefined | { offset: number, length: number } {
if (encoded === null) {
return
}
const parts = encoded.split("bytes=")[1]?.split("-") ?? []
if (parts.length !== 2) {
throw new Error('Not supported to skip specifying the beginning/ending byte at this time')
}
return {
offset: Number(parts[0]),
length: Number(parts[1]) + 1 - Number(parts[0]),
}
}
function objectNotFound(objectName: string): Response {
return new Response(`<html><body>R2 object "<b>${objectName}</b>" not found</body></html>`, {
status: 404,
headers: {
'content-type': 'text/html; charset=UTF-8'
}
})
}
export default {
async fetch(request: Request, env: Env, context: any): Promise<Response> {
const url = new URL(request.url)
const objectName = url.pathname.slice(1)
console.log(`${request.method} object ${objectName}: ${request.url}`)
if (request.method === 'GET' || request.method === 'HEAD') {
if (objectName === '') {
if (request.method == 'HEAD') {
return new Response(undefined, { status: 400 })
}
const options: R2ListOptions = {
prefix: url.searchParams.get('prefix') ?? undefined,
delimiter: url.searchParams.get('delimiter') ?? undefined,
cursor: url.searchParams.get('cursor') ?? undefined,
include: ['customMetadata', 'httpMetadata'],
}
console.log(JSON.stringify(options))
const listing = await env.KEMAL.list(options)
return new Response(JSON.stringify(listing), {headers: {
'content-type': 'application/json; charset=UTF-8',
}})
}
if (request.method === 'GET') {
const range = parseRange(request.headers.get('range'))
const object = await env.KEMAL.get(objectName, {
range,
onlyIf: request.headers,
})
if (object === null) {
return objectNotFound(objectName)
}
// Construct the cache key from the cache URL
// const cacheKey = new Request(url.toString(), request);
// const cache = caches.default;
// Check whether the value is already available in the cache
// if not, you will need to fetch it from R2, and store it in the cache
// for future access
// let response = await cache.match(cacheKey);
// context.waitUntil(cache.put(cacheKey, response.clone()));
const headers = new Headers()
const status = object.body ? (range ? 206 : 200) : 304
object.writeHttpMetadata(headers)
headers.set('etag', object.httpEtag)
headers.set('Access-Control-Allow-Origin', '*')
headers.set('Cache-Control', 's-max-age=3600');
const response = new Response(object.body, {
headers,
status
})
return response
}
const object = await env.KEMAL.head(objectName, {
onlyIf: request.headers,
})
if (object === null) {
return objectNotFound(objectName)
}
const headers = new Headers()
object.writeHttpMetadata(headers)
headers.set('etag', object.httpEtag)
return new Response(null, {
headers,
})
}
if (request.method === 'PUT' || request.method == 'POST') {
const object = await env.KEMAL.put(objectName, request.body, {
httpMetadata: request.headers,
})
return new Response(null, {
headers: {
'etag': object.httpEtag,
}
})
}
if (request.method === 'DELETE') {
await env.KEMAL.delete(url.pathname.slice(1))
return new Response()
}
return new Response(`Unsupported method`, {
status: 400
})
}
}
johnspurlock-skymethod
augustblack
Hi there, the public read has a couple of issues.
The second time you try to download a file you will recieve this error, the string will be different. I have tried this with multiple files.
Status Code: 500TypeError: Conditional ETag should not be wrapped in quotes ("d03c2f258e9fc6e7236f61c130ed1e48").Range files, specifically m3u8 video files don't work.
Using this:
denoflare push https://raw.githubusercontent.com/skymethod/denoflare/v0.5.4/examples/r2-public-read-worker/worker.ts