package com.genersoft.iot.vmp.gb28181.transmit;

import javax.sip.RequestEvent;
import javax.sip.ResponseEvent;
import javax.sip.header.CSeqHeader;
import javax.sip.message.Request;
import javax.sip.message.Response;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.genersoft.iot.vmp.gb28181.transmit.request.ISIPRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.AckRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.ByeRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.CancelRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.InviteRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.MessageRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.OtherRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.SubscribeRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.ISIPResponseProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.impl.ByeResponseProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.impl.CancelResponseProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.impl.InviteResponseProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.impl.OtherResponseProcessor;

/**    
 * @Description:TODO(这里用一句话描述这个类的作用)   
 * @author: songww
 * @date:   2020年5月3日 下午4:24:37     
 */
@Component
public class SIPProcessorFactory {
	
	@Autowired
	private InviteRequestProcessor inviteRequestProcessor;
	
	@Autowired
	private RegisterRequestProcessor registerRequestProcessor;
	
	@Autowired
	private SubscribeRequestProcessor subscribeRequestProcessor;
	
	@Autowired
	private AckRequestProcessor ackRequestProcessor;
	
	@Autowired
	private ByeRequestProcessor byeRequestProcessor;
	
	@Autowired
	private CancelRequestProcessor cancelRequestProcessor;
	
	@Autowired
	private MessageRequestProcessor messageRequestProcessor;
	
	@Autowired
	private OtherRequestProcessor otherRequestProcessor;
	
	@Autowired
	private InviteResponseProcessor inviteResponseProcessor;
	
	@Autowired
	private ByeResponseProcessor byeResponseProcessor;
	
	@Autowired
	private CancelResponseProcessor cancelResponseProcessor;
	
	@Autowired
	private OtherResponseProcessor otherResponseProcessor;
	
	
	public ISIPRequestProcessor createRequestProcessor(RequestEvent evt) {
		Request request = evt.getRequest();
		String method = request.getMethod();
		
		if (Request.INVITE.equals(method)) {
			return inviteRequestProcessor;
		} else if (Request.REGISTER.equals(method)) {
			return registerRequestProcessor;
		} else if (Request.SUBSCRIBE.equals(method)) {
			return subscribeRequestProcessor;
		} else if (Request.ACK.equals(method)) {
			return ackRequestProcessor;
		} else if (Request.BYE.equals(method)) {
			return byeRequestProcessor;
		} else if (Request.CANCEL.equals(method)) {
			return cancelRequestProcessor;
		} else if (Request.MESSAGE.equals(method)) {
			return messageRequestProcessor;
		} else {
			return otherRequestProcessor;
		}
	}
	
	public ISIPResponseProcessor createResponseProcessor(ResponseEvent evt) {
		Response response = evt.getResponse();
		CSeqHeader cseqHeader = (CSeqHeader) response.getHeader(CSeqHeader.NAME);
		String method = cseqHeader.getMethod();
		if(Request.INVITE.equals(method)){
			return inviteResponseProcessor;
		} else if (Request.BYE.equals(method)) {
			return byeResponseProcessor;
		} else if (Request.CANCEL.equals(method)) {
			return cancelResponseProcessor;
		} else {
			return otherResponseProcessor;
		}
	}
	
}