123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533 |
- #include <http_client.h>
- #include <aos/kernel.h>
- #include <aos/debug.h>
- #define TAG "https_example"
- static char ca_crt_rsa[] = {
- "-----BEGIN CERTIFICATE-----\r\n"
- "MIIEkjCCA3qgAwIBAgIQCgFBQgAAAVOFc2oLheynCDANBgkqhkiG9w0BAQsFADA/\r\n"
- "MSQwIgYDVQQKExtEaWdpdGFsIFNpZ25hdHVyZSBUcnVzdCBDby4xFzAVBgNVBAMT\r\n"
- "DkRTVCBSb290IENBIFgzMB4XDTE2MDMxNzE2NDA0NloXDTIxMDMxNzE2NDA0Nlow\r\n"
- "SjELMAkGA1UEBhMCVVMxFjAUBgNVBAoTDUxldCdzIEVuY3J5cHQxIzAhBgNVBAMT\r\n"
- "GkxldCdzIEVuY3J5cHQgQXV0aG9yaXR5IFgzMIIBIjANBgkqhkiG9w0BAQEFAAOC\r\n"
- "AQ8AMIIBCgKCAQEAnNMM8FrlLke3cl03g7NoYzDq1zUmGSXhvb418XCSL7e4S0EF\r\n"
- "q6meNQhY7LEqxGiHC6PjdeTm86dicbp5gWAf15Gan/PQeGdxyGkOlZHP/uaZ6WA8\r\n"
- "SMx+yk13EiSdRxta67nsHjcAHJyse6cF6s5K671B5TaYucv9bTyWaN8jKkKQDIZ0\r\n"
- "Z8h/pZq4UmEUEz9l6YKHy9v6Dlb2honzhT+Xhq+w3Brvaw2VFn3EK6BlspkENnWA\r\n"
- "a6xK8xuQSXgvopZPKiAlKQTGdMDQMc2PMTiVFrqoM7hD8bEfwzB/onkxEz0tNvjj\r\n"
- "/PIzark5McWvxI0NHWQWM6r6hCm21AvA2H3DkwIDAQABo4IBfTCCAXkwEgYDVR0T\r\n"
- "AQH/BAgwBgEB/wIBADAOBgNVHQ8BAf8EBAMCAYYwfwYIKwYBBQUHAQEEczBxMDIG\r\n"
- "CCsGAQUFBzABhiZodHRwOi8vaXNyZy50cnVzdGlkLm9jc3AuaWRlbnRydXN0LmNv\r\n"
- "bTA7BggrBgEFBQcwAoYvaHR0cDovL2FwcHMuaWRlbnRydXN0LmNvbS9yb290cy9k\r\n"
- "c3Ryb290Y2F4My5wN2MwHwYDVR0jBBgwFoAUxKexpHsscfrb4UuQdf/EFWCFiRAw\r\n"
- "VAYDVR0gBE0wSzAIBgZngQwBAgEwPwYLKwYBBAGC3xMBAQEwMDAuBggrBgEFBQcC\r\n"
- "ARYiaHR0cDovL2Nwcy5yb290LXgxLmxldHNlbmNyeXB0Lm9yZzA8BgNVHR8ENTAz\r\n"
- "MDGgL6AthitodHRwOi8vY3JsLmlkZW50cnVzdC5jb20vRFNUUk9PVENBWDNDUkwu\r\n"
- "Y3JsMB0GA1UdDgQWBBSoSmpjBH3duubRObemRWXv86jsoTANBgkqhkiG9w0BAQsF\r\n"
- "AAOCAQEA3TPXEfNjWDjdGBX7CVW+dla5cEilaUcne8IkCJLxWh9KEik3JHRRHGJo\r\n"
- "uM2VcGfl96S8TihRzZvoroed6ti6WqEBmtzw3Wodatg+VyOeph4EYpr/1wXKtx8/\r\n"
- "wApIvJSwtmVi4MFU5aMqrSDE6ea73Mj2tcMyo5jMd6jmeWUHK8so/joWUoHOUgwu\r\n"
- "X4Po1QYz+3dszkDqMp4fklxBwXRsW10KXzPMTZ+sOPAveyxindmjkW8lGy+QsRlG\r\n"
- "PfZ+G6Z6h7mjem0Y+iWlkYcV4PIWL1iwBi8saCbGS5jN2p8M+X+Q7UNKEkROb3N6\r\n"
- "KOqkqm57TH2H3eDJAkSnh6/DNFu0Qg==\r\n"
- "-----END CERTIFICATE-----\r\n"
- " "
- };
- #define MAX_HTTP_RECV_BUFFER 512
- static int e_count = 0;
- int _http_event_handler(http_client_event_t *evt)
- {
- switch(evt->event_id) {
- case HTTP_EVENT_ERROR:
- LOGD(TAG, "HTTP_EVENT_ERROR");
- break;
- case HTTP_EVENT_ON_CONNECTED:
- LOGD(TAG, "HTTP_EVENT_ON_CONNECTED");
- break;
- case HTTP_EVENT_HEADER_SENT:
- LOGD(TAG, "HTTP_EVENT_HEADER_SENT");
- break;
- case HTTP_EVENT_ON_HEADER:
- LOGD(TAG, "HTTP_EVENT_ON_HEADER, key=%s, value=%s", evt->header_key, evt->header_value);
- break;
- case HTTP_EVENT_ON_DATA:
- LOGD(TAG, "HTTP_EVENT_ON_DATA, len=%d", evt->data_len);
- if (!http_client_is_chunked_response(evt->client)) {
- // Write out data
- // printf("%.*s", evt->data_len, (char*)evt->data);
- }
- break;
- case HTTP_EVENT_ON_FINISH:
- LOGD(TAG, "HTTP_EVENT_ON_FINISH");
- break;
- case HTTP_EVENT_DISCONNECTED:
- LOGD(TAG, "HTTP_EVENT_DISCONNECTED");
- break;
- }
- return 0;
- }
- static void http_rest_with_url()
- {
- http_client_config_t config = {
- .url = "http://httpbin.org/get",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- // GET
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP GET Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP GET request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- // POST
- const char *post_data = "field1=value1&field2=value2";
- http_client_set_url(client, "http://httpbin.org/post");
- http_client_set_method(client, HTTP_METHOD_POST);
- http_client_set_post_field(client, post_data, strlen(post_data));
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP POST Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP POST request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //PUT
- http_client_set_url(client, "http://httpbin.org/put");
- http_client_set_method(client, HTTP_METHOD_PUT);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP PUT Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP PUT request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //PATCH
- http_client_set_url(client, "http://httpbin.org/patch");
- http_client_set_method(client, HTTP_METHOD_PATCH);
- http_client_set_post_field(client, NULL, 0);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP PATCH Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP PATCH request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //DELETE
- http_client_set_url(client, "http://httpbin.org/delete");
- http_client_set_method(client, HTTP_METHOD_DELETE);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP DELETE Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP DELETE request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //HEAD
- http_client_set_url(client, "http://httpbin.org/head");
- http_client_set_method(client, HTTP_METHOD_HEAD);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP HEAD Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP HEAD request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_rest_with_hostname_path()
- {
- http_client_config_t config = {
- .host = "httpbin.org",
- .path = "/get",
- .transport_type = HTTP_TRANSPORT_OVER_TCP,
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- // GET
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP GET Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP GET request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- // POST
- const char *post_data = "field1=value1&field2=value2";
- http_client_set_url(client, "/post");
- http_client_set_method(client, HTTP_METHOD_POST);
- http_client_set_post_field(client, post_data, strlen(post_data));
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP POST Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP POST request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //PUT
- http_client_set_url(client, "/put");
- http_client_set_method(client, HTTP_METHOD_PUT);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP PUT Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP PUT request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //PATCH
- http_client_set_url(client, "/patch");
- http_client_set_method(client, HTTP_METHOD_PATCH);
- http_client_set_post_field(client, NULL, 0);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP PATCH Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP PATCH request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //DELETE
- http_client_set_url(client, "/delete");
- http_client_set_method(client, HTTP_METHOD_DELETE);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP DELETE Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP DELETE request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- //HEAD
- http_client_set_url(client, "/get");
- http_client_set_method(client, HTTP_METHOD_HEAD);
- err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP HEAD Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "HTTP HEAD request failed: 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_auth_basic()
- {
- http_client_config_t config = {
- .url = "http://user:passwd@httpbin.org/basic-auth/user/passwd",
- .event_handler = _http_event_handler,
- .auth_type = HTTP_AUTH_TYPE_BASIC,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP Basic Auth Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_auth_basic_redirect()
- {
- http_client_config_t config = {
- .url = "http://user:passwd@httpbin.org/basic-auth/user/passwd",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP Basic Auth redirect Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_auth_digest()
- {
- http_client_config_t config = {
- .url = "http://user:passwd@httpbin.org/digest-auth/auth/user/passwd/MD5/never",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP Digest Auth Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void https_with_url()
- {
- http_client_config_t config = {
- .url = "https://www.howsmyssl.com",
- .event_handler = _http_event_handler,
- .cert_pem = ca_crt_rsa,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTPS Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void https_with_hostname_path()
- {
- http_client_config_t config = {
- .host = "www.howsmyssl.com",
- .path = "/",
- .transport_type = HTTP_TRANSPORT_OVER_SSL,
- .event_handler = _http_event_handler,
- .cert_pem = ca_crt_rsa,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTPS Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_relative_redirect()
- {
- http_client_config_t config = {
- .url = "http://httpbin.org/relative-redirect/3",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP Relative path redirect Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_absolute_redirect()
- {
- http_client_config_t config = {
- .url = "http://httpbin.org/absolute-redirect/3",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP Absolute path redirect Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_redirect_to_https()
- {
- http_client_config_t config = {
- .url = "http://httpbin.org/redirect-to?url=https%3A%2F%2Fwww.howsmyssl.com",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP redirect to HTTPS Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_download_chunk()
- {
- http_client_config_t config = {
- .url = "http://httpbin.org/stream-bytes/8912",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err = http_client_perform(client);
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTP chunk encoding Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- static void http_perform_as_stream_reader()
- {
- char *buffer = aos_malloc(MAX_HTTP_RECV_BUFFER + 1);
- if (buffer == NULL) {
- LOGE(TAG, "Cannot aos_malloc http receive buffer");
- return;
- }
- http_client_config_t config = {
- .url = "http://httpbin.org/get",
- .event_handler = _http_event_handler,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err;
- if ((err = http_client_open(client, 0)) != HTTP_CLI_OK) {
- LOGE(TAG, "Failed to open HTTP connection: 0x%x @#@@@@@@", (err));
- aos_free(buffer);
- return;
- }
- int content_length = http_client_fetch_headers(client);
- int total_read_len = 0, read_len;
- if (total_read_len < content_length && content_length <= MAX_HTTP_RECV_BUFFER) {
- read_len = http_client_read(client, buffer, content_length);
- if (read_len <= 0) {
- LOGE(TAG, "Error read data");
- }
- buffer[read_len] = 0;
- LOGD(TAG, "read_len = %d", read_len);
- }
- LOGI(TAG, "HTTP Stream reader Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- http_client_close(client);
- http_client_cleanup(client);
- aos_free(buffer);
- }
- static void https_async()
- {
- http_client_config_t config = {
- .url = "https://postman-echo.com/post",
- .event_handler = _http_event_handler,
- .is_async = true,
- .timeout_ms = 5000,
- };
- http_client_handle_t client = http_client_init(&config);
- http_errors_t err;
- const char *post_data = "Using a Palantír requires a person with great strength of will and wisdom. The Palantíri were meant to "
- "be used by the Dúnedain to communicate throughout the Realms in Exile. During the War of the Ring, "
- "the Palantíri were used by many individuals. Sauron used the Ithil-stone to take advantage of the users "
- "of the other two stones, the Orthanc-stone and Anor-stone, but was also susceptible to deception himself.";
- http_client_set_method(client, HTTP_METHOD_POST);
- http_client_set_post_field(client, post_data, strlen(post_data));
- while (1) {
- err = http_client_perform(client);
- if (err != EAGAIN) {
- break;
- }
- }
- if (err == HTTP_CLI_OK) {
- LOGI(TAG, "HTTPS Status = %d, content_length = %d \r\n",
- http_client_get_status_code(client),
- http_client_get_content_length(client));
- } else {
- LOGE(TAG, "Error perform http request 0x%x @#@@@@@@", (err));
- e_count ++;
- }
- http_client_cleanup(client);
- }
- void test_https(void)
- {
- ca_crt_rsa[sizeof(ca_crt_rsa) - 1] = 0;
- http_rest_with_url();
- http_rest_with_hostname_path();
- http_auth_basic();
- http_auth_basic_redirect();
- http_auth_digest();
- http_relative_redirect();
- http_absolute_redirect();
- https_with_url();
- https_with_hostname_path();
- http_redirect_to_https();
- http_download_chunk();
- http_perform_as_stream_reader();
- https_async();
- LOGI(TAG, "Finish http example [%d]", e_count);
- }
|