FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
esp32_https_server/src/HTTPSConnection.cpp at master · bligeti/esp32_https_server · GitHub
bligeti
esp32_https_server
Repository navigation
Code
Pull requests
1
(1)
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
esp32_https_server
/
src
/
HTTPSConnection.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
113 lines (91 loc) · 3.26 KB
Breadcrumbs
esp32_https_server
/
src
/
HTTPSConnection.cpp
Copy path
File metadata and controls
113 lines (91 loc) · 3.26 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#
include
"
HTTPSConnection.hpp
"
namespace
httpsserver
{
HTTPSConnection::HTTPSConnection
(ResourceResolver * resResolver):
HTTPConnection
(resResolver) {
_ssl =
NULL
;
}
HTTPSConnection::~HTTPSConnection
() {
//
Close the socket
closeConnection
();
}
bool
HTTPSConnection::isSecure
() {
return
true
;
}
/*
*
* Initializes the connection from a server socket.
*
* The call WILL BLOCK if accept(serverSocketID) blocks. So use select() to check for that in advance.
*/
int
HTTPSConnection::initialize
(
int
serverSocketID,
esp_tls_cfg_server_t
* cfgSrv, HTTPHeaders *defaultHeaders) {
if
(_connectionState ==
STATE_UNDEFINED
) {
//
Let the base class connect the plain tcp socket
int
resSocket =
HTTPConnection::initialize
(serverSocketID, defaultHeaders);
HTTPS_LOGI
(
"
Cert len:%d, apn:%s
"
,cfgSrv->
servercert_bytes
,cfgSrv->
alpn_protos
[
0
]);
//
Build up SSL Connection context if the socket has been created successfully
if
(resSocket >=
0
) {
_ssl =
esp_tls_init
();
if
(!_ssl) {
HTTPS_LOGE
(
"
esp_tls_init failed. FID=%d
"
, resSocket);
return
-
1
;
}
int
res=
esp_tls_server_session_create
(cfgSrv,resSocket,_ssl);
if
(res !=
0
) {
HTTPS_LOGE
(
"
esp_tls_server_session_create failed. FID=%d, Error=%d
"
, resSocket, res);
}
else
{
return
resSocket;
}
}
else
{
HTTPS_LOGE
(
"
Could not accept() new connection. FID=%d
"
, resSocket);
}
_connectionState =
STATE_ERROR
;
_clientState =
CSTATE_ACTIVE
;
//
This will only be called if the connection could not be established and cleanup
//
variables like _ssl etc.
closeConnection
();
}
//
Error: The connection has already been established or could not be established
return
-
1
;
}
void
HTTPSConnection::closeConnection
() {
//
FIXME: Copy from HTTPConnection, could be done better probably
if
(_connectionState !=
STATE_ERROR
&& _connectionState !=
STATE_CLOSED
) {
//
First call to closeConnection - set the timestamp to calculate the timeout later on
if
(_connectionState !=
STATE_CLOSING
) {
_shutdownTS =
millis
();
}
//
Set the connection state to closing. We stay in closing as long as SSL has not been shutdown
//
correctly
_connectionState =
STATE_CLOSING
;
}
if
(
this
->
_wsHandler
!=
nullptr
) {
this
->
_wsHandler
->
onClose
();
}
//
Try to tear down SSL while we are in the _shutdownTS timeout period or if an error occurred
if
(_ssl) {
esp_tls_server_session_delete
(_ssl);
_ssl =
NULL
;
_connectionState =
STATE_ERROR
;
}
//
If SSL has been brought down, close the socket
if
(!_ssl) {
HTTPConnection::closeConnection
();
}
}
size_t
HTTPSConnection::writeBuffer
(byte* buffer,
size_t
length) {
return
esp_tls_conn_write
(_ssl,buffer,length);
//
SSL_write(_ssl, buffer, length);
}
size_t
HTTPSConnection::readBytesToBuffer
(byte* buffer,
size_t
length) {
int
ret =
esp_tls_conn_read
(_ssl, buffer, length);
if
(ret <
0
) {
//
HTTPS_LOGD("SSL_read error: %d", SSL_get_error(_ssl, ret));
HTTPS_LOGD
(
"
SSL_read error
"
);
}
return
ret;
}
size_t
HTTPSConnection::pendingByteCount
() {
return
esp_tls_get_bytes_avail
(_ssl);
}
bool
HTTPSConnection::canReadData
() {
return
HTTPConnection::canReadData
() || (
esp_tls_get_bytes_avail
(_ssl) >
0
);
}
}
/*
namespace httpsserver
*/
Back
|
FazBrowse Home
|
New Git URL