---

procrwil.cpp

Go to the documentation of this file.

#include "rwil.h"
#include "procrwil.h"
#include "X10Device.h"
#include "X10Recv.h"

#include <stdio.h>
using namespace rwil;


static void rwil_callback(const list<Message>& messages);


rwil_handle rwil_init()
{
  RWIL *ptr = new RWIL;
  rwil_handle handle;
  ptr->Start();
  ptr->AddDevice(new X10Recv("rwil_x10_listener", ptr->output));
  handle = ptr;
  ptr->output.SetAddCallback(rwil_callback);
  return handle;
}

rwil_device rwil_create(rwil_handle rwilhandle, char house, int num)
{
  char buf[20];
  int val;
  RWIL *rwil = (RWIL*)rwilhandle;
  rwil_device device;
  val = (house << 16) + num;
  sprintf(buf, "%d", val);
  X10Device *dev = new X10Device(buf, rwil->output, house, num);
  rwil->AddDevice(dev);
  device.handle = rwilhandle;
  device.dev_handle = val;
  return device;
}

void rwil_destroy(rwil_device handle)
{
  RWIL *rwil = (RWIL*)handle.handle;
  char buf[20];
  sprintf(buf, "%d", handle.dev_handle);
  rwil->RemoveDevice(buf);
}

void rwil_on(rwil_device handle, time_t when)
{
  rwil_setbright(handle, 100, when);
}
void rwil_off(rwil_device handle, time_t when)
{
  rwil_setbright(handle, 0, when);
}

void rwil_setbright(rwil_device handle, int brightness, time_t when)
{
  RWIL *rwil = (RWIL*)handle.handle;
  char buf[20];
  sprintf(buf, "%d", handle.dev_handle);

  Message msg(buf, "dim", when);
  msg.SetParam("percent", IntToString(brightness));
  msg.SetParam("rwilhandle", IntToString((int)rwil));
  rwil->input.Add(msg);
}

void rwil_interpolatebright(rwil_device handle, int startbrightness, int endbrightness, time_t startwhen, time_t endwhen, int steps)
{
  RWIL *rwil = (RWIL*)handle.handle;
  char buf[20];

  time_t timedif = endwhen - startwhen;
  int brightdif = endbrightness - startbrightness;

  sprintf(buf, "%d", handle.dev_handle);

  int count = 0;
  for(count = 0; count < steps; count++)
  {
    Message msg(buf, "dim", startwhen + timedif * count / steps);
    msg.SetParam("percent", IntToString(startbrightness + brightdif * count / steps));

    //Ensure that the callback is only called by the last change in brightness
    if((count + 1)== steps)msg.SetParam("rwilhandle", IntToString((int)rwil));
    rwil->input.Add(msg);
  }
}

int rwil_getbright(rwil_device handle)
{
  RWIL *rwil = (RWIL*)handle.handle;
  char buf[20];
  sprintf(buf, "%d", handle.dev_handle);

  X10Device* dev = (X10Device *)rwil->GetDevice(buf);
  return StringToInt(dev->GetStatus());
}

int rwil_ison(rwil_device handle)
{
  if(rwil_getbright(handle)) return 1;
  return 0;
}
static rwil_success_callback_t success_call = NULL;
static rwil_failure_callback_t failure_call = NULL;
static rwil_x10_listener_t listener_call = NULL;


void rwil_success_callback(rwil_success_callback_t callback)
{
  success_call = callback;
}

void rwil_failure_callback(rwil_failure_callback_t callback)
{
  failure_call = callback;
}

void rwil_set_x10_listener(rwil_x10_listener_t callback)
{
  listener_call = callback;
}

void rwil_shutdown(rwil_handle rwilhandle)
{
  RWIL *rwil = (RWIL*)rwilhandle;
  rwil->Kill();
  rwil->Join();
  delete rwil;
}

static void rwil_callback(const list<Message>& messages)
{
  list<Message>::const_iterator iter;

  iter = messages.begin();
  rwil_device dev;
  while(iter != messages.end())
    {
      std::string str = iter->GetParam("rwilhandle");
      if(str=="")
        {
          if(iter->GetDevice().compare("rwil_x10_listener") == 0)
          { // got a listener message
            if(listener_call != 0)
            {
              listener_call(iter->GetParam("house")[0], StringToInt(iter->GetParam("number")), iter->GetCommand().c_str());
            }
          }
          iter++;
          continue;
        }
      dev.handle = (void *)StringToInt(str);
      dev.dev_handle = StringToInt(iter->GetDevice());
      str = iter->GetParam("message");
      if(str == "success")
        {
          if(success_call)
            {
              success_call(dev);
            }
        }
      else
        {
          if(failure_call)
            {
              failure_call(dev, str.c_str());
            }
        }
      iter++;
    }
}

---