kmx git

defmodule Kmxgit.GitManager do

  @git_root "priv/git"

  def git_dir(repo) do
    "#{@git_root}/#{repo}.git"
  end

  def branches(repo) do
    dir = git_dir(repo)
    {out, status} = System.cmd("git", ["-C", dir, "branch", "--list"], stderr_to_stdout: true)
    case status do
      0 ->
        b = out
        |> String.split("\n")
        |> filter_branches()
        |> Enum.reject(&(!&1 || &1 == ""))  
        {:ok, b}
      _ -> {:error, out}
    end
  end

  defp filter_branches(lines) do
    filter_branches(lines, [], nil)
  end

  defp filter_branches([], acc, nil) do
    Enum.reverse(acc)
  end
  defp filter_branches([], acc, main) do
    [main | Enum.reverse(acc)]
  end
  defp filter_branches([line | rest], acc, main) do
    case Regex.run(~r/^(\* )? *([^ ].*)$/, line) do
      [_, "* ", branch] -> filter_branches(rest, acc, branch)
      [_, _, branch] -> filter_branches(rest, [branch | acc], main)
      _ -> filter_branches(rest, acc, main)
    end
  end

  def content(repo, path) do
    dir = git_dir(repo)
    path = if path == "" do "." else path end
    {out, status} = System.cmd("git", ["-C", dir, "cat-file", "blob", path], stderr_to_stdout: true)
    case status do
      0 -> {:ok, out}
      _ -> {:error, out}
    end
  end

  def files(repo, tree, path, parent \\ ".") do
    dir = git_dir(repo)
    path1 = if path == "" do "." else path end
    {out, status} = System.cmd("git", ["-C", dir, "ls-tree", tree, path1], stderr_to_stdout: true)
    case status do
      0 ->
        list = out
        |> String.split("\n")
        |> Enum.reject(&(&1 == ""))
        |> Enum.map(fn line ->
          case String.split(line, "\t") do
            [stat, name] ->
              [mode, type, sha1] = String.split(stat, " ")
              url = "#{parent}/#{name}"
              %{mode: mode, name: name, sha1: sha1, type: type, url: url}
            _ -> nil
          end
        end)
        |> Enum.reject(&(&1 == nil))
        case list do
          [%{name: ^path1, sha1: sha1, type: "tree"}] ->
            files(repo, sha1, "", "#{parent}/#{path1}")
          _ -> {:ok, list}
        end
      _ ->
        if Regex.match?(~r(^fatal: Not a valid object name ), out) do
          {:ok, []}
        else
          {:error, String.split(out, "\n")}
        end
    end
  end

  def update_auth do
    {out, status} = System.cmd("update_etc_git_auth", [], stderr_to_stdout: true)
    case status do
      0 ->
        {out, status} = System.cmd("update_git_ssh_authorized_keys", [], stderr_to_stdout: true)
        case status do
          0 -> :ok
          _ -> {:error, out}
        end
      _ -> {:error, out}
    end
  end

  def rename(from, to) do
    dir_from = git_dir(from)
    dir_to = git_dir(to)
    if File.exists?(dir_to) do
      {:error, "file exists"}
    else
      dir = Path.dirname(dir_to)
      :ok = File.mkdir_p(dir)
      {out, status} = System.cmd("mv", [dir_from, dir_to], stderr_to_stdout: true)
      case status do
        0 -> :ok
        _ -> {:error, out}
      end
    end
  end

  def rename_dir(from, to) do
    dir_from = "#{@git_root}/#{from}/"
    dir_to   = "#{@git_root}/#{to}/"
    if File.exists?(dir_to) do
      {:error, "file exists"}
    else
      {out, status} = System.cmd("mv", [dir_from, dir_to], stderr_to_stdout: true)
      case status do
        0 -> :ok
        _ -> {:error, out}
      end
    end
  end

  def create(repo) do
    dir = "#{@git_root}/#{Path.dirname(repo)}"
    name = "#{Path.basename(repo)}.git"
    :ok = File.mkdir_p(dir)
    {out, status} = System.cmd("git", ["-C", dir, "init", "--bare", name], stderr_to_stdout: true)
    case status do
      0 -> {:ok, out}
      _ -> {:error, out}
    end
  end

  defp rm_rf(dir) do
    case System.cmd("rm", ["-rf", dir], stderr_to_stdout: true) do
      {"", 0} -> :ok
      {err, _} -> {:error, err}
    end
  end

  def delete(repo) do
    repo |> git_dir() |> rm_rf()
  end

  def delete_dir(dir) do
    "#{@git_root}/#{dir}/"
    |> rm_rf()
  end

  def fork(from, to) do
    dir_from = git_dir(from)
    dir_to = git_dir(to)
    if File.exists?(dir_to) do
      {:error, "file exists"}
    else
      dir = Path.dirname(dir_to)
      :ok = File.mkdir_p(dir)
      {out, status} = System.cmd("cp", ["-PRp", dir_from, dir_to], stderr_to_stdout: true)
      case status do
        0 -> :ok
        _ -> {:error, out}
      end
    end
  end

  def public_access(repo, true) do
    dir = git_dir(repo)
    if ! File.exists?(export = "#{dir}/git-daemon-export-ok") do
      File.write!(export, "")
    end
    :ok
  end
  def public_access(repo, false) do
    dir = git_dir(repo)
    if File.exists?(export = "#{dir}/git-daemon-export-ok") do
      File.rm!(export)
    end
    :ok
  end

  def log(repo, tree \\ nil) do
    if tree do
      log_(repo, [tree])
    else
      log_(repo, [])
    end
  end

  def log_file(repo, path, tree \\ nil) do
    if tree do
      log_(repo, [tree, "--", path])
    else
      log_(repo, ["--", path])
    end
  end

  defp ok_hd({:ok, list}), do: {:ok, hd(list)}
  defp ok_hd(x), do: x

  def log1(repo, tree \\ nil) do
    if tree do
      log_(repo, ["-1", tree])
    else
      log_(repo, ["-1"])
    end
    |> ok_hd()
  end

  def log1_file(repo, file, tree \\ nil) do
    if tree do
      log_(repo, ["-1", tree, "--", file])
    else
      log_(repo, ["-1", "--", file])
    end
    |> ok_hd()
  end

  defp log_(repo, args) do
    dir = git_dir(repo)
    args = ["-C", dir, "log", "--format=%H %aI \"%an <%ae>\" %s"] ++ args
    {out, status} = System.cmd("git", args, stderr_to_stdout: true)
    case status do
      0 ->
        entries = out
        |> String.split("\n")
        |> Enum.map(fn line ->
          case Regex.run(~r/^([^ ]+) ([^ ]+) "(.+) <([^>]+)>" (.*)$/, line) do
            [_ , hash, date, author, email, msg] -> %{author: author, author_email: email, hash: hash, date: date, message: msg}
            _ -> nil
          end
        end)
        |> Enum.filter(& &1)

        {:ok, entries}
      _ -> {:error, out}
    end
  end

  def tag(repo, tag) do
    dir = git_dir(repo)
    args = ["-C", dir, "log", "-1", "--format=%H %aI \"%an <%ae>\"", tag]
    {out, status} = System.cmd("git", args, stderr_to_stdout: true)
    case status do
      0 ->
        case Regex.run(~r/^([^ ]+) ([^ ]+) "([^"]+)"$/, out) do
          [_ , hash, date, author] -> {:ok, %{author: author, date: date, hash: hash}}
          _ -> {:error, nil}
        end
      _ -> {:error, out}
    end
  end

  def tags(repo) do
    dir = git_dir(repo)
    {out, status} = System.cmd("git", ["-C", dir, "tag", "-l"], stderr_to_stdout: true)
    case status do
      0 ->
        tags = out
        |> String.split("\n")
        |> Enum.filter(& &1 && &1 != "")
        |> Enum.map(& tag_info(repo, &1))

        {:ok, tags}
      _ ->
        {:error, out}
    end
  end

  def tag_info(repo, tag) do
    {:ok, commit} = log1(repo, tag)
    commit
    |> Map.put(:tag, tag)
  end

  def diff(repo, from, to) do
    dir = git_dir(repo)
    IO.inspect("git -C #{dir} diff #{from} #{to}")
    {out, status} = System.cmd("git", ["-C", dir, "diff", from, to], stderr_to_stdout: true)
    case status do
      0 -> {:ok, out}
      _ -> {:error, out}
    end
  end

  def disk_usage(repo) do
    dir = git_dir(repo)
    {out, status} = System.cmd("du", ["-ks", dir], stderr_to_stdout: true)
    case status do
      0 -> {:ok, Integer.parse(out)}
      _ -> {:error, out}
    end
  end
end
kmx.io/kmxgit/lib/kmxgit/git_manager.ex

Commit

lib/kmxgit/git_manager.ex
