[MrFisherman]

Jak to zrobić w WebFlux żeby po operacji dodania itemu do bazy, automatycznie wysyłać taką informację do endpointu który zbiera wszystkie itemy z bazy? Chodzi o to że mam powiedzmy tabele songs, odpytuję endpoint /GET songs i zwraca mi TEXTEVENTVALUESTREAM i wszystkie elementy, teraz kiedy dodałbym item poprzez /POST songs chciałbym żeby w tamtej karcie przeglądarki pojawił się nowy item. Wiem, że to jest możliwe ale nie wiem jak się podpiąc pod insniejący stream? Może żeby reagował na jakiś event?

Mój kod:

@RestController
@RequestMapping("/songs")
public class SongController {

 private final SongRepository songRepository;

 public SongController(SongRepository songRepository) {
 this.songRepository = songRepository;
 }

 @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
 public Flux getAllSongs() {
 return Flux.interval(Duration.ofSeconds(1))
 .flatMap(x -> songRepository.findAll());
 }

 @PostMapping
 public Mono addSong(@RequestBody Song song) {
 return songRepository.save(song);
 }
}

Narazie odpytuje co sekundę ale wtedy mi zwraca za każdym razem całość (razem z nowym itemem) a nie dokłada nowy.

#webflux #flux #spring #programowaniereaktywne #java

[k.....g]

@MrFisherman: A może jakiś webhook który będzie zwracał taką wartość wszystkim subskrybentom?

[b0lec]

@MrFisherman: kumam chyba co chcesz zrobić - chcesz żeby Ci zwracało deltę a nie cały stream. Więc to co ty musiałbyś zrobić to na froncie trzymac se w cache całość danych a endponintem ciągnąć deltę (zmianę). Więc (koncepcyjnie) ja bym to widział tak:
1. Dodaj sobie endpoint getDeltaSongs - endpoint z logiką która zwraca te songi które zostały ostatnio dodane (czyli tą deltę) - różnicę względem całości
2. Zrobić cachowanie

[b0lec]

@MrFisherman: tu masz taki przykład jak to jest full reaktywnie https://kwonghung-yip.medium.com/a-demo-for-http-2-multiplexing-with-spring-webflux-netty-and-react-9a1a62d8fb61 z reactem i mongo, to tak jakby to zrobić w idealnym świecie :D

[MrFisherman]

@b0lec: dzięki za przykład, zaraz poczytam, właśbie mam Mongo i w przyszłości chciałem jeszcze React dołożyć więc dobrze się składa :D

[MrFisherman]

@b0lec: znalazłem jeszcze bardzo fajne rozwiązanie z czymś co nazywa się TailableCursor w Mongo vinsguru.com/mongo-db-tailable-cursor/