SECAPIConn.java

Go to the documentation of this file.

/*
 * Project: Server for annotations sharing
 * Author: Jaroslav Dytrych, idytrych@fit.vutbr.cz
 * File: SECAPIConn.java
 * Description: Class implementing functions for communication with remote SEC API
 */

/**
 * @file SECAPIConn.java
 *
 * @brief Class implementing functions for communication with remote SEC API
 */

package cz.vutbr.fit.knot.annotations.modules.suggestionManager;

import cz.vutbr.fit.knot.annotations.app.AppBean;
import cz.vutbr.fit.knot.annotations.app.Constants;
import cz.vutbr.fit.knot.annotations.app.Localisation;
import cz.vutbr.fit.knot.annotations.comet.RequestInfo;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.ProtocolException;
import java.net.URL;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * Class implementing functions for communication with remote SEC API
 *
 * @brief Class implementing functions for communication with remote SEC API
 */
public class SECAPIConn extends Thread {
  private URL secServ;
  // connection for a requests
  private HttpURLConnection conn;
  // write stream to the SEC API server
  private OutputStreamWriter outW;
  // reader stream from the SEC API server
  private BufferedReader inR;


  /**
   * Constructor.
   * Initializes connection to the remote SEC API.
   * Creates objects for communication.
   */
  public SECAPIConn() {
    try {
      secServ = new URL(AppBean.getSecApiServerUri());
    }
    catch (MalformedURLException e) {
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to create connection from provided URI.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
    }
    catch (IOException e){
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Error opening a connection to provided URI.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
    }
  }

  /**
   * Constructor.
   * Initializes connection to the SEC API.
   * Creates objects for communication.
   *
   * @param secUri Address of the remote SEC API server
   */
  public SECAPIConn(String secUri) {
    try {
      secServ = new URL(secUri);
    }
    catch (MalformedURLException e) {
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Malformed SEC Store API server URI.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
    }
    catch(IOException e){
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Error opening a connection to provided SEC Store API server URI.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
    }
  }

  /**
   * Method sends data to the SEC API server.
   * 
   * @param requestData Data containing request to SEC API server
   * @param requestInfo Info about client request
   * @return True if operation was successful, false otherwise
   */
  public String sendReqToSECAPI(String requestData, RequestInfo requestInfo) {
    StringBuilder ret = new StringBuilder("");
    try {
      conn = (HttpURLConnection) secServ.openConnection();
    }
    catch (IOException e) {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to open connection to the SEC API server.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }
    if (conn == null) {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to open connection to the SEC API server.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }

    // set request properties
    try {
      conn.setRequestMethod("POST");
      conn.setDoOutput(true);
      conn.setDoInput(true);
      conn.addRequestProperty("Content-Length", Integer.toString(requestData.length()));
    }
    catch (ProtocolException e) {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to set protocol request method for SEC API connection.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }

    // send request data via HTTP to the SEC API server
    try {
      outW = new OutputStreamWriter(conn.getOutputStream(), "UTF-8");
      outW.write(requestData);
      outW.close();
    }
    catch (IOException e) {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to get output stream for SEC API connection.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }

    // read SEC API server's response data
    InputStream is;
    try {
      is = conn.getInputStream();
    }
    catch (Exception e)  {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to get input stream for SEC API connection.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }
    InputStreamReader isr = new InputStreamReader(is);
    inR = new BufferedReader(isr);
    String inputLine;
    try {
      while((inputLine = inR.readLine()) != null) {
        ret.append(inputLine);
      }
      inR.close();
    }
    catch (IOException e) {
      if(requestInfo != null){
        int langNum = requestInfo.getSession().getLanguageNum();
        int lod = requestInfo.getSession().getProtocolLOD();    
        requestInfo.addError(lod, langNum, Localisation.ERROR_60_SEC_NOT_AVAILABLE);
      }
      if (Constants.LOG_LEVEL >= Constants.LOG_LEVEL_SERVER_ERRORS) {
        String msg = "Unable to read from input stream connected to SEC API server.";
        Logger.getLogger(SECAPIConn.class.getName()).log(Level.SEVERE, msg);
      }
      return null;
    }

    return ret.toString();
  } // sendReqToSECAPI()
}  // class SECAPIConn