main.cpp

#include <glib.h>
#include <string>
#include <luna-service2/lunaservice.h>
#include <wiringPi.h>
#include <wiringSerial.h>
#include <wiringPiI2C.h>
#include <wiringPiSPI.h>
#include <json-c/json.h>
#include "./include/logging.h"
#include "./include/gpioBase.h"

static bool cbHello(LSHandle *sh, LSMessage* message, void* ctx)
{
    int i = 0;
    LSError lserror;
    json_object *pinObj;
    json_object *pinNum;
    int num=0;
   
    GPIO_LOG_DEBUG("test");
    pinObj = json_tokener_parse(LSMessageGetPayload(message));

    pinNum = json_object_object_get(pinObj,"pinNum");
    num = json_object_get_int(pinNum);
    
    if(!num) {
	LSMessageReplyErrorBadJson(sh,message);
    }


    if(wiringPiSetup() == -1) {
	LSMessageReplySetupFail(sh, message);
	return false;
    }

    pinMode(num, OUTPUT);
    
    for(i=0; i<10; i++) {
	digitalWrite(num, 1);
	delay(1000);
	digitalWrite(num, 0);
	delay(1000);
    }

    LSMessageReplySuccess(sh, message);
    return true;
}

static bool setWiringPi(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;

   if(wiringPiSetup() == -1)
   {
	LSMessageReplySetupFail(sh, message);
	return false;
   }
  
   LSMessageReplySuccess(sh, message);
   return true;
}

static bool setWiringPiPhys(LSHandle *sh, LSMessage* message, void *ctx) 
{
   LSError lserror;

   if(wiringPiSetupPhys() == -1)
   {
	LSMessageReplySetupFail(sh, message);
	return false;
   }
   
   LSMessageReplySuccess(sh, message);
   return true;

}

static bool setWiringPiSys(LSHandle *sh, LSMessage* message, void *ctx) 
{
   LSError lserror;

   if(wiringPiSetupSys() == -1)
   {
	LSMessageReplySetupFail(sh, message);
	return false;
   }
 
   LSMessageReplySuccess(sh, message);
   return true;

}

static bool setPinMode(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num, mode;
   json_object *pinObj;
   json_object *pinNum;
   json_object *pinmode;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   pinmode = json_object_object_get(pinObj,"pinMode");
   num = json_object_get_int(pinNum);
   mode = json_object_get_int(pinmode);
    
   if((!num) || (!mode)) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   pinMode(num, mode);
   LSMessageReplySuccess(sh, message);
   
   return true;
}

static bool digitWrite(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num, value;
   json_object *pinObj;
   json_object *pinNum;
   json_object *pinValue;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   pinValue = json_object_object_get(pinObj,"pinValue");
   num = json_object_get_int(pinNum);
   value = json_object_get_int(pinValue);
    
   if((!num) || (!value)) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   digitalWrite(num, value);
   LSMessageReplySuccess(sh, message);
   
   return true;
}

static bool setPullUpDnControl(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num, pud;
   json_object *pinObj;
   json_object *pinNum;
   json_object *pinPud;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   pinPud = json_object_object_get(pinObj,"pinPud");
   num = json_object_get_int(pinNum);
   pud = json_object_get_int(pinPud);
    
   if((!num) || (!pud)) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   pullUpDnControl(num,pud);
   LSMessageReplySuccess(sh, message);
   
   return true;
}

static bool writePwm(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num, pwm;
   json_object *pinObj;
   json_object *pinNum;
   json_object *pinPwm;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   pinPwm = json_object_object_get(pinObj,"pinPwm");
   num = json_object_get_int(pinNum);
   pwm = json_object_get_int(pinPwm);
    
   if((!num) || (!pwm)) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   pwmWrite(num, pwm);
   LSMessageReplySuccess(sh, message);
   
   return true;
}
static bool digitRead(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num;
   json_object *pinObj;
   json_object *pinNum;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   num = json_object_get_int(pinNum);
    
   if(!num) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   digitalRead(num);
   LSMessageReplySuccess(sh, message);
   
   return true;
}
static bool analRead(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num;
   json_object *pinObj;
   json_object *pinNum;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   num = json_object_get_int(pinNum);
    
   if(!num) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   analogRead(num);
   LSMessageReplySuccess(sh, message);
   
   return true;
}
static bool analWrite(LSHandle *sh, LSMessage* message, void *ctx)
{
   LSError lserror;
   int num, value;
   json_object *pinObj;
   json_object *pinNum;
   json_object *pinValue;
   
   pinObj = json_tokener_parse(LSMessageGetPayload(message));

   pinNum = json_object_object_get(pinObj,"pinNum");
   pinValue = json_object_object_get(pinObj,"pinValue");
   num = json_object_get_int(pinNum);
   value = json_object_get_int(pinValue);
    
   if((!num) || (!value)) {
      LSMessageReplyErrorBadJson(sh,message);
      return false;
   }

   analogWrite(num, value);
   LSMessageReplySuccess(sh, message);
   
   return true;
}

static LSMethod serviceMethods[] = {
   { "gpio", cbHello }, 
   {"setWiringPi", setWiringPi},
   {"setWiringPiPhys", setWiringPiPhys},
   {"setWiringPiSys", setWiringPiSys},
   {"setPinMode", setPinMode},
   {"digitWrite", digitWrite},
   {"setPullUpDnControl", setPullUpDnControl},
   {"writePwm", writePwm},
   {"digitRead", digitRead},
   {"analRead", analRead},
   {"analWrite", analWrite}
};
 
int main(int argc, char* argv[])
{
    LSError lserror;
    LSErrorInit(&lserror);
 
    GMainLoop* mainLoop = g_main_loop_new(nullptr, false);
    LSHandle *m_handle = nullptr;   
 
    if(!LSRegister("com.webos.service.rpi.gpio", &m_handle, &lserror))
    {
        g_print("Unable to register to luna-bus\n");
        LSErrorPrint(&lserror, stdout);
 
        return false;
    }
 
    if (!LSRegisterCategory(m_handle, "/", serviceMethods, NULL, NULL, &lserror))
    {
        g_print("Unable to register category and method\n");
        LSErrorPrint(&lserror, stdout);
 
        return false;
    }
 
    if(!LSGmainAttach(m_handle, mainLoop, &lserror))
    {
        g_print("Unable to attach service\n");
        LSErrorPrint(&lserror, stdout);
 
        return false;
    }
 
    g_main_loop_run(mainLoop);
 
    if(!LSUnregister(m_handle, &lserror))
    {
        g_print("Unable to unregister service\n");
        LSErrorPrint(&lserror, stdout);
 
        return false;
    }
 
    g_main_loop_unref(mainLoop);
    mainLoop = nullptr;
 
    return 0;
}