7f26b17652
* Improve error message when using invalid client_id during code exchange * Extract SPA example OAuth client in own package * wip * remove dependency on get-port * Properly configure jest to only transpile "get-port" from node_modules https://jestjs.io/docs/configuration#transformignorepatterns-arraystring * Use dynamically assigned port number during tests * use puppeteer to run tests * remove login input "id" attribute * code style * add missing declaration * tidy * headless * remove get-port dependency * fix tests/proxied/admin.test.ts * fix tests * Allow unsecure oauth providers through configuration * transpile "lande" during ozone tests * Cache Puppeteer browser binaries * Use puppeteer cache during all workflow steps * remove use of set-output * use get-port in xrpc-server tests * Renamed to allowHttp * tidy * tidy
76 lines
1.9 KiB
TypeScript
76 lines
1.9 KiB
TypeScript
import * as http from 'node:http'
|
|
import { AddressInfo } from 'node:net'
|
|
import { LexiconDoc } from '@atproto/lexicon'
|
|
import { XrpcClient } from '@atproto/xrpc'
|
|
import { byteIterableToStream } from '@atproto/common'
|
|
import { createServer, closeServer } from './_util'
|
|
import * as xrpcServer from '../src'
|
|
|
|
const LEXICONS: LexiconDoc[] = [
|
|
{
|
|
lexicon: 1,
|
|
id: 'io.example.readableStream',
|
|
defs: {
|
|
main: {
|
|
type: 'query',
|
|
parameters: {
|
|
type: 'params',
|
|
properties: {
|
|
shouldErr: { type: 'boolean' },
|
|
},
|
|
},
|
|
output: {
|
|
encoding: 'application/vnd.ipld.car',
|
|
},
|
|
},
|
|
},
|
|
},
|
|
]
|
|
|
|
describe('Responses', () => {
|
|
let s: http.Server
|
|
const server = xrpcServer.createServer(LEXICONS)
|
|
server.method(
|
|
'io.example.readableStream',
|
|
async (ctx: { params: xrpcServer.Params }) => {
|
|
async function* iter(): AsyncIterable<Uint8Array> {
|
|
for (let i = 0; i < 5; i++) {
|
|
yield new Uint8Array([i])
|
|
}
|
|
if (ctx.params.shouldErr) {
|
|
throw new Error('error')
|
|
}
|
|
}
|
|
return {
|
|
encoding: 'application/vnd.ipld.car',
|
|
body: byteIterableToStream(iter()),
|
|
}
|
|
},
|
|
)
|
|
|
|
let client: XrpcClient
|
|
beforeAll(async () => {
|
|
s = await createServer(server)
|
|
const { port } = s.address() as AddressInfo
|
|
client = new XrpcClient(`http://localhost:${port}`, LEXICONS)
|
|
})
|
|
afterAll(async () => {
|
|
await closeServer(s)
|
|
})
|
|
|
|
it('returns readable streams of bytes', async () => {
|
|
const res = await client.call('io.example.readableStream', {
|
|
shouldErr: false,
|
|
})
|
|
const expected = new Uint8Array([0, 1, 2, 3, 4])
|
|
expect(res.data).toEqual(expected)
|
|
})
|
|
|
|
it('handles errs on readable streams of bytes', async () => {
|
|
const attempt = client.call('io.example.readableStream', {
|
|
shouldErr: true,
|
|
})
|
|
await expect(attempt).rejects.toThrow()
|
|
})
|
|
})
|