---

X10Recv.cpp

Go to the documentation of this file.

#include <unistd.h> /* UNIX standard function definitions */
#include <fcntl.h>
#include <stdio.h>
#include <unistd.h>
#include <termios.h>
#include <sys/ioctl.h>

#include "X10Recv.h"
#include "SerialOp.h"

namespace rwil {
using namespace SerialOp;
std::string X10Recv::GetRealHouse(char house) const
{
  switch(house)
  {
    case 'F' : return "A";
    case 'N' : return "B";
    case 'B' : return "C";
    case 'J' : return "D";
    case 'A' : return "E";
    case 'I' : return "F";
    case 'E' : return "G";
    case 'M' : return "H";
    case 'G' : return "I";
    case 'O' : return "J";
    case 'C' : return "K";
    case 'K' : return "L";
    case '@' : return "M";
    case 'H' : return "N";
    case 'D' : return "O";
    case 'L' : return "P";
    }
  return "";
  assert(0); //should never get here
}

  std::string X10Recv::GetRealNumber(char unitnumber) const
  {
    switch(unitnumber)
      {
      case 'L' : return "1";
      case '\\' : return "2";
      case 'D' : return "3";
      case 'T' : return "4";
      case 'B' : return "5";
      case 'R' : return "6";
      case 'J' : return "7";
      case 'Z' : return "8";
      case 'N' : return "9";
      case '^' : return "10";
      case 'F' : return "11";
      case 'V' : return "12";
      case '@' : return "13";
      case 'P' : return "14";
      case 'H' : return "15";
      case 'X' : return "16";
      }
    return "";
    assert(0); //should never get here  
  }
  
std::string X10Recv::GetMessageType(char type) const
{
  switch(type)
  {
    case 'A' : return "all-units-off";
    case 'C' : return "all-lights-on";
    case 'E' : return "on";
    case 'G' : return "off";
    case 'I' : return "dim";
    case 'K' : return "bright";
    case 'M' : return "all-lights-off";
    case 'O' : return "extended-code";
    case 'Q' : return "hail-request";
    case 'W' : return "pre-set-dim-high";
    case 'U' : return "pre-set-dim-low";
    case 'Y' : return "extended-data";
    case '[' : return "status-on";
    case ']' : return "status-off";
    case '_' : return "status-request";
  }
  return "";
  assert(0);
}

bool X10Recv::Tick()
{
  std::string messagetype;
  std::string unitnumber;
  std::string house;
  char buf[5];
  //check to see if 5 bytes .. or more are sitting there.
  int waiting;
  if(fd==0)
  {
        open_port();
        configure_port();
  }
  
  while(true)
  {
    int n;
    ioctl(fd, FIONREAD, &waiting);
    if(waiting < 5) return false;

    n = read(fd, buf, 1);
    if(n < 0) return false;
    if(n == 1)
    {
      if((buf[0] == 0x58) || (buf[0] == 0x78))
        break;
    }
  }
  
  //read 5 bytes
  int n;
  int totalread = 0;
  while(totalread < 4)
  {
    n = read(fd, buf + 1 + totalread, 4-totalread);
    if(n < 0) return false;
    totalread += n;
  }
  house = GetRealHouse(buf[1]);
  unitnumber = GetRealNumber(buf[2]);
  messagetype = GetMessageType(buf[2]);


  if(!((buf[4] == 0x0d) || (buf[4] == 0x0a))) return false;
  if(house.length() == 0) return false;
  if((unitnumber.length() == 0) && (messagetype.length() == 0)) return false;
  if(unitnumber.length())
  {
        activenums[house] = unitnumber;
        return true;
  }
  if(activenums[house].length() == 0) return true;
  //If here we've got a complete message.
  Message msg(GetName(), messagetype);
  msg.SetParam("house", house);
  msg.SetParam("number", activenums[house]);
  m_output.Add(msg);
  //verify that its a message
  
}

}// end namesapce

---