src/org/cacert/gigi/api/GigiAPI.java

   1 package org.cacert.gigi.api;
   2
   3 import java.io.IOException;
   4 import java.io.InputStreamReader;
   5 import java.util.HashMap;
   6
   7 import javax.servlet.ServletException;
   8 import javax.servlet.ServletInputStream;
   9 import javax.servlet.http.HttpServlet;
  10 import javax.servlet.http.HttpServletRequest;
  11 import javax.servlet.http.HttpServletResponse;
  12
  13 import org.cacert.gigi.database.DatabaseConnection;
  14 import org.cacert.gigi.database.DatabaseConnection.Link;
  15
  16 public class GigiAPI extends HttpServlet {
  17
  18     private static final long serialVersionUID = 659963677032635817L;
  19
  20     HashMap<String, APIPoint> api = new HashMap<>();
  21
  22     public GigiAPI() {
  23         api.put(CreateCertificate.PATH, new CreateCertificate());
  24         api.put(Emails.PATH, new Emails());
  25         api.put(EmailReping.PATH, new EmailReping());
  26         api.put(RevokeCertificate.PATH, new RevokeCertificate());
  27         api.put(CATSImport.PATH, new CATSImport());
  28         api.put(CATSResolve.PATH, new CATSResolve());
  29         FindAgent.register(api);
  30     }
  31
  32     @Override
  33     protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  34         String pi = req.getPathInfo();
  35         if (pi == null) {
  36             return;
  37         }
  38         if (pi.equals("/security/csp/report")) {
  39             ServletInputStream sis = req.getInputStream();
  40             InputStreamReader isr = new InputStreamReader(sis, "UTF-8");
  41             StringBuffer strB = new StringBuffer();
  42             char[] buffer = new char[4 * 1024];
  43             int len;
  44             while ((len = isr.read(buffer)) > 0) {
  45                 strB.append(buffer, 0, len);
  46             }
  47             System.out.println(strB);
  48             return;
  49         }
  50
  51         APIPoint p = api.get(pi);
  52         try (Link l = DatabaseConnection.newLink(false)) {
  53             if (p != null) {
  54                 p.process(req, resp);
  55             }
  56         } catch (InterruptedException e) {
  57             throw new Error(e);
  58         }
  59     }
  60 }