# Copyright (c) 2007-2009 The PyAMF Project.
# See LICENSE.txt for details.

"""
Gateway for Google App Engine.

This gateway allows you to expose functions in Google App Engine web
applications to AMF clients and servers.

@see: U{Google App Engine homepage (external)
    <http://code.google.com/appengine>}

@since: 0.3.1
"""
from pyamf import remoting
from pyamf.remoting import gateway

from tipfy import RequestHandler, Response, abort

__all__ = ['AmfRequestHandler']


class AmfRequestHandler(RequestHandler):
    """Google App Engine Remoting Gateway."""
    def get(self, **kwargs):
        """Just raise a 405 Method Not Allowed."""
        abort(405)

    def post(self, **kwargs):
        self.set_gateway()
        return self.process_request()

    def set_gateway(self, *args, **kwargs)
        self.gateway = gateway.BaseGateway(*args, **kwargs)

    def process_request(self):
        body = self.request.data
        stream = None
        timezone_offset = self.gateway._get_timezone_offset()

        # Decode the request
        try:
            request = remoting.decode(body, strict=self.gateway.strict,
                logger=self.gateway.logger, timezone_offset=timezone_offset)
        except (KeyboardInterrupt, SystemExit):
            raise
        except:
            abort(400)

        if self.gateway.logger:
            self.gateway.logger.info("AMF Request: %r" % request)

        # Process the request
        try:
            response = self.get_response(request)
        except (KeyboardInterrupt, SystemExit):
            raise
        except:
            abort(500)

        if self.gateway.logger:
            self.gateway.logger.info("AMF Response: %r" % response)

        # Encode the response
        try:
            stream = remoting.encode(response, strict=self.gateway.strict,
                logger=self.gateway.logger, timezone_offset=timezone_offset)
        except:
            abort(500)

        response = stream.getvalue()
        headers = {
            'Content-Type':   remoting.CONTENT_TYPE,
            'Content-Length': str(len(response)),
            'Server':         gateway.SERVER_NAME,
        }
        return Response(response, headers=headers)

    def get_response(self, request):
        """
        Processes the AMF request, returning an AMF response.

        @param request: The AMF Request.
        @type request: L{Envelope<pyamf.remoting.Envelope>}
        @rtype: L{Envelope<pyamf.remoting.Envelope>}
        @return: The AMF Response.
        """
        response = remoting.Envelope(request.amfVersion, request.clientType)

        for name, message in request:
            self.request.amf_request = message

            processor = self.getProcessor(message)
            response[name] = processor(message, http_request=self.request)

        return response

@@ -2716,16 +2716,24 @@
  = self.
+gateway.
 getProce

Fix in ext.pyamf.