Browse Source

added input for brewscans as a temporary solution need to consolodate into a single method that applys business logic

exception_work
Nicholas Caughey 3 years ago
parent
commit
ce9b1c536f
  1. 6
      src/main/java/constants/PSGQL.java
  2. 2
      src/main/java/dto/BrewObj.java
  3. 16
      src/main/java/dto/ScanObj.java
  4. 2
      src/main/java/dto/ScanObjPayload.java
  5. 29
      src/main/java/rest/CreateGetResource.java
  6. 17
      src/main/java/rest/CreateScanRequest.java
  7. 29
      src/main/java/rest/CreateScanResource.java

6
src/main/java/constants/PSGQL.java

@ -1,7 +1,7 @@
package constants; package constants;
public class PSGQL { public class PSGQL {
public static final String url = "jdbc:postgresql://localhost:5432/ScanDB"; public static final String url = "jdbc:postgresql://localhost:5432/mydb";
public static final String user = "ncaughey"; public static final String user = "postgres";
public static final String password = ""; public static final String password = "password";
} }

2
src/main/java/dto/BrewObj.java

@ -16,7 +16,7 @@ import java.io.Serializable;
@Jacksonized @Jacksonized
@Builder @Builder
public class BrewObj implements Serializable { public class BrewObj implements Serializable {
public String buildSysyemType; public String buildSystemType;
public String brewId; public String brewId;
public String brewNvr; public String brewNvr;
public String pncId; public String pncId;

16
src/main/java/dto/ScanObj.java

@ -17,15 +17,9 @@ import java.io.Serializable;
@Builder @Builder
public class ScanObj implements Serializable { public class ScanObj implements Serializable {
private String hub; public String scanId;
private String source; public String productId;
private String username; public String eventId;
private String password; public String isManagedService;
private String scanUrl; public String componentList;
private String scanId;
private String advisoryId;
private String owner;
private String release;
private String base;
} }

2
src/main/java/dto/ScanObjPayload.java

@ -18,6 +18,6 @@ import static constants.HttpHeaders.AUTHORIZATION_STRING;
public class ScanObjPayload { public class ScanObjPayload {
public static ScanObj constructScanPayload(JSONObject scanObj) throws URISyntaxException { public static ScanObj constructScanPayload(JSONObject scanObj) throws URISyntaxException {
return new ScanObj(scanObj.getString("hub"),scanObj.getString("source"),scanObj.getString("username"),scanObj.getString("password"),scanObj.getString("scanUrl"),scanObj.getString("scanId"),scanObj.getString("advisoryId"),scanObj.getString("owner"),scanObj.getString("release"),scanObj.getString("base")); return new ScanObj(scanObj.getString("scanId"),scanObj.getString("productId"),scanObj.getString("eventId"),scanObj.getString("isManagedService"),scanObj.getString("componentList"));
} }
} }

29
src/main/java/rest/CreateGetResource.java

@ -10,6 +10,11 @@ import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.SQLException; import java.sql.SQLException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.ws.rs.DELETE; import javax.ws.rs.DELETE;
import javax.ws.rs.GET; import javax.ws.rs.GET;
import javax.ws.rs.POST; import javax.ws.rs.POST;
@ -39,8 +44,6 @@ public class CreateGetResource {
public CreateGetResource() { public CreateGetResource() {
Scans.add(new ScanObj("a","a","a","a","a","a","a","a","a","a"));
} }
@GET @GET
@ -50,16 +53,22 @@ public class CreateGetResource {
try { try {
ConnectDB connectDB = new ConnectDB(); ConnectDB connectDB = new ConnectDB();
Connection conn = connectDB.connect(); Connection conn = connectDB.connect();
String sql = "SELECT" + scanId + "FROM scans"; Statement stmt = null;
PreparedStatement preparedStatment = conn.prepareStatement(sql); String sql = "SELECT * FROM scans WHERE scanid=" +scanId;
preparedStatment.executeQuery(sql); stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
String a = rs.getString("scanid");
String b = rs.getString("productid");
String c = rs.getString("eventid");
String d = rs.getString("ismanagedservice");
String e = rs.getString("componentlist");
Scans.add(new ScanObj(a,b,c,d,e));
}
} catch (SQLException e){ } catch (SQLException e){
System.out.println("failed"); System.out.println(e);
} }
// conn.
System.out.println(Scans);
System.out.println(scanId);
return Scans; return Scans;
} }
} }

17
src/main/java/rest/CreateScanRequest.java

@ -48,19 +48,16 @@ public class CreateScanRequest {
JSONObject jsonData = new JSONObject(scanInvocation); JSONObject jsonData = new JSONObject(scanInvocation);
BrewObj brewObj = BrewObjPayload.constructScanPayload(jsonData); BrewObj brewObj = BrewObjPayload.constructScanPayload(jsonData);
// scanBrewObj();
ConnectDB connectDB = new ConnectDB(); ConnectDB connectDB = new ConnectDB();
Connection conn = connectDB.connect(); Connection conn = connectDB.connect();
Statement stmt = null; Statement stmt = null;
// String sql = "INSERT INTO scans (scanid, productid, eventid, ismanagedservice, componentlist) VALUES ('" +scanObj.scanId+"', '"+scanObj.productId+"', '"+scanObj.eventId+"', '"+scanObj.isManagedService+"', '"+scanObj.componentList+"')"; String sql = "INSERT INTO brewscans (buildsystemtype, brewid, brewnvr, pncid, artifacttype, filename, builtfromsource) VALUES ('"+brewObj.buildSystemType+"','"+brewObj.brewId+"','"+brewObj.brewNvr+"','"+brewObj.pncId+"','"+brewObj.artifactType+"','"+brewObj.fileName+"','"+brewObj.buildFromSource+"')";
// try{ try{
// stmt = conn.createStatement(); stmt = conn.createStatement();
// ResultSet rs = stmt.executeQuery(sql); ResultSet rs = stmt.executeQuery(sql);
// } catch (SQLException e){ } catch (SQLException e){
// System.out.println(e); System.out.println(e);
// } }
brewObj = null;
return brewObj; return brewObj;
} }

29
src/main/java/rest/CreateScanResource.java

@ -16,12 +16,21 @@ import java.util.List;
import java.util.UUID; import java.util.UUID;
import org.json.JSONObject; import org.json.JSONObject;
import org.json.JSONArray; import org.json.JSONArray;
import dto.ScanObj;
import dto.ConnectDB;
import dto.ScanObjPayload; import dto.ScanObjPayload;
import static constants.HttpHeaders.AUTHORIZATION_STRING; import static constants.HttpHeaders.AUTHORIZATION_STRING;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
@Path("/createScan") @Path("/")
public class CreateScanResource { public class CreateScanResource {
// @Inject // @Inject
@ -31,14 +40,20 @@ public class CreateScanResource {
@POST @POST
@Consumes({ "application/json" }) @Consumes({ "application/json" })
//in theory should take List<String> but something weird is happening, didnt want to fix it specifically before adding the DB dto //in theory should take List<String> to clean it up
public ScanObj invokeScanAnalyze(@Valid String scanInvocation) throws URISyntaxException { public ScanObj invokeScanAnalyze(@Valid String scanInvocation) throws URISyntaxException {
//weird work around is currently being fixed
JSONObject jsonData = new JSONObject(scanInvocation); JSONObject jsonData = new JSONObject(scanInvocation);
System.out.println(jsonData);
//ignore all of this, temporary for testing purposes, "parser" will be in ScanObjPayload
ScanObj scanObj = ScanObjPayload.constructScanPayload(jsonData); ScanObj scanObj = ScanObjPayload.constructScanPayload(jsonData);
ConnectDB connectDB = new ConnectDB();
Connection conn = connectDB.connect();
Statement stmt = null;
String sql = "INSERT INTO scans (scanid, productid, eventid, ismanagedservice, componentlist) VALUES ('" +scanObj.scanId+"', '"+scanObj.productId+"', '"+scanObj.eventId+"', '"+scanObj.isManagedService+"', '"+scanObj.componentList+"')";
try{
stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);
} catch (SQLException e){
System.out.println(e);
}
return scanObj; return scanObj;
} }
} }

Loading…
Cancel
Save