1
1
package net .dancier .dancer .chat .client ;
2
2
3
3
import io .netty .handler .logging .LogLevel ;
4
- import net .dancier .dancer .chat .dto .ChatDto ;
5
- import net .dancier .dancer .chat .dto .CreateChatDto ;
6
- import net .dancier .dancer .chat .dto .ChatsDto ;
7
- import net .dancier .dancer .chat .dto .MessagesDto ;
4
+ import net .dancier .dancer .chat .dto .*;
8
5
import org .slf4j .Logger ;
9
6
import org .slf4j .LoggerFactory ;
10
7
import org .springframework .beans .factory .annotation .Value ;
8
+ import org .springframework .boot .actuate .autoconfigure .metrics .MetricsProperties ;
9
+ import org .springframework .http .ResponseEntity ;
11
10
import org .springframework .http .client .reactive .ReactorClientHttpConnector ;
12
11
import org .springframework .stereotype .Service ;
13
12
import org .springframework .web .reactive .function .client .ExchangeFilterFunction ;
@@ -39,6 +38,7 @@ public void init() {
39
38
.create ()
40
39
.wiretap ("reactor.netty.http.client.HttpClient" ,
41
40
LogLevel .INFO , AdvancedByteBufFormat .TEXTUAL );
41
+
42
42
this .webClient = WebClient .builder ()
43
43
.baseUrl (host )
44
44
.clientConnector (new ReactorClientHttpConnector (httpClient ))
@@ -58,7 +58,7 @@ public ChatsDto getChats(UUID dancerId) {
58
58
.block ();
59
59
}
60
60
61
- public ChatDto createChat (CreateChatDto createChatDto ) {
61
+ public CreatedChatDto createChat (CreateChatDto createChatDto ) {
62
62
log .info ("now creating" );
63
63
return webClient .post ()
64
64
.uri (uriBuilder -> uriBuilder
@@ -67,7 +67,7 @@ public ChatDto createChat(CreateChatDto createChatDto) {
67
67
)
68
68
.body (Mono .just (createChatDto ), CreateChatDto .class )
69
69
.retrieve ()
70
- .bodyToMono (ChatDto .class )
70
+ .bodyToMono (CreatedChatDto .class )
71
71
.block ();
72
72
}
73
73
0 commit comments