#!/usr/bin/python
# -*- coding: utf-8 -*-

import sys
from PyQt4 import QtGui, QtCore
import threading
from socket import *
import Queue
import time


class Conn(threading.Thread):
    JPEG_HEAD = """\xff\xd8"""
    JPEG_TAIL = """\xff\xd9"""
    #HOST = '172.16.24.56'

    def __init__(self, parent):
        threading.Thread.__init__(self, name='Conn')
        self._stopEvent = threading.Event()
        self.buf = ''
        self.parent = parent

    def join(self, timeout=None):
        self._stopEvent.set()
   
    def process(self):
        begin = end = 0
        while True:
            try:
                begin = self.buf.index(self.JPEG_HEAD, begin)
            except Exception, ex:
                #print 'no begin'
                time.sleep(0.1)
                break
           
            try:
                end = self.buf.index(self.JPEG_TAIL, begin) + len(self.JPEG_TAIL)
            except:
                #print 'no end'
                time.sleep(0.1)
                break
           
            img = self.buf[begin : end]
            begin = end
           
            self.parent.img_queue.put(img)
            #self.emit(QtCore.SIGNAL("show_picture(QString)"), '')
       
        self.buf = self.buf[begin:]
   
    def run(self):
       
        err_counter = 0
        while not self._stopEvent.isSet():
           
            self.sd = socket(AF_INET, SOCK_STREAM)
            self.sd.settimeout(16)
            try:
                self.sd.connect((self.parent.HOST, self.parent.PORT))
            except Exception, ex:
                print 'cannot connect to host:', ex
                self.sd.close()
                time.sleep(1)
               
                err_counter += 1
                if err_counter > 5:
                    self.parent.disconnect_slot()
                    self._stopEvent.set()
                continue
           
            while not self._stopEvent.isSet():
                try:
                    data = self.sd.recv(1024 * 64)
                    if data:
                        self.buf += data
                    else:
                        print 'link down'
                        break
                except Exception, ex:
                    print 'recv except: %s' %(ex)
                    break
               
                self.process()
               
                #print len(self.buf)
                #print '======================\n'


class ConnWindow(QtGui.QWidget):

    def __init__(self, parent):
        QtGui.QWidget.__init__(self)
        self.parent = parent
       
        grid_layout = QtGui.QGridLayout()
       
        if self.parent.HOST or self.parent.PORT:
            self.host_edit = QtGui.QLineEdit(self.parent.HOST, self)
            self.port_edit = QtGui.QLineEdit(str(self.parent.PORT), self)
            self.conn_btn = QtGui.QPushButton('done', self)
        else:
            self.host_edit = QtGui.QLineEdit('set host name here', self)
            self.port_edit = QtGui.QLineEdit('set port number here', self)
            self.conn_btn = QtGui.QPushButton('done', self)
        self.connect(self.conn_btn, QtCore.SIGNAL('clicked()'), self.done_slot)
       
        grid_layout.addWidget(self.host_edit, 0, 0)
        grid_layout.addWidget(self.port_edit, 1, 0)
        grid_layout.addWidget(self.conn_btn, 3, 3)
        self.setLayout(grid_layout)
       
        self.resize(320, 320)

    def done_slot(self):
        host = self.host_edit.text()
        port = self.port_edit.text().toInt()
       
        if port[1]:
            port = port[0]
            if (port > 65535 or port <= 0):
                QtGui.QMessageBox.warning(self, 'ERROR', 'Port should be a integer between 0 and 65535')
                return
        else:
            QtGui.QMessageBox.warning(self, 'ERROR', 'Port should be a integer')
            return
       
        sd = socket(AF_INET, SOCK_STREAM)
        try:
            sd.connect((host, port))
            sd.close()
        except Exception, ex:
            QtGui.QMessageBox.warning(self,"CANNOT ACCESS",'Cannot connect to service you given! Please input host name and port name again.\ndetail: %s' %(ex))
            return
       
        self.parent.HOST = host
        self.parent.PORT = port
        self.parent.connect_slot()
        self.close()


class Gui(QtGui.QWidget):
   
    def __init__(self):
        QtGui.QWidget.__init__(self)
       
        self.pic_label_frame = QtGui.QFrame(self)
        self.pic_label_frame.setGeometry(0, 0, 720, 540)
        self.pic_label = QtGui.QLabel(self.pic_label_frame)
        self.pic_label.setScaledContents(True)
        self.scroll = QtGui.QScrollArea(self.pic_label_frame)
        self.scroll.setWidget(self.pic_label)
        self.scroll.resize(720, 540)
        self.scroll.setWidgetResizable(True)
       
        self.cmd_frame = QtGui.QFrame(self)
        self.cmd_frame.setGeometry(0, 540, 720, 40)
        self.conn_btn = QtGui.QPushButton(self.cmd_frame)
        self.conn_btn.setGeometry(0, 10, 100, 30)
        self.conn_btn.setText('CONNECT')
        self.pic_label.setText('click "CONNECT" to setup host and port')
        self.connect(self.conn_btn, QtCore.SIGNAL('clicked()'), self.show_conn_window)
       
        self.img_queue = Queue.Queue()
        #self.connect(self.conn, QtCore.SIGNAL('show_picture(QString)'), self.show_picture_sig)
       
        self.timer = QtCore.QTimer(self)
        self.connect(self.timer,QtCore.SIGNAL("timeout()"),self.show_picture_timer)
       
        self.HOST = ''
        self.PORT = 0
        self.resize(720, 580)

    def connect_slot(self):
        self.disconnect_slot()
       
        self.conn = Conn(self)
        self.conn.start()
        self.timer.start()

    def disconnect_slot(self):
        self.timer.stop()
        if hasattr(self, 'conn'):
            self.conn.join()
        self.pic_label.setText('disconnected')

    #def show_picture_sig(self, data):
        #img = QtGui.QPixmap()
        #if img.loadFromData(self.img_queue.get_nowait()):
            #print 'showing'
            #self.pic_label.setPixmap(img)
        #else:
            #print 'not a image, cannot show'

    def show_conn_window(self):
        self.conn_win = ConnWindow(self)
        self.conn_win.show()
   
    def show_picture_timer(self):
        try:
            data = self.img_queue.get_nowait()
        except:
            return
       
        img = QtGui.QPixmap()
        if img.loadFromData(data):
            self.pic_label.setPixmap(img)
        else:
            print 'not a image, cannot show'


####
if __name__ == '__main__':
    app = QtGui.QApplication(sys.argv)
    run = Gui()
    run.show()
   
    app.exec_()