package com.genersoft.iot.vmp.gb28181.utils; import com.genersoft.iot.vmp.utils.GitUtil; import gov.nist.javax.sip.address.AddressImpl; import gov.nist.javax.sip.address.SipUri; import gov.nist.javax.sip.header.Subject; import javax.sip.PeerUnavailableException; import javax.sip.SipFactory; import javax.sip.header.FromHeader; import javax.sip.header.Header; import javax.sip.header.UserAgentHeader; import javax.sip.message.Request; import java.text.ParseException; import java.util.ArrayList; import java.util.List; import java.util.UUID; /** * @author panlinlin * @version 1.0.0 * @description JAIN SIP的工具类 * @createTime 2021年09月27日 15:12:00 */ public class SipUtils { public static String getUserIdFromFromHeader(Request request) { FromHeader fromHeader = (FromHeader)request.getHeader(FromHeader.NAME); return getUserIdFromFromHeader(fromHeader); } /** * 从subject读取channelId * */ public static String getChannelIdFromRequest(Request request) { Header subject = request.getHeader("subject"); if (subject == null) { // 如果缺失subject return null; } return ((Subject) subject).getSubject().split(":")[0]; } public static String getUserIdFromFromHeader(FromHeader fromHeader) { AddressImpl address = (AddressImpl)fromHeader.getAddress(); SipUri uri = (SipUri) address.getURI(); return uri.getUser(); } public static String getNewViaTag() { return "z9hG4bK" + System.currentTimeMillis(); } public static UserAgentHeader createUserAgentHeader(SipFactory sipFactory, GitUtil gitUtil) throws PeerUnavailableException, ParseException { List agentParam = new ArrayList<>(); agentParam.add("WVP-Pro v"); if (gitUtil != null && gitUtil.getCommitTime() != null) { agentParam.add(gitUtil.getBuildVersion() + "."); agentParam.add(gitUtil.getCommitTime()); } return sipFactory.createHeaderFactory().createUserAgentHeader(agentParam); } public static String getNewFromTag(){ return UUID.randomUUID().toString().replace("-", ""); // return getNewTag(); } public static String getNewTag(){ return String.valueOf(System.currentTimeMillis()); } }