packages/apps/lynq-function-test/src/main.cpp

/* gets example */
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <libtel/lib_tele.h>
#include "ril_test.h"
#include "gpio_test.h"
#include "fota_test.h"
#include "audio_test.h"
#include "system_test.h"
//#include "service_test.h"
#include "function_common.h"
//#include "conti_plugin_test.h"
//#include "exception_multicast.h"


#include<unistd.h>

#ifdef __cplusplus
extern "C" {
#endif
#include "liblynq-broadcast/broadcast_send.h"
#include <gio/gio.h>
#include <glib.h>
#include "liblynq-driver/libdriver.h"

#ifdef __cplusplus
}
#endif

#define BUFFER_SIZE 8192
#define USER_LOG_TAG "FUNCTION_TEST"
#define MAX_ARGS 5
typedef enum {
    API_MENU = 1,
    DEMO_MENU,
}TEST_MAIN_ITEM;
typedef enum{
    API_RIL=0,
    API_GPIO,
    API_MQTT,
    API_HTTP,
    API_WIFI,
    API_GNSS,
    API_SERVICE,
    API_AUDIO,
    API_DHCP,
    API_SYSTEM,
    API_FOTA,
} API_MOUDLE;


void lynq_incoming_call_cb(RIL_SOCKET_ID soc_id,int index, char * addr, RIL_CallState state, int toa)
{
   // printf("[SIM%d]index is %d,addr is %s,state is %d,toa is %d\n",soc_id,index,addr,state,toa);
    LYVERBLOG("[SIM%d]index is %d,addr is %s,state is %d,toa is %d\n",soc_id,index,addr,state,toa);
}

void lynq_recive_new_sms_cb(RIL_SOCKET_ID soc_id,char * num, char * smsc, char * msg, int charset)
{
  //  printf("[SIM%d]num is %s,smsc is %s,msg is %s,charset is %d\n",soc_id,num,smsc,msg,charset);
    LYVERBLOG("[SIM%d]num is %s,smsc is %s,msg is %s,charset is %d\n",soc_id,num,smsc,msg,charset);
}

static user_cb mytest={
    lynq_recive_new_sms_cb,
    lynq_incoming_call_cb
};


static void getCallback(const char* str_arg, int int_arg )
{
    //printf("SignalCallback,str_arg:%s,int_arg:%d\n", str_arg,int_arg);
    LYVERBLOG("SignalCallback,str_arg:%s,int_arg:%d\n", str_arg,int_arg);

    return;
}

void hold_on(){
    char any[5]={ 0 };
    printf("Press any key to return\n");
    fgets(any, 5, stdin);
}

int parse_param(char *cmd, char *argv[], int max_args){
    char *pos, *pos2;
    int argc = 0;

    pos = cmd;
    while (1) {
        // Trim the space characters.
        while (*pos == ' ') {
            pos++;
        }

        if (*pos == '\0') {
          break;
        }

        // One token may start with '"' or other characters.
        if (*pos == '"' && (pos2 = strchr(pos + 1, '"'))) {
            argv[argc++] = pos + 1;
            *pos2 = '\0';
            pos = pos2 + 1;
            if (*pos == '\n'){
                *pos = '\0';
                pos = pos + 1;
            }
        }
        else {
            argv[argc++] = pos;
            while (*pos != '\0' && *pos != ' '&& *pos != '\n') 
                {
                    if (*pos == '"' && (pos2 = strchr(pos + 1, '"'))) 
                    {
                        pos = pos2 ;
                    }
                    else
                    pos++;
                }
            *pos++ = '\0';
        }

    // Check if the maximum of arguments is reached.
        if (argc == max_args) {
            break;
        }
    }

    return argc;
}
int getRilModule(char *module)
{
    if (module==NULL)
    {
       //printf("[ERROR] Please input module,and try again!");
       // LYVERBLOG("+[command error]:error num = %d\n",MENU_INPUT_ERROR);
        return -1;
    }
    if(!strcmp(module,"ril"))
    {
        return API_RIL;
    }
    else if(!strcmp(module,"gpio"))
    {
        return API_GPIO;
    }
    else if(!strcmp(module,"MQTT"))
    {
        return API_MQTT;
    }
    else if(!strcmp(module,"HTTP"))
    {
        return API_HTTP;
    }
    else if(!strcmp(module,"WIFI"))
    {
        return API_WIFI;
    }
    else if(!strcmp(module,"GNSS"))
    {
        return API_GNSS;
    }
  //  else if(!strcmp(module, "SERVICE"))
   // {
  //      return API_SERVICE;
  //  }
      else if(!strcmp(module, "AUDIO"))
    {
        return API_AUDIO;
    }
	else if(!strcmp(module,"DHCP"))
    {
        return API_DHCP;
    }
    else if(!strcmp(module,"SYSTEM"))
    {
        return API_SYSTEM;
    }
    else if(!strcmp(module, "fota"))
    {
        return API_FOTA;
    }
    else
    {
       LYVERBLOG("+[command error]:error num = %d\n",MENU_INPUT_ERROR);
       // printf("can not find %s API  module ",module);
        return -1;
    }
    return -1;
}

int api_start(int argc, char *argv[]){
    LYDBGLOG("api_start,argc:%d\n",argc);
    char *menu[2] = {0};// menu[0] is the "moudle",menu[1] is the "API"
    char* argvHead=NULL;
    int module = -1;
    argvHead = getMenu(argv[2],menu);//find the "module" and the "API"
    module = getRilModule(menu[0]);
   // if(argvHead == NULL)
   // {
    //     printf("pram api error\n");
    //     return 0;
   // }
    switch(module)
    {
        case API_RIL:
        {
            if(argvHead)
            {
                ril_test(menu[1],argvHead);
                break;
            }
        }
        /* Add the code of the owner modules below*/
        case API_GPIO:
        {
            gpio_test(menu[1],argvHead);
            break;
        }
     //   case API_SERVICE:
    //    {
      //      service_test(menu[1],argvHead);
       //     break;
     //   }
        case API_AUDIO:
        {
            audio_test(menu[1],argvHead);
            break;
        }
        case API_DHCP:
        {
            //dhcp_test(menu[1],argvHead);
            break;
        }
        case API_SYSTEM:
        {
            system_test(menu[1],argvHead);
            break;
        }
	case API_FOTA:
	{
		fota_test(menu[1],argvHead);		
		break;
	}

        case API_MQTT:
        case API_HTTP:
        case API_WIFI:
        case API_GNSS:
            break;
        default:
          //  printf("pram module error\n");
          LYVERBLOG("+[command error]:error num = %d\n",MENU_INPUT_ERROR);

            break;
    }
   // hold_on(); //add by zhouqunchao delete help message
    return 1;
}

int function_start(int argc, char *argv[])
{
	int select_menu = atoi(argv[0]);
	int thread = atoi(argv[1]);
	// printf("select_menu:%d,thread:%d\n",select_menu,thread);
 	switch(select_menu)
	{
		case API_MENU:
		{
			if (thread == 1)//rita add @2021.6.21 for threadhandle test
			{
				LYDBGLOG("[%s-%d] argv[2] = [%s]\n", __FUNCTION__, __LINE__, argv[2]);
				if(strlen(argv[2])){//rita add @2021.6.21 for data error
					LYDBGLOG("[%s-%d] argv[2] = [%s]\n", __FUNCTION__, __LINE__, argv[2]);
					send_broadcast_by_name("function", strlen(argv[2]), argv[2]);
				}
				else{
					LYVERBLOG("+[thhandle]: error num = %d\n", INVALID_CMD);
					return INVALID_CMD;
				}
			}
			else if(thread ==2){//rita add @2021.6.21 for local test
				api_start(argc,argv);
			}
			else{
				//printf("thread 1,local 2\n");
				LYDBGLOG("thread 1,local 2\n");
			}
			break;
		}
		case DEMO_MENU:
		{
			//printf("DEMO_MENU\n");
			LYDBGLOG("DEMO_MENU\n");
			break;
		}
		default:
        break;
    }
    return 0; 
}


void help_display(){
    printf("\n");
    printf("*****************************************************************************\n");
    printf("0:help ------- help\n");
    printf("*****************************************************************************\n");
    printf("1:API TEST\n" );
    printf("          1-1:Async api-\n" );
    printf("                        --MQTT\n" );
    printf("\n");
    printf("                        --HTTP\n" );
    printf("          1-2:Sync api-\n" );
    printf("                        --GPIO\n" );
    printf("\n");
    printf("                        --RIL\n" );
    printf("\n");
    printf("                        --WIFI\n" );
    printf("\n");
    printf("                        --GNSS\n" );
    printf("\n");
    printf("                        --SERVICE\n" );
    printf("*****************************************************************************\n");
    printf("2:DEMO TEST:Subsequent updates\n" );
    printf("*****************************************************************************\n");
    printf("\n");
    printf("1:API TEST The format is as follows :\n" );
    printf("{menu}-{mode selection} moudle=\"{moudle}\"&API=\"{api interface}\"&session=\"{session id}\"\"&parameterA=\"{parameter A}\"\n" );
    /*
    printf("The main parameters are as follows:\n");
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("menu:1--API TEST,2--DEMO TEST\n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("mode selection:1--async api,2--sync api\n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("moudle:Test module--includes the following modules\n" );
    printf("RIL, GPIO,MQTT,HTTP,WIFI,GNSS\n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("api interface:--Interface corresponding to module\n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("session id:--Used to distinguish different session groups of the same module\n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    printf("parameter A:--API parameter,Add format {\"&parameter_name=\"{parameter}\"} \n" );
    printf("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n");
    */
    printf("Select menu:\n");
}
void menu_display(){
    printf("\n");
    printf("**********************\n");
    printf("0:help menu\n");
    printf("1:API TEST\n");
    printf("2:DEMO TEST\n");
    printf("**********************\n");
    printf("\n");
    printf("Select menu:\n");
}
int main()
{   

    LYLOGEINIT(USER_LOG_TAG);
    LYLOGSET(4);
    registerTriggerCallback(getCallback);
    register_key_info();
    lynqRegisterUnsolicitedResponse(&mytest);

    /*Check whether the modem works correctly and start the corresponding service*/  //add by liulei
    char buf[1024]={0};
    int fd[2];
    int backfd;
    pipe(fd);
    backfd=dup(STDOUT_FILENO);//备份标准输出，用于恢复
    dup2(fd[1],STDOUT_FILENO);  //将标准输出重定向到fd[1]
    system("cat /sys/kernel/ccci/boot");
    read(fd[0],buf,1024);
    dup2(backfd,STDOUT_FILENO);  //恢复标准输出
    LYVERBLOG("this is a test :\n%s",buf);  //上面不恢复，则此处的执行结果无法再屏幕上打印
    if(!strncmp(buf, "md1:4", 5)){
        lynq_ril_init();
    }
    else{
        printf("\033[40;31mmodem go wrong, May cause problems with your subsequent use of the service\033[0m\n");
        printf("\033[40;31mmodem go wrong, May cause problems with your subsequent use of the service\033[0m\n");
        printf("\033[40;31mmodem go wrong, May cause problems with your subsequent use of the service\033[0m\n");
    }
    /*Check whether the modem works correctly and start the corresponding service*/
    sleep_with_restart(1);
    register_broadcast_send();

    while (1) {
        char *argv[MAX_ARGS];
        char str[BUFFER_SIZE]={ 0 };
        menu_display();
        fgets(str, BUFFER_SIZE, stdin);
        LYDBGLOG("[%s-%d] str= [%s]\n", __FUNCTION__, __LINE__, str);
        str[strlen(str)-1]='\0';
        if(!strcmp(str, "0")){
           help_display();
           //hold_on(); //add by zhouqunchao delete help message
           continue;
        }
        if(!strcmp(str,"quit"))
        {   
            //system("killall lynq-framework-service");
           break;
        }
        if ((strncmp(str,"1-",2) == 0)||
           (strncmp(str,"2-",2)== 0))
        {
         char* at_cmd = strstr(str, "-");
         strncpy(at_cmd, " ", 1);
        LYDBGLOG("[%s-%d] at_cmd = [%s]\n", __FUNCTION__, __LINE__, at_cmd);

	
         int argc = parse_param(str, argv, MAX_ARGS);
   //add by zqc  Format error judgment start
        if(argv[2] == NULL)
        {
        LYVERBLOG("+[command error]:error num = %d\n",MENU_INPUT_ERROR);
        continue;
        }
        //add by zqc  Format error judgment end
         function_start(argc,argv);
         continue;
        }
        else{
        // printf("pram error\n");
         LYVERBLOG("+[command error]:error num = %d\n",MENU_INPUT_ERROR);
         continue;
        }
   }
return 0;
}