# encoding: utf-8

require 'mechanize'
require 'zip/zip'
require 'savon'

module Oddb2xml
  class Downloader
    def initialize(url=nil)
      @url         = url
      @retry_times = 3
      HTTPI.log = false # disable httpi warning
      init
    end
    def init
      @agent = Mechanize.new
      @agent.user_agent = 'Mozilla/5.0 (X11; Linux x86_64; rv:16.0) Gecko/20100101 Firefox/16.0'
      @agent.redirect_ok         = true
      @agent.redirection_limit   = 5
      @agent.follow_meta_refresh = true
    end
    protected
    def retrievable?
      if @retry_times > 0
        sleep 5
        @retry_times -= 1
        true
      else
        false
      end
    end
    def read_xml_form_zip(target, zipfile)
      xml = ''
      if RUBY_PLATFORM =~ /mswin/i # for memory error
        Zip::ZipFile.foreach(zipfile) do |entry|
          if entry.name =~ target
            entry.get_input_stream do |io|
              while line = io.gets
                xml << line
              end
            end
          end
        end
      else
        Zip::ZipFile.foreach(zipfile) do |entry|
          if entry.name =~ target
            entry.get_input_stream { |io| xml = io.read }
          end
        end
      end
      xml
    end
  end
  class BagXmlDownloader < Downloader
    def init
      super
      @url ||= 'http://bag.e-mediat.net/SL2007.Web.External/File.axd?file=XMLPublications.zip'
    end
    def download
      file = 'XMLPublications.zip'
      begin
        response = @agent.get(@url)
        response.save_as file
        return read_xml_form_zip(/^Preparation/iu, file)
      rescue Timeout::Error
        retrievable? ? retry : raise
      ensure
        if File.exists? file
          File.unlink file
        end
      end
    end
  end
  class SwissIndexDownloader < Downloader
    def initialize(type=:pharma, lang='DE')
      @type = (type == :pharma ? 'Pharma' : 'NonPharma')
      @lang = lang
      url = "https://index.ws.e-mediat.net/Swissindex/#{@type}/ws_#{@type}_V101.asmx?WSDL"
      super(url)
    end
    def init
      config = {
        :log_level       => :info,
        :log             => false, # $stdout
        :raise_errors    => true,
        :ssl_verify_mode => :none,
        :wsdl            => @url
      }
      @client = Savon::Client.new(config)
    end
    def download
      begin
        soap = <<XML
<?xml version="1.0" encoding="utf-8"?>
<soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
<soap:Body>
  <lang xmlns="http://swissindex.e-mediat.net/Swissindex#{@type}_out_V101">#{@lang}</lang>
</soap:Body>
</soap:Envelope>
XML
        response = @client.call(:download_all, :xml => soap)
        if response.success?
          if xml = response.to_xml
            return xml
          else
            # received broken data or internal error
            raise StandardError
          end
        else
          raise Timeout::Error
        end
      rescue Timeout::Error
        retrievable? ? retry : raise
      end
    end
  end
  class SwissmedicDownloader < Downloader
    def initialize(type=:orphans)
      @type = type
      case @type
      when :orphans
        action = "daten/00081/index.html?lang=de"
        @xpath = "//div[@id='sprungmarke0_4']//a[@title='Humanarzneimittel']"
      when :fridges
        action = "daten/00080/00254/index.html?lang=de"
        @xpath = "//table[@class='swmTableFlex']//a[@title='B3.1.35-d.xls']"
      end
      url = "http://www.swissmedic.ch/#{action}"
      super(url)
    end
    def download
      file = "swissmedic_#{@type}.xls"
      begin
        page = @agent.get(@url)
        if link_node = page.search(@xpath).first
          link = Mechanize::Page::Link.new(link_node, @agent, page)
          response = link.click
          response.save_as file
        end
        return File.open(file, 'rb')
      rescue Timeout::Error
        retrievable? ? retry : raise
      ensure
        if File.exists? file
          File.unlink file
        end
      end
    end
  end
  class SwissmedicInfoDownloader < Downloader
    def init
      super
      @agent.ignore_bad_chunking = true
      @url ||= "http://download.swissmedicinfo.ch/Accept.aspx?ReturnUrl=%2f"
    end
    def download
      file = "swissmedic_info.zip"
      begin
        response = nil
        if home = @agent.get(@url)
          form = home.form_with(:id => 'Form1')
          bttn = form.button_with(:name => 'ctl00$MainContent$btnOK')
          if page = form.submit(bttn)
            form = page.form_with(:id => 'Form1')
            bttn = form.button_with(:name => 'ctl00$MainContent$BtnYes')
            response = form.submit(bttn)
          end
        end
        if response
          response.save_as file
        end
        return read_xml_form_zip(/^AipsDownload_/iu, file)
      rescue Timeout::Error
        retrievable? ? retry : raise
      rescue NoMethodError => e
        # pass
      ensure
        if File.exists? file
          File.unlink file
        end
      end
    end
  end
  class EphaDownloader < Downloader
    def init
      super
      @url ||= 'http://community.epha.ch/interactions_de_utf8.csv'
    end
    def download
      file = "epha_interactions.csv"
      begin
        response = @agent.get(@url)
        response.save_as file
        return File.open(file, 'r')
      rescue Timeout::Error
        retrievable? ? retry : raise
      ensure
        if File.exists? file
          File.unlink file
        end
      end
    end
  end
  class YweseeBMDownloader < Downloader
    def init
      super
      @url ||= 'http://www.ywesee.com/uploads/Main/BM_Update.txt'
    end
    def download
      file = 'ywesee_bm_update.txt'
      begin
        response = @agent.get(@url)
        response.save_as file
        return File.open(file, 'r')
      rescue Timeout::Error
        retrievable? ? retry : raise
      ensure
        if File.exists? file
          File.unlink file
        end
      end
    end
  end
end