Technical test for Schibsted

.gitignore

@@ -1,6 +1,7 @@
 .gradle
 /build/
 !gradle/wrapper/gradle-wrapper.jar
+out
 
 ### STS ###
 .apt_generated

src/main/java/com/scmspain/MsFcTechTestApplication.java

@@ -2,17 +2,19 @@
 
 import com.scmspain.configuration.InfrastructureConfiguration;
 import com.scmspain.configuration.TweetConfiguration;
+import com.scmspain.configuration.ValidatorConfiguration;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
 
 @Configuration
 @EnableAutoConfiguration
-@Import({TweetConfiguration.class, InfrastructureConfiguration.class})
+@Import({TweetConfiguration.class, InfrastructureConfiguration.class, ValidatorConfiguration.class})
 public class MsFcTechTestApplication {
+
     public static void main(String[] args) {
         SpringApplication.run(MsFcTechTestApplication.class, args);
     }
+
 }

src/main/java/com/scmspain/configuration/InfrastructureConfiguration.java

@@ -9,8 +9,11 @@
 
 @Configuration
 public class InfrastructureConfiguration {
-    @Bean @ExportMetricWriter
+
+    @Bean
+    @ExportMetricWriter
     public MetricWriter getMetricWriter(MBeanExporter exporter) {
         return new JmxMetricWriter(exporter);
     }
+
 }

src/main/java/com/scmspain/configuration/TweetConfiguration.java

@@ -1,7 +1,10 @@
 package com.scmspain.configuration;
 
 import com.scmspain.controller.TweetController;
+import com.scmspain.repository.ITweetRepository;
+import com.scmspain.repository.TweetRepository;
 import com.scmspain.services.TweetService;
+import com.scmspain.validators.TweetValidator;
 import org.springframework.boot.actuate.metrics.writer.MetricWriter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -10,13 +13,19 @@
 
 @Configuration
 public class TweetConfiguration {
-    @Bean
-    public TweetService getTweetService(EntityManager entityManager, MetricWriter metricWriter) {
-        return new TweetService(entityManager, metricWriter);
-    }
 
     @Bean
     public TweetController getTweetConfiguration(TweetService tweetService) {
         return new TweetController(tweetService);
     }
+
+    @Bean
+    public TweetRepository getTweetRepository(EntityManager entityManager) {
+        return new TweetRepository(entityManager);
+    }
+
+    @Bean
+    public TweetService getTweetService(ITweetRepository tweetRepository, MetricWriter metricWriter, TweetValidator tweetValidator) {
+        return new TweetService(tweetRepository, metricWriter, tweetValidator);
+    }
 }

src/main/java/com/scmspain/configuration/ValidatorConfiguration.java

@@ -0,0 +1,14 @@
+package com.scmspain.configuration;
+
+import com.scmspain.validators.TweetValidator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ValidatorConfiguration {
+
+    @Bean
+    public TweetValidator tweetValidator() {
+        return new TweetValidator();
+    }
+}

src/main/java/com/scmspain/controller/TweetController.java

@@ -1,17 +1,18 @@
 package com.scmspain.controller;
 
-import com.scmspain.controller.command.PublishTweetCommand;
+import com.scmspain.controller.command.TweetCommand;
 import com.scmspain.entities.Tweet;
+import com.scmspain.exception.NotFoundException;
 import com.scmspain.services.TweetService;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
-import static org.springframework.http.HttpStatus.BAD_REQUEST;
-import static org.springframework.http.HttpStatus.CREATED;
+import static org.springframework.http.HttpStatus.*;
 
 @RestController
 public class TweetController {
+
     private TweetService tweetService;
 
     public TweetController(TweetService tweetService) {
@@ -20,13 +21,24 @@ public TweetController(TweetService tweetService) {
 
     @GetMapping("/tweet")
     public List<Tweet> listAllTweets() {
-        return this.tweetService.listAllTweets();
+        return this.tweetService.listAllPublishedTweets();
     }
 
-    @PostMapping("/tweet")
+    @PostMapping(path = "/tweet", consumes = "application/json")
     @ResponseStatus(CREATED)
-    public void publishTweet(@RequestBody PublishTweetCommand publishTweetCommand) {
-        this.tweetService.publishTweet(publishTweetCommand.getPublisher(), publishTweetCommand.getTweet());
+    public void publishTweet(@RequestBody TweetCommand tweetCommand) {
+        this.tweetService.publishTweet(tweetCommand.getPublisher(), tweetCommand.getTweet());
+    }
+
+    @PostMapping("/discarded")
+    @ResponseStatus(NO_CONTENT)
+    public void discardTweet(@RequestBody TweetCommand tweetCommand) throws NotFoundException {
+        this.tweetService.discardTweet(tweetCommand.getTweet());
+    }
+
+    @GetMapping("/discarded")
+    public List<Tweet> listDiscardedTweets() {
+        return this.tweetService.listAllDiscardedTweets();
     }
 
     @ExceptionHandler(IllegalArgumentException.class)
@@ -38,4 +50,14 @@ public Object invalidArgumentException(IllegalArgumentException ex) {
             public String exceptionClass = ex.getClass().getSimpleName();
         };
     }
+
+    @ExceptionHandler(NotFoundException.class)
+    @ResponseStatus(NOT_FOUND)
+    @ResponseBody
+    public Object notFoundException(NotFoundException ex) {
+        return new Object() {
+            public String message = ex.getMessage();
+            public String exceptionClass = ex.getClass().getSimpleName();
+        };
+    }
 }

src/main/java/com/scmspain/controller/command/PublishTweetCommand.java → src/main/java/com/scmspain/controller/command/TweetCommand.java

@@ -1,6 +1,7 @@
 package com.scmspain.controller.command;
 
-public class PublishTweetCommand {
+public class TweetCommand {
+
     private String publisher;
     private String tweet;
 

src/main/java/com/scmspain/entities/Tweet.java

@@ -1,25 +1,51 @@
 package com.scmspain.entities;
 
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
+import java.util.Date;
+import java.util.Objects;
 
 @Entity
 public class Tweet {
+
     @Id
     @GeneratedValue
     private Long id;
+
     @Column(nullable = false)
     private String publisher;
-    @Column(nullable = false, length = 140)
+
+    @Column(nullable = false, length = 2048)
     private String tweet;
-    @Column (nullable=true)
+
+    @Column
     private Long pre2015MigrationStatus = 0L;
 
+    @JsonIgnore
+    @Column(nullable = false)
+    private Date publicationDate;
+
+    @JsonIgnore
+    @Column(nullable = false)
+    private Boolean discarded = Boolean.FALSE;
+
+    @JsonIgnore
+    @Column
+    private Date discardedDate;
+
     public Tweet() {
     }
 
+    public Tweet(String publisher, String text) {
+        this.publisher = publisher;
+        this.tweet = text;
+        this.publicationDate = new Date();
+    }
+
     public Long getId() {
         return id;
     }
@@ -52,4 +78,59 @@ public void setPre2015MigrationStatus(Long pre2015MigrationStatus) {
         this.pre2015MigrationStatus = pre2015MigrationStatus;
     }
 
+    public Date getPublicationDate() {
+        return publicationDate;
+    }
+
+    public void setPublicationDate(Date publicationDate) {
+        this.publicationDate = publicationDate;
+    }
+
+    public Boolean isDiscarded() {
+        return discarded;
+    }
+
+    public void setDiscarded(Boolean discarded) {
+        this.discarded = discarded;
+    }
+
+    public Date getDiscardedDate() {
+        return discardedDate;
+    }
+
+    public void setDiscardedDate(Date discardedDate) {
+        this.discardedDate = discardedDate;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        Tweet tweet1 = (Tweet) o;
+        return Objects.equals(id, tweet1.id) &&
+                Objects.equals(publisher, tweet1.publisher) &&
+                Objects.equals(tweet, tweet1.tweet) &&
+                Objects.equals(pre2015MigrationStatus, tweet1.pre2015MigrationStatus) &&
+                Objects.equals(publicationDate, tweet1.publicationDate) &&
+                Objects.equals(discarded, tweet1.discarded) &&
+                Objects.equals(discardedDate, tweet1.discardedDate);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, publisher, tweet, pre2015MigrationStatus, publicationDate, discarded, discardedDate);
+    }
+
+    @Override
+    public String toString() {
+        return "Tweet{" +
+                "id=" + id +
+                ", publisher='" + publisher + '\'' +
+                ", tweet='" + tweet + '\'' +
+                ", pre2015MigrationStatus=" + pre2015MigrationStatus +
+                ", publicationDate=" + publicationDate +
+                ", discarded=" + discarded +
+                ", discardedDate=" + discardedDate +
+                '}';
+    }
 }

src/main/java/com/scmspain/exception/NotFoundException.java

@@ -0,0 +1,16 @@
+package com.scmspain.exception;
+
+public class NotFoundException extends RuntimeException {
+
+    private String message;
+
+    public NotFoundException(String message) {
+        super();
+        this.message = message;
+    }
+
+    @Override
+    public String getMessage() {
+        return message;
+    }
+}

src/main/java/com/scmspain/repository/ITweetRepository.java

@@ -0,0 +1,18 @@
+package com.scmspain.repository;
+
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface ITweetRepository<T, U> {
+
+    void create(T tweet);
+
+    T get(U id);
+
+    List<T> getAll(Boolean discarded);
+
+    void discard(T tweet);
+
+}

src/main/java/com/scmspain/repository/TweetRepository.java

@@ -0,0 +1,53 @@
+package com.scmspain.repository;
+
+import com.scmspain.entities.Tweet;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Root;
+import java.util.List;
+
+public class TweetRepository implements ITweetRepository<Tweet, Long> {
+
+    private EntityManager entityManager;
+
+    public TweetRepository(EntityManager entityManager) {
+        this.entityManager = entityManager;
+    }
+
+    @Override
+    public void create(Tweet tweet) {
+        this.entityManager.persist(tweet);
+    }
+
+    @Override
+    public Tweet get(Long id) {
+        return this.entityManager.find(Tweet.class, id);
+    }
+
+    @Override
+    public List<Tweet> getAll(Boolean discarded) {
+        CriteriaBuilder criteriaBuilder = entityManager.getCriteriaBuilder();
+        CriteriaQuery criteriaQuery = criteriaBuilder.createQuery();
+        Root<Tweet> tweet = criteriaQuery.from(Tweet.class);
+        criteriaQuery.select(tweet);
+        criteriaQuery.where(
+                criteriaBuilder.notEqual(tweet.get("pre2015MigrationStatus"), 99),
+                criteriaBuilder.equal(tweet.get("discarded"), discarded)
+        );
+        if (Boolean.FALSE.equals(discarded)) {
+            criteriaQuery.orderBy(criteriaBuilder.desc(tweet.get("publicationDate")));
+        } else {
+            criteriaQuery.orderBy(criteriaBuilder.desc(tweet.get("discardedDate")));
+        }
+        Query query = entityManager.createQuery(criteriaQuery);
+        return query.getResultList();
+    }
+
+    @Override
+    public void discard(Tweet tweet) {
+        this.entityManager.merge(tweet);
+    }
+}