/* * Copyright (C) 2008-2017, Juick * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ package com.juick.api; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import rocks.xmpp.core.XmppException; import rocks.xmpp.core.session.Extension; import rocks.xmpp.core.session.XmppSessionConfiguration; import rocks.xmpp.core.session.debug.LogbackDebugger; import rocks.xmpp.extensions.component.accept.ExternalComponent; import javax.annotation.PostConstruct; /** * @author Ugnich Anton */ public class ApiServer implements AutoCloseable { private static Logger logger = LoggerFactory.getLogger(ApiServer.class); private ExternalComponent xmpp; @Value("${xmpp_host:localhost}") private String xmppHost; @Value("${xmpp_password:secret}") private String xmppPassword; @Value("${xmpp_jid:api.localhost}") private String xmppJid; @Value("${xmpp_port:5347}") private int xmppPort; @Value("${xmpp_disabled:false}") private boolean isXmppDisabled; @PostConstruct public void init() { if (!isXmppDisabled) { setupXmppComponent(xmppHost, xmppPort, xmppJid, xmppPassword); } } @Override public void close() { try { if (getXmpp() != null) getXmpp().close(); logger.info("ExternalComponent on juick-api destroyed"); } catch (Exception e) { logger.warn("Exception occurs on juick-api destroy", e); } } public void setupXmppComponent(final String host, final int port, final String jid, final String password) { XmppSessionConfiguration configuration = XmppSessionConfiguration.builder() .debugger(LogbackDebugger.class) .extensions(Extension.of(com.juick.Message.class)) .build(); setXmpp(ExternalComponent.create(jid, password, configuration, host, port)); try { getXmpp().connect(); } catch (XmppException e) { logger.warn("xmpp extension", e); } } public ExternalComponent getXmpp() { return xmpp; } public void setXmpp(ExternalComponent xmpp) { this.xmpp = xmpp; } }