397 lines
12 KiB
JavaScript
397 lines
12 KiB
JavaScript
//
|
|
// The Antville Project
|
|
// http://code.google.com/p/antville
|
|
//
|
|
// Copyright 2001-2007 by The Antville People
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the ``License'');
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an ``AS IS'' BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
// $Revision$
|
|
// $LastChangedBy$
|
|
// $LastChangedDate$
|
|
// $URL$
|
|
//
|
|
|
|
Root.VERSION = "1.2";
|
|
|
|
Root.getScopes = defineConstants(Root, markgettext("every site"),
|
|
markgettext("public sites"), markgettext("trusted sites"),
|
|
markgettext("no site"));
|
|
|
|
this.handleMetadata("notificationScope");
|
|
this.handleMetadata("quota");
|
|
this.handleMetadata("creationScope");
|
|
this.handleMetadata("creationDelay");
|
|
this.handleMetadata("qualifyingPeriod");
|
|
this.handleMetadata("qualifyingDate");
|
|
this.handleMetadata("autoCleanupEnabled");
|
|
this.handleMetadata("autoCleanupStartTime");
|
|
this.handleMetadata("phaseOutPrivateSites");
|
|
this.handleMetadata("phaseOutInactiveSites");
|
|
this.handleMetadata("phaseOutNotificationPeriod");
|
|
this.handleMetadata("phaseOutGracePeriod");
|
|
|
|
Root.restore = function(ref) {
|
|
var backup;
|
|
if (backup = session.data.backup) {
|
|
ref.title = decodeURIComponent(backup.title);
|
|
ref.text = decodeURIComponent(backup.text);
|
|
}
|
|
return ref;
|
|
}
|
|
|
|
Root.commitRequests = function() {
|
|
var requests = app.data.requests;
|
|
app.data.requests = {};
|
|
for each (var item in requests) {
|
|
switch (item.type) {
|
|
case Story:
|
|
var story = Story.getById(item.id);
|
|
story && (story.requests = item.requests);
|
|
break;
|
|
}
|
|
}
|
|
res.commit();
|
|
return;
|
|
}
|
|
|
|
Root.commitReferrers = function() {
|
|
var referrers = app.data.referrers;
|
|
if (referrers.length < 1) {
|
|
return;
|
|
}
|
|
|
|
app.data.referrers = [];
|
|
var history = [];
|
|
|
|
for each (var item in referrers) {
|
|
var referrer = helma.Http.evalUrl(item.referrer);
|
|
if (!referrer) {
|
|
continue;
|
|
}
|
|
|
|
// Only log unique combinations of context, ip and referrer
|
|
referrer = String(referrer);
|
|
var key = item.context_type + "#" + item.context_id + ":" +
|
|
item.ip + ":" + referrer;
|
|
if (history.indexOf(key) > -1) {
|
|
continue;
|
|
}
|
|
history.push(key);
|
|
|
|
// Exclude requests coming from the same site
|
|
if (item.site) {
|
|
var href = item.site.href().toLowerCase();
|
|
if (referrer.toLowerCase().contains(href.substr(0, href.length-1))) {
|
|
continue;
|
|
}
|
|
}
|
|
item.persist();
|
|
//root.referrers.add(item);
|
|
}
|
|
|
|
res.commit();
|
|
return;
|
|
}
|
|
|
|
Root.purgeReferrers = function() {
|
|
var sql = new Sql;
|
|
var result = sql.execute("delete from log where action = 'main' and " +
|
|
"created < date_add(now(), interval -1 day)");
|
|
return result;
|
|
}
|
|
|
|
Root.invokeCallbacks = function() {
|
|
var http = helma.Http();
|
|
http.setTimeout(200);
|
|
http.setReadTimeout(300);
|
|
http.setMethod("POST");
|
|
|
|
var ref, site, item;
|
|
while (ref = app.data.callbacks.pop()) {
|
|
site = Site.getById(ref.site);
|
|
item = ref.handler && ref.handler.getById(ref.id);
|
|
if (!site || !item) {
|
|
continue;
|
|
}
|
|
app.log("Invoking callback URL " + site.callbackUrl + " for " + item);
|
|
try {
|
|
http.setContent({
|
|
type: item.constructor.name,
|
|
id: item.name || item._id,
|
|
url: item.href(),
|
|
date: item.modified.valueOf(),
|
|
user: item.modifier.name,
|
|
site: site.title || site.name,
|
|
origin: site.href()
|
|
});
|
|
http.getUrl(site.callbackUrl);
|
|
} catch (ex) {
|
|
app.debug("Invoking callback URL " + site.callbackUrl + " failed: " + ex);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
|
|
Root.updateHealth = function() {
|
|
var health = Root.health || {};
|
|
if (!health.modified || new Date - health.modified > 5 * Date.ONEMINUTE) {
|
|
health.modified = new Date;
|
|
health.requestsPerUnit = app.requestCount -
|
|
(health.currentRequestCount || 0);
|
|
health.currentRequestCount = app.requestCount;
|
|
health.errorsPerUnit = app.errorCount - (health.currentErrorCount || 0);
|
|
health.currentErrorCount = app.errorCount;
|
|
Root.health = health;
|
|
}
|
|
return;
|
|
}
|
|
|
|
Root.prototype.processHref = function(href) {
|
|
return app.properties.defaulthost + href;
|
|
}
|
|
|
|
Root.prototype.getPermission = function(action) {
|
|
if (action.contains("admin")) {
|
|
return User.require(User.PRIVILEGED);
|
|
}
|
|
switch (action) {
|
|
case "debug":
|
|
case "health":
|
|
return true;
|
|
case "create":
|
|
return this.getCreationPermission();
|
|
case "default.hook":
|
|
case "sites":
|
|
case "updates.xml":
|
|
return this.mode !== Site.CLOSED;
|
|
}
|
|
return Site.prototype.getPermission.apply(this, arguments);
|
|
}
|
|
|
|
Root.prototype.main_action = function() {
|
|
return Site.prototype.main_action.apply(this);
|
|
|
|
/*var re = /("[^"]*"|'[^']*'|<%(\S*)|/gm;
|
|
var macro = '"1xfoo {0} 2xbar {1}" foo "bar bar" <% test %>';
|
|
var result = macro.replace(re, function() {
|
|
res.debug(arguments[1])
|
|
});
|
|
// res.debug(result)
|
|
return;*/
|
|
|
|
/* FIXME: setup routine needs to be rewritten
|
|
// check if this installation is already configured
|
|
// if not, we display the welcome-page as frontpage
|
|
if (!root.sys_issetup) {
|
|
if (!root.users.size()) {
|
|
res.data.body = this.renderSkinAsString("welcome");
|
|
root.renderSkin("Site#page");
|
|
return;
|
|
} else
|
|
res.redirect(this.manage.href("setup"));
|
|
} else if (!root.size())
|
|
res.redirect(this.href("new"));
|
|
*/
|
|
}
|
|
|
|
Root.prototype.getFormOptions = function(name) {
|
|
switch (name) {
|
|
case "notificationScope":
|
|
return Root.getScopes();
|
|
case "creationScope":
|
|
return User.getScopes();
|
|
case "autoCleanupStartTime":
|
|
return Admin.getHours();
|
|
return;
|
|
}
|
|
return Site.prototype.getFormOptions.apply(this, arguments);
|
|
}
|
|
|
|
Root.prototype.error_action = function() {
|
|
res.status = 500;
|
|
res.data.title = root.getTitle() + " - Error";
|
|
res.data.body = root.renderSkinAsString("$Root#error", res);
|
|
res.handlers.site.renderSkin("Site#page");
|
|
return;
|
|
}
|
|
|
|
Root.prototype.notfound_action = function() {
|
|
res.status = 404;
|
|
res.data.title = root.getTitle() + " - Error";
|
|
res.data.body = root.renderSkinAsString("$Root#notfound", req);
|
|
res.handlers.site.renderSkin("Site#page");
|
|
return;
|
|
}
|
|
|
|
Root.prototype.create_action = function() {
|
|
var site = new Site;
|
|
if (req.postParams.create) {
|
|
try {
|
|
site.update(req.postParams);
|
|
site.layout = new Layout(site);
|
|
this.add(site);
|
|
site.members.add(new Membership(session.user, Membership.OWNER));
|
|
root.admin.log.add(site, "added");
|
|
res.message = gettext("Successfully created your site.");
|
|
res.redirect(site.href());
|
|
} catch (ex) {
|
|
res.message = ex;
|
|
app.log(ex);
|
|
}
|
|
}
|
|
|
|
res.data.action = this.href(req.action);
|
|
res.data.title = gettext("Create a new site");
|
|
res.data.body = site.renderSkinAsString("$Site#create");
|
|
root.renderSkin("Site#page");
|
|
return;
|
|
}
|
|
|
|
Root.prototype.sites_action = function() {
|
|
res.data.list = renderList(root.sites,
|
|
"Site#preview", 10, req.queryParams.page);
|
|
res.data.pager = renderPager(root.sites,
|
|
this.href(req.action), 10, req.queryParams.page);
|
|
res.data.title = gettext("Sites of {0}", root.title);
|
|
res.data.body = this.renderSkinAsString("Root#sites");
|
|
root.renderSkin("Site#page");
|
|
return;
|
|
}
|
|
|
|
Root.prototype.updates_xml_action = function() {
|
|
var now = new Date;
|
|
var feed = new rome.SyndFeedImpl();
|
|
feed.setFeedType("rss_2.0");
|
|
feed.setLink(root.href());
|
|
feed.setTitle("Recently updated sites at " + root.title);
|
|
feed.setDescription(root.tagline);
|
|
feed.setLanguage(root.locale.replace("_", "-"));
|
|
feed.setPublishedDate(now);
|
|
var entries = new java.util.ArrayList();
|
|
var entry, description;
|
|
var sites = root.updates.list(0, 25).sort(Number.Sorter("modified",
|
|
Number.Sorter.DESC));
|
|
for each (var site in sites) {
|
|
entry = new rome.SyndEntryImpl();
|
|
entry.setTitle(site.title);
|
|
entry.setLink(site.href());
|
|
entry.setAuthor(site.creator.name);
|
|
entry.setPublishedDate(site.modified);
|
|
description = new rome.SyndContentImpl();
|
|
description.setType("text/plain");
|
|
description.setValue(site.tagline);
|
|
entry.setDescription(description);
|
|
entries.add(entry);
|
|
}
|
|
feed.setEntries(entries);
|
|
var output = new rome.SyndFeedOutput();
|
|
//output.output(feed, res.servletResponse.writer); return;
|
|
var xml = output.outputString(feed);
|
|
res.contentType = "text/xml";
|
|
res.write(xml); //injectXslDeclaration(xml));
|
|
return;
|
|
}
|
|
|
|
Root.prototype.health_action = function() {
|
|
var jvm = java.lang.Runtime.getRuntime();
|
|
var totalMemory = jvm.totalMemory() / 1024 / 1024;
|
|
var freeMemory = jvm.freeMemory() / 1024 / 1024;
|
|
|
|
var param = {
|
|
uptime: formatNumber((new Date - app.upSince.getTime()) /
|
|
Date.ONEDAY, "0.##"),
|
|
freeMemory: formatNumber(freeMemory),
|
|
totalMemory: formatNumber(totalMemory),
|
|
usedMemory: formatNumber(totalMemory - freeMemory),
|
|
sessions: formatNumber(app.countSessions()),
|
|
cacheSize: formatNumber(getProperty("cacheSize"))
|
|
};
|
|
|
|
for each (key in ["activeThreads", "freeThreads", "requestCount",
|
|
"errorCount", "xmlrpcCount", "cacheusage"]) {
|
|
param[key] = formatNumber(app[key]);
|
|
}
|
|
|
|
if (Root.health) {
|
|
param.requestsPerUnit = formatNumber(Root.health.requestsPerUnit);
|
|
param.errorsPerUnit = formatNumber(Root.health.errorsPerUnit);
|
|
}
|
|
|
|
param.mails = app.data.mails.length;
|
|
param.referrers = app.data.referrers.length;
|
|
param.requests = 0;
|
|
for (var i in app.data.requests) {
|
|
param.requests += 1;
|
|
}
|
|
param.callbacks = app.data.callbacks.length;
|
|
|
|
res.data.title = "Health of " + root.getTitle();
|
|
res.data.body = this.renderSkinAsString("$Root#health", param);
|
|
this.renderSkin("Site#page");
|
|
}
|
|
|
|
Root.prototype.getMacroHandler = function(name) {
|
|
switch (name) {
|
|
case "admin":
|
|
case "api":
|
|
case "sites":
|
|
return this[name];
|
|
}
|
|
return Site.prototype.getMacroHandler.apply(this, arguments);
|
|
}
|
|
|
|
Root.prototype.getCreationPermission = function() {
|
|
var user;
|
|
if (!(user = session.user)) {
|
|
return false;
|
|
} if (User.require(User.PRIVILEGED)) {
|
|
return true;
|
|
}
|
|
|
|
switch (root.creationScope) {
|
|
case User.PRIVILEGEDUSERS:
|
|
return false;
|
|
case User.TRUSTEDUSERS:
|
|
return User.require(User.TRUSTED);
|
|
default:
|
|
case User.ALLUSERS:
|
|
if (root.qualifyingPeriod) {
|
|
var days = Math.floor((new Date - user.created) / Date.ONEDAY);
|
|
if (days < root.qualifyingPeriod) {
|
|
//throw Error(gettext("Sorry, you have to be a member for at " +
|
|
// "least {0} days to create a new site.",
|
|
// formatDate(root.qualifyingPeriod));
|
|
return false;
|
|
}
|
|
} else if (root.qualifyingDate) {
|
|
if (user.created > root.qualifyingDate) {
|
|
//throw Error(gettext("Sorry, only members who have registered " +
|
|
// "before {0} are allowed to create a new site.",
|
|
// formatDate(root.qualifyingDate));
|
|
return false;
|
|
}
|
|
}
|
|
if (user.sites.count() > 0) {
|
|
var days = Math.floor((new Date - user.sites.get(0).created) /
|
|
Date.ONEDAY);
|
|
if (days < root.creationDelay) {
|
|
//throw Error(gettext("Sorry, you still have to wait {0} days " +
|
|
// "before you can create another site.",
|
|
// root.creationDelay - days));
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|