while (true) {
let foo = await reader.read();
if (foo.value) {
console.log(foo.value)
let md = metadataExtractor.extract(foo.value)
if (md.val) {
let encoder = new TextEncoder()
let strung = encoder.encode(JSON.stringify(md.val))
console.log("MD", strung)
console.log(strung.length)
let {readable, writable} = new FixedLengthStream(strung.length)
let writer = writable.getWriter()
await writer.write(strung).then(e => console.log({e}))
await env.CONTENT_BUCKET.put(`${key}-md`, readable)
console.log("PUT METADATA IN R2")
}
}
while (true) {
let foo = await reader.read();
if (foo.value) {
console.log(foo.value)
let md = metadataExtractor.extract(foo.value)
if (md.val) {
let encoder = new TextEncoder()
let strung = encoder.encode(JSON.stringify(md.val))
console.log("MD", strung)
console.log(strung.length)
let {readable, writable} = new FixedLengthStream(strung.length)
let writer = writable.getWriter()
await writer.write(strung).then(e => console.log({e}))
await env.CONTENT_BUCKET.put(`${key}-md`, readable)
console.log("PUT METADATA IN R2")
}
}