clouddesk/operator/ajax/operatorchat.php

<?php

header("Cache-Control: no-cache, must-revalidate");
header("Expires: Sat, 6 May 1998 03:10:00 GMT");

/*===============================================*\
|| ############################################# ||
|| # JAKWEB.CH / Version 2.0.2                 # ||
|| # ----------------------------------------- # ||
|| # Copyright 2021 JAKWEB All Rights Reserved # ||
|| ############################################# ||
\*===============================================*/

if (!file_exists('../../config.php')) die('ajax/[usronline.php] config.php not exist');
require_once '../../config.php';

if (!isset($_SERVER['HTTP_X_REQUESTED_WITH']) && !isset($_SESSION['jak_lcp_idhash'])) die("Nothing to see here");

// User is on idle let's check if there is a new client
if (isset($_GET['id']) && $_GET['id'] == "check_only" && is_numeric($_GET['opid'])) {

  // Now let us add the active chat file so the operator can come online.
  $chatsfile = APP_PATH.JAK_CACHE_DIRECTORY.'/chats'.$opcacheid.'.txt';
  
  if (file_exists($chatsfile)) {
  
    $trimmed = file($chatsfile, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
    
    foreach ($trimmed as $v) {
      
      $opid = explode(":#:", $v);
      
      // Check if we have a chat request
      if ($opid[2] == $_GET['opid'] && $opid[0] > (time() - 10)) {  
        $nopid[] = $opid[1].":#:".$opid[3];
      } else {
        $nopid = false;
      }
      
    }
    
    // If we have forward the new window array
    if (is_array($nopid)) {
      die(json_encode(array("startcalling" => true, "win" => $nopid)));
    } else {
      // Nothing to do, keep idle.
      die(json_encode(array("startcalling" => false)));
    }
    
  } else {
    // Nothing to do, keep idle.
    die(json_encode(array("startcalling" => false)));
  }

}

if (!is_numeric($_POST['uid'])) die("There is no such thing!");

// Import the user or standard language file
if (isset($_SESSION['jak_lcp_lang']) && file_exists(APP_PATH.JAK_OPERATOR_LOC.'/lang/'.$_SESSION['jak_lcp_lang'].'.php')) {
    include_once(APP_PATH.JAK_OPERATOR_LOC.'/lang/'.$_SESSION['jak_lcp_lang'].'.php');
} else {
    include_once(APP_PATH.JAK_OPERATOR_LOC.'/lang/'.JAK_LANG.'.php');
}

$sent_time = time() - OPERATOR_CHAT_EXPIRE;
$print_offline = '';
  
switch ($_POST['page']) {
  
  case 'load-msg':
    
      // Check if the Operater is still available
      $available = $jakdb->has("user", ["AND" => ["id" => $_POST['partner_id'], "available" => 1]]);
      
      if (!$available) {
        $print_offline = '<li class="list-group-item error">'.$jkl["g139"].'</li>';
      }
      
      // A few vars
      $unreadmsg = false;
      $chatmsg = "";
    
      // Load messages
      $resultu = $jakdb->select("operatorchat", "*", ["AND #check" => ["OR #first" => ["fromid" => $_POST['uid'], "toid" => $_POST['uid']], "OR #second" => ["operatorchat.fromid" => $_POST['opid'], "operatorchat.toid" => $_POST['opid']], "opid" => $opcacheid, "sent[>]" => $sent_time, "msgpublic" => 0], "ORDER" => ["sent" => "ASC"]]);
      
      if (isset($resultu) && !empty($resultu)) {
      
        foreach ($resultu as $rowu) {
        
          // check if current user has unreceived messages which are older than limit, if yes, display it with date
          if ($rowu["sent"] < $sent_time AND $rowu["received"] == 0) {
        
            $updatesqla .= sprintf("WHEN %d THEN '%s' ", $rowu['id'], time());
            $updatesqla1 .= sprintf("WHEN %d THEN '%s' ", $rowu['id'], 1);
            $alloid[] = $rowu['id'];
            $unreadmsg = true;
          
          }
          
          // Load Messages
          if (($rowu["fromid"] == $_POST['uid'] && $rowu["toid"] == $_POST['partner_id']) || ($rowu["fromid"] == $_POST['partner_id'] && $rowu["toid"] == $_POST['uid'])) {
          
            //print messages
            if ($rowu['system_message'] != 'no') {
              
              $chatmsg .= '<li class="list-group-item system">'. stripcslashes($rowu['message']).'</li>';
                                
            } elseif ($rowu['fromid'] != $_POST['uid']) {
            
              $chatmsg .= '<li class="list-group-item me">'.$rowu['message'].'</li>';
            
            } else {
              $chatmsg .= '<li class="list-group-item">'.$rowu['message'].'</li>';
            }
            
            
            // If message has been received mark it!
            if ($rowu['toid'] == $_POST['uid']) {
              $jakdb->update("operatorchat", ["received" => 1], ["AND" => ["id" => $rowu['id'], "opid" => $opcacheid, "received" => 0]]);
            }    
            
            $last_msg = $rowu['sent'];
          
          }
          
          
        }
        
        //print last message time if older than 2 mins
        $math = time() - $last_msg;
        if ($math > 120) {
          $chatmsg .= '<li class="list-group-item system">'.str_replace("%s", date("H:i", $last_msg), $jkl["g141"]).'</li>';
        }
        
        $chatmsg .= $print_offline;
        
        // Let's update the unread messages
        if ($unreadmsg && is_array($alloid)) {
        
          $realid = implode(',', $alloid);
            
          // Update in one query
          $jakdb->query('UPDATE '.DB_PREFIX.'operatorchat SET received = CASE id
            '.$updatesqla.'
            END,
            sent = CASE id
            '.$updatesqla1.'
            END
            WHERE id IN ('.$realid.') AND "opid" = '.$opcacheid);
        }
        
        die(json_encode(array("status" => true, "msg" => '<ul class="list-group">'.$chatmsg.'</ul>')));
      
      } else {
        die(json_encode(array("status" => false)));  
      }
  
  break;
  
  case 'send-msg':
  
    if (empty($_POST['message'])) {
      echo $jkl['e1'];
    } else {
      
      $message = trim($_POST['message']);
      
      $message = filter_var($message, FILTER_SANITIZE_FULL_SPECIAL_CHARS);
    
      $jakdb->insert("operatorchat", ["opid" => $opcacheid, "fromid" => $_POST['uid'], "toid" => $_POST['to_id'], "message" => $message, "sent" => time()]);

      $lastid = $jakdb->id();
    
      if ($lastid) {
        
        // Now let us add the active chat file so the operator can come online.
        $chatsfile = APP_PATH.JAK_CACHE_DIRECTORY.'/chats'.$opcacheid.'.txt';
        
        if (file_exists($chatsfile)) {
          unlink($chatsfile);
        }
        
        // Write the from to operator id
        $opid = time().":#:".$_POST['uid'].":#:".$_POST['to_id'].":#:".$_POST['uname']."\n";
        
        // Create, write or append to the file.
        file_put_contents($chatsfile, $opid, FILE_APPEND);

        die(json_encode(array("status" => true, "txt" => '<li class="list-group-item">'.$message.'</li>')));
      } else {
        die(json_encode(array("status" => false)));
      }
    
    }
  
  break;
  
  default:
  
    return false;

}