VSAC/application/plugins/feeds/feed.php at master · EurActiv/VSAC · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
<?php

namespace VSAC;


if (!($feed = request_query('feed'))) {
    response_send_json(array('error' =>  'no feed specified'));
}

if (!($feed = http_uri_is_authorized($feed))) {
    response_send_json(array('error' =>  'feed not allowed'));
}

$count = (int) request_query('count', 3);

$fields = explode(',', request_query('fields', 'title,link'));

$strip_tags = (bool) request_query('strip_tags', true);

$content = cal_get_permutation(
    $feed,
    function () use ($feed) {
        $response = http_get($feed, true);
        if (!$response['body'] || $response['error']) {
            return null;
        }
        if (!($xml = @simplexml_load_string($response['body'], null, LIBXML_NOCDATA))) {
            return null;
        }
        if (!$xml->channel || !$xml->channel->item) {
            return null;
        }
        $items = array();
        foreach ($xml->channel->item as $entry) {
            $item = json_decode(json_encode($entry), TRUE);
            $namespaces = $entry->getNameSpaces(true);
            if (isset($namespaces['dc']) && $dc = $entry->children($namespaces['dc'])) {
                $dc = json_decode(json_encode($dc), TRUE);
                $item = array_merge($item, $dc);
            }
            $items[] = $item;
        }
        return $items;
    },
    implode('-', array($count, implode(',', $fields), $strip_tags)),
    function ($feed_content) use ($count, $fields, $strip_tags) {
        $return = array();
        foreach ($feed_content as $item) {
            $formatted = array();
            foreach($fields as $field) {
                $formatted[$field] = '';
                if (empty($item[$field])) {
                    $continue;
                }
                if ($field == 'enclosure') {
                    if (is_array($item[$field]) && !empty($item[$field]['@attributes']['url'])) {
                        $formatted[$field] = $item[$field]['@attributes']['url'];
                    }
                } else {
                    $formatted[$field] = $item[$field];
                }
            }
            if ($strip_tags) {
                $formatted = array_map('strip_tags', $formatted);
                $formatted = array_map('html_entity_decode', $formatted);
            }
            $return[] = $formatted;
            if (count($return) >= $count) {
                break;
            }
        }
        return $return;
    }
);

if (!$content) {
    response_send_json(array('error' => 'unknown error'));
}
callmap_log($feed);
response_send_json($content, 60 * 60 * 24 * 31);