Package tigase.pubsub.utils
Class DefaultPubSubLogic
- java.lang.Object
-
- tigase.pubsub.utils.DefaultPubSubLogic
-
- All Implemented Interfaces:
PubSubLogic
@Bean(name="logic", parent=PubSubComponent.class, active=true) public class DefaultPubSubLogic extends java.lang.Object implements PubSubLogic
Helper bean containing PubSub logicCreated by andrzej on 25.12.2016.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface tigase.pubsub.utils.PubSubLogic
PubSubLogic.Action
-
-
Constructor Summary
Constructors Constructor Description DefaultPubSubLogic()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
checkNodeConfig(AbstractNodeConfig nodeConfig)
void
checkPermission(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName, tigase.xmpp.jid.JID senderJid, PubSubLogic.Action action)
protected java.util.stream.Stream<tigase.xmpp.jid.JID>
getActiveSubscribers(ISubscriptions subscriptions, IAffiliations affiliations)
protected IPubSubConfig
getPubSubConfig()
protected IPubSubRepository
getRepository()
boolean
hasSenderSubscription(tigase.xmpp.jid.BareJID bareJid, IAffiliations affiliations)
boolean
isMAMEnabled(tigase.xmpp.jid.BareJID serviceJid, java.lang.String node)
boolean
isSenderInRosterGroup(tigase.xmpp.jid.BareJID bareJid, AbstractNodeConfig nodeConfig, IAffiliations affiliations, ISubscriptions subscriptions)
boolean
isServiceAutoCreated()
boolean
isServiceJidPEP(tigase.xmpp.jid.BareJID serivceJid)
tigase.xml.Element
prepareNotificationMessage(tigase.xmpp.jid.JID from, java.lang.String id, java.lang.String uuid, java.lang.String nodeName, tigase.xml.Element items, java.lang.String expireAt, java.util.Map<java.lang.String,java.lang.String> headers, tigase.xmpp.StanzaType stanzaType)
java.util.stream.Stream<tigase.xmpp.jid.JID>
subscribersOfNotifications(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName)
java.lang.String
validateItemId(tigase.xmpp.jid.BareJID toJid, java.lang.String nodeName, java.lang.String id)
-
-
-
Method Detail
-
checkPermission
public void checkPermission(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName, tigase.xmpp.jid.JID senderJid, PubSubLogic.Action action) throws PubSubException, tigase.component.exceptions.RepositoryException
- Specified by:
checkPermission
in interfacePubSubLogic
- Throws:
PubSubException
tigase.component.exceptions.RepositoryException
-
prepareNotificationMessage
public tigase.xml.Element prepareNotificationMessage(tigase.xmpp.jid.JID from, java.lang.String id, java.lang.String uuid, java.lang.String nodeName, tigase.xml.Element items, java.lang.String expireAt, java.util.Map<java.lang.String,java.lang.String> headers, tigase.xmpp.StanzaType stanzaType)
- Specified by:
prepareNotificationMessage
in interfacePubSubLogic
-
isServiceAutoCreated
public boolean isServiceAutoCreated()
- Specified by:
isServiceAutoCreated
in interfacePubSubLogic
-
checkNodeConfig
public void checkNodeConfig(AbstractNodeConfig nodeConfig) throws PubSubException
- Specified by:
checkNodeConfig
in interfacePubSubLogic
- Throws:
PubSubException
-
hasSenderSubscription
public boolean hasSenderSubscription(tigase.xmpp.jid.BareJID bareJid, IAffiliations affiliations) throws tigase.component.exceptions.RepositoryException
- Specified by:
hasSenderSubscription
in interfacePubSubLogic
- Throws:
tigase.component.exceptions.RepositoryException
-
isSenderInRosterGroup
public boolean isSenderInRosterGroup(tigase.xmpp.jid.BareJID bareJid, AbstractNodeConfig nodeConfig, IAffiliations affiliations, ISubscriptions subscriptions) throws tigase.component.exceptions.RepositoryException
- Specified by:
isSenderInRosterGroup
in interfacePubSubLogic
- Throws:
tigase.component.exceptions.RepositoryException
-
getActiveSubscribers
protected java.util.stream.Stream<tigase.xmpp.jid.JID> getActiveSubscribers(ISubscriptions subscriptions, IAffiliations affiliations)
-
subscribersOfNotifications
public java.util.stream.Stream<tigase.xmpp.jid.JID> subscribersOfNotifications(tigase.xmpp.jid.BareJID serviceJid, java.lang.String nodeName) throws tigase.component.exceptions.RepositoryException
- Specified by:
subscribersOfNotifications
in interfacePubSubLogic
- Throws:
tigase.component.exceptions.RepositoryException
-
isMAMEnabled
public boolean isMAMEnabled(tigase.xmpp.jid.BareJID serviceJid, java.lang.String node) throws tigase.component.exceptions.RepositoryException
- Specified by:
isMAMEnabled
in interfacePubSubLogic
- Throws:
tigase.component.exceptions.RepositoryException
-
getPubSubConfig
protected IPubSubConfig getPubSubConfig()
-
getRepository
protected IPubSubRepository getRepository()
-
isServiceJidPEP
public boolean isServiceJidPEP(tigase.xmpp.jid.BareJID serivceJid)
- Specified by:
isServiceJidPEP
in interfacePubSubLogic
-
validateItemId
public java.lang.String validateItemId(tigase.xmpp.jid.BareJID toJid, java.lang.String nodeName, java.lang.String id)
- Specified by:
validateItemId
in interfacePubSubLogic
-
-