-
Notifications
You must be signed in to change notification settings - Fork 24
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Tom Blum trinitus01@googlemail.com
- Loading branch information
1 parent
4b20d7f
commit 92bd0d0
Showing
1 changed file
with
127 additions
and
127 deletions.
There are no files selected for viewing
254 changes: 127 additions & 127 deletions
254
.../smarthomej/binding/notificationsforfiretv/internal/NotificationsForFireTVConnection.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,127 +1,127 @@ | ||
| /** | ||
| * Copyright (c) 2021-2023 Contributors to the SmartHome/J project | ||
| * | ||
| * See the NOTICE file(s) distributed with this work for additional | ||
| * information. | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Eclipse Public License 2.0 which is available at | ||
| * http://www.eclipse.org/legal/epl-2.0 | ||
| * | ||
| * SPDX-License-Identifier: EPL-2.0 | ||
| */ | ||
| package org.smarthomej.binding.notificationsforfiretv.internal; | ||
|
|
||
| import java.io.File; | ||
| import java.io.FileNotFoundException; | ||
| import java.io.IOException; | ||
| import java.net.HttpURLConnection; | ||
| import java.net.URI; | ||
| import java.net.http.HttpClient; | ||
| import java.net.http.HttpRequest; | ||
| import java.net.http.HttpRequest.BodyPublisher; | ||
| import java.net.http.HttpRequest.BodyPublishers; | ||
| import java.net.http.HttpResponse; | ||
| import java.net.http.HttpResponse.BodyHandlers; | ||
| import java.nio.charset.StandardCharsets; | ||
| import java.nio.file.Files; | ||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.UUID; | ||
|
|
||
| import org.eclipse.jdt.annotation.NonNullByDefault; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| /** | ||
| * | ||
| * @author Tom Blum - Initial contribution | ||
| */ | ||
| @NonNullByDefault | ||
| public class NotificationsForFireTVConnection { | ||
|
|
||
| private static final String PROTOCOL = "http"; | ||
| private static final String LINE = "\r\n"; | ||
| private static final String QUOTE = "\""; | ||
|
|
||
| private URI uri; | ||
| private String boundary; | ||
| private HttpClient httpClient; | ||
| private List<byte[]> byteArrays = new ArrayList<>(); | ||
|
|
||
| private final Logger logger = LoggerFactory.getLogger(NotificationsForFireTVConnection.class); | ||
|
|
||
| /** | ||
| * This constructor initializes a new HTTP POST request with content | ||
| * type is set to multipart/form-data | ||
| * | ||
| * @param hostname device IP address or a FQDN | ||
| * @param port application port | ||
| * @throws IOException | ||
| */ | ||
| public NotificationsForFireTVConnection(String hostname, int port) throws IOException { | ||
| uri = URI.create(PROTOCOL + "://" + hostname + ":" + port); | ||
| boundary = UUID.randomUUID().toString(); | ||
| httpClient = HttpClient.newBuilder().build(); | ||
| } | ||
|
|
||
| /** | ||
| * Adds a form field to the request | ||
| * | ||
| * @param name field name | ||
| * @param value field value | ||
| */ | ||
| public void addFormField(String name, String value) { | ||
| byteArrays.add( | ||
| ("--" + boundary + LINE + "Content-Disposition: form-data; name=").getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add((QUOTE + name + QUOTE + LINE + LINE + value + LINE).getBytes(StandardCharsets.UTF_8)); | ||
| } | ||
|
|
||
| /** | ||
| * Adds a upload file section to the request | ||
| * | ||
| * @param name field name | ||
| * @param file file value | ||
| * @throws IOException | ||
| */ | ||
| public void addFilePart(String name, File file) throws IOException { | ||
| if (!file.exists()) { | ||
| throw new FileNotFoundException("File not found: " + file.getPath()); | ||
| } | ||
|
|
||
| byteArrays.add( | ||
| ("--" + boundary + LINE + "Content-Disposition: form-data; name=").getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add((QUOTE + name + QUOTE + "; filename=" + QUOTE + file.toPath().getFileName() + QUOTE + LINE | ||
| + "Content-Type: application/octet-stream" + LINE + LINE).getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add(Files.readAllBytes(file.toPath())); | ||
| byteArrays.add(LINE.getBytes(StandardCharsets.UTF_8)); | ||
| } | ||
|
|
||
| /** | ||
| * Completes the request and receives response from the server. | ||
| * | ||
| * @return String as response in case the server returned status OK, | ||
| * otherwise an exception is thrown. | ||
| * @throws IOException | ||
| * @throws InterruptedException | ||
| */ | ||
| public String send() throws IOException, InterruptedException { | ||
| byteArrays.add(("--" + boundary + "--").getBytes(StandardCharsets.UTF_8)); | ||
|
|
||
| int length = 0; | ||
| for (byte[] bytes : byteArrays) { | ||
| length += bytes.length; | ||
| } | ||
|
|
||
| BodyPublisher bodyPublisher = BodyPublishers.fromPublisher(BodyPublishers.ofByteArrays(byteArrays), length); | ||
| HttpRequest httpRequest = HttpRequest.newBuilder() | ||
| .header("Content-Type", "multipart/form-data;boundary=" + boundary).POST(bodyPublisher).uri(uri) | ||
| .build(); | ||
| HttpResponse<String> response = httpClient.send(httpRequest, BodyHandlers.ofString()); | ||
| if (response.statusCode() == HttpURLConnection.HTTP_OK) { | ||
| return response.body(); | ||
| } else { | ||
| throw new IOException("Unable to connect to server: " + response.statusCode()); | ||
| } | ||
| } | ||
| } | ||
| /** | ||
| * Copyright (c) 2021-2023 Contributors to the SmartHome/J project | ||
| * | ||
| * See the NOTICE file(s) distributed with this work for additional | ||
| * information. | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Eclipse Public License 2.0 which is available at | ||
| * http://www.eclipse.org/legal/epl-2.0 | ||
| * | ||
| * SPDX-License-Identifier: EPL-2.0 | ||
| */ | ||
| package org.smarthomej.binding.notificationsforfiretv.internal; | ||
|
|
||
| import java.io.File; | ||
| import java.io.FileNotFoundException; | ||
| import java.io.IOException; | ||
| import java.net.HttpURLConnection; | ||
| import java.net.URI; | ||
| import java.net.http.HttpClient; | ||
| import java.net.http.HttpRequest; | ||
| import java.net.http.HttpRequest.BodyPublisher; | ||
| import java.net.http.HttpRequest.BodyPublishers; | ||
| import java.net.http.HttpResponse; | ||
| import java.net.http.HttpResponse.BodyHandlers; | ||
| import java.nio.charset.StandardCharsets; | ||
| import java.nio.file.Files; | ||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.UUID; | ||
|
|
||
| import org.eclipse.jdt.annotation.NonNullByDefault; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| /** | ||
| * | ||
| * @author Tom Blum - Initial contribution | ||
| */ | ||
| @NonNullByDefault | ||
| public class NotificationsForFireTVConnection { | ||
|
|
||
| private static final String PROTOCOL = "http"; | ||
| private static final String LINE = "\r\n"; | ||
| private static final String QUOTE = "\""; | ||
|
|
||
| private URI uri; | ||
| private String boundary; | ||
| private HttpClient httpClient; | ||
| private List<byte[]> byteArrays = new ArrayList<>(); | ||
|
|
||
| private final Logger logger = LoggerFactory.getLogger(NotificationsForFireTVConnection.class); | ||
|
|
||
| /** | ||
| * This constructor initializes a new HTTP POST request with content | ||
| * type is set to multipart/form-data | ||
| * | ||
| * @param hostname device IP address or a FQDN | ||
| * @param port application port | ||
| * @throws IOException | ||
| */ | ||
| public NotificationsForFireTVConnection(String hostname, int port) throws IOException { | ||
| uri = URI.create(PROTOCOL + "://" + hostname + ":" + port); | ||
| boundary = UUID.randomUUID().toString(); | ||
| httpClient = HttpClient.newBuilder().build(); | ||
| } | ||
|
|
||
| /** | ||
| * Adds a form field to the request | ||
| * | ||
| * @param name field name | ||
| * @param value field value | ||
| */ | ||
| public void addFormField(String name, String value) { | ||
| byteArrays.add( | ||
| ("--" + boundary + LINE + "Content-Disposition: form-data; name=").getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add((QUOTE + name + QUOTE + LINE + LINE + value + LINE).getBytes(StandardCharsets.UTF_8)); | ||
| } | ||
|
|
||
| /** | ||
| * Adds a upload file section to the request | ||
| * | ||
| * @param name field name | ||
| * @param file file value | ||
| * @throws IOException | ||
| */ | ||
| public void addFilePart(String name, File file) throws IOException { | ||
| if (!file.exists()) { | ||
| throw new FileNotFoundException("File not found: " + file.getPath()); | ||
| } | ||
|
|
||
| byteArrays.add( | ||
| ("--" + boundary + LINE + "Content-Disposition: form-data; name=").getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add((QUOTE + name + QUOTE + "; filename=" + QUOTE + file.toPath().getFileName() + QUOTE + LINE | ||
| + "Content-Type: application/octet-stream" + LINE + LINE).getBytes(StandardCharsets.UTF_8)); | ||
| byteArrays.add(Files.readAllBytes(file.toPath())); | ||
| byteArrays.add(LINE.getBytes(StandardCharsets.UTF_8)); | ||
| } | ||
|
|
||
| /** | ||
| * Completes the request and receives response from the server. | ||
| * | ||
| * @return String as response in case the server returned status OK, | ||
| * otherwise an exception is thrown. | ||
| * @throws IOException | ||
| * @throws InterruptedException | ||
| */ | ||
| public String send() throws IOException, InterruptedException { | ||
| byteArrays.add(("--" + boundary + "--").getBytes(StandardCharsets.UTF_8)); | ||
|
|
||
| int length = 0; | ||
| for (byte[] bytes : byteArrays) { | ||
| length += bytes.length; | ||
| } | ||
|
|
||
| BodyPublisher bodyPublisher = BodyPublishers.fromPublisher(BodyPublishers.ofByteArrays(byteArrays), length); | ||
| HttpRequest httpRequest = HttpRequest.newBuilder() | ||
| .header("Content-Type", "multipart/form-data;boundary=" + boundary).POST(bodyPublisher).uri(uri) | ||
| .build(); | ||
| HttpResponse<String> response = httpClient.send(httpRequest, BodyHandlers.ofString()); | ||
| if (response.statusCode() == HttpURLConnection.HTTP_OK) { | ||
| return response.body(); | ||
| } else { | ||
| throw new IOException("Unable to connect to server: " + response.statusCode()); | ||
| } | ||
| } | ||
| } |