view src/pages/g/e/page_meta.py @ 995:f88325b56a6a

server: dynamic pages first draft: /!\ new dependency: autobahn This patch introduce server part of dynamic pages. Dynamic pages use websockets to establish constant connection with a Libervia page, allowing to receive real time data or update it. The feature is activated by specifying "dynamic = true" in the page. Once activated, page can implement "on_data" method which will be called when data are sent by the page. To send data the other way, the page can use request.sendData. The new "registerSignal" method allows to use an "on_signal" method to be called each time given signal is received, with automatic (and optional) filtering on profile. New renderPartial and renderAndUpdate method allow to append new HTML elements to the dynamic page.
author Goffi <goffi@goffi.org>
date Wed, 03 Jan 2018 01:10:12 +0100
parents 36e9747520fd
children ad97d7e7de3b
line wrap: on
line source

#!/usr/bin/env python2.7
# -*- coding: utf-8 -*-

from libervia.server.constants import Const as C
from sat.core.i18n import _
from twisted.internet import defer
from twisted.words.protocols.jabber import jid
from libervia.server import session_iface
from sat.tools.common import uri
import time
from sat.core.log import getLogger
log = getLogger('pages/g/e')

access = C.PAGES_ACCESS_PROFILE
template = u"event/invitation.html"


@defer.inlineCallbacks
def prepare_render(self, request):
    template_data = request.template_data
    guest_session = self.host.getSessionData(request, session_iface.ISATGuestSession)
    try:
        event_uri = guest_session.data['event_uri']
    except KeyError:
        log.warning(_(u"event URI not found, can't render event page"))
        self.pageError(request, C.HTTP_SERVICE_UNAVAILABLE)

    data = self.getRData(request)

    ## Event ##

    event_uri_data = uri.parseXMPPUri(event_uri)
    if event_uri_data[u'type'] != u'pubsub':
        self.pageError(request, C.HTTP_SERVICE_UNAVAILABLE)

    event_service = template_data[u'event_service'] = jid.JID(event_uri_data[u'path'])
    event_node = template_data[u'event_node'] = event_uri_data[u'node']
    event_id = template_data[u'event_id'] = event_uri_data.get(u'item','')
    profile = self.getProfile(request)
    event_timestamp, event_data = yield self.host.bridgeCall(u"eventGet", event_service.userhost(), event_node, event_id, profile)
    try:
        background_image = event_data.pop('background-image')
    except KeyError:
        pass
    else:
        template_data['background_image'] = background_image
    template_data['event'] = event_data
    event_invitee_data = yield self.host.bridgeCall(
        u"eventInviteeGet",
        event_data['invitees_service'],
        event_data['invitees_node'],
        profile)
    template_data['invitee'] = event_invitee_data
    template_data['days_left'] = int((event_timestamp - time.time()) / (60 * 60 * 24))

    ## Blog ##

    data[u'service'] = jid.JID(event_data[u'blog_service'])
    data[u'node'] = event_data[u'blog_node']
    data[u'allow_commenting'] = u'simple'

    # we now need blog items, using blog common page
    # this will fill the "items" template data
    blog_page = self.getPageByName(u'blog')
    yield blog_page.prepare_render(self, request)

@defer.inlineCallbacks
def on_data_post(self, request):
    type_ = self.getPostedData(request, u'type')
    if type_ == u'comment':
        blog_page = self.getPageByName(u'blog')
        yield blog_page.on_data_post(self, request)
    elif type_ == u'attendance':
        profile = self.getProfile(request)
        service, node, attend, guests = self.getPostedData(request, (u'service', u'node', u'attend', u'guests'))
        data = {u'attend': attend,
                u'guests': guests}
        yield self.host.bridgeCall(u"eventInviteeSet", service, node, data, profile)
    else:
        log.warning(_(u"Unhandled data type: {}").format(type_))