osm-tools/fileformat.proto.js at master · arijs/osm-tools · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
'use strict'; // hand-written readers for OSMPBF fileformat (pbf-compatible)

var Pbf = require('pbf');

// BlobHeader ========================================

var BlobHeader = exports.BlobHeader = {};

BlobHeader.read = function (pbf, end) {
	return pbf.readFields(
		BlobHeader._readField,
		{ type: '', indexdata: null, datasize: 0 },
		end
	);
};
BlobHeader._readField = function (tag, obj, pbf) {
	if (tag === 1) obj.type = pbf.readString();
	else if (tag === 2) obj.indexdata = pbf.readBytes();
	else if (tag === 3) obj.datasize = pbf.readVarint(true);
};
BlobHeader.write = function (obj, pbf) {
	if (obj.type) pbf.writeStringField(1, obj.type);
	if (obj.indexdata) pbf.writeBytesField(2, obj.indexdata);
	if (obj.datasize) pbf.writeVarintField(3, obj.datasize);
};

// Blob ========================================

var Blob = exports.Blob = {};

Blob.read = function (pbf, end) {
	return pbf.readFields(
		Blob._readField,
		{
			raw_size: 0,
			raw: null,
			zlib_data: null,
			lzma_data: null,
			OBSOLETE_bzip2_data: null,
			lz4_data: null,
			zstd_data: null
		},
		end
	);
};
Blob._readField = function (tag, obj, pbf) {
	if (tag === 1) obj.raw = pbf.readBytes();
	else if (tag === 2) obj.raw_size = pbf.readVarint(true);
	else if (tag === 3) obj.zlib_data = pbf.readBytes();
	else if (tag === 4) obj.lzma_data = pbf.readBytes();
	else if (tag === 5) obj.OBSOLETE_bzip2_data = pbf.readBytes();
	else if (tag === 6) obj.lz4_data = pbf.readBytes();
	else if (tag === 7) obj.zstd_data = pbf.readBytes();
};
Blob.write = function (obj, pbf) {
	if (obj.raw) pbf.writeBytesField(1, obj.raw);
	if (obj.raw_size) pbf.writeVarintField(2, obj.raw_size);
	if (obj.zlib_data) pbf.writeBytesField(3, obj.zlib_data);
	if (obj.lzma_data) pbf.writeBytesField(4, obj.lzma_data);
	if (obj.OBSOLETE_bzip2_data) pbf.writeBytesField(5, obj.OBSOLETE_bzip2_data);
	if (obj.lz4_data) pbf.writeBytesField(6, obj.lz4_data);
	if (obj.zstd_data) pbf.writeBytesField(7, obj.zstd_data);
};

exports.readBlobHeader = function (buf) {
	return BlobHeader.read(new Pbf(buf));
};
exports.readBlob = function (buf) {
	return Blob.read(new Pbf(buf));
};