basicFunctions.c

/*
 *   Copyright (C) 2017,2018 by Lieven De Samblanx ON7LDS
 *   Copyright (C) 2019,2019 by Mariano Sánchez EA5KL
 *
 *   This program is free software; you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License as published by
 *   the Free Software Foundation; either version 2 of the License, or
 *   (at your option) any later version.
 *
 *   This program is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with this program; if not, write to the Free Software
 *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <ifaddrs.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <syslog.h>
#include <time.h>

#include "NextionDriver.h"
#include "helpers.h"
#include "basicFunctions.h"

void basicFunctions(unsigned char param) {

    char text[300];

    if (strlen(TXbuffer)==0) return;

    if (time(NULL)>sleepTimeOut) {
        sendCommand("sleep=0");
        sleepTimeOut=time(NULL)+30;
    }

    //---------------------------------------------------
    // the 'page' variable holds the last selected page
    //---------------------------------------------------
    if (strncmp(TXbuffer,"page ",5)==0) {
        if (sleepWhenInactive) {
            sendCommand("sleep=0"); usleep(1000);
            sprintf(text,"ussp=%d",sleepWhenInactive);
            sendCommand(text);
        }
        if (strcmp(TXbuffer,"page MMDVM")==0) {
            page=0;
        }
        if (strcmp(TXbuffer,"page DStar")==0) {
            page=1;
        }
        if (strcmp(TXbuffer,"page DMR")==0) {
            page=2;
        }
        if (strcmp(TXbuffer,"page YSF")==0) {
            page=3;
        }
        if (strcmp(TXbuffer,"page P25")==0) {
            page=4;
        }
        if (strcmp(TXbuffer,"page NXDN")==0) {
            page=5;
        }
        if (strcmp(TXbuffer,"page POCSAG")==0) {
            page=6;
        }
        if (strcmp(TXbuffer,"page LastHeard")==0) {
            page=7;
        }
    }

    if ((strncmp(TXbuffer,"page ",5)==0)&&(changepages==1)) {
        strcat(TXbuffer,"0");
    }


    //--------------------------------------------------------------
    //                  Rest page
    //--------------------------------------------------------------
    //  * remove Freq and time when stopping
    //  * regularly check IP interface and send to display
    //  * get CPU temperature & frequency & load average 
    //       and send to display
    //  * send RX frequency and location (info from MMDVM.ini)
    //--------------------------------------------------------------
	
if ((page==0)||(param == 0x01)) {
    //MMDVM is doing a clean shutdown.
    if ((page==0)&&(strstr(TXbuffer,"MMDVM STOPPED")>0)){
        sprintf(text, "t30.txt=\"\"");
        sendCommand(text);
        sprintf(text, "t2.txt=\"\"");
    }

    //remove dim if necessary
    if (removeDim) {
        if (strstr(TXbuffer,"dim=")!=NULL) {
            TXbuffer[0]=0;
            return;
        }
    }

    // if date/time is sent, check IP interface from time to time:
    //   and disk free in %
    if ((page==0)&&(strstr(TXbuffer,"t2.txt=")>0)&&(check++>100)) {
        getNetworkInterface(ipaddr);
        netIsActive[0]=getInternetStatus(check);
        sprintf(TXbuffer, "t3.txt=\"%s\"", ipaddr);
        check=0;
    }
    // check temp & CPU freq (also not too often)
    if ((page==0)&&(strstr(TXbuffer,"t2.txt=")>0)&&(check%8==0)) {
        FILE *deviceInfoFile;
        double val;
//see basicFunction.h for info about defining the XTRA condition
//#ifdef XTRA
        //CPU temperature
        deviceInfoFile = fopen ("/sys/class/thermal/thermal_zone0/temp", "r");
        if (deviceInfoFile == NULL) {
            sprintf(text, "t20.txt=\"???\"");
        } else {
            fscanf (deviceInfoFile, "%lf", &val);
            val /= 1000;
            sprintf(text, "t20.txt=\"%4.1f%cC\"", val, 176);
            /*
            If you live in one of the countries where they use degrees F, you could comment the line above
             and uncomment the following line :                                      */
            //val=(val*1.8)+32;  sprintf(text, "t20.txt=\"%4.1f%cF\"", val, 176);
            fclose(deviceInfoFile);
        }
        sendCommand(text);
//#endif

       //CPU frequency
        deviceInfoFile = fopen ("/sys/devices/system/cpu/cpu0/cpufreq/cpuinfo_cur_freq", "r");
        if (deviceInfoFile == NULL) {
            sprintf(text, "t21.txt=\"?\"");
        } else {
            fscanf (deviceInfoFile, "%lf", &val);
            val /= 1000;
            sprintf(text, "t21.txt=\"%0.0f MHz\"", val);
            fclose(deviceInfoFile);
        }
        sendCommand(text);
        //CPU loadavg 1 min
        deviceInfoFile = fopen ("/proc/loadavg", "r");
        if (deviceInfoFile == NULL) {
            sprintf(text, "t22.txt=\"?\"");
            sendCommand(text);
            sprintf(text, "cpuload.val=0");
        } else {
            fscanf (deviceInfoFile, "%lf", &val);
            sprintf(text, "t22.txt=\"%0.2f\"", val);
            sendCommand(text);
            sprintf(text, "cpuload.val=%d", (int)(val*100));
            fclose(deviceInfoFile);
        }
        sendCommand(text);

        //Disk free %
        int f=getDiskFree(FALSE);
        if (f<0) 
            sprintf(text, "t23.txt=\"??\"");
        else
            sprintf(text, "t23.txt=\"%d\"",getDiskFree(FALSE));
        sendCommand(text);

#ifdef XTRA
        //RXFrequency
        float fx;
        fx=RXfrequency;
        fx/=1000000;
        sprintf(text, "t30.txt=\"%3.4fMHz\"",fx);
        sendCommand(text);

        //TXFrequency
        fx=TXfrequency;
        fx/=1000000;
        sprintf(text, "t32.txt=\"%3.4fMHz\"",fx);
        sendCommand(text);

        //Location
        sprintf(text, "t31.txt=\"%s\"",location);
        sendCommand(text);
#endif

        //disable 25356 text 46486
        //enable  1472  text 0
        //error   55879

        #define bcoEN	1472
        #define bcoDIS	25356
        #define pcoEN	0
        #define pcoDIS	65535

        if (showModesStatus) {
            //Modes enabled/disabled
            sprintf(text, "A1.bco=%d",modeIsEnabled[C_DSTAR] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A1.pco=%d",modeIsEnabled[C_DSTAR] ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A2.bco=%d",modeIsEnabled[C_DMR] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A2.pco=%d",modeIsEnabled[C_DMR] ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A3.bco=%d",modeIsEnabled[C_YSF] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A3.pco=%d",modeIsEnabled[C_YSF] ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A4.bco=%d",modeIsEnabled[C_P25] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A4.pco=%d",modeIsEnabled[C_P25] ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A5.bco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2DMR")>0||proc_find("YSF2NXDN")>0||proc_find("YSF2P25")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A5.pco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2DMR")>0||proc_find("YSF2NXDN")>0||proc_find("YSF2P25")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A6.bco=%d",modeIsEnabled[C_NXDN] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A6.pco=%d",modeIsEnabled[C_NXDN] ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A7.bco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2YSF")>0||proc_find("DMR2NXDN")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A7.pco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2YSF")>0||proc_find("DMR2NXDN")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "A8.bco=%d",modeIsEnabled[C_POCSAG] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "A8.pco=%d",modeIsEnabled[C_POCSAG] ?  pcoEN : pcoDIS); sendCommand(text);
    
            //Internet
            sprintf(text, "N0.bco=%d",netIsActive[0] ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N0.pco=%d",netIsActive[0] ?  pcoEN : pcoDIS); sendCommand(text);
    
            //Network connections
            sprintf(text, "N1.bco=%d",(modeIsEnabled[C_DSTARNET]&&(proc_find("ircddbgatewayd")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N1.pco=%d",(modeIsEnabled[C_DSTARNET]&&(proc_find("ircddbgatewayd")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N2.bco=%d",(modeIsEnabled[C_DMRNET]&&(proc_find("DMRGateway")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N2.pco=%d",(modeIsEnabled[C_DMRNET]&&(proc_find("DMRGateway")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N3.bco=%d",(modeIsEnabled[C_YSFNET]&&(proc_find("YSFGateway")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N3.pco=%d",(modeIsEnabled[C_YSFNET]&&(proc_find("YSFGateway")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N4.bco=%d",(modeIsEnabled[C_P25NET]&&(proc_find("P25Gateway")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N4.pco=%d",(modeIsEnabled[C_P25NET]&&(proc_find("P25Gateway")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N5.bco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2DMR")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N5.pco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2DMR")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N6.bco=%d",(modeIsEnabled[C_NXDNNET]&&(proc_find("NXDNGateway")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N6.pco=%d",(modeIsEnabled[C_NXDNNET]&&(proc_find("NXDNGateway")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N7.bco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2NXDN")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N7.pco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2NXDN")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N8.bco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2P25")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N8.pco=%d",(modeIsEnabled[C_YSF]&&(proc_find("MMDVMHost")>0)&&(proc_find("YSF2P25")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N9.bco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2NXDN")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N9.pco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2NXDN")>0)) ?  pcoEN : pcoDIS); sendCommand(text);
            sprintf(text, "N10.bco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2YSF")>0)) ?  bcoEN : bcoDIS); sendCommand(text);
            sprintf(text, "N10.pco=%d",(modeIsEnabled[C_DMR]&&(proc_find("MMDVMHost")>0)&&(proc_find("DMR2YSF")>0)) ?  pcoEN : pcoDIS); sendCommand(text);

        }
        //Done
        sprintf(text, "MMDVM.status.val=20");
        sendCommand(text);
        sendCommand("click S0,1");
    }
}

	//send TG name if found for TS1
    if ((page==2)&&(strstr(TXbuffer,"t1.txt")!=NULL)) {
        char *TGname;
        int nr,TGindex;
        sendCommand(TXbuffer);
        if ((TXbuffer[8]>='0')&&(TXbuffer[8]<='9'))
            nr=atoi(&TXbuffer[8]);
        else
            nr=atoi(&TXbuffer[10]);
        TGindex=search_group(nr,groups,0,nmbr_groups-1);
        if (TGindex>=0) {
            TGname=groups[TGindex].name;
            sprintf(TXbuffer,"t9.txt=\"%s\"",TGname);
        } else if (TGindex<0) {
            //is it maybe a user private call ?
            TGindex=search_user_index_for_ID(nr,users,0,nmbr_users-1);
			writelog(LOG_DEBUG,"- Found [%s] for ID %d",users[TGindex].data1,TGindex);
            if (TGindex>=0) sprintf(TXbuffer,"t9.txt=\"Private %s\"",users[TGindex].data1);
        } else {
            sprintf(TXbuffer,"t9.txt=\"TG%d name not found\"",nr);
        }
        sendCommand(TXbuffer);
    }

	
    //send TG name if found for TS2
    if ((page==2)&&(strstr(TXbuffer,"t3.txt")!=NULL)) {
        char *TGname;
        int nr,TGindex;
        sendCommand(TXbuffer);
        if ((TXbuffer[8]>='0')&&(TXbuffer[8]<='9'))
            nr=atoi(&TXbuffer[8]);
        else
            nr=atoi(&TXbuffer[10]);
        TGindex=search_group(nr,groups,0,nmbr_groups-1);
        if (TGindex>=0) {
            TGname=groups[TGindex].name;
            sprintf(TXbuffer,"t8.txt=\"%s\"",TGname);
        } else if (TGindex<0) {
            //is it maybe a user private call ?
            TGindex=search_user_index_for_ID(nr,users,0,nmbr_users-1);
			writelog(LOG_DEBUG,"- Found [%s] for ID %d",users[TGindex].data1,TGindex);
            if (TGindex>=0) sprintf(TXbuffer,"t8.txt=\"Private %s\"",users[TGindex].data1);
        } else {
            sprintf(TXbuffer,"t8.txt=\"TG%d name not found\"",nr);
        }
        sendCommand(TXbuffer);
    }
	

    //send user data if found
    if (((page==1)||(page==3)||(page==4)||(page==5))&&(strstr(TXbuffer,"t0.txt")!=NULL)) { // for D-Star, YSF, P25 and NXDN
        int user;

        sendCommand(TXbuffer);

        user=0;
	if (strstr(TXbuffer,"Listening")==NULL) {
            TXbuffer[strlen(TXbuffer)-1]=' ';
            char* l=strchr(&TXbuffer[10], ' ');
            if (l!=NULL) l[0]=0;
            writelog(LOG_DEBUG,"Search for call [%s] \n",&TXbuffer[10]);
            user=search_user_index_for_CALL(&TXbuffer[10],usersCALL_IDX,0,nmbr_users-1);
            writelog(LOG_DEBUG,"- Found user [%s] for CALL %s",users[user].data1,&TXbuffer[10]);
            if (user>0) {
                sprintf(TXbuffer,"t13.txt=\"%s\"",users[user].data1);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t14.txt=\"%s\"",users[user].data2);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t15.txt=\"%s\"",users[user].data3);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t16.txt=\"%s\"",users[user].data4);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t17.txt=\"%s\"",users[user].data5);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t18.txt=\"%s\"",users[user].data6);
            	sendCommand(TXbuffer);
	    } else {
         	sendCommand("t13.txt=\"\"");
                sendCommand("t14.txt=\"Callsign\"");
                sendCommand("t15.txt=\"not found in\"");
                sendCommand("t16.txt=\"in database\"");
                sendCommand("t17.txt=\"\"");
                sendCommand("t18.txt=\"\"");
            }
        } else {
            sendCommand("t13.txt=\"\"");
            sendCommand("t14.txt=\"\"");
            sendCommand("t15.txt=\"\"");
            sendCommand("t16.txt=\"\"");
            sendCommand("t17.txt=\"\"");
            sendCommand("t18.txt=\"\"");
	}
	if (page==1)
            sendCommand("MMDVM.status.val=49");
	else if (page==3)
	    sendCommand("MMDVM.status.val=89");
	else if (page==4)
	    sendCommand("MMDVM.status.val=109");
	else if (page==5)
	    sendCommand("MMDVM.status.val=129");
        sendCommand("click S0,1");
    }

    if ((page==2)&&(strstr(TXbuffer,"t0.txt")!=NULL)) { // for DMR - TS1
        int user;

        sendCommand(TXbuffer);

        user=0;
	if (strstr(TXbuffer,"Listening")==NULL) {
            TXbuffer[strlen(TXbuffer)-1]=' ';
            char* l=strchr(&TXbuffer[12], ' ');
            if (l!=NULL) l[0]=0;
            writelog(LOG_DEBUG,"Search for call [%s] \n",&TXbuffer[12]);
            user=search_user_index_for_CALL(&TXbuffer[12],usersCALL_IDX,0,nmbr_users-1);
            writelog(LOG_DEBUG,"- Found user [%s] for CALL %s",users[user].data1,&TXbuffer[12]);
            if (user>0) {
                sprintf(TXbuffer,"t23.txt=\"%s\"",users[user].data1);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t24.txt=\"%s\"",users[user].data2);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t25.txt=\"%s\"",users[user].data3);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t26.txt=\"%s\"",users[user].data4);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t27.txt=\"%s\"",users[user].data5);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t28.txt=\"%s\"",users[user].data6);
            	sendCommand(TXbuffer);
	    } else {
         	sendCommand("t23.txt=\"\"");
                sendCommand("t24.txt=\"Callsign\"");
                sendCommand("t25.txt=\"not found in\"");
                sendCommand("t26.txt=\"in database\"");
                sendCommand("t27.txt=\"\"");
                sendCommand("t28.txt=\"\"");
            }
        } else {
            sendCommand("t23.txt=\"\"");
            sendCommand("t24.txt=\"\"");
            sendCommand("t25.txt=\"\"");
            sendCommand("t26.txt=\"\"");
            sendCommand("t27.txt=\"\"");
            sendCommand("t28.txt=\"\"");
	}
        sendCommand("MMDVM.status.val=79");
        sendCommand("click S0,1");
    }

	
    if ((page==2)&&(strstr(TXbuffer,"t2.txt")!=NULL)) { // for DMR - TS2
        int user;

        sendCommand(TXbuffer);

        user=0;
	if (strstr(TXbuffer,"Listening")==NULL) {
            TXbuffer[strlen(TXbuffer)-1]=' ';
            char* l=strchr(&TXbuffer[12], ' ');
            if (l!=NULL) l[0]=0;
            writelog(LOG_DEBUG,"Search for call [%s] \n",&TXbuffer[12]);
            user=search_user_index_for_CALL(&TXbuffer[12],usersCALL_IDX,0,nmbr_users-1);
            writelog(LOG_DEBUG,"- Found user [%s] for CALL %s",users[user].data1,&TXbuffer[12]);
            if (user>0) {
                sprintf(TXbuffer,"t13.txt=\"%s\"",users[user].data1);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t14.txt=\"%s\"",users[user].data2);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t15.txt=\"%s\"",users[user].data3);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t16.txt=\"%s\"",users[user].data4);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t17.txt=\"%s\"",users[user].data5);
            	sendCommand(TXbuffer);
            	sprintf(TXbuffer,"t18.txt=\"%s\"",users[user].data6);
            	sendCommand(TXbuffer);
	    } else {
         	sendCommand("t13.txt=\"\"");
                sendCommand("t14.txt=\"Callsign\"");
                sendCommand("t15.txt=\"not found in\"");
                sendCommand("t16.txt=\"in database\"");
                sendCommand("t17.txt=\"\"");
                sendCommand("t18.txt=\"\"");
            }
        } else {
            sendCommand("t13.txt=\"\"");
            sendCommand("t14.txt=\"\"");
            sendCommand("t15.txt=\"\"");
            sendCommand("t16.txt=\"\"");
            sendCommand("t17.txt=\"\"");
            sendCommand("t18.txt=\"\"");
	}
        sendCommand("MMDVM.status.val=78");
        sendCommand("click S0,1");
    }

}