import { createReadStream } from 'fs'; import { join } from 'path'; 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 { AclTestHelper, FileTestHelper } from '../util/TestHelpers'; import { BASE, getTestFolder, createFolder, removeFolder, instantiateFromConfig } from './Config'; const rootFilePath = getTestFolder('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 => createFolder(rootFilePath), teardown: (): void => removeFolder(rootFilePath), }], ]; describe.each(stores)('An LDP handler with auth using %s', (name, { storeUrn, setup, teardown }): void => { let handler: HttpHandler; let aclHelper: AclTestHelper; let fileHelper: FileTestHelper; beforeAll(async(): Promise => { // Set up the internal store await setup(); const variables: Record = { '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; ({ 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 => { await teardown(); }); it('can add a file to the store, read it and delete it if allowed.', async(): Promise => { // 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 => { // 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 => { // 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); }); });