patches 20/11/2024

This commit is contained in:
2024-11-20 11:32:50 +07:00
parent 26579a8acf
commit 142c400273

View File

@@ -25,6 +25,8 @@ import java.util.Hashtable;
import java.util.Timer; import java.util.Timer;
import java.util.TimerTask; import java.util.TimerTask;
import lombok.Getter;
import lombok.Setter;
import org.pmw.tinylog.Logger; import org.pmw.tinylog.Logger;
import peers.Config; import peers.Config;
@@ -54,6 +56,7 @@ public class RegisterHandler extends MethodHandler
public static final int REFRESH_MARGIN = 10; // seconds public static final int REFRESH_MARGIN = 10; // seconds
@Setter
private InitialRequestManager initialRequestManager; private InitialRequestManager initialRequestManager;
private Timer timer; private Timer timer;
@@ -64,6 +67,7 @@ public class RegisterHandler extends MethodHandler
//FIXME should be on a profile based context //FIXME should be on a profile based context
private boolean unregisterInvoked; private boolean unregisterInvoked;
@Getter
private boolean registered; private boolean registered;
public RegisterHandler(UserAgent userAgent, public RegisterHandler(UserAgent userAgent,
@@ -132,7 +136,7 @@ public class RegisterHandler extends MethodHandler
public void errResponseReceived(SipResponse sipResponse) { public void errResponseReceived(SipResponse sipResponse) {
String password = userAgent.getConfig().getPassword(); String password = userAgent.getConfig().getPassword();
if (password != null && !"".equals(password.trim())) { if (password != null && !password.trim().isEmpty()) {
int statusCode = sipResponse.getStatusCode(); int statusCode = sipResponse.getStatusCode();
if (statusCode == RFC3261.CODE_401_UNAUTHORIZED if (statusCode == RFC3261.CODE_401_UNAUTHORIZED
|| statusCode == || statusCode ==
@@ -170,7 +174,7 @@ public class RegisterHandler extends MethodHandler
} }
} }
String received = via.getParam(receivedName); String received = via.getParam(receivedName);
if (received != null && !"".equals(received.trim())) { if (received != null && !received.trim().isEmpty()) {
if (viaValue.equals(received)) { if (viaValue.equals(received)) {
notifyListener(sipResponse); notifyListener(sipResponse);
} else { // received != via ip address } else { // received != via ip address
@@ -180,10 +184,7 @@ public class RegisterHandler extends MethodHandler
Config config = userAgent.getConfig(); Config config = userAgent.getConfig();
config.setPublicInetAddress(receivedInetAddress); config.setPublicInetAddress(receivedInetAddress);
userAgent.register(); userAgent.register();
} catch (UnknownHostException e) { } catch (Exception e) {
notifyListener(sipResponse);
Logger.error(e.getMessage(), e);
} catch (SipUriSyntaxException e) {
notifyListener(sipResponse); notifyListener(sipResponse);
Logger.error(e.getMessage(), e); Logger.error(e.getMessage(), e);
} }
@@ -237,7 +238,7 @@ public class RegisterHandler extends MethodHandler
// patch mobicents simple application // patch mobicents simple application
registered = true; registered = true;
int delay = -1; int delay = -1;
if (expires == null || "".equals(expires.trim())) { if (expires == null || expires.trim().isEmpty()) {
delay = 3600; delay = 3600;
} }
if (!unregisterInvoked) { if (!unregisterInvoked) {
@@ -246,7 +247,7 @@ public class RegisterHandler extends MethodHandler
} }
timer = new Timer(getClass().getSimpleName() timer = new Timer(getClass().getSimpleName()
+ " refresh timer"); + " refresh timer");
timer.schedule(new RefreshTimerTask(), delay * 1000); timer.schedule(new RefreshTimerTask(), delay * 1000L);
} }
} }
SipListener sipListener = userAgent.getSipListener(); SipListener sipListener = userAgent.getSipListener();
@@ -266,10 +267,6 @@ public class RegisterHandler extends MethodHandler
//TODO alert user //TODO alert user
} }
public boolean isRegistered() {
return registered;
}
////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////
// TimerTask // TimerTask
////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////
@@ -286,8 +283,4 @@ public class RegisterHandler extends MethodHandler
} }
} }
public void setInitialRequestManager(InitialRequestManager initialRequestManager) {
this.initialRequestManager = initialRequestManager;
}
} }