view piecrust/sources/prose.py @ 552:9612cfc6455a

serve: Rewrite of the Server-Sent Event code for build notifications. At the moment the server monitors the asset directories, and notifies the browser when an asset has changed and has been re-processed. * Fix issues around long-running requests/threads which mess up the ability to shutdown the server correctly with `CTRL-C` (see comments in code). * Move the notification queue to each SSE producer, to support having multiple pages open in a browser. * Add JS/CSS for showing quick notifications about re-processed assets. * Add support for hot-reloading CSS and pictures that have been re-processed.
author Ludovic Chabant <ludovic@chabant.com>
date Sat, 08 Aug 2015 16:12:04 -0700
parents 65db6df28120
children 4850f8c21b6e
line wrap: on
line source

import os
import os.path
import copy
import logging
from piecrust.sources.base import MODE_CREATING, MODE_PARSING
from piecrust.sources.default import DefaultPageSource


logger = logging.getLogger(__name__)


class ProseSource(DefaultPageSource):
    SOURCE_NAME = 'prose'

    def __init__(self, app, name, config):
        super(ProseSource, self).__init__(app, name, config)
        self.config_recipe = config.get('config', {})

    def _populateMetadata(self, rel_path, metadata, mode=None):
        metadata['config'] = self._makeConfig(rel_path, mode)

    def _makeConfig(self, rel_path, mode):
        c = copy.deepcopy(self.config_recipe)
        if c.get('title') == '%first_line%' and mode != MODE_CREATING:
            path = os.path.join(self.fs_endpoint_path, rel_path)
            try:
                c['title'] = get_first_line(path)
            except IOError:
                if mode == MODE_PARSING:
                    raise
        return c


def get_first_line(path):
    with open(path, 'r') as f:
        while True:
            l = f.readline()
            if not l:
                break
            l = l.strip()
            if not l:
                continue
            return l
    return None