Fabio/tileserver-gl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: update syntax, use inbuilt buffer funcs

Browse source 
Signed-off-by: Andrew Calcutt <acalcutt@techidiots.net>
This commit is contained in:
Andrew Calcutt 2023-10-13 09:57:02 -04:00
parent a24a48bd1e
commit d95e8a1f89
1 changed files with 10 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
src/pmtiles_adapter.js
View file

@ -2,7 +2,7 @@ import fs from 'node:fs';
import PMTiles from 'pmtiles';
import { isValidHttpUrl } from './utils.js';
const PMTilesFileSource = class {
class PMTilesFileSource {
constructor(fd) {
this.fd = fd;
}
@ -12,11 +12,12 @@ const PMTilesFileSource = class {
async getBytes(offset, length) {
const buffer = Buffer.alloc(length);
await ReadFileBytes(this.fd, buffer, offset);
return { data: BufferToArrayBuffer(buffer) };
const ab = buffer.buffer.slice(buffer.byteOffset, buffer.byteOffset + buffer.byteLength)
return { data: ab };
}
};
const ReadFileBytes = async (fd, buffer, offset) => {
async function ReadFileBytes(fd, buffer, offset) {
return new Promise((resolve, reject) => {
fs.read(fd, buffer, 0, buffer.length, offset, (err) => {
if (err) {
@ -27,7 +28,7 @@ const ReadFileBytes = async (fd, buffer, offset) => {
});
};
export const PMtilesOpen = (FilePath) => {
export function PMtilesOpen(FilePath) {
let pmtiles = undefined;
let fd = undefined;
@ -42,11 +43,11 @@ export const PMtilesOpen = (FilePath) => {
return { pmtiles: pmtiles, fd: fd };
};
export const PMtilesClose = (fd) => {
export function PMtilesClose(fd) {
fs.closeSync(fd);
};
export const GetPMtilesInfo = async (pmtiles) => {
export async function GetPMtilesInfo(pmtiles) {
const header = await pmtiles.getHeader();
const metadata = await pmtiles.getMetadata();
@ -83,19 +84,19 @@ export const GetPMtilesInfo = async (pmtiles) => {
return metadata;
};
export const GetPMtilesTile = async (pmtiles, z, x, y) => {
export async function GetPMtilesTile(pmtiles, z, x, y) {
const header = await pmtiles.getHeader();
const TileType = GetPmtilesTileType(header.tileType);
let zxyTile = await pmtiles.getZxy(z, x, y);
if (zxyTile && zxyTile.data) {
zxyTile = ArrayBufferToBuffer(zxyTile.data);
zxyTile = Buffer.from(zxyTile.data);
} else {
zxyTile = undefined;
}
return { data: zxyTile, header: TileType.header };
};
const GetPmtilesTileType = (typenum) => {
function GetPmtilesTileType(typenum) {
let head = {};
let tileType;
switch (typenum) {
@ -125,21 +126,3 @@ const GetPmtilesTileType = (typenum) => {
}
return { type: tileType, header: head };
};
const BufferToArrayBuffer = (buffer) => {
const arrayBuffer = new ArrayBuffer(buffer.length);
const view = new Uint8Array(arrayBuffer);
for (let i = 0; i < buffer.length; ++i) {
view[i] = buffer[i];
}
return arrayBuffer;
};
const ArrayBufferToBuffer = (array_buffer) => {
var buffer = Buffer.alloc(array_buffer.byteLength);
var view = new Uint8Array(array_buffer);
for (var i = 0; i < buffer.length; ++i) {
buffer[i] = view[i];
}
return buffer;
};