Changeset 17088 for lang/python

Timestamp:

08/05/08 11:09:40 (4 months ago)

Author:

showyou

Message:

crochet いろいろ追加

Location:

lang/python/crochet

Files:

• chat_allsrc.py (modified) (7 diffs)
• twitter3.py (modified) (1 diff)

lang/python/crochet/chat_allsrc.py

@@ -6 +6 @@
 import wx
 import wx_utils
-from wx_utils import XRC, XRCID, XRCCTRL
 
 import main_icon
@@ -14 +13 @@
 import Image
 
-class MainFrame(wx.Frame):
-        u"""MainFrame class deffinition.
-        """
-        binder = wx_utils.bind_manager()
+import threading
+
+"""
+画像取得用スレッド
+"""
+class ImageGetThread(threading.Thread):
+        def __init__(self,url,callbackFunc,result):
+                threading.Thread.__init__(self)
+                self.url = url 
+                self.func = callbackFunc 
+                self.result = result
+        def run(self):
+                import urllib,time
+                #ここに通信処理を書く
+                imagePath = urllib.urlopen(self.url).read()
+                #time.sleep(1)
+                self.func(imagePath,self.result)
+"""
+twitterにhttpRequestを投げるスレッド
+"""
+class TwDMHttpThread(threading.Thread):
+        def __init__(self,tw,func):
+                threading.Thread.__init__(self)
+                self.tw = tw
+                self.func = func
+        def run(self):
+                #ここに通信処理を書く
+                a = self.tw.getDM("")
+                self.func(a)
+"""
+twitterにhttpRequestを投げるスレッド
+"""
+class TwReplyHttpThread(threading.Thread):
+        def __init__(self,tw,func):
+                threading.Thread.__init__(self)
+                self.tw = tw
+                self.func = func
+        def run(self):
+                #ここに通信処理を書く
+                a = self.tw.getReplies("")
+                self.func(a)
+"""
+twitterにhttpRequestを投げるスレッド
+"""
+class TwHttpThread(threading.Thread):
+        def __init__(self,tw,func):
+                threading.Thread.__init__(self)
+                self.tw = tw
+                self.func = func
+        def run(self):
+                #ここに通信処理を書く
+                a = self.tw.get("")
+                self.func(a)
+
+"""
+最近のfriendsの発言一覧を表示するページ
+"""
+class RecentPage(wx.NotebookPage):
+
         dataList = []
-        TIMER_ID = 1
-        imageList = {}
-        def loadUserData(self, fileName):
-                #ファイルを開いて、データを読み込んで変換する
-                #データ形式は(user,password)
-                #try
-                file = open(fileName,'r')
-                a = simplejson.read(file.read())
-                file.close()
-                return a
-                #catch exit(1)
-                
-        def __init__(self, parent=None):
-                twUserdata = self.loadUserData(".chat/twdata")
-                wx.Frame.__init__(self,None, -1, "crochet")
-                
-                self.CreateStatusBar()
-
-                self.selectedRow = -1
-                text = self.text = wx.TextCtrl(self,-1,style=wx.TE_PROCESS_ENTER)
-                text.Bind(wx.EVT_TEXT_ENTER, self.OnSendTW)
-                button = self.button = wx.Button(self, -1, "Send")
-                self.button.Bind(wx.EVT_BUTTON, self.OnSendTW) 
-        
-                notebook = wx.Notebook(self,-1)
-
-                # Recent
-                recentPage = wx.NotebookPage(notebook,-1)
-                notebook.AddPage(recentPage,u'Recent')
-                list = self.list = wx.ListCtrl(recentPage,-1,style=wx.LC_REPORT|wx.LC_HRULES)
+        def __init__(self, parent):
+                self.owner = parent
+                wx.NotebookPage.__init__(self,parent.getNotebook(),-1)
+                parent.getNotebook().AddPage(self,'Recent')
+                list = self.list = wx.ListCtrl(self,-1,style=wx.LC_REPORT|wx.LC_HRULES)
                 list.Bind(wx.EVT_KEY_DOWN, self.myKeyHandler)
                 list.Bind(wx.EVT_LIST_ITEM_ACTIVATED,self.OnDoubleClick)
-                # Reply
-                replyPage = wx.NotebookPage(notebook,-1)
-                notebook.AddPage(replyPage,u'Reply')
-                replyList = self.replyList = wx.ListCtrl(replyPage,-1,style=wx.LC_REPORT|wx.LC_HRULES)
-                replyList.Bind(wx.EVT_KEY_DOWN, self.myKeyHandler)
-
-                # Direct
-                directPage = wx.NotebookPage(notebook,-1)
-                notebook.AddPage(directPage,u'Direct')
-                directList = self.directList = wx.ListCtrl(directPage,-1,style=wx.LC_REPORT|wx.LC_HRULES)
-                directList.Bind(wx.EVT_KEY_DOWN, self.myKeyHandler)
-
-                inputSizer = wx.BoxSizer(wx.HORIZONTAL)
-                inputSizer.Add(self.text,2,wx.EXPAND)
-                inputSizer.Add(self.button,0)
-                
-
-                messageText=self.messageText = wx.TextCtrl(self,-1,style=wx.TE_MULTILINE|wx.TE_AUTO_URL|wx.TE_READONLY)
-                userIcon = self.userIcon = wx.StaticBitmap(self,-1,wx.NullBitmap,(0,0),(64,64))
-                userName = self.userName = wx.StaticText(self,-1,"test")
-                twitTime = self.twitTime = wx.StaticText(self,-1,"")
-                
-                messageSizer3 = wx.BoxSizer(wx.HORIZONTAL)
-                messageSizer3.Add(userName,0)
-                messageSizer3.Add(twitTime,0)
-
-                messageSizer2 = wx.BoxSizer(wx.VERTICAL)
-                messageSizer2.Add(messageSizer3,0,wx.EXPAND)
-                messageSizer2.Add(messageText,1,wx.EXPAND)
-                
-                messageSizer1 = wx.BoxSizer(wx.HORIZONTAL)
-                messageSizer1.Add(userIcon,0)
-                messageSizer1.Add(messageSizer2,1,wx.EXPAND)
-        
-                messageSizer = wx.BoxSizer(wx.VERTICAL) 
-                messageSizer.Add(messageSizer1,3,wx.EXPAND)
-                messageSizer.Add(inputSizer,1,wx.EXPAND)
-                
-                self.sizer = wx.BoxSizer(wx.VERTICAL)
-                self.sizer.Add(notebook,1,wx.EXPAND)
-                self.sizer.Add(messageSizer,0,wx.EXPAND)
-                
-                self.SetSizer(self.sizer)
-                self.SetAutoLayout(True)
-                inputSizer.Fit(self)
-                self.sizer.Fit(self)
-                #pre = wx.PreFrame()
-                #XRC().LoadOnFrame(pre, parent, 'MainFrame')
-        
-                self.tw = twitter3.Twitter(twUserdata)
-                self.tw.setAuthService("twitter")
-                #self.PostCreate(pre)
-                #self.binder.bindall(self)
-                self.SetIcon(main_icon.getIcon())
-                self.SetSize((300,400))
-                self.timer = wx.Timer(self,self.TIMER_ID)
-                wx.EVT_TIMER(self,self.TIMER_ID,self.OnUpdate)
-                self.timer.Start(60000)
-
-                #list = XRCCTRL(self,'ID_TWITLIST')
+
                 list.InsertColumn(0," ",1,20)
                 list.InsertColumn(1,u"ユーザ")
                 list.InsertColumn(2,u"発言",0,200)
                 list.Bind(wx.EVT_LIST_ITEM_SELECTED,self.OnTwitListSelect)
-                self.RefleshTw()
-                
-                self.SetNowTime2StatusBar()
-        
-        def OnSendTW(self, event):
-                # 送信する
-                # コンボボックスの中身を空にする
-                combo = self.text 
-                #name = XRCCTRL(self,'ID_NAME')
-                self.tw.put(combo.GetValue())   
-                combo.SetValue("")
-                self.RefleshTw()
-        
-        # チャットのログデータをListCtrlに表示
-        def RefleshTw(self):
-                #name = XRCCTRL(self,'ID_NAME')
-                list = self.list
-                a = self.tw.get("")
-                dataList = []
-                for x in a:
-                        flag = 0
-                        
-                        # 重複発言チェック
-                        for d in self.dataList:
-                                if d[2] == x[1]:
-                                        flag = 1
-                                        break
-                        if flag == 0 : 
-                                dataListElement = []
-                                dataListElement.append("")
-                                dataListElement.append(x[0])
-                                dataListElement.append(x[1])
-                                dataListElement.append(x[2])
-                                dataListElement.append(x[3])
-
-                                dataList.append(dataListElement)
-                i = 0
-                for b in dataList:
-                        j = 0
-                        list.InsertStringItem(i,"")
-                        for j in range(3):
-                                list.SetStringItem(i,j,b[j])
-                                
-                        i+=1
-                self.dataList = dataList + self.dataList
-                #if self.selectRow != -1 :self.selectRow+=len(dataList) 
-        def OnUpdate(self, event):
-                self.RefleshTw()
-                self.SetNowTime2StatusBar()
-        
-        def OnTwitListSelect(self,event):
-                import re
-                self.selectedRow = event.GetIndex()
-                label = self.userName
-                text = self.messageText
-                selectedRow = self.selectedRow
-                text.SetValue(self.dataList[selectedRow][2])
-                label.SetLabel(self.dataList[selectedRow][1])
-                self.LoadImage(self.GetImageListElement(self.dataList[selectedRow][4]),self.userIcon)
-                #選択したユーザに関する発言の色を変えてみる
-                p = re.compile(self.dataList[selectedRow][1])
-                for i in range(0,self.list.GetItemCount()):
-                        if p.search(self.dataList[i][1]):
-                                self.list.SetItemBackgroundColour(i,wx.Color(225,225,225))              
-                        elif p.search(self.dataList[i][2]) :
-                                self.list.SetItemBackgroundColour(i,wx.Color(192,225,225))              
-                        else:
-                                self.list.SetItemBackgroundColour(i,wx.Color(255,255,255))
-        
-        def SetNowTime2StatusBar(self):
-                #現在時刻を表示
-                from time import localtime, strftime
-                nowtime = strftime("%H:%M:%S", localtime())
-                sb = wx.GetApp().GetTopWindow().GetStatusBar()
-                sb.SetStatusText(nowtime+u"に更新しました")
-        
+
         def myKeyHandler(self,evt):
                 print evt.GetKeyCode(), 
@@ -213 +108 @@
                                         self.MoveList(rightcol)
 
-                #print list.
                 if evt.GetKeyCode() in [ord('q'), ord('Q')]:
                         wx.Exit()
@@ -249 +143 @@
                 self.list.Focus(self.selectedRow)
 
+        def OnTwitListSelect(self,event):
+                import re
+                selectedRow = self.selectedRow = event.GetIndex()
+                dataList = self.dataList
+                label = self.owner.userName
+                text = self.owner.messageText
+                text.SetValue(dataList[selectedRow][2])
+                label.SetLabel(dataList[selectedRow][1])
+                self.owner.SetImage(dataList[selectedRow][4])
+                #選択したユーザに関する発言の色を変えてみる
+                p = re.compile(dataList[selectedRow][1])
+                for i in range(0,self.list.GetItemCount()):
+                        if p.search(dataList[i][1]):
+                                self.list.SetItemBackgroundColour(i,wx.Color(225,225,225))              
+                        elif p.search(self.dataList[i][2]) :
+                                self.list.SetItemBackgroundColour(i,wx.Color(192,225,225))              
+                        else:
+                                self.list.SetItemBackgroundColour(i,wx.Color(255,255,255))
+        
+
+        def OnDoubleClick(self,event):
+                selectedRow = event.GetIndex()
+                user = "@" + self.dataList[selectedRow][1]
+                self.owner.addUser2Inputbox(user)
+
+        def Reflesh(self):
+                t = TwHttpThread(self.owner.tw,self.RefleshList)
+                t.run()
+        
+        def RefleshList(self,a):
+                #lockかけた方がいいのかも。。
+                list = self.list
+                dataList = []
+                for x in a:
+                        flag = 0
+                        
+                        # 重複発言チェック
+                        for d in self.dataList:
+                                if d[2] == x[1]:
+                                        flag = 1
+                                        break
+                        if flag == 0 : 
+                                dataListElement = []
+                                dataListElement.append("")
+                                dataListElement.append(x[0])
+                                dataListElement.append(x[1])
+                                dataListElement.append(x[2])
+                                dataListElement.append(x[3])
+
+                                dataList.append(dataListElement)
+                i = 0
+                for b in dataList:
+                        j = 0
+                        list.InsertStringItem(i,"")
+                        for j in range(3):
+                                list.SetStringItem(i,j,b[j])
+                        
+                        #import time
+                        #time.sleep(1)          
+                        #if 先読み=on
+                        try:    
+                                self.owner.GetImageListElement(b[4])
+                        except:
+                                pass
+                        i+=1
+                self.dataList = dataList + self.dataList
+                #if self.selectRow != -1 :self.selectRow+=len(dataList) 
+
+class ReplyPage(RecentPage):
+
+        dataList = []
+        def __init__(self, parent):
+                
+                self.owner = parent
+                wx.NotebookPage.__init__(self,parent.getNotebook(),-1)
+                parent.getNotebook().AddPage(self,'Reply')
+                list = self.list = wx.ListCtrl(self,-1,style=wx.LC_REPORT|wx.LC_HRULES)
+                list.Bind(wx.EVT_KEY_DOWN, self.myKeyHandler)
+                list.Bind(wx.EVT_LIST_ITEM_ACTIVATED,self.OnDoubleClick)
+
+                list.InsertColumn(0," ",1,20)
+                list.InsertColumn(1,u"ユーザ")
+                list.InsertColumn(2,u"発言",0,200)
+                list.Bind(wx.EVT_LIST_ITEM_SELECTED,self.OnTwitListSelect)
+        
+        def Reflesh(self):
+                t = TwReplyHttpThread(self.owner.tw,self.RefleshList)
+                t.run()
+
+        
+class DMPage(RecentPage):
+
+        dataList = []
+        def __init__(self, parent):
+                
+                self.owner = parent
+                wx.NotebookPage.__init__(self,parent.getNotebook(),-1)
+                parent.getNotebook().AddPage(self,'DM')
+                list = self.list = wx.ListCtrl(self,-1,style=wx.LC_REPORT|wx.LC_HRULES)
+                list.Bind(wx.EVT_KEY_DOWN, self.myKeyHandler)
+                list.Bind(wx.EVT_LIST_ITEM_ACTIVATED,self.OnDoubleClick)
+
+                list.InsertColumn(0," ",1,20)
+                list.InsertColumn(1,u"ユーザ")
+                list.InsertColumn(2,u"発言",0,200)
+                list.Bind(wx.EVT_LIST_ITEM_SELECTED,self.OnTwitListSelect)
+        
+        def Reflesh(self):
+                t = TwDMHttpThread(self.owner.tw,self.RefleshList)
+                t.run()
+        
+class MainFrame(wx.Frame):
+        """MainFrame class deffinition.
+        """
+        binder = wx_utils.bind_manager()
+
+        TIMER_ID = 1
+        TIMER_ID2= TIMER_ID+1
+        TIMER_ID3= TIMER_ID2+1
+        imageList = {}
+        def loadUserData(self, fileName):
+                #ファイルを開いて、データを読み込んで変換する
+                #データ形式は(user,password)
+                #try
+                file = open(fileName,'r')
+                a = simplejson.read(file.read())
+                file.close()
+                return a
+                #catch exit(1)
+                
+        def __init__(self, parent=None):
+                twUserdata = self.loadUserData(".chat/twdata")
+                wx.Frame.__init__(self,None, -1, "crochet")
+                
+                self.CreateStatusBar()
+
+                self.selectedRow = -1
+                text = self.text = wx.TextCtrl(self,-1,style=wx.TE_PROCESS_ENTER)
+                text.Bind(wx.EVT_TEXT_ENTER, self.OnSendTW)
+                button = self.button = wx.Button(self, -1, "Send")
+                self.button.Bind(wx.EVT_BUTTON, self.OnSendTW) 
+        
+                notebook = self.notebook = wx.Notebook(self,-1)
+
+                # Recent
+                self.recentPage = RecentPage(self)
+                
+                # Reply
+                self.replyPage = ReplyPage(self)
+
+                # Direct
+                self.directPage = DMPage(self) 
+
+                inputSizer = wx.BoxSizer(wx.HORIZONTAL)
+                inputSizer.Add(self.text,2,wx.EXPAND)
+                inputSizer.Add(self.button,0)
+                
+
+                messageText=self.messageText = wx.TextCtrl(self,-1,style=wx.TE_MULTILINE|wx.TE_AUTO_URL|wx.TE_READONLY)
+                userIcon = self.userIcon = wx.StaticBitmap(self,-1,wx.NullBitmap,(0,0),(64,64))
+                userName = self.userName = wx.StaticText(self,-1,"test")
+                twitTime = self.twitTime = wx.StaticText(self,-1,"")
+                
+                messageSizer3 = wx.BoxSizer(wx.HORIZONTAL)
+                messageSizer3.Add(userName,0)
+                messageSizer3.Add(twitTime,0)
+
+                messageSizer2 = wx.BoxSizer(wx.VERTICAL)
+                messageSizer2.Add(messageSizer3,0,wx.EXPAND)
+                messageSizer2.Add(messageText,1,wx.EXPAND)
+                
+                messageSizer1 = wx.BoxSizer(wx.HORIZONTAL)
+                messageSizer1.Add(userIcon,0)
+                messageSizer1.Add(messageSizer2,1,wx.EXPAND)
+        
+                messageSizer = wx.BoxSizer(wx.VERTICAL) 
+                messageSizer.Add(messageSizer1,3,wx.EXPAND)
+                messageSizer.Add(inputSizer,1,wx.EXPAND)
+                
+                self.sizer = wx.BoxSizer(wx.VERTICAL)
+                self.sizer.Add(notebook,1,wx.EXPAND)
+                self.sizer.Add(messageSizer,0,wx.EXPAND)
+                
+                self.SetSizer(self.sizer)
+                self.SetAutoLayout(True)
+                inputSizer.Fit(self)
+                self.sizer.Fit(self)
+        
+                self.tw = twitter3.Twitter(twUserdata)
+                self.tw.setAuthService("twitter")
+                self.SetIcon(main_icon.getIcon())
+                self.SetSize((300,400))
+                self.timer = wx.Timer(self,self.TIMER_ID)
+                wx.EVT_TIMER(self,self.TIMER_ID,self.OnUpdate)
+                self.timer.Start(60000)
+
+                self.timer2 = wx.Timer(self,self.TIMER_ID2)
+                wx.EVT_TIMER(self,self.TIMER_ID2,self.OnReplyUpdate)
+                self.timer2.Start(90000)
+                
+                self.timer3 = wx.Timer(self,self.TIMER_ID3)
+                wx.EVT_TIMER(self,self.TIMER_ID3,self.OnDMUpdate)
+                self.timer3.Start(90000)
+                self.RefleshTw()
+                self.SetNowTime2StatusBar()
+        
+        def OnSendTW(self, event):
+                # 送信する
+                # コンボボックスの中身を空にする
+                combo = self.text 
+                #name = XRCCTRL(self,'ID_NAME')
+                self.tw.put(combo.GetValue())   
+                combo.SetValue("")
+                self.RefleshTw()
+        
+        # チャットのログデータをListCtrlに表示
+        def RefleshTw(self):
+                self.recentPage.Reflesh()       
+                #self.replyPage.Reflesh()
+                #self.directPage.Reflesh()
+        
+        def OnUpdate(self, event):
+                self.RefleshTw()
+                self.SetNowTime2StatusBar()
+        
+        def OnReplyUpdate(self, event):
+                self.replyPage.Reflesh()
+                #self.SetNowTime2StatusBar()
+
+        def OnDMUpdate(self, event):
+                self.directPage.Reflesh()
+                #self.SetNowTime2StatusBar()
+
+        def SetNowTime2StatusBar(self):
+                #現在時刻を表示
+                from time import localtime, strftime
+                nowtime = strftime("%H:%M:%S", localtime())
+                sb = wx.GetApp().GetTopWindow().GetStatusBar()
+                sb.SetStatusText(nowtime+u"に更新しました")
+        
+        def myKeyHandler(self,evt):
+                print evt.GetKeyCode(), 
+                if self.selectedRow != -1:
+                        if evt.GetKeyCode() in [ord('k'),ord('K'),wx.WXK_UP]:
+                                print ('up')
+                                if self.selectedRow > 0:
+                                        self.MoveList(self.selectedRow-1)
+                        if evt.GetKeyCode() in [ord('j'),ord('J'),wx.WXK_DOWN]:
+                                print ('down')
+                                if self.selectedRow < self.list.GetItemCount()-1:
+                                        self.MoveList(self.selectedRow+1)
+                        if evt.GetKeyCode() in [ord('h'),ord('H'),wx.WXK_LEFT]:
+                                print ('left')
+                                leftcol = self.GetPrevItem(self.selectedRow)
+                                if leftcol != -1:
+                                        self.MoveList(leftcol)
+                        if evt.GetKeyCode() in [ord('l'),ord('L'),wx.WXK_RIGHT]:
+                                print ('right') 
+                                rightcol = self.GetNextItem(self.selectedRow)
+                                if rightcol != -1:
+                                        self.MoveList(rightcol)
+
+                #print list.
+                if evt.GetKeyCode() in [ord('q'), ord('Q')]:
+                        wx.Exit()
+
         """Web上の画像を読み込みImageListとして保持する。
                 既に読まれてるなら読みに行かない。ImageList['URL']という形で格納
@@ -255 +415 @@
                 unicodeUrl = url
                 if self.imageList.has_key(unicodeUrl):
+
+                        self.userIcon.SetBitmap(self.imageList[unicodeUrl].ConvertToBitmap())
                         pass
                 else:
-                        self.imageList[unicodeUrl] = self.WebImage2StringIO(url)
+                        self.imageList[unicodeUrl] = "" 
+                        self.WebImage2StringIO(url,unicodeUrl)
                 return self.imageList[unicodeUrl]
         
         # Web上の画像を引っ張ってくる
-        def WebImage2StringIO(self,url):
+        def WebImage2StringIO(self,url,result):
                 import urllib
-                from cStringIO import StringIO
 
                 #try:
@@ -269 +431 @@
                 #print "url:"+url
                 #print "urlName:"+urlName
-                imagePath = urllib.urlopen(urlName).read()
-
-                image_pil = Image.open(StringIO(imagePath))
+                #thread化したいですね
+                t = ImageGetThread(urlName,self.WebImageCallback,result)
+                t.run()
+
+        def WebImageCallback(self,imageData,result):
+
+                from cStringIO import StringIO
+
+                image_pil = Image.open(StringIO(imageData))
                 image_pil.thumbnail((64,64))
 
                 image_wx = wx.EmptyImage(image_pil.size[0],image_pil.size[1])
                 image_wx.SetData(image_pil.convert('RGB').tostring())
-                return image_wx
+                #self.userIcon.SetBitmap(image_wx.ConvertToBitmap())
+                self.imageList[result] = image_wx
                 #except:
                 #       print "Error:URL not valid!:"+url
@@ -282 +451 @@
         
         # 画像を読み込んで表示のテスト
-        def LoadImage(self,image,bmp):
+        def SetImage(self,imageName):
+                
+                bmp = self.userIcon
+                image = self.GetImageListElement(imageName)
                 bmp.SetBitmap(image.ConvertToBitmap())
 
-        #ダブルクリック時
-        def OnDoubleClick(self,event):
-                print ("dblclk")
+        def addUser2Inputbox(self,user):
+                
+                text = self.text
+                value = text.GetValue()
+                
+                flag = 1 
+                import re
+                print value + ":" + user
+                if re.search(user,value):
+                        flag = 0
+
+                if flag == 1:
+                        text.SetValue(user+value)
+
+        def getNotebook(self):
+                return self.notebook
+
 # startup application.
 if __name__=='__main__':
         app = wx.App(False)
-        #wx_utils.XrcInit()
         frame = MainFrame()
         app.SetTopWindow(frame)

lang/python/crochet/twitter3.py

@@ -131 +131 @@
                         resultSub.append(x['text'])