chore: bumped geo-pixel-stream to gdal-async branch

lib/hooks/hooks.geojson.js

@@ -48,11 +48,11 @@ export function readSequentialGeoJson (options = {}) {
 
     await new Promise((resolve, reject) => {
       rl
-      .on('line', (line) => {
-        json.push(JSON.parse(line))
-      })
-      .on('close', resolve)
-      .on('error', reject)
+        .on('line', (line) => {
+          json.push(JSON.parse(line))
+        })
+        .on('close', resolve)
+        .on('error', reject)
     })
     // Allow transform after read
     if (options.transform) json = transformJsonObject(json, options.transform)

lib/hooks/hooks.mongo.js

@@ -19,7 +19,6 @@ async function dropIndex (collection, collectionName, index) {
     // If index does not exist we do not raise
     if (error instanceof MongoError && error.code === 27) {
       debug(collectionName + ' collection index does not exist, skipping drop')
-      return
     } else {
       // Rethrow
       throw error
@@ -40,7 +39,6 @@ async function createIndex (collection, collectionName, index) {
     // If index already exists with different options we do not raise
     if (error instanceof MongoError && error.code === 85) {
       debug(collectionName + ' collection index does already exist with different options, skipping create')
-      return
     } else {
       // Rethrow
       throw error
@@ -145,12 +143,12 @@ export function createMongoCollection (options = {}) {
     }
     // Add index if required
     if (options.index) {
-      await createIndex (collection, collectionName, options.index)
+      await createIndex(collection, collectionName, options.index)
     } else if (options.indices) { // Or multiple indices
       // As arguments or single object ?
       for (let i = 0; i < options.indices.length; i++) {
         const index = options.indices[i]
-        await createIndex (collection, collectionName, index)
+        await createIndex(collection, collectionName, index)
       }
     }
     return hook
@@ -168,7 +166,7 @@ export function dropMongoIndex (options = {}) {
 
     const collectionName = template(item, _.get(options, 'collection', _.snakeCase(item.id)))
     // Check if already exist (strict mode requires a callback)
-    let collection = await new Promise((resolve, reject) => {
+    const collection = await new Promise((resolve, reject) => {
       client.db.collection(collectionName, { strict: true }, (error, collection) => {
         // If it does not exist we will create it
         if (error) resolve(null)
@@ -181,11 +179,11 @@ export function dropMongoIndex (options = {}) {
     }
     // Drop index if required
     if (options.index) {
-      await dropIndex (collection, collectionName, options.index)
+      await dropIndex(collection, collectionName, options.index)
     } else if (options.indices) { // Or multiple indices
       for (let i = 0; i < options.indices.length; i++) {
         const index = options.indices[i]
-        await dropIndex (collection, collectionName, index)
+        await dropIndex(collection, collectionName, index)
       }
     }
     return hook
@@ -203,7 +201,7 @@ export function createMongoIndex (options = {}) {
 
     const collectionName = template(item, _.get(options, 'collection', _.snakeCase(item.id)))
     // Check if already exist (strict mode requires a callback)
-    let collection = await new Promise((resolve, reject) => {
+    const collection = await new Promise((resolve, reject) => {
       client.db.collection(collectionName, { strict: true }, (error, collection) => {
         // If it does not exist we will create it
         if (error) resolve(null)
@@ -217,11 +215,11 @@ export function createMongoIndex (options = {}) {
     }
     // Add index if required
     if (options.index) {
-      await createIndex (collection, collectionName, options.index)
+      await createIndex(collection, collectionName, options.index)
     } else if (options.indices) { // Or multiple indices
       for (let i = 0; i < options.indices.length; i++) {
         const index = options.indices[i]
-        await createIndex (collection, collectionName, index)
+        await createIndex(collection, collectionName, index)
       }
     }
     return hook

lib/hooks/hooks.raster.js

@@ -2,7 +2,7 @@ import path from 'path'
 import _ from 'lodash'
 import makeDebug from 'debug'
 import gtif from '@kalisio/geo-pixel-stream'
-import gdal from 'gdal-next'
+import gdal from 'gdal-async'
 import { getStoreFromHook } from '../utils.js'
 
 const debug = makeDebug('krawler:hooks:raster')

lib/hooks/index.js

@@ -181,7 +181,7 @@ export function activateHooks (serviceHooks, service) {
 }
 
 export function insertHookBefore (insertionHookName, hooksDefinition, insertedHookName, insertedHookOptions) {
-  let newHooksDefinition = {}
+  const newHooksDefinition = {}
   // Need to create a new definition object as key insertion order matters
   _.forOwn(hooksDefinition, (hookOptions, hookName) => {
     if (hookName === insertionHookName) {
@@ -193,7 +193,7 @@ export function insertHookBefore (insertionHookName, hooksDefinition, insertedHo
 }
 
 export function insertHookAfter (insertionHookName, hooksDefinition, insertedHookName, insertedHookOptions) {
-  let newHooksDefinition = {}
+  const newHooksDefinition = {}
   // Need to create a new definition object as key insertion order matters
   _.forOwn(hooksDefinition, (hookOptions, hookName) => {
     newHooksDefinition[hookName] = hookOptions

package.json

@@ -60,7 +60,7 @@
     "@feathersjs/feathers": "^5.0.8",
     "@feathersjs/socketio": "^5.0.8",
     "@kalisio/feathers-distributed": "^2.4.0",
-    "@kalisio/geo-pixel-stream": "https://github.com/kalisio/geo-pixel-stream#next",
+    "@kalisio/geo-pixel-stream": "https://github.com/kalisio/geo-pixel-stream#gdal-async",
     "@mapbox/sphericalmercator": "^1.0.5",
     "@tmcw/togeojson": "^5.2.1",
     "@turf/turf": "6.2.0-alpha.3",

test/hooks.utils.js

@@ -159,7 +159,7 @@ describe('krawler:hooks:utils', () => {
   }
 
   it('insert hook before', () => {
-    let newHookDefinitions = pluginHooks.insertHookBefore('convertToGeoJson', hookDefinitions, 'transformJson', {})
+    const newHookDefinitions = pluginHooks.insertHookBefore('convertToGeoJson', hookDefinitions, 'transformJson', {})
     let index = 0
     _.forOwn(newHookDefinitions, (hookOptions, hookName) => {
       if (index === 0) expect(hookName).to.equal('readJson')
@@ -170,7 +170,7 @@ describe('krawler:hooks:utils', () => {
   })
 
   it('insert hook after', () => {
-    let newHookDefinitions = pluginHooks.insertHookAfter('readJson', hookDefinitions, 'transformJson', {})
+    const newHookDefinitions = pluginHooks.insertHookAfter('readJson', hookDefinitions, 'transformJson', {})
     let index = 0
     _.forOwn(newHookDefinitions, (hookOptions, hookName) => {
       if (index === 0) expect(hookName).to.equal('readJson')