Hash :
1e30f33a
Author :
tokyovania
Date :
2022-07-05T15:23:26
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130
defmodule KmxgitWeb.PageController do
use KmxgitWeb, :controller
require Logger
alias Kmxgit.OrganisationManager
alias Kmxgit.Repo
alias Kmxgit.RepositoryManager
alias Kmxgit.RepositoryManager.Repository
alias Kmxgit.SlugManager
alias Kmxgit.UserManager
alias Kmxgit.UserManager.User
alias KmxgitWeb.UserAuth
def auth(conn, _params) do
a = RepositoryManager.list_all_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
def doc_git_install(conn, _) do
conn
|> render(:doc_git_install)
end
def index(conn, _params) do
if ! UserManager.admin_user_present? do
redirect(conn, to: Routes.page_path(conn, :new_admin))
else
conn
|> assign(:discord, Application.get_env(:kmxgit, :discord))
|> assign(:git_ssh_url, Application.get_env(:kmxgit, :git_ssh_url))
|> assign(:org_count, OrganisationManager.count_organisations())
|> assign(:repo_count, RepositoryManager.count_repositories())
|> assign(:user_count, UserManager.count_users())
|> render(:index)
end
end
def keys(conn, _params) do
k1 = UserManager.list_all_users
|> Enum.map(&User.ssh_keys_with_env/1)
k2 = RepositoryManager.list_all_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 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})
case Repo.transaction(fn ->
case UserManager.admin_create_user(user_params) do
{:ok, user, changeset} ->
case SlugManager.create_slug(user) do
{:ok, _slug} -> user
{:error, changeset1} ->
IO.inspect(changeset1)
changeset
|> Map.put(:action, :insert)
|> Ecto.Changeset.add_error(:slug_, "is already taken", [constraint: :unique, constraint_name: "slugs_slug_index"])
|> Repo.rollback()
end
{:error, changeset1} ->
IO.inspect(changeset1)
Repo.rollback(changeset1)
end
end) do
{:ok, user} ->
conn
|> UserAuth.log_in_user(user, user_params)
|> redirect(to: "/")
{:error, changeset} ->
IO.inspect(changeset)
conn
|> assign(:no_navbar_links, true)
|> assign(:changeset, changeset)
|> assign(:action, Routes.page_path(conn, :new_admin))
|> render("new_admin.html")
end
else
redirect(conn, to: "/")
end
end
def privacy(conn, _params) do
conn
|> render(:privacy)
end
def robots(conn, _params) do
conn
|> put_resp_content_type("text/plain")
|> render("robots.txt")
end
def sitemap(conn, _params) do
conn
|> assign(:orgs, OrganisationManager.list_all_organisations())
|> assign(:users, UserManager.list_all_users())
|> put_resp_content_type("text/plain")
|> render("sitemap.txt")
end
def user_agreement(conn, _params) do
conn
|> render(:user_agreement)
end
end