+class msgproc(object):
+ def attach(self, reader):
+ self.rd = reader
+ self.msg = gtk.Alignment(0, 0.5, 0, 0)
+ self.hlay = gtk.HBox()
+ self.lbl = gtk.Label("")
+ self.hlay.pack_start(self.lbl)
+ self.lbl.show()
+ self.msg.add(self.hlay)
+ self.hlay.show()
+ self.rd.sbar.pack_start(self.msg)
+ self.msg.show()
+ self._prog = None
+
+ def prog(self, p):
+ if p is not None:
+ if self._prog is None:
+ self._prog = gtk.ProgressBar()
+ self.hlay.pack_start(self._prog, padding=5)
+ self._prog.show()
+ self._prog.set_fraction(p)
+ elif p is None and self._prog is not None:
+ self.hlay.remove(self._prog)
+ self._prog = None
+
+ def abort(self):
+ self.rd.sbar.remove(self.msg)
+
+class pagefetch(msgproc):
+ def __init__(self, fpage, setcb=None):
+ self.pg = fpage
+ self.setcb = setcb
+
+ def attach(self, reader):
+ super(pagefetch, self).attach(reader)
+ self.lbl.set_text("Fetching page...")
+ self.pg.notify(self.haspage)
+
+ def haspage(self):
+ if self.rd.pagefetch.cur != self: return False
+ if not self.pg.done:
+ return True
+ if self.pg.val is not None:
+ self.rd.setpage(self.pg.val)
+ if self.setcb is not None:
+ self.setcb(self.pg.val)
+ self.rd.pagefetch.set(None)
+
+class imgfetch(msgproc):
+ def __init__(self, fimage):
+ self.img = fimage
+ self.upd = False
+ self.error = None
+
+ def attach(self, reader):
+ super(imgfetch, self).attach(reader)
+ self.lbl.set_text("Fetching image...")
+ self.img.notify(self.imgprog)
+
+ def imgprog(self):
+ if self.rd.imgfetch.cur != self: return False
+ if self.img.done:
+ try:
+ img = self.img.val
+ except Exception as e:
+ self.error = str(e)
+ else:
+ self.rd.setimg(img)
+ self.upd = True
+ self.rd.imgfetch.set(None)
+ else:
+ self.prog(self.img.prog)
+ return True
+
+ def abort(self):
+ self.rd.sbar.remove(self.msg)
+ if not self.upd:
+ self.rd.setimg(None)
+ if self.error is not None:
+ self.rd.pagelbl.set_text("Error fetching image: " + self.error)
+
+class preload(msgproc):
+ def __init__(self, fpage):
+ self.pg = fpage
+
+ def attach(self, reader):
+ super(preload, self).attach(reader)
+ self.lbl.set_text("Fetching next page...")
+ self.pg.notify(self.haspage)
+
+ def haspage(self):
+ if self.rd.preload.cur != self: return False
+ if not self.pg.done: return True
+ if self.pg.val is not None:
+ self.img = self.rd.cache[self.pg.val]
+ self.lbl.set_text("Loading next page...")
+ self.img.notify(self.imgprog)
+ else:
+ self.rd.preload.set(None)
+
+ def imgprog(self):
+ if self.rd.preload.cur != self: return False
+ if self.img.done:
+ self.rd.preload.set(None)
+ else:
+ self.prog(self.img.prog)
+ return True
+
+ def abort(self):
+ self.rd.sbar.remove(self.msg)
+
+class procslot(object):
+ __slots__ = ["cur", "p"]
+ def __init__(self, p):
+ self.cur = None
+ self.p = p
+
+ def set(self, proc):
+ if self.cur is not None:
+ self.cur.abort()
+ self.cur = None
+ if proc is not None:
+ self.cur = proc
+ try:
+ proc.attach(self.p)
+ except:
+ self.cur = None
+ raise
+
+class plistget(future):
+ def __init__(self, node):
+ super(plistget, self).__init__()
+ self.node = node
+
+ def value(self):
+ return list(self.node)
+
+class loadplist(object):
+ def __init__(self, pnode):
+ self.pnode = pnode
+ self.flist = plistget(self.pnode)
+
+ def attach(self, sbox):
+ self.sbox = sbox
+ self.flist.notify(self.haslist)
+
+ def haslist(self):
+ if self.sbox.loadlist.cur != self: return False
+ if not self.flist.done: return True
+ self.sbox.setlist(self.flist.val)
+
+class sbox(gtk.ComboBox):
+ def __init__(self, reader, ptnode):
+ super(sbox, self).__init__()
+ self.rd = reader
+ self.node = ptnode
+ self.pnode, self.pidx = self.node.stack[-1]
+
+ self.bk = gtk.ListStore(str)
+ self.set_model(self.bk)
+ cell = gtk.CellRendererText()
+ self.pack_start(cell, True)
+ self.add_attribute(cell, "text", 0)
+ self.set_active(0)
+
+ self.set_sensitive(False)
+ self.set_focus_on_click(False)
+ self.bk.append([ptnode.name])
+ self.loadlist = procslot(self)
+ self.loadlist.set(loadplist(self.pnode))
+
+ def setlist(self, ls):
+ self.bk.clear()
+ for i, ch in enumerate(ls):
+ self.bk.append(["%i/%i: %s" % (i + 1, len(ls), ch.name)])
+ self.set_active(self.pidx)
+ self.set_sensitive(True)
+ self.connect("changed", self.changed_cb)
+
+ def changed_cb(self, wdg, data=None):
+ self.rd.fetchpage(pageget(self.pnode[self.get_active()]))
+
+class profprop(object):
+ def __init__(self, key, default=None):
+ self.key = key
+ self.default = default
+
+ def __get__(self, ins, cls):
+ return ins.profile.props.get(self.key, self.default)
+
+ def __set__(self, ins, val):
+ ins.profile.props[self.key] = val
+ ins.profile.save()
+
+ def __delete__(self, ins):
+ del ins.profile.props[self.key]
+ ins.profile.save()
+
+class reader(gtk.Window):
+ def __init__(self, manga, prof=None):
+ super(reader, self).__init__(gtk.WINDOW_TOPLEVEL)
+ self.connect("delete_event", lambda wdg, ev, data=None: False)
+ self.connect("destroy", lambda wdg, data=None: self.quit())
+ self.connect("key_press_event", self.key)
+ self.cache = pagecache()
+ self.pagefetch = procslot(self)
+ self.imgfetch = procslot(self)
+ self.preload = procslot(self)
+ self.profile = prof if prof else profile.memmanga(None, None, manga.id)
+
+ self.manga = manga