Skip to content

Commit

Permalink
Optional test of site-specific data sources
Browse files Browse the repository at this point in the history
  • Loading branch information
@cpiker
cpiker committed Aug 23, 2024
1 parent 82d0235 commit 6c582ce
Showing 1 changed file with 73 additions and 48 deletions.
121 changes: 73 additions & 48 deletions test/TestBuilder.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -96,42 +96,8 @@ bool test_file(const char* sFile, int nTest){
return true;
}


int main(int argc, char** argv)
bool test_plain_url(const char* sInitialUrl, int nTest)
{
/* Exit on errors, log info messages and above */
das_init(argv[0], DASERR_DIS_EXIT, 0, DASLOG_INFO, NULL);

const char* sFile = "test/galileo_pws_sample.d2t";
DasStream* pStream = read_stream(sFile, 1);
if(! print_info(pStream, 1) ) return 1;

size_t uDs = DasStream_getNPktDesc(pStream);
if((pStream == NULL)||(uDs != 1)){
printf("ERROR: Test 1 failed, expected 1 dataset from %s, found %zu\n",
sFile, uDs);
return 1;
}

if(!test_file("test/x_multi_y.d2s", 2)) return 13;
if(!test_file("test/cassini_rpws_sample.d2t", 3)) return 13;
if(!test_file("test/juno_waves_sample.d2t", 4)) return 13;
if(!test_file("test/mex_marsis_bmag.d2t", 5)) return 13;
if(!test_file("test/cassini_rpws_wfrm_sample.d2s", 6)) return 13;

/* New tests for das3 streams */
if(!test_file("test/ex12_sounder_xyz.d3t", 7)) return 13;
if(!test_file("test/ex15_vector_frame.d3b", 8)) return 13;
if(!test_file("test/ex17_vector_noframe.d3b", 9)) return 13;

printf("INFO: All local builder operation tests passed\n\n");

/* Now for the big one, try to get a dataset from a remote server, this may
* fail, it's up to the test runner to decide if the failure is okay */
const char* sInitialUrl = "https://jupiter.physics.uiowa.edu/das/server"
"?server=dataset&dataset=Galileo/PWS/Survey_Electric"
"&start_time=2001-001&end_time=2001-002";

printf("INFO: Contacting remote HTTP URL %s\n\n", sInitialUrl);

DasHttpResp res;
Expand All @@ -158,53 +124,112 @@ int main(int argc, char** argv)
return 9;
}

pStream = DasDsBldr_getStream(pBldr);
uDs = DasStream_getNPktDesc(pStream);
DasStream* pStream = DasDsBldr_getStream(pBldr);
size_t uDs = DasStream_getNPktDesc(pStream);

printf("INFO: %zu Datasets retrieved from %s\n", uDs, sUrl);

DasDsBldr_release(pBldr); /* Avoid double delete with print_info function */
if(! print_info(pStream, 10)) return 10;
del_DasIO(pIn);
del_DasDsBldr(pBldr);

sInitialUrl = "https://jupiter.physics.uiowa.edu/das/server"
"?server=dataset&dataset=Earth/LWA-1/Ephemeris/Jupiter"
"&end_time=2015-02-21T03:00&start_time=2015-02-21T02:00&interval=60";


return true;
}

bool test_secure_url(const char* sInitialUrl, int nTest)
{
printf("INFO: Contacting remote HTTPS URL %s\n\n", sInitialUrl);

DasHttpResp_clear(&res);

DasHttpResp res;
if(!das_http_getBody(sInitialUrl, NULL, NULL, &res, DASHTTP_TO_MIN)){
printf("ERROR: Could not get body for URL, reason: %s\n", res.sError);
return 13;
}

char sUrl[512] = {'\0'};
das_url_toStr(&(res.url), sUrl, 511);
if(strcmp(sUrl, sInitialUrl) != 0)
printf("INFO: Redirected to %s\n\n", sUrl);

pIn = NULL;
DasIO* pIn = NULL;
if(DasHttpResp_useSsl(&res))
pIn = new_DasIO_ssl("TestBuilder", res.pSsl, "r");
else
pIn = new_DasIO_socket("TestBuilder", res.nSockFd, "r");

pBldr = new_DasDsBldr();
DasDsBldr* pBldr = new_DasDsBldr();
DasIO_addProcessor(pIn, (StreamHandler*)pBldr);

if(DasIO_readAll(pIn) != 0){
printf("ERROR: Test 11 failed, couldn't process %s\n", sUrl);
return 13;
}

pStream = DasDsBldr_getStream(pBldr);
uDs = DasStream_getNPktDesc(pStream);
DasStream* pStream = DasDsBldr_getStream(pBldr);
size_t uDs = DasStream_getNPktDesc(pStream);

printf("INFO: %zu Datasets retrieved from %s\n", uDs, sUrl);
DasDsBldr_release(pBldr); /* Avoid double delete with print_info function */
if(! print_info(pStream, 11)) return 13;
del_DasIO(pIn);
del_DasDsBldr(pBldr);

return true;
}

int main(int argc, char** argv)
{
/* Exit on errors, log info messages and above */
das_init(argv[0], DASERR_DIS_EXIT, 0, DASLOG_INFO, NULL);

const char* sFile = "test/galileo_pws_sample.d2t";
DasStream* pStream = read_stream(sFile, 1);
if(! print_info(pStream, 1) ) return 1;

size_t uDs = DasStream_getNPktDesc(pStream);
if((pStream == NULL)||(uDs != 1)){
printf("ERROR: Test 1 failed, expected 1 dataset from %s, found %zu\n",
sFile, uDs);
return 1;
}

if(!test_file("test/x_multi_y.d2s", 2)) return 13;
if(!test_file("test/cassini_rpws_sample.d2t", 3)) return 13;
if(!test_file("test/juno_waves_sample.d2t", 4)) return 13;
if(!test_file("test/mex_marsis_bmag.d2t", 5)) return 13;
if(!test_file("test/cassini_rpws_wfrm_sample.d2s", 6)) return 13;

/* New tests for das3 streams */
if(!test_file("test/ex12_sounder_xyz.d3t", 7)) return 13;
if(!test_file("test/ex15_vector_frame.d3b", 8)) return 13;
if(!test_file("test/ex17_vector_noframe.d3b", 9)) return 13;

printf("INFO: All local builder operation tests passed\n\n");

/* Now for the big one, try to get a dataset from a remote server, this may
* fail, it's up to the test runner to decide if the failure is okay */
const char* sInitialUrl = "https://jupiter.physics.uiowa.edu/das/server"
"?server=dataset&dataset=Galileo/PWS/Survey_Electric"
"&start_time=2001-001&end_time=2001-002";

if(!test_plain_url(sInitialUrl, 10)) return 13;

sInitialUrl = "https://jupiter.physics.uiowa.edu/das/server"
"?server=dataset&dataset=Earth/LWA-1/Ephemeris/Jupiter"
"&end_time=2015-02-21T03:00&start_time=2015-02-21T02:00&interval=60";

if(!test_secure_url(sInitialUrl, 11)) return 13;

/* Extra items that can be tested if local: */
if((argc > 1) &&(strcmp(argv[1], "--uiowa") == 0)){

sInitialUrl = "https://tracers-dev.physics.uiowa.edu/stream"
"?server=dataset&dataset=PreFlight/L1/ACI/FM-1/ipd_anode"
"&start_time=2024-06-29T16:52&end_time=2024-06-29T17-08";

if(!test_secure_url(sInitialUrl, 11)) return 13;
}

return 0;
}

0 comments on commit 6c582ce

Please sign in to comment.