|
60 | 60 | import java.io.FileOutputStream; |
61 | 61 | import java.io.IOException; |
62 | 62 | import java.io.InputStream; |
| 63 | +import java.io.OutputStream; |
63 | 64 | import java.nio.charset.StandardCharsets; |
64 | 65 | import java.nio.file.Path; |
65 | 66 | import java.time.Instant; |
@@ -183,7 +184,6 @@ void testGetMessages() throws IOException { |
183 | 184 | messages.stream().map(V4Message::getMessageId).collect(Collectors.toList())); |
184 | 185 | } |
185 | 186 |
|
186 | | - |
187 | 187 | @Test |
188 | 188 | void testSearchMessages() throws IOException { |
189 | 189 | mockApiClient.onPost(V4_SEARCH_MESSAGES, |
@@ -238,71 +238,83 @@ void testSendWithStreamObjectCallsSendWithStreamId() { |
238 | 238 | @Test |
239 | 239 | void testSendPassingMessageInstanceToStreamId(@TempDir Path tmpDir) throws IOException { |
240 | 240 | Path tempFilePath = tmpDir.resolve("tempFile"); |
241 | | - IOUtils.write("test", new FileOutputStream(tempFilePath.toFile()), StandardCharsets.UTF_8); |
| 241 | + try (OutputStream out = new FileOutputStream(tempFilePath.toFile())) { |
| 242 | + IOUtils.write("test", out, StandardCharsets.UTF_8); |
| 243 | + } |
| 244 | + |
242 | 245 | mockApiClient.onPost(V4_STREAM_MESSAGE_CREATE.replace("{sid}", STREAM_ID), |
243 | 246 | JsonHelper.readFromClasspath("/message/send_message.json")); |
244 | 247 |
|
245 | | - InputStream inputStream = new FileInputStream(tempFilePath.toString()); |
246 | | - Message message = Message.builder() |
247 | | - .content(MESSAGE) |
248 | | - .addAttachment(inputStream, "test.png") |
249 | | - .build(); |
| 248 | + try (InputStream inputStream = new FileInputStream(tempFilePath.toString())) { |
| 249 | + Message message = Message.builder() |
| 250 | + .content(MESSAGE) |
| 251 | + .addAttachment(inputStream, "test.png") |
| 252 | + .build(); |
250 | 253 |
|
251 | | - final V4Message sentMessage = messageService.send(STREAM_ID, message); |
| 254 | + final V4Message sentMessage = messageService.send(STREAM_ID, message); |
252 | 255 |
|
253 | | - assertEquals(MESSAGE_ID, sentMessage.getMessageId()); |
254 | | - assertEquals("gXFV8vN37dNqjojYS_y2wX___o2KxfmUdA", sentMessage.getStream().getStreamId()); |
| 256 | + assertEquals(MESSAGE_ID, sentMessage.getMessageId()); |
| 257 | + assertEquals("gXFV8vN37dNqjojYS_y2wX___o2KxfmUdA", sentMessage.getStream().getStreamId()); |
| 258 | + } |
255 | 259 | } |
256 | 260 |
|
257 | 261 | @Test |
258 | 262 | void testSendPassingMessageInstanceToStream(@TempDir Path tmpDir) throws IOException { |
259 | 263 | Path tempFilePath = tmpDir.resolve("tempFile"); |
260 | | - IOUtils.write("test", new FileOutputStream(tempFilePath.toFile()), StandardCharsets.UTF_8); |
| 264 | + try (OutputStream out = new FileOutputStream(tempFilePath.toFile())) { |
| 265 | + IOUtils.write("test", out, StandardCharsets.UTF_8); |
| 266 | + } |
261 | 267 | mockApiClient.onPost(V4_STREAM_MESSAGE_CREATE.replace("{sid}", STREAM_ID), |
262 | 268 | JsonHelper.readFromClasspath("/message/send_message.json")); |
263 | 269 |
|
264 | | - InputStream inputStream = new FileInputStream(tempFilePath.toString()); |
265 | | - Message message = Message.builder() |
266 | | - .content(MESSAGE) |
267 | | - .addAttachment(inputStream, "test.png") |
268 | | - .build(); |
| 270 | + try (InputStream inputStream = new FileInputStream(tempFilePath.toString())) { |
| 271 | + Message message = Message.builder() |
| 272 | + .content(MESSAGE) |
| 273 | + .addAttachment(inputStream, "test.png") |
| 274 | + .build(); |
269 | 275 |
|
270 | | - final V4Message sentMessage = messageService.send(new V4Stream().streamId(STREAM_ID), message); |
| 276 | + final V4Message sentMessage = messageService.send(new V4Stream().streamId(STREAM_ID), message); |
271 | 277 |
|
272 | | - assertEquals(MESSAGE_ID, sentMessage.getMessageId()); |
273 | | - assertEquals("gXFV8vN37dNqjojYS_y2wX___o2KxfmUdA", sentMessage.getStream().getStreamId()); |
| 278 | + assertEquals(MESSAGE_ID, sentMessage.getMessageId()); |
| 279 | + assertEquals("gXFV8vN37dNqjojYS_y2wX___o2KxfmUdA", sentMessage.getStream().getStreamId()); |
| 280 | + } |
274 | 281 | } |
275 | 282 |
|
276 | 283 | @Test |
277 | 284 | void testSendPassingMessageInstanceToStreamWrongAttachmentName(@TempDir Path tmpDir) throws IOException { |
278 | 285 | Path tempFilePath = tmpDir.resolve("tempFile"); |
279 | | - IOUtils.write("test", new FileOutputStream(tempFilePath.toFile()), StandardCharsets.UTF_8); |
| 286 | + try (OutputStream out = new FileOutputStream(tempFilePath.toFile())) { |
| 287 | + IOUtils.write("test", out, StandardCharsets.UTF_8); |
| 288 | + } |
280 | 289 | mockApiClient.onPost(V4_STREAM_MESSAGE_CREATE.replace("{sid}", STREAM_ID), |
281 | 290 | JsonHelper.readFromClasspath("/message/send_message.json")); |
282 | 291 |
|
283 | | - InputStream inputStream = new FileInputStream(tempFilePath.toString()); |
284 | | - |
285 | | - assertThrows(MessageCreationException.class, |
286 | | - () -> { |
287 | | - final Message message = Message.builder() |
288 | | - .content(MESSAGE) |
289 | | - .addAttachment(inputStream, "wrong-name") |
290 | | - .build(); |
291 | | - messageService.send(new V4Stream().streamId(STREAM_ID), message); |
292 | | - }); |
| 292 | + try (InputStream inputStream = new FileInputStream(tempFilePath.toString())) { |
| 293 | + assertThrows(MessageCreationException.class, |
| 294 | + () -> { |
| 295 | + final Message message = Message.builder() |
| 296 | + .content(MESSAGE) |
| 297 | + .addAttachment(inputStream, "wrong-name") |
| 298 | + .build(); |
| 299 | + messageService.send(new V4Stream().streamId(STREAM_ID), message); |
| 300 | + }); |
| 301 | + } |
293 | 302 | } |
294 | 303 |
|
295 | 304 | @Test |
296 | 305 | void testMessageCreationFailed(@TempDir Path tmpDir) throws IOException { |
297 | 306 | Path tempFilePath = tmpDir.resolve("tempFile"); |
298 | | - IOUtils.write("test", new FileOutputStream(tempFilePath.toFile()), StandardCharsets.UTF_8); |
| 307 | + try (OutputStream out = new FileOutputStream(tempFilePath.toFile())) { |
| 308 | + IOUtils.write("test", out, StandardCharsets.UTF_8); |
| 309 | + } |
299 | 310 |
|
300 | | - InputStream inputStream = new FileInputStream(tempFilePath.toString()); |
301 | | - assertThrows(MessageCreationException.class, |
302 | | - () -> Message.builder() |
303 | | - .content(MESSAGE) |
304 | | - .addAttachment(inputStream, "test.png") |
305 | | - .data(new MockObject("wrong object")).build()); |
| 311 | + try (InputStream inputStream = new FileInputStream(tempFilePath.toString())) { |
| 312 | + assertThrows(MessageCreationException.class, |
| 313 | + () -> Message.builder() |
| 314 | + .content(MESSAGE) |
| 315 | + .addAttachment(inputStream, "test.png") |
| 316 | + .data(new MockObject("wrong object")).build()); |
| 317 | + } |
306 | 318 | } |
307 | 319 |
|
308 | 320 | @Test |
|
0 commit comments