20
20
use WrkFlow \ApiSdkBuilder \Events \SendingRequestEvent ;
21
21
use WrkFlow \ApiSdkBuilder \Exceptions \ResponseException ;
22
22
use WrkFlow \ApiSdkBuilder \Log \Contracts \LoggerContract ;
23
+ use WrkFlow \ApiSdkBuilder \Log \Entities \LoggerConfigEntity ;
23
24
use WrkFlow \ApiSdkBuilder \Responses \AbstractResponse ;
24
25
25
- class SendRequestAction
26
+ final class SendRequestAction
26
27
{
27
28
public function __construct (
28
29
private readonly BuildHeadersAction $ buildHeadersAction ,
@@ -73,6 +74,7 @@ public function execute(
73
74
api: $ api ,
74
75
dispatcher: $ dispatcher ,
75
76
logger: $ logger ,
77
+ loggerConfig: $ loggerConfig ,
76
78
request: $ request ,
77
79
responseClass: $ responseClass ,
78
80
requestId: $ id ,
@@ -87,6 +89,7 @@ public function execute(
87
89
responseClass: $ responseClass ,
88
90
dispatcher: $ dispatcher ,
89
91
logger: $ logger ,
92
+ loggerConfig: $ loggerConfig ,
90
93
id: $ id ,
91
94
request: $ request ,
92
95
timeStart: $ timeStart
@@ -96,11 +99,12 @@ public function execute(
96
99
/**
97
100
* @param class-string<AbstractResponse> $responseClass
98
101
*/
99
- protected function sendRequest (
102
+ private function sendRequest (
100
103
AbstractEnvironment $ environment ,
101
104
AbstractApi $ api ,
102
105
?EventDispatcherInterface $ dispatcher ,
103
106
?LoggerContract $ logger ,
107
+ LoggerConfigEntity $ loggerConfig ,
104
108
RequestInterface $ request ,
105
109
string $ responseClass ,
106
110
string $ requestId ,
@@ -130,13 +134,13 @@ protected function sendRequest(
130
134
requestDurationInSeconds: $ this ->getRequestDuration ($ timeStart )
131
135
);
132
136
$ dispatcher ?->dispatch($ event );
133
- $ logger ?->requestConnectionFailed($ event );
137
+ $ logger ?->requestConnectionFailed(event: $ event, config: $ loggerConfig );
134
138
135
139
throw $ exception ;
136
140
}
137
141
}
138
142
139
- protected function withBody (
143
+ private function withBody (
140
144
AbstractApi $ api ,
141
145
OptionsContract |StreamInterface |string |null $ body ,
142
146
RequestInterface $ request
@@ -154,7 +158,7 @@ protected function withBody(
154
158
return $ request ;
155
159
}
156
160
157
- protected function getRequestDuration (float $ timeStart ): float
161
+ private function getRequestDuration (float $ timeStart ): float
158
162
{
159
163
return (float ) microtime (true ) - $ timeStart ;
160
164
}
@@ -169,13 +173,14 @@ protected function getRequestDuration(float $timeStart): float
169
173
*
170
174
* @return TResponse
171
175
*/
172
- protected function handleResponse (
176
+ private function handleResponse (
173
177
AbstractApi $ api ,
174
178
ResponseInterface $ response ,
175
179
?int $ expectedResponseStatusCode ,
176
180
string $ responseClass ,
177
181
?EventDispatcherInterface $ dispatcher ,
178
182
?LoggerContract $ logger ,
183
+ LoggerConfigEntity $ loggerConfig ,
179
184
string $ id ,
180
185
RequestInterface $ request ,
181
186
float $ timeStart
@@ -199,7 +204,7 @@ protected function handleResponse(
199
204
requestDurationInSeconds: $ this ->getRequestDuration ($ timeStart )
200
205
);
201
206
$ dispatcher ?->dispatch($ event );
202
- $ logger ?->responseReceivedEvent($ event );
207
+ $ logger ?->responseReceivedEvent(event: $ event, config: $ loggerConfig );
203
208
204
209
return $ finalResponse ;
205
210
}
@@ -218,13 +223,13 @@ protected function handleResponse(
218
223
requestDurationInSeconds: $ this ->getRequestDuration ($ timeStart )
219
224
);
220
225
$ dispatcher ?->dispatch($ event );
221
- $ logger ?->requestFailed($ event );
226
+ $ logger ?->requestFailed(event: $ event, config: $ loggerConfig );
222
227
223
228
throw $ exception ;
224
229
}
225
230
}
226
231
227
- protected function buildRequest (
232
+ private function buildRequest (
228
233
AbstractEnvironment $ environment ,
229
234
AbstractApi $ api ,
230
235
array $ headers ,
0 commit comments