   'TotalWages'
   'Notes'
 ]
+###
 
 fetchDb = (mongo, callback) ->
   throw new Error 'need a mongo connection'  unless mongo

csv           = require 'csv'
fs            = require 'fs'
nodePath      = require 'path'
{MongoClient} = require 'mongodb'
{daisy}       = require 'sinkrow'

{Stream} = require 'stream'

COLUMNS = [
  'RecordNumber'
  'Zipcode'

    process.nextTick -> callback null, mongo


module.exports = (options) ->
  { path, mongo, collectionName, encoding, dropFirst } = options

  path      ?= nodePath.join __dirname, '../db/zips.csv'
  encoding  ?= 'utf-8'
  dropFirst ?= yes

  stream = new Stream

