mirrors/linphone-iphone
1
0
Fork 1
mirror of https://gitlab.linphone.org/BC/public/linphone-iphone.git synced 2026-01-29 09:09:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

prepare proxy

Browse source 
git-svn-id: svn+ssh://svn.savannah.nongnu.org/linphone/trunk@61 3f6dc0c8-ddfe-455d-9043-3cd528dc4637
This commit is contained in:
jehan 2008-10-01 19:39:50 +00:00
parent 4b4331bb56
commit 74b9610aee
1 changed files with 57 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
p2pproxy/src/org/linphone/p2pproxy/core/sipproxy/superpeers/SuperPeerProxy.java
View file

@ -21,12 +21,22 @@ package org.linphone.p2pproxy.core.sipproxy.superpeers;
import java.util.Map;
import org.apache.log4j.Logger;
import org.linphone.p2pproxy.api.P2pProxyException;
import org.linphone.p2pproxy.api.P2pProxyUserNotFoundException;
import org.linphone.p2pproxy.core.JxtaNetworkManager;
import org.linphone.p2pproxy.core.sipproxy.RegistrationHandler;
import org.linphone.p2pproxy.core.sipproxy.SipProxy;
import org.linphone.p2pproxy.core.sipproxy.SipUtils;
import org.linphone.p2pproxy.core.sipproxy.SipProxyRegistrar.Registration;
import org.zoolu.sip.address.NameAddress;
import org.zoolu.sip.address.SipURL;
import org.zoolu.sip.header.Header;
import org.zoolu.sip.header.MultipleHeader;
import org.zoolu.sip.header.RecordRouteHeader;
import org.zoolu.sip.header.RouteHeader;
import org.zoolu.sip.message.Message;
import org.zoolu.sip.provider.SipProvider;
@ -34,15 +44,61 @@ public class SuperPeerProxy implements SipProxy, RegistrationHandler {
private final JxtaNetworkManager mJxtaNetworkManager;
private final String mRegistrarAddress;
private final Map<String,Registration> mRegistrationTab;
private static Logger mLog = Logger.getLogger(SuperPeerProxy.class);
public SuperPeerProxy(JxtaNetworkManager aJxtaNetworkManager, String aRegistrarAddress, Map<String,Registration> aRegistrationTab ) {
mJxtaNetworkManager = aJxtaNetworkManager;
mRegistrarAddress = aRegistrarAddress;
mRegistrationTab = aRegistrationTab;
}
public void proxyRequest(SipProvider provider, Message message) throws P2pProxyException {
public void proxyRequest(SipProvider aProvider, Message aMessage) throws P2pProxyException {
// 1 check if user is a local user
if (mLog.isInfoEnabled()) mLog.info("processing request " +aMessage);
String lTo = aMessage.getFromHeader().getNameAddress().getAddress().toString();
SipURL lNextHope = null;
//check if invite
if (aMessage.isInvite()) {
//ok need to find the root
//is local ?
synchronized (mRegistrationTab) {
if (mRegistrationTab.containsKey(lTo)) {
//great, just need to get it
lNextHope = new SipURL(mRegistrationTab.get(lTo).Contact);
} else {
throw new P2pProxyUserNotFoundException("user ["+lTo+"] not found");
}
}
} else {
//just look at route set
MultipleHeader lMultipleRecordRoute = aMessage.getRecordRoutes();
if (lMultipleRecordRoute != null) {
lMultipleRecordRoute.removeTop();
}
if (lMultipleRecordRoute.getTop() != null) {
lNextHope = ((RecordRouteHeader)lMultipleRecordRoute.getTop()).getNameAddress().getAddress();
} else {
// last proxy, get route
}
throw new P2pProxyException("not implemented yet");
}
//RequestLine lRequestLine = new RequestLine(lSipMessage.getRequestLine().getMethod(),lNextHope);
//lSipMessage.setRequestLine(lRequestLine);
MultipleHeader lMultipleRoute = aMessage.getRoutes();
RouteHeader lRouteHeader = new RouteHeader(new NameAddress(lNextHope+";lr"));
//lRouteHeader.setParameter("lr", null);
if (lMultipleRoute != null) {
lMultipleRoute.addTop(lRouteHeader);
aMessage.setRoutes(lMultipleRoute);
} else {
aMessage.addRouteHeader(lRouteHeader);
}
// add Via only udp
SipUtils.addVia(aProvider,aMessage);
// add recordRoute
SipUtils.addRecordRoute(aProvider,aMessage);
aProvider.sendMessage(aMessage);
}