flimshaw

'use strict';
var fs = require('fs')
  , csv = require('fast-csv')
  , sqlite3 = require('sqlite3').verbose()
  , db = new sqlite3.Database('./data/gaia.sqlite');

var fields = ['ra', 'dec', 'parallax', 'phot_g_mean_mag'];
var headers = ['solution_id','source_id','random_index','ref_epoch','ra','ra_error','dec','dec_error','parallax','parallax_error','pmra','pmra_error','pmdec','pmdec_error','ra_dec_corr','ra_parallax_corr','ra_pmra_corr','ra_pmdec_corr','dec_parallax_corr','dec_pmra_corr','dec_pmdec_corr','parallax_pmra_corr','parallax_pmdec_corr','pmra_pmdec_corr','astrometric_n_obs_al','astrometric_n_obs_ac','astrometric_n_good_obs_al','astrometric_n_good_obs_ac','astrometric_n_bad_obs_al','astrometric_n_bad_obs_ac','astrometric_delta_q','astrometric_excess_noise','astrometric_excess_noise_sig','astrometric_primary_flag','astrometric_relegation_factor','astrometric_weight_al','astrometric_weight_ac','astrometric_priors_used','matched_observations','duplicated_source','scan_direction_strength_k1','scan_dire

flimshaw

var http = require('http')

class HttpStore {

  constructor(storeUrl) {
    
    // begin downloading the url we requested, stream it to our handleData function
    http.get(storeUrl, (res) => {
      res.on('data', this.handleData.bind(this))
      res.on('end', this.handleEnd.bind(this))