Subversion Repositories SmartDukaan

package in.shop2020.alert.handler;

import in.shop2020.alert.AlertMapper;
import in.shop2020.alert.AlertService.Iface;
import in.shop2020.alert.AlertServiceException;
import in.shop2020.alert.AlertType;
import in.shop2020.alert.AlertedEntity;
import in.shop2020.alert.EntityType;
import in.shop2020.alert.MonitoredEntity;
import in.shop2020.alert.SearchFilter;
import in.shop2020.alert.handler.EntityHandler;

import java.util.List;

import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class AlertServiceHandler implements Iface {

        private static Logger logger = LoggerFactory.getLogger(AlertServiceHandler.class);
        
        private EntityHandler entityHandler;
        private ApplicationContext context;
        
        
        public AlertServiceHandler() {
                logger.info("Creating context");
                context = new ClassPathXmlApplicationContext("context.xml");
                entityHandler              = context.getBean(EntityHandler.class);
        }

        @Override
        public void scheduleAlert(MonitoredEntity monitoredEntity)
                        throws AlertServiceException, TException {
                entityHandler.scheduleAlert(monitoredEntity);
                
        }

        @Override
        public void updateMonitoredObject(MonitoredEntity monitoredEntity)
                        throws AlertServiceException, TException {
                entityHandler.updateMonitoredObject(monitoredEntity);
                
        }
        @Override
        public void endMonitoringEntity(EntityType entityType, String key)
                        throws AlertServiceException, TException {
                entityHandler.endMonitoring(entityType, key);
                
        }

        @Override
        public List<MonitoredEntity> getEntities(SearchFilter searchFilter)
                        throws AlertServiceException, TException {
                return entityHandler.getEntities(searchFilter);
        }
        
        @Override
        public List<AlertedEntity> getAlertedEntities(SearchFilter searchFilter)
                        throws AlertServiceException, TException {
                return entityHandler.getAlertedEntities(searchFilter);
        }

        @Override
        public void registerEventType(AlertMapper alertMap)
                        throws AlertServiceException, TException {
                entityHandler.registerEventType(alertMap);
        }

        @Override
        public AlertMapper getAlertMapper(EntityType entityType, int eventType)
                        throws AlertServiceException, TException {
                return entityHandler.getAlertMapper(entityType, eventType);
        }
        
        @Override
        public void activateEntityMonitoring(EntityType entityType, String userIds)
                        throws AlertServiceException, TException {
                entityHandler.activateEntityMonitoring(entityType, userIds);
                
        }

        @Override
        public void deActivateEntityMonitoring(EntityType entityType)
                        throws AlertServiceException, TException {
                entityHandler.deActivateEntityMonitoring(entityType);
        }
        
        @Override
        public boolean isAlive() throws TException {
                 try {
                    return true;
                } catch (Exception e) {
                    logger.error("Alert Service not running", e);
                    return false;
                }
        }

        @Override
        public void closeSession() throws TException {
        }

        public void setDataSourceUrl(String dbHost) {
                org.apache.commons.dbcp.BasicDataSource ds = (org.apache.commons.dbcp.BasicDataSource)context.getBean("dataSource");
                ds.setUrl(dbHost);
        }

        public String getDataSourceUrl() {
                org.apache.commons.dbcp.BasicDataSource ds = (org.apache.commons.dbcp.BasicDataSource)context.getBean("dataSource");
                return ds.getUrl();
        }

}