mirror of
https://github.com/CommunitySolidServer/CommunitySolidServer.git
synced 2024-10-03 14:55:10 +00:00
test: Add crash test for guard stream edge case
See https://github.com/solid/community-server/pull/462#issuecomment-758013492 for details on why this crashes the server.
This commit is contained in:
53
test/integration/GuardedStream.test.ts
Normal file
53
test/integration/GuardedStream.test.ts
Normal file
@@ -0,0 +1,53 @@
|
||||
import {
|
||||
RepresentationMetadata,
|
||||
TypedRepresentationConverter,
|
||||
readableToString,
|
||||
ChainedConverter,
|
||||
guardedStreamFrom,
|
||||
RdfToQuadConverter, BasicRepresentation, getLoggerFor,
|
||||
} from '../../src';
|
||||
import type { Representation,
|
||||
RepresentationConverterArgs,
|
||||
Logger } from '../../src';
|
||||
|
||||
jest.mock('../../src/logging/LogUtil', (): any => {
|
||||
const logger: Logger = { error: jest.fn(), debug: jest.fn(), warn: jest.fn(), info: jest.fn() } as any;
|
||||
return { getLoggerFor: (): Logger => logger };
|
||||
});
|
||||
const logger: jest.Mocked<Logger> = getLoggerFor('GuardedStream') as any;
|
||||
|
||||
class DummyConverter extends TypedRepresentationConverter {
|
||||
public async getInputTypes(): Promise<Record<string, number>> {
|
||||
return { '*/*': 1 };
|
||||
}
|
||||
|
||||
public async getOutputTypes(): Promise<Record<string, number>> {
|
||||
return { 'custom/type': 1 };
|
||||
}
|
||||
|
||||
public async handle({ representation }: RepresentationConverterArgs): Promise<Representation> {
|
||||
const data = guardedStreamFrom([ 'dummy' ]);
|
||||
const metadata = new RepresentationMetadata(representation.metadata, 'custom/type');
|
||||
|
||||
return { binary: true, data, metadata };
|
||||
}
|
||||
}
|
||||
|
||||
describe('A chained converter where data gets ignored', (): void => {
|
||||
const identifier = { path: 'http://test.com/' };
|
||||
const rep = new BasicRepresentation('<a:b> <a:b> c!', identifier, 'text/turtle');
|
||||
const converter = new ChainedConverter([
|
||||
new RdfToQuadConverter(),
|
||||
new DummyConverter(),
|
||||
]);
|
||||
|
||||
it('does not throw on async crash.', async(): Promise<void> => {
|
||||
jest.useFakeTimers();
|
||||
const result = await converter.handleSafe({ identifier, representation: rep, preferences: {}});
|
||||
|
||||
expect(await readableToString(result.data)).toBe('dummy');
|
||||
|
||||
jest.advanceTimersByTime(1000);
|
||||
expect(logger.error).toHaveBeenCalledTimes(1);
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user