diff -r 000000000000 -r ca70ae20a155 src/extras/fileserver/fileserver.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/extras/fileserver/fileserver.py	Tue Feb 16 10:07:05 2010 +0530
@@ -0,0 +1,199 @@
+# fileserver.py
+#
+# A simple file transfer server for Series 60 Python environment.
+#     
+# Copyright (c) 2005 Nokia Corporation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+import binascii
+
+#DEBUGLOG=lambda x: sys.stdout.write(x+"\n")
+DEBUGLOG=lambda x: 0
+
+def file_checksums(filelist):
+    retval={}
+    for fname in filelist:
+        try: 
+            f=open(fname,'rb')
+            checksum=binascii.crc32(f.read())
+            f.close()
+        except:
+            checksum=None
+        retval[fname]=checksum
+    return retval
+
+class fileserver:
+    def __init__(self,sock):
+        self.sock=sock
+        self.commands={'quit': self.cmd_quit,
+                       'get': self.cmd_get,
+                       'put': self.cmd_put,
+                       'exec': self.cmd_exec,
+                       'eval': self.cmd_eval}
+    def cmd_quit(self,line):
+        self.finished=True
+    def cmd_invalid(self,line):
+        print >>sys.stderr,'Invalid command '+line,
+        self.finished=True        
+    def cmd_get(self,cmdline):
+        filename=eval(cmdline[4:])
+        DEBUGLOG("get "+filename)
+        f=open(filename,'rb')
+        content=f.read()
+        f.close()
+        self.senddata(content)
+    def cmd_put(self,cmdline):
+        words=cmdline.split()
+        filename=eval(words[1])
+        DEBUGLOG("put "+filename)
+        content=self.recvdata()
+        f=open(filename,'wb')
+        f.write(content)
+        f.close()
+        print "Wrote %d bytes to %s."%(len(content),filename)
+    def senddata(self,data):
+        DEBUGLOG("Content-Length: %d"%len(data))
+        self.write('Content-Length: '+str(len(data))+'\n'+
+                   'CRC32: '+str(binascii.crc32(data))+'\n')
+        sentbytes=0        
+        # Send the data in little bits because the Bluetooth serial
+        # connection may lose data on large sends.
+        MAX_SEND=2048
+        while sentbytes<len(data):
+            n=min(len(data),MAX_SEND)
+            self.write(data[sentbytes:sentbytes+n])
+            sentbytes+=n
+        print "Sent %d bytes."%sentbytes
+    def recvdata(self):
+        DEBUGLOG("Waiting for data...")
+        header_lines=[self.readline() for x in range(2)]
+        header=dict([x.rstrip().split(': ') for x in header_lines])
+        content_length=int(header['Content-Length'])
+        crc32=int(header['CRC32'])
+        DEBUGLOG("Content-Length: %d"%content_length)
+        recvbytes=0
+        content=[]
+        DEBUGLOG("Receiving data...")
+        while recvbytes<content_length:
+            recvstring=self.sock.recv(min(content_length-recvbytes,2048))
+            recvbytes+=len(recvstring)
+            #print "Received: %d bytes (%3.1f%%)\r"%(recvbytes,(100.*recvbytes/content_length)),
+            content.append(recvstring)
+        print "Received %d bytes."%recvbytes
+        content=''.join(content)
+        if crc32 != binascii.crc32(content):
+            print "*** CRC error!"        
+        return content
+    def cmd_exec(self,cmdline):
+#        command=eval(cmdline[5:])
+        command=eval(self.recvdata())
+        DEBUGLOG("exec "+command)
+        try:
+            exec command in globals()
+            result=(0,'')
+        except:
+            import traceback
+            result=(1,apply(traceback.format_exception,sys.exc_info()))
+        self.senddata(repr(result))
+
+    def cmd_eval(self,cmdline):
+        expr=eval(self.recvdata())
+        #expr=eval(cmdline[5:])
+        DEBUGLOG("eval "+expr)
+        # two eval's because we need to first get rid of one level of
+        # quoting.
+        result=''
+        try:
+            value=eval(expr,globals())
+            result=(0,value)
+        except:
+            import traceback
+            result=(1,apply(traceback.format_exception,sys.exc_info()))
+        self.senddata(repr(result))
+
+    def readline(self):
+        s=[]
+        while 1:
+            c=self.sock.recv(1)
+            #self.sock.send(c)
+            s.append(c)
+            # We support just sane line-endings here.
+            if c=='\n':
+                break
+        return ''.join(s)
+    def write(self,msg):
+        self.sock.send(msg)
+    def run(self):
+        self.finished=False
+        while not self.finished:
+            cmdline=self.readline().rstrip()
+            print "Received: "+cmdline
+            words=cmdline.split()
+            if len(words)>0:
+                cmd=words[0]
+                DEBUGLOG("Running command: "+cmdline)
+                self.commands.get(cmd,self.cmd_invalid)(cmdline)
+
+if __name__ == '__main__':
+    import sys
+    from e32socket import *
+    import e32
+    if not e32.is_ui_thread():
+        f=open('c:/pythonout.txt','at')
+        sys.stdout=f
+        sys.stderr=f
+
+    print "Starting server"
+    use_tcp=0
+    
+    if use_tcp:
+        s=socket(AF_INET,SOCK_STREAM)
+        addr=('127.0.0.1',1025)
+        s.bind(addr)
+        s.listen(1)
+    
+        while 1:
+            print "Waiting"
+            (sock,remoteaddr)=s.accept()
+            print "Connected"
+            server=fileserver(sock)
+            try:
+                server.run()
+            except:
+                import traceback
+                traceback.print_exc()
+            sock.close()
+    else:
+        s=socket(AF_BT,SOCK_STREAM)
+        try:
+            f=open('c:/system/apps/python/fileserver_conf.txt')
+            conf=eval(f.read())
+            f.close()
+            addr=conf['target']
+        except:
+            addr=('00:20:e0:76:c3:52',10)
+            conf={}
+        #addr=('00:20:e0:76:c3:52',9)
+        print "Connecting to "+`addr`
+        s.connect(addr)
+        server=fileserver(s)
+        try:
+            server.run()
+        except:
+            import traceback
+            traceback.print_exc()
+        s.close()
+        print "Server finished."
+