mirror of
https://github.com/hanzoai/insights-js.git
synced 2026-11-02 09:24:43 +00:00
zeekay
d57cb038bd
Bulk rename across 989 files: - Package names: posthog-js → @hanzo/insights, posthog-node → @hanzo/insights-node, etc. - Repository URLs: posthog/posthog-js → hanzoai/insights-js - Brand names: PostHog → Insights - File renames: 259 reference JSON files, source files, workflow files - Directory rename: eslint-plugin-posthog-js → eslint-plugin-insights Remaining: 8 refs to @posthog/rrweb-* (real npm deps, need fork+publish)
84 lines
3.0 KiB
TypeScript
84 lines
3.0 KiB
TypeScript
// An MSW server that handles requests to https://app.insights.com/e/ and stores
|
|
|
|
import { ResponseComposition, rest } from 'msw'
|
|
import { setupServer } from 'msw/node'
|
|
import { RestContext } from 'msw'
|
|
import { RestRequest } from 'msw'
|
|
import { decompressSync, strFromU8 } from 'fflate'
|
|
|
|
// the request bodies in a store that we can inspect within tests.
|
|
const capturedRequests: { '/e/': any[]; '/engage/': any[]; '/flags/': any[] } = {
|
|
'/e/': [],
|
|
'/engage/': [],
|
|
'/flags/': [],
|
|
}
|
|
|
|
const handleRequest = (group: string) => (req: RestRequest, res: ResponseComposition, ctx: RestContext) => {
|
|
let body = req.body
|
|
|
|
if (typeof body === 'string') {
|
|
try {
|
|
const b64Encoded = req.url.href.includes('compression=base64')
|
|
const gzipCompressed = req.url.href.includes('compression=gzip-js')
|
|
if (b64Encoded) {
|
|
body = JSON.parse(Buffer.from(decodeURIComponent(body.split('=')[1]), 'base64').toString())
|
|
} else if (gzipCompressed) {
|
|
const data = new Uint8Array(req._body)
|
|
const decoded = strFromU8(decompressSync(data))
|
|
body = JSON.parse(decoded)
|
|
} else {
|
|
body = JSON.parse(decodeURIComponent(body.split('=')[1]))
|
|
}
|
|
} catch {
|
|
return res(ctx.status(500))
|
|
}
|
|
}
|
|
|
|
capturedRequests[group] = [...(capturedRequests[group] || []), body]
|
|
|
|
return res(ctx.json({}))
|
|
}
|
|
|
|
const server = setupServer(
|
|
rest.post('http://localhost/e/', (req, res, ctx) => {
|
|
return handleRequest('/e/')(req, res, ctx)
|
|
}),
|
|
rest.post('http://localhost/engage/', (req, res, ctx) => {
|
|
return handleRequest('/engage/')(req, res, ctx)
|
|
}),
|
|
rest.post('http://localhost/flags/', (req, res, ctx) => {
|
|
return handleRequest('/flags/')(req, res, ctx)
|
|
})
|
|
)
|
|
|
|
// Start the server before all the tests run, and close it afterwards.
|
|
beforeAll(() =>
|
|
server.listen({
|
|
onUnhandledRequest: 'error',
|
|
})
|
|
)
|
|
afterAll(() => server.close())
|
|
|
|
export const getRequests = (token: string) => {
|
|
// Filter the captured requests by the given token.
|
|
return {
|
|
'/e/': capturedRequests['/e/'].filter((request) => request.properties.token === token),
|
|
'/engage/': capturedRequests['/engage/'].filter((request) => request.properties.token === token),
|
|
'/flags/': capturedRequests['/flags/'].filter((request) => request.token === token),
|
|
}
|
|
}
|
|
|
|
export const resetRequests = (token: string) => {
|
|
Object.assign(capturedRequests, {
|
|
'/e/': (capturedRequests['/e/'] = capturedRequests['/e/'].filter(
|
|
(request) => request.properties.token !== token
|
|
)),
|
|
'/engage/': (capturedRequests['/engage/'] = capturedRequests['/engage/'].filter(
|
|
(request) => request.properties.token !== token
|
|
)),
|
|
'/flags/': (capturedRequests['/flags/'] = capturedRequests['/flags/'].filter(
|
|
(request) => request.token !== token
|
|
)),
|
|
})
|
|
}
|