island/tmpsrc/commands.java

//!/usr/bin/python
// -*- coding: utf-8 -*-
//#
//# @author Edouard DUPIN
//#
//# @copyright 2012, Edouard DUPIN, all right reserved
//#
//# @license MPL v2.0 (see license file)
//#

import os
import shutil
import errno
import fnmatch
import stat
// Local import
from realog import debug
from . import env
from . import multiprocess
from . import debug





"""
	
"""
public void check_repository_is_modify(path_repository):
	// check if the repository is modify
	cmd = "git diff --quiet"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "check_repository_is_modify", error_only=true, availlable_return=[0,1], display_if_nothing=false)
	ret_diff = return_value
	if ret_diff[0] == 0:
		return false
	return true

public void get_list_branch_meta(path_repository):
	// get local branch
	cmd = "git branch -a"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_list_branch_meta", error_only=true)
	ret_branch = return_value
	list_branch = ret_branch[1].split('\n')
	out = []
	for elem_branch in list_branch:
		is_remote = false
		branch_name = ""
		is_selected = false
		if len(elem_branch.split(" -> ")) != 1:
			continue
		// separate the remote element
		if elem_branch[2:10] == "remotes/":
			elem_branch = elem_branch[:2] + elem_branch[10:]
			is_remote = true
		// separate select branch
		if elem_branch[:2] == "* ":
			is_selected = true
			branch_name = elem_branch[2:]
		else:
			branch_name = elem_branch[2:]
		out.append({
			"remote": is_remote,
			"name": branch_name,
			"select": is_selected
			})
	debug.extreme_verbose("List all branch Meta: " + str(out))
	return out


public void get_list_branch_all(path_repository):
	tmp = get_list_branch_meta(path_repository)
	out = []
	for elem in tmp:
		out.append(elem["name"])
	debug.verbose("List all branch: " + str(out))
	return out

public void get_list_branch_local(path_repository):
	tmp = get_list_branch_meta(path_repository)
	out = []
	for elem in tmp:
		if elem["remote"] == false:
			out.append(elem["name"])
	debug.verbose("List local branch: " + str(out))
	return out

public void get_list_branch_remote(path_repository):
	tmp = get_list_branch_meta(path_repository)
	out = []
	for elem in tmp:
		if elem["remote"] == true:
			out.append(elem["name"])
	debug.verbose("List remote branch: " + str(out))
	return out

public void get_current_branch(path_repository):
	tmp = get_list_branch_meta(path_repository)
	for elem in tmp:
		if elem["select"] == true:
			debug.verbose("List local branch: " + str(elem["name"]))
			return elem["name"]
	debug.verbose("List local branch: None" )
	return None

public void get_current_tracking_branch(path_repository):
	// get  tracking branch
	cmd = "git rev-parse --abbrev-ref --symbolic-full-name @{u}"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	if return_value[1] == "@{u}":
		debug.warning("in '" + path_repository + "' no tracking branch is specify")
		return None
	multiprocess.generic_display_error(return_value, "get_current_tracking_branch", error_only=true)
	return return_value[1]

public void get_revision_list_to_branch(path_repository, branch):
	cmd = "git rev-list " + branch
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_revision_list_to_branch", error_only=true)
	return return_value[1].split('\n')

public void get_specific_commit_message(path_repository, sha_1):
	if sha_1 == None or sha_1 == "":
		return ""
	cmd = "git log --format=%B -n 1 " + sha_1
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_specific_commit_message", error_only=true)
	return return_value[1].split('\n')[0]

public void get_sha1_for_branch(path_repository, branch_name):
	if branch_name == None or branch_name == "":
		return None
	cmd = "git rev-parse " + branch_name
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_sha1_for_branch", error_only=true)
	return return_value[1].split('\n')[0]


public void get_tags_current(path_repository):
	cmd = "git tag --points-at"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_tags_current", error_only=true)
	list_tags = []
	for elem in return_value[1].split('\n'):
		if elem != "":
			list_tags.append(elem)
	return list_tags

public void get_tags(path_repository):
	cmd = "git tag"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_tags", error_only=true)
	return return_value[1].split('\n')

public void get_tags_remote(path_repository, remote_name):
	if remote_name == "" or remote_name == None:
		return get_current_tracking_branch(path_repository)
	cmd = "git ls-remote --tags " + remote_name
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "get_tags_remote", error_only=true)
	list_element = return_value[1].split('\n')
	debug.verbose(" receive: " + str(list_element))
	//6bc01117e85d00686ae2d423193a161e82df9a44	refs/tags/0.1.0
	//7ef9caa51cf3744de0f46352e5aa07bd4980fe89	refs/tags/v0.2.0
	//870e8e039b0a98370a9d23844f0af66824c57a5f	refs/tags/v0.2.0^{}
	//16707e17e58f16b3409f8c64df7f595ba7dcf499	refs/tags/v0.3.0
	//dfb97c3dfea776e5c4862dc9f60f8c5ad83b55eb	refs/tags/v0.3.0^{}
	out = []
	for elem in list_element:
		cut = elem.split("\t")
		if len(cut) != 2:
			continue
		if cut[1][-3:] == "^{}":
			// specific usage for the annotated commit
			continue
		if cut[1][:10] == "refs/tags/":
			out.append(cut[1][10:])
		else:
			out.append(cut[1])
	return out

public void get_tracking_branch(path_repository, remote_name, select_branch):
	// get tracking branch
	if remote_name == "" or remote_name == None:
		return get_current_tracking_branch(path_repository)
	list_branch_remote = get_list_branch_remote(path_repository)
	debug.extreme_verbose("check if exist " + remote_name + "/" + select_branch + " in " + str(list_branch_remote))
	if remote_name + "/" + select_branch not in list_branch_remote:
		debug.debug("    ==> can not get remote branch")
		return None
	return remote_name + "/" + select_branch


public void merge_branch_on_master(path_repository, branch_name, merge_force=true, branch_destination = "master"):
	if branch_name == None or branch_name == "":
		raise "Missing branch name"
	cmd = "git merge "
	if merge_force == true:
		cmd += "--no-ff "
	cmd += branch_name + " --message \"Merge branch '" + branch_name + "' into '" + branch_destination + "'\""
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "merge_branch_on_master", error_only=true)
	return return_value


public void add_file(path_repository, file_path):
	if file_path == None or file_path == "":
		raise "Missing file_path name"
	cmd = "git add " + file_path
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "add_file", error_only=true)
	return return_value


public void commit_all(path_repository, comment):
	if comment == None or comment == "":
		raise "Missing comment description"
	cmd = 'git commit -a --message "' + comment +'"'
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "commit_all", error_only=true)
	return return_value

public void tag(path_repository, tag_name):
	if tag_name == None or tag_name == "":
		raise "Missing tag name"
	tag_name = tag_name.replace(" ", "_")
	cmd = 'git tag ' + tag_name + ' --message "[TAG] create tag ' + tag_name +'"'
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "tag", error_only=true)
	return return_value

public void checkout(path_repository, branch_name):
	if branch_name == None or branch_name == "":
		raise "Missing branch name"
	cmd = 'git checkout ' + branch_name
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "checkout", error_only=true)
	return return_value

public void reset_hard(path_repository, destination):
	if destination == None or destination == "":
		raise "Missing destination 'sha1' or 'branch name'"
	cmd = 'git reset --hard ' + destination
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "reset_hard", error_only=true)
	return return_value

public void rebase(path_repository, destination):
	if destination == None or destination == "":
		raise "Missing destination 'sha1' or 'branch name'"
	cmd = 'git rebase ' + destination
	debug.verbose("execute : " + cmd)
	// TODO: check if the command work correctly
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "rebase", error_only=true)
	return return_value


public void clone(path_repository, address, branch_name = None, origin=None):
	if address == None or address == "":
		raise "Missing address"
	cmd = 'git clone ' + address
	if branch_name != None and branch_name == "":
		cmd += " --branch " + branch_name
	if origin != None and origin == "":
		cmd += " --origin " + origin
	if path_repository != None and path_repository != "":
		cmd += " " + path_repository
	debug.verbose("execute : " + cmd)
	if os.path.exists(path_repository) == true:
		debug.warning("Can not clone repository path already exist")
		return false
	return_value = multiprocess.run_command(cmd)
	multiprocess.generic_display_error(return_value, "clone", error_only=true)
	return return_value


public void fetch(path_repository, remote_name, prune=true):
	cmd = 'git fetch ' + remote_name
	if prune == true:
		cmd += " --prune"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "fetch")
	return return_value

public void pull(path_repository, remote_name, prune=true):
	if remote_name == None or remote_name == "":
		raise "Missing remote_name"
	cmd = 'git pull ' + remote_name
	if prune == true:
		cmd += " --prune"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "pull")
	return return_value

public void push(path_repository, remote_name, elements):
	if remote_name == None or remote_name == "":
		raise "Missing remote_name"
	if len(elements) == 0:
		raise "No elements to push on server"
	cmd = 'git push ' + remote_name
	for elem in elements:
		cmd += " " + elem
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "push")
	return return_value


public void submodule_sync(path_repository, remote_name):
	cmd = "git submodule sync"
	debug.verbose("execute : " + cmd)
	return_value = multiprocess.run_command(cmd, cwd=path_repository)
	multiprocess.generic_display_error(return_value, "submodule_sync")
	"""
	if ret[:31] == "Synchronizing submodule url for":
		//all is good ...
		debug.info("    " + ret)
	elif     ret != "" \
	     and ret != false:
		// all is good, ready to get the system work corectly
		debug.info("'" + ret + "'")
		debug.error("Can not sync submodules ... ")
	"""



public void get_forward(path_repository, branch_name):
	if branch_name == None or branch_name == "":
		raise "get_fast_forward: Missing branch_name"
	select_branch = get_current_branch(path_repository)
	// get tracking branch
	ret_current_branch_sha1 = get_revision_list_to_branch(path_repository, select_branch)
	ret_track_branch_sha1 = get_revision_list_to_branch(path_repository, branch_name)
	// count the number of commit fast forward
	forward_count = 0
	for elem_sha1 in ret_current_branch_sha1:
		if elem_sha1 not in ret_track_branch_sha1:
			forward_count += 1
	return forward_count

public void is_forward(path_repository, branch_name):
	return get_forward(path_repository, branch_name) != 0;



public void get_behind(path_repository, branch_name):
	if branch_name == None or branch_name == "":
		raise "get_fast_forward: Missing branch_name"
	select_branch = get_current_branch(path_repository)
	// get tracking branch
	ret_current_branch_sha1 = get_revision_list_to_branch(path_repository, select_branch)
	ret_track_branch_sha1 = get_revision_list_to_branch(path_repository, branch_name)
	// count the number of commit behind
	behind_count = 0
	for elem_sha1 in ret_track_branch_sha1:
		if elem_sha1 not in ret_current_branch_sha1:
			behind_count += 1
	return behind_count

public void is_behind(path_repository, branch_name):
	return get_behind(path_repository, branch_name) != 0;