14
15
# along with this program; if not, write to the Free Software
15
16
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21
20
pygtk.require("2.0")
31
import olive.backend.commit as commit
32
import olive.backend.errors as errors
33
import olive.backend.info as info
36
""" Display Push dialog and perform the needed actions. """
37
def __init__(self, gladefile, comm, dialog):
26
from errors import show_bzr_error
28
from bzrlib.config import LocationConfig
29
import bzrlib.errors as errors
31
from dialog import error_dialog, info_dialog, question_dialog
33
from history import UrlHistory
35
class PushDialog(gtk.Dialog):
36
""" New implementation of the Push dialog. """
37
def __init__(self, repository, revid, branch=None, parent=None):
38
38
""" Initialize the Push dialog. """
39
self.gladefile = gladefile
40
self.glade = gtk.glade.XML(self.gladefile, 'window_push')
42
# Communication object
47
self.window = self.glade.get_widget('window_push')
49
# Dictionary for signal_autoconnect
50
dic = { "on_button_push_push_clicked": self.push,
51
"on_button_push_cancel_clicked": self.close,
52
"on_button_push_test_clicked": self.test,
53
"on_radiobutton_push_stored_toggled": self.stored_toggled,
54
"on_radiobutton_push_specific_toggled": self.specific_toggled, }
56
# Connect the signals to the handlers
57
self.glade.signal_autoconnect(dic)
59
# Get some useful widgets
60
self.radio_stored = self.glade.get_widget('radiobutton_push_stored')
61
self.radio_specific = self.glade.get_widget('radiobutton_push_specific')
62
self.entry_stored = self.glade.get_widget('entry_push_stored')
63
self.entry_location = self.glade.get_widget('entry_push_location')
64
self.check_remember = self.glade.get_widget('checkbutton_push_remember')
65
self.check_overwrite = self.glade.get_widget('checkbutton_push_overwrite')
66
self.check_create = self.glade.get_widget('checkbutton_push_create')
67
self.label_test = self.glade.get_widget('label_push_test')
68
self.image_test = self.glade.get_widget('image_push_test')
71
self.entry_location.set_sensitive(0)
72
self.check_remember.set_sensitive(0)
73
self.check_create.set_sensitive(0)
76
self.notbranch = False
78
loc = info.get_push_location(self.comm.get_path())
79
except errors.NotBranchError:
84
self.entry_stored.set_text(loc)
87
""" Display the Push dialog. """
89
self.dialog.error_dialog(_('Directory is not a branch'),
90
_('You can perform this action only in a branch.'))
94
self.width, self.height = self.window.get_size()
96
def stored_toggled(self, widget):
97
if widget.get_active():
98
self.entry_stored.set_sensitive(1)
99
self.entry_location.set_sensitive(0)
100
self.check_remember.set_sensitive(0)
101
self.check_create.set_sensitive(0)
103
self.entry_stored.set_sensitive(0)
104
self.entry_location.set_sensitive(1)
105
self.check_remember.set_sensitive(1)
106
self.check_create.set_sensitive(1)
108
def specific_toggled(self, widget):
109
if widget.get_active():
110
self.entry_stored.set_sensitive(0)
111
self.entry_location.set_sensitive(1)
112
self.check_remember.set_sensitive(1)
113
self.check_create.set_sensitive(1)
115
self.entry_stored.set_sensitive(1)
116
self.entry_location.set_sensitive(0)
117
self.check_remember.set_sensitive(0)
118
self.check_create.set_sensitive(0)
120
def push(self, widget):
122
self.comm.set_busy(self.window)
123
if self.radio_stored.get_active():
125
revs = commit.push(self.comm.get_path(),
126
overwrite=self.check_overwrite.get_active())
127
except errors.NotBranchError:
128
self.dialog.error_dialog(_('Directory is not a branch'),
129
_('You can perform this action only in a branch.'))
131
except errors.NoLocationKnown:
132
self.dialog.error_dialog(_('Push location is unknown'),
133
_('Please specify a location manually.'))
135
except errors.NonExistingParent, errmsg:
136
self.dialog.error_dialog(_('Non existing parent directory'),
137
_("The parent directory (%s)\ndoesn't exist.") % errmsg)
139
except errors.DivergedBranchesError:
140
self.dialog.error_dialog(_('Branches have been diverged'),
141
_('You cannot push if branches have diverged. Use the\noverwrite option if you want to push anyway.'))
145
elif self.radio_specific.get_active():
146
location = self.entry_location.get_text()
148
self.dialog.error_dialog(_('No location specified'),
149
_('Please specify a location or use the default.'))
153
revs = commit.push(self.comm.get_path(), location,
154
self.check_remember.get_active(),
155
self.check_overwrite.get_active(),
156
self.check_create.get_active())
157
except errors.NotBranchError:
158
self.dialog.error_dialog(_('Directory is not a branch'),
159
_('You can perform this action only in a branch.'))
160
self.comm.set_busy(self.window, False)
162
except errors.NonExistingParent, errmsg:
163
self.dialog.error_dialog(_('Non existing parent directory'),
164
_("The parent directory (%s)\ndoesn't exist.") % errmsg)
165
self.comm.set_busy(self.window, False)
167
except errors.DivergedBranchesError:
168
self.dialog.error_dialog(_('Branches have been diverged'),
169
_('You cannot push if branches have diverged. Use the\noverwrite option if you want to push anyway.'))
170
self.comm.set_busy(self.window, False)
172
except errors.PathPrefixNotCreated:
173
self.dialog.error_dialog(_('Path prefix not created'),
174
_("The path leading up to the specified location couldn't\nbe created."))
175
self.comm.set_busy(self.window, False)
180
# This should really never happen
184
self.dialog.info_dialog(_('Push successful'),
185
_('%d revision(s) pushed.') % revs)
187
def test(self, widget):
188
""" Test if write access possible. """
39
gtk.Dialog.__init__(self, title="Push - Olive",
42
buttons=(gtk.STOCK_CANCEL, gtk.RESPONSE_CANCEL))
45
self.repository = repository
50
self._label_location = gtk.Label(_("Location:"))
51
self._label_test = gtk.Label(_("(click the Test button to check write access)"))
52
self._check_prefix = gtk.CheckButton(_("Create the path _leading up to the location"),
54
self._combo = gtk.ComboBoxEntry()
55
self._button_test = gtk.Button(_("_Test"), use_underline=True)
56
self._button_push = gtk.Button(_("_Push"), use_underline=True)
57
self._hbox_location = gtk.HBox()
58
self._hbox_test = gtk.HBox()
59
self._image_test = gtk.Image()
62
self._button_test.connect('clicked', self._on_test_clicked)
63
self._button_push.connect('clicked', self._on_push_clicked)
66
self._image_test.set_from_stock(gtk.STOCK_DIALOG_INFO, gtk.ICON_SIZE_BUTTON)
67
self._label_location.set_alignment(0, 0.5)
68
self._label_test.set_alignment(0, 0.5)
69
self._hbox_location.set_spacing(3)
70
self._hbox_test.set_spacing(3)
71
self.vbox.set_spacing(3)
74
self._hbox_location.pack_start(self._label_location, False, False)
75
self._hbox_location.pack_start(self._combo, True, True)
76
self._hbox_test.pack_start(self._image_test, False, False)
77
self._hbox_test.pack_start(self._label_test, True, True)
78
self.vbox.pack_start(self._hbox_location)
79
self.vbox.pack_start(self._check_prefix)
80
self.vbox.pack_start(self._hbox_test)
81
self.action_area.pack_start(self._button_test)
82
self.action_area.pack_end(self._button_push)
87
# Build location history
88
self._history = UrlHistory(self.branch.get_config(), 'push_history')
91
def _build_history(self):
92
""" Build up the location history. """
93
self._combo_model = gtk.ListStore(str)
94
for item in self._history.get_entries():
95
self._combo_model.append([ item ])
96
self._combo.set_model(self._combo_model)
97
self._combo.set_text_column(0)
99
if self.branch is not None:
100
location = self.branch.get_push_location()
101
if location is not None:
102
self._combo.get_child().set_text(location)
104
def _on_test_clicked(self, widget):
105
""" Test button clicked handler. """
190
107
_urlRE = re.compile(r'^(?P<proto>[^:/\\]+)://(?P<path>.*)$')
192
if self.radio_stored.get_active():
193
url = self.entry_stored.get_text()
194
elif self.radio_specific.get_active():
195
url = self.entry_location.get_text()
109
url = self._combo.get_child().get_text()
197
111
m = _urlRE.match(url)
199
113
proto = m.groupdict()['proto']
200
if (proto == 'sftp') or (proto == 'file') or (proto == 'ftp'):
201
# have write acces (most probably)
202
self.image_test.set_from_stock(gtk.STOCK_YES, 4)
203
self.label_test.set_markup(_('<b>Write access is probably available</b>'))
114
# FIXME: This should ask the transport or branch rather than
115
# guessing using regular expressions. JRV 20070714
116
if proto in ('sftp', 'file', 'ftp'):
117
# have write access (most probably)
118
self._image_test.set_from_stock(gtk.STOCK_YES, 4)
119
self._label_test.set_markup(_('<b>Write access is probably available</b>'))
205
121
# no write access
206
self.image_test.set_from_stock(gtk.STOCK_NO, 4)
207
self.label_test.set_markup(_('<b>No write access</b>'))
122
self._image_test.set_from_stock(gtk.STOCK_NO, 4)
123
self._label_test.set_markup(_('<b>No write access</b>'))
209
125
# couldn't determine
210
self.image_test.set_from_stock(gtk.STOCK_DIALOG_QUESTION, 4)
211
self.label_test.set_markup(_('<b>Could not determine</b>'))
213
def close(self, widget=None):
214
self.window.destroy()
126
self._image_test.set_from_stock(gtk.STOCK_DIALOG_QUESTION, 4)
127
self._label_test.set_markup(_('<b>Could not determine</b>'))
130
def _on_push_clicked(self, widget):
131
""" Push button clicked handler. """
132
location = self._combo.get_child().get_text()
134
if self.branch is not None and self.branch.get_push_location() is None:
135
response = question_dialog(_('Set default push location'),
136
_('There is no default push location set.\nSet %r as default now?') % location)
137
if response == gtk.REPONSE_OK:
138
self.branch.set_push_location(location)
141
revs = do_push(self.branch,
144
create_prefix=self._check_prefix.get_active())
145
except errors.DivergedBranches:
146
response = question_dialog(_('Branches have been diverged'),
147
_('You cannot push if branches have diverged.\nOverwrite?'))
148
if response == gtk.RESPONSE_OK:
149
revs = do_push(self.branch, location=location,
151
create_prefix=self._check_prefix.get_active()
155
self._history.add_entry(location)
156
info_dialog(_('Push successful'),
157
_("%d revision(s) pushed.") % revs)
159
self.response(gtk.RESPONSE_OK)
161
def do_push(branch, location, overwrite, create_prefix):
162
""" Update a mirror of a branch.
164
:param branch: the source branch
166
:param location: the location of the branch that you'd like to update
168
:param overwrite: overwrite target location if it diverged
170
:param create_prefix: create the path leading up to the branch if it doesn't exist
172
:return: number of revisions pushed
174
from bzrlib.bzrdir import BzrDir
175
from bzrlib.transport import get_transport
177
transport = get_transport(location)
178
location_url = transport.base
183
dir_to = BzrDir.open(location_url)
184
br_to = dir_to.open_branch()
185
except errors.NotBranchError:
187
transport = transport.clone('..')
188
if not create_prefix:
190
relurl = transport.relpath(location_url)
191
transport.mkdir(relurl)
192
except errors.NoSuchFile:
193
error_dialog(_('Non existing parent directory'),
194
_("The parent directory (%s)\ndoesn't exist.") % location)
197
current = transport.base
198
needed = [(transport, transport.relpath(location_url))]
201
transport, relpath = needed[-1]
202
transport.mkdir(relpath)
204
except errors.NoSuchFile:
205
new_transport = transport.clone('..')
206
needed.append((new_transport,
207
new_transport.relpath(transport.base)))
208
if new_transport.base == transport.base:
209
error_dialog(_('Path prefix not created'),
210
_("The path leading up to the specified location couldn't\nbe created."))
212
dir_to = br_from.bzrdir.clone(location_url,
213
revision_id=br_from.last_revision())
214
br_to = dir_to.open_branch()
215
count = len(br_to.revision_history())
217
old_rh = br_to.revision_history()
219
tree_to = dir_to.open_workingtree()
220
except errors.NotLocalUrl:
221
# FIXME - what to do here? how should we warn the user?
222
count = br_to.pull(br_from, overwrite)
223
except errors.NoWorkingTree:
224
count = br_to.pull(br_from, overwrite)
226
count = tree_to.pull(br_from, overwrite)
added
removed
push.py
