MovieCatlogResource.java
1.69 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package com.krunal.moviecatlogservice.resources;
import com.krunal.moviecatlogservice.model.CatlogItem;
import com.krunal.moviecatlogservice.model.Movie;
import com.krunal.moviecatlogservice.model.UserRating;
import com.netflix.discovery.DiscoveryClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.List;
import java.util.stream.Collectors;
@RestController
@RequestMapping("/catalog")
public class MovieCatlogResource {
@Autowired
private RestTemplate restTemplate;
/*@Autowired
private WebClient.Builder webClientBuilder;*/
@RequestMapping("/{userId}")
public List<CatlogItem> getCatlog(@PathVariable("userId") String userId) {
UserRating ratingList = restTemplate.getForObject("http://RATING-DATA-SERVICE/ratingsdata/user/" + userId, UserRating.class);
return ratingList.getRatings().stream().map(rating -> {
Movie movie = restTemplate.getForObject("http://MOVIE-INFO-SERVICE/movies/" + rating.getMovieId(), Movie.class);
/* Movie movie=webClientBuilder.build().get()
.uri("http://localhost:8081/movies/" + rating.getMovieId())
.retrieve()
.bodyToMono(Movie.class)
.block();*/
return new CatlogItem(movie.getName(), "cool", rating.getRating());
}).collect(Collectors.toList());
// return Collections.singletonList(new CatlogItem("Transformer","owesome movie",7));
}
}