mirror of
https://github.com/CommunitySolidServer/CommunitySolidServer.git
synced 2024-10-03 14:55:10 +00:00
126 lines
4.7 KiB
TypeScript
126 lines
4.7 KiB
TypeScript
import { createReadStream, mkdirSync } from 'fs';
|
|
import { join } from 'path';
|
|
import * as rimraf from 'rimraf';
|
|
import type { HttpHandler, Initializer, ResourceStore } from '../../src/';
|
|
import { RepresentationMetadata } from '../../src/ldp/representation/RepresentationMetadata';
|
|
import { guardStream } from '../../src/util/GuardedStream';
|
|
import { CONTENT_TYPE, LDP } from '../../src/util/UriConstants';
|
|
import { BASE, getRootFilePath, instantiateFromConfig } from '../configs/Util';
|
|
import { AclTestHelper, FileTestHelper } from '../util/TestHelpers';
|
|
|
|
const rootFilePath = getRootFilePath('full-config-acl');
|
|
const stores: [string, any][] = [
|
|
[ 'in-memory storage', {
|
|
storeUrn: 'urn:solid-server:default:MemoryResourceStore',
|
|
setup: jest.fn(),
|
|
teardown: jest.fn(),
|
|
}],
|
|
[ 'on-disk storage', {
|
|
storeUrn: 'urn:solid-server:default:FileResourceStore',
|
|
setup(): void {
|
|
mkdirSync(rootFilePath, { recursive: true });
|
|
},
|
|
teardown(): void {
|
|
rimraf.sync(rootFilePath, { glob: false });
|
|
},
|
|
}],
|
|
];
|
|
|
|
describe.each(stores)('A server using %s', (name, { storeUrn, setup, teardown }): void => {
|
|
describe('with acl', (): void => {
|
|
let handler: HttpHandler;
|
|
let aclHelper: AclTestHelper;
|
|
let fileHelper: FileTestHelper;
|
|
|
|
beforeAll(async(): Promise<void> => {
|
|
// Set up the internal store
|
|
await setup();
|
|
const variables: Record<string, any> = {
|
|
'urn:solid-server:default:variable:baseUrl': BASE,
|
|
'urn:solid-server:default:variable:rootFilePath': rootFilePath,
|
|
};
|
|
const internalStore = await instantiateFromConfig(
|
|
storeUrn,
|
|
'auth-ldp-handler.json',
|
|
variables,
|
|
) as ResourceStore;
|
|
variables['urn:solid-server:default:variable:store'] = internalStore;
|
|
|
|
// Create and initialize the HTTP handler and related components
|
|
let initializer: Initializer;
|
|
let store: ResourceStore;
|
|
const instances = await instantiateFromConfig(
|
|
'urn:solid-server:test:Instances',
|
|
'auth-ldp-handler.json',
|
|
variables,
|
|
) as Record<string, any>;
|
|
({ handler, store, initializer } = instances);
|
|
await initializer.handleSafe();
|
|
|
|
// Create test helpers for manipulating the components
|
|
aclHelper = new AclTestHelper(store, BASE);
|
|
fileHelper = new FileTestHelper(handler, new URL(BASE));
|
|
|
|
// Write test resource
|
|
await store.setRepresentation({ path: `${BASE}/permanent.txt` }, {
|
|
binary: true,
|
|
data: guardStream(createReadStream(join(__dirname, '../assets/permanent.txt'))),
|
|
metadata: new RepresentationMetadata({ [CONTENT_TYPE]: 'text/plain' }),
|
|
});
|
|
});
|
|
|
|
afterAll(async(): Promise<void> => {
|
|
await teardown();
|
|
});
|
|
|
|
it('can add a file to the store, read it and delete it if allowed.', async():
|
|
Promise<void> => {
|
|
// Set acl
|
|
await aclHelper.setSimpleAcl({ read: true, write: true, append: true }, 'agent');
|
|
|
|
// Create file
|
|
let response = await fileHelper.createFile('../assets/testfile2.txt', 'testfile2.txt', 'text/plain');
|
|
const id = response._getHeaders().location;
|
|
|
|
// Get file
|
|
response = await fileHelper.getFile(id);
|
|
expect(response.statusCode).toBe(200);
|
|
expect(response._getBuffer().toString()).toContain('TESTFILE2');
|
|
expect(response.getHeaders().link).toBe(`<${LDP.Resource}>; rel="type"`);
|
|
|
|
// DELETE file
|
|
await fileHelper.deleteResource(id);
|
|
await fileHelper.shouldNotExist(id);
|
|
});
|
|
|
|
it('can not add a file to the store if not allowed.', async():
|
|
Promise<void> => {
|
|
// Set acl
|
|
await aclHelper.setSimpleAcl({ read: true, write: true, append: true }, 'authenticated');
|
|
|
|
// Try to create file
|
|
const response = await fileHelper.createFile('../assets/testfile2.txt', 'testfile2.txt', 'text/plain', true);
|
|
expect(response.statusCode).toBe(401);
|
|
});
|
|
|
|
it('can not add/delete, but only read files if allowed.', async():
|
|
Promise<void> => {
|
|
// Set acl
|
|
await aclHelper.setSimpleAcl({ read: true, write: false, append: false }, 'agent');
|
|
|
|
// Try to create file
|
|
let response = await fileHelper.createFile('../assets/testfile2.txt', 'testfile2.txt', 'text/plain', true);
|
|
expect(response.statusCode).toBe(401);
|
|
|
|
// GET permanent file
|
|
response = await fileHelper.getFile('http://test.com/permanent.txt');
|
|
expect(response._getBuffer().toString()).toContain('TEST');
|
|
expect(response.getHeaders().link).toBe(`<${LDP.Resource}>; rel="type"`);
|
|
|
|
// Try to delete permanent file
|
|
response = await fileHelper.deleteResource('http://test.com/permanent.txt', true);
|
|
expect(response.statusCode).toBe(401);
|
|
});
|
|
});
|
|
});
|