kmx.io/ex_ovh/lib/supervisor.ex

• Show log

  Commit

• Hash : 2e8a3d5b
  Author :
  Date : 2016-02-18T09:27:48
  

  replace LoggingUtils dependency with Og.

Download

• lib/supervisor.ex

• defmodule ExOvh.Supervisor do
    @moduledoc :false
    @doc ~S"""
    Supervisor for the Hubic and Ovh api configuration.
    """
    use Supervisor
    alias ExOvh.Ovh.Cache
    alias ExOvh.Ovh.Defaults, as: OvhDefaults
    alias ExOvh.Hubic.Defaults, as: HubicDefaults
    alias ExOvh.Ovh.Supervisor, as: OvhSupervisor
    alias ExOvh.Hubic.Supervisor, as: HubicSupervisor
    require Logger
  
  
    #####################
    #  Public
    #####################
  
    @doc ~S"""
    Starts the OVH and Hubic supervisors.
  
    If the hubic_config is set to :nil, it will simply ignore hubic and start ovh only.
    If the ovh_config is set to :nil, it will simply ignore ovh and start hubic only.
  
    If the both ovh_config and hubic_config are set to :nil, then an error will be raised
    which will crash the supervisor.
    """
    def start_link(client, config, opts) do
      Og.context(__ENV__, :debug)
      Supervisor.start_link(__MODULE__, {client, config, opts}, [name: client])
    end
  
    #####################
    #  Callbacks
    #####################
  
    def init({client, config, opts}) do
      Og.context(__ENV__, :debug)
      sup_tree =
      case ovh_config(config, client) do
        {:error, :config_not_found} ->
          Logger.warn(IO. inspect("No ovh config found. OVH supervisor will not be started for client #{client}"))
          []
        valid_config ->
          [{OvhSupervisor,
           {OvhSupervisor, :start_link, [client, valid_config, opts]}, :permanent, 10_000, :supervisor, [OvhSupervisor]}]
      end
      sup_tree =
      case hubic_config(config, client) do
        {:error, :config_not_found} ->
          Og.log_return("No hubic config found. Hubic supervisor will not be started for client #{client}", :warn)
          sup_tree
        valid_config -> sup_tree ++
          [{HubicSupervisor,
           {HubicSupervisor, :start_link, [client, valid_config, opts]}, :permanent, 10_000, :supervisor, [HubicSupervisor]}]
      end
      if sup_tree === [] do
          raise "No configuration found for hubic or ovh."
      end
      supervise(sup_tree, strategy: :one_for_one, max_restarts: 20)
    end
  
  
  
    @doc """
    Gets the ovh config settings.
  
    Returns the config_map if the ovh_config is not :nil.
    or
    Returns {:error, :config_not_found} if the ovh_config is set to :nil.
    """
    @spec ovh_config(config :: map, client :: atom) :: map | {:error, atom}
    def ovh_config(config, client) do
      case config[:ovh] do
        :nil -> {:error, :config_not_found}
        _ -> Map.merge(OvhDefaults.ovh(), client.config()[:ovh])
      end
    end
  
  
    @doc """
    Gets the hubic config settings.
  
    Returns the config_map if the hubic_config is not :nil.
    or
    Returns {:error, :config_not_found} if the hubic_config is set to :nil.
    """
    @spec hubic_config(config :: map, client :: atom) :: map | :nil
    def hubic_config(config, client) do
      case config[:hubic] do
        :nil -> {:error, :config_not_found}
        _ -> Map.merge(HubicDefaults.hubic(), client.config()[:hubic])
      end
    end
  
  end
  

Download