TeamPiped-mirror/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-08-14 23:51:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Simplify logic and fix typos.

Browse source
This commit is contained in:
FireMasterK 2021-08-14 00:03:20 +05:30
parent 3a6df12844
commit 46e449a5df
No known key found for this signature in database
GPG key ID: 49451E4482CC5BCD
2 changed files with 15 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

4
config.properties
View file

@ -7,8 +7,8 @@ HTTP_WORKERS: 2
# Proxy
PROXY_PART: https://pipedproxy-ams.kavin.rocks
# Ougoing HTTP proxy host:port (for both https and http requests)
HTTP_PROXY:
# Outgoing HTTP Proxy - eg: 127.0.0.1:8118
#HTTP_PROXY: 127.0.0.1:8118
# Captcha Parameters
CAPTCHA_BASE_URL: https://api.capmonster.cloud/

28
src/main/java/me/kavin/piped/consts/Constants.java
View file

@ -1,15 +1,15 @@
package me.kavin.piped.consts;
import java.io.FileReader;
import java.net.InetSocketAddress;
import java.net.ProxySelector;
import java.net.http.HttpClient;
import java.net.http.HttpClient.Builder;
import java.net.http.HttpClient.Redirect;
import java.net.http.HttpClient.Version;
import java.net.ProxySelector;
import java.net.InetSocketAddress;
import java.util.Properties;
import org.apache.commons.lang3.StringUtils;
import org.schabi.newpipe.extractor.NewPipe;
import org.schabi.newpipe.extractor.Page;
import org.schabi.newpipe.extractor.StreamingService;
@ -40,7 +40,6 @@ public class Constants {
public static final HttpClient h2client;
public static final HttpClient h2_no_redir_client;
// public static final HttpClient h3client = Http3ClientBuilder.newBuilder().followRedirects(Redirect.NORMAL).build();
public static final ObjectMapper mapper = new ObjectMapper().addMixIn(Page.class, PageMixin.class);
@ -64,18 +63,17 @@ public class Constants {
if (key.startsWith("hibernate"))
hibernateProperties.put(key, value);
});
Builder h2c = HttpClient.newBuilder().followRedirects(Redirect.NORMAL)
.version(Version.HTTP_2);
Builder h2nrc = HttpClient.newBuilder().followRedirects(Redirect.NEVER)
.version(Version.HTTP_2);
if (HTTP_PROXY != null && !HTTP_PROXY.trim().isEmpty()) {
String[] parts = HTTP_PROXY.split(":");
ProxySelector proxy = ProxySelector.of(new InetSocketAddress(parts[0], Integer.parseInt(parts[1])));
h2c = h2c.proxy(proxy);
h2nrc = h2nrc.proxy(proxy);
Builder builder = HttpClient.newBuilder().followRedirects(Redirect.NORMAL).version(Version.HTTP_2);
Builder builder_noredir = HttpClient.newBuilder().followRedirects(Redirect.NEVER).version(Version.HTTP_2);
if (HTTP_PROXY != null && HTTP_PROXY.contains(":")) {
String host = StringUtils.substringBefore(HTTP_PROXY, ":");
String port = StringUtils.substringAfter(HTTP_PROXY, ":");
InetSocketAddress sa = new InetSocketAddress(host, Integer.parseInt(port));
ProxySelector ps = ProxySelector.of(sa);
ProxySelector.setDefault(ps);
}
h2client = h2c.build();
h2_no_redir_client = h2nrc.build();
h2client = builder.build();
h2_no_redir_client = builder_noredir.build();
} catch (Exception e) {
throw new RuntimeException(e);
}