# frozen_string_literal: true

require_relative "nuva/version"
require_relative "nuva/NuvaDatabase_pb"
require_relative "nuva/repository"
require_relative "nuva/queries"
require "net/http"
require "json"
require "ostruct"

module Nuva
  class Nuva
    attr_reader :repositories
    attr_reader :queries

    def initialize(db)
      @db = db

      @repositories = OpenStruct.new
      @repositories.vaccines = VaccineRepository.new db.vaccines
      @repositories.valences = ValenceRepository.new db.valences
      @repositories.diseases = DiseaseRepository.new db.diseases
      @repositories.freeze

      @queries = OpenStruct.new
      @queries.valences_by_vaccine =
        ::Nuva::Queries::ValencesByVaccineQuery.new @repositories
      @queries.vaccines_by_valence =
        ::Nuva::Queries::VaccinesByValenceQuery.new @repositories
      @queries.vaccines_by_disease =
        ::Nuva::Queries::VaccinesByDiseaseQuery.new @repositories
      @queries.valences_by_disease =
        ::Nuva::Queries::ValencesByDiseaseQuery.new @repositories
      @queries.diseases_by_vaccine =
        ::Nuva::Queries::DiseasesByVaccineQuery.new @repositories
      @queries.diseases_by_valence =
        ::Nuva::Queries::DiseasesByValenceQuery.new @repositories
      @queries.vaccine_fuzzy_search =
        ::Nuva::Queries::VaccineFuzzySearchQuery.new @repositories
      @queries.lookup_vaccine_by_code =
        ::Nuva::Queries::LookupVaccineByCodeQuery.new @repositories
      @queries.lookup_equivalent_vaccines =
        ::Nuva::Queries::LookupEquivalentVaccinesQuery.new @repositories
      @queries.lookup_generalized_vaccines =
        ::Nuva::Queries::LookupGeneralizedVaccinesQuery.new @repositories,
        @queries.valences_by_vaccine
      @queries.all_nomenclatures =
        ::Nuva::Queries::AllNomenclaturesQuery.new @repositories
      @queries.all_code_by_nomenclature =
        ::Nuva::Queries::AllCodeByNomenclatureQuery.new @repositories
      @queries.freeze
    end

    def version
      @db.version
    end

    def self.load(lang = "en")
      latest_version_uri =
        URI "https://cdnnuva.mesvaccins.net/versions/last.json"

      ::Net::HTTP.start(
        latest_version_uri.host,
        latest_version_uri.port,
        use_ssl: latest_version_uri.scheme == "https"
      ) do |http|
        # Fetch version manifest
        req = ::Net::HTTP::Get.new latest_version_uri

        res = http.request req
        res.value

        manifest = JSON.parse(res.body)

        dump_hash = manifest["dump_hash"]

        # Fetch latest database
        dump_uri = latest_version_uri.dup
        dump_uri.path = "/proto/#{dump_hash}_#{lang}.db"

        req = ::Net::HTTP::Get.new dump_uri

        res = http.request req
        res.value

        # The return value of the block is returned by the start method
        ::Nuva::Nuva.new(::Nuva::NuvaDatabase.decode(res.body))
      end
    end

    def self.load_from_file(path)
      Nuva.new(NuvaDatabase.decode(File.read(path)))
    end
  end
end