123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432 |
- /*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
- package model;
-
- import gov.nist.javax.sip.DialogTimeoutEvent;
- import gov.nist.javax.sip.SipListenerExt;
- import gui.Hauptfenster;
- import java.net.InetAddress;
- import java.security.SecureRandom;
- import java.text.ParseException;
- import java.util.*;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- import javax.sip.DialogTerminatedEvent;
- import javax.sip.IOExceptionEvent;
- import javax.sip.InvalidArgumentException;
- import javax.sip.ListeningPoint;
- import javax.sip.RequestEvent;
- import javax.sip.ResponseEvent;
- import javax.sip.SipException;
- import javax.sip.SipFactory;
- import javax.sip.SipProvider;
- import javax.sip.SipStack;
- import javax.sip.TimeoutEvent;
- import javax.sip.TransactionTerminatedEvent;
- import javax.sip.address.*;
- import javax.sip.header.*;
- import javax.sip.message.*;
- import logger.OhmLogger;
-
- /**
- *
- * @author Jan komplettes Model für SIPmodel evtl. Vererbung und für jeden SIP
- * Response/Request eigene Klasse oder Interface da es langsam unübersichtlich
- * wird :( ACK schicken muss noch ergänzt werden BYE muss noch ergänzt werden.
- */
- public class SIPmodel implements SipListenerExt
- {
- private static final String TEST = "0123456789abcdefghijklmnopqrstuvwxyz";//für Random String
- private static final SecureRandom RANDOM = new SecureRandom(); //für Random String
-
- Hauptfenster view; //später entfernen wegen Zugriff
- public static final Logger lg = OhmLogger.getLogger();
- public SipFactory sipFactory; // Used to access the SIP API.
- public SipStack sipStack; // The SIP stack.
- public SipProvider sipProvider; // Used to send SIP messages.
- public MessageFactory messageFactory; // Used to create SIP message factory.
- public HeaderFactory headerFactory; // Used to create SIP headers.
- public AddressFactory addressFactory; // Used to create SIP URIs.
- public ListeningPoint listeningPoint; // SIP listening IP address/port.
- public Properties properties; // Other properties.
-
- private int myPort = 5060;
- private String myName = "129";
- public String protocolTyp = "UDP";
- public String myIPAddress;
- public String proxyAddress;
- public CallIdHeader callID;
-
- Boolean anrufer; //Hilfsvariable ob ich selbst anrufer bin
- Boolean anrufAngenommen;
- Boolean anrufCancel;
- //Hilfsvariablen wenn ich angerufen werde. evtl. noch optimieren
- Boolean werdeAngerufen;
-
- private long cSequenz;
- private String proxyTag;
- private String myTag;
- private String branch;
- private String line;
- private Address contactAddress;
- private ContactHeader contactHeader;
-
- public SIPmodel(Hauptfenster view) //Konstruktor für eigene Daten
- {
- this.view = view;
- anrufer = false;
- anrufAngenommen = false;
- anrufCancel = false;
- proxyAddress = "";
- proxyTag = "";
- line = "";
- cSequenz = 1;
- werdeAngerufen = false;
-
- myTag = createString(8); //erzeugt Random Tag mit Länge 8
- branch = createString(18);//erzeugt Random branch mit Länge 18
-
- try
- {
- //wird an sich erstmal nicht gebraucht aber später sinnvoll um eigene Daten zu initialisieren
- this.myIPAddress = InetAddress.getLocalHost().getHostAddress();
- this.sipFactory = SipFactory.getInstance();
- this.sipFactory.setPathName("gov.nist");
- this.properties = new Properties();
- this.properties.setProperty("javax.sip.STACK_NAME", "stack");
- this.sipStack = this.sipFactory.createSipStack(this.properties);
- this.messageFactory = this.sipFactory.createMessageFactory();
- this.headerFactory = this.sipFactory.createHeaderFactory();
- this.addressFactory = this.sipFactory.createAddressFactory();
- this.listeningPoint = this.sipStack.createListeningPoint(this.myIPAddress, this.myPort, this.protocolTyp);
- this.sipProvider = this.sipStack.createSipProvider(this.listeningPoint);
- this.sipProvider.addSipListener(this);
- this.contactAddress = this.addressFactory.createAddress("sip:" + this.myName + "@" + this.myIPAddress + ":" + this.myPort);
- this.contactHeader = this.headerFactory.createContactHeader(contactAddress);
- }
- catch (Exception e)
- {
- System.out.println("Fehler bei Initialisierung eigener Addresse");
- System.exit(-1);
- }
- }
-
- private String createString(int anzahl)
- {
- StringBuilder sb = new StringBuilder();
- for (int i = 0; i < anzahl; i++)
- {
- sb.append(TEST.charAt(RANDOM.nextInt(TEST.length())));
- }
- return sb.toString();
- }
-
- public void sendRegister(String serverIP, int serverPort) throws ParseException, InvalidArgumentException, SipException
- {
- proxyAddress = serverIP + ":" + serverPort;
- SIPRegister register = new SIPRegister(proxyAddress, myTag, myIPAddress, myPort, branch, addressFactory, headerFactory, messageFactory, contactHeader, sipProvider.getNewCallId());
- this.sipProvider.sendRequest(register.getRequest());
- lg.info("Erfolgreiches Senden der Registrierung");
- }
-
- public void sendInvitation(String sipaddresse, String proxyaddresse,
- int serverPort) throws SipException
- { //ServerPort wird nicht verwendet?
- resetCallParameter();
- anrufer = true;
- callID = this.sipProvider.getNewCallId();
- SIPSessionDescription sdp = new SIPSessionDescription(myName, myIPAddress, null, anrufer);
- SIPInvite sipinvite = new SIPInvite(sipaddresse, proxyaddresse, myIPAddress, myPort, myTag, branch, callID, cSequenz, addressFactory, sdp.getSessionDescription(), headerFactory, messageFactory, contactHeader);
- this.sipProvider.sendRequest(sipinvite.getInviterequest());
- lg.info("Erfolgreiches Senden der Invitation");
- }
-
- @Override
- public void processRequest(RequestEvent requestEvent)
- {
- lg.info("Bekomme Anfrage");
- if ((Request.OPTIONS).equals(requestEvent.getRequest().getMethod())) //Options Anfrage von Server nach erfolgreicher Registrierung
- {
- lg.info("Option Request von Server, erstellen 200 OK zu Server");
- try
- {
- SIP200Ok tempOk = new SIP200Ok(messageFactory, requestEvent, contactHeader, headerFactory);
- this.sipProvider.sendResponse(tempOk.getResponse());
- view.getTxtArea().append("Server Option Request erfolgreich beantwortet\n");
- lg.info("Erfolgreiches senden des 200Ok-Headers");
- }
- catch (SipException ex)
- {
- lg.getLogger(SIPmodel.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- //Aktive Kommunikation
- else if ((Request.INVITE).equals(requestEvent.getRequest().getMethod())) // Invite von anderem Benutzer
- {
- resetCallParameter();
- anrufer = false;
- //Falls Anruf ankommt, wichtige Variablen Zwischenspeichern (Branch, Cseq, CallID, proxyTag)
- branch = ((ViaHeader) requestEvent.getRequest().getHeader("Via")).getBranch();
- cSequenz = ((CSeqHeader) requestEvent.getRequest().getHeader("Cseq")).getSeqNumber();
- proxyTag = ((FromHeader) requestEvent.getRequest().getHeader("From")).getTag();
- callID = ((CallIdHeader) requestEvent.getRequest().getHeader("CallID"));
- //Standartabfolge sobald man angerufen wird
- try
- {
- //Trying Response erzeugen und abschicken
- SIP100Trying tempTrying = new SIP100Trying(messageFactory, requestEvent, headerFactory);
- sipProvider.sendResponse(tempTrying.getTryResponse());
- view.getTxtArea().append("Trying geschickt\n");
- lg.info("Trying ist raus");
-
- //Ringing Response erzeugen und abschicken noch Schleife mit "Anruf annehmen"
- SIP180Ringing tempRinging = new SIP180Ringing(requestEvent, myTag, contactHeader, headerFactory, messageFactory);
- Timer timer = new Timer();
- timer.scheduleAtFixedRate(new TimerTask()
- {
- @Override
- public void run()
- {
- try
- {
- if (anrufAngenommen != true)
- {
- sipProvider.sendResponse(tempRinging.getResponseRing());
- }
- else if(anrufAngenommen==true)
- {
- SIP200Ok respcall = new SIP200Ok(messageFactory, requestEvent, contactHeader, headerFactory);
- SIPSessionDescription sdp = new SIPSessionDescription(myName, myIPAddress, requestEvent, anrufer);
- respcall.addSDP(sdp.getSessionDescription(), myTag);
- sipProvider.sendResponse(respcall.getResponse());
- view.getTxtArea().append("Telefonat beginnt\n");
- timer.cancel();
- }
- }
- catch (SipException ex)
- {
-
- }
- }
- }, 0, 1000);
- }
- catch (SipException ex)
- {
- lg.getLogger(SIPmodel.class.getName()).log(Level.SEVERE, null, ex);
- }
-
- }
- else if ((Request.ACK).equals(requestEvent.getRequest().getMethod()))
- {
-
- }
- else if ((Request.CANCEL).equals(requestEvent.getRequest().getMethod()))
- {
- view.getTxtArea().append("Anruf wurde gecancelt");
- try
- {
- //Cancel Request -> Response 200 Ok + Response 487 Request Terminated
- //200 Ok
- anrufCancel = true;
- SIP200Ok tempOk = new SIP200Ok(messageFactory, requestEvent, contactHeader, headerFactory);
- this.sipProvider.sendResponse(tempOk.getResponse());
- view.getTxtArea().append("Anrufender canceld Anfrage\n");
- lg.info("Erfolgreiches senden des 200 OkHeaders auf CancelAnfrage");
- //487 Request Terminated
- }
- catch (SipException ex)
- {
- Logger.getLogger(SIPmodel.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- else if ((Request.BYE).equals(requestEvent.getRequest().getMethod()))
- {
- try
- {
- SIP200Ok tempOk = new SIP200Ok(messageFactory, requestEvent, contactHeader, headerFactory);
- this.sipProvider.sendResponse(tempOk.getResponse());
- }
- catch (SipException ex)
- {
- Logger.getLogger(SIPmodel.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- }
-
- @Override
- public void processResponse(ResponseEvent responseEvent)
- {
- if (responseEvent.getResponse().getStatusCode() == Response.UNAUTHORIZED)
- {
- try
- {
- cSequenz += 1L;
- branch += 10;
- SIPUnauthReq req2 = new SIPUnauthReq(myName, proxyAddress, myTag, myIPAddress, branch, cSequenz, myPort, contactHeader, addressFactory, headerFactory, responseEvent, messageFactory);
- sipProvider.sendRequest(req2.getUnauthReq());
- view.getTxtArea().append("Erfolgreich registriert\n");
- }
- catch (SipException ex)
- {
- lg.getLogger(SIPmodel.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- else if (responseEvent.getResponse().getStatusCode() == Response.OK)
- {
- lg.info("Erfolgreichen Response (200 OK) bekommen");
- }
- else if (responseEvent.getResponse().getStatusCode() == Response.RINGING)
- {
- ToHeader temp = (ToHeader) responseEvent.getResponse().getHeader("To");
- proxyTag = temp.getTag();
- }
-
- }
-
- public void byecall(String calluser) throws ParseException, InvalidArgumentException, SipException
- {
- Address addressLine = this.addressFactory.createAddress("sip:" + calluser + "@" + proxyAddress);
- URI requestURI = addressLine.getURI();
-
- Address addressfrom = this.addressFactory.createAddress("sip:" + myName + "@" + myIPAddress);
- FromHeader from = this.headerFactory.createFromHeader(addressfrom, String.valueOf(this.myTag));
-
- Address addressTo = this.addressFactory.createAddress("sip:" + myName + "@" + proxyAddress);
- ToHeader to = this.headerFactory.createToHeader(addressTo, proxyTag); // Ergänzung TAG!!
-
- ArrayList via = new ArrayList(); //Via needs a List as input
- ViaHeader viaheader = this.headerFactory.createViaHeader(this.myIPAddress, this.myPort, "UDP", String.valueOf(branch));
- via.add(viaheader);
-
- cSequenz++;
- CSeqHeader cSeq = this.headerFactory.createCSeqHeader(cSequenz, "BYE");
- MaxForwardsHeader maxForwards = this.headerFactory.createMaxForwardsHeader(70);
- AllowHeader allow = this.headerFactory.createAllowHeader("NOTIFY,INVITE,ACK,CANCEL,BYE,REFER,INFO,OPTIONS,MESSAGE");
- ExpiresHeader expire = this.headerFactory.createExpiresHeader(3600); //int value
- Request request = this.messageFactory.createRequest(requestURI, "BYE", callID, cSeq, from, to, via, maxForwards);
- request.addHeader(contactHeader);
- request.addHeader(allow);
- request.addHeader(expire);
- this.sipProvider.sendRequest(request);
- lg.info("Erfolgreiches Senden des BYE Headers");
- }
-
- public void resetCallParameter()
- {
- anrufAngenommen = false;
- anrufer = false;
- }
-
- public void anrufAnnehmen()
- {
- anrufAngenommen = true;
- }
-
- //Get Methoden falls man mal die Parameter braucht
- public String getmyName()
- {
- return myName;
- }
-
- public Integer getMyPort()
- {
- return myPort;
- }
-
- public String getMyIPAdress()
- {
- return myIPAddress;
- }
-
- // Herausfinden bei welchen Events die unteren Funktionen aufgerufen werden -> evtl brauchbar
- @Override
- public void processTimeout(TimeoutEvent timeoutEvent)
- {
- //view.getTxtArea().append("processTimeout\n");
- }
-
- @Override
- public void processIOException(IOExceptionEvent exceptionEvent)
- {
- //view.getTxtArea().append("processIOException\n");
- }
-
- @Override
- public void processTransactionTerminated(
- TransactionTerminatedEvent transactionTerminatedEvent)
- {
- //view.getTxtArea().append("processTransactionTerminated\n");
- }
-
- @Override
- public void processDialogTerminated(
- DialogTerminatedEvent dialogTerminatedEvent)
- {
- //view.getTxtArea().append("processDialogTerminated\n");
- }
-
- @Override
- public void processDialogTimeout(DialogTimeoutEvent timeoutEvent)
- {
- //view.getTxtArea().append("processDialogTerminated\n");
- }
-
- /**
- * @param myPort the myPort to set
- */
- public void setMyPort(int myPort)
- {
- this.myPort = myPort;
- }
-
- /**
- * @return the myName
- */
- public String getMyName()
- {
- return myName;
- }
-
- /**
- * @return the proxyTag
- */
- public String getProxyTag()
- {
- return proxyTag;
- }
-
- /**
- * @param proxyTag the proxyTag to set
- */
- public void setProxyTag(String proxyTag)
- {
- this.proxyTag = proxyTag;
- }
-
- /**
- * @return the myTag
- */
- public String getMyTag()
- {
- return myTag;
- }
-
- /**
- * @param myTag the myTag to set
- */
- public void setMyTag(String myTag)
- {
- this.myTag = myTag;
- }
-
- /**
- * @return the branch
- */
- public String getBranch()
- {
- return branch;
- }
- }
|