Bluesky app fork with some witchin' additions 💫 forked from jollywhoppers.com/witchsky.app
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384import {BskyAgent, stringifyLex, jsonToLex} from '@atproto/api'import RNFS from 'react-native-fs'
const GET_TIMEOUT = 15e3 // 15sconst POST_TIMEOUT = 60e3 // 60s
export function doPolyfill() { BskyAgent.configure({fetch: fetchHandler})}
interface FetchHandlerResponse { status: number headers: Record<string, string> body: any}
async function fetchHandler( reqUri: string, reqMethod: string, reqHeaders: Record<string, string>, reqBody: any,): Promise<FetchHandlerResponse> { const reqMimeType = reqHeaders['Content-Type'] || reqHeaders['content-type'] if (reqMimeType && reqMimeType.startsWith('application/json')) { reqBody = stringifyLex(reqBody) } else if ( typeof reqBody === 'string' && (reqBody.startsWith('/') || reqBody.startsWith('file:')) ) { if (reqBody.endsWith('.jpeg') || reqBody.endsWith('.jpg')) { // HACK // React native has a bug that inflates the size of jpegs on upload // we get around that by renaming the file ext to .bin // see https://github.com/facebook/react-native/issues/27099 // -prf const newPath = reqBody.replace(/\.jpe?g$/, '.bin') await RNFS.moveFile(reqBody, newPath) reqBody = newPath } // NOTE // React native treats bodies with {uri: string} as file uploads to pull from cache // -prf reqBody = {uri: reqBody} }
const controller = new AbortController() const to = setTimeout( () => controller.abort(), reqMethod === 'post' ? POST_TIMEOUT : GET_TIMEOUT, )
const res = await fetch(reqUri, { method: reqMethod, headers: reqHeaders, body: reqBody, signal: controller.signal, })
const resStatus = res.status const resHeaders: Record<string, string> = {} res.headers.forEach((value: string, key: string) => { resHeaders[key] = value }) const resMimeType = resHeaders['Content-Type'] || resHeaders['content-type'] let resBody if (resMimeType) { if (resMimeType.startsWith('application/json')) { resBody = jsonToLex(await res.json()) } else if (resMimeType.startsWith('text/')) { resBody = await res.text() } else { throw new Error('TODO: non-textual response body') } }
clearTimeout(to)
return { status: resStatus, headers: resHeaders, body: resBody, }}