Review

finding-9

org/asteriskjava/manager/internal/EventBuilderImpl.java

buildEvent(Object, Map)

class EventBuilderImpl {
    @SuppressWarnings("unchecked")
	public ManagerEvent buildEvent(Object source, Map<String, Object> attributes)
    {
        ManagerEvent event;
        String eventType = null;
        Class<?> eventClass;
        Constructor<?> constructor;

        if (attributes.get("event") == null)
        {
            logger.error("No event type in properties");
            return null;
        }

        if (attributes.get("event") instanceof List ) 
		{
            List<?> eventNames = (List<?>) attributes.get( "event" );
            if (eventNames.size() > 0 && "PeerEntry".equals(eventNames.get(0))) 
			{
                // List of PeerEntry events was received (AJ-329)
                // Convert map of lists to list of maps - one map for each PeerEntry event
                int peersAmount = attributes.get("listitems") != null ?
                    Integer.valueOf((String) attributes.get("listitems")) :
                        eventNames.size() - 1; // Last event is PeerlistComplete
                List<Map<String, Object>> peersAttributes = new ArrayList<Map<String, Object>>();
                for (Map.Entry<String, Object> attribute : attributes.entrySet()) 
				{
                    String key = attribute.getKey();
                    Object value = attribute.getValue();
                    for (int i = 0; i < peersAmount; i++) 
					{
                        Map<String, Object> peerAttrs;
                        if (peersAttributes.size() > i) 
						{
                            peerAttrs = peersAttributes.get(i);
                        } 
						else 
						{
                            peerAttrs = new HashMap<String, Object>();
                            peersAttributes.add(i, peerAttrs);
                        }
                        if (value instanceof List) 
						{
                            peerAttrs.put(key, ((List<?>) value).get(i));
                        } 
						else if (value instanceof String && !"listitems".equals(key)) 
						{
                            peerAttrs.put(key, value);
                        }
                    }
                }
                attributes.put("peersAttributes", peersAttributes);
                eventType = "peers";
            }
        } 
		else 
		{
            if (!(attributes.get("event") instanceof String)) 
			{
                logger.error("Event type is not a String or List");
                return null;
            }

            eventType = ((String) attributes.get("event")).toLowerCase(Locale.US);

            // Change in Asterisk 1.4 where the name of the UserEvent is sent as property instead
            // of the event name (AJ-48)
            if ("userevent".equals(eventType))
            {
                String userEventType;

                if (attributes.get("userevent") == null)
                {
                    logger.error("No user event type in properties");
                    return null;
                }
                if (!(attributes.get("userevent") instanceof String))
                {
                    logger.error("User event type is not a String");
                    return null;
                }

                userEventType = ((String) attributes.get("userevent")).toLowerCase(Locale.US);
                eventType = eventType + userEventType;
            }
        }

        eventClass = registeredEventClasses.get(eventType);
        if (eventClass == null)
        {
            logger.info("No event class registered for event type '" + eventType + "', attributes: " + attributes
                    + ". Please report at https://github.com/asterisk-java/asterisk-java/issues");
            return null;
        }

        try
        {
            constructor = eventClass.getConstructor(new Class[]{Object.class});
        }
        catch (NoSuchMethodException ex)
        {
            logger.error("Unable to get constructor of " + eventClass.getName(), ex);
            return null;
        }

        try
        {
            event = (ManagerEvent) constructor.newInstance(source);
        }
        catch (Exception ex)
        {
            logger.error("Unable to create new instance of " + eventClass.getName(), ex);
            return null;
        }

        if (attributes.get("peersAttributes") != null && attributes.get( "peersAttributes" ) instanceof List) {
            // Fill Peers event with list of PeerEntry events (AJ-329)
            PeersEvent peersEvent = (PeersEvent) event;
            // TODO: This cast is very ugly, we should review how attributes are being passed around. 
            for( Map<String, Object> peerAttrs : (List<Map<String, Object>>) attributes.get("peersAttributes")) {
                PeerEntryEvent peerEntryEvent = new PeerEntryEvent( source );
                setAttributes(peerEntryEvent, peerAttrs, ignoredAttributes);
                List<PeerEntryEvent> peerEntryEvents = peersEvent.getChildEvents();
                if (peerEntryEvents == null) 
				{
                    peerEntryEvents = new ArrayList<PeerEntryEvent>();
                    peersEvent.setChildEvents(peerEntryEvents);
                }
                peerEntryEvents.add(peerEntryEvent);
            }
            peersEvent.setActionId((peersEvent.getChildEvents().get(0).getActionId()));
        } 
		else 
		{
            setAttributes(event, attributes, ignoredAttributes);
        }

        // ResponseEvents are sent in response to a ManagerAction if the
        // response contains lots of data. They include the actionId of
        // the corresponding ManagerAction.
        if (event instanceof ResponseEvent)
        {
            ResponseEvent responseEvent;
            String actionId;

            responseEvent = (ResponseEvent) event;
            actionId = responseEvent.getActionId();
            if (actionId != null)
            {
                responseEvent.setActionId(ManagerUtil.stripInternalActionId(actionId));
                responseEvent.setInternalActionId(ManagerUtil.getInternalActionId(actionId));
            }
        }

        return event;
    }

}