Class MongoMucDAO

  • All Implemented Interfaces:
    tigase.db.DataSourceAware<MongoDataSource>, tigase.muc.repository.IMucDAO<MongoDataSource,​byte[]>

    public class MongoMucDAO
    extends tigase.muc.repository.AbstractMucDAO<MongoDataSource,​byte[]>
    Created by andrzej on 20.10.2016.
    • Field Detail

      • roomAffilaitionsCollection

        protected com.mongodb.client.MongoCollection<org.bson.Document> roomAffilaitionsCollection
      • roomsCollection

        protected com.mongodb.client.MongoCollection<org.bson.Document> roomsCollection
    • Constructor Detail

      • MongoMucDAO

        public MongoMucDAO()
    • Method Detail

      • calculateHash

        protected byte[] calculateHash​(String user)
                                throws tigase.db.TigaseDBException
        Throws:
        tigase.db.TigaseDBException
      • createRoom

        public byte[] createRoom​(tigase.muc.RoomWithId<byte[]> room)
                          throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • destroyRoom

        public void destroyRoom​(tigase.xmpp.jid.BareJID roomJID)
                         throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • generateId

        protected byte[] generateId​(tigase.xmpp.jid.BareJID user)
                             throws tigase.db.TigaseDBException
        Throws:
        tigase.db.TigaseDBException
      • getAffiliations

        public Map<tigase.xmpp.jid.BareJID,​tigase.muc.RoomAffiliation> getAffiliations​(tigase.muc.RoomWithId<byte[]> room)
                                                                                      throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • getRoom

        public tigase.muc.RoomWithId<byte[]> getRoom​(tigase.xmpp.jid.BareJID roomJID)
                                              throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • getRoomsJIDList

        public ArrayList<tigase.xmpp.jid.BareJID> getRoomsJIDList()
                                                           throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • setAffiliation

        public void setAffiliation​(tigase.muc.RoomWithId<byte[]> room,
                                   tigase.xmpp.jid.BareJID jid,
                                   tigase.muc.RoomAffiliation affiliation)
                            throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • setDataSource

        public void setDataSource​(MongoDataSource dataSource)
      • getRoomAvatar

        public String getRoomAvatar​(tigase.muc.RoomWithId<byte[]> room)
                             throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • updateRoomAvatar

        public void updateRoomAvatar​(tigase.muc.RoomWithId<byte[]> room,
                                     String encodedAvatar,
                                     String hash)
                              throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • setSubject

        public void setSubject​(tigase.muc.RoomWithId<byte[]> room,
                               String subject,
                               String creatorNickname,
                               Date changeDate)
                        throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException
      • updateRoomConfig

        public void updateRoomConfig​(tigase.muc.RoomConfig roomConfig)
                              throws tigase.component.exceptions.RepositoryException
        Throws:
        tigase.component.exceptions.RepositoryException