mirror of
https://github.com/vanitasvitae/Smack.git
synced 2024-11-26 14:02:06 +01:00
Compare commits
No commits in common. "926c5892ad985b9fe5ef11104effa7400226304e" and "f0300dc906089564d57135f791c4e4900cfe224d" have entirely different histories.
926c5892ad
...
f0300dc906
26 changed files with 115 additions and 1031 deletions
|
@ -650,16 +650,13 @@ def getGitCommit() {
|
||||||
def dotGit = new File("$projectDir/.git")
|
def dotGit = new File("$projectDir/.git")
|
||||||
if (!dotGit.isDirectory()) return 'non-git build'
|
if (!dotGit.isDirectory()) return 'non-git build'
|
||||||
|
|
||||||
def projectDir = dotGit.getParentFile()
|
|
||||||
def cmd = 'git describe --always --tags --dirty=+'
|
def cmd = 'git describe --always --tags --dirty=+'
|
||||||
def proc = cmd.execute(null, projectDir)
|
def proc = cmd.execute()
|
||||||
proc.waitForOrKill(10 * 1000)
|
|
||||||
|
|
||||||
def gitCommit = proc.text.trim()
|
def gitCommit = proc.text.trim()
|
||||||
assert !gitCommit.isEmpty()
|
assert !gitCommit.isEmpty()
|
||||||
|
|
||||||
def srCmd = 'git symbolic-ref --short HEAD'
|
def srCmd = 'git symbolic-ref --short HEAD'
|
||||||
def srProc = srCmd.execute(null, projectDir)
|
def srProc = srCmd.execute()
|
||||||
srProc.waitForOrKill(10 * 1000)
|
srProc.waitForOrKill(10 * 1000)
|
||||||
if (srProc.exitValue() == 0) {
|
if (srProc.exitValue() == 0) {
|
||||||
// Only add the information if the git command was
|
// Only add the information if the git command was
|
||||||
|
|
|
@ -56,7 +56,6 @@ Smack Extensions and currently supported XEPs of smack-extensions
|
||||||
| [SI File Transfer](filetransfer.md) | [XEP-0096](https://xmpp.org/extensions/xep-0096.html) | n/a | Transfer files between two users over XMPP. |
|
| [SI File Transfer](filetransfer.md) | [XEP-0096](https://xmpp.org/extensions/xep-0096.html) | n/a | Transfer files between two users over XMPP. |
|
||||||
| User Mood | [XEP-0107](https://xmpp.org/extensions/xep-0107.html) | 1.2.1 | Communicate the users current mood. |
|
| User Mood | [XEP-0107](https://xmpp.org/extensions/xep-0107.html) | 1.2.1 | Communicate the users current mood. |
|
||||||
| [Entity Capabilities](caps.md) | [XEP-0115](https://xmpp.org/extensions/xep-0115.html) | n/a | Broadcasting and dynamic discovery of entity capabilities. |
|
| [Entity Capabilities](caps.md) | [XEP-0115](https://xmpp.org/extensions/xep-0115.html) | n/a | Broadcasting and dynamic discovery of entity capabilities. |
|
||||||
| User Tune | [XEP-0118](https://xmpp.org/extensions/xep-0118.html) | n/a | Defines a payload format for communicating information about music to which a user is listening. |
|
|
||||||
| Data Forms Validation | [XEP-0122](https://xmpp.org/extensions/xep-0122.html) | n/a | Enables an application to specify additional validation guidelines . |
|
| Data Forms Validation | [XEP-0122](https://xmpp.org/extensions/xep-0122.html) | n/a | Enables an application to specify additional validation guidelines . |
|
||||||
| Service Administration | [XEP-0133](https://xmpp.org/extensions/xep-0133.html) | n/a | Recommended best practices for service-level administration of servers and components using Ad-Hoc Commands. |
|
| Service Administration | [XEP-0133](https://xmpp.org/extensions/xep-0133.html) | n/a | Recommended best practices for service-level administration of servers and components using Ad-Hoc Commands. |
|
||||||
| Stream Compression | [XEP-0138](https://xmpp.org/extensions/xep-0138.html) | n/a | Support for optional compression of the XMPP stream.
|
| Stream Compression | [XEP-0138](https://xmpp.org/extensions/xep-0138.html) | n/a | Support for optional compression of the XMPP stream.
|
||||||
|
|
|
@ -204,25 +204,25 @@ public class SmackReactor {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
ScheduledAction nextScheduledAction = scheduledActions.peek();
|
||||||
|
|
||||||
|
long selectWait;
|
||||||
|
if (nextScheduledAction == null) {
|
||||||
|
// There is no next scheduled action, wait indefinitely in select() or until another thread invokes
|
||||||
|
// selector.wakeup().
|
||||||
|
selectWait = 0;
|
||||||
|
} else {
|
||||||
|
selectWait = nextScheduledAction.getTimeToDueMillis();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (selectWait < 0) {
|
||||||
|
// A scheduled action was just released and become ready to execute.
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
int newSelectedKeysCount = 0;
|
int newSelectedKeysCount = 0;
|
||||||
List<SelectionKey> selectedKeys;
|
List<SelectionKey> selectedKeys;
|
||||||
synchronized (selector) {
|
synchronized (selector) {
|
||||||
ScheduledAction nextScheduledAction = scheduledActions.peek();
|
|
||||||
|
|
||||||
long selectWait;
|
|
||||||
if (nextScheduledAction == null) {
|
|
||||||
// There is no next scheduled action, wait indefinitely in select() or until another thread invokes
|
|
||||||
// selector.wakeup().
|
|
||||||
selectWait = 0;
|
|
||||||
} else {
|
|
||||||
selectWait = nextScheduledAction.getTimeToDueMillis();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (selectWait < 0) {
|
|
||||||
// A scheduled action was just released and became ready to execute.
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Before we call select, we handle the pending the interest Ops. This will not block since no other
|
// Before we call select, we handle the pending the interest Ops. This will not block since no other
|
||||||
// thread is currently in select() at this time.
|
// thread is currently in select() at this time.
|
||||||
// Note: This was put deliberately before the registration lock. It may cause more synchronization but
|
// Note: This was put deliberately before the registration lock. It may cause more synchronization but
|
||||||
|
|
|
@ -54,29 +54,13 @@ public abstract class Scalar extends java.lang.Number {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public abstract int hashCode();
|
public final int hashCode() {
|
||||||
|
return number.hashCode();
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object other) {
|
public final boolean equals(Object other) {
|
||||||
if (!(other instanceof Scalar)) {
|
return number.equals(other);
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
Scalar otherScalar = (Scalar) other;
|
|
||||||
|
|
||||||
if (longValue() == otherScalar.longValue()) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (doubleValue() == otherScalar.doubleValue()) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (floatValue() == otherScalar.floatValue()) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -39,19 +39,4 @@ public final class UInt16 extends Scalar {
|
||||||
public static UInt16 from(int number) {
|
public static UInt16 from(int number) {
|
||||||
return new UInt16(number);
|
return new UInt16(number);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public int hashCode() {
|
|
||||||
return number;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean equals(Object other) {
|
|
||||||
if (other instanceof UInt16) {
|
|
||||||
UInt16 otherUint16 = (UInt16) other;
|
|
||||||
return number == otherUint16.number;
|
|
||||||
}
|
|
||||||
|
|
||||||
return super.equals(other);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -39,20 +39,4 @@ public final class UInt32 extends Scalar {
|
||||||
public static UInt32 from(long number) {
|
public static UInt32 from(long number) {
|
||||||
return new UInt32(number);
|
return new UInt32(number);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public int hashCode() {
|
|
||||||
// TODO: Use Long.hashCode(number) once Smack's minimum Android SDK level is 24 or higher.
|
|
||||||
return (int) (number ^ (number >>> 32));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean equals(Object other) {
|
|
||||||
if (other instanceof UInt32) {
|
|
||||||
UInt32 otherUint32 = (UInt32) other;
|
|
||||||
return number == otherUint32.number;
|
|
||||||
}
|
|
||||||
|
|
||||||
return super.equals(other);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -31,6 +31,8 @@ import org.jivesoftware.smack.util.PacketUtil;
|
||||||
import org.jivesoftware.smack.util.XmlStringBuilder;
|
import org.jivesoftware.smack.util.XmlStringBuilder;
|
||||||
|
|
||||||
import org.jxmpp.jid.Jid;
|
import org.jxmpp.jid.Jid;
|
||||||
|
import org.jxmpp.jid.impl.JidCreate;
|
||||||
|
import org.jxmpp.stringprep.XmppStringprepException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Base class for XMPP Stanzas, which are called Stanza in older versions of Smack (i.e. < 4.1).
|
* Base class for XMPP Stanzas, which are called Stanza in older versions of Smack (i.e. < 4.1).
|
||||||
|
@ -45,7 +47,6 @@ import org.jxmpp.jid.Jid;
|
||||||
* </p>
|
* </p>
|
||||||
*
|
*
|
||||||
* @author Matt Tucker
|
* @author Matt Tucker
|
||||||
* @author Florian Schmaus
|
|
||||||
* @see <a href="http://xmpp.org/rfcs/rfc6120.html#stanzas">RFC 6120 § 8. XML Stanzas</a>
|
* @see <a href="http://xmpp.org/rfcs/rfc6120.html#stanzas">RFC 6120 § 8. XML Stanzas</a>
|
||||||
*/
|
*/
|
||||||
public abstract class Stanza implements TopLevelStreamElement {
|
public abstract class Stanza implements TopLevelStreamElement {
|
||||||
|
@ -108,6 +109,16 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
return id;
|
return id;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the Stanza ID.
|
||||||
|
* @return the stanza id.
|
||||||
|
* @deprecated use {@link #getStanzaId()} instead.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public String getPacketID() {
|
||||||
|
return getStanzaId();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets the unique ID of the packet. To indicate that a stanza has no id
|
* Sets the unique ID of the packet. To indicate that a stanza has no id
|
||||||
* pass <code>null</code> as the packet's id value.
|
* pass <code>null</code> as the packet's id value.
|
||||||
|
@ -121,6 +132,16 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
this.id = id;
|
this.id = id;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Set the stanza ID.
|
||||||
|
* @param packetID TODO javadoc me please
|
||||||
|
* @deprecated use {@link #setStanzaId(String)} instead.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public void setPacketID(String packetID) {
|
||||||
|
setStanzaId(packetID);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Check if this stanza has an ID set.
|
* Check if this stanza has an ID set.
|
||||||
*
|
*
|
||||||
|
@ -138,43 +159,9 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
*
|
*
|
||||||
* @return the stanza id.
|
* @return the stanza id.
|
||||||
* @since 4.2
|
* @since 4.2
|
||||||
* @deprecated use {@link #setNewStanzaId()} instead.
|
|
||||||
*/
|
*/
|
||||||
@Deprecated
|
|
||||||
// TODO: Remove in Smack 4.5.
|
|
||||||
public String setStanzaId() {
|
public String setStanzaId() {
|
||||||
return ensureStanzaIdSet();
|
if (!hasStanzaIdSet()) {
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Set a new stanza ID even if there is already one set.
|
|
||||||
*
|
|
||||||
* @return the stanza id.
|
|
||||||
* @since 4.4
|
|
||||||
*/
|
|
||||||
public String setNewStanzaId() {
|
|
||||||
return ensureStanzaIdSet(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Ensure a stanza id is set.
|
|
||||||
*
|
|
||||||
* @return the stanza id.
|
|
||||||
* @since 4.4
|
|
||||||
*/
|
|
||||||
public String ensureStanzaIdSet() {
|
|
||||||
return ensureStanzaIdSet(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Ensure that a stanza ID is set.
|
|
||||||
*
|
|
||||||
* @param forceNew force a new ID even if there is already one set.
|
|
||||||
* @return the stanza ID.
|
|
||||||
* @since 4.4
|
|
||||||
*/
|
|
||||||
private String ensureStanzaIdSet(boolean forceNew) {
|
|
||||||
if (forceNew || !hasStanzaIdSet()) {
|
|
||||||
setStanzaId(StanzaIdUtil.newStanzaId());
|
setStanzaId(StanzaIdUtil.newStanzaId());
|
||||||
}
|
}
|
||||||
return getStanzaId();
|
return getStanzaId();
|
||||||
|
@ -192,6 +179,26 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
return to;
|
return to;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets who the stanza is being sent "to". The XMPP protocol often makes
|
||||||
|
* the "to" attribute optional, so it does not always need to be set.
|
||||||
|
*
|
||||||
|
* @param to who the stanza is being sent to.
|
||||||
|
* @throws IllegalArgumentException if to is not a valid JID String.
|
||||||
|
* @deprecated use {@link #setTo(Jid)} instead.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public void setTo(String to) {
|
||||||
|
Jid jid;
|
||||||
|
try {
|
||||||
|
jid = JidCreate.from(to);
|
||||||
|
}
|
||||||
|
catch (XmppStringprepException e) {
|
||||||
|
throw new IllegalArgumentException(e);
|
||||||
|
}
|
||||||
|
setTo(jid);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets who the packet is being sent "to". The XMPP protocol often makes
|
* Sets who the packet is being sent "to". The XMPP protocol often makes
|
||||||
* the "to" attribute optional, so it does not always need to be set.
|
* the "to" attribute optional, so it does not always need to be set.
|
||||||
|
@ -214,6 +221,27 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
return from;
|
return from;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets who the stanza is being sent "from". The XMPP protocol often
|
||||||
|
* makes the "from" attribute optional, so it does not always need to
|
||||||
|
* be set.
|
||||||
|
*
|
||||||
|
* @param from who the stanza is being sent to.
|
||||||
|
* @throws IllegalArgumentException if from is not a valid JID String.
|
||||||
|
* @deprecated use {@link #setFrom(Jid)} instead.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public void setFrom(String from) {
|
||||||
|
Jid jid;
|
||||||
|
try {
|
||||||
|
jid = JidCreate.from(from);
|
||||||
|
}
|
||||||
|
catch (XmppStringprepException e) {
|
||||||
|
throw new IllegalArgumentException(e);
|
||||||
|
}
|
||||||
|
setFrom(jid);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets who the packet is being sent "from". The XMPP protocol often
|
* Sets who the packet is being sent "from". The XMPP protocol often
|
||||||
* makes the "from" attribute optional, so it does not always need to
|
* makes the "from" attribute optional, so it does not always need to
|
||||||
|
@ -235,6 +263,17 @@ public abstract class Stanza implements TopLevelStreamElement {
|
||||||
return error;
|
return error;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets the error for this packet.
|
||||||
|
*
|
||||||
|
* @param error the error to associate with this packet.
|
||||||
|
* @deprecated use {@link #setError(org.jivesoftware.smack.packet.StanzaError.Builder)} instead.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
public void setError(StanzaError error) {
|
||||||
|
this.error = error;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets the error for this stanza.
|
* Sets the error for this stanza.
|
||||||
*
|
*
|
||||||
|
|
|
@ -43,7 +43,7 @@ public class XmlUnitUtils {
|
||||||
|
|
||||||
NormalizedSource expected = new NormalizedSource(new StreamSource(new StringReader(expectedString)));
|
NormalizedSource expected = new NormalizedSource(new StreamSource(new StringReader(expectedString)));
|
||||||
NormalizedSource actual = new NormalizedSource(new StreamSource(new StringReader(actualString)));
|
NormalizedSource actual = new NormalizedSource(new StreamSource(new StringReader(actualString)));
|
||||||
return XmlAssert.assertThat(actual).and(expected)
|
return XmlAssert.assertThat(expected).and(actual)
|
||||||
.ignoreChildNodesOrder()
|
.ignoreChildNodesOrder()
|
||||||
.withNodeMatcher(new DefaultNodeMatcher(ElementSelectors.byNameAndAllAttributes, ElementSelectors.byNameAndText))
|
.withNodeMatcher(new DefaultNodeMatcher(ElementSelectors.byNameAndAllAttributes, ElementSelectors.byNameAndText))
|
||||||
.normalizeWhitespace();
|
.normalizeWhitespace();
|
||||||
|
|
|
@ -1,47 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Florian Schmaus.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smack.util;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.packet.StandardExtensionElement;
|
|
||||||
import org.jivesoftware.smack.packet.XmlEnvironment;
|
|
||||||
import org.jivesoftware.smack.test.util.XmlUnitUtils;
|
|
||||||
|
|
||||||
import org.junit.jupiter.api.Test;
|
|
||||||
|
|
||||||
public class XmlStringBuilderTest {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Test that {@link XmlStringBuilder} does not omit the second inner namespace declaration.
|
|
||||||
*/
|
|
||||||
@Test
|
|
||||||
public void equalInnerNamespaceTest() {
|
|
||||||
StandardExtensionElement innerOne = StandardExtensionElement.builder("inner", "inner-namespace").build();
|
|
||||||
StandardExtensionElement innerTwo = StandardExtensionElement.builder("inner", "inner-namespace").build();
|
|
||||||
|
|
||||||
StandardExtensionElement outer = StandardExtensionElement.builder("outer", "outer-namespace").addElement(
|
|
||||||
innerOne).addElement(innerTwo).build();
|
|
||||||
|
|
||||||
String expectedXml = "<outer xmlns='outer-namespace'><inner xmlns='inner-namespace'></inner><inner xmlns='inner-namespace'></inner></outer>";
|
|
||||||
XmlStringBuilder actualXml = outer.toXML(XmlEnvironment.EMPTY);
|
|
||||||
|
|
||||||
XmlUnitUtils.assertXmlSimilar(expectedXml, actualXml);
|
|
||||||
|
|
||||||
StringBuilder actualXmlTwo = actualXml.toXML(XmlEnvironment.EMPTY);
|
|
||||||
|
|
||||||
XmlUnitUtils.assertXmlSimilar(expectedXml, actualXmlTwo);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -22,6 +22,7 @@ import org.jivesoftware.smack.packet.ExtensionElement;
|
||||||
import org.jivesoftware.smack.packet.Message;
|
import org.jivesoftware.smack.packet.Message;
|
||||||
import org.jivesoftware.smack.packet.Stanza;
|
import org.jivesoftware.smack.packet.Stanza;
|
||||||
import org.jivesoftware.smack.packet.XmlEnvironment;
|
import org.jivesoftware.smack.packet.XmlEnvironment;
|
||||||
|
import org.jivesoftware.smack.packet.id.StanzaIdUtil;
|
||||||
import org.jivesoftware.smack.provider.ExtensionElementProvider;
|
import org.jivesoftware.smack.provider.ExtensionElementProvider;
|
||||||
import org.jivesoftware.smack.xml.XmlPullParser;
|
import org.jivesoftware.smack.xml.XmlPullParser;
|
||||||
import org.jivesoftware.smack.xml.XmlPullParserException;
|
import org.jivesoftware.smack.xml.XmlPullParserException;
|
||||||
|
@ -82,7 +83,9 @@ public class DeliveryReceiptRequest implements ExtensionElement {
|
||||||
* @return the Message ID which will be used as receipt ID
|
* @return the Message ID which will be used as receipt ID
|
||||||
*/
|
*/
|
||||||
public static String addTo(Message message) {
|
public static String addTo(Message message) {
|
||||||
message.ensureStanzaIdSet();
|
if (message.getStanzaId() == null) {
|
||||||
|
message.setStanzaId(StanzaIdUtil.newStanzaId());
|
||||||
|
}
|
||||||
message.addExtension(new DeliveryReceiptRequest());
|
message.addExtension(new DeliveryReceiptRequest());
|
||||||
return message.getStanzaId();
|
return message.getStanzaId();
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,27 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.packet.Message;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
|
|
||||||
import org.jxmpp.jid.BareJid;
|
|
||||||
|
|
||||||
public interface UserTuneListener {
|
|
||||||
|
|
||||||
void onUserTuneUpdated(BareJid jid, Message message, UserTuneElement userTuneElement);
|
|
||||||
}
|
|
|
@ -1,143 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Set;
|
|
||||||
import java.util.WeakHashMap;
|
|
||||||
import java.util.concurrent.CopyOnWriteArraySet;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.AsyncButOrdered;
|
|
||||||
import org.jivesoftware.smack.Manager;
|
|
||||||
import org.jivesoftware.smack.SmackException.NoResponseException;
|
|
||||||
import org.jivesoftware.smack.SmackException.NotConnectedException;
|
|
||||||
import org.jivesoftware.smack.SmackException.NotLoggedInException;
|
|
||||||
import org.jivesoftware.smack.XMPPConnection;
|
|
||||||
import org.jivesoftware.smack.XMPPException.XMPPErrorException;
|
|
||||||
import org.jivesoftware.smack.packet.ExtensionElement;
|
|
||||||
import org.jivesoftware.smack.packet.Message;
|
|
||||||
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
|
||||||
import org.jivesoftware.smackx.pep.PepListener;
|
|
||||||
import org.jivesoftware.smackx.pep.PepManager;
|
|
||||||
import org.jivesoftware.smackx.pubsub.EventElement;
|
|
||||||
import org.jivesoftware.smackx.pubsub.ItemsExtension;
|
|
||||||
import org.jivesoftware.smackx.pubsub.PayloadItem;
|
|
||||||
import org.jivesoftware.smackx.pubsub.PubSubException.NotALeafNodeException;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
|
|
||||||
import org.jxmpp.jid.BareJid;
|
|
||||||
import org.jxmpp.jid.EntityBareJid;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Entry point for Smacks API for XEP-0118: User Tune.
|
|
||||||
* <br>
|
|
||||||
* To publish a UserTune, please use {@link #publishUserTune(UserTuneElement)} method. This will publish the node.
|
|
||||||
* <br>
|
|
||||||
* To stop publishing a UserTune, please use {@link #clearUserTune()} method. This will send a disabling publish signal.
|
|
||||||
* <br>
|
|
||||||
* To add a UserTune listener in order to remain updated with other users UserTune, use {@link #addUserTuneListener(UserTuneListener)} method.
|
|
||||||
* <br>
|
|
||||||
* To link a UserTuneElement with {@link Message}, use 'message.addExtension(userTuneElement)'.
|
|
||||||
* <br>
|
|
||||||
* An example to illustrate is provided inside UserTuneElementTest inside the test package.
|
|
||||||
* <br>
|
|
||||||
* @see <a href="https://xmpp.org/extensions/xep-0118.html">
|
|
||||||
* XEP-0118: User Tune</a>
|
|
||||||
*/
|
|
||||||
public final class UserTuneManager extends Manager {
|
|
||||||
|
|
||||||
public static final String USERTUNE_NODE = "http://jabber.org/protocol/tune";
|
|
||||||
public static final String USERTUNE_NOTIFY = USERTUNE_NODE + "+notify";
|
|
||||||
|
|
||||||
private static final Map<XMPPConnection, UserTuneManager> INSTANCES = new WeakHashMap<>();
|
|
||||||
|
|
||||||
private static boolean ENABLE_USER_TUNE_NOTIFICATIONS_BY_DEFAULT = true;
|
|
||||||
|
|
||||||
private final Set<UserTuneListener> userTuneListeners = new CopyOnWriteArraySet<>();
|
|
||||||
private final AsyncButOrdered<BareJid> asyncButOrdered = new AsyncButOrdered<>();
|
|
||||||
private final ServiceDiscoveryManager serviceDiscoveryManager;
|
|
||||||
private final PepManager pepManager;
|
|
||||||
|
|
||||||
public static synchronized UserTuneManager getInstanceFor(XMPPConnection connection) throws NotLoggedInException {
|
|
||||||
UserTuneManager manager = INSTANCES.get(connection);
|
|
||||||
if (manager == null) {
|
|
||||||
manager = new UserTuneManager(connection);
|
|
||||||
INSTANCES.put(connection, manager);
|
|
||||||
}
|
|
||||||
return manager;
|
|
||||||
}
|
|
||||||
|
|
||||||
private UserTuneManager(XMPPConnection connection) throws NotLoggedInException {
|
|
||||||
super(connection);
|
|
||||||
pepManager = PepManager.getInstanceFor(connection);
|
|
||||||
pepManager.addPepListener(new PepListener() {
|
|
||||||
@Override
|
|
||||||
public void eventReceived(EntityBareJid from, EventElement event, Message message) {
|
|
||||||
if (!USERTUNE_NODE.equals(event.getEvent().getNode())) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
final BareJid contact = from.asBareJid();
|
|
||||||
asyncButOrdered.performAsyncButOrdered(contact, () -> {
|
|
||||||
ItemsExtension itemsExtension = (ItemsExtension) event.getEvent();
|
|
||||||
List<ExtensionElement> items = itemsExtension.getExtensions();
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
PayloadItem<UserTuneElement> payload = (PayloadItem<UserTuneElement>) items.get(0);
|
|
||||||
UserTuneElement tune = payload.getPayload();
|
|
||||||
|
|
||||||
for (UserTuneListener listener : userTuneListeners) {
|
|
||||||
listener.onUserTuneUpdated(contact, message, tune);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
serviceDiscoveryManager = ServiceDiscoveryManager.getInstanceFor(connection);
|
|
||||||
if (ENABLE_USER_TUNE_NOTIFICATIONS_BY_DEFAULT) {
|
|
||||||
enableUserTuneNotifications();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void setUserTuneNotificationsEnabledByDefault(boolean bool) {
|
|
||||||
ENABLE_USER_TUNE_NOTIFICATIONS_BY_DEFAULT = bool;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void enableUserTuneNotifications() {
|
|
||||||
serviceDiscoveryManager.addFeature(USERTUNE_NOTIFY);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void disableUserTuneNotifications() {
|
|
||||||
serviceDiscoveryManager.removeFeature(USERTUNE_NOTIFY);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void clearUserTune() throws NotLoggedInException, NotALeafNodeException, NoResponseException, NotConnectedException, XMPPErrorException, InterruptedException {
|
|
||||||
publishUserTune(UserTuneElement.EMPTY_USER_TUNE);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void publishUserTune(UserTuneElement userTuneElement) throws NotLoggedInException, NotALeafNodeException, NoResponseException, NotConnectedException, XMPPErrorException, InterruptedException {
|
|
||||||
// TODO: To prevent a large number of updates when a user is skipping through tracks, an implementation SHOULD wait several seconds before publishing new tune information.
|
|
||||||
pepManager.publish(USERTUNE_NODE, new PayloadItem<>(userTuneElement));
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean addUserTuneListener(UserTuneListener listener) {
|
|
||||||
return userTuneListeners.add(listener);
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean removeUserTuneListener(UserTuneListener listener) {
|
|
||||||
return userTuneListeners.remove(listener);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,266 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune.element;
|
|
||||||
|
|
||||||
import java.net.URI;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.datatypes.UInt16;
|
|
||||||
import org.jivesoftware.smack.packet.ExtensionElement;
|
|
||||||
import org.jivesoftware.smack.packet.Message;
|
|
||||||
import org.jivesoftware.smack.packet.XmlEnvironment;
|
|
||||||
import org.jivesoftware.smack.util.EqualsUtil;
|
|
||||||
import org.jivesoftware.smack.util.HashCode;
|
|
||||||
import org.jivesoftware.smack.util.XmlStringBuilder;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* {@link ExtensionElement} that contains the UserTune. <br>
|
|
||||||
* Instance of UserTuneElement can be created using {@link Builder#build()}
|
|
||||||
* method.
|
|
||||||
*/
|
|
||||||
public final class UserTuneElement implements ExtensionElement {
|
|
||||||
|
|
||||||
public static final String NAMESPACE = "http://jabber.org/protocol/tune";
|
|
||||||
public static final String ELEMENT = "tune";
|
|
||||||
|
|
||||||
private final String artist;
|
|
||||||
private final UInt16 length;
|
|
||||||
private final Integer rating;
|
|
||||||
private final String source;
|
|
||||||
private final String title;
|
|
||||||
private final String track;
|
|
||||||
private final URI uri;
|
|
||||||
|
|
||||||
public static final UserTuneElement EMPTY_USER_TUNE = null;
|
|
||||||
|
|
||||||
private UserTuneElement(Builder builder) {
|
|
||||||
this.artist = builder.artist;
|
|
||||||
this.length = builder.length;
|
|
||||||
this.rating = builder.rating;
|
|
||||||
this.source = builder.source;
|
|
||||||
this.title = builder.title;
|
|
||||||
this.track = builder.track;
|
|
||||||
this.uri = builder.uri;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getNamespace() {
|
|
||||||
return NAMESPACE;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getElementName() {
|
|
||||||
return ELEMENT;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getArtist() {
|
|
||||||
return artist;
|
|
||||||
}
|
|
||||||
|
|
||||||
public UInt16 getLength() {
|
|
||||||
return length;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Integer getRating() {
|
|
||||||
return rating;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getSource() {
|
|
||||||
return source;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getTitle() {
|
|
||||||
return title;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getTrack() {
|
|
||||||
return track;
|
|
||||||
}
|
|
||||||
|
|
||||||
public URI getUri() {
|
|
||||||
return uri;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public XmlStringBuilder toXML(XmlEnvironment xmlEnvironment) {
|
|
||||||
XmlStringBuilder xml = new XmlStringBuilder(this);
|
|
||||||
if (isEmptyUserTune()) {
|
|
||||||
return xml.closeEmptyElement();
|
|
||||||
}
|
|
||||||
xml.rightAngleBracket();
|
|
||||||
xml.optElement("artist", artist);
|
|
||||||
xml.optElement("length", length);
|
|
||||||
xml.optElement("rating", rating);
|
|
||||||
xml.optElement("source", source);
|
|
||||||
xml.optElement("title", title);
|
|
||||||
xml.optElement("track", track);
|
|
||||||
xml.optElement("uri", uri);
|
|
||||||
return xml.closeElement(getElementName());
|
|
||||||
}
|
|
||||||
|
|
||||||
private boolean isEmptyUserTune() {
|
|
||||||
return this.equals(EMPTY_USER_TUNE);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static boolean hasUserTuneElement(Message message) {
|
|
||||||
return message.hasExtension(ELEMENT, NAMESPACE);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static UserTuneElement from(Message message) {
|
|
||||||
return message.getExtension(ELEMENT, NAMESPACE);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int hashCode() {
|
|
||||||
return HashCode.builder()
|
|
||||||
.append(artist)
|
|
||||||
.append(length)
|
|
||||||
.append(rating)
|
|
||||||
.append(source)
|
|
||||||
.append(title)
|
|
||||||
.append(track)
|
|
||||||
.append(uri).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean equals(Object obj) {
|
|
||||||
return EqualsUtil
|
|
||||||
.equals(this, obj, (equalsBuilder, otherTune) -> equalsBuilder
|
|
||||||
.append(artist, otherTune.artist)
|
|
||||||
.append(length, otherTune.length)
|
|
||||||
.append(rating, otherTune.rating)
|
|
||||||
.append(source, otherTune.source)
|
|
||||||
.append(title, otherTune.title)
|
|
||||||
.append(track, otherTune.track)
|
|
||||||
.append(uri, otherTune.uri));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns a new instance of {@link Builder}.
|
|
||||||
* @return Builder
|
|
||||||
*/
|
|
||||||
public static Builder getBuilder() {
|
|
||||||
return new Builder();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This class defines a Builder class for {@link UserTuneElement}. <br>
|
|
||||||
* {@link UserTuneElement} instance can be obtained using the {@link #build()} method as follows. <br>
|
|
||||||
* UserTuneElement.Builder builder = new UserTuneElement.Builder();
|
|
||||||
* builder.setSource("Yessongs"); builder.setTitle("Heart of the Sunrise");
|
|
||||||
* UserTuneElement userTuneElement = builder.build(); <br>
|
|
||||||
* Values such as title, source, artist, length, source, track and uri can be set using their respective setters through {@link Builder}
|
|
||||||
*/
|
|
||||||
public static final class Builder {
|
|
||||||
private String artist;
|
|
||||||
private UInt16 length;
|
|
||||||
private Integer rating;
|
|
||||||
private String source;
|
|
||||||
private String title;
|
|
||||||
private String track;
|
|
||||||
private URI uri;
|
|
||||||
|
|
||||||
private Builder() {
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Artist is an optional element in UserTuneElement.
|
|
||||||
* @param artist.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setArtist(String artist) {
|
|
||||||
this.artist = artist;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Length is an optional element in UserTuneElement.
|
|
||||||
* @param length.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setLength(int length) {
|
|
||||||
return setLength(UInt16.from(length));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Length is an optional element in UserTuneElement.
|
|
||||||
* @param length.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setLength(UInt16 length) {
|
|
||||||
this.length = length;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Rating is an optional element in UserTuneElement.
|
|
||||||
* @param rating.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setRating(int rating) {
|
|
||||||
this.rating = rating;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Source is an optional element in UserTuneElement.
|
|
||||||
* @param source.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setSource(String source) {
|
|
||||||
this.source = source;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Title is an optional element in UserTuneElement.
|
|
||||||
* @param title.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setTitle(String title) {
|
|
||||||
this.title = title;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Track is an optional element in UserTuneElement.
|
|
||||||
* @param track.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setTrack(String track) {
|
|
||||||
this.track = track;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* URI is an optional element in UserTuneElement.
|
|
||||||
* @param uri.
|
|
||||||
* @return builder.
|
|
||||||
*/
|
|
||||||
public Builder setUri(URI uri) {
|
|
||||||
this.uri = uri;
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This method is called to build a UserTuneElement.
|
|
||||||
* @return UserTuneElement.
|
|
||||||
*/
|
|
||||||
public UserTuneElement build() {
|
|
||||||
return new UserTuneElement(this);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,21 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Smack's API for <a href="https://xmpp.org/extensions/xep-0118.html"> XEP-0118: User Tune</a>.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune.element;
|
|
|
@ -1,21 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Smack's API for <a href="https://xmpp.org/extensions/xep-0118.html"> XEP-0118: User Tune</a>.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
|
@ -1,89 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune.provider;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.net.URI;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.packet.XmlEnvironment;
|
|
||||||
import org.jivesoftware.smack.parsing.SmackParsingException;
|
|
||||||
import org.jivesoftware.smack.provider.ExtensionElementProvider;
|
|
||||||
import org.jivesoftware.smack.util.ParserUtils;
|
|
||||||
import org.jivesoftware.smack.xml.XmlPullParser;
|
|
||||||
import org.jivesoftware.smack.xml.XmlPullParserException;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This is the Provider Class for {@link UserTuneElement}.
|
|
||||||
*/
|
|
||||||
public class UserTuneProvider extends ExtensionElementProvider<UserTuneElement> {
|
|
||||||
|
|
||||||
public static final UserTuneProvider INSTANCE = new UserTuneProvider();
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public UserTuneElement parse(XmlPullParser parser, int initialDepth, XmlEnvironment xmlEnvironment)
|
|
||||||
throws XmlPullParserException, IOException, SmackParsingException {
|
|
||||||
|
|
||||||
UserTuneElement.Builder builder = UserTuneElement.getBuilder();
|
|
||||||
XmlPullParser.TagEvent tag = parser.nextTag();
|
|
||||||
outerloop: while (true) {
|
|
||||||
switch (tag) {
|
|
||||||
case START_ELEMENT:
|
|
||||||
String name = parser.getName();
|
|
||||||
String namespace = parser.getNamespace();
|
|
||||||
if (!UserTuneElement.NAMESPACE.equals(namespace)) {
|
|
||||||
continue outerloop;
|
|
||||||
}
|
|
||||||
while (tag == XmlPullParser.TagEvent.START_ELEMENT) {
|
|
||||||
switch (name) {
|
|
||||||
case "artist":
|
|
||||||
builder.setArtist(parser.nextText());
|
|
||||||
break;
|
|
||||||
case "length":
|
|
||||||
builder.setLength(ParserUtils.getIntegerFromNextText(parser));
|
|
||||||
break;
|
|
||||||
case "rating":
|
|
||||||
builder.setRating(ParserUtils.getIntegerFromNextText(parser));
|
|
||||||
break;
|
|
||||||
case "source":
|
|
||||||
builder.setSource(parser.nextText());
|
|
||||||
break;
|
|
||||||
case "title":
|
|
||||||
builder.setTitle(parser.nextText());
|
|
||||||
break;
|
|
||||||
case "track":
|
|
||||||
builder.setTrack(parser.nextText());
|
|
||||||
break;
|
|
||||||
case "uri":
|
|
||||||
URI uri = ParserUtils.getUriFromNextText(parser);
|
|
||||||
builder.setUri(uri);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
tag = parser.nextTag();
|
|
||||||
name = parser.getName();
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case END_ELEMENT:
|
|
||||||
if (parser.getDepth() == initialDepth) {
|
|
||||||
break outerloop;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return builder.build();
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,21 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Smack's API for <a href="https://xmpp.org/extensions/xep-0118.html"> XEP-0118: User Tune</a>.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune.provider;
|
|
|
@ -1,6 +1,6 @@
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* Copyright 2014-2019 Florian Schmaus
|
* Copyright 2014 Florian Schmaus
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -27,6 +27,7 @@ import org.jivesoftware.smack.XMPPConnection;
|
||||||
import org.jivesoftware.smack.XMPPConnectionRegistry;
|
import org.jivesoftware.smack.XMPPConnectionRegistry;
|
||||||
import org.jivesoftware.smack.XMPPException.XMPPErrorException;
|
import org.jivesoftware.smack.XMPPException.XMPPErrorException;
|
||||||
import org.jivesoftware.smack.packet.IQ;
|
import org.jivesoftware.smack.packet.IQ;
|
||||||
|
import org.jivesoftware.smack.packet.id.StanzaIdUtil;
|
||||||
|
|
||||||
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
||||||
import org.jivesoftware.smackx.vcardtemp.packet.VCard;
|
import org.jivesoftware.smackx.vcardtemp.packet.VCard;
|
||||||
|
@ -104,7 +105,7 @@ public final class VCardManager extends Manager {
|
||||||
vcard.setType(IQ.Type.set);
|
vcard.setType(IQ.Type.set);
|
||||||
// Also make sure to generate a new stanza id (the given vcard could be a vcard result), in which case we don't
|
// Also make sure to generate a new stanza id (the given vcard could be a vcard result), in which case we don't
|
||||||
// want to use the same stanza id again (although it wouldn't break if we did)
|
// want to use the same stanza id again (although it wouldn't break if we did)
|
||||||
vcard.setNewStanzaId();
|
vcard.setStanzaId(StanzaIdUtil.newStanzaId());
|
||||||
connection().createStanzaCollectorAndSend(vcard).nextResultOrThrow();
|
connection().createStanzaCollectorAndSend(vcard).nextResultOrThrow();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -589,11 +589,4 @@
|
||||||
<className>org.jivesoftware.smackx.mood.provider.MoodProvider</className>
|
<className>org.jivesoftware.smackx.mood.provider.MoodProvider</className>
|
||||||
</extensionProvider>
|
</extensionProvider>
|
||||||
|
|
||||||
<!-- XEP-0118: User Tune -->
|
|
||||||
<extensionProvider>
|
|
||||||
<elementName>tune</elementName>
|
|
||||||
<namespace>http://jabber.org/protocol/tune</namespace>
|
|
||||||
<className>org.jivesoftware.smackx.usertune.provider.UserTuneProvider</className>
|
|
||||||
</extensionProvider>
|
|
||||||
|
|
||||||
</smackProviders>
|
</smackProviders>
|
||||||
|
|
|
@ -1,74 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
||||||
|
|
||||||
import static org.jivesoftware.smack.test.util.XmlUnitUtils.assertXmlSimilar;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.net.URI;
|
|
||||||
import java.net.URISyntaxException;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.parsing.SmackParsingException;
|
|
||||||
import org.jivesoftware.smack.test.util.SmackTestSuite;
|
|
||||||
import org.jivesoftware.smack.test.util.SmackTestUtil;
|
|
||||||
import org.jivesoftware.smack.test.util.SmackTestUtil.XmlPullParserKind;
|
|
||||||
import org.jivesoftware.smack.xml.XmlPullParser;
|
|
||||||
import org.jivesoftware.smack.xml.XmlPullParserException;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
import org.jivesoftware.smackx.usertune.provider.UserTuneProvider;
|
|
||||||
|
|
||||||
import org.junit.Test;
|
|
||||||
import org.junit.jupiter.params.ParameterizedTest;
|
|
||||||
import org.junit.jupiter.params.provider.EnumSource;
|
|
||||||
|
|
||||||
public class UserTuneElementTest extends SmackTestSuite {
|
|
||||||
|
|
||||||
private final String xml = "<tune xmlns='http://jabber.org/protocol/tune'>" +
|
|
||||||
"<artist>Yes</artist>" +
|
|
||||||
"<length>686</length>" +
|
|
||||||
"<rating>8</rating>" +
|
|
||||||
"<source>Yessongs</source>" +
|
|
||||||
"<title>Heart of the Sunrise</title>" +
|
|
||||||
"<track>3</track>" +
|
|
||||||
"<uri>http://www.yesworld.com/lyrics/Fragile.html#9</uri>" +
|
|
||||||
"</tune>";
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void toXmlTest() throws IOException, XmlPullParserException, SmackParsingException, URISyntaxException {
|
|
||||||
|
|
||||||
URI uri = new URI("http://www.yesworld.com/lyrics/Fragile.html#9");
|
|
||||||
|
|
||||||
UserTuneElement.Builder builder = UserTuneElement.getBuilder();
|
|
||||||
UserTuneElement userTuneElement = builder.setArtist("Yes")
|
|
||||||
.setLength(686)
|
|
||||||
.setRating(8)
|
|
||||||
.setSource("Yessongs")
|
|
||||||
.setTitle("Heart of the Sunrise")
|
|
||||||
.setTrack("3")
|
|
||||||
.setUri(uri)
|
|
||||||
.build();
|
|
||||||
assertXmlSimilar(xml, userTuneElement.toXML().toString());
|
|
||||||
}
|
|
||||||
|
|
||||||
@ParameterizedTest
|
|
||||||
@EnumSource(value = SmackTestUtil.XmlPullParserKind.class)
|
|
||||||
public void userTuneElementProviderTest(XmlPullParserKind parserKind) throws XmlPullParserException, IOException, SmackParsingException {
|
|
||||||
XmlPullParser parser = SmackTestUtil.getParserFor(xml, parserKind);
|
|
||||||
UserTuneElement parsed = UserTuneProvider.INSTANCE.parse(parser);
|
|
||||||
assertXmlSimilar(xml, parsed.toXML().toString());
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,58 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
||||||
|
|
||||||
import static junit.framework.TestCase.assertEquals;
|
|
||||||
import static junit.framework.TestCase.assertNotNull;
|
|
||||||
import static junit.framework.TestCase.assertTrue;
|
|
||||||
|
|
||||||
import java.net.URI;
|
|
||||||
import java.net.URISyntaxException;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.packet.Message;
|
|
||||||
import org.jivesoftware.smack.test.util.SmackTestSuite;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
|
|
||||||
import org.junit.Test;
|
|
||||||
|
|
||||||
public class UserTuneManagerTest extends SmackTestSuite{
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void addMessage() throws URISyntaxException {
|
|
||||||
|
|
||||||
UserTuneElement.Builder builder = UserTuneElement.getBuilder();
|
|
||||||
builder.setArtist("Yes");
|
|
||||||
builder.setLength(686);
|
|
||||||
builder.setRating(8);
|
|
||||||
builder.setSource("Yessongs");
|
|
||||||
builder.setTitle("Heart of the Sunrise");
|
|
||||||
builder.setTrack("3");
|
|
||||||
URI uri = new URI("http://www.yesworld.com/lyrics/Fragile.html#9");
|
|
||||||
builder.setUri(uri);
|
|
||||||
UserTuneElement userTuneElement = builder.build();
|
|
||||||
|
|
||||||
Message message = new Message();
|
|
||||||
message.addExtension(userTuneElement);
|
|
||||||
|
|
||||||
assertTrue(message.hasExtension(UserTuneElement.ELEMENT, UserTuneElement.NAMESPACE));
|
|
||||||
assertTrue(UserTuneElement.hasUserTuneElement(message));
|
|
||||||
|
|
||||||
UserTuneElement element = UserTuneElement.from(message);
|
|
||||||
assertNotNull(element);
|
|
||||||
assertEquals(userTuneElement, element);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -67,7 +67,7 @@ public class MamIntegrationTest extends AbstractSmackIntegrationTest {
|
||||||
EntityBareJid userTwo = conTwo.getUser().asEntityBareJid();
|
EntityBareJid userTwo = conTwo.getUser().asEntityBareJid();
|
||||||
|
|
||||||
Message message = new Message(userTwo);
|
Message message = new Message(userTwo);
|
||||||
String messageId = message.ensureStanzaIdSet();
|
String messageId = message.setStanzaId();
|
||||||
final String messageBody = "Test MAM message (" + testRunId + ')';
|
final String messageBody = "Test MAM message (" + testRunId + ')';
|
||||||
message.setBody(messageBody);
|
message.setBody(messageBody);
|
||||||
|
|
||||||
|
|
|
@ -1,89 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
||||||
|
|
||||||
import java.net.URI;
|
|
||||||
|
|
||||||
import org.jivesoftware.smack.SmackException;
|
|
||||||
import org.jivesoftware.smack.SmackException.NotLoggedInException;
|
|
||||||
import org.jivesoftware.smack.XMPPException;
|
|
||||||
import org.jivesoftware.smack.packet.Message;
|
|
||||||
import org.jivesoftware.smackx.usertune.element.UserTuneElement;
|
|
||||||
|
|
||||||
import org.igniterealtime.smack.inttest.AbstractSmackIntegrationTest;
|
|
||||||
import org.igniterealtime.smack.inttest.SmackIntegrationTest;
|
|
||||||
import org.igniterealtime.smack.inttest.SmackIntegrationTestEnvironment;
|
|
||||||
import org.igniterealtime.smack.inttest.util.IntegrationTestRosterUtil;
|
|
||||||
import org.igniterealtime.smack.inttest.util.SimpleResultSyncPoint;
|
|
||||||
import org.junit.AfterClass;
|
|
||||||
|
|
||||||
import org.jxmpp.jid.BareJid;
|
|
||||||
|
|
||||||
public class UserTuneIntegrationTest extends AbstractSmackIntegrationTest {
|
|
||||||
|
|
||||||
private final UserTuneManager utm1;
|
|
||||||
private final UserTuneManager utm2;
|
|
||||||
|
|
||||||
public UserTuneIntegrationTest(SmackIntegrationTestEnvironment<?> environment) throws NotLoggedInException {
|
|
||||||
super(environment);
|
|
||||||
utm1 = UserTuneManager.getInstanceFor(conOne);
|
|
||||||
utm2 = UserTuneManager.getInstanceFor(conTwo);
|
|
||||||
}
|
|
||||||
|
|
||||||
@SmackIntegrationTest
|
|
||||||
public void test() throws Exception {
|
|
||||||
URI uri = new URI("http://www.yesworld.com/lyrics/Fragile.html#9");
|
|
||||||
UserTuneElement.Builder builder = UserTuneElement.getBuilder();
|
|
||||||
UserTuneElement userTuneElement1 = builder.setArtist("Yes")
|
|
||||||
.setLength(686)
|
|
||||||
.setRating(8)
|
|
||||||
.setSource("Yessongs")
|
|
||||||
.setTitle("Heart of the Sunrise")
|
|
||||||
.setTrack("3")
|
|
||||||
.setUri(uri)
|
|
||||||
.build();
|
|
||||||
|
|
||||||
IntegrationTestRosterUtil.ensureBothAccountsAreSubscribedToEachOther(conOne, conTwo, timeout);
|
|
||||||
|
|
||||||
final SimpleResultSyncPoint userTuneReceived = new SimpleResultSyncPoint();
|
|
||||||
|
|
||||||
final UserTuneListener userTuneListener = new UserTuneListener() {
|
|
||||||
@Override
|
|
||||||
public void onUserTuneUpdated(BareJid jid, Message message, UserTuneElement userTuneElement) {
|
|
||||||
if (userTuneElement.equals(userTuneElement1)) {
|
|
||||||
userTuneReceived.signal();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
utm2.addUserTuneListener(userTuneListener);
|
|
||||||
|
|
||||||
try {
|
|
||||||
utm1.publishUserTune(userTuneElement1);
|
|
||||||
userTuneReceived.waitForResult(timeout);
|
|
||||||
} finally {
|
|
||||||
utm2.removeUserTuneListener(userTuneListener);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@AfterClass
|
|
||||||
public void unsubscribe()
|
|
||||||
throws SmackException.NotLoggedInException, XMPPException.XMPPErrorException,
|
|
||||||
SmackException.NotConnectedException, InterruptedException, SmackException.NoResponseException {
|
|
||||||
IntegrationTestRosterUtil.ensureBothAccountsAreNotInEachOthersRoster(conOne, conTwo);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,17 +0,0 @@
|
||||||
/**
|
|
||||||
*
|
|
||||||
* Copyright 2019 Aditya Borikar.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.jivesoftware.smackx.usertune;
|
|
|
@ -40,10 +40,6 @@ import org.jivesoftware.smack.xml.XmlPullParserException;
|
||||||
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
||||||
import org.jivesoftware.smackx.disco.packet.DiscoverInfo;
|
import org.jivesoftware.smackx.disco.packet.DiscoverInfo;
|
||||||
|
|
||||||
import org.jxmpp.jid.DomainBareJid;
|
|
||||||
import org.jxmpp.jid.impl.JidCreate;
|
|
||||||
import org.jxmpp.stringprep.XmppStringprepException;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* RTPBridge IQ Stanza used to request and retrieve a RTPBridge Candidates that can be used for a Jingle Media Transmission between two parties that are behind NAT.
|
* RTPBridge IQ Stanza used to request and retrieve a RTPBridge Candidates that can be used for a Jingle Media Transmission between two parties that are behind NAT.
|
||||||
* This Jingle Bridge has all the needed information to establish a full UDP Channel (Send and Receive) between two parties.
|
* This Jingle Bridge has all the needed information to establish a full UDP Channel (Send and Receive) between two parties.
|
||||||
|
@ -401,6 +397,7 @@ public class RTPBridge extends IQ {
|
||||||
* @throws NotConnectedException if the XMPP connection is not connected.
|
* @throws NotConnectedException if the XMPP connection is not connected.
|
||||||
* @throws InterruptedException if the calling thread was interrupted.
|
* @throws InterruptedException if the calling thread was interrupted.
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("deprecation")
|
||||||
public static RTPBridge getRTPBridge(XMPPConnection connection, String sessionID) throws NotConnectedException, InterruptedException {
|
public static RTPBridge getRTPBridge(XMPPConnection connection, String sessionID) throws NotConnectedException, InterruptedException {
|
||||||
|
|
||||||
if (!connection.isConnected()) {
|
if (!connection.isConnected()) {
|
||||||
|
@ -408,13 +405,7 @@ public class RTPBridge extends IQ {
|
||||||
}
|
}
|
||||||
|
|
||||||
RTPBridge rtpPacket = new RTPBridge(sessionID);
|
RTPBridge rtpPacket = new RTPBridge(sessionID);
|
||||||
DomainBareJid jid;
|
rtpPacket.setTo(RTPBridge.NAME + "." + connection.getXMPPServiceDomain());
|
||||||
try {
|
|
||||||
jid = JidCreate.domainBareFrom(RTPBridge.NAME + "." + connection.getXMPPServiceDomain());
|
|
||||||
} catch (XmppStringprepException e) {
|
|
||||||
throw new AssertionError(e);
|
|
||||||
}
|
|
||||||
rtpPacket.setTo(jid);
|
|
||||||
|
|
||||||
StanzaCollector collector = connection.createStanzaCollectorAndSend(rtpPacket);
|
StanzaCollector collector = connection.createStanzaCollectorAndSend(rtpPacket);
|
||||||
|
|
||||||
|
@ -478,6 +469,7 @@ public class RTPBridge extends IQ {
|
||||||
* @throws NotConnectedException if the XMPP connection is not connected.
|
* @throws NotConnectedException if the XMPP connection is not connected.
|
||||||
* @throws InterruptedException if the calling thread was interrupted.
|
* @throws InterruptedException if the calling thread was interrupted.
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("deprecation")
|
||||||
public static RTPBridge relaySession(XMPPConnection connection, String sessionID, String pass, TransportCandidate proxyCandidate, TransportCandidate localCandidate) throws NotConnectedException, InterruptedException {
|
public static RTPBridge relaySession(XMPPConnection connection, String sessionID, String pass, TransportCandidate proxyCandidate, TransportCandidate localCandidate) throws NotConnectedException, InterruptedException {
|
||||||
|
|
||||||
if (!connection.isConnected()) {
|
if (!connection.isConnected()) {
|
||||||
|
@ -485,13 +477,7 @@ public class RTPBridge extends IQ {
|
||||||
}
|
}
|
||||||
|
|
||||||
RTPBridge rtpPacket = new RTPBridge(sessionID, RTPBridge.BridgeAction.change);
|
RTPBridge rtpPacket = new RTPBridge(sessionID, RTPBridge.BridgeAction.change);
|
||||||
DomainBareJid jid;
|
rtpPacket.setTo(RTPBridge.NAME + "." + connection.getXMPPServiceDomain());
|
||||||
try {
|
|
||||||
jid = JidCreate.domainBareFrom(RTPBridge.NAME + "." + connection.getXMPPServiceDomain());
|
|
||||||
} catch (XmppStringprepException e) {
|
|
||||||
throw new AssertionError(e);
|
|
||||||
}
|
|
||||||
rtpPacket.setTo(jid);
|
|
||||||
rtpPacket.setType(Type.set);
|
rtpPacket.setType(Type.set);
|
||||||
|
|
||||||
rtpPacket.setPass(pass);
|
rtpPacket.setPass(pass);
|
||||||
|
@ -520,6 +506,7 @@ public class RTPBridge extends IQ {
|
||||||
* @throws NotConnectedException if the XMPP connection is not connected.
|
* @throws NotConnectedException if the XMPP connection is not connected.
|
||||||
* @throws InterruptedException if the calling thread was interrupted.
|
* @throws InterruptedException if the calling thread was interrupted.
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("deprecation")
|
||||||
public static String getPublicIP(XMPPConnection xmppConnection) throws NotConnectedException, InterruptedException {
|
public static String getPublicIP(XMPPConnection xmppConnection) throws NotConnectedException, InterruptedException {
|
||||||
|
|
||||||
if (!xmppConnection.isConnected()) {
|
if (!xmppConnection.isConnected()) {
|
||||||
|
@ -527,13 +514,7 @@ public class RTPBridge extends IQ {
|
||||||
}
|
}
|
||||||
|
|
||||||
RTPBridge rtpPacket = new RTPBridge(RTPBridge.BridgeAction.publicip);
|
RTPBridge rtpPacket = new RTPBridge(RTPBridge.BridgeAction.publicip);
|
||||||
DomainBareJid jid;
|
rtpPacket.setTo(RTPBridge.NAME + "." + xmppConnection.getXMPPServiceDomain());
|
||||||
try {
|
|
||||||
jid = JidCreate.domainBareFrom(RTPBridge.NAME + "." + xmppConnection.getXMPPServiceDomain());
|
|
||||||
} catch (XmppStringprepException e) {
|
|
||||||
throw new AssertionError(e);
|
|
||||||
}
|
|
||||||
rtpPacket.setTo(jid);
|
|
||||||
rtpPacket.setType(Type.set);
|
rtpPacket.setType(Type.set);
|
||||||
|
|
||||||
// LOGGER.debug("Relayed to: " + candidate.getIp() + ":" + candidate.getPort());
|
// LOGGER.debug("Relayed to: " + candidate.getIp() + ":" + candidate.getPort());
|
||||||
|
|
|
@ -37,10 +37,6 @@ import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
|
||||||
import org.jivesoftware.smackx.disco.packet.DiscoverInfo;
|
import org.jivesoftware.smackx.disco.packet.DiscoverInfo;
|
||||||
import org.jivesoftware.smackx.disco.packet.DiscoverItems;
|
import org.jivesoftware.smackx.disco.packet.DiscoverItems;
|
||||||
|
|
||||||
import org.jxmpp.jid.DomainBareJid;
|
|
||||||
import org.jxmpp.jid.impl.JidCreate;
|
|
||||||
import org.jxmpp.stringprep.XmppStringprepException;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* STUN IQ Stanza used to request and retrieve a STUN server and port to make p2p connections easier. STUN is usually used by Jingle Media Transmission between two parties that are behind NAT.
|
* STUN IQ Stanza used to request and retrieve a STUN server and port to make p2p connections easier. STUN is usually used by Jingle Media Transmission between two parties that are behind NAT.
|
||||||
*
|
*
|
||||||
|
@ -181,6 +177,7 @@ public class STUN extends SimpleIQ {
|
||||||
* @throws NotConnectedException if the XMPP connection is not connected.
|
* @throws NotConnectedException if the XMPP connection is not connected.
|
||||||
* @throws InterruptedException if the calling thread was interrupted.
|
* @throws InterruptedException if the calling thread was interrupted.
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("deprecation")
|
||||||
public static STUN getSTUNServer(XMPPConnection connection) throws NotConnectedException, InterruptedException {
|
public static STUN getSTUNServer(XMPPConnection connection) throws NotConnectedException, InterruptedException {
|
||||||
|
|
||||||
if (!connection.isConnected()) {
|
if (!connection.isConnected()) {
|
||||||
|
@ -188,13 +185,7 @@ public class STUN extends SimpleIQ {
|
||||||
}
|
}
|
||||||
|
|
||||||
STUN stunPacket = new STUN();
|
STUN stunPacket = new STUN();
|
||||||
DomainBareJid jid;
|
stunPacket.setTo(DOMAIN + "." + connection.getXMPPServiceDomain());
|
||||||
try {
|
|
||||||
jid = JidCreate.domainBareFrom(DOMAIN + "." + connection.getXMPPServiceDomain());
|
|
||||||
} catch (XmppStringprepException e) {
|
|
||||||
throw new AssertionError(e);
|
|
||||||
}
|
|
||||||
stunPacket.setTo(jid);
|
|
||||||
|
|
||||||
StanzaCollector collector = connection.createStanzaCollectorAndSend(stunPacket);
|
StanzaCollector collector = connection.createStanzaCollectorAndSend(stunPacket);
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue