Reads a 23andme genome download into redis

genome.coffee

fs = require 'fs'
path = require 'path'
redis = require('redis').createClient()

multi = redis.multi()
console.log 'Reading...'

fileName = process.argv.slice(-1)[0]
filePath = path.join process.cwd, fileName
fileStream = fs.createReadStream filePath
fileStream.on 'data', (data) ->
  data.toString().split('\r\n').forEach (line) ->
    if /^\s*#/.test line or not line
      return
    [rsid, chromosome, position, genotype] = line.split '\t'
    unless rsid and chromosome and position and genotype
      return
    multi.zadd "genome:#{chromosome}", position, "#{rsid}:#{genotype}", (err) ->
      console.error err.message, rsid, chromosome, position, genotype

fileStream.on 'end', ->
  console.log 'Done. Writing...'
  multi.exec (err) -> console.log "Done. #{err?.message}"

fileStream.on 'error', (err) ->
  console.error err.message