diff options
Diffstat (limited to 'test/regression/web_test/netx_web_delete_basic_test.c')
| -rw-r--r-- | test/regression/web_test/netx_web_delete_basic_test.c | 525 |
1 files changed, 525 insertions, 0 deletions
diff --git a/test/regression/web_test/netx_web_delete_basic_test.c b/test/regression/web_test/netx_web_delete_basic_test.c new file mode 100644 index 00000000..74c7db76 --- /dev/null +++ b/test/regression/web_test/netx_web_delete_basic_test.c @@ -0,0 +1,525 @@ +/* This case tests basic DELETE method. */ +#include "tx_api.h" +#include "nx_api.h" +#include "fx_api.h" +#include "nx_web_http_client.h" +#include "nx_web_http_server.h" + +extern void test_control_return(UINT); + +#if !defined(NX_DISABLE_IPV4) + +#include "test_device_cert.c" +#include "test_ca_cert.c" +#define ca_cert_der test_ca_cert_der +#define ca_cert_der_len test_ca_cert_der_len + +#define DEMO_STACK_SIZE 4096 + +/* Set up FileX and file memory resources. */ +static CHAR ram_disk_memory[4096]; +static FX_MEDIA ram_disk; +static UCHAR media_memory[4096]; + +static UCHAR server_stack[16000]; + +/* Define device drivers. */ +extern void _fx_ram_driver(FX_MEDIA *media_ptr); +extern void _nx_ram_network_driver_1024(NX_IP_DRIVER *driver_req_ptr); + +/* Set up the HTTP client global variables. */ + +#define CLIENT_PACKET_SIZE (NX_WEB_HTTP_CLIENT_MIN_PACKET_SIZE * 2) + +static TX_THREAD client_thread; +static NX_PACKET_POOL client_pool; +static NX_WEB_HTTP_CLIENT my_client; +static NX_IP client_ip; +static UINT error_counter; + +/* Set up the HTTP server global variables */ + +#define SERVER_PACKET_SIZE (NX_WEB_HTTP_SERVER_MIN_PACKET_SIZE * 2) + +static NX_WEB_HTTP_SERVER my_server; +static NX_PACKET_POOL server_pool; +static TX_THREAD server_thread; +static NX_IP server_ip; +static NXD_ADDRESS server_ip_address; +static UINT http_server_start = 0; +static UINT http_client_stop = 0; + +static void thread_client_entry(ULONG thread_input); +static void thread_server_entry(ULONG thread_input); + +#define HTTP_SERVER_ADDRESS IP_ADDRESS(1,2,3,4) +#define HTTP_CLIENT_ADDRESS IP_ADDRESS(1,2,3,5) + +#ifdef NX_WEB_HTTPS_ENABLE +static UINT https_server_start = 0; +static UINT https_client_stop = 0; +static UINT loop = 4; +extern const NX_SECURE_TLS_CRYPTO nx_crypto_tls_ciphers; +static CHAR crypto_metadata_server[20000 * NX_WEB_HTTP_SERVER_SESSION_MAX]; +static CHAR crypto_metadata_client[20000 * NX_WEB_HTTP_SERVER_SESSION_MAX]; +static UCHAR tls_packet_buffer[18500]; +static NX_SECURE_X509_CERT certificate; +static NX_SECURE_X509_CERT trusted_certificate; +static NX_SECURE_X509_CERT remote_certificate, remote_issuer; +static UCHAR remote_cert_buffer[2000]; +static UCHAR remote_issuer_buffer[2000]; +#else +static UINT loop = 2; +#endif /* NX_WEB_HTTPS_ENABLE */ + +#ifdef CTEST +VOID test_application_define(void *first_unused_memory) +#else +void netx_web_delete_basic_test_application_define(void *first_unused_memory) +#endif +{ +CHAR *pointer; +UINT status; + + + error_counter = 0; + + /* Setup the working pointer. */ + pointer = (CHAR *) first_unused_memory; + + /* Create a helper thread for the server. */ + tx_thread_create(&server_thread, "HTTP Server thread", thread_server_entry, 0, + pointer, DEMO_STACK_SIZE, + NX_WEB_HTTP_SERVER_PRIORITY, NX_WEB_HTTP_SERVER_PRIORITY, TX_NO_TIME_SLICE, TX_AUTO_START); + + pointer = pointer + DEMO_STACK_SIZE; + + /* Initialize the NetX system. */ + nx_system_initialize(); + + /* Create the server packet pool. */ + status = nx_packet_pool_create(&server_pool, "HTTP Server Packet Pool", SERVER_PACKET_SIZE, + pointer, SERVER_PACKET_SIZE*8); + pointer = pointer + SERVER_PACKET_SIZE * 8; + if (status) + error_counter++; + + /* Create an IP instance. */ + status = nx_ip_create(&server_ip, "HTTP Server IP", HTTP_SERVER_ADDRESS, + 0xFFFFFF00UL, &server_pool, _nx_ram_network_driver_1024, + pointer, 4096, 1); + pointer = pointer + 4096; + if (status) + error_counter++; + + /* Enable ARP and supply ARP cache memory for the server IP instance. */ + status = nx_arp_enable(&server_ip, (void *) pointer, 1024); + pointer = pointer + 1024; + if (status) + error_counter++; + + /* Enable TCP traffic. */ + status = nx_tcp_enable(&server_ip); + if (status) + error_counter++; + + /* Create the HTTP Client thread. */ + status = tx_thread_create(&client_thread, "HTTP Client", thread_client_entry, 0, + pointer, DEMO_STACK_SIZE, + NX_WEB_HTTP_SERVER_PRIORITY + 2, NX_WEB_HTTP_SERVER_PRIORITY + 2, TX_NO_TIME_SLICE, TX_AUTO_START); + pointer = pointer + DEMO_STACK_SIZE; + if (status) + error_counter++; + + /* Create the Client packet pool. */ + status = nx_packet_pool_create(&client_pool, "HTTP Client Packet Pool", CLIENT_PACKET_SIZE, + pointer, CLIENT_PACKET_SIZE*8); + pointer = pointer + CLIENT_PACKET_SIZE * 8; + if (status) + error_counter++; + + /* Create an IP instance. */ + status = nx_ip_create(&client_ip, "HTTP Client IP", HTTP_CLIENT_ADDRESS, + 0xFFFFFF00UL, &client_pool, _nx_ram_network_driver_1024, + pointer, 2048, 1); + pointer = pointer + 2048; + if (status) + error_counter++; + + status = nx_arp_enable(&client_ip, (void *) pointer, 1024); + pointer = pointer + 2048; + if (status) + error_counter++; + + /* Enable TCP traffic. */ + status = nx_tcp_enable(&client_ip); + if (status) + error_counter++; +} + +#ifdef NX_WEB_HTTPS_ENABLE +/* Define the TLS setup callback function. */ +static UINT tls_setup_callback(NX_WEB_HTTP_CLIENT *client_ptr, NX_SECURE_TLS_SESSION *tls_session) +{ +UINT status; + + + /* Initialize and create TLS session. */ + status = nx_secure_tls_session_create(tls_session, &nx_crypto_tls_ciphers, crypto_metadata_client, sizeof(crypto_metadata_client)); + + /* Check status. */ + if (status) + { + return(status); + } + + /* Allocate space for packet reassembly. */ + status = nx_secure_tls_session_packet_buffer_set(&(client_ptr -> nx_web_http_client_tls_session), tls_packet_buffer, sizeof(tls_packet_buffer)); + + /* Check status. */ + if (status) + { + return(status); + } + + /* Add a CA Certificate to our trusted store for verifying incoming server certificates. */ + nx_secure_x509_certificate_initialize(&trusted_certificate, ca_cert_der, ca_cert_der_len, NX_NULL, 0, NULL, 0, NX_SECURE_X509_KEY_TYPE_NONE); + nx_secure_tls_trusted_certificate_add(&(client_ptr -> nx_web_http_client_tls_session), &trusted_certificate); + + /* Need to allocate space for the certificate coming in from the remote host. */ + nx_secure_tls_remote_certificate_allocate(&(client_ptr -> nx_web_http_client_tls_session), &remote_certificate, remote_cert_buffer, sizeof(remote_cert_buffer)); + nx_secure_tls_remote_certificate_allocate(&(client_ptr -> nx_web_http_client_tls_session), &remote_issuer, remote_issuer_buffer, sizeof(remote_issuer_buffer)); + + return(NX_SUCCESS); +} +#endif /* NX_WEB_HTTPS_ENABLE */ + +void thread_client_entry(ULONG thread_input) +{ +UINT i; +UINT status; +NX_PACKET *send_packet; +NX_PACKET *recv_packet; + + + /* Give IP task and driver a chance to initialize the system. */ + tx_thread_sleep(NX_IP_PERIODIC_RATE); + + /* Set server IP address. */ + server_ip_address.nxd_ip_address.v4 = HTTP_SERVER_ADDRESS; + server_ip_address.nxd_ip_version = NX_IP_VERSION_V4; + + /* First loop test HTTP, second loop test HTTPS. */ + for (i = 0; i < loop ; i++) + { + if (i < 2) + { + + /* Wait HTTP server started. */ + while(!http_server_start) + { + tx_thread_sleep(NX_IP_PERIODIC_RATE); + } + } +#ifdef NX_WEB_HTTPS_ENABLE + else + { + + /* Wait HTTPS server started. */ + while(!https_server_start) + { + tx_thread_sleep(NX_IP_PERIODIC_RATE); + } + } +#endif /* NX_WEB_HTTPS_ENABLE */ + + /* Create an HTTP client instance. */ + status = nx_web_http_client_create(&my_client, "HTTP Client", &client_ip, &client_pool, 1536); + + /* Check status. */ + if (status) + error_counter++; + + /* Send PUT request. */ + if (i < 2) + { + + status = nx_web_http_client_put_start(&my_client, &server_ip_address, + NX_WEB_HTTP_SERVER_PORT, "/index.htm", + "www.abc.com", "name", "password", 103, NX_WAIT_FOREVER); + } +#ifdef NX_WEB_HTTPS_ENABLE + else + { + + status = nx_web_http_client_put_secure_start(&my_client, &server_ip_address, + NX_WEB_HTTPS_SERVER_PORT, "/index.htm", + "www.abc.com", "name", "password", 103, tls_setup_callback, NX_WAIT_FOREVER); + } +#endif /* NX_WEB_HTTPS_ENABLE */ + + /* Check status. */ + if (status) + error_counter++; + + /* Allocate a packet. */ + status = nx_web_http_client_request_packet_allocate(&my_client, &send_packet, NX_WAIT_FOREVER); + + /* Check status. */ + if (status) + error_counter++; + + /* Build a simple 103-byte HTML page. */ + nx_packet_data_append(send_packet, "<HTML>\r\n", 8, + &client_pool, NX_WAIT_FOREVER); + nx_packet_data_append(send_packet, + "<HEAD><TITLE>NetX HTTP Test</TITLE></HEAD>\r\n", 44, + &client_pool, NX_WAIT_FOREVER); + nx_packet_data_append(send_packet, "<BODY>\r\n", 8, + &client_pool, NX_WAIT_FOREVER); + nx_packet_data_append(send_packet, "<H1>Another NetX Test Page!</H1>\r\n", 25, + &client_pool, NX_WAIT_FOREVER); + nx_packet_data_append(send_packet, "</BODY>\r\n", 9, + &client_pool, NX_WAIT_FOREVER); + nx_packet_data_append(send_packet, "</HTML>\r\n", 9, + &client_pool, NX_WAIT_FOREVER); + + /* Complete the PUT by writing the total length. */ + status = nx_web_http_client_put_packet(&my_client, send_packet, 1 * NX_IP_PERIODIC_RATE); + if (status) + { + nx_packet_release(send_packet); + error_counter++; + } + + /* Get response from server. */ + while (1) + { + status = nx_web_http_client_response_body_get(&my_client, &recv_packet, 1 * NX_IP_PERIODIC_RATE); + + if (status) + break; + else + nx_packet_release(recv_packet); + } + + /* Check status. */ + if (status != NX_WEB_HTTP_GET_DONE) + error_counter++; + else + nx_packet_release(recv_packet); + + /* Send DELETE request. */ + if (i == 0) + { + status = nx_web_http_client_delete_start(&my_client, &server_ip_address, NX_WEB_HTTP_SERVER_PORT, + "/index.htm", "www.abc.com", NX_NULL, NX_NULL, + NX_WAIT_FOREVER); + } + else if (i == 1) + { + status = nx_web_http_client_delete_start_extended(&my_client, &server_ip_address, NX_WEB_HTTP_SERVER_PORT, + "/index.htm", 10, "www.abc.com", 11, NX_NULL, 0, NX_NULL, 0, + NX_WAIT_FOREVER); + } +#ifdef NX_WEB_HTTPS_ENABLE + else if (i == 2) + { + status = nx_web_http_client_delete_secure_start(&my_client, &server_ip_address, NX_WEB_HTTPS_SERVER_PORT, + "/index.htm", "www.abc.com", NX_NULL, NX_NULL, + tls_setup_callback, NX_WAIT_FOREVER); + } + else + { + status = nx_web_http_client_delete_secure_start_extended(&my_client, &server_ip_address, NX_WEB_HTTPS_SERVER_PORT, + "/index.htm", 10, "www.abc.com", 11, NX_NULL, 0, NX_NULL, 0, + tls_setup_callback, NX_WAIT_FOREVER); + } +#endif /* NX_WEB_HTTPS_ENABLE */ + + /* Check status. */ + if (status) + error_counter++; + + /* Get response from server. */ + while (1) + { + status = nx_web_http_client_response_body_get(&my_client, &recv_packet, 1 * NX_IP_PERIODIC_RATE); + + if (status) + break; + else + nx_packet_release(recv_packet); + } + + /* Check status. */ + if (status != NX_WEB_HTTP_GET_DONE) + error_counter++; + else + nx_packet_release(recv_packet); + + status = nx_web_http_client_delete(&my_client); + if (status) + error_counter++; + + /* Set the flag. */ + if (i == 1) + { + http_client_stop = 1; + } +#ifdef NX_WEB_HTTPS_ENABLE + else if (i == 3) + { + https_client_stop = 1; + } +#endif /* NX_WEB_HTTPS_ENABLE */ + } +} + + +/* Define the helper HTTP server thread. */ +void thread_server_entry(ULONG thread_input) +{ +UINT i; +UINT status; +UINT server_port = NX_WEB_HTTP_SERVER_PORT; + + + /* Print out test information banner. */ + printf("NetX Test: Web Delete Basic Test....................................."); + + /* Check for earlier error. */ + if(error_counter) + { + printf("ERROR!\n"); + test_control_return(1); + } + + fx_media_format(&ram_disk, + _fx_ram_driver, // Driver entry + ram_disk_memory, // RAM disk memory pointer + media_memory, // Media buffer pointer + sizeof(media_memory), // Media buffer size + "MY_RAM_DISK", // Volume Name + 1, // Number of FATs + 32, // Directory Entries + 0, // Hidden sectors + 256, // Total sectors + 512, // Sector size + 8, // Sectors per cluster + 1, // Heads + 1); // Sectors per track + + /* Open the RAM disk. */ + status = fx_media_open(&ram_disk, "RAM DISK", _fx_ram_driver, ram_disk_memory, media_memory, sizeof(media_memory)) ; + status += fx_file_create(&ram_disk, "TEST.TXT"); + if(status) + error_counter++; + + /* Give NetX a chance to initialize the system. */ + tx_thread_sleep(NX_IP_PERIODIC_RATE); + + /* First loop test HTTP, second loop test HTTPS. */ + for (i = 0; i < loop/2; i++) + { + + if (i == 1) + { + server_port = NX_WEB_HTTPS_SERVER_PORT; + } + + /* Create the HTTP Server. */ + status = nx_web_http_server_create(&my_server, "My HTTP Server", &server_ip, server_port, &ram_disk, + &server_stack, sizeof(server_stack), &server_pool, + NX_NULL, NX_NULL); + if (status) + error_counter++; + +#ifdef NX_WEB_HTTPS_ENABLE + /* Set TLS for HTTPS. */ + if (i == 1) + { + /* Initialize device certificate (used for all sessions in HTTPS server). */ + memset(&certificate, 0, sizeof(certificate)); + nx_secure_x509_certificate_initialize(&certificate, test_device_cert_der, test_device_cert_der_len, NX_NULL, 0, test_device_cert_key_der, test_device_cert_key_der_len, NX_SECURE_X509_KEY_TYPE_RSA_PKCS1_DER); + + /* Setup TLS session data for the TCP server. */ + status = nx_web_http_server_secure_configure(&my_server, &nx_crypto_tls_ciphers, + crypto_metadata_server, sizeof(crypto_metadata_server), tls_packet_buffer, sizeof(tls_packet_buffer), + &certificate, NX_NULL, 0, NX_NULL, 0, NX_NULL, 0); + if (status) + error_counter++; + } +#endif /* NX_WEB_HTTPS_ENABLE */ + + /* OK to start the HTTP Server. */ + status = nx_web_http_server_start(&my_server); + if (status) + error_counter++; + + /* Set the flag. */ + if (i == 0) + { + http_server_start = 1; + + /* Wait HTTP test finished. */ + while(!http_client_stop) + { + tx_thread_sleep(NX_IP_PERIODIC_RATE); + } + } +#ifdef NX_WEB_HTTPS_ENABLE + else + { + https_server_start = 1; + + /* Wait HTTPS test finished. */ + while(!https_client_stop) + { + tx_thread_sleep(NX_IP_PERIODIC_RATE); + } + } +#endif /* NX_WEB_HTTPS_ENABLE */ + + status = nx_web_http_server_delete(&my_server); + if (status) + error_counter++; + } + + /* Check packet pool. */ + if (server_pool.nx_packet_pool_available != server_pool.nx_packet_pool_total) + { + error_counter++; + } + + if (client_pool.nx_packet_pool_available != client_pool.nx_packet_pool_total) + { + error_counter++; + } + + if(error_counter) + { + printf("ERROR!\n"); + test_control_return(1); + } + else + { + printf("SUCCESS!\n"); + test_control_return(0); + } +} +#else + +#ifdef CTEST +VOID test_application_define(void *first_unused_memory) +#else +void netx_web_delete_basic_test_application_define(void *first_unused_memory) +#endif +{ + + /* Print out test information banner. */ + printf("NetX Test: Web Delete Basic Test.....................................N/A\n"); + + test_control_return(3); +} +#endif |