Function TEST

net/http/test/client_function_test.cpp:74–141

};

TEST(http_client, get) {
    system("mkdir -p /tmp/ease_ut/http_test/");
    system("echo \"this is a http_client request body text for socket stream\" > /tmp/ease_ut/http_test/ease-httpclient-gettestfile");
    auto tcpserver = new_tcp_socket_server();
    tcpserver->setsockopt<int>(IPPROTO_TCP, TCP_NODELAY, 1);
    tcpserver->bind_v4any();
    tcpserver->listen();
    DEFER(delete tcpserver);
    auto server = new_http_server();
    DEFER(delete server);
    auto fs = photon::fs::new_localfs_adaptor("/tmp/ease_ut/http_test/");
    DEFER(delete fs);
    auto fs_handler = new_fs_handler(fs);
    DEFER(delete fs_handler);
    server->add_handler(fs_handler);
    tcpserver->set_handler(server->get_connection_handler());
    tcpserver->start_loop();
    auto target = to_url(tcpserver, "/ease-httpclient-gettestfile");
    auto client = new_http_client();
    DEFER(delete client);
    auto op2 = client->new_operation(Verb::GET, target);
    DEFER(client->destroy_operation(op2));
    op2->req.headers.content_length(0);
    int ret = client->call(op2);
    GTEST_ASSERT_EQ(0, ret);

    char resp_body_buf[1024];
    EXPECT_EQ(sizeof(socket_buf), op2->resp.resource_size());
    ret = op2->resp.read(resp_body_buf, sizeof(socket_buf));
    EXPECT_EQ(sizeof(socket_buf), ret);
    resp_body_buf[sizeof(socket_buf) - 1] = '\0';
    LOG_DEBUG(resp_body_buf);
    EXPECT_EQ(0, strcmp(resp_body_buf, socket_buf));

    auto op3 = client->new_operation(Verb::GET, target);
    DEFER(client->destroy_operation(op3));
    op3->req.headers.content_length(0);
    op3->req.headers.range(10, 19);
    client->call(op3);
    char resp_body_buf_range[1024];
    ret = op3->resp.read(resp_body_buf_range, op3->resp.headers.content_length());
    resp_body_buf_range[10] = '\0';
    EXPECT_EQ(0, strcmp("http_clien", resp_body_buf_range));
    LOG_DEBUG(resp_body_buf_range);

    auto op4 = client->new_operation(Verb::GET, target);
    DEFER(client->destroy_operation(op4));
    op4->req.headers.content_length(0);
    op4->call();
    EXPECT_EQ(sizeof(socket_buf), op4->resp.resource_size());
    ret =  op4->resp.read(resp_body_buf, 10);
    EXPECT_EQ(10, ret);
    resp_body_buf[10] = '\0';
    EXPECT_EQ(0, strcmp("this is a ", resp_body_buf));
    LOG_DEBUG(resp_body_buf);
    ret =  op4->resp.read(resp_body_buf, 10);
    EXPECT_EQ(10, ret);
    resp_body_buf[10] = '\0';