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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
# Copyright (c) 2012 The Chromium Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.
from data_source import DataSource
from docs_server_utils import StringIdentity
from environment import IsPreviewServer
from file_system import FileNotFoundError
from future import Future, All
from jsc_view import JSCView, GetEventByNameFromEvents
from platform_util import GetPlatforms
from samples_data_source import CreateSamplesView
class APIDataSource(DataSource):
'''This class fetches and loads JSON APIs from the FileSystem passed in with
|compiled_fs_factory|, so the APIs can be plugged into templates.
'''
def __init__(self, server_instance, request):
file_system = server_instance.host_file_system_provider.GetTrunk()
self._json_cache = server_instance.compiled_fs_factory.ForJson(file_system)
self._template_cache = server_instance.compiled_fs_factory.ForTemplates(
file_system)
self._platform_bundle = server_instance.platform_bundle
self._view_cache = server_instance.object_store_creator.Create(
APIDataSource,
# Update the models when any of templates, APIs, or Features change.
category=StringIdentity(self._json_cache.GetIdentity(),
self._template_cache.GetIdentity(),
self._platform_bundle.GetIdentity()))
# This caches the result of _LoadEventByName.
self._event_byname_futures = {}
self._request = request
def _LoadEventByName(self, platform):
'''All events have some members in common. We source their description
from Event in events.json.
'''
if platform not in self._event_byname_futures:
future = self._GetSchemaView(platform, 'events')
self._event_byname_futures[platform] = Future(
callback=lambda: GetEventByNameFromEvents(future.Get()))
return self._event_byname_futures[platform]
def _GetSchemaView(self, platform, api_name):
object_store_key = '/'.join((platform, api_name))
api_models = self._platform_bundle.GetAPIModels(platform)
jsc_view_future = self._view_cache.Get(object_store_key)
model_future = api_models.GetModel(api_name)
content_script_apis_future = api_models.GetContentScriptAPIs()
def resolve():
jsc_view = jsc_view_future.Get()
if jsc_view is None:
jsc_view = JSCView(
content_script_apis_future.Get(),
model_future.Get(),
self._platform_bundle.GetAvailabilityFinder(platform),
self._json_cache,
self._template_cache,
self._platform_bundle.GetFeaturesBundle(platform),
self._LoadEventByName(platform),
platform).ToDict()
self._view_cache.Set(object_store_key, jsc_view)
return jsc_view
return Future(callback=resolve)
def _GetImpl(self, platform, api_name):
jsc_view_future = self._GetSchemaView(platform, api_name)
def resolve():
jsc_view = jsc_view_future.Get()
# Parsing samples on the preview server takes seconds and doesn't add
# anything. Don't do it.
if not IsPreviewServer():
samples_model = self._platform_bundle.GetSamplesModel(platform)
# Creates an object that lazily gets samples.
jsc_view['samples'] = type('getter', (object,), {
'get': lambda _, platform: CreateSamplesView(
samples_model.FilterSamples(jsc_view['name']), self._request)
})()
return jsc_view
return Future(callback=resolve)
def get(self, platform):
'''Return a getter object so that templates can perform lookups such
as apis.extensions.runtime.
'''
getter = lambda: 0
getter.get = lambda api_name: self._GetImpl(platform, api_name).Get()
return getter
def Cron(self):
futures = []
for platform in GetPlatforms():
futures += [self._GetImpl(platform, name)
for name in self._platform_bundle.GetAPIModels(platform).GetNames()]
return All(futures, except_pass=FileNotFoundError)
|
