class Dozens

# File lib/dozens_jp_cli.rb, line 11
def initialize(user,auth_key)
    @user = user
    @auth_key = auth_key
    @ua = Mechanize.new
end

# File lib/dozens_jp_cli.rb, line 150
def address_is_changed?(record_id_or_name,content=nil)
    ## TODO dns round robin
    record_name = ( record_id_or_name =~ /\d+/ ) ? self.record_name(record_id_or_name): record_id_or_name
    current_dns_result = Resolv.getaddresses(record_name)
    if current_dns_result 
      current_dns_result = current_dns_result.first
    end
    replace_content   = (content) ? content : self.current_global_ip
    return current_dns_result != replace_content
end

# File lib/dozens_jp_cli.rb, line 45
def auth_token
    if @auth_token && @expires && @expires > Time.now then
        return @auth_token
    end

    uri = API_BASE_URI+"/authorize.json"
    self.get(uri ,{"X-Auth-User"=>@user,"X-Auth-Key"=>@auth_key})

    @auth_token = JSON.parse(ua.page.body)["auth_token"]
    @expires = Time.now+60*60*24
    @auth_token
end

# File lib/dozens_jp_cli.rb, line 161
def current_global_ip
    url = "http://myexternalip.com/json"
    ret = self.get(url,{},[])
    ret = JSON.parse(ret)["ip"]
end

# File lib/dozens_jp_cli.rb, line 22
def delete(uri,header=nil,params={})
    self.request(:delete,uri,header,params)
end

# File lib/dozens_jp_cli.rb, line 99
def find_record_id(name)
    ## TODO dns round robin
    zone = self.zone_list.find{|e| 
        name =~/#{e["name"]}/
    }
    return nil unless zone
    record = self.record_list(zone["name"]).find{|e|
        name =~/#{e["name"]}/
    }
    return nil unless record
    record["id"]
end

# File lib/dozens_jp_cli.rb, line 79
def find_zone_id(name)
    zone = self.zone_list.find{|e| 
        name =~/#{e["name"]}/
    }
    return nil unless zone
    return zone["id"]
end

# File lib/dozens_jp_cli.rb, line 16
def get(uri,header=nil,params=[])
    self.request(:get,uri,header,params)
end

# File lib/dozens_jp_cli.rb, line 19
def post(uri,header=nil,params=[])
    self.request(:post,uri,header,params)
end

# File lib/dozens_jp_cli.rb, line 119
def record_create(name,zone,content=nil,type="A",prio=10,ttl=7200)
    if name =~/#{zone}/ then
        name = name.gsub(/\.#{zone}/,"" )
    end
    content ||= self.current_global_ip
    raise unless self.zone_exists? zone

    param = { 
        domain: zone,
        name: name,
        type: type,
        prio: prio,
        content: content,
        ttl: ttl,
    }.to_json

    url = API_BASE_URI+"/record/create.json"
    self.post(url,nil,param)
    

        
end

# File lib/dozens_jp_cli.rb, line 114
def record_delete(name_or_id)
    record_id = ( name_or_id =~ /\d+/ ) ? name_or_id : self.find_record_id(name_or_id)
    url = API_BASE_URI+"/record/delete/#{record_id}.json"
    self.delete(url)
end

# File lib/dozens_jp_cli.rb, line 111
def record_exists?(record_name)
    self.find_record_id(record_name)!=nil
end

# File lib/dozens_jp_cli.rb, line 74
def record_list(zone_name)
    uri = API_BASE_URI+"/record/#{zone_name}.json"
    ret = self.get(uri)
    @records = JSON.parse(ret)["record"]
end

# File lib/dozens_jp_cli.rb, line 89
def record_name(id)
    ## TODO dns round robin
    zone = self.zone_list.each{|zone| 
      record = self.record_list(zone["name"]).each{|record|
        return record["name"] if record['id'] == id 
      }
    }
    return nil
end

# File lib/dozens_jp_cli.rb, line 141
def record_update(record_id_or_name,prio=10,content=nil,ttl=7200,force=false)
    ## TODO dns round robin
    record_id = ( record_id_or_name =~ /\d+/ ) ? record_id_or_name : self.find_record_id(record_id_or_name)
    content = self.current_global_ip unless content 
    params = {"prio"=>prio,"content"=>content,"ttl"=>ttl}.to_json
    url = API_BASE_URI+"/record/update/#{record_id}.json"
    ret = self.post(url,nil,params)
    JSON.parse(ret)["record"]
end

# File lib/dozens_jp_cli.rb, line 25
def request(method,uri,header=nil,params=[])
    header = {"X-Auth-Token"=> self.auth_token } if header.nil?
    begin
        if method == :get then
            ua.get(uri, params,nil,header)  
        end

        if method == :post then
            header["Content-type"] = "application/json"
            ua.post(uri,params,header) 
        end
        if method == :delete then
            ua.delete(uri,params,header)
        end

    rescue =>e
        raise e
    end
    ua.page.body
end

# File lib/dozens_jp_cli.rb, line 63
def zone_create_new(name,email)
    params_str = {name:name, mailaddress:email, add_google_apps:false}.to_json
    url = API_BASE_URI+"/zone/create.json"
    self.post(url,nil,params_str)
end

# File lib/dozens_jp_cli.rb, line 58
def zone_delete(name_or_id)
    zone_id = ( name_or_id =~ /\d+/ ) ? name_or_id : self.find_zone_id(name_or_id)
    url = API_BASE_URI+"/zone/delete/#{zone_id}.json"
    self.delete(url)
end

# File lib/dozens_jp_cli.rb, line 86
def zone_exists?(name)
    self.find_zone_id(name)!=nil
end

# File lib/dozens_jp_cli.rb, line 69
def zone_list
     uri = API_BASE_URI+"/zone.json"
     ret = self.get(uri)
     @domains = JSON.parse(ret)["domain"]
end