full/hfaxlib/hfaxlib.py

#!/usr/bin/env python

# Author: Harald Holzer (harald.holzer@eunet.at)
# 5.4.2000: Initial release

# 6.5.2000: Harald Holzer (harald.holzer@eunet.at)
#       added logging support

# 13.6.2000: Added patch, for job_new. jobids now returned correctly.
#       Patch supplied by Victor M. Moreno (vmoreno@geminus.com)

import string,sys
from socket import *


class hfax:
    s=None
    sf=None
    d=None
    df=None
    user=""
    pw=""
    host=""
    port=4559
    debuglevel=0
    logfile="c:\w2hfax.log"

    def readline(self):
        data=self.sf.readline()
        self.loginfo("read: " + data)
        return data
        
    def writeline(self,line):
        self.loginfo("write: " + line)
        self.s.send(line)
        
    def connect(self,host,user,pw):
        self.host=host
        self.user=user
        self.pw=pw
        self.s=socket(AF_INET,SOCK_STREAM)
        try:
            self.s.connect(host,self.port)
            self.sf=self.s.makefile("rw")
            line=self.readline()
            self.writeline("USER " + user + "\n")
            line=self.readline()
            if line[:3]=="230":
                rc=0
            else:
                rc=1
        except error,detail:
            self.loginfo("error: " + str(detail))
            rc=2
        return rc
        
    def job_new(self):
        self.writeline("JOB default\n")
        self.readline()
        self.writeline("JNEW\n")
        data=self.readline()
        #Victor: 200 NEW job created jobid: 2 groupid: 2.
        jobid=string.atoi(data[string.find(data,"jobid:")+6:string.find(data,"groupid:")])
        return jobid

    def job_select(self,jobid):
        self.writeline("JOB " + str(jobid) + "\n")
        self.readline()

    def job_kill(self):
        self.writeline("JKILL\n")
        self.readline()

    def job_delete(self):
        self.writeline("JDELE\n")
        self.readline()
        
    def job_param_getall(self):
        self.writeline("JPARM\n")
        self.readline()
        data=""
        while 1:
            line=self.readline()
            if line[:4]=="217 ": break
            data=data + line
        return data
        
    def job_param_get(self,pname):
        self.writeline("JPARM " + pname + "\n")
        data=""
        while 1:
            line = self.readline()
            data = data + line[4:]
            if line[3]==" ": break
        return string.strip(data)
        
    def job_param_set(self,pname,pvalue):
        self.writeline("JPARM " + pname + " " + pvalue +"\n")
        self.readline() 

    def getfolder(self,folder):
        self.writeline("PASV\n")
        data=self.readline()
        #print data
        data=data[string.find(data,"(")+1:string.find(data,")")]
        a1,a2,a3,a4,p1,p2=string.split(data,",")
        addr=a1 + "." + a2 + "." + a3 + "." + a4
        port=string.atoi(p1)*256 + string.atoi(p2)
        self.d=socket(AF_INET,SOCK_STREAM)
        self.d.connect(addr,port)
        self.df=self.d.makefile()
        self.writeline("list "+folder+"\n")
        fdata=""
        while 1:
            line=self.df.readline()
            if not line: break
            fdata=fdata + line
        self.df.close()
        self.d.close()
        self.readline()
        self.readline()
        return fdata

    def storefile(self,filename):
        self.writeline("PASV\n")
        data=self.readline()
        #print data
        data=data[string.find(data,"(")+1:string.find(data,")")]
        a1,a2,a3,a4,p1,p2=string.split(data,",")
        addr=a1 + "." + a2 + "." + a3 + "." + a4
        port=string.atoi(p1)*256 + string.atoi(p2)
        self.d=socket(AF_INET,SOCK_STREAM)
        self.d.connect(addr,port)
        self.df=self.d.makefile("w")
        
        self.writeline("STOT\n")
        reply=self.readline()
        sfile=open(filename,"r")
        while 1:
            line=sfile.readline()
            if not line: break
            self.df.write(line)
        sfile.close()
        self.df.close()
        self.d.close()
        self.readline()
        filename=string.split(reply," ")[2]
        return filename

    def retrfile(self,filename,tmpfilename):
        self.writeline("PASV\n")
        data=self.readline()
        #print data
        data=data[string.find(data,"(")+1:string.find(data,")")]
        a1,a2,a3,a4,p1,p2=string.split(data,",")
        addr=a1 + "." + a2 + "." + a3 + "." + a4
        port=string.atoi(p1) * 256 + string.atoi(p2)
        self.d=socket(AF_INET,SOCK_STREAM)
        self.d.connect(addr,port)
        self.df=self.d.makefile("rb")
        
        self.writeline("RETR " + filename + "\n")
        reply=self.readline()
        sfile=open(tmpfilename,"wb")
        line=self.df.read()
        #while 1:
        #    line=self.df.readline()
        #    if not line: break
        #    sfile.write(line)
        sfile.write(line)
        sfile.close()
        self.df.close()
        self.d.close()
        self.readline()
        return reply
                
    def deletefile(self,name):
        self.writeline("DELE " + name + "\n")
        self.readline()

    def jobparam(self,param):
        self.writeline("JPARM " + param+"\n")
        self.readline()
        
    def submitjob(self):
        self.writeline("JSUBM\n")
        self.readline()
        
    def docmd(self,cmd):
        self.writeline(cmd+"\n")
        self.readline()
        
    def close(self):
        self.sf.close()
        self.s.close()

    def setdebuginfo(self,dbglevel,logfile):
        self.debuglevel=dbglevel
        self.logfile=logfile
        
    def loginfo(self,info):
        if self.debuglevel>0:
            f=open(self.logfile,"a")
            f.write(info+"\r\n")
            f.close
        
if __name__=="__main__":
    host="127.0.0.1"
    if len(sys.argv)>1:
        listdir=sys.argv[1]
    else:
        listdir="/"
    test=hfax()
    test.connect(host,"root")
    print test.getfolder(listdir)
    test.close()

1	joko	1.1	#!/usr/bin/env python
2
3			# Author: Harald Holzer (harald.holzer@eunet.at)
4			# 5.4.2000: Initial release
5
6			# 6.5.2000: Harald Holzer (harald.holzer@eunet.at)
7			# added logging support
8
9			# 13.6.2000: Added patch, for job_new. jobids now returned correctly.
10			# Patch supplied by Victor M. Moreno (vmoreno@geminus.com)
11
12			import string,sys
13			from socket import *
14
15
16			class hfax:
17			s=None
18			sf=None
19			d=None
20			df=None
21			user=""
22			pw=""
23			host=""
24			port=4559
25			debuglevel=0
26			logfile="c:\w2hfax.log"
27
28			def readline(self):
29			data=self.sf.readline()
30			self.loginfo("read: " + data)
31			return data
32
33			def writeline(self,line):
34			self.loginfo("write: " + line)
35			self.s.send(line)
36
37			def connect(self,host,user,pw):
38			self.host=host
39			self.user=user
40			self.pw=pw
41			self.s=socket(AF_INET,SOCK_STREAM)
42			try:
43			self.s.connect(host,self.port)
44			self.sf=self.s.makefile("rw")
45			line=self.readline()
46			self.writeline("USER " + user + "\n")
47			line=self.readline()
48			if line[:3]=="230":
49			rc=0
50			else:
51			rc=1
52			except error,detail:
53			self.loginfo("error: " + str(detail))
54			rc=2
55			return rc
56
57			def job_new(self):
58			self.writeline("JOB default\n")
59			self.readline()
60			self.writeline("JNEW\n")
61			data=self.readline()
62			#Victor: 200 NEW job created jobid: 2 groupid: 2.
63			jobid=string.atoi(data[string.find(data,"jobid:")+6:string.find(data,"groupid:")])
64			return jobid
65
66			def job_select(self,jobid):
67			self.writeline("JOB " + str(jobid) + "\n")
68			self.readline()
69
70			def job_kill(self):
71			self.writeline("JKILL\n")
72			self.readline()
73
74			def job_delete(self):
75			self.writeline("JDELE\n")
76			self.readline()
77
78			def job_param_getall(self):
79			self.writeline("JPARM\n")
80			self.readline()
81			data=""
82			while 1:
83			line=self.readline()
84			if line[:4]=="217 ": break
85			data=data + line
86			return data
87
88			def job_param_get(self,pname):
89			self.writeline("JPARM " + pname + "\n")
90			data=""
91			while 1:
92			line = self.readline()
93			data = data + line[4:]
94			if line[3]==" ": break
95			return string.strip(data)
96
97			def job_param_set(self,pname,pvalue):
98			self.writeline("JPARM " + pname + " " + pvalue +"\n")
99			self.readline()
100
101			def getfolder(self,folder):
102			self.writeline("PASV\n")
103			data=self.readline()
104			#print data
105			data=data[string.find(data,"(")+1:string.find(data,")")]
106			a1,a2,a3,a4,p1,p2=string.split(data,",")
107			addr=a1 + "." + a2 + "." + a3 + "." + a4
108			port=string.atoi(p1)*256 + string.atoi(p2)
109			self.d=socket(AF_INET,SOCK_STREAM)
110			self.d.connect(addr,port)
111			self.df=self.d.makefile()
112			self.writeline("list "+folder+"\n")
113			fdata=""
114			while 1:
115			line=self.df.readline()
116			if not line: break
117			fdata=fdata + line
118			self.df.close()
119			self.d.close()
120			self.readline()
121			self.readline()
122			return fdata
123
124			def storefile(self,filename):
125			self.writeline("PASV\n")
126			data=self.readline()
127			#print data
128			data=data[string.find(data,"(")+1:string.find(data,")")]
129			a1,a2,a3,a4,p1,p2=string.split(data,",")
130			addr=a1 + "." + a2 + "." + a3 + "." + a4
131			port=string.atoi(p1)*256 + string.atoi(p2)
132			self.d=socket(AF_INET,SOCK_STREAM)
133			self.d.connect(addr,port)
134			self.df=self.d.makefile("w")
135
136			self.writeline("STOT\n")
137			reply=self.readline()
138			sfile=open(filename,"r")
139			while 1:
140			line=sfile.readline()
141			if not line: break
142			self.df.write(line)
143			sfile.close()
144			self.df.close()
145			self.d.close()
146			self.readline()
147			filename=string.split(reply," ")[2]
148			return filename
149
150			def retrfile(self,filename,tmpfilename):
151			self.writeline("PASV\n")
152			data=self.readline()
153			#print data
154			data=data[string.find(data,"(")+1:string.find(data,")")]
155			a1,a2,a3,a4,p1,p2=string.split(data,",")
156			addr=a1 + "." + a2 + "." + a3 + "." + a4
157			port=string.atoi(p1) * 256 + string.atoi(p2)
158			self.d=socket(AF_INET,SOCK_STREAM)
159			self.d.connect(addr,port)
160			self.df=self.d.makefile("rb")
161
162			self.writeline("RETR " + filename + "\n")
163			reply=self.readline()
164			sfile=open(tmpfilename,"wb")
165			line=self.df.read()
166			#while 1:
167			# line=self.df.readline()
168			# if not line: break
169			# sfile.write(line)
170			sfile.write(line)
171			sfile.close()
172			self.df.close()
173			self.d.close()
174			self.readline()
175			return reply
176
177			def deletefile(self,name):
178			self.writeline("DELE " + name + "\n")
179			self.readline()
180
181			def jobparam(self,param):
182			self.writeline("JPARM " + param+"\n")
183			self.readline()
184
185			def submitjob(self):
186			self.writeline("JSUBM\n")
187			self.readline()
188
189			def docmd(self,cmd):
190			self.writeline(cmd+"\n")
191			self.readline()
192
193			def close(self):
194			self.sf.close()
195			self.s.close()
196
197			def setdebuginfo(self,dbglevel,logfile):
198			self.debuglevel=dbglevel
199			self.logfile=logfile
200
201			def loginfo(self,info):
202			if self.debuglevel>0:
203			f=open(self.logfile,"a")
204			f.write(info+"\r\n")
205			f.close
206
207			if __name__=="__main__":
208			host="127.0.0.1"
209			if len(sys.argv)>1:
210			listdir=sys.argv[1]
211			else:
212			listdir="/"
213			test=hfax()
214			test.connect(host,"root")
215			print test.getfolder(listdir)
216			test.close()
217
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26