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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
var _ = require('underscore');
var AWS = require('aws-sdk');
var s3 = new AWS.S3();
var doc = require('dynamodb-doc');
var dynamo = new doc.DynamoDB();
var DDB_VIEWS_TABLE = 'podcast-views';
/**
* PodcastView represents a pre-rendered view template.
*
* @param {Object} view - properties to set on the view and pass to the
* template.
* @constructor
*/
var PodcastView = module.exports = function PodcastView(view) {
for (var property in view) {
if (view.hasOwnProperty(property)) {
this[property] = view[property];
}
}
};
/**
* Find a view in DynamoDB by Id.
*
* @param {Object} id - The view id.
* @param {Function} - Callback to call with an error or view.
*/
PodcastView.findById = function(id, callback) {
var params = {
TableName: DDB_VIEWS_TABLE,
Key: id
};
dynamo.getItem(params, function(error, data) {
if (error) {
callback(error);
return;
}
var view = new PodcastView(data.Item);
callback(null, view);
});
}
/**
* Find all views for a given feed.
*
* @param {Object} feedId - The feed id.
* @param {Function} - Callback with signature function(error, view, last)
*/
PodcastView.forEachView = function(feedId, callback) {
forEachView(feedId, callback);
};
function forEachView(feedId, callback, startKey) {
var params = {
TableName: DDB_VIEWS_TABLE,
KeyConditionExpression: "feedId = :feedId",
ExpressionAttributeValues: {
':feedId': feedId
}
};
if (startKey) {
params['ExclusiveStartKey'] = startKey;
}
dynamo.query(params, function(error, data) {
if (error != null) {
callback(error);
return;
}
var lastResponse = !data.LastEvaluatedKey;
data.Items.forEach(function(viewData, index, array) {
var view = new PodcastView(viewData);
var last = lastResponse && index == (array.length - 1);
callback(null, view, last);
});
// If this is not the last set of responses, get more.
if (!lastResponse) {
forEachView(feedId, callback, data.LastEvaluatedKey);
}
});
}
PodcastView.prototype.render = function(episodes, callback) {
var bucket = this.bucket;
var filenameTemplate = this.filenameTemplate;
var template = this.template;
var data = {
view: this,
episodes: episodes,
};
if (this.renderEach) {
var remainingEpisodes = episodes.length;
var uploadCallback = function(error) {
remainingEpisodes--;
if (remainingEpisodes == 0 || error != null) {
callback(error);
}
};
episodes.forEach(function(episode) {
data['episode'] = episode;
var filename = _.template(filenameTemplate)(data);
var renderedView = _.template(template)(data);
saveView(bucket, filename, renderedView, uploadCallback);
});
} else {
var filename = _.template(filenameTemplate)(data);
var renderedView = _.template(template)(data);
saveView(bucket, filename, renderedView, callback);
}
};
function saveView(bucket, filename, renderedView, callback) {
var params = {
Bucket: bucket,
Key: filename,
Body: renderedView,
};
s3.putObject(params, callback);
}
PodcastView.prototype.remove = function(callback) {
if (!this.bucket || !this.key) {
callback(new Error("View is missing bucket or key"));
return;
}
var params = {
Bucket: this.bucket,
Key: this.key
};
s3.deleteObject(params, callback);
}
|
