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

import com.genersoft.iot.vmp.conf.SipConfig;
import com.genersoft.iot.vmp.gb28181.SipLayer;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.response.ISIPResponseProcessor;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import gov.nist.core.Host;
import gov.nist.javax.sip.address.AddressImpl;
import gov.nist.javax.sip.address.SipUri;
import gov.nist.javax.sip.header.To;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.sip.ResponseEvent;
import javax.sip.address.Address;
import javax.sip.address.URI;
import javax.sip.header.CallIdHeader;
import javax.sip.header.ExpiresHeader;
import javax.sip.header.ToHeader;
import javax.sip.header.WWWAuthenticateHeader;
import javax.sip.message.Response;
import java.util.UUID;

/**    
 * @Description:Register响应处理器
 * @author: swwheihei
 * @date:   2020年5月3日 下午5:32:23     
 */
@Component
public class RegisterResponseProcessor implements ISIPResponseProcessor {

	private Logger logger = LoggerFactory.getLogger(RegisterRequestProcessor.class);

	@Autowired
	private ISIPCommanderForPlatform sipCommanderForPlatform;

	@Autowired
	private IVideoManagerStorager storager;

	@Autowired
	private IRedisCatchStorage redisCatchStorage;

	public RegisterResponseProcessor() {
	}

	/**
	 * 处理Register响应
	 *
 	 * @param evt
	 * @param layer
	 * @param config
	 */
	@Override
	public void process(ResponseEvent evt, SipLayer layer, SipConfig config) {
		// TODO Auto-generated method stub
		Response response = evt.getResponse();
		ToHeader toHeader = (ToHeader) response.getHeader(ToHeader.NAME);
		SipUri uri = (SipUri)toHeader.getAddress().getURI();
		String platformGBId = uri.getAuthority().getUser();

		logger.info(String.format("收到 %s 的注册/注销%S响应", platformGBId, response.getStatusCode() ));

		ParentPlatformCatch parentPlatformCatch = redisCatchStorage.queryPlatformCatchInfo(platformGBId);
		if (parentPlatformCatch == null) {
			logger.warn(String.format("收到 %s 的注册/注销%S请求, 但是平台缓存信息未查询到!!!", platformGBId, response.getStatusCode()));
			return;
		}
		ParentPlatform parentPlatform = parentPlatformCatch.getParentPlatform();
		if (parentPlatform == null) {
			logger.warn(String.format("收到 %s 的注册/注销%S请求, 但是平台信息未查询到!!!", platformGBId, response.getStatusCode()));
			return;
		}

		if (response.getStatusCode() == 401) {
			WWWAuthenticateHeader www = (WWWAuthenticateHeader)response.getHeader(WWWAuthenticateHeader.NAME);


			CallIdHeader callIdHeader = (CallIdHeader)response.getHeader(CallIdHeader.NAME);
			String callId = callIdHeader.getCallId();

			sipCommanderForPlatform.register(parentPlatform, callId, www, null, null);
		}else if (response.getStatusCode() == 200){
			// 注册成功
			logger.info(String.format("%s 注册成功", platformGBId ));
			parentPlatform.setStatus(true);
			storager.updateParentPlatform(parentPlatform);
			//
			redisCatchStorage.updatePlatformRegister(parentPlatform);

			redisCatchStorage.updatePlatformKeepalive(parentPlatform);

			parentPlatformCatch.setParentPlatform(parentPlatform);

			redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch);
		}
	}

}