jonny
/
covscanrest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

update tekton

exception_work
Nicholas Caughey 3 years ago
parent
39cd02490e
commit
2f043bacc3
2 changed files with 123 additions and 118 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 11
      src/main/java/rest/TektonTaskCreate.java
  2. 232
      src/main/java/rest/callTekton.java

11
src/main/java/rest/TektonTaskCreate.java
Unescape View File

@ -130,18 +130,23 @@ import io.fabric8.tekton.client.TektonClient;
import io.fabric8.tekton.pipeline.v1beta1.TaskBuilder; import io.fabric8.tekton.pipeline.v1beta1.TaskBuilder;
import io.fabric8.tekton.pipeline.v1beta1.TaskRunBuilder; import io.fabric8.tekton.pipeline.v1beta1.TaskRunBuilder;
@Path("/tekton")
public class TektonTaskCreate { public class TektonTaskCreate {
@RestClient @RestClient
private static final String NAMESPACE = "default"; private static final String NAMESPACE = "default";
@POST @POST
@Consumes({ "application/json" }) @Consumes({ "application/json" })
public static void invokeTektonTask(String config, String nvr) { public void invokeTektonTask(String data) {
JSONObject jsonData = new JSONObject(data);
// ScanObj scanObj = ScanObjPayload.constructScanPayload(jsonData);
//dont leave this in live needs to be adjusted (currently would cause a ton of issues) //dont leave this in live needs to be adjusted (currently would cause a ton of issues)
String tektonArgs = "osh-cli mock-build --config="+config+"--brew-build"+nvr; String tektonArgs = "osh-cli mock-build --config="+jsonData.get("config")+"--brew-build"+jsonData.get("nvr");
try (TektonClient tkn = new DefaultTektonClient()) { try (TektonClient tkn = new DefaultTektonClient()) {
// Create Task // Create Task
tkn.v1beta1().tasks().inNamespace(NAMESPACE).resource(new TaskBuilder() tkn.v1beta1().tasks().inNamespace(NAMESPACE).resource(new TaskBuilder()

232
src/main/java/rest/callTekton.java
Unescape View File

@ -1,116 +1,116 @@
package rest; // package rest;
import io.fabric8.tekton.client.DefaultTektonClient; // import io.fabric8.tekton.client.DefaultTektonClient;
import io.fabric8.tekton.client.TektonClient; // import io.fabric8.tekton.client.TektonClient;
import javax.inject.Inject; // import javax.inject.Inject;
import javax.validation.Valid; // import javax.validation.Valid;
import javax.ws.rs.Consumes; // import javax.ws.rs.Consumes;
import javax.ws.rs.POST; // import javax.ws.rs.POST;
import javax.ws.rs.Path; // import javax.ws.rs.Path;
import java.net.URI; // import java.net.URI;
import java.net.URISyntaxException; // import java.net.URISyntaxException;
import java.util.ArrayList; // import java.util.ArrayList;
import java.util.Arrays; // import java.util.Arrays;
import java.util.List; // 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.ScanObj;
import dto.BrewObj; // import dto.BrewObj;
import dto.ConnectDB; // import dto.ConnectDB;
import dto.ScanObjPayload; // import dto.ScanObjPayload;
import dto.BrewObjPayload; // import dto.BrewObjPayload;
import dto.GitObj; // import dto.GitObj;
import dto.GitObjPayload; // import dto.GitObjPayload;
import dto.PncObj; // import dto.PncObj;
import dto.PncObjPayload; // import dto.PncObjPayload;
import static constants.HttpHeaders.AUTHORIZATION_STRING; // import static constants.HttpHeaders.AUTHORIZATION_STRING;
import java.sql.Connection; // 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.Connection;
import java.sql.DriverManager; // import java.sql.DriverManager;
import java.sql.ResultSet; // import java.sql.ResultSet;
import java.sql.Statement; // import java.sql.Statement;
import java.util.Collections; // import java.util.Collections;
import java.util.LinkedHashMap; // import java.util.LinkedHashMap;
import java.util.Set; // import java.util.Set;
import dto.ScanObj; // import dto.ScanObj;
import dto.ConnectDB; // import dto.ConnectDB;
import java.sql.Connection; // 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.Connection;
import java.sql.DriverManager; // import java.sql.DriverManager;
import java.sql.ResultSet; // import java.sql.ResultSet;
import java.sql.Statement; // 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;
import javax.ws.rs.Path; // import javax.ws.rs.Path;
import javax.inject.Inject; // import javax.inject.Inject;
import javax.ws.rs.GET; // import javax.ws.rs.GET;
import javax.ws.rs.Path; // import javax.ws.rs.Path;
import javax.ws.rs.PathParam; // import javax.ws.rs.PathParam;
import java.util.Set; // import java.util.Set;
import java.util.stream.Collectors; // import java.util.stream.Collectors;
import javax.inject.Inject; // import javax.inject.Inject;
import javax.ws.rs.Consumes; // import javax.ws.rs.Consumes;
import java.sql.*; // import java.sql.*;
import com.fasterxml.jackson.databind.ObjectMapper; // import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter; // import com.fasterxml.jackson.databind.ObjectWriter;
// import org.hibernate.EntityManager; // // import org.hibernate.EntityManager;
import jakarta.persistence.EntityManager; // import jakarta.persistence.EntityManager;
import jakarta.persistence.Cacheable; // import jakarta.persistence.Cacheable;
import jakarta.persistence.Column; // import jakarta.persistence.Column;
import jakarta.persistence.Entity; // import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue; // import jakarta.persistence.GeneratedValue;
import jakarta.persistence.Id; // import jakarta.persistence.Id;
import jakarta.persistence.NamedQuery; // import jakarta.persistence.NamedQuery;
import jakarta.persistence.QueryHint; // import jakarta.persistence.QueryHint;
import jakarta.persistence.SequenceGenerator; // import jakarta.persistence.SequenceGenerator;
import jakarta.persistence.Table; // import jakarta.persistence.Table;
import io.fabric8.tekton.client.DefaultTektonClient; // import io.fabric8.tekton.client.DefaultTektonClient;
import io.fabric8.tekton.client.TektonClient; // import io.fabric8.tekton.client.TektonClient;
import io.fabric8.tekton.pipeline.v1beta1.TaskBuilder; // import io.fabric8.tekton.pipeline.v1beta1.TaskBuilder;
import io.fabric8.tekton.pipeline.v1beta1.Task; // import io.fabric8.tekton.pipeline.v1beta1.Task;
public class callTekton { // public class callTekton {
private static final String NAMESPACE = "default"; // private static final String NAMESPACE = "default";
public static void main(String[] args) { // public static void main(String[] args) {
try (TektonClient tkn = new DefaultTektonClient()) { // try (TektonClient tkn = new DefaultTektonClient()) {
// Load Task object from YAML // // Load Task object from YAML
Task task = tkn.v1beta1() // Task task = tkn.v1beta1()
.tasks() // .tasks()
.load(callTekton.class.getResourceAsStream("../resources/baseScan.yml")).get(); // .load(callTekton.class.getResourceAsStream("../resources/baseScan.yml")).get();
// Create Task object into Kubernetes // // Create Task object into Kubernetes
tkn.v1beta1().tasks().inNamespace(NAMESPACE).createOrReplace(task); // tkn.v1beta1().tasks().inNamespace(NAMESPACE).createOrReplace(task);
// Get Task object from APIServer // // Get Task object from APIServer
String taskName = task.getMetadata().getName(); // String taskName = task.getMetadata().getName();
task = tkn.v1beta1().tasks().inNamespace(NAMESPACE) // task = tkn.v1beta1().tasks().inNamespace(NAMESPACE)
.withName(taskName) // .withName(taskName)
.get(); // .get();
// Delete Task object // // Delete Task object
tkn.v1beta1().tasks().inNamespace(NAMESPACE).withName(taskName).delete(); // tkn.v1beta1().tasks().inNamespace(NAMESPACE).withName(taskName).delete();
} // }
} // }
} // }
Write Preview
Loading…
Cancel
Save