WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/thriftpy/utils/HelperService.py

+#
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
 from thrift.Thrift import *
+import shop2020.thriftpy.generic.GenericService
 from ttypes import *
 from thrift.Thrift import TProcessor
 from thrift.transport import TTransport
 from thrift.protocol import TBinaryProtocol
 try:
   from thrift.protocol import fastbinary
 except:
   fastbinary = None
-class Iface:
-  def closeSession(self, ):
-    """
-    For closing the open session in sqlalchemy
+class Iface(shop2020.thriftpy.generic.GenericService.Iface):
-    """
-    pass
   def saveUserEmailForSending(self, emailTo, emailFrom, subject, body, source, emailType):
     """
     Save email details, to be sent later; Also returns its identifier.
     Parameters:
      - role
     """
     pass
-class Client(Iface):
+class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
   def __init__(self, iprot, oprot=None):
-    self._iprot = self._oprot = iprot
-    if oprot != None:
-      self._oprot = oprot
-    self._seqid = 0
-  def closeSession(self, ):
-    """
-    For closing the open session in sqlalchemy
-    """
-    self.send_closeSession()
-    self.recv_closeSession()
-  def send_closeSession(self, ):
-    self._oprot.writeMessageBegin('closeSession', TMessageType.CALL, self._seqid)
+    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
-    args = closeSession_args()
-    args.write(self._oprot)
-    self._oprot.writeMessageEnd()
-    self._oprot.trans.flush()
-  def recv_closeSession(self, ):
-    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-    if mtype == TMessageType.EXCEPTION:
-      x = TApplicationException()
-      x.read(self._iprot)
-      self._iprot.readMessageEnd()
-      raise x
-    result = closeSession_result()
-    result.read(self._iprot)
-    self._iprot.readMessageEnd()
-    return
   def saveUserEmailForSending(self, emailTo, emailFrom, subject, body, source, emailType):
     """
     Save email details, to be sent later; Also returns its identifier.
     if result.hse != None:
       raise result.hse
     raise TApplicationException(TApplicationException.MISSING_RESULT, "authenticateCatalogUser failed: unknown result");
-class Processor(Iface, TProcessor):
+class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
   def __init__(self, handler):
-    self._handler = handler
-    self._processMap = {}
-    self._processMap["closeSession"] = Processor.process_closeSession
+    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
     self._processMap["saveUserEmailForSending"] = Processor.process_saveUserEmailForSending
     self._processMap["getEmailsToBeSent"] = Processor.process_getEmailsToBeSent
     self._processMap["markEmailAsSent"] = Processor.process_markEmailAsSent
     self._processMap["sendMail"] = Processor.process_sendMail
     self._processMap["sendText"] = Processor.process_sendText
       return
     else:
       self._processMap[name](self, seqid, iprot, oprot)
     return True
-  def process_closeSession(self, seqid, iprot, oprot):
-    args = closeSession_args()
-    args.read(iprot)
-    iprot.readMessageEnd()
-    result = closeSession_result()
-    self._handler.closeSession()
-    oprot.writeMessageBegin("closeSession", TMessageType.REPLY, seqid)
-    result.write(oprot)
-    oprot.writeMessageEnd()
-    oprot.trans.flush()
   def process_saveUserEmailForSending(self, seqid, iprot, oprot):
     args = saveUserEmailForSending_args()
     args.read(iprot)
     iprot.readMessageEnd()
     result = saveUserEmailForSending_result()
     oprot.trans.flush()
 # HELPER FUNCTIONS AND STRUCTURES
-class closeSession_args:
-  thrift_spec = (
-  )
-  def read(self, iprot):
-    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      else:
-        iprot.skip(ftype)
-      iprot.readFieldEnd()
-    iprot.readStructEnd()
-  def write(self, oprot):
-    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('closeSession_args')
-    oprot.writeFieldStop()
-    oprot.writeStructEnd()
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-  def __ne__(self, other):
-    return not (self == other)
-class closeSession_result:
-  thrift_spec = (
-  )
-  def read(self, iprot):
-    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      else:
-        iprot.skip(ftype)
-      iprot.readFieldEnd()
-    iprot.readStructEnd()
-  def write(self, oprot):
-    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('closeSession_result')
-    oprot.writeFieldStop()
-    oprot.writeStructEnd()
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-  def __ne__(self, other):
-    return not (self == other)
 class saveUserEmailForSending_args:
   """
   Attributes:
    - emailTo
    - emailFrom

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/thriftpy/utils/HelperService.py – Rev 3206 → 3376