mirror of
				https://github.com/ansible-collections/community.general.git
				synced 2024-09-14 20:13:21 +02:00 
			
		
		
		
	
		
			
				
	
	
		
			200 lines
		
	
	
	
		
			6.2 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			200 lines
		
	
	
	
		
			6.2 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
| #!/usr/bin/python
 | |
| # -*- coding: utf-8 -*-
 | |
| 
 | |
| # (c) 2013, André Paramés <git@andreparames.com>
 | |
| # Based on the Git module by Michael DeHaan <michael.dehaan@gmail.com>
 | |
| #
 | |
| # This file is part of Ansible
 | |
| #
 | |
| # Ansible is free software: you can redistribute it and/or modify
 | |
| # it under the terms of the GNU General Public License as published by
 | |
| # the Free Software Foundation, either version 3 of the License, or
 | |
| # (at your option) any later version.
 | |
| #
 | |
| # Ansible is distributed in the hope that it will be useful,
 | |
| # but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
| # GNU General Public License for more details.
 | |
| #
 | |
| # You should have received a copy of the GNU General Public License
 | |
| # along with Ansible.  If not, see <http://www.gnu.org/licenses/>.
 | |
| 
 | |
| DOCUMENTATION = u'''
 | |
| ---
 | |
| module: bzr
 | |
| author: André Paramés
 | |
| version_added: "1.1"
 | |
| short_description: Deploy software (or files) from bzr branches
 | |
| description:
 | |
|     - Manage I(bzr) branches to deploy files or software.
 | |
| options:
 | |
|     name:
 | |
|         required: true
 | |
|         aliases: [ 'parent' ]
 | |
|         description:
 | |
|             - SSH or HTTP protocol address of the parent branch.
 | |
|     dest:
 | |
|         required: true
 | |
|         description:
 | |
|             - Absolute path of where the branch should be cloned to.
 | |
|     version:
 | |
|         required: false
 | |
|         default: "head"
 | |
|         description:
 | |
|             - What version of the branch to clone.  This can be the
 | |
|               bzr revno or revid.
 | |
|     force:
 | |
|         required: false
 | |
|         default: "yes"
 | |
|         choices: [ 'yes', 'no' ]
 | |
|         description:
 | |
|             - If C(yes), any modified files in the working
 | |
|               tree will be discarded.
 | |
|     executable:
 | |
|         required: false
 | |
|         default: null
 | |
|         version_added: "1.4"
 | |
|         description:
 | |
|             - Path to bzr executable to use. If not supplied,
 | |
|               the normal mechanism for resolving binary paths will be used.
 | |
| '''
 | |
| 
 | |
| EXAMPLES = '''
 | |
| # Example bzr checkout from Ansible Playbooks
 | |
| - bzr: name=bzr+ssh://foosball.example.org/path/to/branch dest=/srv/checkout version=22
 | |
| '''
 | |
| 
 | |
| import re
 | |
| 
 | |
| 
 | |
| class Bzr(object):
 | |
|     def __init__(self, module, parent, dest, version, bzr_path):
 | |
|         self.module = module
 | |
|         self.parent = parent
 | |
|         self.dest = dest
 | |
|         self.version = version
 | |
|         self.bzr_path = bzr_path
 | |
| 
 | |
|     def _command(self, args_list, **kwargs):
 | |
|         (rc, out, err) = self.module.run_command(
 | |
|             [self.bzr_path] + args_list, **kwargs)
 | |
|         return (rc, out, err)
 | |
| 
 | |
|     def get_version(self):
 | |
|         '''samples the version of the bzr branch'''
 | |
|         os.chdir(self.dest)
 | |
|         cmd = "%s revno" % self.bzr_path
 | |
|         revno = os.popen(cmd).read().strip()
 | |
|         return revno
 | |
| 
 | |
|     def clone(self):
 | |
|         '''makes a new bzr branch if it does not already exist'''
 | |
|         dest_dirname = os.path.dirname(self.dest)
 | |
|         try:
 | |
|             os.makedirs(dest_dirname)
 | |
|         except:
 | |
|             pass
 | |
|         os.chdir(dest_dirname)
 | |
|         if self.version.lower() != 'head':
 | |
|             args_list = ["branch", "-r", self.version, self.parent, self.dest]
 | |
|         else:
 | |
|             args_list = ["branch", self.parent, self.dest]
 | |
|         return self._command(args_list, check_rc=True)
 | |
| 
 | |
|     def has_local_mods(self):
 | |
|         os.chdir(self.dest)
 | |
|         cmd = "%s status -S" % self.bzr_path
 | |
|         lines = os.popen(cmd).read().splitlines()
 | |
|         lines = filter(lambda c: not re.search('^\\?\\?.*$', c), lines)
 | |
|         return len(lines) > 0
 | |
| 
 | |
|     def reset(self, force):
 | |
|         '''
 | |
|         Resets the index and working tree to head.
 | |
|         Discards any changes to tracked files in the working
 | |
|         tree since that commit.
 | |
|         '''
 | |
|         os.chdir(self.dest)
 | |
|         if not force and self.has_local_mods():
 | |
|             self.module.fail_json(msg="Local modifications exist in branch (force=no).")
 | |
|         return self._command(["revert"], check_rc=True)
 | |
| 
 | |
|     def fetch(self):
 | |
|         '''updates branch from remote sources'''
 | |
|         os.chdir(self.dest)
 | |
|         if self.version.lower() != 'head':
 | |
|             (rc, out, err) = self._command(["pull", "-r", self.version])
 | |
|         else:
 | |
|             (rc, out, err) = self._command(["pull"])
 | |
|         if rc != 0:
 | |
|             self.module.fail_json(msg="Failed to pull")
 | |
|         return (rc, out, err)
 | |
| 
 | |
|     def switch_version(self):
 | |
|         '''once pulled, switch to a particular revno or revid'''
 | |
|         os.chdir(self.dest)
 | |
|         if self.version.lower() != 'head':
 | |
|             args_list = ["revert", "-r", self.version]
 | |
|         else:
 | |
|             args_list = ["revert"]
 | |
|         return self._command(args_list, check_rc=True)
 | |
| 
 | |
| # ===========================================
 | |
| 
 | |
| def main():
 | |
|     module = AnsibleModule(
 | |
|         argument_spec = dict(
 | |
|             dest=dict(required=True),
 | |
|             name=dict(required=True, aliases=['parent']),
 | |
|             version=dict(default='head'),
 | |
|             force=dict(default='yes', type='bool'),
 | |
|             executable=dict(default=None),
 | |
|         )
 | |
|     )
 | |
| 
 | |
|     dest    = os.path.abspath(os.path.expanduser(module.params['dest']))
 | |
|     parent  = module.params['name']
 | |
|     version = module.params['version']
 | |
|     force   = module.params['force']
 | |
|     bzr_path = module.params['executable'] or module.get_bin_path('bzr', True)
 | |
| 
 | |
|     bzrconfig = os.path.join(dest, '.bzr', 'branch', 'branch.conf')
 | |
| 
 | |
|     rc, out, err, status = (0, None, None, None)
 | |
| 
 | |
|     bzr = Bzr(module, parent, dest, version, bzr_path)
 | |
| 
 | |
|     # if there is no bzr configuration, do a branch operation
 | |
|     # else pull and switch the version
 | |
|     before = None
 | |
|     local_mods = False
 | |
|     if not os.path.exists(bzrconfig):
 | |
|         (rc, out, err) = bzr.clone()
 | |
| 
 | |
|     else:
 | |
|         # else do a pull
 | |
|         local_mods = bzr.has_local_mods()
 | |
|         before = bzr.get_version()
 | |
|         (rc, out, err) = bzr.reset(force)
 | |
|         if rc != 0:
 | |
|             module.fail_json(msg=err)
 | |
|         (rc, out, err) = bzr.fetch()
 | |
|         if rc != 0:
 | |
|             module.fail_json(msg=err)
 | |
| 
 | |
|     # switch to version specified regardless of whether
 | |
|     # we cloned or pulled
 | |
|     (rc, out, err) = bzr.switch_version()
 | |
| 
 | |
|     # determine if we changed anything
 | |
|     after = bzr.get_version()
 | |
|     changed = False
 | |
| 
 | |
|     if before != after or local_mods:
 | |
|         changed = True
 | |
| 
 | |
|     module.exit_json(changed=changed, before=before, after=after)
 | |
| 
 | |
| # import module snippets
 | |
| from ansible.module_utils.basic import *
 | |
| main()
 |