22
22
import os, re, shutil, filecmp, json
24
from walker.copy_in import CopyInWalker
25
from walker.conflict import ConflictWalker
26
from walker.copy_out import CopyOutWalker
24
from walker.copy_in_walker import CopyInWalker
25
from walker.conflict_walker import ConflictWalker
26
from walker.copy_out_walker import CopyOutWalker
32
31
def __init__( self ):
34
raise RuntimeError( 'logic error: Deployment initialised when '
36
32
self.load_deployment_state()
37
33
self.conflicts_checked = False
40
36
def load_deployment_state( self ):
41
"""Load any deployment state. If one is found then a deployment will be
42
considered to be ongoing.
45
38
# list of files that were copied-in (or at least given the opportunity
46
39
# to be) and updated through the vcs update. This means that, while
47
# there may have been conflicts during the update (which the user will
48
# have to deal with in the repo), any conflicts arising with these files
49
# in the home directory are no longer important and can be ignored. In
50
# short, this is a list of files that can safely be deployed, regardless
51
# of the state of the home directory.
40
# there may have been conflicts during the update (which will be dealt
41
# with in the repo), any arising conflicts with the filesystem are now
42
# assumed to be because of the vcs update and can be ignored (that is to
43
# say, we no longer care about the file in the home directory). In
44
# short, this is a list of files that it is safe to deploy, regardless
45
# of the state of the filesystem.
52
46
self.deploy_files = None
54
48
# 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)
49
# need to be checked for deployment conflicts or copied-out)
56
50
self.affected_files = None
58
# the revno that the repo was as prior to a recent update
59
self.initial_revno = None
61
52
# do we have a repo?
62
53
if not os.path.exists( the.repo.full_dir ): return
69
60
# read the file list
70
if the.verbose: print "deployment state found; loading"
61
if the.verbose: print "loading deployment state"
71
62
f = open( file, 'r' )
72
63
state = json.loads( f.read() )
74
65
# unpack deployment state
75
66
self.deploy_files = state['deploy_files'];
76
self.initial_revno = state['initial_revno'];
77
67
self.affected_files = state['affected_files'];
80
70
def save_deployment_state( self ):
81
"""Save the current deployment state (so there will be a deployment ongoing).
84
71
if the.verbose: print "saving deployment state"
86
73
# create metadata directory, as necessary
116
100
def is_ongoing( self ):
117
"""Is there a deployment currently ongoing?
120
101
return False if self.deploy_files is None else True
123
104
def check_ongoing( self, ongoing = True ):
124
"""Check that a deployment either is or is not ongoing and raise an error if
129
106
if self.deploy_files is None:
130
107
raise self.DeploymentOngoing( False )
133
110
raise self.DeploymentOngoing( True )
136
def get_initial_revno( self ):
137
"""Get the initial revision identifier from the deployment state.
140
return self.initial_revno
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.
148
115
# check we don't already have a file list
149
116
self.check_ongoing( False )
156
123
if the.verbose: print "importing files..."
157
124
walker = CopyInWalker()
126
if( walker.changed ):
127
raise self.CopyInConflicts( walker.changed )
159
128
self.deploy_files = walker.walk_list
161
# obtain initial revno
162
self.initial_revno = the.repo.vcs.get_revno()
165
131
self.save_deployment_state()
168
134
def get_conflicts( self, affected_files = None ):
169
"""Check to see if there are any delpoyment conflicts. If a list of affected
170
files is supplied, then only those files are checked (and they are also
171
saved with the deployment state). Otherwise, all files in the
172
repository are checked.
175
136
# check we have a file list
176
137
self.check_ongoing( True )
187
148
self.conflicts_checked = True
188
return walker.changed + walker.obstructed
149
return walker.changed
191
152
def copy_out( self ):
192
"""Copy-out changed files frmo the repository to the home directory. If the
193
deployment state incudes a list of affected files, then only those fiels
197
154
# check we have a file list
198
155
self.check_ongoing( True )
added
removed
lib/stdhome/deployment.py
