validate pdf documents

validate.js

// INSTALL DEPENDENCIES
// $> npm install osm-read

// USAGE
// $> node validate.js auckland.osm.pbf

var osmread = require('osm-read');

var nodeIds = {},
    orphanedRefIds = {};

// check filename
if( process.argv.length < 3 ){
  console.error( 'invalid filename' );
  process.exit(1);
}

// parse pbf document
osmread.parse({
  filePath: process.argv[2],
  endDocument: function(){
    var missingNodeIds = Object.keys( orphanedRefIds );
    if( missingNodeIds.length ){
      console.log( '\ntotal missing node ids: %d', missingNodeIds.length );
      process.exit(1);
    } else {
      console.log( '\nyay, no missing node ids!!' );
      process.exit(0); 
    }
  },
  bounds: function( bounds ){
    incStat( 'bounds' );
  },
  node: function( node ){
    incStat( 'node' );
    nodeIds[ node.id ] = true;
  },
  way: function( way ){
    incStat( 'way' );
    way.nodeRefs.forEach( function( nodeRefId ){
      if( !nodeIds.hasOwnProperty( nodeRefId ) ){ // referenced node not found in this document
        orphanedRefIds[ nodeRefId ] = true;
        // console.log( 'missing referenced node id: %s', nodeRefId );
      }
    });
  },
  error: function( msg ){
    incStat( 'error' );
    console.error( 'error: ' + msg );
  }
});

// live import stats
var stats = {};

function incStat( type ){
  if( !stats.hasOwnProperty( type ) ){ stats[type] = 0; }
  stats[type]++;
}

function writeStats(){
  process.stderr.clearLine();  // clear current text
  process.stderr.cursorTo(0);
  process.stderr.write( JSON.stringify( stats ) );
}

setInterval( writeStats, 100 );