mirror of
https://github.com/CommunitySolidServer/CommunitySolidServer.git
synced 2024-10-03 14:55:10 +00:00
feat: Add Content-Type constructor to metadata.
This commit is contained in:
parent
775aaa79cd
commit
be1af89b56
@ -7,7 +7,6 @@ import { TEXT_TURTLE } from '../util/ContentTypes';
|
|||||||
import { NotFoundHttpError } from '../util/errors/NotFoundHttpError';
|
import { NotFoundHttpError } from '../util/errors/NotFoundHttpError';
|
||||||
import { ensureTrailingSlash } from '../util/PathUtil';
|
import { ensureTrailingSlash } from '../util/PathUtil';
|
||||||
import { guardedStreamFrom } from '../util/StreamUtil';
|
import { guardedStreamFrom } from '../util/StreamUtil';
|
||||||
import { CONTENT_TYPE } from '../util/Vocabularies';
|
|
||||||
import { Initializer } from './Initializer';
|
import { Initializer } from './Initializer';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -67,7 +66,7 @@ export class AclInitializer extends Initializer {
|
|||||||
acl:mode acl:Control;
|
acl:mode acl:Control;
|
||||||
acl:accessTo <${this.baseUrl}>;
|
acl:accessTo <${this.baseUrl}>;
|
||||||
acl:default <${this.baseUrl}>.`;
|
acl:default <${this.baseUrl}>.`;
|
||||||
const metadata = new RepresentationMetadata(rootAcl, { [CONTENT_TYPE]: TEXT_TURTLE });
|
const metadata = new RepresentationMetadata(rootAcl, TEXT_TURTLE);
|
||||||
this.logger.debug(`Installing root ACL document at ${rootAcl.path}`);
|
this.logger.debug(`Installing root ACL document at ${rootAcl.path}`);
|
||||||
await this.store.setRepresentation(
|
await this.store.setRepresentation(
|
||||||
rootAcl,
|
rootAcl,
|
||||||
|
@ -2,12 +2,13 @@ import { DataFactory, Store } from 'n3';
|
|||||||
import type { BlankNode, Literal, NamedNode, Quad, Term } from 'rdf-js';
|
import type { BlankNode, Literal, NamedNode, Quad, Term } from 'rdf-js';
|
||||||
import { getLoggerFor } from '../../logging/LogUtil';
|
import { getLoggerFor } from '../../logging/LogUtil';
|
||||||
import { toSubjectTerm, toObjectTerm, toCachedNamedNode, isTerm } from '../../util/TermUtil';
|
import { toSubjectTerm, toObjectTerm, toCachedNamedNode, isTerm } from '../../util/TermUtil';
|
||||||
import { CONTENT_TYPE_TERM } from '../../util/Vocabularies';
|
import { CONTENT_TYPE, CONTENT_TYPE_TERM } from '../../util/Vocabularies';
|
||||||
import type { ResourceIdentifier } from './ResourceIdentifier';
|
import type { ResourceIdentifier } from './ResourceIdentifier';
|
||||||
import { isResourceIdentifier } from './ResourceIdentifier';
|
import { isResourceIdentifier } from './ResourceIdentifier';
|
||||||
|
|
||||||
export type MetadataIdentifier = ResourceIdentifier | NamedNode | BlankNode;
|
export type MetadataIdentifier = ResourceIdentifier | NamedNode | BlankNode;
|
||||||
export type MetadataOverrideValue = NamedNode | Literal | string | (NamedNode | Literal | string)[];
|
export type MetadataValue = NamedNode | Literal | string | (NamedNode | Literal | string)[];
|
||||||
|
export type MetadataRecord = Record<string, MetadataValue>;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Determines whether the object is a `RepresentationMetadata`.
|
* Determines whether the object is a `RepresentationMetadata`.
|
||||||
@ -34,23 +35,40 @@ export class RepresentationMetadata {
|
|||||||
*
|
*
|
||||||
* `@ignored` tag is necessary for Components-Generator.js
|
* `@ignored` tag is necessary for Components-Generator.js
|
||||||
*/
|
*/
|
||||||
public constructor(identifier?: MetadataIdentifier, overrides?: Record<string, MetadataOverrideValue>);
|
public constructor(identifier?: MetadataIdentifier, overrides?: MetadataRecord);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param metadata - Starts as a copy of the input metadata.
|
* @param metadata - Starts as a copy of the input metadata.
|
||||||
* @param overrides - Key/value map of extra values that need to be added to the metadata.
|
* @param overrides - Key/value map of extra values that need to be added to the metadata.
|
||||||
* Will override values that were set by the input metadata.
|
* Will override values that were set by the input metadata.
|
||||||
*/
|
*/
|
||||||
public constructor(metadata?: RepresentationMetadata, overrides?: Record<string, MetadataOverrideValue>);
|
public constructor(metadata?: RepresentationMetadata, overrides?: MetadataRecord);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param overrides - Key/value map of extra values that need to be added to the metadata.
|
* @param identifier - Identifier of the resource relevant to this metadata.
|
||||||
|
* @param contentType - Override for the content type of the representation.
|
||||||
*/
|
*/
|
||||||
public constructor(overrides?: Record<string, MetadataOverrideValue>);
|
public constructor(identifier?: MetadataIdentifier, contentType?: string);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param metadata - Starts as a copy of the input metadata.
|
||||||
|
* @param contentType - Override for the content type of the representation.
|
||||||
|
*/
|
||||||
|
public constructor(metadata?: RepresentationMetadata, contentType?: string);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param contentType - The content type of the representation.
|
||||||
|
*/
|
||||||
|
public constructor(contentType?: string);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param overrides - Metadata values (defaulting to content type if a string)
|
||||||
|
*/
|
||||||
|
public constructor(metadata?: RepresentationMetadata | MetadataRecord | string);
|
||||||
|
|
||||||
public constructor(
|
public constructor(
|
||||||
input?: MetadataIdentifier | RepresentationMetadata | Record<string, MetadataOverrideValue>,
|
input?: MetadataIdentifier | RepresentationMetadata | MetadataRecord | string,
|
||||||
overrides?: Record<string, MetadataOverrideValue>,
|
overrides?: MetadataRecord | string,
|
||||||
) {
|
) {
|
||||||
this.store = new Store();
|
this.store = new Store();
|
||||||
if (isResourceIdentifier(input)) {
|
if (isResourceIdentifier(input)) {
|
||||||
@ -66,11 +84,14 @@ export class RepresentationMetadata {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (overrides) {
|
if (overrides) {
|
||||||
|
if (typeof overrides === 'string') {
|
||||||
|
overrides = { [CONTENT_TYPE]: overrides };
|
||||||
|
}
|
||||||
this.setOverrides(overrides);
|
this.setOverrides(overrides);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private setOverrides(overrides: Record<string, MetadataOverrideValue>): void {
|
private setOverrides(overrides: Record<string, MetadataValue>): void {
|
||||||
for (const predicate of Object.keys(overrides)) {
|
for (const predicate of Object.keys(overrides)) {
|
||||||
const namedPredicate = toCachedNamedNode(predicate);
|
const namedPredicate = toCachedNamedNode(predicate);
|
||||||
this.removeAll(namedPredicate);
|
this.removeAll(namedPredicate);
|
||||||
|
@ -2,7 +2,6 @@ import type { Representation } from '../../ldp/representation/Representation';
|
|||||||
import { RepresentationMetadata } from '../../ldp/representation/RepresentationMetadata';
|
import { RepresentationMetadata } from '../../ldp/representation/RepresentationMetadata';
|
||||||
import type { ValuePreferences } from '../../ldp/representation/RepresentationPreferences';
|
import type { ValuePreferences } from '../../ldp/representation/RepresentationPreferences';
|
||||||
import { NotImplementedHttpError } from '../../util/errors/NotImplementedHttpError';
|
import { NotImplementedHttpError } from '../../util/errors/NotImplementedHttpError';
|
||||||
import { CONTENT_TYPE } from '../../util/Vocabularies';
|
|
||||||
import { matchesMediaType, matchingMediaTypes } from './ConversionUtil';
|
import { matchesMediaType, matchingMediaTypes } from './ConversionUtil';
|
||||||
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
||||||
import { RepresentationConverter } from './RepresentationConverter';
|
import { RepresentationConverter } from './RepresentationConverter';
|
||||||
@ -50,7 +49,7 @@ export class ContentTypeReplacer extends RepresentationConverter {
|
|||||||
*/
|
*/
|
||||||
public async handle({ representation, preferences }: RepresentationConverterArgs): Promise<Representation> {
|
public async handle({ representation, preferences }: RepresentationConverterArgs): Promise<Representation> {
|
||||||
const contentType = this.getReplacementType(representation.metadata.contentType, preferences.type);
|
const contentType = this.getReplacementType(representation.metadata.contentType, preferences.type);
|
||||||
const metadata = new RepresentationMetadata(representation.metadata, { [CONTENT_TYPE]: contentType });
|
const metadata = new RepresentationMetadata(representation.metadata, contentType);
|
||||||
return { ...representation, metadata };
|
return { ...representation, metadata };
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -7,7 +7,7 @@ import type { ValuePreferences } from '../../ldp/representation/RepresentationPr
|
|||||||
import { INTERNAL_QUADS } from '../../util/ContentTypes';
|
import { INTERNAL_QUADS } from '../../util/ContentTypes';
|
||||||
import { guardStream } from '../../util/GuardedStream';
|
import { guardStream } from '../../util/GuardedStream';
|
||||||
import { pipeSafely } from '../../util/StreamUtil';
|
import { pipeSafely } from '../../util/StreamUtil';
|
||||||
import { CONTENT_TYPE, PREFERRED_PREFIX_TERM } from '../../util/Vocabularies';
|
import { PREFERRED_PREFIX_TERM } from '../../util/Vocabularies';
|
||||||
import { matchingMediaTypes } from './ConversionUtil';
|
import { matchingMediaTypes } from './ConversionUtil';
|
||||||
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
||||||
import { TypedRepresentationConverter } from './TypedRepresentationConverter';
|
import { TypedRepresentationConverter } from './TypedRepresentationConverter';
|
||||||
@ -27,7 +27,7 @@ export class QuadToRdfConverter extends TypedRepresentationConverter {
|
|||||||
|
|
||||||
public async handle({ representation: quads, preferences }: RepresentationConverterArgs): Promise<Representation> {
|
public async handle({ representation: quads, preferences }: RepresentationConverterArgs): Promise<Representation> {
|
||||||
const contentType = matchingMediaTypes(preferences.type, await this.getOutputTypes())[0];
|
const contentType = matchingMediaTypes(preferences.type, await this.getOutputTypes())[0];
|
||||||
const metadata = new RepresentationMetadata(quads.metadata, { [CONTENT_TYPE]: contentType });
|
const metadata = new RepresentationMetadata(quads.metadata, contentType);
|
||||||
let data: Readable;
|
let data: Readable;
|
||||||
|
|
||||||
// Use prefixes if possible (see https://github.com/rubensworks/rdf-serialize.js/issues/1)
|
// Use prefixes if possible (see https://github.com/rubensworks/rdf-serialize.js/issues/1)
|
||||||
|
@ -5,7 +5,6 @@ import { RepresentationMetadata } from '../../ldp/representation/RepresentationM
|
|||||||
import { INTERNAL_QUADS } from '../../util/ContentTypes';
|
import { INTERNAL_QUADS } from '../../util/ContentTypes';
|
||||||
import { BadRequestHttpError } from '../../util/errors/BadRequestHttpError';
|
import { BadRequestHttpError } from '../../util/errors/BadRequestHttpError';
|
||||||
import { pipeSafely } from '../../util/StreamUtil';
|
import { pipeSafely } from '../../util/StreamUtil';
|
||||||
import { CONTENT_TYPE } from '../../util/Vocabularies';
|
|
||||||
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
import type { RepresentationConverterArgs } from './RepresentationConverter';
|
||||||
import { TypedRepresentationConverter } from './TypedRepresentationConverter';
|
import { TypedRepresentationConverter } from './TypedRepresentationConverter';
|
||||||
|
|
||||||
@ -18,7 +17,7 @@ export class RdfToQuadConverter extends TypedRepresentationConverter {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public async handle({ representation, identifier }: RepresentationConverterArgs): Promise<Representation> {
|
public async handle({ representation, identifier }: RepresentationConverterArgs): Promise<Representation> {
|
||||||
const metadata = new RepresentationMetadata(representation.metadata, { [CONTENT_TYPE]: INTERNAL_QUADS });
|
const metadata = new RepresentationMetadata(representation.metadata, INTERNAL_QUADS);
|
||||||
const rawQuads = rdfParser.parse(representation.data, {
|
const rawQuads = rdfParser.parse(representation.data, {
|
||||||
contentType: representation.metadata.contentType!,
|
contentType: representation.metadata.contentType!,
|
||||||
baseIRI: identifier.path,
|
baseIRI: identifier.path,
|
||||||
|
@ -14,7 +14,6 @@ import { NotFoundHttpError } from '../../util/errors/NotFoundHttpError';
|
|||||||
import { NotImplementedHttpError } from '../../util/errors/NotImplementedHttpError';
|
import { NotImplementedHttpError } from '../../util/errors/NotImplementedHttpError';
|
||||||
import { guardStream } from '../../util/GuardedStream';
|
import { guardStream } from '../../util/GuardedStream';
|
||||||
import type { ResourceLocker } from '../../util/locking/ResourceLocker';
|
import type { ResourceLocker } from '../../util/locking/ResourceLocker';
|
||||||
import { CONTENT_TYPE } from '../../util/Vocabularies';
|
|
||||||
import type { ResourceStore } from '../ResourceStore';
|
import type { ResourceStore } from '../ResourceStore';
|
||||||
import { PatchHandler } from './PatchHandler';
|
import { PatchHandler } from './PatchHandler';
|
||||||
|
|
||||||
@ -109,7 +108,7 @@ export class SparqlUpdatePatchHandler extends PatchHandler {
|
|||||||
this.logger.debug(`${store.size} quads will be stored to ${identifier.path}.`);
|
this.logger.debug(`${store.size} quads will be stored to ${identifier.path}.`);
|
||||||
|
|
||||||
// Write the result
|
// Write the result
|
||||||
const metadata = new RepresentationMetadata(identifier, { [CONTENT_TYPE]: INTERNAL_QUADS });
|
const metadata = new RepresentationMetadata(identifier, INTERNAL_QUADS);
|
||||||
const representation: Representation = {
|
const representation: Representation = {
|
||||||
binary: false,
|
binary: false,
|
||||||
data: guardStream(store.match() as Readable),
|
data: guardStream(store.match() as Readable),
|
||||||
|
@ -1,9 +1,6 @@
|
|||||||
import { createReadStream } from 'fs';
|
import { createReadStream } from 'fs';
|
||||||
import type { HttpHandler, Initializer, ResourceStore } from '../../src/';
|
import type { HttpHandler, Initializer, ResourceStore } from '../../src/';
|
||||||
import {
|
import { LDP, RepresentationMetadata, guardStream, joinFilePath } from '../../src/';
|
||||||
CONTENT_TYPE, LDP,
|
|
||||||
RepresentationMetadata, guardStream, joinFilePath,
|
|
||||||
} from '../../src/';
|
|
||||||
import { AclHelper, ResourceHelper } from '../util/TestHelpers';
|
import { AclHelper, ResourceHelper } from '../util/TestHelpers';
|
||||||
import { BASE, getTestFolder, createFolder, removeFolder, instantiateFromConfig } from './Config';
|
import { BASE, getTestFolder, createFolder, removeFolder, instantiateFromConfig } from './Config';
|
||||||
|
|
||||||
@ -59,7 +56,7 @@ describe.each(stores)('An LDP handler with auth using %s', (name, { storeUrn, se
|
|||||||
await store.setRepresentation({ path: `${BASE}/permanent.txt` }, {
|
await store.setRepresentation({ path: `${BASE}/permanent.txt` }, {
|
||||||
binary: true,
|
binary: true,
|
||||||
data: guardStream(createReadStream(joinFilePath(__dirname, '../assets/permanent.txt'))),
|
data: guardStream(createReadStream(joinFilePath(__dirname, '../assets/permanent.txt'))),
|
||||||
metadata: new RepresentationMetadata({ [CONTENT_TYPE]: 'text/plain' }),
|
metadata: new RepresentationMetadata('text/plain'),
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -13,7 +13,6 @@ import type { ResourceLocker } from '../../src/util/locking/ResourceLocker';
|
|||||||
import { SingleThreadedResourceLocker } from '../../src/util/locking/SingleThreadedResourceLocker';
|
import { SingleThreadedResourceLocker } from '../../src/util/locking/SingleThreadedResourceLocker';
|
||||||
import { WrappedExpiringResourceLocker } from '../../src/util/locking/WrappedExpiringResourceLocker';
|
import { WrappedExpiringResourceLocker } from '../../src/util/locking/WrappedExpiringResourceLocker';
|
||||||
import { guardedStreamFrom } from '../../src/util/StreamUtil';
|
import { guardedStreamFrom } from '../../src/util/StreamUtil';
|
||||||
import { CONTENT_TYPE } from '../../src/util/Vocabularies';
|
|
||||||
import { BASE } from './Config';
|
import { BASE } from './Config';
|
||||||
|
|
||||||
describe('A LockingResourceStore', (): void => {
|
describe('A LockingResourceStore', (): void => {
|
||||||
@ -40,7 +39,7 @@ describe('A LockingResourceStore', (): void => {
|
|||||||
store = new LockingResourceStore(source, expiringLocker);
|
store = new LockingResourceStore(source, expiringLocker);
|
||||||
|
|
||||||
// Make sure something is in the store before we read from it in our tests.
|
// Make sure something is in the store before we read from it in our tests.
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: APPLICATION_OCTET_STREAM });
|
const metadata = new RepresentationMetadata(APPLICATION_OCTET_STREAM);
|
||||||
const data = guardedStreamFrom([ 1, 2, 3 ]);
|
const data = guardedStreamFrom([ 1, 2, 3 ]);
|
||||||
await store.setRepresentation({ path }, { metadata, data, binary: true });
|
await store.setRepresentation({ path }, { metadata, data, binary: true });
|
||||||
});
|
});
|
||||||
|
@ -4,7 +4,6 @@ import { ChainedConverter } from '../../src/storage/conversion/ChainedConverter'
|
|||||||
import { QuadToRdfConverter } from '../../src/storage/conversion/QuadToRdfConverter';
|
import { QuadToRdfConverter } from '../../src/storage/conversion/QuadToRdfConverter';
|
||||||
import { RdfToQuadConverter } from '../../src/storage/conversion/RdfToQuadConverter';
|
import { RdfToQuadConverter } from '../../src/storage/conversion/RdfToQuadConverter';
|
||||||
import { guardedStreamFrom, readableToString } from '../../src/util/StreamUtil';
|
import { guardedStreamFrom, readableToString } from '../../src/util/StreamUtil';
|
||||||
import { CONTENT_TYPE } from '../../src/util/Vocabularies';
|
|
||||||
|
|
||||||
describe('A ChainedConverter', (): void => {
|
describe('A ChainedConverter', (): void => {
|
||||||
const converters = [
|
const converters = [
|
||||||
@ -14,7 +13,7 @@ describe('A ChainedConverter', (): void => {
|
|||||||
const converter = new ChainedConverter(converters);
|
const converter = new ChainedConverter(converters);
|
||||||
|
|
||||||
it('can convert from JSON-LD to turtle.', async(): Promise<void> => {
|
it('can convert from JSON-LD to turtle.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'application/ld+json' });
|
const metadata = new RepresentationMetadata('application/ld+json');
|
||||||
const representation: Representation = {
|
const representation: Representation = {
|
||||||
binary: true,
|
binary: true,
|
||||||
data: guardedStreamFrom(
|
data: guardedStreamFrom(
|
||||||
@ -34,7 +33,7 @@ describe('A ChainedConverter', (): void => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('can convert from turtle to JSON-LD.', async(): Promise<void> => {
|
it('can convert from turtle to JSON-LD.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
const representation: Representation = {
|
const representation: Representation = {
|
||||||
binary: true,
|
binary: true,
|
||||||
data: guardedStreamFrom([ '<http://test.com/s> <http://test.com/p> <http://test.com/o>.' ]),
|
data: guardedStreamFrom([ '<http://test.com/s> <http://test.com/p> <http://test.com/o>.' ]),
|
||||||
|
@ -9,7 +9,6 @@ import { RepresentationMetadata } from '../../../../src/ldp/representation/Repre
|
|||||||
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
||||||
import { NotImplementedHttpError } from '../../../../src/util/errors/NotImplementedHttpError';
|
import { NotImplementedHttpError } from '../../../../src/util/errors/NotImplementedHttpError';
|
||||||
import { guardedStreamFrom } from '../../../../src/util/StreamUtil';
|
import { guardedStreamFrom } from '../../../../src/util/StreamUtil';
|
||||||
import { CONTENT_TYPE } from '../../../../src/util/Vocabularies';
|
|
||||||
import { StaticAsyncHandler } from '../../../util/StaticAsyncHandler';
|
import { StaticAsyncHandler } from '../../../util/StaticAsyncHandler';
|
||||||
|
|
||||||
describe('A BasicResponseWriter', (): void => {
|
describe('A BasicResponseWriter', (): void => {
|
||||||
@ -28,7 +27,7 @@ describe('A BasicResponseWriter', (): void => {
|
|||||||
it('requires the input to be a binary ResponseDescription.', async(): Promise<void> => {
|
it('requires the input to be a binary ResponseDescription.', async(): Promise<void> => {
|
||||||
await expect(writer.canHandle({ response, result: new Error('error') }))
|
await expect(writer.canHandle({ response, result: new Error('error') }))
|
||||||
.rejects.toThrow(NotImplementedHttpError);
|
.rejects.toThrow(NotImplementedHttpError);
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: INTERNAL_QUADS });
|
const metadata = new RepresentationMetadata(INTERNAL_QUADS);
|
||||||
await expect(writer.canHandle({ response, result: { statusCode: 201, metadata }}))
|
await expect(writer.canHandle({ response, result: { statusCode: 201, metadata }}))
|
||||||
.rejects.toThrow(NotImplementedHttpError);
|
.rejects.toThrow(NotImplementedHttpError);
|
||||||
await expect(writer.canHandle({ response, result }))
|
await expect(writer.canHandle({ response, result }))
|
||||||
|
@ -27,11 +27,22 @@ describe('A RepresentationMetadata', (): void => {
|
|||||||
expect(metadata.identifier).toEqualRdfTerm(namedNode('identifier'));
|
expect(metadata.identifier).toEqualRdfTerm(namedNode('identifier'));
|
||||||
});
|
});
|
||||||
|
|
||||||
it('converts identifier strings to named nodes.', async(): Promise<void> => {
|
it('converts identifiers to named nodes.', async(): Promise<void> => {
|
||||||
metadata = new RepresentationMetadata({ path: 'identifier' });
|
metadata = new RepresentationMetadata({ path: 'identifier' });
|
||||||
expect(metadata.identifier).toEqualRdfTerm(namedNode('identifier'));
|
expect(metadata.identifier).toEqualRdfTerm(namedNode('identifier'));
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it('converts string to content type.', async(): Promise<void> => {
|
||||||
|
metadata = new RepresentationMetadata('text/turtle');
|
||||||
|
expect(metadata.contentType).toEqual('text/turtle');
|
||||||
|
|
||||||
|
metadata = new RepresentationMetadata({ path: 'identifier' }, 'text/turtle');
|
||||||
|
expect(metadata.contentType).toEqual('text/turtle');
|
||||||
|
|
||||||
|
metadata = new RepresentationMetadata(new RepresentationMetadata(), 'text/turtle');
|
||||||
|
expect(metadata.contentType).toEqual('text/turtle');
|
||||||
|
});
|
||||||
|
|
||||||
it('copies an other metadata object.', async(): Promise<void> => {
|
it('copies an other metadata object.', async(): Promise<void> => {
|
||||||
const other = new RepresentationMetadata({ path: 'otherId' }, { 'test:pred': 'objVal' });
|
const other = new RepresentationMetadata({ path: 'otherId' }, { 'test:pred': 'objVal' });
|
||||||
metadata = new RepresentationMetadata(other);
|
metadata = new RepresentationMetadata(other);
|
||||||
|
@ -14,7 +14,7 @@ describe('A RepresentationConvertingStore', (): void => {
|
|||||||
const convertedIn = { metadata: {}};
|
const convertedIn = { metadata: {}};
|
||||||
const convertedOut = { metadata: {}};
|
const convertedOut = { metadata: {}};
|
||||||
const inType = 'text/turtle';
|
const inType = 'text/turtle';
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
let representation: Representation;
|
let representation: Representation;
|
||||||
|
|
||||||
beforeEach(async(): Promise<void> => {
|
beforeEach(async(): Promise<void> => {
|
||||||
|
@ -32,7 +32,7 @@ describe('A FileDataAccessor', (): void => {
|
|||||||
cache = mockFs(rootFilePath, now);
|
cache = mockFs(rootFilePath, now);
|
||||||
accessor = new FileDataAccessor(new ExtensionBasedMapper(base, rootFilePath));
|
accessor = new FileDataAccessor(new ExtensionBasedMapper(base, rootFilePath));
|
||||||
|
|
||||||
metadata = new RepresentationMetadata({ [CONTENT_TYPE]: APPLICATION_OCTET_STREAM });
|
metadata = new RepresentationMetadata(APPLICATION_OCTET_STREAM);
|
||||||
|
|
||||||
data = guardedStreamFrom([ 'data' ]);
|
data = guardedStreamFrom([ 'data' ]);
|
||||||
});
|
});
|
||||||
|
@ -7,7 +7,7 @@ import { APPLICATION_OCTET_STREAM } from '../../../../src/util/ContentTypes';
|
|||||||
import { NotFoundHttpError } from '../../../../src/util/errors/NotFoundHttpError';
|
import { NotFoundHttpError } from '../../../../src/util/errors/NotFoundHttpError';
|
||||||
import type { Guarded } from '../../../../src/util/GuardedStream';
|
import type { Guarded } from '../../../../src/util/GuardedStream';
|
||||||
import { guardedStreamFrom, readableToString } from '../../../../src/util/StreamUtil';
|
import { guardedStreamFrom, readableToString } from '../../../../src/util/StreamUtil';
|
||||||
import { CONTENT_TYPE, LDP, RDF } from '../../../../src/util/Vocabularies';
|
import { LDP, RDF } from '../../../../src/util/Vocabularies';
|
||||||
|
|
||||||
describe('An InMemoryDataAccessor', (): void => {
|
describe('An InMemoryDataAccessor', (): void => {
|
||||||
const base = 'http://test.com/';
|
const base = 'http://test.com/';
|
||||||
@ -21,7 +21,7 @@ describe('An InMemoryDataAccessor', (): void => {
|
|||||||
// Create default root container
|
// Create default root container
|
||||||
await accessor.writeContainer({ path: `${base}` }, new RepresentationMetadata());
|
await accessor.writeContainer({ path: `${base}` }, new RepresentationMetadata());
|
||||||
|
|
||||||
metadata = new RepresentationMetadata({ [CONTENT_TYPE]: APPLICATION_OCTET_STREAM });
|
metadata = new RepresentationMetadata(APPLICATION_OCTET_STREAM);
|
||||||
|
|
||||||
data = guardedStreamFrom([ 'data' ]);
|
data = guardedStreamFrom([ 'data' ]);
|
||||||
});
|
});
|
||||||
|
@ -49,7 +49,7 @@ describe('A ChainedConverter', (): void => {
|
|||||||
];
|
];
|
||||||
converter = new ChainedConverter(converters);
|
converter = new ChainedConverter(converters);
|
||||||
|
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
representation = { metadata } as Representation;
|
representation = { metadata } as Representation;
|
||||||
preferences = { type: { 'internal/quads': 1 }};
|
preferences = { type: { 'internal/quads': 1 }};
|
||||||
args = { representation, preferences, identifier: { path: 'path' }};
|
args = { representation, preferences, identifier: { path: 'path' }};
|
||||||
|
@ -8,7 +8,7 @@ import type { RepresentationPreferences } from '../../../../src/ldp/representati
|
|||||||
import type { ResourceIdentifier } from '../../../../src/ldp/representation/ResourceIdentifier';
|
import type { ResourceIdentifier } from '../../../../src/ldp/representation/ResourceIdentifier';
|
||||||
import { QuadToRdfConverter } from '../../../../src/storage/conversion/QuadToRdfConverter';
|
import { QuadToRdfConverter } from '../../../../src/storage/conversion/QuadToRdfConverter';
|
||||||
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
||||||
import { CONTENT_TYPE, DC, PREFERRED_PREFIX_TERM } from '../../../../src/util/Vocabularies';
|
import { DC, PREFERRED_PREFIX_TERM } from '../../../../src/util/Vocabularies';
|
||||||
|
|
||||||
describe('A QuadToRdfConverter', (): void => {
|
describe('A QuadToRdfConverter', (): void => {
|
||||||
const converter = new QuadToRdfConverter();
|
const converter = new QuadToRdfConverter();
|
||||||
@ -16,7 +16,7 @@ describe('A QuadToRdfConverter', (): void => {
|
|||||||
let metadata: RepresentationMetadata;
|
let metadata: RepresentationMetadata;
|
||||||
|
|
||||||
beforeEach((): void => {
|
beforeEach((): void => {
|
||||||
metadata = new RepresentationMetadata({ [CONTENT_TYPE]: INTERNAL_QUADS });
|
metadata = new RepresentationMetadata(INTERNAL_QUADS);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('supports parsing quads.', async(): Promise<void> => {
|
it('supports parsing quads.', async(): Promise<void> => {
|
||||||
|
@ -11,7 +11,6 @@ import type { ResourceIdentifier } from '../../../../src/ldp/representation/Reso
|
|||||||
import { RdfToQuadConverter } from '../../../../src/storage/conversion/RdfToQuadConverter';
|
import { RdfToQuadConverter } from '../../../../src/storage/conversion/RdfToQuadConverter';
|
||||||
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
import { INTERNAL_QUADS } from '../../../../src/util/ContentTypes';
|
||||||
import { BadRequestHttpError } from '../../../../src/util/errors/BadRequestHttpError';
|
import { BadRequestHttpError } from '../../../../src/util/errors/BadRequestHttpError';
|
||||||
import { CONTENT_TYPE } from '../../../../src/util/Vocabularies';
|
|
||||||
|
|
||||||
describe('A RdfToQuadConverter', (): void => {
|
describe('A RdfToQuadConverter', (): void => {
|
||||||
const converter = new RdfToQuadConverter();
|
const converter = new RdfToQuadConverter();
|
||||||
@ -26,21 +25,21 @@ describe('A RdfToQuadConverter', (): void => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('can handle turtle to quad conversions.', async(): Promise<void> => {
|
it('can handle turtle to quad conversions.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
const representation = { metadata } as Representation;
|
const representation = { metadata } as Representation;
|
||||||
const preferences: RepresentationPreferences = { type: { [INTERNAL_QUADS]: 1 }};
|
const preferences: RepresentationPreferences = { type: { [INTERNAL_QUADS]: 1 }};
|
||||||
await expect(converter.canHandle({ identifier, representation, preferences })).resolves.toBeUndefined();
|
await expect(converter.canHandle({ identifier, representation, preferences })).resolves.toBeUndefined();
|
||||||
});
|
});
|
||||||
|
|
||||||
it('can handle JSON-LD to quad conversions.', async(): Promise<void> => {
|
it('can handle JSON-LD to quad conversions.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'application/ld+json' });
|
const metadata = new RepresentationMetadata('application/ld+json');
|
||||||
const representation = { metadata } as Representation;
|
const representation = { metadata } as Representation;
|
||||||
const preferences: RepresentationPreferences = { type: { [INTERNAL_QUADS]: 1 }};
|
const preferences: RepresentationPreferences = { type: { [INTERNAL_QUADS]: 1 }};
|
||||||
await expect(converter.canHandle({ identifier, representation, preferences })).resolves.toBeUndefined();
|
await expect(converter.canHandle({ identifier, representation, preferences })).resolves.toBeUndefined();
|
||||||
});
|
});
|
||||||
|
|
||||||
it('converts turtle to quads.', async(): Promise<void> => {
|
it('converts turtle to quads.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
const representation = {
|
const representation = {
|
||||||
data: streamifyArray([ '<http://test.com/s> <http://test.com/p> <http://test.com/o>.' ]),
|
data: streamifyArray([ '<http://test.com/s> <http://test.com/p> <http://test.com/o>.' ]),
|
||||||
metadata,
|
metadata,
|
||||||
@ -61,7 +60,7 @@ describe('A RdfToQuadConverter', (): void => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('converts JSON-LD to quads.', async(): Promise<void> => {
|
it('converts JSON-LD to quads.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'application/ld+json' });
|
const metadata = new RepresentationMetadata('application/ld+json');
|
||||||
const representation = {
|
const representation = {
|
||||||
data: streamifyArray([ '{"@id": "http://test.com/s", "http://test.com/p": { "@id": "http://test.com/o" }}' ]),
|
data: streamifyArray([ '{"@id": "http://test.com/s", "http://test.com/p": { "@id": "http://test.com/o" }}' ]),
|
||||||
metadata,
|
metadata,
|
||||||
@ -82,7 +81,7 @@ describe('A RdfToQuadConverter', (): void => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('throws an BadRequestHttpError on invalid triple data.', async(): Promise<void> => {
|
it('throws an BadRequestHttpError on invalid triple data.', async(): Promise<void> => {
|
||||||
const metadata = new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' });
|
const metadata = new RepresentationMetadata('text/turtle');
|
||||||
const representation = {
|
const representation = {
|
||||||
data: streamifyArray([ '<http://test.com/s> <http://test.com/p> <http://test.co' ]),
|
data: streamifyArray([ '<http://test.com/s> <http://test.com/p> <http://test.co' ]),
|
||||||
metadata,
|
metadata,
|
||||||
|
@ -7,7 +7,6 @@ import type { MockResponse } from 'node-mocks-http';
|
|||||||
import { createResponse } from 'node-mocks-http';
|
import { createResponse } from 'node-mocks-http';
|
||||||
import type { ResourceStore, PermissionSet, HttpHandler, HttpRequest } from '../../src/';
|
import type { ResourceStore, PermissionSet, HttpHandler, HttpRequest } from '../../src/';
|
||||||
import { guardedStreamFrom, RepresentationMetadata, joinFilePath, ensureTrailingSlash } from '../../src/';
|
import { guardedStreamFrom, RepresentationMetadata, joinFilePath, ensureTrailingSlash } from '../../src/';
|
||||||
import { CONTENT_TYPE } from '../../src/util/Vocabularies';
|
|
||||||
import { performRequest } from './Util';
|
import { performRequest } from './Util';
|
||||||
|
|
||||||
/* eslint-disable jest/no-standalone-expect */
|
/* eslint-disable jest/no-standalone-expect */
|
||||||
@ -49,7 +48,7 @@ export class AclHelper {
|
|||||||
const representation = {
|
const representation = {
|
||||||
binary: true,
|
binary: true,
|
||||||
data: guardedStreamFrom(acl),
|
data: guardedStreamFrom(acl),
|
||||||
metadata: new RepresentationMetadata({ [CONTENT_TYPE]: 'text/turtle' }),
|
metadata: new RepresentationMetadata('text/turtle'),
|
||||||
};
|
};
|
||||||
|
|
||||||
return this.store.setRepresentation(
|
return this.store.setRepresentation(
|
||||||
|
Loading…
x
Reference in New Issue
Block a user