java-bells/src/com/xonami/javaBells/JinglePacketHandler.java at 6cd84a6a1a3a57f267fdd8d75d532e41ed1102f1 · bejayoharen/java-bells · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
package com.xonami.javaBells;

import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

import net.java.sip.communicator.impl.protocol.jabber.extensions.jingle.JingleIQ;

import net.java.sip.communicator.impl.protocol.jabber.extensions.jingle.JinglePacketFactory;
import net.java.sip.communicator.impl.protocol.jabber.extensions.jingle.Reason;
import org.jivesoftware.smack.PacketListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.filter.PacketFilter;
import org.jivesoftware.smack.packet.Packet;

/**
 * Processes incoming jingle packets on a given connection.
 * Creates new jingleSessions as needed and passes the JingleIQ to them
 * based on their action.
 *
 * @author bjorn
 *
 */
public class JinglePacketHandler implements PacketListener, PacketFilter {
//	private final Map<String,JingleSession> jingleSessions = new ConcurrentHashMap<String,JingleSession>();
    private volatile JingleSession jingleSession;
    private volatile String sid;
    private volatile String jid;
	protected final XMPPConnection connection;

	public JinglePacketHandler( XMPPConnection connection ) {
		this.connection = connection;
		connection.addPacketListener( this, this );
	}

	@Override
	public void processPacket(Packet packet) {
		JingleIQ jiq = (JingleIQ) packet;

		String sid = jiq.getSID();
//		JingleSession js = jingleSessions.get(sid);
		if( jingleSession == null ) {
            createSession(jiq, sid);
//			jingleSessions.put( sid, js );
        } else if (!jingleSession.getSessionId().equals(sid)) {
            JingleIQ sessionTerminate = JinglePacketFactory
                    .createSessionTerminate(this.jid, jiq.getFrom(), this.sid, Reason.GONE,
                            "New session request from " + jiq.getFrom());
            connection.sendPacket(sessionTerminate);
            destroySession();
            createSession(jiq, sid);
        }
        JingleSession js = jingleSession;
		switch( jiq.getAction() ) {
		case CONTENT_ACCEPT:
			js.handleContentAcept( jiq );
			break;
		case CONTENT_ADD:
			js.handleContentAdd( jiq );
			break;
		case CONTENT_MODIFY:
			js.handleContentModify( jiq );
			break;
		case CONTENT_REJECT:
			js.handleContentReject( jiq );
			break;
		case CONTENT_REMOVE:
			js.handleContentRemove( jiq );
			break;
		case DESCRIPTION_INFO:
			js.handleDescriptionInfo( jiq );
			break;
		case SECURITY_INFO:
			js.handleSecurityInfo( jiq );
			break;
		case SESSION_ACCEPT:
			js.handleSessionAccept( jiq );
			break;
		case SESSION_INFO:
			js.handleSessionInfo( jiq );
			break;
		case SESSION_INITIATE:
			js.handleSessionInitiate( jiq );
			break;
		case SESSION_TERMINATE:
			js.handleSessionTerminate( jiq );
			break;
		case TRANSPORT_ACCEPT:
			js.handleTransportAccept( jiq );
			break;
		case TRANSPORT_INFO:
			js.handleTransportInfo( jiq );
			break;
		case TRANSPORT_REJECT:
			js.handleTransportReject( jiq );
			break;
		case TRANSPORT_REPLACE:
			js.handleSessionReplace( jiq );
			break;
		}
	}

    private void destroySession() {
        jingleSession.handleSessionTerminate(null);
    }

    private void createSession(final JingleIQ jiq, final String sid) {
        jingleSession = createJingleSession( sid, jiq );
        this.sid = sid;
        this.jid = jiq.getTo();
    }

    public JingleSession removeJingleSession( JingleSession session ) {
        JingleSession ret = null;
        if (jingleSession == session) {
            ret = jingleSession;
            jingleSession = null;
            this.sid = null;
            this.jid = null;
        }
        return ret;
	}

	/**
	 * Override this to create JingleSessions the way you want. If you do not
	 * Override this, a DefaultJingleSession Object will be returned.
	 *
	 * @param sid
	 * @param jiq
	 */
	public JingleSession createJingleSession( String sid, JingleIQ jiq ) {
		return new DefaultJingleSession(this, sid, connection);
	}

	/**
	 * Only handle Jingle packets.
	 */
	@Override
	public boolean accept(Packet packet) {
		return packet.getClass() == JingleIQ.class;
	}

    public Collection<JingleSession> getSessions(){
        return new HashSet<JingleSession>(Arrays.asList(jingleSession));
    }
}