package com.franklinmint.mule.processors;

import java.util.List;

import org.apache.commons.lang.StringUtils;
import org.mule.api.MuleEvent;
import org.mule.api.MuleException;

import com.franklinmint.api.CustomerLookupQuery;
import com.franklinmint.sugarcrm.model.Contact;

public class SugarLookupCustomerProcessor extends NewAbstractSugarProcessor {

	@Override
	public MuleEvent process(MuleEvent event) throws MuleException {
		try {
			CustomerLookupQuery query = convertTo(CustomerLookupQuery.class, event.getMessage().getPayload());
			if (StringUtils.isNotBlank(query.getSugarCRMCustomerId())) {
				Contact contact = new Contact();
				contact.setId(query.getSugarCRMCustomerId());
				List<Contact> result = sugarCRMClient.lookup(contact);
				if (result.size() > 0) {
					event.getMessage().setPayload(result.get(0));
					return event;
				}
			}
			if (StringUtils.isNotBlank(query.getOmxCustomerId())) {
				Contact contact = new Contact();
				contact.setOmxNumber(query.getOmxCustomerId());
				List<Contact> result = sugarCRMClient.lookup(contact);
				if (result.size() > 0) {
					event.getMessage().setPayload(result.get(0));
					return event;
				}
			}
			if (StringUtils.isNotBlank(query.getMagentoCustomerId())) {
				Contact contact = new Contact();
				contact.setMagentoCustomerId(query.getMagentoCustomerId());
				List<Contact> result = sugarCRMClient.lookup(contact);
				if (result.size() > 0) {
					event.getMessage().setPayload(result.get(0));
					return event;
				}
			}

			event.getMessage().setPayload(null);
			return event;
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

}