/* * Juick * Copyright (C) 2008-2013, Ugnich Anton * * 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.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; /** * @author Ugnich Anton */ public class ApiServer implements AutoCloseable { private static Logger logger = LoggerFactory.getLogger(ApiServer.class); private ExternalComponent xmpp; public String tmpDir; public String imgDir; private String xmppHost, xmppPassword, xmppJid; private int xmppPort; private boolean isXmppDisabled; public ApiServer(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", "api.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-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() .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; } }