To get this branch, use:
bzr branch
http://bzr.ed.am/stdhome
« back to all changes in this revision
Viewing changes to lib/stdhome/deployment.py
- browse files at revision 2
- compare with another revision
- download diff
- download tarball
- view history from revision 2
- Committer: Tim Marston
- Date: 2014-01-05 11:51:35 UTC
- Revision ID: tim@ed.am-20140105115135-6ses87ggwyjrxzfj
added global objects (the.repo, the.program), deployment object and implemented
init command
init command
- files removed:
- lib/stdhome/command
- lib/stdhome/vcs
- lib/stdhome/walker
- files renamed:
- lib/stdhome/command/init.py => lib/stdhome/command_init.py
- files modified:
- .bzrignore
added
removed
lib/stdhome/deployment.py
1
1
# deployment.py
2
2
#
3
# Copyright (C) 2013 to 2014 Tim Marston <tim@edm.am>
3
# Copyright (C) 2013 Tim Marston <tim@edm.am>
4
4
#
5
5
# This file is part of stdhome (hereafter referred to as "this program").
6
6
# See http://ed.am/dev/stdhome for more information.
19
19
# along with this program. If not, see <http://www.gnu.org/licenses/>.
20
20
21
21
22
import os, re, shutil, filecmp, json
23
import the, util
24
from walker.copy_in import CopyInWalker
25
from walker.conflict import ConflictWalker
26
from walker.copy_out import CopyOutWalker
22
import os
23
import the
27
24
28
25
29
26
class Deployment:
30
27
31
28
32
29
def __init__( self ):
33
if the.repo is None:
34
raise RuntimeError( 'logic error: Deployment initialised when '
35
'the.repo is unset' )
36
self.load_deployment_state()
37
self.conflicts_checked = False
38
39
40
def load_deployment_state( self ):
41
"""Load any deployment state. If one is found then a deployment will be
42
considered to be ongoing.
43
"""
44
45
# list of files that were copied-in (or at least given the opportunity
46
# to be) and updated through the vcs update. This means that, while
47
# there may have been conflicts during the update (which will be dealt
48
# with in the repo), any conflicts arising with these files in the home
49
# directory are no longer important and can be ignored. In short, this
50
# is a list of files that it is safe to deploy, regardless of their
51
# state in the home directory.
52
self.deploy_files = None
53
54
# list of files that were affected by a recent vcs update (so only these
55
# files need to be checked for deployment conflicts or copied-out)
56
self.affected_files = None
57
58
# the revno that the repo was as prior to a recent update
59
self.initial_revno = None
60
61
# do we have a repo?
62
if not os.path.exists( the.repo.full_dir ): return
63
64
# if no file list exists, we're done
65
file = os.path.join( the.full_mddir, "deploy.%s" % the.repo.name )
66
if not os.path.isfile( file ):
30
31
# initialise the file list
32
self.file_list = None
33
if not os.path.exists( the.repo.expanded_dir ):
34
self.file_list = []
35
else:
36
self.load_file_list()
37
38
assert False # not implemented
39
40
41
def load_file_list( self ):
42
43
# if no file list, don't load one
44
if .....
67
45
return
68
46
69
# read the file list
70
if the.verbose: print "deployment state found; loading"
71
f = open( file, 'r' )
72
state = json.loads( f.read() )
73
74
# unpack deployment state
75
self.deploy_files = state['deploy_files'];
76
self.initial_revno = state['initial_revno'];
77
self.affected_files = state['affected_files'];
78
79
80
def save_deployment_state( self ):
81
"""Save the current deployment state (so there will be a deployment ongoing).
82
"""
83
84
if the.verbose: print "saving deployment state"
85
86
# create metadata directory, as necessary
87
if not os.path.isdir( the.full_mddir ):
88
os.mkdir( the.full_mddir )
89
90
# pack deployment state
91
state = {
92
'deploy_files': self.deploy_files,
93
'initial_revno': self.initial_revno,
94
'affected_files': self.affected_files,
95
}
96
97
# create file
98
file = os.path.join( the.full_mddir, "deploy.%s" % the.repo.name )
99
f = open( file, 'w' )
100
f.write( json.dumps( state ) );
101
102
103
def remove_deployment_state( self ):
104
"""Remove the current deployment state (so no deployment will be ongoing).
105
"""
106
107
# check it exists
108
file = os.path.join( the.full_mddir, "deploy.%s" % the.repo.name )
109
if( os.path.isfile( file ) ):
110
111
# delete it
112
if the.verbose: print "removing deployment state"
113
os.unlink( file )
114
115
116
def is_ongoing( self ):
117
"""Is there a deployment currently ongoing?
118
"""
119
120
return False if self.deploy_files is None else True
121
122
123
def check_ongoing( self, ongoing = True ):
124
"""Check that a deployment either is or is not ongoing and raise an error if
125
not.
126
"""
127
128
if( ongoing ):
129
if self.deploy_files is None:
130
raise self.DeploymentOngoing( False )
131
else:
132
if self.deploy_files is not None:
133
raise self.DeploymentOngoing( True )
134
135
136
def get_initial_revno( self ):
137
"""Get the initial revision identifier from the deployment state.
138
"""
139
140
return self.initial_revno
141
142
143
def copy_in( self, initial_revno = None ):
144
"""Copy-in changes from the home directory to the repository. When finished,
145
the state of deployment is saved, meaning that a deployment is ongoing.
146
"""
47
# load it
48
49
50
def copy_in( self ):
147
51
148
52
# check we don't already have a file list
149
self.check_ongoing( False )
150
151
# if the repo doesn't exist, we have an empty file list
152
if not os.path.exists( the.repo.full_dir ):
153
self.deploy_files = list()
154
else:
155
# copy in
156
if the.verbose: print "importing files..."
157
walker = CopyInWalker()
158
walker.walk()
159
if( walker.changed ):
160
raise self.CopyInConflicts( walker.changed )
161
self.deploy_files = walker.walk_list
162
163
# obtain initial revno
164
self.initial_revno = the.repo.vcs.get_revno()
165
166
# save state
167
self.save_deployment_state()
168
169
170
def get_conflicts( self, affected_files = None ):
171
"""Check to see if there are any delpoyment conflicts. If a list of affected
172
files is supplied, then only those files are checked (and they are also
173
saved with the deployment state). Otherwise, all files in the
174
repository are checked.
175
"""
176
177
# check we have a file list
178
self.check_ongoing( True )
179
180
# set updated files
181
if affected_files is not None:
182
self.affected_files = affected_files
183
self.save_deployment_state()
184
185
# check for deployment conflicts
186
walker = ConflictWalker( self.deploy_files, self.affected_files )
187
walker.walk()
188
189
self.conflicts_checked = True
190
return walker.changed + walker.obstructed
53
if self.file_list is not None:
54
raise the.FatalError( 'deployment in progress; ' + \
55
'see "%s resolve --help" for information' % the.program.name )
56
57
assert False # not implemented
191
58
192
59
193
60
def copy_out( self ):
194
"""Copy-out changed files frmo the repository to the home directory. If the
195
deployment state incudes a list of affected files, then only those fiels
196
are copied-out.
197
"""
198
199
# check we have a file list
200
self.check_ongoing( True )
201
202
# check that deployment conflicts have been checked-for
203
if not self.conflicts_checked:
204
raise RuntimeError('logic error: deployment conflicts unchecked' )
205
206
# copy out
207
if the.verbose: print "exporting files..."
208
walker = CopyOutWalker( self.affected_files )
209
walker.walk()
210
211
# clear state
212
self.remove_deployment_state()
213
214
215
class DeploymentOngoing( the.program.FatalError ):
216
217
def __init__( self, ongoing ):
218
if( ongoing ):
219
self.msg = "there is an ongoing deployment"
220
else:
221
self.msg = "there is no ongoing deployment"
222
223
224
class CopyInConflicts( the.program.FatalError ):
225
226
def __init__( self, conflicts ):
227
self.conflicts = conflicts
61
if self.pre_copy_out_list is None:
62
return
63
64
print "deploying files"
65
66
# walk the repo
67
for ( repodir, directories, files ) in os.walk( the.repo.expanded_dir ):
68
assert path[ : len( the.repo.expanded_dir ) ] == \
69
the.repo.expanded_dir
70
relative_path = path[ len( the.repo.expanded_dir ) : ]
71
fsdir = the.expanded_fsdir + relative_path
72
73
print relative_path
74
75
# check directories
76
for dir in directories:
77
if os.path.exists( fsdir + dir ) and \
78
not os.path.isdir( fsdir + dir ):
79
80
#
81
82
# if exists in repo as directory and also in fs as non-directory
83
if os.path.isdir( the.repo.expnaded_dir + relative_path +
Loggerhead is a web-based interface for Bazaar branches
Version: 1.18.2, Revision: 480