Refactor toGeoJson to accept an options object with file prop

Author: platypii

demo/demo.js

@@ -17,8 +17,8 @@ window.initMap = async function loadGeoParquet() {
 
   try {
     // Read the GeoParquet file and convert to GeoJSON
-    const asyncBuffer = await asyncBufferFromUrl({ url: parquetUrl })
-    const geojson = await toGeoJson(asyncBuffer)
+    const file = await asyncBufferFromUrl({ url: parquetUrl })
+    const geojson = await toGeoJson({ file })
 
     console.log('GeoJSON:', geojson)
 

src/toGeoJson.js

@@ -8,11 +8,12 @@ import { decodeWKB } from './wkb.js'
  *
  * @import { AsyncBuffer } from 'hyparquet'
  * @import { Feature, GeoJSON } from './geojson.js'
- * @param {AsyncBuffer} asyncBuffer 
+ * @param {Object} options
+ * @param {AsyncBuffer} options.file 
  * @returns {Promise<GeoJSON>}
  */
-export async function toGeoJson(asyncBuffer) {
-  const metadata = await parquetMetadataAsync(asyncBuffer)
+export async function toGeoJson({ file }) {
+  const metadata = await parquetMetadataAsync(file)
   const geoMetadata = metadata.key_value_metadata?.find(kv => kv.key === 'geo')
   if (!geoMetadata) {
     throw new Error('Invalid GeoParquet file: missing "geo" metadata')
@@ -22,7 +23,7 @@ export async function toGeoJson(asyncBuffer) {
   const geoSchema = JSON.parse(geoMetadata.value || '{}')
 
   // Read all parquet data
-  const data = await parquetQuery({ file: asyncBuffer, utf8: false })
+  const data = await parquetQuery({ file, utf8: false })
 
   /** @type {Feature[]} */
   const features = []

test/toGeoJson.test.js

@@ -6,14 +6,14 @@ import polys from '../examples/polys.json' with { type: 'json' }
 
 describe('toGeoJson', () => {
   it('should parse example.parquet', async () => {
-    const asyncBuffer = await asyncBufferFromFile('examples/example.parquet')
-    const geojson = await toGeoJson(asyncBuffer)
+    const file = await asyncBufferFromFile('examples/example.parquet')
+    const geojson = await toGeoJson({ file })
     expect(geojson).toEqual(example)
   })
 
   it('should parse polys.parquet', async () => {
-    const asyncBuffer = await asyncBufferFromFile('examples/polys.parquet')
-    const geojson = await toGeoJson(asyncBuffer)
+    const file = await asyncBufferFromFile('examples/polys.parquet')
+    const geojson = await toGeoJson({ file })
     expect(geojson).toEqual(polys)
   })
 })