Insteon Integrated! EZBridge now, PLM soon

Ok, I'll take the lack of responses as noone knows... I'm reinstalling linuxmce from the DVD now...

FYI, I have successfully implemented Insteon via an EZ Bridge. Code still a bit buggy (I'm learning ruby as I go, and it's changed considerably from what I posted earlier)

I figured out the messaging back to linuxmce.. sort of...

Now that I'm getting more familiar with Ruby, I want to re-write my routines to implement a message queue. (Ruby isn't threaded, and crashes if attempted). I need two queues, 1 for commands from MCE to Insteon, and another for back.

I've written my code to be as object oriented as possible so most of it I can reuse. Basic commands are implemented, along with framework for implementing groups, etc. I'd like to also implememt a 'spider' to detect insteon devices not currently installed.

PeteK, Thank you for all your help.. As I do not have a PLC, I cannot develop for that, however, I have both a PLM and an EZ-Bridge, so I'll be integrating the PLM in ruby next. Basically their the same thing, the EZ-Bridge connects the PLM to ethernet, and uses XML rather than bytes, but almost everything in is pretty much the same.

Code you say?? hehe, thought you'd never ask...

I am posting my current code, I tried to put a 'busy' flag in, and broke it... hence why I'll implement queues. Here it is...

Comments are welcome and encouraged!

If you use this, please let me know, It's free, but a lot of sweat went into this so far... I'd like gratification SOMEONE is using it other than me.

#### Written by Dan Damron #### #373 Private Method Listing #### # # Commands send back to DCE # 184 - SetLevel value 0-100 (% on) or +-1 for steps # 193 - Turn Light OFF # 192 - Turn Light ON # # # # require "rexml/document" include REXML def log(line) $log = File.open("/var/log/pluto/insteon1.log", "a") $log.puts line.to_s $log.close end def parseMessage(param) #get parameter name instruction = param.keys[1] # log('instruction=:' + instruction + ':') case instruction when 'Parameter2' # Standard Command #get parameter value insvalue = param[instruction] case insvalue when '0X50' # InsStdMsg log('Standard Insteon Message') log('From ' + $cmdTo.to_s + ', To ' + $cmdFrom.to_s + ', Pri ' + $cmdPriority.to_s + ', Type ' + $cmdType.to_s + ', ID ' + $cmdID.to_s) sndCommand = Command.new($cmdTo, $cmdFrom, $cmdPriority, $cmdType, $cmdID) sndCommand.params_ = $cmdParams insHb = "%X" %param['Parameter3'].hex insMb = "%X" %param['Parameter4'].hex insLb = "%X" %param['Parameter5'].hex insID = insHb + "." + insMb + "." + insLb insFlags = "%X" %param['Parameter9'].hex insCmd1 = "%X" %param['Parameter10'].hex insCmd2 = "%X" %param['Parameter11'].hex log('From:' + insID + ', cmd1:' + insCmd1 + ', cmd2:' + insCmd2) case insCmd1 when '1' # Assign to Group(inscmd2) when '2' # Delete from Group(inscmd2) when '10' # ping when '11' # ON Level(inscmd2) # sndCommand.params_[184] = hextopercent(insCmd2).to_s # sndCommand.params_[76] = hextopercent(insCmd2).to_s if insCmd2 = 'FF' then # sndCommand.params_[192] = '' # sndCommand.params_[97] = '' # sndCommand.params_[98] = '' end SendCommand(sndCommand) when '13' # off (cmd2=none or Group#) # sndCommand.params_[76] = '0' # sndCommand.params_[97] = '' # sndCommand.params_[98] = '' # sndCommand.params_[184] = '0' # sndCommand.params_[193] = '' SendCommand(sndCommand) when '15' # Bright (cmd2=# of steps) # sndCommand.params_[184] = '+' + indCmd2.hex.to_s SendCommand(sndCommand) when '16' # Dim (cmd2=# of steps) # sndCommand.params_[184] = '-' + indCmd2.hex.to_s SendCommand(sndCommand) when '17' # Start Manual Change (cmd2, 1=Up, 0=Down) when '18' # Stop Manual Change when '19' # Status Request (see docs) when '24' # Do Read EEPROM when '28' # Set MSB for peek/poke end when '0X51' # InsExtMsg log('Extended Insteon Message') when '0X52' # X10Msg log('X10 Message') when '0X53' # InsLnkSts log('Insteon Link Status Report') when '0X54' # BtnRpt log('Insteon Button Report') when '0X55' # UsrRst log('User Reset') when '0X56' # GrpEventRpt log('Group Member Failure') when '0X57' # LnkData log('PLM Link Database Record') linkFlags = "%X" %param['Parameter3'].hex group = "%X" %param['Parameter4'].hex insHb = "%X" %(param['Parameter5'].hex) insMb = "%X" %(param['Parameter6'].hex) insLb = "%X" %(param['Parameter7'].hex) insID = insHb + "." + insMb + "." + insLb lnkData = "%X" %param['Parameter8'].hex lnkData += ".%X" %param['Parameter9'].hex lnkData += ".%x" %param['Parameter10'].hex log(insID + ", G:" + group + ", F:" + linkFlags + ", D:" + lnkData) $links[insID] = linkFlags + group + lnkData when '0X60' # GetVersion log('PLM Version Information') when '0X73' # GetCfg end end $busy = false log('\busy - send command to DCE') end # create a new XML command for SndIns def SndIns(command, param) log('Command = ' + command) doc = Document.new doc << XMLDecl.new el = doc.add_element 'command' el.text = command param.keys.each {|k| el1 = el.add_element k el1.text = param[k]} # log('SndIns:CmdSent:' + doc.to_s) conn_.Send(doc.to_s) $cmd=command log('Command Sent:' + $cmd) $busy = false log('/busy - Sent Insteon Command') end def percenttohex(level) # convert from percent to byte return "%X" %((level.to_i * 2.56) -1).to_i end def hextopercent(level) return (level.hex.to_i / 2.55).to_i end ************************************************************************************ ### PROCESS-IDLE *** if $getConfig == 'PLM' then log 'Getting Links...' command = 'GetNext' param = {} SndIns(command, param) end if $getConfig == 'LstDevices' then command = 'LstDevices' param = {} SndIns(command, param) end ************************************************************************************ #### Written by Dan Damron #### #350 Process Incoming Data #### #log('Entered Process Incoming Data') #log('ReceiveData:$resposeString=' + $responseString) recv = "" #while ($busy == false) while(recv <=> $responseString) # log('recv <=> $responseString = ' + (recv <=> $responseString).to_s) buff=conn_.RecvDelimited($responseString, 10) if(buff.length() == 0) break end recv += buff log("RecvLoop:" + (recv <=> $responseString).to_s) end end #log('Busy Process incoming data') $busy = true log("*** INCOMING from INSTEON:\n") #log('$cmd=:' + $cmd + ':') #log(recv) # recv now contains XML param = {} # hash to save data elname = "" eltext = "" #parse XML into hash doc = Document.new recv command = doc.root.get_text.value.to_s if doc.root.has_elements? then #has elements el = doc.root.elements[1] while el != nil elname = el.name.to_s eltext = doc.root.elements[elname].text.to_s # log(elname + '=' + eltext) param[elname] = eltext el = doc.root.elements[elname].next_element end end if $cmd == "" then # not waiting for a command ack. log('Command received') parseMessage(param) else # log($cmd <=> command) log(':' + $cmd + ': <=> :' + command + ': = ' + ($cmd <=> command).to_s) if ($cmd <=> command)> -1 then #command response received #check for ack # log(param[param.keys.last].to_s) if param[param.keys.last].to_s == '0X6' then log('Command Successfull') else log('Command NOT successfull') end $cmd = "" else #waiting for ack, but received another command log('waiting for ' + $cmd + ' but got ' + command + 'instead') #parseMessage(param) end #log('/busy - process incoming data') #$busy = false #end ************************************************************************************ #### Written by Dan Damron #### #355 Process Initialize #### $log = File.new("/var/log/pluto/insteon1.log", "w") $bFlush = true $waitTime = 4000 $links = {} $cmdTo = '' $cmdFrom = '' $cmdPriority = '' $cmdType = '' $cmdID = '' $cmdParams = {} $busy = false $x10HouseCodes = {'6', 'A', 'E', 'B', '2', 'C', 'A', 'D', '1', 'E', '9', 'F', '5', 'G', 'D', 'H', '7', 'I', 'F', 'J', '3', 'K', 'B', 'L', '0', 'M', '8', 'N', '4', 'O', 'C', 'P'} $X10UnitCodes = {'6', '1', 'E', '2', '2', '3', 'A', '4', '1', '5', '9', '6', '5', '7', 'D', '8', '7', '9', 'F', '10', '3', '11', 'B', '12', '0', '13', '8', '14', '4', '15', 'C', '16'} $X10CommandCodes = {'6', 'All Lights Off', 'E', 'Status = off', '2', 'On', 'A', 'Pre-Set Dim', '1', 'All Lights On', '9', 'Hail Ack', '5', 'Bright', 'D', 'Status=on', '7', 'Extended Code', 'F', 'Status Request', '3', 'Off', 'B', 'Pre-set Dim', '0', 'All Units Off', '8', 'Hail Request', '4', 'Dim', 'C', 'Extended Data(analog)'} #$getConfig = 'PLM' #$getConfig = 'LstDevices' $getConfig = '' $responseString = '<' + '/' + 'Response' + '>' log('Getting Links...') #command = 'GetLnk' #param = {} #SndIns(command, param) ************************************************************************************ #### Written by Dan Damron #### #384 Process Receive Command for Child #### #if $busy==true then # break #end #$busy = true #log('busy=true - Recv cmd for Child') #log('We got cmd: ' + cmd.id_.to_s) insteonID = device_.childdevices_[cmd.devidto_].devdata_[12].chomp.split('.') $cmdID = cmd.id_ $cmdTo = cmd.devidto_ childType = device_.childdevices_[cmd.devidto_].devtemplid_ $cmdFrom = cmd.devidfrom_ $cmdPriority = cmd.priority_ $cmdType = cmd.type_ $cmdParams = cmd.params_ log('cmdID:' + $cmdID.to_s + ', cmdFrom:' + $cmdFrom.to_s + ', cmdTo:' + $cmdTo.to_s + ', cmdType:' + $cmdType.to_s + ', Priority:' + $cmdPriority.to_s) $cmdParams.keys.each {|p| log('Param_[' + p.to_s + ']=' + $cmdParams[p])} case cmd.id_ when 192 command = 'SndIns' param = {'Parameter1' => insteonID[0], 'Parameter2' => insteonID[1], 'Parameter3' => insteonID[2], 'Parameter4' => '0F', 'Parameter5' => '11', 'Parameter6' => 'FF'} SndIns(command, param) when 193 command = 'SndIns' param = {'Parameter1' => insteonID[0], 'Parameter2' => insteonID[1], 'Parameter3' => insteonID[2], 'Parameter4' => '0F', 'Parameter5' => '13', 'Parameter6' => '00'} SndIns(command, param) when 184 # convert from percent to hex dim_level = percenttohex(cmd.params_[76]).to_i command = 'SndIns' param = {'Parameter1' => insteonID[0], 'Parameter2' => insteonID[1], 'Parameter3' => insteonID[2], 'Parameter4' => '0F', 'Parameter5' => '11', 'Parameter6' => dim_level} SndIns(command, param) end #$busy = false #log('finished recv cmd for child - busy set to false')