55 lines
1.8 KiB
TypeScript
55 lines
1.8 KiB
TypeScript
/*
|
|
Copyright 2021 The CloudEvents Authors
|
|
SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
import Ajv from "ajv";
|
|
import { ValidationError, isBase64 } from "./validation";
|
|
|
|
import { CloudEventV1, CloudEventV03 } from "./interfaces";
|
|
import { schemaV03, schemaV1 } from "./schemas";
|
|
import { Version } from "./cloudevent";
|
|
import CONSTANTS from "../constants";
|
|
|
|
const ajv = new Ajv({ extendRefs: true });
|
|
|
|
// handle date-time format specially because a user could pass
|
|
// Date().toString(), which is not spec compliant date-time format
|
|
ajv.addFormat("js-date-time", function (dateTimeString) {
|
|
const date = new Date(Date.parse(dateTimeString));
|
|
return date.toString() !== "Invalid Date";
|
|
});
|
|
|
|
const isValidAgainstSchemaV1 = ajv.compile(schemaV1);
|
|
const isValidAgainstSchemaV03 = ajv.compile(schemaV03);
|
|
|
|
export function validateCloudEvent(event: CloudEventV03 | CloudEventV1): boolean {
|
|
if (event.specversion === Version.V1) {
|
|
if (!isValidAgainstSchemaV1(event)) {
|
|
throw new ValidationError("invalid payload", isValidAgainstSchemaV1.errors);
|
|
}
|
|
return true;
|
|
} else if (event.specversion === Version.V03) {
|
|
if (!isValidAgainstSchemaV03(event)) {
|
|
throw new ValidationError("invalid payload", isValidAgainstSchemaV03.errors);
|
|
}
|
|
return checkDataContentEncoding(event);
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function checkDataContentEncoding(event: CloudEventV03): boolean {
|
|
if (event.datacontentencoding) {
|
|
// we only support base64
|
|
const encoding = event.datacontentencoding.toLocaleLowerCase();
|
|
if (encoding !== CONSTANTS.ENCODING_BASE64) {
|
|
throw new ValidationError("invalid payload", [`Unsupported content encoding: ${encoding}`]);
|
|
} else {
|
|
if (!isBase64(event.data)) {
|
|
throw new ValidationError("invalid payload", [`Invalid content encoding of data: ${event.data}`]);
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|