Enhance the examples folder

[AutomGuy]

what do you think about the extension of the examples folder with examples in other programming languages like e.g. php
Best Regards

[zuckschwerdt]

I like the idea, but would want to limit it to very simple examples like https://github.com/merbanan/rtl_433/blob/master/examples/rtl_433_custom.py

Not sure if people are running "server"-style (long running daemon) PHP code? I only ever see "script"-style (execute one short task) code.

[AutomGuy]

Hi Christian @zuckschwerdt , here one short example with rtl433 an a php udp server, with the associated service files
system is ubuntu, lubuntu, xubuntu, debian, ubuntu core and so on.

pre-condition -> php_cli have to be installed

Service file for start the rtl433 software

[Unit]
Description=rtl433 udp service
After=network.target
[Service]
Restart=always
RestartSec=5
RemainAfterExit=no
User=root
ExecStart=/bin/bash -c "/usr/bin/rtl_433 -f 433920000 -f 433920000 -H 120 -F syslog:127.0.0.1:1433"

[Install]
WantedBy=multi-user.target

---

service file for start the php udp server

[Unit]
Description=syslog 433 udp service
After=network.target
StartLimitIntervalSec=0
[Service]
Type=simple
Restart=always
RestartSec=1
User=root
ExecStart=/usr/bin/php /home/haserver/homeautomation/udp/udpserver.php "0"

[Install]
WantedBy=multi-user.target

---

*php udp server it self udpserver.php

#!/usr/bin/php
<?php
//udp server
error_reporting(E_ALL | E_STRICT);

//switch on debug mode
$debug = "1";
if(sizeof($argv) > 1)
{
  $debug  = $argv[1];
}
//udp server IP and Port for listen
$UDP_IP = "127.0.0.1";
$UDP_PORT = 1433;
//create socket and bind them
$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
socket_bind($socket, $UDP_IP, $UDP_PORT);
//init of this variables
$from = '';
$port = 0;

//use the output of rtl_433 -f 433920000 -f 433920000 -H 120 -F syslog:127.0.0.1:1433"
//returns the json payload
function parse_syslog($line)
{
    //Try to extract the payload from a syslog line.//
    $line =  mb_convert_encoding($line, "ASCII");
    
    if(startsWith($line,"<"))
    {
        //fields should be "VER", timestamp, hostname, command, pid, mid, sdata, payload
        $fields = explode(" ",$line, 8);
        $line = $fields[7];
    }
    return $line;
}

//server main loop
for(;;)
{
  //read from $socket into $line
  socket_recvfrom($socket, $line, 1024, 0, $from, $port);
  try
  {
   //parse $line -> returns the json payload
   $line = parse_syslog($line);

   /*
     do something with content of $line
     for example decode $line into a array
     $arr = json_decode($line,true);
     
     do something with that array and
     puted into a file as json
     
     file_put_contents('test.json', json_encode($arr, JSON_PRETTY_PRINT);
     
   */
   
  }
  catch(Exception $e) {
   echo "---------------------------------------------\n";
   echo 'Exception intercepted: ',  $e->getMessage(), "\n"; 
   echo "------------------------------------------- -\n";  
  }

}
?>
 

---

Best Regards

[AutomGuy]

I have been using this constellation for about 2 years. :)

[zuckschwerdt]

Interesting, looks easy enough. Do you want to PR that file (with the systemd examples as comment block preferably)? Or should I commit that for you?

[AutomGuy]

Christian @zuckschwerdt it will be awesome when you can commit that for me.
Many Thx

[zuckschwerdt]

Added with 9cd036e

[AutomGuy]

Christian @zuckschwerdt ,

during all my tests i have a solution more to distribute sensor datas by using "piping" the example are writen in php.
firstable Unit file

[Unit]
Description=syslog 433 udp service
After=network.target
StartLimitIntervalSec=0
[Service]
Type=simple
Restart=always
RestartSec=1
User=root
ExecStart=  rtl_433 -f 433920000 -f 433920000 -H 120 -F json: | /usr/bin/php /home/haserver/homeautomation/udp/stdin.php

[Install]
WantedBy=multi-user.target

and here the stdin.php

<?php

    $host = "127.0.0.1";
    $port = 1435;
    stream_set_blocking(STDIN, 0);
    $sock = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);

    //convinence function for php version below 8.0
    function startsWith( $haystack, $needle ) {
        $length = strlen( $needle );
        return substr( $haystack, 0, $length ) === $needle;
    }

    function endsWith( $haystack, $needle ) {
        $length = strlen( $needle );
        if( !$length ) {
            return true;
        }
        return substr( $haystack, -$length ) === $needle;
    }

    function str__contains($haystack,$needle)
    {
     $res = false;
     if (preg_match("/{$needle}/i", $haystack)) 
     {
      $res = true;
     }
      else 
     {
      $res = false;
     }
     return $res;
    }

    //main loop
    for(;;)                                                                                                                                                                                                        
    {                                                                                                                                                                                                              
     $line =  stream_get_line(STDIN, 1024, "\n");                                                                                                                                                                  
                                                                                                                                                                                                                   
     if(false !== $line && startsWith($line, "{") == true)                                                                                                                                                         
     {                                                                                                                                                                                                             
       $line =  $line . "\n" ;                                                                                                                                                                                     
       $len = strlen($line);                                                                                                                                                                                       
       socket_sendto($sock, $line, $len, 0, $host , $port);                                                                                                                                                 
       //echo $line;                                                                                                                                                                                               
     }                                                                                                                                                                                                             
    }                                                                                                                                                                                                              
    socket_close($sock);                                                                                                                                                                                           
?>

it takes the json output and send it one by one to a udp server without syslog protocol
might be interested for someone :)

Best Regards

[zuckschwerdt]

We usually do not recommend pipes. For long running servers a robust method like UDP or TCP (web API) is easier.

[AutomGuy]

Ok understud. 👍