* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* In addition, as a special exception, The Mir-coders gives permission to link
- * the code of this program with any library licensed under the Apache Software License,
- * The Sun (tm) Java Advanced Imaging library (JAI), The Sun JIMI library
- * (or with modified versions of the above that use the same license as the above),
- * and distribute linked combinations including the two. You must obey the
- * GNU General Public License in all respects for all of the code used other than
- * the above mentioned libraries. If you modify this file, you may extend this
- * exception to your version of the file, but you are not obligated to do so.
+ * the code of this program with any library licensed under the Apache Software License,
+ * The Sun (tm) Java Advanced Imaging library (JAI), The Sun JIMI library
+ * (or with modified versions of the above that use the same license as the above),
+ * and distribute linked combinations including the two. You must obey the
+ * GNU General Public License in all respects for all of the code used other than
+ * the above mentioned libraries. If you modify this file, you may extend this
+ * exception to your version of the file, but you are not obligated to do so.
* If you do not wish to do so, delete this exception statement from your version.
*/
package mircoders.global;
+import mir.bundle.BasicBundleFactory;
+import mir.bundle.BundleFactory;
+import mir.bundle.CascadingBundleFactory;
+import mir.bundle.PropertiesFileBundleLoader;
import mir.config.MirPropertiesConfiguration;
-import mir.config.MirPropertiesConfiguration.PropertiesConfigExc;
-import mir.misc.ConfigException;
-import mircoders.localizer.MirCachingLocalizerDecorator;
+import mir.entity.adapter.EntityAdapter;
+import mir.log.LoggerEngine;
+import mir.log.LoggerWrapper;
+import mircoders.accesscontrol.AccessControl;
+import mircoders.entity.EntityComment;
+import mircoders.entity.EntityContent;
+import mircoders.entity.EntityUsers;
+import mircoders.localizer.MirAdminInterfaceLocalizer;
+import mircoders.localizer.LocalizerCache;
import mircoders.localizer.MirLocalizer;
+import mircoders.localizer.MirLocalizerExc;
+import mircoders.localizer.MirLocalizerFailure;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
public class MirGlobal {
- static private MirPropertiesConfiguration configuration;
static private MirLocalizer localizer;
static private ProducerEngine producerEngine;
static private Abuse abuse;
static private MRUCache mruCache;
+ static private AccessControl accessControl;
+ static private Map articleOperations;
+ static private Map commentOperations;
+ static private final Map loggedInUsers = new HashMap();
+ static private final Map loggedInUserIds = new HashMap();
+ static private LoggerWrapper logger = new LoggerWrapper("Global");
+ static private LoggerWrapper adminUsageLogger = new LoggerWrapper("AdminUsage");
+
+ static private ChangeEngine changeEngine = new ChangeEngine();
+
+ static private DatabaseEngine databaseEngine;
+
+ static private BundleFactory bundleFactory =
+ new CascadingBundleFactory(
+ new BasicBundleFactory(
+ new PropertiesFileBundleLoader(
+ config().getHome())));
- public static MirLocalizer localizer() {
+ private MirGlobal() {
+ }
+
+ public synchronized static MirLocalizer localizer() {
String localizerClassName;
Class localizerClass;
if (localizer == null ) {
- synchronized(MirGlobal.class) {
- if (localizer == null ) {
- localizerClassName = config().getString("Mir.Localizer", "mirlocal.localizer.basic.MirBasicLocalizer");
-
- try {
- localizerClass = Class.forName(localizerClassName);
- }
- catch (Throwable t) {
- throw new ConfigException("localizer class '" + localizerClassName + "' not found: " + t.toString());
- }
-
- if (!(MirLocalizer.class.isAssignableFrom(localizerClass)))
- throw new ConfigException("localizer class '" + localizerClassName + "' is not assignable from MirLocalizer");
-
- try {
- localizer = new MirCachingLocalizerDecorator((MirLocalizer) localizerClass.newInstance());
- }
- catch (Throwable t) {
- throw new ConfigException("localizer class '" + localizerClassName + "' cannot be instantiated: " + t.toString());
- }
- }
+ localizerClassName = config().getString("Mir.Localizer", "mirlocal.localizer.basic.MirBasicLocalizer");
+
+ try {
+ localizerClass = Class.forName(localizerClassName);
+ }
+ catch (Throwable t) {
+ throw new MirLocalizerFailure("localizer class '" +
+ localizerClassName + "' not found: ", t);
+ }
+
+ if (!MirLocalizer.class.isAssignableFrom(localizerClass)) {
+ throw new MirLocalizerFailure("localizer class '" +
+ localizerClassName + "' is not assignable from MirLocalizer");
+ }
+
+ try {
+ localizer = new LocalizerCache((MirLocalizer) localizerClass.newInstance());
+ }
+ catch (Throwable t) {
+ throw new MirLocalizerFailure("localizer class '" +
+ localizerClassName + "' cannot be instantiated: " + t.getMessage(), t);
}
}
return localizer;
}
- public static Abuse abuse() {
+ /**
+ * Returns a string that provides some global status information
+ */
+ public static String getStatus() {
+ StringBuffer result = new StringBuffer();
+
+ result.append((Runtime.getRuntime().totalMemory()-Runtime.getRuntime().freeMemory())/(1024*1024));
+ result.append("M in use, ");
+ result.append(Thread.activeCount()).append(" threads, ");
+ result.append(getDatabaseEngine().getStatus());
+
+ return result.toString();
+ }
+
+ synchronized public static Abuse abuse() {
if (abuse==null) {
- synchronized(MirGlobal.class) {
- if (abuse==null)
- abuse = new Abuse();
+ try {
+ abuse = new Abuse(localizer().dataModel().adapterModel());
+ }
+ catch (MirLocalizerExc e) {
+ throw new RuntimeException(e.getMessage());
}
}
return abuse;
}
+ /**
+ * returns the global change engine (used to track changed files)
+ */
+ public static ChangeEngine getChangeEngine() {
+ return changeEngine;
+ }
+
public static MirPropertiesConfiguration config() {
- try {
- return MirPropertiesConfiguration.instance();
- }
- catch (PropertiesConfigExc e) {
- throw new RuntimeException(e.getMessage());
+ return MirPropertiesConfiguration.instance();
+ }
+
+ synchronized public static DatabaseEngine getDatabaseEngine() {
+ if (databaseEngine==null) {
+ databaseEngine = new DatabaseEngine();
}
+
+ return databaseEngine;
}
- public static ProducerEngine producerEngine() {
+ public static ProducerEngine getProducerEngine() {
if (producerEngine == null) {
producerEngine = new ProducerEngine();
}
public static MRUCache mruCache() {
synchronized(MirGlobal.class) {
if (mruCache == null) {
- mruCache = new MRUCache();
+ mruCache = new MRUCache();
}
return mruCache;
}
}
+
+ synchronized public static AccessControl accessControl() {
+ if (accessControl == null) {
+ accessControl=new AccessControl();
+ }
+
+ return accessControl;
+ }
+
+ public static void performArticleOperation(EntityUsers aUser, EntityContent anArticle, String anOperation) {
+ MirAdminInterfaceLocalizer.EntityOperation operation = getArticleOperationForName(anOperation);
+
+ try {
+ EntityAdapter user = null;
+ if (aUser!=null) {
+ user = localizer().dataModel().adapterModel().makeEntityAdapter("user", aUser);
+ }
+
+ if (operation!=null) {
+ operation.perform(
+ user,
+ localizer().dataModel().adapterModel().makeEntityAdapter("content", anArticle));
+ }
+ }
+ catch (Throwable t) {
+ throw new MirGlobalFailure(t.getMessage(), t);
+ }
+ }
+
+ public static void performCommentOperation(EntityUsers aUser, EntityComment aComment, String anOperation) {
+ MirAdminInterfaceLocalizer.EntityOperation operation = getCommentOperationForName(anOperation);
+
+ try {
+ EntityAdapter user = null;
+ if (aUser!=null) {
+ user = localizer().dataModel().adapterModel().makeEntityAdapter("user", aUser);
+ }
+
+ if (operation!=null) {
+ operation.perform(
+ user,
+ localizer().dataModel().adapterModel().makeEntityAdapter("comment", aComment));
+ }
+ }
+ catch (Throwable t) {
+ throw new MirGlobalFailure(t.getMessage(), t);
+ }
+ }
+
+ private synchronized static MirAdminInterfaceLocalizer.EntityOperation
+ getArticleOperationForName(String aName) {
+ try {
+ if (articleOperations == null) {
+ articleOperations = new HashMap();
+ Iterator i = localizer().adminInterface().simpleArticleOperations().iterator();
+ while (i.hasNext()) {
+ MirAdminInterfaceLocalizer.EntityOperation operation =
+ (MirAdminInterfaceLocalizer.EntityOperation) i.next();
+ articleOperations.put(operation.getName(), operation);
+ }
+ }
+
+ return (MirAdminInterfaceLocalizer.EntityOperation) articleOperations.get(aName);
+ }
+ catch (Throwable t) {
+ throw new MirGlobalFailure(t.getMessage(), t);
+ }
+ }
+
+ private synchronized static MirAdminInterfaceLocalizer.EntityOperation
+ getCommentOperationForName(String aName) {
+ try {
+ if (commentOperations == null) {
+ commentOperations = new HashMap();
+ Iterator i = localizer().adminInterface().simpleCommentOperations().iterator();
+ while (i.hasNext()) {
+ MirAdminInterfaceLocalizer.EntityOperation operation =
+ (MirAdminInterfaceLocalizer.EntityOperation) i.next();
+ commentOperations.put(operation.getName(), operation);
+ }
+ }
+
+ return (MirAdminInterfaceLocalizer.EntityOperation) commentOperations.get(aName);
+ }
+ catch (Throwable t) {
+ throw new MirGlobalFailure(t.getMessage(), t);
+ }
+ }
+
+ public static boolean isUserLoggedIn(String anId) {
+ synchronized (loggedInUserIds) {
+ return loggedInUserIds.containsKey(anId);
+ }
+ }
+
+ public static List getLoggedInUsers() {
+ List result = new ArrayList();
+
+ synchronized (loggedInUsers) {
+ Iterator i = loggedInUsers.entrySet().iterator();
+
+ while (i.hasNext()) {
+ Map.Entry entry = (Map.Entry) i.next();
+
+ Map item = new HashMap();
+ item.put("name", entry.getKey());
+ item.put("count", entry.getValue());
+ result.add(item);
+ }
+ }
+
+ return result;
+ }
+
+ public static BundleFactory getBundleFactory() {
+ return bundleFactory;
+ }
+
+ public static void registerLogin(String aName, String anId) {
+ modifyLoggedInCount(aName, anId, 1);
+ }
+
+ public static void registerLogout(String aName, String anId) {
+ modifyLoggedInCount(aName, anId, -1);
+ }
+
+ private static void modifyLoggedInCount(String aName, String anId, int aModifier) {
+ synchronized (loggedInUsers) {
+ Integer count = (Integer) loggedInUsers.get(aName);
+ if (count==null)
+ count = new Integer(0);
+
+ if (count.intValue()+aModifier<=0) {
+ loggedInUsers.remove(aName);
+ }
+ else {
+ loggedInUsers.put(aName, new Integer(count.intValue() + aModifier));
+ }
+ }
+
+ synchronized (loggedInUserIds) {
+ Integer count = (Integer) loggedInUserIds.get(anId);
+ if (count==null)
+ count = new Integer(0);
+
+ if (count.intValue()+aModifier<=0) {
+ loggedInUserIds.remove(anId);
+ }
+ else {
+ loggedInUserIds.put(anId, new Integer(count.intValue() + aModifier));
+ }
+ }
+ }
+
+ /**
+ * Called whenever a modifying admin action occurs. Used to log
+ * the action, if admin activity logging is turned on,
+ */
+ public static void logAdminUsage(EntityUsers aUser, String anObject, String aDescription) {
+ try {
+ if (config().getString("Mir.Admin.LogAdminActivity", "0").equals("1")) {
+ String user = "unknown (" + aUser.toString() + ")";
+ if (aUser != null)
+ user = aUser.getFieldValue("login");
+ adminUsageLogger.info(user + " | " + anObject + " | " + aDescription);
+ }
+ }
+ catch (Throwable t) {
+ logger.error("Error while logging admin usage ("+
+ aUser.toString()+", "+aDescription+"): " +t.toString());
+ }
+ }
+
+ /**
+ * Reloads all reloadable configurations, such as the producer subsystem.
+ */
+ public static void reloadConfigurations() throws MirGlobalExc, MirGlobalFailure {
+ getProducerEngine().reloadConfiguration();
+ try {
+ LoggerEngine.reload();
+ }
+ catch (Throwable e) {
+ throw new MirGlobalFailure(e);
+ }
+ getBundleFactory().reload();
+ }
}
-
+
projects / mir.git / blobdiff