Finds all .json freeswitch cdrs in the current directory and posts them to local couchdb.

freeswitch_json_to_couch.rb

#!/usr/bin/env ruby
require 'rubygems' unless defined?(Gem)
require 'json'
require 'pry'


require 'net/http'

module Couch

  class Server
    def initialize(host, port, options = nil)
      @host = host
      @port = port
      @options = options
    end

    def delete(uri)
      request(Net::HTTP::Delete.new(uri))
    end

    def get(uri)
      request(Net::HTTP::Get.new(uri))
    end

    def put(uri, json)
      req = Net::HTTP::Put.new(uri)
      req["content-type"] = "application/json"
      req.body = json
      request(req)
    end

    def post(uri, json)
      req = Net::HTTP::Post.new(uri)
      req["content-type"] = "application/json"
      req.body = json
      request(req)
    end

    def request(req)
      res = Net::HTTP.start(@host, @port) { |http|http.request(req) }
      unless res.kind_of?(Net::HTTPSuccess)
        handle_error(req, res)
      end
      res
    end

    private

    def handle_error(req, res)
      e = RuntimeError.new("#{res.code}:#{res.message}\nMETHOD:#{req.method}\nURI:#{req.path}\n#{res.body}")
      raise e
    end
  end
end


filenames = Dir.glob("*.json")

DB_NAME = 'freeswitch_cdrs'

server = Couch::Server.new("localhost", "5984")
server.delete("/#{DB_NAME}")
server.put("/#{DB_NAME}/", "")

filenames.each_with_index do |file,i|
  contents = File.read(file)
  hash = JSON.parse(contents)

  uuid = hash["variables"]["uuid"]
  contents = hash["variables"].to_json
  puts "#{i} #{uuid}"
  server.put("/#{DB_NAME}/#{uuid}", contents)

end