Adding a container view pages

Author: SimpleMethod

src/main/java/pl/simplemethod/codebin/ContextWrapper.java

@@ -1,9 +1,8 @@
 package pl.simplemethod.codebin;
 
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.http.HttpMethod;
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
-import org.springframework.security.config.annotation.web.builders.WebSecurity;
 import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
 import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
 import org.springframework.security.oauth2.client.web.AuthorizationRequestRepository;
@@ -16,7 +15,9 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
 
  @Override
  protected void configure(HttpSecurity http) throws Exception {
- http.authorizeRequests().antMatchers("/**").permitAll();
+ http.authorizeRequests().antMatchers(HttpMethod.GET, "/**").permitAll();
+ http.csrf().disable();
+ http.cors().disable();
  /* http.authorizeRequests()
  .antMatchers("/", "/**", "/postlogin", "/v1.0/**", "/404", "/logowanie/github")
  .permitAll()

src/main/java/pl/simplemethod/codebin/SecurityConfig.java

@@ -9,7 +9,9 @@
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
+import pl.simplemethod.codebin.model.Containers;
 import pl.simplemethod.codebin.model.Users;
+import pl.simplemethod.codebin.repository.ContainersRepository;
 import pl.simplemethod.codebin.repository.UsersRepository;
 
 
@@ -23,6 +25,8 @@ public class GithubRestController {
  @Autowired
  UsersRepository usersRepository;
 
+ @Autowired
+ private ContainersRepository containersRepository;
  /**
  * Returns the necessary information about the repository
  *
@@ -125,6 +129,7 @@ ResponseEntity getInfoAboutUser(@CookieValue("token") String token, @PathVariabl
  public @ResponseBody
  ResponseEntity checkToken(@RequestParam("token") String token) {
  HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
  org.json.JSONObject body = new org.json.JSONObject();
  try {
  Users users = usersRepository.getFirstByToken(token);
@@ -157,6 +162,7 @@ ResponseEntity checkToken(@RequestParam("token") String token) {
  public @ResponseBody
  ResponseEntity getpublicrepos(@CookieValue("token") String token) {
  HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
  JSONParser parser = new JSONParser();
  org.json.JSONObject body = new org.json.JSONObject();
  org.json.simple.JSONArray result = new org.json.simple.JSONArray();
@@ -183,6 +189,17 @@ ResponseEntity getpublicrepos(@CookieValue("token") String token) {
  helper.put("html_url", obj1.get("html_url"));
  helper.put("description", obj1.get("description"));
  helper.put("created_at", obj1.get("created_at"));
+
+ Containers containers = containersRepository.getFirstByName(obj1.get("id").toString());
+ if(containers!=null)
+ {
+ helper.put("container_create", obj1.get("id"));
+ 
+ }
+ else
+ {
+ helper.put("container_create", null);
+ }
  result.add(helper);
  }
  });

src/main/java/pl/simplemethod/codebin/githubOauth/GithubRestController.java

@@ -19,6 +19,8 @@ public interface ContainersRepository extends JpaRepository<Containers, Long> {
 
  Containers getFirstByShareUrl(String shareURL);
 
+ Containers getFirstByName(String name);
+
  List<Containers> getByHostPorts(Integer ports);
 
  List<Containers> getByIdDocker(String dockerId);

src/main/java/pl/simplemethod/codebin/repository/ContainersRepository.java

@@ -247,6 +247,33 @@ protected org.json.JSONObject restartContainer(String id) {
  return body;
  }
  }
+
+ /**
+ * The method returns top process inside container data
+ *
+ * @param id Container ID
+ * @return Json object with status
+ */
+ protected String topContainer(String id) {
+ org.json.JSONObject body = new org.json.JSONObject();
+ try {
+ HttpResponse<String> topContainer = Unirest.get(SERVER_URL + "/v1.0/containers/" + id + "/top")
+ .header("accept", "application/json").header("Content-Type", "application/json").queryString("ps_args","").asString();
+ if (topContainer.getStatus() != 200) {
+ body.put("message", "Something went wrong ");
+ body.put("status", topContainer.getStatus());
+ return body.toString();
+ } else {
+ return topContainer.getBody();
+ }
+
+ } catch (NullPointerException | org.json.JSONException | UnirestException e) {
+ body.put("message", "Something went wrong " + e);
+ body.put("status", 510);
+ return body.toString();
+ }
+ }
+
  /**
  * The method returns container data
  *

src/main/java/pl/simplemethod/codebin/srv/SrvClient.java

@@ -7,7 +7,6 @@
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.util.WebUtils;
 import pl.simplemethod.codebin.linkDeploy.LinkClient;
 import pl.simplemethod.codebin.model.Containers;
 import pl.simplemethod.codebin.model.Images;
@@ -16,8 +15,6 @@
 import pl.simplemethod.codebin.repository.ImagesRepository;
 import pl.simplemethod.codebin.repository.UsersRepository;
 
-import javax.servlet.http.Cookie;
-import javax.servlet.http.HttpServletResponse;
 import java.time.Instant;
 import java.util.ArrayList;
 import java.util.List;
@@ -41,21 +38,61 @@ public class SrvRestController {
  @Autowired
  private UsersRepository usersRepository;
 
-/*
- @GetMapping("/createtest")
+ /**
+ * List of containers of any user
+ *
+ * @param id User ID
+ * @return Object Json with data
+ */
+ @GetMapping("users/{ID}/container")
  public @ResponseBody
- ResponseEntity kek() {
-
- List<Containers> containers = new ArrayList<>();
- Images images = imagesRepository.getFirstByName("java");
- containers.add(new Containers("test","test",images,1010,4510,(long)1000,(long)1000,1, Instant.now().getEpochSecond()));
- containers.forEach(containersRepository::save);
+ ResponseEntity usersContainer(@PathVariable(value = "ID") String id) {
+ Users users = usersRepository.getFirstById(Integer.valueOf(id));
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ List<Containers> containers = users.getContainers();
+ org.json.JSONObject result = new org.json.JSONObject();
+ result.put("containers", containers);
+ return new ResponseEntity<>(result.toString(), headers, HttpStatus.valueOf(200));
+ }
 
+ /**
+ * List of containers for login user
+ *
+ * @param id Current logged user
+ * @return Object Json with data
+ */
+ @GetMapping("user/container")
+ public @ResponseBody
+ ResponseEntity userContainer(@CookieValue("id") String id) {
  HttpHeaders headers = new HttpHeaders();
- return new ResponseEntity<>("xd", headers, HttpStatus.valueOf(200));
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ Users users = usersRepository.getFirstById(Integer.valueOf(id));
+ List<Containers> containers = users.getContainers();
+ org.json.JSONObject result = new org.json.JSONObject();
+ result.put("containers", containers);
+ return new ResponseEntity<>(result.toString(), headers, HttpStatus.valueOf(200));
  }
 
-*/
+ /**
+ * Returns container information from the database
+ *
+ * @param dockerGithubId Name of container
+ * @return Object Json with data
+ */
+ @GetMapping("user/container/info")
+ public @ResponseBody
+ ResponseEntity userContainerCheck(@RequestParam("dockergithubid") String dockerGithubId) {
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ Containers containers = containersRepository.getFirstByName(dockerGithubId);
+ if (containers != null) {
+
+ return new ResponseEntity<>(containers, headers, HttpStatus.valueOf(200));
+ } else {
+ return new ResponseEntity<>("error", headers, HttpStatus.valueOf(400));
+ }
+ }
 
  /**
  * REST for container creation
@@ -68,7 +105,7 @@ ResponseEntity kek() {
  * @param diskQuota Maximum amount of allocated memory on the disk
  * @return Json object with data
  */
- @GetMapping("container/create")
+ @PostMapping("container/create")
  public @ResponseBody
  ResponseEntity createContainerForUser(@RequestParam("dockerimage") String dockerImage, @RequestParam("exposedports") Integer exposedPorts, @RequestParam("hostports") Integer hostPorts, @RequestParam("name") String name, @RequestParam("rammemory") Long ramMemory, @RequestParam("diskquota") Long diskQuota, @CookieValue("id") String id) {
  HttpHeaders headers = new HttpHeaders();
@@ -142,6 +179,21 @@ ResponseEntity startContainer(@PathVariable(value = "ID") String containerId) {
  return new ResponseEntity<>(response.toString(), headers, HttpStatus.valueOf(response.getInt("status")));
  }
 
+ /**
+ * The method returns information about processes inside container
+ *
+ * @param containerId Container ID
+ * @return Json object as response
+ */
+ @GetMapping("container/{ID}/top")
+ public @ResponseBody
+ ResponseEntity topContainer(@PathVariable(value = "ID") String containerId) {
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ String response = srvClient.topContainer(containerId);
+ return new ResponseEntity<>(response, headers, HttpStatus.valueOf(200));
+ }
+
  /**
  * The method returns container logs
  *
@@ -152,11 +204,14 @@ ResponseEntity startContainer(@PathVariable(value = "ID") String containerId) {
  public @ResponseBody
  ResponseEntity logsContainer(@PathVariable(value = "ID") String containerId) {
  HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
  String response = srvClient.logsContainer(containerId);
  String replaceString = response.replace('\u0001', '\n');
  replaceString = replaceString.replace('�', ' ');
 
- return new ResponseEntity<>(replaceString, headers, HttpStatus.valueOf(201));
+ org.json.JSONObject result = new org.json.JSONObject();
+ result.put("logs",replaceString);
+ return new ResponseEntity<>(result.toString(), headers, HttpStatus.valueOf(201));
  }
 
  /**