<?php
function get_new_events($room) {
   $tracking_file = "/tmp/listen_matrix_owncast.json";
   $since = file_get_contents($tracking_file);
   if(empty($since))
      $since = "s1022334_0_0_0_0_0_0_0_0";
   $homeserver = "matrix.homeserver.com";
   $access_token = "YOUR_MATRIX_ACCESS_TOKEN HERE";
   $url = "https://$homeserver/_matrix/client/r0/rooms/$room/messages?access_token=$access_token&from=$since";
   $data = json_decode(file_get_contents($url), true);
   $new_tracking_data = $data['end'];
   file_put_contents($tracking_file, $new_tracking_data);
   return $data;
}

$room_id = "!room_id:homeserver";

$sender_name = "@botname:homeserver"; // IMPORTANT: Set this to the name of the user associated with the access token, this stops it from getting stuck in a loop (and repeating what is said in both rooms forever).

while(true) {
$data = get_new_events($room_id);

if(is_array($data['chunk']) and sizeof($data['chunk'])>0) {
   foreach($data['chunk'] as $message) {
      if($message['sender'] != $sender_name) {
         if($message['content']['msgtype'] == "m.text") {
            if(!empty($message['content']['body'])) {
               $nick_parts = explode(":", $message['sender']);
               $relay = "[".substr($nick_parts[0],1)."] ".$message['content']['body'];
               echo $relay."\n";
               send_owncast_system_message($relay);
            }
         }
      }
   }
}

sleep(10);
}


function send_owncast_system_message($str) {
   if(empty($str))
      return false;
   $url = "http://owncast_server.com";
   $access_token = "YOUR_OWNCAST_ACCESS_TOKEN_HERE"; // you may have to escape hyphens with a backslash

   $endpoint = "/api/integrations/chat/system";

   $post = array("body" => $str);
   $auth = "Authorization: Bearer $access_token";

   $ch = curl_init($url.$endpoint);
   $headers = array("Content-Type: application/json",
                 $auth);
   curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
   curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
   curl_setopt($ch, CURLOPT_POSTFIELDS,json_encode($post));
   $result = curl_exec($ch);
   curl_close($ch);
}