-# -*- coding: utf8 -*-
from Components.MenuList import MenuList
from Screens.Screen import Screen
from Screens.MessageBox import MessageBox
client.HTTPDownloader.page(self, "")
else:
client.HTTPDownloader.noPage(self, reason)
-
+
def gotHeaders(self, headers):
if self.status == "200":
if headers.has_key("content-length"):
self.totalbytes = 0
self.currentbytes = 0.0
return client.HTTPDownloader.gotHeaders(self, headers)
-
+
def pagePart(self, packet):
if self.status == "200":
self.currentbytes += len(packet)
if self.totalbytes and self.progress_callback:
self.progress_callback(self.currentbytes, self.totalbytes)
return client.HTTPDownloader.pagePart(self, packet)
-
+
def pageEnd(self):
return client.HTTPDownloader.pageEnd(self)
scheme, host, port, path = client._parse(url)
self.factory = HTTPProgressDownloader(url, outputfile, *args, **kwargs)
self.connection = reactor.connectTCP(host, port, self.factory)
-
+
def start(self):
return self.factory.deferred
-
+
def stop(self):
print "[stop]"
self.connection.disconnect()
def getNFIname(self):
l = self.l.getCurrentSelection()
return l and l[0][0]
-
+
def getNFIurl(self):
l = self.l.getCurrentSelection()
return l and l[0][1]
-
+
def getNFOname(self):
l = self.l.getCurrentSelection()
return l and l[0][0][:-3]+"nfo"
return False
else:
return True
-
+
def moveSelection(self,idx=0):
if self.instance is not None:
self.instance.moveSelectionTo(idx)
self.box = HardwareInfo().get_device_name()
self.feed_base = "http://www.dreamboxupdate.com/opendreambox/1.5/%s/images/" % self.box
self.nfi_filter = "" # "release" # only show NFIs containing this string, or all if ""
-
+
self["actions"] = ActionMap(["OkCancelActions", "ColorActions", "DirectionActions", "EPGSelectActions"],
{
"cancel": self.closeCB,
"downRepeated": self.down,
"down": self.down
}, -1)
-
+
self.feed_download()
-
+
def downloading(self, state=True):
if state is True:
self["key_red"].text = _("Cancel")
self["key_green"].text = ""
self["key_yellow"].text = ""
self["key_blue"].text = ""
-
else:
self.download = None
self["key_red"].text = _("Exit")
else:
self["key_yellow"].text = (_("Select image"))
self["key_blue"].text = (_("Fix USB stick"))
-
+
def switchList(self,to_where=None):
if self.download or not self["feedlist"].isValid():
return
-
+
self["job_progressbar"].value = 0
self["job_progresslabel"].text = ""
-
+
if to_where is None:
if self.focus is self.LIST_SOURCE:
to_where = self.LIST_DEST
if self.focus is self.LIST_DEST:
to_where = self.LIST_SOURCE
-
+
if to_where is self.LIST_DEST:
self.focus = self.LIST_DEST
self["statusbar"].text = _("Please select target directory or medium")
self["label_bottom"].text = _("Selected source image")+":"
self["path_bottom"].text = str(self["feedlist"].getNFIname())
self["key_yellow"].text = (_("Select image"))
-
+
elif to_where is self.LIST_SOURCE:
self.focus = self.LIST_SOURCE
self["statusbar"].text = _("Please choose .NFI image file from feed server to download")
self["label_bottom"].text = _("Destination directory")+":"
self["path_bottom"].text = str(self["destlist"].getCurrentDirectory())
self["key_yellow"].text = (_("Change dir."))
-
+
def up(self):
if self.download:
return
self.nfo_download()
if self.focus is self.LIST_DEST:
self["destlist"].up()
-
+
def down(self):
if self.download:
return
self.nfo_download()
if self.focus is self.LIST_DEST:
self["destlist"].down()
-
+
def left(self):
if self.download:
return
self.nfo_download()
if self.focus is self.LIST_DEST:
self["destlist"].pageUp()
-
+
def right(self):
if self.download:
return
self.nfofilename = ""
self.nfo = ""
self.downloading(False)
-
+
def nfo_finished(self,nfodata=""):
print "[nfo_finished] " + str(nfodata)
self.downloading(False)
self.switchList(self.LIST_TARGET)
if self["feedlist"].isValid():
url = self["feedlist"].getNFIurl()
- localfile = self["destlist"].getCurrentDirectory()+'/'+self["feedlist"].getNFIname()
- print "[nfi_download] downloading %s to %s" % (url, localfile)
- self.download = downloadWithProgress(url,localfile)
+ self.nfilocal = self["destlist"].getCurrentDirectory()+'/'+self["feedlist"].getNFIname()
+ print "[nfi_download] downloading %s to %s" % (url, self.nfilocal)
+ self.download = downloadWithProgress(url,self.nfilocal)
self.download.addProgress(self.nfi_progress)
self["job_progressbar"].range = 1000
self.download.start().addCallback(self.nfi_finished).addErrback(self.nfi_failed)
#print "[update_progress] recvbytes=%d, totalbytes=%d" % (recvbytes, totalbytes)
self["job_progressbar"].value = int(1000*recvbytes/float(totalbytes))
self["job_progresslabel"].text = "%d of %d kBytes (%.2f%%)" % (recvbytes/1024, totalbytes/1024, 100*recvbytes/float(totalbytes))
-
+
def nfi_failed(self, failure_instance=None, error_message=""):
if error_message == "" and failure_instance is not None:
error_message = failure_instance.getErrorMessage()
self.session.open(MessageBox, message, MessageBox.TYPE_ERROR)
self.downloading(False)
- #def nfi_failed(self, failure_instance):
- #print "[nfi_failed] "
- #print failure_instance
- #if isinstance(failure_instance, Plugins.SystemPlugins.NFIFlash.plugin.UserRequestedCancel):
- #print "is instance of Plugins.SystemPlugins.NFIFlash.plugin.UserRequestedCancel"
- #else:
- #print "not an instance of Plugins.SystemPlugins.NFIFlash.plugin.UserRequestedCancel"
-
def nfi_finished(self, string=""):
print "[nfi_finished] " + str(string)
if self.nfo != "":
+ self.nfofilename = self["destlist"].getCurrentDirectory() + '/' + self["feedlist"].getNFOname()
nfofd = open(self.nfofilename, "w")
if nfofd:
nfofd.write(self.nfo)
nfofd.close()
else:
print "couldn't save nfo file " + self.nfofilename
-
- pos = self.nfo.find("md5sum")
- if pos > 0:
+
+ pos = self.nfo.find("MD5:")
+ if pos > 0 and len(self.nfo) >= pos+5+32:
self["statusbar"].text = _("Please wait for md5 signature verification...")
- cmd = "md5sum -cs " + self.nfofilename
- print cmd
+ cmd = "md5sum -c -"
+ md5 = self.nfo[pos+5:pos+5+32] + " " + self.nfilocal
+ print cmd, md5
self.download_container.setCWD(self["destlist"].getCurrentDirectory())
- self.download_container.appClosed.get().append(self.md5finished)
+ self.download_container.appClosed.append(self.md5finished)
self.download_container.execute(cmd)
+ self.download_container.write(md5)
+ self.download_container.dataSent.append(self.md5ready)
else:
self["statusbar"].text = "Download completed."
self.downloading(False)
self["statusbar"].text = "Download completed."
self.downloading(False)
+ def md5ready(self, retval):
+ self.download_container.sendEOF()
+
def md5finished(self, retval):
print "[md5finished]: " + str(retval)
- self.download_container.appClosed.get().remove(self.md5finished)
+ self.download_container.appClosed.remove(self.md5finished)
if retval==0:
self["statusbar"].text = _(".NFI file passed md5sum signature check. You can safely flash this image!")
self.switchList(self.LIST_SOURCE)
self.downloading(False)
else:
self.session.openWithCallback(self.nfi_remove, MessageBox, (_("The md5sum validation failed, the file may be downloaded incompletely or be corrupted!") + "\n" + _("Remove the broken .NFI file?")), MessageBox.TYPE_YESNO)
-
+
def nfi_remove(self, answer):
self.downloading(False)
if answer == True:
self.imagefilename = "/tmp/nfiflash_" + self.box + ".img"
message = _("You have chosen to create a new .NFI flasher bootable USB stick. This will repartition the USB stick and therefore all data on it will be erased.")
self.session.openWithCallback(self.flasherdownload_query, MessageBox, (message + '\n' + _("First we need to download the latest boot environment for the USB flasher.")), MessageBox.TYPE_YESNO)
-
+
def flasherdownload_query(self, answer):
if answer is False:
self.downloading(False)
print "[flasherdownload_failed] " + error_message
message = "%s %s" % (_("Download of USB flasher boot image failed: "),error_message)
self.session.open(MessageBox, message, MessageBox.TYPE_ERROR)
- self.query_remove_img(True)
+ self.remove_img(True)
def flasherdownload_finished(self, string=""):
print "[flasherdownload_finished] " + str(string)
self.container = eConsoleAppContainer()
- self.container.appClosed.get().append(self.umount_finished)
- self.container.dataAvail.get().append(self.tool_avail)
+ self.container.appClosed.append(self.umount_finished)
+ self.container.dataAvail.append(self.tool_avail)
self.taskstring = ""
umountdevs = ""
from os import listdir
self.taskstring += string
def umount_finished(self, retval):
- self.container.appClosed.get().remove(self.umount_finished)
+ self.container.appClosed.remove(self.umount_finished)
self.session.openWithCallback(self.dmesg_clear, MessageBox, _("To make sure you intend to do this, please remove the target USB stick now and stick it back in upon prompt. Press OK when you have taken the stick out."), MessageBox.TYPE_INFO)
def dmesg_clear(self, answer):
- self.container.appClosed.get().append(self.dmesg_cleared)
+ self.container.appClosed.append(self.dmesg_cleared)
self.taskstring = ""
self.cmd = "dmesg -c"
print "executing " + self.cmd
self.container.execute(self.cmd)
-
+
def dmesg_cleared(self, retval):
- self.container.appClosed.get().remove(self.dmesg_cleared)
+ self.container.appClosed.remove(self.dmesg_cleared)
self.session.openWithCallback(self.stick_back_in, MessageBox, (_("Now please insert the USB stick (minimum size is 64 MB) that you want to format and use as .NFI image flasher. Press OK after you've put the stick back in.")), MessageBox.TYPE_INFO)
def stick_back_in(self, answer):
self["job_progresslabel"].text = "-%d s" % (6-self.delayCount)
if self.delayCount > 5:
self.delayTimer.stop()
- self.container.appClosed.get().append(self.dmesg_scanned)
+ self.container.appClosed.append(self.dmesg_scanned)
self.taskstring = ""
self.cmd = "dmesg"
print "executing " + self.cmd
self.container.execute(self.cmd)
-
+
def dmesg_scanned(self, retval):
- self.container.appClosed.get().remove(self.dmesg_scanned)
+ self.container.appClosed.remove(self.dmesg_scanned)
dmesg_lines = self.taskstring.splitlines()
self.devicetext = None
self.stickdevice = None
self.session.openWithCallback(self.remove_img, MessageBox, _("No useable USB stick found"), MessageBox.TYPE_ERROR)
else:
self.session.openWithCallback(self.fdisk_query, MessageBox, (_("The following device was found:\n\n%s\n\nDo you want to write the USB flasher to this stick?") % self.devicetext), MessageBox.TYPE_YESNO)
-
+
def fdisk_query(self, answer):
if answer == True:
self["statusbar"].text = _("Partitioning USB stick...")
self["job_progressbar"].value = 100
self["job_progresslabel"].text = "5.00%"
self.taskstring = ""
- self.container.appClosed.get().append(self.fdisk_finished)
+ self.container.appClosed.append(self.fdisk_finished)
self.container.execute("fdisk " + self.stickdevice + "/disc")
self.container.write("d\nn\np\n1\n\n\nt\n6\nw\n")
self.delayTimer = eTimer()
self.delayTimer.callback.append(self.progress_increment)
self.delayTimer.start(105, False)
else:
- self.remove_img()
+ self.remove_img(True)
def fdisk_finished(self, retval):
- self.container.appClosed.get().remove(self.fdisk_finished)
+ self.container.appClosed.remove(self.fdisk_finished)
self.delayTimer.stop()
if retval == 0:
if fileExists(self.imagefilename):
else:
self["statusbar"].text = _("Decompressing USB stick flasher boot image...")
self.taskstring = ""
- self.container.appClosed.get().append(self.tar_finished)
+ self.container.appClosed.append(self.tar_finished)
self.container.setCWD("/tmp")
self.cmd = "tar -xjvf nfiflasher_image.tar.bz2"
self.container.execute(self.cmd)
def tar_finished(self, retval):
self.delayTimer.stop()
- if len(self.container.appClosed.get()) > 0:
- self.container.appClosed.get().remove(self.tar_finished)
+ if len(self.container.appClosed) > 0:
+ self.container.appClosed.remove(self.tar_finished)
if retval == 0:
self.imagefilename = "/tmp/nfiflash_" + self.box + ".img"
self["statusbar"].text = _("Copying USB flasher boot image to stick...")
self.taskstring = ""
- self.container.appClosed.get().append(self.dd_finished)
+ self.container.appClosed.append(self.dd_finished)
self.cmd = "dd if=%s of=%s" % (self.imagefilename,self.stickdevice+"/part1")
self.container.execute(self.cmd)
print "executing " + self.cmd
def dd_finished(self, retval):
self.delayTimer.stop()
- self.container.appClosed.get().remove(self.dd_finished)
+ self.container.appClosed.remove(self.dd_finished)
self.downloading(False)
if retval == 0:
self["job_progressbar"].value = 950
self["job_progresslabel"].text = "95.00%"
self["statusbar"].text = _("Remounting stick partition...")
self.taskstring = ""
- self.container.appClosed.get().append(self.mount_finished)
+ self.container.appClosed.append(self.mount_finished)
self.cmd = "mount %s /mnt/usb -o rw,sync" % (self.stickdevice+"/part1")
self.container.execute(self.cmd)
print "executing " + self.cmd
self.session.openWithCallback(self.remove_img, MessageBox, (self.cmd + " " + _("failed") + ":\n" + str(self.taskstring)), MessageBox.TYPE_ERROR)
def mount_finished(self, retval):
- self.container.dataAvail.get().remove(self.tool_avail)
- self.container.appClosed.get().remove(self.mount_finished)
+ self.container.dataAvail.remove(self.tool_avail)
+ self.container.appClosed.remove(self.mount_finished)
if retval == 0:
self["job_progressbar"].value = 1000
self["job_progresslabel"].text = "100.00%"
self["destlist"].changeDir("/mnt/usb")
else:
self.session.openWithCallback(self.remove_img, MessageBox, (self.cmd + " " + _("failed") + ":\n" + str(self.taskstring)), MessageBox.TYPE_ERROR)
-
+
def remove_img(self, answer):
if fileExists("/tmp/nfiflasher_image.tar.bz2"):
remove("/tmp/nfiflasher_image.tar.bz2")
git.cweiske.de / enigma2.git / blobdiff