cadence/out-of-your-element
cadence/out-of-your-element
3
7
Fork 2
Code Issues 12 Pull requests 1 Releases 22 Activity

Fix d->m file uploads

Browse source
This commit is contained in:
Cadence Ember 2025-02-13 01:14:29 +13:00
parent cfaada6797
commit b0ded8e289
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/matrix/mreq.js
View file

@ -2,6 +2,7 @@
const mixin = require("@cloudrac3r/mixin-deep") const mixin = require("@cloudrac3r/mixin-deep")
const stream = require("stream") const stream = require("stream")
const {ReadableStream} = require("stream/web")
const getStream = require("get-stream") const getStream = require("get-stream")
const {reg, writeRegistration} = require("./read-registration.js") const {reg, writeRegistration} = require("./read-registration.js")
@ -30,18 +31,18 @@ async function mreq(method, url, body, extra = {}) {
} else if (body instanceof stream.Readable && reg.ooye.content_length_workaround) { } else if (body instanceof stream.Readable && reg.ooye.content_length_workaround) {
body = await getStream.buffer(body) body = await getStream.buffer(body)
} else if (body instanceof ReadableStream && reg.ooye.content_length_workaround) { } else if (body instanceof ReadableStream && reg.ooye.content_length_workaround) {
body = await stream.consumers.buffer(body) body = await stream.consumers.buffer(stream.Readable.fromWeb(body))
} }
/** @type {RequestInit} */ /** @type {RequestInit} */
const opts = { const opts = mixin({
method, method,
body, body,
headers: { headers: {
Authorization: `Bearer ${reg.as_token}` Authorization: `Bearer ${reg.as_token}`
}, },
...extra ...(body && {duplex: "half"}), // https://github.com/octokit/request.js/pull/571/files
} }, extra)
// console.log(baseUrl + url, opts) // console.log(baseUrl + url, opts)
const res = await fetch(baseUrl + url, opts) const res = await fetch(baseUrl + url, opts)
const root = await res.json() const root = await res.json()