XPlaneConnectCSP/TestScripts/C Tests/main.c

//
//  main.cpp
//  XPC Tests
//
//  Created by Chris Teubert on 11/25/14.
//  Copyright (c) 2014 Chris Teubert. All rights reserved.
//

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include "xplaneconnect.h"

int testFailed = 0;
int testPassed = 0;

void runTest(short (*f)())
{
    short result;
    
    printf("Test %i: ",testPassed+testFailed+1);
    result = (*f)(); // Run Test
    if (result == 0)
    {
        printf("PASSED\n");
        testPassed++;
    }
    else
    {
        printf("FAILED\n\tError: %i\n", result);
        testFailed++;
    }
}

short test1() // openUDP Test
{
    printf("openUDP - ");
    struct xpcSocket sendPort = openUDP( 49062, "127.0.0.1", 49009 );
    return 0;
}

short test2() // closeUDP test
{
    printf("closeUDP - ");
    struct xpcSocket sendPort = openUDP( 49063, "127.0.0.1", 49009 );
    closeUDP(sendPort);
    return 0;
}

short test3() // send/read Test
{
    printf("send/readUDP - ");
    
    // Initialization
    int i; // Iterator
    char test[] = {0, 1, 2, 3};
    char buf[5] = {0};
    struct xpcSocket sendPort, recvPort;
    
    // Setup
    sendPort = openUDP( 49064, "127.0.0.1", 49063 );
    recvPort = openUDP( 49063, "127.0.0.1", 49009 );
    
    // Execution
    sendUDP( sendPort, test, sizeof(test) );
    readUDP( recvPort, buf, NULL ); // Test
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Tests
    for (i=0; i<4; i++)
    {
        if (test[i] != buf[i]) // Not received correctly
        {
            return -1;
        }
    }
    
    return 0;
}

short test4() // Request DREF Test (Required for next tests)
{
    printf("requestDREF - ");
    
    // Initialization
    int i; // Iterator
    char DREFArray[100][100];
    float *recDATA[100];
    short DREFSizes[100];
    struct xpcSocket sendPort, recvPort;
    short result = 0;
    
    // Setup
    for (i = 0; i < 100; i++) {
        recDATA[i]   = (float *) malloc(40*sizeof(float));
        memset(DREFArray[i],0,100);
    }
    sendPort = openUDP( 49064, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/cockpit/switches/gear_handle_status");
    strcpy(DREFArray[1],"cockpit2/switches/panel_brightness_ratio");
    for (i=0;i<2;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    
    // Execution
    result = requestDREF(sendPort, recvPort, DREFArray, DREFSizes, 2, recDATA, DREFSizes);
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Tests
    if ( result < 0)// Request 2 values
    {
        return -1;
    }
    if (DREFSizes[0] != 1 || DREFSizes[1] != 4)
    {
        return -2;
    }
    return 0;
}

short test5() // sendDREF test
{
    printf("sendDREF - ");
    
    // Initialization
    int i; // Iterator
    char DREFArray[100][100];
    float *recDATA[100];
    short DREFSizes[100];
    float value = 0.0;
    struct xpcSocket sendPort, recvPort;
    short result = 0;
    
    // Setup
    for (i = 0; i < 100; i++) {
        recDATA[i]   = (float *) malloc(40*sizeof(float));
        memset(DREFArray[i],0,100);
    }
    sendPort = openUDP( 49066, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/cockpit/switches/gear_handle_status");
    for (i=0;i<1;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    
    // Execution
    sendDREF(sendPort, DREFArray[0], DREFSizes[0], &value, 1);
    result = requestDREF(sendPort, recvPort, DREFArray, DREFSizes, 1, recDATA, DREFSizes);
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Tests
    if (result < 0)// Request 1 value
    {
        return -1;
    }
    if (DREFSizes[0] != 1)
    {
        return -2;
    }
    if (*recDATA[0] != value)
    {
        return -3;
    }
    return 0;
}

short test6() // sendDATA test
{
    printf("sendData - ");
    
    // Initialize
    int i,j; // Iterator
    char DREFArray[100][100];
    float data[4][9] = {0};
    float *recDATA[100];
    short DREFSizes[100];
    struct xpcSocket sendPort, recvPort;
    short result = 0;
    
    // Setup
    for (i = 0; i < 100; i++) {
        recDATA[i]   = (float *) malloc(40*sizeof(float));
        memset(DREFArray[i],0,100);
    }
    sendPort = openUDP( 49066, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/aircraft/parts/acf_gear_deploy");
    for (i=0;i<1;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    for (i=0;i<4;i++) { // Set array to -999
        for (j=0;j<9;j++) data[i][j] = -999;
    }
    data[0][0] = 14; // Gear
    data[0][1] = 1;
    data[0][2] = 0;
    
    // Execution
    sendDATA(sendPort, data, 1); // Gear
    result = requestDREF(sendPort, recvPort, DREFArray, DREFSizes, 1, recDATA, DREFSizes); // Test
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Tests
    if ( result < 0 )// Request 1 value
    {
        return -1;
    }
    if (DREFSizes[0] != 10)
    {
        return -2;
    }
    if (*recDATA[0] != data[0][1])
    {
        return -3;
    }
    return 0;
}

short test7() // sendCTRL test
{
    printf("sendCTRL - ");
    
    // Initialize
    int i; // Iterator
    char DREFArray[100][100];
    float CTRL[5] = {0.0};
    float *recDATA[100];
    short DREFSizes[100];
    struct xpcSocket sendPort, recvPort;
    
    // Setup
    for (i = 0; i < 100; i++) {
        recDATA[i]   = (float *) malloc(40*sizeof(float));
        memset(DREFArray[i],0,100);
    }
    sendPort = openUDP( 49067, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/cockpit/switches/gear_handle_status");
    for (i=0;i<1;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    CTRL[3] = 0.8; // Throttle
    
    // Execute
    sendCTRL(sendPort, 4, CTRL);
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Test
    
    //    if (requestDREF(sendPort, recvPort, DREFArray, DREFSizes, 1, recDATA, DREFSizes) < 0)// Request 1 value
    //    {
    //        return -1;
    //    }
    //    if (DREFSizes[0] != 1)
    //    {
    //        return -2;
    //    }
    //    if (*recDATA[0] != value)
    //    {
    //        return -3;
    //    }
    return 0;
}

short test8() // sendPOSI test
{
    printf("sendPOSI - ");
    
    // Initialization
    int i; // Iterator
    char DREFArray[100][100];
    float POSI[8] = {0.0};
    float *recDATA[100];
    short DREFSizes[100];
    struct xpcSocket sendPort, recvPort;
    
    // Setup
    for (i = 0; i < 100; i++) {
        recDATA[i]   = (float *) malloc(40*sizeof(float));
        memset(DREFArray[i],0,100);
    }
    sendPort = openUDP( 49067, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/cockpit/switches/gear_handle_status");
    for (i=0;i<1;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    POSI[0] = 37.524; // Lat
    POSI[1] = -122.06899; // Lon
    POSI[2] = 2500; // Alt
    POSI[3] = 0; // Pitch
    POSI[4] = 0; // Roll
    POSI[5] = 0; // Heading
    POSI[6] = 1; // Gear
    
    // Execution
    sendPOSI( sendPort, 0, 7, POSI );
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Test
    
    return 0;
}

short test9() // pauseSim test
{
    printf("pauseSim - ");
    
    // Initialize
    struct xpcSocket sendPort, recvPort;
    
    // Setup
    sendPort = openUDP( 49067, "127.0.0.1", 49009 );
    recvPort = openUDP( 49008, "127.0.0.1", 49009 );
    
    // Execute
    pauseSim(sendPort, 1);
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Test
    
    return 0;
}

short test10() // setConn test
{
    printf("setConn - ");
    
    // Initialize
    int i; // Iterator
    char DREFArray[100][100];
    float *recDATA[100];
    short DREFSizes[100];
    struct xpcSocket sendPort, recvPort;
    short result = 0;
    usleep(0);
    
    // Setup
    sendPort = openUDP( 49067, "127.0.0.1", 49009 );
    recvPort = openUDP( 49055, "127.0.0.1", 49009 );
    strcpy(DREFArray[0],"sim/cockpit/switches/gear_handle_status");
    for (i=0;i<1;i++) {
        DREFSizes[i] = (int) strlen(DREFArray[i]);
    }
    
    // Execution
    setCONN(sendPort, 49055);
    result = requestDREF(sendPort, recvPort, DREFArray, DREFSizes, 1, recDATA, DREFSizes); // Test
    
    // Close
    closeUDP(sendPort);
    closeUDP(recvPort);
    
    // Test
    if ( result < 0 )// No data received
    {
        return -1;
    }
    
    
    // Set up for next test
    sendPort = openUDP( 49067, "127.0.0.1", 49009 );
    setCONN(sendPort, 49009);
    closeUDP(sendPort);
    return 0;
}

int main(int argc, const char * argv[])
{
    printf("XPC Tests-cpp ");
    
#ifdef _WIN32
    printf("(Windows)\n");
#elif (__APPLE__)
    printf("(Mac) \n");
#elif (__linux)
    printf("(Linux) \n");
#endif
    
    runTest(test1);
    runTest(test2);
    runTest(test3);
    runTest(test4);
    runTest(test5);
    runTest(test6);
    runTest(test7);
    runTest(test8);
    runTest(test9);
    runTest(test10);
    
    printf( "----------------\nTest Summary\n\tFailed: %i\n\tPassed: %i\n", testFailed, testPassed );
    
    return 0;
}