Brewery/gravitymon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed hostname for min ssl buffer

Browse Source
This commit is contained in:
Magnus Persson 2022-02-04 16:22:14 +01:00
parent 838d062eea
commit 4bcacea9d7
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/pushtarget.cpp
View File

@ -199,6 +199,17 @@ void PushTarget::sendHttp(TemplatingEngine& engine, bool isSecure, int index) {
if (isSecure) { if (isSecure) {
Log.notice(F("PUSH: HTTP, SSL enabled without validation." CR)); Log.notice(F("PUSH: HTTP, SSL enabled without validation." CR));
wifiSecure.setInsecure(); wifiSecure.setInsecure();
String host = serverPath.substring(8); // remove the prefix or the probe will fail, it needs a pure host name.
int idx = host.indexOf("/");
if (idx!=-1)
host = host.substring(0, idx);
if (wifiSecure.probeMaxFragmentLength(host, 443, 512)) {
Log.notice(F("PUSH: HTTP server supports smaller SSL buffer." CR));
wifiSecure.setBufferSizes(512, 512);
}
httpSecure.begin(wifiSecure, serverPath); httpSecure.begin(wifiSecure, serverPath);
httpSecure.setTimeout(myHardwareConfig.getPushTimeout() * 1000); httpSecure.setTimeout(myHardwareConfig.getPushTimeout() * 1000);
@ -255,16 +266,22 @@ void PushTarget::sendMqtt(TemplatingEngine& engine, bool isSecure) {
#endif #endif
MQTTClient mqtt(512); MQTTClient mqtt(512);
String url = myConfig.getMqttUrl(); String host = myConfig.getMqttUrl();
String doc = engine.create(TemplatingEngine::TEMPLATE_MQTT); String doc = engine.create(TemplatingEngine::TEMPLATE_MQTT);
int port = myConfig.getMqttPort(); int port = myConfig.getMqttPort();
if (myConfig.isMqttSSL()) { if (myConfig.isMqttSSL()) {
Log.notice(F("PUSH: MQTT, SSL enabled without validation." CR)); Log.notice(F("PUSH: MQTT, SSL enabled without validation." CR));
wifiSecure.setInsecure(); wifiSecure.setInsecure();
mqtt.begin(url.c_str(), port, wifiSecure);
if (wifiSecure.probeMaxFragmentLength(host, port, 512)) {
Log.notice(F("PUSH: MQTT server supports smaller SSL buffer." CR));
wifiSecure.setBufferSizes(512, 512);
}
mqtt.begin(host.c_str(), port, wifiSecure);
} else { } else {
mqtt.begin(myConfig.getMqttUrl(), port, wifi); mqtt.begin(host.c_str(), port, wifi);
} }
mqtt.connect(myConfig.getMDNS(), myConfig.getMqttUser(), mqtt.connect(myConfig.getMDNS(), myConfig.getMqttUser(),