package com.juick.www; import org.apache.commons.lang3.BooleanUtils; import org.apache.commons.lang3.math.NumberUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.env.Environment; import rocks.xmpp.core.XmppException; import rocks.xmpp.core.session.Extension; import rocks.xmpp.core.session.XmppSessionConfiguration; import rocks.xmpp.extensions.component.accept.ExternalComponent; import javax.annotation.PostConstruct; /** * Created by vitalyster on 09.12.2016. */ public class WebApp implements AutoCloseable { private static Logger logger = LoggerFactory.getLogger(WebApp.class); private ExternalComponent xmpp; public String tmpDir; public String imgDir; private String xmppHost, xmppPassword, xmppJid; private int xmppPort; private boolean isXmppDisabled; public WebApp(Environment conf) { tmpDir = conf.getProperty("upload_tmp_dir", "/var/www/juick.com/i/tmp/"); imgDir = conf.getProperty("img_path", "/var/www/juick.com/i/"); isXmppDisabled = BooleanUtils.toBoolean(conf.getProperty("xmpp_disabled")); xmppHost = conf.getProperty("xmpp_host", "localhost"); xmppPort = NumberUtils.toInt(conf.getProperty("xmpp_port", "5347"), 5347); xmppJid = conf.getProperty("xmpp_jid", "www.localhost"); xmppPassword = conf.getProperty("xmpp_password"); } @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-www destroyed"); } catch (Exception e) { logger.warn("Exception occurs on juick-www destroy", e); } } public void setupXmppComponent(final String host, final int port, final String jid, final String password) { XmppSessionConfiguration configuration = XmppSessionConfiguration.builder() .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; } }