kmx.io/kmxgit/lib/kmxgit_web/controllers/page_controller.ex

• Show log

  Commit

• Hash : 0abc9e55
  Author : Thomas de Grivel
  Date : 2022-01-07T11:27:55
  

  refactor

Download

• lib/kmxgit_web/controllers/page_controller.ex

• defmodule KmxgitWeb.PageController do
    use KmxgitWeb, :controller
  
    alias Kmxgit.Repo
    alias Kmxgit.RepositoryManager
    alias Kmxgit.RepositoryManager.Repository
    alias Kmxgit.UserManager
    alias Kmxgit.UserManager.{Guardian, User}
  
    def index(conn, _params) do
      if ! UserManager.admin_user_present? do
        redirect(conn, to: Routes.page_path(conn, :new_admin))
      else
        conn
        |> render(:index)
      end
    end
  
    def new_admin(conn, _params) do
      if ! UserManager.admin_user_present? do
        changeset = UserManager.change_user(%User{})
        conn
        |> assign(:action, Routes.page_path(conn, :new_admin))
        |> assign(:changeset, changeset)
        |> assign(:no_navbar_links, true)
        |> render("new_admin.html")
      else
        redirect(conn, to: "/")
      end
    end
  
    def new_admin_post(conn, params) do
      if ! UserManager.admin_user_present? do
        user_params = Map.merge(params["user"], %{"is_admin" => true})
        Repo.transaction fn ->
          case UserManager.admin_create_user(user_params) do
            {:ok, user} ->
              conn
              |> Guardian.Plug.sign_in(user)
              |> redirect(to: "/")
            {:error, changeset} ->
              conn
              |> assign(:no_navbar_links, true)
              |> assign(:changeset, changeset)
              |> assign(:action, Routes.page_path(conn, :new_admin))
              |> render("new_admin.html")
          end
        end
      else
        redirect(conn, to: "/")
      end
    end
  
    def keys(conn, _params) do
      k1 = UserManager.list_users
      |> Enum.map(&User.ssh_keys_with_env/1)
      k2 = RepositoryManager.list_repositories
      |> Enum.map(&Repository.deploy_keys_with_env/1)
      k = (k1 ++ k2) |> Enum.join("\n")
      conn
      |> put_resp_content_type("text/text")
      |> resp(200, k)
    end
  
    def auth(conn, _params) do
      a = RepositoryManager.list_repositories
      |> Enum.sort(fn a, b ->
        Repository.full_slug(a) < Repository.full_slug(b)
      end)
      |> Enum.map(fn repo -> Repository.auth(repo) end)
      |> Enum.join("\n")
      conn
      |> put_resp_content_type("text/text")
      |> resp(200, a)
    end    
  end
  

Download