2019-06-05

Dependencies:   DataStorage NetworkManager IR_Manager WheelManager RestAPI_Manager

main.cpp

Committer:
asaewing
Date:
2018-12-21
Revision:
2:7581451de520
Parent:
1:dc6fd86fb7f9
Child:
4:acd433b7ecd7

File content as of revision 2:7581451de520:

#if !FEATURE_LWIP 
    #error [NOT_SUPPORTED] LWIP not supported for this target
#endif

#include "module_for_all.h"

#define PORT 8080

#define IP1        "192.168.20.101"
#define IP2        "192.168.20.102"
#define IP3        "192.168.20.103"
#define IP4        "192.168.20.104"
#define GATEWAY    "192.168.20.1"
#define MASK       "255.255.255.0"

const char* ip = 0;
const char* mac = 0;
DataStorage ds_manager("");

//DigitalIn  IP_Select2(PG_2);

//DigitalIn  Test_Mode(PC_14);

NetworkManager*  net_manager = new NetworkManager(IP1, GATEWAY, MASK, PORT);
RestAPI_Manager* restAPI_manager = new RestAPI_Manager(&ds_manager, IP1, "1");

//NetworkManager  net_manager();
//RestAPI_Manager restAPI_manager();

void checkServer()
{
    //TCPSocket socket;

    printf("Sending HTTP request to www.arm.com...\r\n");

    // Open a socket on the network interface, and create a TCP connection to www.arm.com
    net_manager->clt_sock.open(&(net_manager->eth));
    net_manager->clt_sock.connect("192.168.20.1", 81);

    // Send a simple http request
    //char sbuffer[] = "GET /iamok/ HTTP/1.1\r\nHost: 192.168.20.1\r\n\r\n";
    std::string sbuffer_str = "GET /iamok/ HTTP/1.1\r\nHost: 192.168.20.1\r\n\r\n";
    char* sbuffer = new char [sbuffer_str.length()+1];
    
    //tmpString = stringToChar(tmpResponse);
    stringToChar(sbuffer, sbuffer_str);
    
    //clt_sock.send(tmpString, strlen(tmpString));
    
    int scount = net_manager->clt_sock.send(sbuffer, strlen(sbuffer));
    printf("sent %d [%.*s]\r\n", scount, strstr(sbuffer, "\r\n")-sbuffer, sbuffer);
    
    if (scount>=0){
        // Recieve a simple http response and print out the response line
        char* rbuffer = new char[1024];
        //char* buf = new char[1024];
        //int rcount = net_manager->clt_sock.recv(rbuffer, sizeof rbuffer);
        int rcount = net_manager->clt_sock.recv(rbuffer, 100);
        printf("recv %d [%.*s]\r\n", rcount, strstr(rbuffer, "\r\n")-rbuffer, rbuffer);
        delete [] rbuffer;
    } else {
        DataStorage::_W1_A = 0;
        DataStorage::_W1_B = 0;
        
        DataStorage::_W2_A = 0;
        DataStorage::_W2_B = 0;
        
        DataStorage::_W3_A = 0;
        DataStorage::_W3_B = 0;
        
        DataStorage::_W4_A = 0;
        DataStorage::_W4_B = 0;
        
        for (int ii=0;ii<5;ii++){
            DataStorage::WM_PWM[ii][0] = 1;
            DataStorage::WM_PWM[ii][1] = 0;
        }
        
        (DataStorage::_WM_PWM_out01).period(DataStorage::WM_PWM[0][0]);
        (DataStorage::_WM_PWM_out02).period(DataStorage::WM_PWM[1][0]);
        (DataStorage::_WM_PWM_out03).period(DataStorage::WM_PWM[2][0]);
        (DataStorage::_WM_PWM_out04).period(DataStorage::WM_PWM[3][0]);
        
        (DataStorage::_WM_PWM_out01).write(DataStorage::WM_PWM[0][1]);
        (DataStorage::_WM_PWM_out02).write(DataStorage::WM_PWM[1][1]);
        (DataStorage::_WM_PWM_out03).write(DataStorage::WM_PWM[2][1]);
        (DataStorage::_WM_PWM_out04).write(DataStorage::WM_PWM[3][1]);
    }

    // Close the socket to return its memory and bring down the network interface
    net_manager->clt_sock.close();
    
    delete [] sbuffer;
    
}

void checkServerLoop() {
    while (true) {
        checkServer();
    }
}

void checkServerThread() {
    Thread thread_connect;
    thread_connect.start(checkServerLoop);
}


bool EventLoop() {
    while (true) {
        printf("$$ EventLoop New\r\n");
        
        //Thread threadMain01;
        //restAPI_manager.changeThread(&threadMain01);
        
        //printf("$$ EventLoop Change Thread\r\n");
        
        LED_NetWait();
        
        printf("$$ EventLoop Waiting\r\n");
        
        net_manager->AcceptEvent();
        //printf("$$ EventLoop run Response\r\n");
        if (DataStorage::isAccept){
            LED_NetProcess();
            DataStorage::http_method = net_manager->getHttpMethod();
            DataStorage::api_command = net_manager->getApiCommand();
            DataStorage::response = restAPI_manager->runCommand(DataStorage::http_method, DataStorage::api_command);
            net_manager->SendResponseEvent(DataStorage::response);
        } else {
            DataStorage::noAcceptCount += 1;
            if (DataStorage::noAcceptCount==20) {
                DataStorage::noAcceptCount = 0;
                checkServer();
            }
        }
        
        //DataStorage::http_method = net_manager->getHttpMethod();
        //DataStorage::api_command = net_manager->getApiCommand();
        
        //DataStorage::response = restAPI_manager->runCommand(DataStorage::http_method, DataStorage::api_command);
        //net_manager->SendResponseEvent(DataStorage::response);
        
        DataStorage::isAccept = false;
        printf("$$ EventLoop Finish\r\n");
    }
    
    //printf("$$ EventLoop ALL Finish\r\n");
    return false;
}

void checkIP(){
    DigitalIn  IP_Select1(PD_7);
    DigitalIn  IP_Select2(PD_6);

    DataStorage::ipSelect = 1;
    
    if (IP_Select1.read() == 1){
        DataStorage::ipSelect += 1;
    }
    
    if (IP_Select2.read() == 1){
        DataStorage::ipSelect += 2;
    }
    
    //char* tmp_IP = 0;
    
    switch(DataStorage::ipSelect) {
        case 1: 
            //tmp_IP = IP1;
            DataStorage::ipChar = IP1;
            break;
        case 2: 
            //tmp_IP = IP2;
            DataStorage::ipChar = IP2;
            break;
        case 3: 
            //tmp_IP = IP3;
            DataStorage::ipChar = IP3;
            break;
        case 4: 
            //tmp_IP = IP4;
            DataStorage::ipChar = IP4;
            break;
    }

    //std::string tmp_IP_s = intToString(DataStorage::ipSelect);
    DataStorage::ipStr = intToString(DataStorage::ipSelect);

    
    net_manager->SetConfig(DataStorage::ipChar, GATEWAY, MASK, PORT);
    restAPI_manager->SetConfig(DataStorage::ipChar, DataStorage::ipStr);
    
    printf("mbed %d Start\r\n", DataStorage::ipSelect);
    
    //delete tmp_IP;
}

int netInit(){
    net_manager->ServerInit();
    printf("ServerInit\r\n");
    
    if (net_manager->OpenServer()) return -1;
    printf("OpenServer\r\n");
    
    if (net_manager->BindPort()) return -1;
    printf("BindPort\r\n");
    
    if (net_manager->ListenConnections()) return -1;
    printf("ListenConnections\r\n");
    
    return 0;
}

void start(){
    printf("mbed Power Start\r\n");
    LED_PowerStart();
    
    checkIP();
    wait(0.5);
    netInit();
}
/* Main function */
int main(){
    start();
    
    if (EventLoop()) {
        return 0;
    }
}