mirrors/PMTiles
1
0
Fork 0
mirror of https://github.com/protomaps/PMTiles.git synced 2026-02-04 10:51:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

cloudflare uses native decompression

Browse Source
This commit is contained in:
Brandon Liu
2022-11-14 22:05:46 +08:00
parent 5de95b8fbe
commit 91ddf2e913
1 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
serverless/cloudflare/src/index.ts
View File

@@ -10,6 +10,7 @@ import {
RangeResponse, RangeResponse,
ResolvedValueCache, ResolvedValueCache,
TileType, TileType,
Compression,
} from "../../../js"; } from "../../../js";
interface Env { interface Env {
@@ -66,7 +67,22 @@ export const tile_path = (
return { ok: false, name: "", tile: [0, 0, 0], ext: "" }; return { ok: false, name: "", tile: [0, 0, 0], ext: "" };
}; };
const CACHE = new ResolvedValueCache(); async function nativeDecompress(
buf: ArrayBuffer,
compression: Compression
): Promise<ArrayBuffer> {
if (compression === Compression.None || compression === Compression.Unknown) {
return buf;
} else if (compression === Compression.Gzip) {
let stream = new Response(buf).body!;
let result = stream.pipeThrough(new DecompressionStream("gzip"));
return new Response(result).arrayBuffer();
} else {
throw Error("Compression method not supported");
}
}
const CACHE = new ResolvedValueCache(undefined, undefined, nativeDecompress);
class R2Source implements Source { class R2Source implements Source {
env: Env; env: Env;
@@ -157,7 +173,7 @@ export default {
const cacheable_headers = new Headers(); const cacheable_headers = new Headers();
const source = new R2Source(env, name); const source = new R2Source(env, name);
const p = new PMTiles(source, CACHE); const p = new PMTiles(source, CACHE, nativeDecompress);
try { try {
const p_header = await p.getHeader(); const p_header = await p.getHeader();
if (tile[0] < p_header.minZoom || tile[0] > p_header.maxZoom) { if (tile[0] < p_header.minZoom || tile[0] > p_header.maxZoom) {