R2 API (#355)

*  R2 API

packages/miniflare/src/plugins/r2/errors.ts

@@ -0,0 +1,174 @@
+import { Response } from "undici";
+import { R2Object } from "./r2Object";
+import { CfHeader } from "./router";
+
+enum Status {
+	BadRequest = 400,
+	NotFound = 404,
+	PreconditionFailed = 412,
+	RangeNotSatisfiable = 416,
+	InternalError = 500,
+}
+enum CfCode {
+	InternalError = 10001,
+	NoSuchObjectKey = 10007,
+	EntityTooLarge = 100100,
+	InvalidDigest = 10014,
+	InvalidObjectName = 10020,
+	InvalidMaxKeys = 10022,
+	InvalidArgument = 10029,
+	PreconditionFailed = 10031,
+	BadDigest = 10037,
+	InvalidRange = 10039,
+}
+
+export class R2Error extends Error {
+	status: number;
+	v4Code: number;
+	object?: R2Object;
+	constructor(status: number, message: string, v4Code: number) {
+		super(message);
+		this.name = "R2Error";
+		this.status = status;
+		this.v4Code = v4Code;
+	}
+
+	toResponse() {
+		if (this.object !== undefined) {
+			const { metadataSize, value } = this.object.encode();
+			return new Response(value, {
+				status: this.status,
+				headers: {
+					[CfHeader.MetadataSize]: `${metadataSize}`,
+					"Content-Type": "application/json",
+					[CfHeader.Error]: JSON.stringify({
+						message: this.message,
+						version: 1,
+						// Note the lowercase 'c', which the runtime expects
+						v4code: this.v4Code,
+					}),
+				},
+			});
+		}
+		return new Response(null, {
+			status: this.status,
+			headers: {
+				[CfHeader.Error]: JSON.stringify({
+					message: this.message,
+					version: 1,
+					// Note the lowercase 'c', which the runtime expects
+					v4code: this.v4Code,
+				}),
+			},
+		});
+	}
+
+	context(info: string) {
+		this.message += ` (${info})`;
+		return this;
+	}
+
+	attach(object: R2Object) {
+		this.object = object;
+		return this;
+	}
+}
+
+export class InvalidMetadata extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"Metadata missing or invalid",
+			CfCode.InvalidArgument
+		);
+	}
+}
+
+export class InternalError extends R2Error {
+	constructor() {
+		super(
+			Status.InternalError,
+			"We encountered an internal error. Please try again.",
+			CfCode.InternalError
+		);
+	}
+}
+export class NoSuchKey extends R2Error {
+	constructor() {
+		super(
+			Status.NotFound,
+			"The specified key does not exist.",
+			CfCode.NoSuchObjectKey
+		);
+	}
+}
+
+export class EntityTooLarge extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"Your proposed upload exceeds the maximum allowed object size.",
+			CfCode.EntityTooLarge
+		);
+	}
+}
+
+export class InvalidDigest extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"The Content-MD5 you specified is not valid.",
+			CfCode.InvalidDigest
+		);
+	}
+}
+
+export class BadDigest extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"The Content-MD5 you specified did not match what we received.",
+			CfCode.BadDigest
+		);
+	}
+}
+
+export class InvalidObjectName extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"The specified object name is not valid.",
+			CfCode.InvalidObjectName
+		);
+	}
+}
+
+export class InvalidMaxKeys extends R2Error {
+	constructor() {
+		super(
+			Status.BadRequest,
+			"MaxKeys params must be positive integer <= 1000.",
+			CfCode.InvalidMaxKeys
+		);
+	}
+}
+
+export class PreconditionFailed extends R2Error {
+	constructor() {
+		super(
+			Status.PreconditionFailed,
+			"At least one of the pre-conditions you specified did not hold.",
+			CfCode.PreconditionFailed
+		);
+	}
+}
+
+export class InvalidRange extends R2Error {
+	constructor() {
+		super(
+			Status.RangeNotSatisfiable,
+			"The requested range is not satisfiable",
+			CfCode.InvalidRange
+		);
+	}
+}