'; } //format message return '
that breaks JS
remove_filter ('the_content', 'wpautop');
//move wpautop filter to BEFORE shortcode is processed
add_filter( 'the_content', 'wpautop' , 1);
//then clean AFTER shortcode
add_filter( 'the_content', 'shortcode_unautop', 100 );
self::setupSchedule();
}
function plugins_loaded()
{
//update user active
//user access update (updates with 10s precision)
if (is_user_logged_in())
{
$ztime = time();
$userID = get_current_user_id();
$accessTime = intval(get_user_meta($userID, 'accessTime', true));
if ($ztime - $accessTime > 10) update_user_meta($userID, 'accessTime', $ztime);
}
$plugin = plugin_basename(__FILE__);
add_filter("plugin_action_links_$plugin", array('VWliveStreaming','settings_link') );
//translations
load_plugin_textdomain('live-streaming', false, dirname(plugin_basename(__FILE__)) .'/languages');
//widget
wp_register_sidebar_widget('liveStreamingWidget','VideoWhisper Streaming', array('VWliveStreaming', 'widget') );
//channel page
add_filter('the_title', array('VWliveStreaming','the_title'));
add_filter('the_content', array('VWliveStreaming','channel_page'));
add_filter('query_vars', array('VWliveStreaming','query_vars'));
add_filter('pre_get_posts', array('VWliveStreaming','pre_get_posts'));
//admin channels
add_filter('manage_channel_posts_columns', array( 'VWliveStreaming', 'columns_head_channel') , 10);
add_filter( 'manage_edit-channel_sortable_columns', array('VWliveStreaming', 'columns_register_sortable') );
add_action('manage_channel_posts_custom_column', array( 'VWliveStreaming', 'columns_content_channel') , 10, 2);
add_filter( 'request', array('VWliveStreaming', 'duration_column_orderby') );
//shortcodes
add_shortcode('videowhisper_channel_user',array( 'VWliveStreaming', 'videowhisper_channel_user'));
add_shortcode('videowhisper_stream_setup', array( 'VWliveStreaming', 'videowhisper_stream_setup'));
add_shortcode('videowhisper_livesnapshots', array( 'VWliveStreaming', 'shortcode_livesnapshots'));
add_shortcode('videowhisper_broadcast', array( 'VWliveStreaming', 'videowhisper_broadcast'));
add_shortcode('videowhisper_external', array( 'VWliveStreaming', 'videowhisper_external'));
add_shortcode('videowhisper_external_broadcast', array( 'VWliveStreaming', 'videowhisper_external_broadcast'));
add_shortcode('videowhisper_external_playback', array( 'VWliveStreaming', 'videowhisper_external_playback'));
add_shortcode('videowhisper_watch', array( 'VWliveStreaming', 'videowhisper_watch'));
add_shortcode('videowhisper_video', array( 'VWliveStreaming', 'videowhisper_video'));
add_shortcode('videowhisper_hls', array( 'VWliveStreaming', 'videowhisper_hls'));
add_shortcode('videowhisper_mpeg', array( 'VWliveStreaming', 'videowhisper_mpeg'));
add_shortcode('videowhisper_channel_manage',array( 'VWliveStreaming', 'videowhisper_channel_manage'));
add_shortcode('videowhisper_channels',array( 'VWliveStreaming', 'videowhisper_channels'));
add_shortcode('videowhisper_webrtc_broadcast', array( 'VWliveStreaming', 'videowhisper_webrtc_broadcast'));
add_shortcode('videowhisper_webrtc_playback', array( 'VWliveStreaming', 'videowhisper_webrtc_playback'));
add_shortcode('videowhisper_htmlchat_playback', array( 'VWliveStreaming', 'videowhisper_htmlchat_playback'));
add_action( 'before_delete_post', array( 'VWliveStreaming','before_delete_post') );
//notify admin about requirements
if( current_user_can( 'administrator' ) ) self::requirements_plugins_loaded();
//ajax
//ip camera / re-stream setup
add_action( 'wp_ajax_vwls_stream_setup', array('VWliveStreaming','vwls_stream_setup'));
add_action( 'wp_ajax_nopriv_vwls_stream_setup', array('VWliveStreaming','vwls_stream_setup'));
add_action( 'wp_ajax_vwls_playlist', array('VWliveStreaming','vwls_playlist') );
add_action( 'wp_ajax_nopriv_vwls_playlist', array('VWliveStreaming','vwls_playlist'));
add_action( 'wp_ajax_vwls_trans', array('VWliveStreaming','vwls_trans') );
add_action( 'wp_ajax_nopriv_vwls_trans', array('VWliveStreaming','vwls_trans'));
add_action( 'wp_ajax_vwls_broadcast', array('VWliveStreaming','vwls_broadcast'));
add_action( 'wp_ajax_vwls', array('VWliveStreaming','vwls_calls'));
add_action( 'wp_ajax_nopriv_vwls', array('VWliveStreaming','vwls_calls'));
add_action( 'wp_ajax_vwls_channels', array('VWliveStreaming','vwls_channels'));
add_action( 'wp_ajax_nopriv_vwls_channels', array('VWliveStreaming','vwls_channels'));
add_action( 'wp_ajax_vwls_htmlchat', array('VWliveStreaming','wp_ajax_vwls_htmlchat') );
add_action( 'wp_ajax_nopriv_vwls_htmlchat', array('VWliveStreaming','wp_ajax_vwls_htmlchat') );
//jquery for ajax
add_action( 'wp_enqueue_scripts', array('VWliveStreaming','wp_enqueue_scripts') );
//update page if not exists or deleted
$page_id = get_option("vwls_page_manage");
$page_id2 = get_option("vwls_page_channels");
if (!$page_id || $page_id == "-1" || !$page_id2 || $page_id2 == "-1") add_action('wp_loaded', array('VWliveStreaming','updatePages'));
//check db and update if necessary
$vw_db_version = "5.3.17";
global $wpdb;
$table_sessions = $wpdb->prefix . "vw_sessions";
$table_viewers = $wpdb->prefix . "vw_lwsessions";
$table_channels = $wpdb->prefix . "vw_lsrooms";
$table_chatlog = $wpdb->prefix . "vw_vwls_chatlog";
$installed_ver = get_option( "vwls_db_version" );
if( $installed_ver != $vw_db_version )
{
//echo "---$installed_ver != $vw_db_version---";
$wpdb->flush();
$sql = "DROP TABLE IF EXISTS `$table_sessions`;
CREATE TABLE `$table_sessions` (
`id` int(11) NOT NULL auto_increment,
`session` varchar(64) NOT NULL,
`username` varchar(64) NOT NULL,
`uid` int(11) NOT NULL,
`room` varchar(64) NOT NULL,
`message` text NOT NULL,
`sdate` int(11) NOT NULL,
`edate` int(11) NOT NULL,
`status` tinyint(4) NOT NULL,
`type` tinyint(4) NOT NULL,
PRIMARY KEY (`id`),
KEY `status` (`status`),
KEY `type` (`type`),
KEY `uid` (`uid`),
KEY `room` (`room`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='Video Whisper: Broadcaster Sessions - 2009@videowhisper.com' AUTO_INCREMENT=1 ;
DROP TABLE IF EXISTS `$table_viewers`;
CREATE TABLE `$table_viewers` (
`id` int(11) NOT NULL auto_increment,
`session` varchar(64) NOT NULL,
`username` varchar(64) NOT NULL,
`uid` int(11) NOT NULL,
`room` varchar(64) NOT NULL,
`rid` int(11) NOT NULL,
`rsdate` int(11) NOT NULL,
`redate` int(11) NOT NULL,
`roptions` text NOT NULL,
`rmode` tinyint(4) NOT NULL,
`message` text NOT NULL,
`ip` text NOT NULL,
`sdate` int(11) NOT NULL,
`edate` int(11) NOT NULL,
`status` tinyint(4) NOT NULL,
`type` tinyint(4) NOT NULL,
PRIMARY KEY (`id`),
KEY `status` (`status`),
KEY `type` (`type`),
KEY `rid` (`rid`),
KEY `uid` (`uid`),
KEY `rmode` (`rmode`),
KEY `rsdate` (`rsdate`),
KEY `redate` (`redate`),
KEY `sdate` (`sdate`),
KEY `edate` (`edate`),
KEY `room` (`room`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Video Whisper: Sessions - 2015@videowhisper.com' AUTO_INCREMENT=1 ;
DROP TABLE IF EXISTS `$table_channels`;
CREATE TABLE `$table_channels` (
`id` int(11) NOT NULL auto_increment,
`name` varchar(64) NOT NULL,
`owner` int(11) NOT NULL,
`sdate` int(11) NOT NULL,
`edate` int(11) NOT NULL,
`btime` int(11) NOT NULL,
`wtime` int(11) NOT NULL,
`rdate` int(11) NOT NULL,
`status` tinyint(4) NOT NULL,
`type` tinyint(4) NOT NULL,
`options` TEXT,
PRIMARY KEY (`id`),
KEY `name` (`name`),
KEY `status` (`status`),
KEY `type` (`type`),
KEY `owner` (`owner`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='Video Whisper: Rooms - 2014@videowhisper.com' AUTO_INCREMENT=1 ;
DROP TABLE IF EXISTS `$table_chatlog`;
CREATE TABLE `$table_chatlog` (
`id` int(11) unsigned NOT NULL auto_increment,
`username` varchar(64) NOT NULL,
`room` varchar(64) NOT NULL,
`message` text NOT NULL,
`mdate` int(11) NOT NULL,
`type` tinyint(4) NOT NULL,
`meta` TEXT,
`user_id` int(11) unsigned NOT NULL,
PRIMARY KEY (`id`),
KEY `room` (`room`),
KEY `mdate` (`mdate`),
KEY `type` (`type`),
KEY `user_id` (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Video Whisper: Chat Logs - 2018@videowhisper.com' AUTO_INCREMENT=1;
";
require_once(ABSPATH . 'wp-admin/includes/upgrade.php');
dbDelta($sql);
if (!$installed_ver) add_option("vwls_db_version", $vw_db_version);
else update_option( "vwls_db_version", $vw_db_version );
$wpdb->flush();
}
}
/*
function delTree($dir) {
$files = array_diff(scandir($dir), array('.','..'));
foreach ($files as $file) {
(is_dir("$dir/$file")) ? VWliveStreaming::delTree("$dir/$file") : unlink("$dir/$file");
}
return rmdir($dir);
}
*/
function before_delete_post($postID)
{
$options = get_option('VWliveStreamingOptions');
if (get_post_type( $postID ) != $options['custom_post']) return;
$post = get_post( $postID );
//delete from room table
$room = sanitize_file_name($post->post_title);
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$sql = "DELETE FROM $table_channels where name='$room'";
$wpdb->query($sql);
}
function login_headerurl($url) {
return get_bloginfo( "url" ) . "/";
}
function login_enqueue_scripts() {
$options = get_option('VWliveStreamingOptions');
if ($options['loginLogo'])
{
?>
get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . sanitize_file_name($room) . "' and post_type='channel' LIMIT 0,1" );
if ($postID) return get_post_permalink($postID);
}
if ($options['channelUrl'] == 'full') return site_url('/fullchannel/' . urlencode($room));
return plugin_dir_url(__FILE__) . 'ls/channel.php?n=' . urlencode(sanitize_file_name($room));
}
function count_user_posts_by_type( $userid, $post_type = 'channel' )
{
global $wpdb;
$where = get_posts_by_author_sql( $post_type, true, $userid );
$count = $wpdb->get_var( "SELECT COUNT(*) FROM $wpdb->posts $where" );
return apply_filters( 'get_usernumposts', $count, $userid );
}
//! Channel Validation
static function channelInvalid( $channel, $broadcast =false)
{
//check if online channel is invalid for any reason
if (!function_exists('fm'))
{
function fm($t, $item = null)
{
$img = '';
if ($item)
{
$options = get_option('VWliveStreamingOptions');
$dir = $options['uploadsPath']. "/_thumbs";
$age = VWliveStreaming::format_age(time() - $item->edate);
$thumbFilename = "$dir/" . $item->name . ".jpg";
$noCache = '';
if ($age=='LIVE') $noCache='?'.((time()/10)%100);
if (file_exists($thumbFilename)) $img = '
';
}
//format message
return '
' . __('This displays a broadcasting channel for registered members that have this feature enabled.', 'live-streaming') . '
'; return $htmlCode; } //channel with same name as $username global $wpdb; $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE `post_title` = '$username' AND `post_type`='".$options['custom_post']."' LIMIT 0,1" ); //same name if (!$postID) { $post = array( 'post_name' => $username, 'post_title' => $username, 'post_author' => $current_user->ID, 'post_type' => $options['custom_post'], 'post_status' => 'publish', ); $postID = wp_insert_post($post); } $channel = get_post( $postID ); if (!$channel) return "Error: Channel #$postID does not exist!"; if ($channel->post_author != $current_user->ID) return 'Error: Channel ' . $channel->post_title . ' exists but belongs to different user '. $channel->post_author .'!'; // display broadcasting channel return do_shortcode('[videowhisper_broadcast channel="' . $channel->post_title . '"]'); } function videowhisper_channel_manage() { //can user create room? $options = get_option('VWliveStreamingOptions'); $maxChannels = $options['maxChannels']; $canBroadcast = $options['canBroadcast']; $broadcastList = $options['broadcastList']; $userName = $options['userName']; if (!$userName) $userName='user_nicename'; $loggedin=0; $current_user = wp_get_current_user(); if ($current_user->$userName) $username = $current_user->$userName; //access keys $userkeys = $current_user->roles; $userkeys[] = $current_user->user_login; $userkeys[] = $current_user->ID; $userkeys[] = $current_user->user_email; switch ($canBroadcast) { case "members": if ($username) $loggedin=1; else $htmlCode .= VWliveStreaming::loginRequiredWarning(); break; case "list"; if ($username) if (VWliveStreaming::inList($userkeys, $broadcastList)) $loggedin=1; else $htmlCode .= "$username, you are not allowed to setup rooms."; else $htmlCode .= VWliveStreaming::loginRequiredWarning(); break; } if (!$loggedin) { $htmlCode .='' . __('This pages allows creating and managing broadcasting channels for registered members that have this feature enabled.', 'live-streaming') . '
'; return $htmlCode; } //premium options $poptions = VWliveStreaming::premiumOptions($userkeys, $options); if ($poptions['pMaxChannels']) $maxChannels = $poptions['pMaxChannels']; $this_page = VWliveStreaming::getCurrentURL(); $channels_count = VWliveStreaming::count_user_posts_by_type($current_user->ID, $options['custom_post']); $deleteChannel = intval($_GET['deleteChannel']); if ($deleteChannel) { $post = get_post($deleteChannel); $htmlCode .= '' . $channel->post_title . '' . $thumbCode . ' ';
//Features Info
//transcode quick update (if settigns changed for role)
$vw_transcode = get_post_meta( $postID, 'vw_transcode', true );
if (VWliveStreaming::inList($userkeys, $options['transcode'])) $new_vw_transcode = 1;
else $new_vw_transcode =0;
if ($vw_transcode != $new_vw_transcode) update_post_meta($postID, 'vw_transcode', $new_vw_transcode);
//info under channel snapshot
$htmlCode .= '
';
$htmlCode .= '' . apply_filters("vw_ls_manage_channel", '', $channel->ID) . ' ';
$htmlCode .= ' | ';
$htmlCode .= '';
//semantic ui
VWliveStreaming::enqueueUI();
$htmlCode .= '
';
/*
$htmlCode .= ' Broadcast'; if ($options['webrtc']) $htmlCode .= ' WebRTC Broadcast'; if ($options['externalKeys']) $htmlCode .= ' External Apps'; $htmlCode .= ' Chat & Video'; $htmlCode .= ' Video Only'; if ($options['webrtc']) $htmlCode .= ' WebRTC Playback'; $htmlCode .= ' Setup'; if ($options['playlists']) if (VWliveStreaming::inList($userkeys, $options['schedulePlaylists'])) $htmlCode .= ' Playlist'; */ $htmlCode .= ' |
' . __('Try HTML5 View', 'live-streaming') . '
'; } return VWliveStreaming::flash_watch($stream, $width, $height) . $afterCode ; } static function transcodeStreamWebRTC($stream, $postID, $options = null, $detect=2) { //transcode for WebRTC usage: RTMP/RTSP as necessary if (!$stream) return; if (!$options) $options = get_option('VWliveStreamingOptions'); if (!$options['webrtc']) return; if (!VWliveStreaming::timeTo($stream . '/transcodeCheckWebRTC-Flood', 3, $options)) return; //prevent duplicate checks // check every 59s $tooSoon = 0; if (!VWliveStreaming::timeTo($stream . '/transcodeCheckWebRTC', 59, $options)) $tooSoon = 1; $sourceProtocol = get_post_meta($postID, 'stream-protocol', true); //rtmp/rtsp $sourceType = get_post_meta($postID, 'stream-type', true); // stream-type: flash/webrtc/restream/playlist if (!$sourceProtocol) $sourceProtocol = 'rtmp'; //assuming plain wowza stream if ($sourceProtocol == 'rtmp') //source available as RTMP (flash, external) { if (!$options['transcodeRTC']) return $stream; //webrtc transcoding disabled: return original stream //RTMP to RTSP (h264/opus) $stream_webrtc = $stream . '_webrtc'; if ($tooSoon) return $stream_webrtc; //detect transcoding process - cancel if already started $cmd = "ps aux | grep '/$stream_webrtc -i rtmp'"; exec($cmd, $output, $returnvalue); $transcoding = 0; foreach ($output as $line) if (strstr($line, "ffmpeg")) { $transcoding = 1; break; } //rtmp keys if ($options['externalKeysTranscoder']) { $keyView = md5('vw' . $options['webKey']. $postID); $rtmpAddressView = $options['rtmp_server'] . '?'. urlencode('ffmpegWebRTC_' . $stream_webrtc) .'&'. urlencode($stream) .'&'. $keyView . '&0&videowhisper'; } else { $rtmpAddress = $options['rtmp_server']; $rtmpAddressView = $options['rtmp_server']; } $userID = get_post_field( 'post_author', $postID ); //$keyBroadcast = md5('vw' . $options['webKey'] . $userID . $postID); // $streamQuery = $stream_webrtc . '?channel_id=' . $postID . '&userID=' . $userID . '&key=' . urlencode($keyBroadcast) . '&transcoding=1'; $streamQuery = VWliveStreaming::webrtcStreamQuery($userID, $postID, 1, $stream_webrtc, $options, 1); //paths $uploadsPath = $options['uploadsPath']; if (!file_exists($uploadsPath)) mkdir($uploadsPath); $upath = $uploadsPath . "/$stream/"; if (!file_exists($upath)) mkdir($upath); if (!$transcoding) //transcode to rtsp { //start transcoding process $log_file = $upath . "transcode_rtmp-webrtc.log"; $cmd = $options['ffmpegPath'] .' ' . $options['ffmpegTranscodeRTC'] . " -threads 1 -f rtsp \"" . $options['rtsp_server_publish'] . '/'. $streamQuery . "\" -i \"" . $rtmpAddressView ."/". $stream . "\" >&$log_file & "; //echo $cmd; exec($cmd, $output, $returnvalue); exec("echo '$cmd' >> $log_file.cmd", $output, $returnvalue); update_post_meta( $postID, 'stream-webrtc', $stream_webrtc ); } else update_post_meta($postID, 'transcoding-webrtc', time()); } if ($sourceProtocol == 'rtsp' && $sourceType != 'restream') //source available as RTSP (WebRTC) and is not a restream (handled from rtmp) { if (!$options['transcodeFromRTC']) return $stream; //from webrtc transcoding disabled: return original stream //RTSP to HLS/RTMP (h264/aac) $stream_hls = 'i_' . $stream; if ($tooSoon) return $stream_hls; //detect transcoding process - cancel if already started $cmd = "ps aux | grep '/$stream_hls -i rtsp'"; exec($cmd, $output, $returnvalue); $transcoding = 0; foreach ($output as $line) if (strstr($line, "ffmpeg")) { $transcoding = 1; break; } //rtmp keys if ($options['externalKeysTranscoder']) { $channel = get_post($postID); $userID = $channel->post_author; $key = md5('vw' . $options['webKey'] . $userID . $postID); $rtmpAddress = $options['rtmp_server'] . '?'. urlencode($stream_hls) .'&'. urlencode($stream) .'&'. $key . '&1&' . $userID . '&videowhisper'; } else { $rtmpAddress = $options['rtmp_server']; $rtmpAddressView = $options['rtmp_server']; } //paths $uploadsPath = $options['uploadsPath']; if (!file_exists($uploadsPath)) mkdir($uploadsPath); $upath = $uploadsPath . "/$stream/"; if (!file_exists($upath)) mkdir($upath); if (!$transcoding) //transcode to rtmp { if ($detect == 2 || ($detect == 1 && !$videoCodec)) { //detect webrtc stream info $log_file = $upath . "streaminfo-webrtc.log"; $cmd = 'timeout -s KILL 3 ' . $options['ffmpegPath'] .' -y -i "' . $options['rtsp_server'] . '/' . $stream . '" 2>&1 '; $info = shell_exec($cmd); //video if (!preg_match('/Stream #(?:[0-9\.]+)(?:.*)\: Video: (?PHLS Playback: for iOS and Safari. Enable sound from controls. Transcoding and HTTP based delivery technology involve high latency and availability delay (may take dozens of seconds for transcoder to start stream to become available, after broadcast starts).
'; return $htmlCode; } function videowhisper_mpeg($atts) { $stream = ''; $options = get_option('VWliveStreamingOptions'); if (is_single()) if (get_post_type( $postID = get_the_ID() ) == $options['custom_post']) $stream = get_the_title($postID); $atts = shortcode_atts(array('channel' => $stream, 'width' => '480px', 'height' => '360px','silent' => '0'), $atts, 'videowhisper_mpeg'); if (!$stream) $stream = $atts['channel']; //parameter channel="name" if (!$stream) $stream = $_GET['n']; $width=$atts['width']; if (!$width) $width = "480px"; $height=$atts['height']; if (!$height) $height = "360px"; if (!$stream) { return "Watch MPEG Dash Error: Missing channel name!"; } //get channel id $postID global $wpdb; $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . sanitize_file_name($stream) . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" ); //auto transcoding if ($options['transcodingAuto']) { $streamName = VWliveStreaming::transcodeStream($stream, 1); //require transcoding name } //get compatible stream $sourceProtocol = get_post_meta($postID, 'stream-protocol', true); if ($sourceProtocol == 'rtsp') //requires transcoding { $stream_hls = get_post_meta( $postID, 'stream-hls', true ); if ($stream_hls) $streamName = $stream_hls; } if (!$streamName) $streamName = $stream; if ($streamName) { $streamURL = $options['httpstreamer'] . $streamName .'/manifest.mpd'; $dir = $options['uploadsPath']. "/_thumbs"; $thumbFilename = "$dir/" . $stream . ".jpg"; $thumbUrl = VWliveStreaming::path2url($thumbFilename) . '?nocache='.((time()/10)%100);; //if (strstr($streamURL,'http://')) wp_enqueue_script('dashjs', 'http://cdn.dashjs.org/latest/dash.all.min.js'); //else wp_enqueue_script('dashjs', 'https://cdn.dashjs.org/latest/dash.all.min.js'); if (strstr($streamURL,'http://')) wp_enqueue_script('dashjs', 'http://cdnjs.cloudflare.com/ajax/libs/shaka-player/2.4.7/shaka-player.compiled.js'); else wp_enqueue_script('dashjs', 'https://cdnjs.cloudflare.com/ajax/libs/shaka-player/2.4.7/shaka-player.compiled.js'); $codecVideo = get_post_meta($postID, 'stream-codec-video', true); $codecAudio = get_post_meta($postID, 'stream-codec-audio', true); $htmlCode = <<MPEG-DASH Playback: For Android and Chrome. Autoplay starts muted to prevent pausing by browser: enable sound from controls. Transcoding and HTTP based delivery technology involve high latency and availability delay (may take dozens of seconds for transcoder to start stream to become available, after broadcast starts).
'; return $htmlCode; } function flash_video($stream, $width = "100%", $height = '360px', $streamName = '') { $stream = sanitize_file_name($stream); if (!$streamName) $streamName = $stream; $swfurl = plugin_dir_url(__FILE__) . "ls/live_video.swf?ssl=1&n=" . urlencode($stream). '&s=' . urlencode($streamName); $swfurl .= "&prefix=" . urlencode(admin_url() . 'admin-ajax.php?action=vwls&task='); $swfurl .= '&extension='.urlencode('_none_'); $swfurl .= '&ws_res=' . urlencode( plugin_dir_url(__FILE__) . 'ls/'); $bgcolor="#333333"; $htmlCode = <<Viewers can send you tips. Balance will update shortly after receiving a tip.
'; $interfaceClass = $options['interfaceClass']; $tipsCode =<<Warning: WebRTC will play directly where possible, depending on settings and viewer device. If transcoding is needed for playback, it may take up to a couple of minutes for transcoder to start and WebRTC published stream to become available for RTMP and HLS/MPEG DASH playback.
For advanced features use advanced web broadcasting interface available in PC browser with Flash plugin.
Try Advanced Flash Broadcast (PC)
'; return $htmlCode; } function videowhisper_webrtc_playback($atts) { $stream = ''; $postID = 0; $options = get_option('VWliveStreamingOptions'); if (is_single()) { $postID = get_the_ID(); if (get_post_type( $postID ) == $options['custom_post'] ) $stream = get_the_title($postID); else $postID = 0; } if (!$postID) { global $wpdb; $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . sanitize_file_name($stream) . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" ); } $atts = shortcode_atts(array( 'channel' => $stream, 'width' => '480px', 'height' => '360px', 'channel_id' => $postID, 'silent' => 0, ), $atts, 'videowhisper_webrtc_playback'); if (!$stream) $stream = $atts['channel']; //parameter channel="name" if (!$stream) $stream = $_GET['n']; $stream = sanitize_file_name($stream); $width=$atts['width']; if (!$width) $width = "100%"; $height=$atts['height']; if (!$height) $height = '360px'; if (!$stream) { return "WebRTC Playback Error: Missing channel name!"; } $userID = 0; if (is_user_logged_in()) { $userName = $options['userName']; if (!$userName) $userName='user_nicename'; $current_user = wp_get_current_user(); if ($current_user->$userName) $username = sanitize_file_name($current_user->$userName); $userID = $current_user->ID; } $postID = $atts['channel_id']; if (!$postID) { global $wpdb; $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . sanitize_file_name($stream) . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" ); } //detect browser $agent = $_SERVER['HTTP_USER_AGENT']; $Android = stripos($agent,"Android"); $iOS = ( strstr($agent,'iPhone') || strstr($agent,'iPod') || strstr($agent,'iPad')); $Safari = (strstr($agent,"Safari") && !strstr($agent,"Chrome")); $Firefox = stripos($agent,"Firefox"); $codeMuted = ''; if ($Safari) { $codeMuted = 'muted'; } //WebRTC playback: detect source type and transcode if necessary $sourceProtocol = get_post_meta($postID, 'stream-protocol', true); if ($sourceProtocol == 'rtsp') $stream_webrtc = $stream; else $stream_webrtc = VWliveStreaming::transcodeStreamWebRTC($stream, $postID, $options); //$keyPlayback = md5('vw' . $options['webKey']. $postID . $userID); //$streamQuery = $stream_webrtc . '?channel_id=' . $postID . '&userID=' . urlencode($userID) . '&key=' . urlencode($keyPlayback); $streamQuery = VWliveStreaming::webrtcStreamQuery($current_user->ID, $postID, 0, $stream_webrtc, $options); //$clientIP = VWliveStreaming::get_ip_address(); //VWliveStreaming::webSessionSave($stream_webrtc, 0, 'webrtc-playback', $clientIP); //approve session for rtmp check wp_enqueue_script( 'jquery'); wp_enqueue_script( 'webrtc-adapter', plugin_dir_url( __FILE__ ) . 'scripts/adapter.js', array('jquery')); wp_enqueue_script( 'videowhisper-webrtc-playback', plugin_dir_url( __FILE__ ) . 'scripts/vwrtc-playback.js', array('jquery', 'webrtc-adapter')); $wsURLWebRTC = $options['wsURLWebRTC']; $applicationWebRTC = $options['applicationWebRTC']; $htmlCode .= <<HTML5 Video Stream Playback: Use controls to enable sound as autoplay is not possible with audio in latest browsers. Transcoding and HTTP based delivery technology involve extra latency and availability delay related to processing video stream. If stream is live but not showing, please wait or reload page if it does not start in few seconds.
'; if ($options['transcodingWarning']>=1) if ($options['transcoding']) $htmlCode .= ''; return $htmlCode; } // static function rtmp_address($userID, $postID, $broadcaster, $session, $room) { //?session&room&key&broadcaster&broadcasterid $options = get_option('VWliveStreamingOptions'); if ($broadcaster) { $key = md5('vw' . $options['webKey'] . $userID . $postID); return $options['rtmp_server'] . '?'. urlencode($session) .'&'. urlencode($room) .'&'. $key . '&1&' . $userID . '&videowhisper'; } else { $keyView = md5('vw' . $options['webKey']. $postID); return $options['rtmp_server'] . '?'. urlencode('-name-') .'&'. urlencode($room) .'&'. $keyView . '&0' . '&videowhisper'; } return $options['rtmp_server']; } static function webrtcStreamQuery($userID, $postID, $broadcaster, $stream_webrtc, $options = null, $transcoding = 0) { if (!$options) $options = get_option('VWliveStreamingOptions'); $clientIP = VWliveStreaming::get_ip_address(); if ($broadcaster) { $key = md5('vw' . $options['webKey'] . $userID . $postID); } else { $key = md5('vw' . $options['webKey']. $postID ); } $streamQuery = $stream_webrtc . '?channel_id=' . $postID . '&userID=' . urlencode($userID) . '&key=' . urlencode($key) . '&ip=' . urlencode($clientIP) . '&transcoding=' . $transcoding ; return $streamQuery; } function videowhisper_external($atts) { if (!is_user_logged_in()) return "After reviewing your encoder setting fields, retrieve settings you need from strings below.
RTMP Address / URL (full address, contains server, port if different than default 1935, application, parameters):
Application (contains application name and parameters):
$application
Stream Name / Key (name of channel):
$stream
Server:
$server
Port:
$port
Stream Address (RTMP Address with Stream Name):
$rtmpAddress/$stream
Use specs above to broadcast channel '$stream' using external applications (GoCoder iOS/Android app, OBS Open Broadcaster Software, XSplit, Adobe Flash Media Live Encoder, Wirecast).
Keep your secret broadcasting rtmp address safe as anyone having it may broadcast to your channel. As external encoders don't comunicate with site scripts, externally broadcast channel shows as online only if RTMP Session Control is enabled.
Copy and paste strings: For mobile encoders send the strings above in an email or notes sharing app. In GoCoder copy and paste each string and save settings before switching between apps to get next string.
Warning: If advanced session control is enabled you can't connect at same time with web broadcasting interface and external encoder (duplicate named session will be refused by server). Connect with external encoder using details above and participate in chat with Watch interface.
RTMP Address / URL (full address, contains server, port if different than default 1935, application, parameters):
$rtmpAddressView
Stream Name:
$stream
Stream Address (RTMP Address with Stream Name, for players that require these settings in 1 string):
$rtmpAddressView/$stream
Use specs above to setup playback using 3rd party RTMP players (Strobe, JwPlayer, FlowPlayer), restreaming servers or apps.
$codeWatch
RTMP Address / URL (full address, contains server, port if different than default 1935, application, parameters):
$rtmpAddressView
Stream Name:
$stream
Stream Address (RTMP Address with Stream Name, for players that require these settings in 1 string):
$rtmpAddressView/$stream
Use specs above to setup playback using 3rd party RTMP players (Strobe, JwPlayer, FlowPlayer), restreaming servers or apps.
$codeWatch
After reviewing your encoder setting fields, retrieve settings you need from strings below.
Use specs above to broadcast channel '$stream' using external applications (GoCoder iOS/Android app, OBS Open Broadcaster Software, XSplit, Adobe Flash Media Live Encoder, Wirecast).
Keep your secret broadcasting rtmp address safe as anyone having it may broadcast to your channel. As external encoders don't comunicate with site scripts, externally broadcast channel shows as online only if RTMP Session Control is configured on streaming server.
Copy and paste strings: For mobile encoders send the strings above in an email or notes sharing app. In GoCoder copy and paste each string and save settings before switching between apps to get next string.
Warning: If advanced session control is enabled you can't connect at same time with web broadcasting interface and external encoder (duplicate named session will be refused by server). Connect with external encoder using details above and if you want to participate in chat you can do that from website with Watch interface.
HTMLCODE; VWliveStreaming::enqueueUI(); return $htmlCode; } function videowhisper_broadcast($atts) { $stream = ''; if (!is_user_logged_in()) return "' . __('Try HTML5 WebRTC Broadcast', 'live-streaming') . '
'; } if (!$options['transcoding']) return $htmlCode; //done //transcoding interface if ($stream) { //access keys if ($current_user) { $userkeys = $current_user->roles; $userkeys[] = $current_user->user_login; $userkeys[] = $current_user->ID; $userkeys[] = $current_user->user_email; $userkeys[] = $current_user->display_name; } $admin_ajax = admin_url() . 'admin-ajax.php'; if (VWliveStreaming::inList($userkeys, $options['transcode'])) //transcode feature enabled if ($options['transcoding']) if ($options['transcodingManual']) $htmlCode .= <<(hide)
HTMLCODE; } return $htmlCode ; } static function path2url($file, $Protocol='http://') { $url = $Protocol.$_SERVER['HTTP_HOST']; //on godaddy hosting uploads is in different folder like /var/www/clients/ .. $upload_dir = wp_upload_dir(); if (strstr($file, $upload_dir['basedir'])) return $upload_dir['baseurl'] . str_replace($upload_dir['basedir'], '', $file); if (strstr($file, $_SERVER['DOCUMENT_ROOT'])) return $url . str_replace($_SERVER['DOCUMENT_ROOT'], '', $file); return $url . $file; } static function format_time($t,$f=':') // t = seconds, f = separator { return sprintf("%02d%s%02d%s%02d", floor($t/3600), $f, ($t/60)%60, $f, $t%60); } static function format_age($t) { if ($t<180) return __('LIVE', 'live-streaming'); //3 min if ($t + 3 > time()) return __('Never', 'live-streaming'); return sprintf("%d%s%d%s%d%s", floor($t/86400), 'd ', ($t/3600)%24,'h ', ($t/60)%60,'m'); } //! Watcher (viewer) Online Status for App + AJAX chat, not Flash static function updateOnline($username, $room, $postID = 0, $type = 2, $current_user = '', $options ='') { //$type: 1 = flash full, 2 = html5 chat, 3 = flash video, 4 = html5 video, 5 = voyeur flash, 6 = voyeur html5 if (!$room && !$postID) return; //no room, no update $s = $u = $username; $r = $room; $ztime = time(); if (!$options) $options = get_option('VWliveStreamingOptions'); if (!$current_user) $current_user = wp_get_current_user(); $uid = 0; if ($current_user) $uid = $current_user->ID; global $wpdb ; $table_sessions = $wpdb->prefix . "vw_lwsessions"; $table_channels = $wpdb->prefix . "vw_lsrooms"; if (!$postID) $postID = $wpdb->get_var( $sql = 'SELECT ID FROM ' . $wpdb->posts . ' WHERE post_title = \'' . $room . '\' and post_type=\''.$options['custom_post'] . '\' LIMIT 0,1' ); //create or update session //status: 0 current, 1 closed, 2 billed $sqlS = "SELECT * FROM `$table_sessions` WHERE session='$s' AND status='0' AND room='$room' AND type='$type' AND rmode='$rmode' LIMIT 1"; $session = $wpdb->get_row($sqlS); if (!$session) { if ($ztime - $redate > $options['onlineExpiration1']) $rsdate = 0; //broadcaster offline else $rsdate = $redate; //broadcaster online: mark room start date $clientIP = VWliveStreaming::get_ip_address(); $sql="INSERT INTO `$table_sessions` ( `session`, `username`, `uid`, `room`, `rid`, `roptions`, `rsdate`, `redate`, `rmode`, `message`, `sdate`, `edate`, `status`, `type`, `ip`) VALUES ('$s', '$u', '$uid', '$r', '$postID', '$roptions', '$rsdate', '$redate', '$rmode', '$m', '$ztime', '$ztime', 0, $type, '$clientIP')"; $wpdb->query($sql); $session = $wpdb->get_row($sqlS); } else { $id = $session->id; //broadcaster was offline and came online: update room start time (rsdate) if ($session->rsdate == 0 && $redate > $session->sdate) $rsdate = $redate; else $rsdate = $session->rsdate; //keep unchanged (0 or start time) $sql="UPDATE `$table_sessions` set edate='$ztime', rsdate='$rsdate', redate='$redate', roptions = '$roptions' WHERE id='$id' LIMIT 1"; $wpdb->query($sql); } //also update view time (based on original session) $sqlC = "SELECT * FROM $table_channels WHERE name='" . $session->room . "' LIMIT 0,1"; $channel = $wpdb->get_row($sqlC); //calculate time in ms based on previous request $lastTime = $session->edate * 1000; $currentTime = $ztime * 1000; //update room time $expTime = $options['onlineExpiration0']+30; $dS = floor(($currentTime-$lastTime)/1000); if ($dS > $expTime || $dS<0) $disconnect = "Web server out of sync ($dS > $expTime)!"; //Updates should be faster than 3 minutes; fraud attempt? $channel->wtime += $dS; //update $sql="UPDATE `$table_channels` set wtime = " . $channel->wtime . " where id = '" . $channel->id. "'"; $wpdb->query($sql); //update post if ($postID) { update_post_meta($postID, 'wtime', $channel->wtime); } //update user watch time, disconnect if exceeded limit if ($current_user) $user = $current_user; else $user = get_user_by('login', $u); if ($user) if (self::updateUserWatchtime($user, $dS, $options)) $disconnect = urlencode('User watch time limit exceeded!'); if (!$disconnect) { //update access time if (is_user_logged_in()) { update_post_meta($postID, 'accessedUser', $ztime); } update_post_meta($postID, 'accessed', $ztime); } return $disconnect; } //! AJAX function wp_enqueue_scripts() { wp_enqueue_script("jquery"); } //! AJAX HTML Chat function wp_ajax_vwls_htmlchat() { $options = get_option('VWliveStreamingOptions'); //output clean ob_clean(); // Handling the supported tasks: global $wpdb; $table_sessions = $wpdb->prefix . "vw_lwsessions"; //viewers $table_chatlog = $wpdb->prefix . "vw_vwls_chatlog"; $room = sanitize_file_name($_GET['room']); $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $room . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" ); if (!$postID) throw new Exception('HTML Chat: Channel not found: ' . $room); $post = get_post( $postID ); //user $username = ''; $user_id = 0; $isBroadcaster = 0; if (is_user_logged_in()) { $current_user = wp_get_current_user(); if (isset($current_user) ) { $user_id = $current_user->ID; $userName = $options['userName']; if (!$userName) $userName='user_nicename'; if ($current_user->$userName) $username = urlencode(sanitize_file_name($current_user->$userName)); $isBroadcaster = ($user_id == $post->post_author); if ($isBroadcaster) $username = $room; } }else { if ($_COOKIE['htmlchat_username']) $username = $_COOKIE['htmlchat_username']; else { $username = 'Guest_' . base_convert(time()%36 * rand(0,36*36),10,36); setcookie('htmlchat_username', $username); } } $ztime = time(); switch($_GET['task']){ //tips case 'getBalance': $balance = 0; if ($user_id) $balance = self::balance($user_id, false, $options); $response = array( 'balance' => $balance ); break; case 'sendTip': if (!isset($current_user)) if (!$options['htmlchatVisitorWrite']) throw new Exception('You are not logged in!'); if ($options['tipCooldown']) { $lastTip = get_user_meta($current_user->ID, 'vwTipLast', true); if ($lastTip + $options['tipCooldown'] > time()) throw new Exception('Already sent tip recently!'); } $label = $message = sanitize_text_field($_POST['label']); $amount = intval($_POST['amount']); $note = sanitize_text_field($_POST['note']); $sound = sanitize_text_field($_POST['sound']); $image = sanitize_text_field($_POST['image']); $meta = array(); $meta['sound'] = $sound; $meta['image'] = $image; $metaS = serialize($meta); if (!$message) $error = 'No message!'; if ($error) { $response = array( 'status' => 0, 'insertID' => 'error', 'success' => 0, 'error' => $error ); } else { $message = preg_replace('/([^\s]{12})(?=[^\s])/', '$1'.'iOS live stream link (open with Safari or test with VLC): HTML5 live video embed below should be accessible only in Safari browser (PC or iOS): Due to HTTP based live streaming technology limitations, video can have 15s or more latency. Use a browser with flash support for faster interactions based on RTMP. Most devices other than iOS, support regular flash playback for live streams. Powered by VideoWhisper Live Video
Streaming Software. Powered by VideoWhisper Live Video Streaming
Software. '.$eventDescription.' ' . __( 'No items.' ) . '
'submit-quick-search-taxonomy-' . $taxonomy_name ) ); ?>
This page shows latest accessed channels (maximum 200). + External players and encoders (if enabled) are not monitored or controlled by this plugin, unless special rtmp side session control is available. + Configure streaming time limitations from these sections:
To allow users to broadcast from frontend (as configured in settings), enable the widget and/or channel posts and frontend management page.
After ordering solution and setting up existing editions, VideoWhisper.com developers can customize these for additional fees depending on exact requirements.');
$message = date("F j, Y, g:i a", $ztime) . " $username: $message";
//generate same private room folder for both users
if ($private)
{
if ($private > $session) $proom=$session ."_". $private;
else $proom=$private ."_". $session;
}
$dir=$options['uploadsPath'];
if (!file_exists($dir)) mkdir($dir);
$dir.="/$room";
if (!file_exists($dir)) mkdir($dir);
if ($proom)
{
$dir.="/$proom";
if (!file_exists($dir)) mkdir($dir);
}
$day=date("y-M-j",time());
$dfile = fopen($dir."/Log$day.html","a");
fputs($dfile,$message."
");
fclose($dfile);
}
//tip
$balance = self::balance($current_user->ID);
$response['success'] = true;
$response['balancePrevious'] = $balance;
$response['postID'] = $postID;
$response['userID'] = $current_user->ID;
$response['amount'] = $amount;
if ($amount > $balance)
{
$response['success'] = false;
$response['error'] = 'Tip amount greater than balance!';
$response['balance'] = $balance;
}
else
{
$ztime = time();
$tipInfo = "$label: $note";
//client cost
$paid = number_format($amount, 2, '.', '');
VWliveStreaming::transaction('channel_tip', $current_user->ID, - $paid, 'Tip for ' . $room.'. (' .$tipInfo.')' , $ztime);
$response['paid'] = $paid;
//performer earning
$received = number_format($amount * $options['tipRatio'], 2, '.', '');
VWliveStreaming::transaction('channel_tip_earning', $post->post_author, $received , 'Tip from ' . $username .' ('.$tipInfo.')', $ztime);
//save last tip time
update_user_meta($current_user->ID, 'vwTipLast', time());
$response['broadcaster'] = $post->post_author;
$response['received'] = $received;
//update balance and report
$response['balance'] = self::balance($current_user->ID);
}
}
break;
//chat
case 'checkLogged':
$response = array('logged' => false);
if (isset($current_user) )
{
$response['logged'] = true;
$response['loggedAs'] = array(
'name' => $username,
'avatar' => get_avatar_url($current_user->ID),
'userID' => $current_user->ID
);
}
elseif ($options['htmlchatVisitorWrite'])
{
$response['logged'] = true;
$response['loggedAs'] = array(
'name' => $username,
);
}
$disconnected = self::updateOnline($username, $room, $postID, 2, $current_user, $options);
if ($disconnected)
{
$response['disconnect'] = $disconnected;
$response['logged'] = false;
}
break;
case 'submitChat':
//$response = Chat::submitChat();
if (!isset($current_user))
if (!$options['htmlchatVisitorWrite']) throw new Exception('You are not logged in!');
else
{
//visitor
}
$message = sanitize_text_field($_POST['chatText']);
$message = preg_replace('/([^\s]{12})(?=[^\s])/', '$1'.'');
$message = date("F j, Y, g:i a", $ztime) . " $username: $message";
//generate same private room folder for both users
if ($private)
{
if ($private > $session) $proom=$session ."_". $private;
else $proom=$private ."_". $session;
}
$dir=$options['uploadsPath'];
if (!file_exists($dir)) mkdir($dir);
$dir.="/$room";
if (!file_exists($dir)) mkdir($dir);
if ($proom)
{
$dir.="/$proom";
if (!file_exists($dir)) mkdir($dir);
}
$day=date("y-M-j",time());
$dfile = fopen($dir."/Log$day.html","a");
fputs($dfile,$message."
");
fclose($dfile);
}
break;
case 'getUsers':
//old session cleanup
//close sessions
$closeTime = time() - $options['onlineExpiration0']; // > client statusInterval
$sql="UPDATE `$table_sessions` SET status = 1 WHERE status = 0 AND edate < $closeTime";
$wpdb->query($sql);
$users = array();
//type 5,6 voyeur: do not show
$sql = "SELECT * FROM `$table_sessions` where room='$room' and status='0' AND type < 5 ORDER by sdate ASC";
$userRows = $wpdb->get_results($sql);
if ($wpdb->num_rows>0)
foreach ($userRows as $userRow)
{
$user = [];
$user_id = $userRow->uid;
$user['name'] = $userRow->session;
$user['id'] = $user_id;
//avatar
if (!$user_id)
{
$wpUser = get_user_by('login', $userRow->session);
$user_id = $wpUser->ID;
}
if ($user_id)
if ($options['userPicture'] == 'avatar' || ($options['userPicture'] == 'avatar_broadcaster' && $isBroadcaster) )
$user['avatar'] = get_avatar_url($user_id );
$users [] = $user;
}
$response = array(
'users' => $users,
'total' => count($userRows)
);
break;
case 'getChats':
$disconnect = self::updateOnline($username, $room, $postID, 2, $current_user, $options);
if (!$disconnect)
{
//clean old chat logs
$closeTime = time() - 900; //only keep for 15min
$sql="DELETE FROM `$table_chatlog` WHERE mdate < $closeTime";
$wpdb->query($sql);
//retrieve only messages since user came online
$sdate = 0;
if ($session) $sdate = $session->sdate;
$chats = array();
$lastID = (int) $_GET['lastID'];
$sql = "SELECT * FROM `$table_chatlog` WHERE room='$room' AND id > $lastID AND mdate > $sdate ORDER BY mdate DESC LIMIT 0,20";
$sql = "SELECT * FROM ($sql) items ORDER BY mdate ASC";
$chatRows = $wpdb->get_results($sql);
if ($wpdb->num_rows>0) foreach ($chatRows as $chatRow)
{
$chat = [];
if ($chatRow->meta)
{
$meta = unserialize($chatRow->meta);
if ($meta['sound']) $chat['sound'] = $meta['sound'];
if ($meta['image']) $chat['image'] = $meta['image'];
}
$chat['id'] = $chatRow->id;
$chat['author'] = $chatRow->username;
$chat['text'] = $chatRow->message;
$chat['time'] = array(
'hours' => gmdate('H',$chatRow->mdate),
'minutes' => gmdate('i',$chatRow->mdate)
);
$uid = $chatRow->user_id;
if (!$uid)
{
$wpUser = get_user_by($userName, $userRow->session);
if (!$wpUser) $wpUser = get_user_by('login', $chatRow->username);
$uid = $wpUser->ID;
}
$chat['avatar'] = get_avatar_url($uid);
$chats[] = $chat;
}
$response = array('chats' => $chats);
}
else
{
$response = array('chats' => array(), 'disconnect' => $disconnect);
}
break;
default:
$response = array('error' => 'HTML Chat: Task not defined!');
;
}
echo json_encode($response);
die();
}
//! channels list ajax handler
function vwls_channels() //list channels
{
//ajax called
//channel meta:
//edate s
//btime s
//wtime s
//viewers n
//maxViewers n
//maxDate s
//hasSnapshot 1
$options = get_option('VWliveStreamingOptions');
//widget id
$id = sanitize_file_name($_GET['id']);
//pagination
$perPage = (int) $_GET['pp'];
if (!$perPage) $perPage = $options['perPage'];
$page = (int) $_GET['p'];
$offset = $page * $perPage;
$perRow = (int) $_GET['pr'];
//admin side
$ban = (int) $_GET['ban'];
//
$category = (int) $_GET['cat'];
//order
$order_by = sanitize_file_name($_GET['ob']);
if (!$order_by) $order_by = $options['order_by'];
if (!$order_by) $order_by = 'edate';
//options
$selectCategory = (int) $_GET['sc'];
$selectOrder = (int) $_GET['so'];
$selectPage = (int) $_GET['sp'];
$selectName = (int) $_GET['sn'];
$selectTags = (int) $_GET['sg'];
//tags,name search
$tags = sanitize_text_field($_GET['tags']);
$name = sanitize_file_name($_GET['name']);
if ($name == 'undefined') $name = '';
if ($tags == 'undefined') $tags = '';
//output clean
ob_clean();
//thumbs dir
$dir = $options['uploadsPath']. "/_thumbs";
$ajaxurl = admin_url() . 'admin-ajax.php?action=vwls_channels&pp=' . $perPage . '&pr=' .$perRow. '&sc=' . $selectCategory . '&sn=' . $selectName . '&sg=' . $selectTags . '&so=' . $selectOrder . '&sp=' . $selectPage . '&id=' . $id . '&tags=' . urlencode($tags) . '&name=' . urlencode($name);
if ($ban) $ajaxurl .= '&ban=' . $ban; //admin side
if ($options['postChannels']) //channel posts enabled
{
//! header option controls
$ajaxurlP = $ajaxurl . '&p='.$page;
$ajaxurlPC = $ajaxurl . '&cat=' . $category ;
$ajaxurlPO = $ajaxurl . '&ob='. $order_by;
$ajaxurlCO = $ajaxurl . '&cat=' . $category . '&ob='.$order_by ;
$htmlCode .= '';
//! query args
$args=array(
'post_type' => 'channel',
'post_status' => 'publish',
'posts_per_page' => $perPage,
'offset' => $offset,
'order' => 'DESC',
'meta_query' => array(
array( 'key' => 'hasSnapshot', 'value' => '1'),
)
);
switch ($order_by)
{
case 'post_date':
$args['orderby'] = 'post_date';
break;
case 'rand':
$args['orderby'] = 'rand';
break;
default:
$args['orderby'] = 'meta_value_num';
$args['meta_key'] = $order_by;
break;
}
if ($category) $args['category'] = $category;
if ($tags)
{
$tagList = explode(',', $tags);
foreach ($tagList as $key=>$value) $tagList[$key] = trim($tagList[$key] );
$args['tax_query'] = array(
array(
'taxonomy' => 'post_tag',
'field' => 'slug',
'operator' => 'AND',
'terms' => $tagList
)
);
}
if ($name)
{
$args['s'] = $name;
}
$postslist = get_posts( $args );
//! list channels
if (count($postslist)>0)
{
//echo '';
$k = 0;
foreach ( $postslist as $item )
{
if ($perRow) if ($k) if ($k % $perRow == 0) $htmlCode .= '';
}
else $htmlCode .= __('No channels match current selection. Channels get listed after being broadcast or configured as events, with snapshot/picture.', 'live-streaming');
//! pagination
if ($selectPage)
{
$htmlCode .= '';
}
}
else // channel post disabled - check db --
{
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$items = $wpdb->get_results("SELECT * FROM `$table_channels` WHERE status=1 ORDER BY edate DESC LIMIT $offset, ". $perPage);
if ($items) foreach ($items as $item)
{
$age = VWliveStreaming::format_age(time() - $item->edate);
if ($ban) $banLink = 'Ban This Channel
';
$edate = get_post_meta($item->ID, 'edate', true);
$age = VWliveStreaming::format_age(time() - $edate);
$name = sanitize_file_name($item->post_title);
if ($ban) $banLink = 'Ban This Channel
';
$htmlCode .= '';
$htmlCode .= '";
}
//echo '' . $name . '';
$htmlCode .= '' . $banLink . $age . '';
$ratingCode = '';
if ($options['rateStarReview'])
{
$rating = get_post_meta($item->ID, 'rateStarReview_rating', true);
$max = 5;
if ($rating > 0) $ratingCode = ''; // . number_format($rating * $max,1) . ' / ' . $max
$htmlCode .= '' . $ratingCode . '';
}
$thumbFilename = "$dir/" . $name . ".jpg";
$url = VWliveStreaming::roomURL($name);
$noCache = '';
if ($age=='LIVE') $noCache='?'.((time()/10)%100);
$showImage=get_post_meta( $item->ID, 'showImage', true );
if (!file_exists($thumbFilename) || $showImage =='all') //show thumb instead
{
$attach_id = get_post_thumbnail_id($item->ID );
if ($attach_id) $thumbFilename = get_attached_file($attach_id);
}
if (file_exists($thumbFilename) && !strstr($thumbFilename, '/.jpg')) $htmlCode .= '';
else $htmlCode .= '
. 'screenshot-3.jpg)
';
$htmlCode .= "
';
$htmlCode .= '';
$htmlCode .= '";
}
//pagination
if ($selectPage)
{
$htmlCode .= "' . $item->name . '';
$htmlCode .= '' . $banLink . $age . '';
$thumbFilename = "$dir/" . $item->name . ".jpg";
$url = VWliveStreaming::roomURL($item->name);
$noCache = '';
if ($age==__('LIVE', 'live-streaming')) $noCache='?'.((time()/10)%100);
if (file_exists($thumbFilename)) $htmlCode .= '';
else $htmlCode .= '
';
$htmlCode .= "
";
if ($page>0) $htmlCode .= ' > ' . __('Previous', 'live-streaming') . ' ';
if (count($items) == $perPage) $htmlCode .= ' ' . __('Next', 'live-streaming') . ' ';
}
}
echo $htmlCode;
die;
}
//! broadcast ajax handler
function vwls_broadcast() //dedicated broadcasting page
{
ob_clean();
?>
";
$log_file = $upath . "videowhisper_transcode.log";
exec("tail -n 1 $log_file", $output1, $returnvalue);
echo "Logs: ". substr($output1[0],0,100) . " ...
";
//-vcodec copy
$cmd = $options['ffmpegPath'] .' ' . $options['ffmpegTranscode'] . " -threads 1 -f flv \"" .
$rtmpAddress . "/i_". $stream . "\" -i \"" . $rtmpAddressView ."/". $stream . "\" >&$log_file & ";
//echo $cmd;
exec($cmd, $output, $returnvalue);
exec("echo '$cmd' >> $log_file.cmd", $output, $returnvalue);
$cmd = "ps aux | grep '/i_$stream -i rtmp'";
exec($cmd, $output, $returnvalue);
//var_dump($output);
foreach ($output as $line) if (strstr($line, "ffmpeg"))
{
$columns = preg_split('/\s+/',$line);
echo "Launching transcoder process #".$columns[1]." ...";
}
echo '';
}
$admin_ajax = admin_url() . 'admin-ajax.php';
echo "
Preview (open in Safari)";
break;
case 'close':
if ( !is_user_logged_in() )
{
echo "Not authorised!";
exit;
}
$cmd = "ps aux | grep '/i_$stream -i rtmp'";
exec($cmd, $output, $returnvalue);
//var_dump($output);
$transcoding = 0;
foreach ($output as $line) if (strstr($line, "ffmpeg"))
{
$columns = preg_split('/\s+/',$line);
$cmd = "kill -9 " . $columns[1];
exec($cmd, $output, $returnvalue);
echo "
Closing #".$columns[1]." CPU: ".$columns[2]." Mem: ".$columns[3];
$transcoding = 1;
}
if (!$transcoding)
{
echo "Transcoder not found for '$stream'! Nothing to close.";
}
break;
case "html5";
?>
VideoLive Channels";
if ($items) foreach ($items as $item)
{
$count = $wpdb->get_results("SELECT count(*) as no FROM `$table_viewers` where status='1' and room='".$item->room."'");
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $item->room . "' and post_type='channel' LIMIT 0,1" );
if ($postID) $url = get_post_permalink($postID);
else $url = plugin_dir_url(__FILE__) . 'ls/channel.php?n=' . urlencode($item->name);
$urli = $root_url . "wp-content/plugins/videowhisper-live-streaming-integration/ls/snapshots/".urlencode($item->room). ".jpg";
if (!file_exists("wp-content/plugins/videowhisper-live-streaming-integration/ls/snapshots/".urlencode($item->room). ".jpg")) $urli = $root_url .
"wp-content/plugins/videowhisper-live-streaming-integration/ls/snapshots/no_video.png";
$livesnapshotsCode .= "";
}
else $livesnapshotsCode .= " ";
$options = get_option('VWliveStreamingOptions');
$state = 'block' ;
if (!$options['videowhisper']) $state = 'none';
$livesnapshotsCode .= 'No broadcasters online.";
$livesnapshotsCode .= "';
echo $livesnapshotsCode;
}
//! Widget
function widget($args) {
extract($args);
echo $before_widget;
echo $before_title;?>Live Streamingprefix . "vw_sessions";
$table_viewers = $wpdb->prefix . "vw_lwsessions";
$root_url = get_bloginfo( "url" ) . "/";
//clean recordings
VWliveStreaming::cleanSessions(0);
VWliveStreaming::cleanSessions(1);
$items = $wpdb->get_results("SELECT * FROM `$table_sessions` where status='1'");
echo "";
if ($items) foreach ($items as $item)
{
$count = $wpdb->get_results("SELECT count(id) as no FROM `$table_viewers` where status='1' and room='".$item->room."'");
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $item->room . "' and post_type='channel' LIMIT 0,1" );
if ($postID) $url = get_post_permalink($postID);
else $url = plugin_dir_url(__FILE__) . 'ls/channel.php?n=' . urlencode($item->name);
echo "
";
$options = get_option('VWliveStreamingOptions');
if ($options['userChannels']||$options['anyChannels'])
if (is_user_logged_in())
{
$userName = $options['userName']; if (!$userName) $userName='user_nicename';
$current_user = wp_get_current_user();
if ($current_user->$userName) $username = $current_user->$userName;
$username = sanitize_file_name($username);
?>;
?>ls/templates/live/i_webcam.png)
Video Broadcast
' . __('Last Broadcast','live-streaming') . ': ' . VWliveStreaming::format_age($ztime - $edate) . '';
//viewers
$maxViewers = get_post_meta($postID, 'maxViewers', true);
if (!is_array($maxViewers)) if ($maxViewers>0)
{
$metaCode .= '';
$maxDate = (int) get_post_meta($postID, 'maxDate', true);
$metaCode .= ' ' . __('Maximum viewers','live-streaming') . ': ' . $maxViewers;
if ($maxDate) $metaCode .= ' on ' . date("F j, Y, g:i a", $maxDate);
$metaCode .= '';
}
//watch time
$wtime = get_post_meta($postID, 'wtime', true);
if ($wtime) $metaCode .= '' . __('Total Watch Time', 'live-streaming') . ': ' . VWliveStreaming::format_time($wtime) . '';
if ($metaCode) $addCode .= '';
if (!$offline) $addCode .= VWliveStreaming::eventInfo($postID);
//! show reviews
if ($options['rateStarReview'])
{
//tab : reviews
if (shortcode_exists("videowhisper_review"))
$addCode .= '' . __('My Review', 'live-streaming') . '
' . do_shortcode('[videowhisper_review content_type="channel" post_id="' . $postID . '" content_id="' . $postID . '"]' );
else $addCode .= 'Warning: shortcodes missing. Plugin Rate Star Review should be installed and enabled or feature disabled.';
if (shortcode_exists("videowhisper_reviews"))
$addCode .= '' . __('Reviews', 'live-streaming') . '
' . do_shortcode('[videowhisper_reviews post_id="' . $postID . '"]' );
}
}
return $addCode . $content;
}
function eventInfo($postID)
{
$eventTitle = get_post_meta($postID, 'eventTitle', true);
if ($eventTitle)
{
$eventStart = get_post_meta($postID, 'eventStart', true);
$eventEnd = get_post_meta($postID, 'eventEnd', true);
$eventStartTime = get_post_meta($postID, 'eventStartTime', true);
$eventEndTime = get_post_meta($postID, 'eventEndTime', true);
$eventDescription= get_post_meta($postID, 'eventDescription', true);
$showImage=get_post_meta( $postID, 'showImage', true );
if ($showImage == 'event' || $showImage == 'all')
{
//get post thumb
$attach_id = get_post_thumbnail_id($postID);
if ($attach_id) $thumbFilename = get_attached_file($attach_id);
if (file_exists($thumbFilename)) $snapshot = VWliveStreaming::path2url($thumbFilename);
$eventCode .= '';
}
$eventCode .= '
';
$eventCode .= '' . $eventTitle. '
';
if ($eventStart||$eventStartTime) $eventCode .= 'Starts: '.$eventStart . ' ' . $eventStartTime;
if ($eventEnd||$eventEndTime) $eventCode .= '
Ends: '.$eventEnd . ' ' . $eventEndTime ;
if ($eventDescription) $eventCode .= '
';
} else return '';
return $eventCode;
}
public static function pre_get_posts($query)
{
//add channels to post listings
if(is_category() || is_tag())
{
$query_type = get_query_var('post_type');
if($query_type)
if (is_array($query_type))
{
if (in_array('post',$query_type) && !in_array('channel',$query_type))
$query_type[] = 'channel';
$query->set('post_type', $query_type);
}
//else //default
// $query_type = array('post', 'channel');
}
return $query;
}
function columns_head_channel($defaults) {
$defaults['featured_image'] = 'Snapshot';
$defaults['edate'] = 'Last Online';
return $defaults;
}
function columns_register_sortable( $columns ) {
$columns['edate'] = 'edate';
return $columns;
}
function columns_content_channel($column_name, $post_id)
{
if ($column_name == 'featured_image')
{
global $wpdb;
$postName = $wpdb->get_var( "SELECT post_title FROM $wpdb->posts WHERE ID = '" . $post_id . "' and post_type='channel' LIMIT 0,1" );
if ($postName)
{
$options = get_option('VWliveStreamingOptions');
$dir = $options['uploadsPath']. "/_thumbs";
$thumbFilename = "$dir/" . $postName . ".jpg";
$url = VWliveStreaming::roomURL($postName);
if (file_exists($thumbFilename)) echo '';
}
}
if ($column_name == 'edate')
{
$edate = get_post_meta($post_id, 'edate', true);
if ($edate)
{
echo ' ' . VWliveStreaming::format_age(time() - $edate);
}
}
}
public static function duration_column_orderby( $vars ) {
if ( isset( $vars['orderby'] ) && 'edate' == $vars['orderby'] ) {
$vars = array_merge( $vars, array(
'meta_key' => 'edate',
'orderby' => 'meta_value_num'
) );
}
return $vars;
}
public static function query_vars( $query_vars ){
// array of recognized query vars
$query_vars[] = 'broadcast';
$query_vars[] = 'flash-broadcast';
$query_vars[] = 'flash-view';
$query_vars[] = 'flash-video';
$query_vars[] = 'video';
$query_vars[] = 'hls';
$query_vars[] = 'mpeg';
$query_vars[] = 'webrtc-broadcast';
$query_vars[] = 'webrtc-playback';
$query_vars[] = 'html5-view';
$query_vars[] = 'external';
$query_vars[] = 'external-broadcast';
$query_vars[] = 'external-playback';
$query_vars[] = 'vwls_eula';
$query_vars[] = 'vwls_crossdomain';
$query_vars[] = 'vwls_fullchannel';
return $query_vars;
}
function parse_request( &$wp )
{
if ( array_key_exists( 'vwls_eula', $wp->query_vars ) ) {
$options = get_option('VWliveStreamingOptions');
echo html_entity_decode(stripslashes($options['eula_txt']));
exit();
}
if ( array_key_exists( 'vwls_crossdomain', $wp->query_vars ) ) {
$options = get_option('VWliveStreamingOptions');
echo html_entity_decode(stripslashes($options['crossdomain_xml']));
exit();
}
if ( array_key_exists( 'vwls_fullchannel', $wp->query_vars ) ) {
$stream = sanitize_file_name($wp->query_vars['vwls_fullchannel']);
if (!$stream)
{
echo "No channel name provided!";
exit;
}
echo '
'. $key . ': ' . $value;
if ($options['walletMulti'] == 2 && $walletTransfer != $key && $options['wallet'] != $key && $value>0) $htmlCode .= ' $key),$wp->request) . ' data-tooltip="Transfer to Active Balance">Transfer';
if ($walletTransfer == $key || ($value>0 && $options['walletMulti'] == 3 && $options['wallet'] != $key))
{
self::walletTransfer($key, $options['wallet'], get_current_user_id(), $options);
$htmlCode .= ' Transferred to active balance.';
}
}
return $htmlCode;
}
static function walletBalances($userID, $view = 'view', $options = null)
{
$balances = array();
if (!$userID) return $balances;
//woowallet
if ($GLOBALS['woo_wallet'])
{
$wooWallet = $GLOBALS['woo_wallet'];
$balances['WooWallet'] = $wooWallet->wallet->get_wallet_balance( $userID, $view);
}
//mycred
if (function_exists( 'mycred_get_users_balance')) $balances['MyCred'] = mycred_get_users_balance($userID);
return $balances;
}
static function walletTransfer($source, $destination, $userID, $options = null)
{
//transfer balance from a wallet to another wallet
if ($source == $destination) return;
if (!$options) $options = get_option('VWliveStreamingOptions');
$balances = self::walletBalances($userID, '', $options);
if ($balances[$source] > 0)
{
self::walletTransaction($destination, $balances[$source], $userID, "Wallet balance transfer from $source to $destination.", 'wallet_transfer');
self::walletTransaction($source, - $balances[$source], $userID, "Wallet balance transfer from $source to $destination.", 'wallet_transfer');
}
}
static function walletTransaction($wallet, $amount, $user_id, $entry, $ref, $ref_id = null, $data = null)
{
//transactions on all supported wallets
//$wallet : MyCred/WooWallet
if ($amount == 0) return; //no transaction
//mycred
if ($wallet == 'MyCred')
if ($amount>0)
{
if (function_exists('mycred_add')) mycred_add($ref, $user_id, $amount, $entry, $ref_id, $data);
}
else
{
if (function_exists('mycred_subtract')) mycred_subtract( $ref, $user_id, $amount, $entry, $ref_id, $data );
}
//woowallet
if ($wallet == 'WooWallet')
if ($GLOBALS['woo_wallet'])
{
$wooWallet = $GLOBALS['woo_wallet'];
if ($amount>0)
{
$wooWallet->wallet->credit( $user_id, $amount, $entry );
}
else
{
$wooWallet->wallet->debit( $user_id, -$amount, $entry );
}
}
}
static function balance($userID, $live = false, $options = null)
{
//get current user balance (as value)
// $live also estimates active (incomplete) session costs for client
if (!$userID) return 0;
if (!$options) $options = get_option('VWliveStreamingOptions');
$balance = 0;
$balances = self::walletBalances($userID, '', $options);
if ($options['wallet'])
if (array_key_exists($options['wallet'], $balances)) $balance = $balances[$options['wallet']];
if ($live)
{
$updated = get_user_meta($userID, 'vw_ppv_tempt', true);
if (time() - $updated < 15) //updated recently: use that estimation
$temp = get_user_meta($userID, 'vw_ppv_temp', true);
else $temp = self::billSessions($userID, 0, false); //estimate charges for current sessions
$balance = $balance - $temp; //deduct temporary charge
}
return $balance;
}
static function transaction($ref = "live_streaming", $user_id = 1, $amount = 0, $entry = "Live Streaming transaction.", $ref_id = null, $data = null, $options = null)
{
//ref = explanation ex. ppv_client_payment
//entry = explanation ex. PPV client payment in room.
//utils: ref_id (int|string|array) , data (int|string|array|object)
if ($amount == 0) return; //nothing
if (!$options) $options = get_option('VWliveStreamingOptions');
//active wallet
if ($options['wallet']) $wallet = $options['wallet'];
if (!$wallet) $wallet = 'MyCred';
if (!function_exists('mycred_add')) if ($GLOBALS['woo_wallet']) $wallet = 'WooWallet';
self::walletTransaction($wallet, $amount, $user_id, $entry, $ref, $ref_id, $data);
}
static function userPaidAccess($userID, $postID)
{
//checks if user has access to content that may be fore sale
if (!class_exists( 'myCRED_Sell_Content_Module' ) ) return true; //sell content disabled
$meta = get_post_meta($postID, 'myCRED_sell_content', true);
if (!$meta) return true; // not for sale
if (!$meta['price']) return true; //or no price
if (!$userID) return false; //not logged in: did not purchase
//check transaction log
global $wpdb;
$table_sessionsC = $wpdb->prefix . "myCRED_log";
$isBuyer = $wpdb->get_col( $sql = "SELECT user_id FROM {$table_sessionsC} WHERE user_id={$userID} AND ref = 'buy_content' AND ref_id = {$postID} AND creds < 0" );
if (!$isBuyer) return false; //did not purchase
else return true;
}
//! Admin
function admin_init()
{
add_meta_box(
'vwls-nav-menus',
'Channel Categories',
array('VWliveStreaming', 'nav_menus'),
'nav-menus',
'side',
'default');
}
function nav_menus()
{
//$object, $taxonomy
global $nav_menu_selected_id;
$taxonomy_name = 'category';
// Paginate browsing for large numbers of objects.
$per_page = 50;
$pagenum = isset( $_REQUEST[$taxonomy_name . '-tab'] ) && isset( $_REQUEST['paged'] ) ? absint( $_REQUEST['paged'] ) : 1;
$offset = 0 < $pagenum ? $per_page * ( $pagenum - 1 ) : 0;
$args = array(
'child_of' => 0,
'exclude' => '',
'hide_empty' => false,
'hierarchical' => 1,
'include' => '',
'number' => $per_page,
'offset' => $offset,
'order' => 'ASC',
'orderby' => 'name',
'pad_counts' => false,
);
$terms = get_terms( $taxonomy_name, $args );
if ( ! $terms || is_wp_error($terms) ) {
echo '
ID = $menu_item->term_id;
$menu_item->db_id = 0;
$menu_item->menu_item_parent = 0;
$menu_item->object_id = (int) $menu_item->term_id;
$menu_item->post_parent = (int) $menu_item->parent;
$menu_item->type = 'custom';
$object = get_taxonomy( $menu_item->taxonomy );
$menu_item->object = $object->name;
$menu_item->type_label = $object->labels->singular_name;
$menu_item->title = $menu_item->name;
$options = get_option('VWliveStreamingOptions');
if ($options['disablePageC']=='0')
{
$page_id = get_option("vwls_page_channels");
$permalink = get_permalink( $page_id);
$menu_item->url = add_query_arg(array('cid' => $menu_item->object_id, 'category' => $menu_item->name), $permalink);
} else $menu_item->url = get_term_link( $menu_item, $menu_item->taxonomy ) . '?channels=1' ;
$menu_item->target = '';
$menu_item->attr_title = '';
$menu_item->description = get_term_field( 'description', $menu_item->term_id, $menu_item->taxonomy );
$menu_item->classes = array();
$menu_item->xfn = '';
/**
* @param object $menu_item The menu item object.
*/
return $menu_item;
}
static function getDirectorySize($path)
{
$totalsize = 0;
$totalcount = 0;
$dircount = 0;
if (!file_exists($path))
{
$total['size'] = $totalsize;
$total['count'] = $totalcount;
$total['dircount'] = $dircount;
return $total;
}
if ($handle = opendir($path))
{
while (false !== ($file = readdir($handle)))
{
$nextpath = $path . '/' . $file;
if ($file != '.' && $file != '..' && !is_link($nextpath))
{
if (is_dir($nextpath))
{
$dircount++;
$result = VWliveStreaming::getDirectorySize($nextpath);
$totalsize += $result['size'];
$totalcount += $result['count'];
$dircount += $result['dircount'];
}
elseif (is_file($nextpath))
{
$totalsize += filesize($nextpath);
$totalcount++;
}
}
}
}
closedir($handle);
$total['size'] = $totalsize;
$total['count'] = $totalcount;
$total['dircount'] = $dircount;
return $total;
}
static function sizeFormat($size)
{
//echo $size;
if($size<1024)
{
return $size." bytes";
}
else if($size<(1024*1024))
{
$size=round($size/1024,2);
return $size." KB";
}
else if($size<(1024*1024*1024))
{
$size=round($size/(1024*1024),2);
return $size." MB";
}
else
{
$size=round($size/(1024*1024*1024),2);
return $size." GB";
}
}
//if any element from array1 in array2
static function any_in_array($array1, $array2)
{
foreach ($array1 as $value) if (in_array($value,$array2)) return true;
return false;
}
function admin_bar_menu($wp_admin_bar)
{
if (!is_user_logged_in()) return;
$options = get_option('VWliveStreamingOptions');
if( current_user_can('editor') || current_user_can('administrator') ) {
$menu_id = 'videowhisper-livestreaming';
$wp_admin_bar->add_node( array(
'id' => $menu_id,
'title' => 'BroadcastLiveVideo',
'href' => admin_url('admin.php?page=live-streaming')
) );
$wp_admin_bar->add_node( array(
'parent' => $menu_id,
'id' => $menu_id . '-live',
'title' => __('Live & Ban', 'live-streaming'),
'href' => admin_url('admin.php?page=live-streaming-live')
) );
$wp_admin_bar->add_node( array(
'parent' => $menu_id,
'id' => $menu_id . '-posts',
'title' => __('Channel Posts', 'live-streaming'),
'href' => admin_url('edit.php?post_type=' . $options['custom_post'])
) );
$wp_admin_bar->add_node( array(
'parent' => $menu_id,
'id' => $menu_id . '-statistics',
'title' => __('Statistics', 'live-streaming'),
'href' => admin_url('admin.php?page=live-streaming-stats')
) );
$wp_admin_bar->add_node( array(
'parent' => $menu_id,
'id' => $menu_id . '-settings',
'title' => __('Settings', 'live-streaming'),
'href' => admin_url('admin.php?page=live-streaming')
) );
$wp_admin_bar->add_node( array(
'parent' => $menu_id,
'id' => $menu_id . '-docs',
'title' => __('Documentation', 'live-streaming'),
'href' => admin_url('admin.php?page=live-streaming-docs')
) );
}
$user_id = get_current_user_id();
$current_user = wp_get_current_user();
if ($vwls_page_manage = get_option("vwls_page_manage"))
if (get_post_status( $vwls_page_manage)) //exists
if ( $options['canBroadcast'] == 'members' || VWliveStreaming::any_in_array( array( $options['broadcastList'], 'administrator', 'super admin'), $current_user->roles))
$wp_admin_bar->add_node(array(
'parent' => 'my-account-with-avatar',
'id' => 'vwls_page_manage',
'title' => __('Broadcast Live', 'live-streaming') ,
'href' => get_permalink($vwls_page_manage),
));
if ($vwls_page_channels = get_option("vwls_page_channels"))
if (get_post_status( $vwls_page_channels)) //exists
if ( $options['canWatch'] == 'members' || $options['canWatch'] == 'all' || VWliveStreaming::any_in_array( array( $options['watchList'], 'administrator', 'super admin'), $current_user->roles))
$wp_admin_bar->add_node(array(
'parent' => 'my-account-with-avatar',
'id' => 'vwls_page_channels',
'title' => __('Browse Channels', 'live-streaming') ,
'href' => get_permalink($vwls_page_channels),
));
//broadcast channels
$args = array(
'author' => $user_id,
'orderby' => 'post_date',
'order' => 'DESC',
'post_type' => $options['custom_post'],
'posts_per_page' => 20,
'offset' => 0,
);
$channels = get_posts( $args );
if (!count($channels)) return;
foreach ($channels as $channel)
{
$args = array(
'parent' => 'my-account-with-avatar',
'id' => 'videowhisper_' . $channel->post_name,
'title' => __('Broadcast', 'live-streaming') . ' ' . $channel->post_title,
'href' => add_query_arg(array('broadcast'=>''), get_permalink($channel->ID)),
);
$wp_admin_bar->add_node( $args );
}
}
function admin_menu() {
add_menu_page('Live Streaming', 'Live Streaming', 'manage_options', 'live-streaming', array('VWliveStreaming', 'settingsPage'), 'dashicons-video-alt',82);
add_submenu_page("live-streaming", "Live Streaming", "Settings", 'manage_options', "live-streaming", array('VWliveStreaming', 'settingsPage'));
add_submenu_page("live-streaming", "Live Streaming", "Statistics", 'manage_options', "live-streaming-stats", array('VWliveStreaming', 'adminStats'));
add_submenu_page("live-streaming", "Live Streaming", "Live & Ban", 'manage_options', "live-streaming-live", array('VWliveStreaming', 'adminLive'));
add_submenu_page("live-streaming", "Live Streaming", "Documentation", 'manage_options', "live-streaming-docs", array('VWliveStreaming', 'adminDocs'));
//hide add submenu
global $submenu;
unset($submenu['edit.php?post_type=channel'][10]);
}
//! cron
function cron_schedules( $schedules ) {
$schedules['min10'] = array(
'interval' => 600,
'display' => __( 'Once every 10 minutes' )
);
return $schedules;
}
static function setupSchedule() {
if ( ! wp_next_scheduled( 'cron_10min_event') )
{
wp_schedule_event( time(), 'min10', 'cron_10min_event');
}
}
function cron_10min_event()
{
//called each 10 min or more
$options = get_option('VWliveStreamingOptions');
if (!$options['restreamPause']) return;
//if (!self::timeTo('/cron_10min', 600, $options)) return; //too fast
//ip camera or re-streams
$meta_query = array(
'relation' => 'AND', // Optional, defaults to "AND"
array(
'key' => 'vw_ipCamera',
'value' => '',
'compare' => '!='
),
array(
'key' => 'vw_ipCamera',
'compare' => 'EXISTS'
)
);
$args=array(
'post_type' => $options['custom_post'],
'numberposts' => -1,
'orderby' => 'post_date',
'order' => 'DESC',
'meta_query' => $meta_query
);
$posts = get_posts( $args );
if (is_array($posts)) if (count($posts))
foreach ($posts as $post)
{
self::restreamPause($post->ID, $post->post_title, $options);
$restreamPaused = get_post_meta($post->ID, 'restreamPaused', true);
if (!$restreamPaused) self::streamSnapshot($post->post_title, true, $post->ID);
}
}
function admin_head() {
if( get_post_type() != 'channel') return;
//hide add button
echo '';
}
function adminStats()
{
$options = get_option('VWliveStreamingOptions');
?>
'count', 'order' => 'DESC', 'number' => 10, 'hierarchical' => false ) );
$args['walker'] = $walker;
echo walk_nav_menu_tree( array_map(array('VWliveStreaming', 'nav_menu_item'), $popular_terms), 0, (object) $args );
?>
$searched, 'fields' => 'all', 'orderby' => 'count', 'order' => 'DESC', 'hierarchical' => false ) );
} else {
$searched = '';
$search_results = array();
}
?>
Channel Status, Statistics
Regenerating thumbs for listed channels.';
}
//RTMP Session Control
if (in_array($options['webStatus'], array('enabled', 'strict', 'auto')))
if (file_exists($path = $options['uploadsPath']. '/_rtmpStatus.txt'))
{
$url = VWliveStreaming::path2url($path);
echo '+ RTMP Session Info Detected: last status request ' . date("D M j G:i:s T Y", filemtime($path)) ;
}
else echo '+ Warning: RTMP Session Control info was not detected. Without this broadcasts external to VideoWhisper apps will not show online and will not generate snapshots. Also all transcoding and thumb generation processes will have longer latency.';
if ($options['transcoding'])
{
$processUser = get_current_user();
$processUid = getmyuid();
echo "
+ FFMPEG transcoding and snapshot retrieval processes currently run by account '$processUser' (#$processUid). Transcoding starts some time after stream is published for VideoWhisper web apps or when RTMP Session Control is enabled.
";
$cmd = "ps aux | grep 'ffmpeg'";
exec($cmd, $output, $returnvalue);
//var_dump($output);
$transcoders = 0;
foreach ($output as $line) if (strstr($line, "ffmpeg"))
{
$columns = preg_split('/\s+/',$line);
if (($processUser == $columns[0] || $processUid == $columns[0]) && (!in_array($columns[10],array('sh','grep'))))
{
echo " - Process #".$columns[1]." CPU: ".$columns[2]." Mem: ".$columns[3].' Start: '.$columns[8].' CPU Time: '.$columns[9]. ' Cmd: ';
for ($n=10; $n<24; $n++) echo $columns[$n].' ';
if ($_GET['kill']== $columns[1])
{
$kcmd = 'kill -KILL ' . $columns[1];
exec($kcmd, $koutput, $kreturnvalue);
echo ' Killing process...';
}
else echo ' Kill';
echo '
';
$transcoders++;
}
}
if (!$transcoders) echo 'No live transcoding/snapshot processes detected.';
else echo '
Total processes for transcoding/snapshot: ' . $transcoders;
}
//start with a cleanup for viewers and broadcasters
self::cleanSessions(0);
self::cleanSessions(1);
//list channels
$typeLabels = array(1 => 'Flash',2 => 'External',3 => 'WebRTC');
global $wpdb;
$table_sessions = $wpdb->prefix . "vw_sessions";
$table_viewers = $wpdb->prefix . "vw_lwsessions";
$table_channels = $wpdb->prefix . "vw_lsrooms";
$items = $wpdb->get_results("SELECT * FROM `$table_channels` ORDER BY edate DESC LIMIT 0, 200");
echo "
";
?>
Channel Last Access Broadcast Time Watch Time Last Reset Type Logs ".$item->name;
if ($_GET['regenerateThumbs'])
{
//
$stream=$item->name;
$filename = "$dir/$stream.jpg";
if (file_exists($filename))
{
//generate thumb
$thumbWidth = $options['thumbWidth'];
$thumbHeight = $options['thumbHeight'];
$src = imagecreatefromjpeg($filename);
list($width, $height) = getimagesize($filename);
$tmp = imagecreatetruecolor($thumbWidth, $thumbHeight);
$dir = $options['uploadsPath']. "/_thumbs";
if (!file_exists($dir)) mkdir($dir);
$thumbFilename = "$dir/$stream.jpg";
imagecopyresampled($tmp, $src, 0, 0, 0, 0, $thumbWidth, $thumbHeight, $width, $height);
imagejpeg($tmp, $thumbFilename, 95);
$sql="UPDATE `$table_channels` set status='1' WHERE name ='$stream'";
$wpdb->query($sql);
} else
{
echo " Snapshot missing!";
$sql="UPDATE `$table_channels` set status='0' WHERE name ='$stream'";
$wpdb->query($sql);
}
}
global $wpdb;
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $item->name . "' and post_type='channel' LIMIT 0,1" );
if (!$options['anyChannels'] && !$options['userChannels'])
{
if (!$postID)
{
$wpdb->query( "DELETE FROM `$table_channels` WHERE name ='".$item->name."'");
echo "
DELETED: No channel post.";
}
}
if ($postID) echo ' View';
if ($item->type >=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channelR->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
$canWatch = $poptions['canWatchPremium'];
$watchList = $poptions['watchListPremium'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
$canWatch = $options['canWatch'];
$watchList = $options['watchList'];
}
if ($item->wtime > $maximumWatchTime || $item->btime > $maximumBroadcastTime) $warnCode = 'Warning: Channel '.$item->name.' consumed allocated time!';
else $warnCode = '';
echo "". VWliveStreaming::format_age(time() - $item->edate)." ". VWliveStreaming::format_time($item->btime) . ' / ' . VWliveStreaming::format_time($maximumBroadcastTime) . " ". VWliveStreaming::format_time($item->wtime) . ' / ' . VWliveStreaming::format_time($maximumWatchTime) ." " . VWliveStreaming::format_age(time() - $item->rdate)." ".($item->type>1?"Premium " . ($item->type-1) :"Standard")." ";
//channel text logs
$upload_c = VWliveStreaming::getDirectorySize($options['uploadsPath'] . '/'.$item->name);
$upload_size = VWliveStreaming::sizeFormat($upload_c['size']);
$logsurl = VWliveStreaming::path2url($options['uploadsPath'] . '/'.$item->name);
echo ''."$upload_size ($upload_c[count] files)".' ' . $warnCode . ' - " . $broadcaster->username . " Session Type: " . $typeLabel . " Status: " . $broadcaster->status . " Started: " . VWliveStreaming::format_age(time() -$broadcaster->sdate). " Broadcaster updated: " . VWliveStreaming::format_age(time() -$broadcaster->edate). " ';
if ($videoCodec) echo 'Video Codec: ' . $videoCodec . ' Audio Codec: ' . get_post_meta($postID, 'stream-codec-audio', true) .' Detected: ' . $codecAge . ' HLS: ' . get_post_meta($postID, 'stream-hls', true);
if ($webRTCmode = get_post_meta($postID, 'stream-mode', true) ) echo ' WebRTC: ' . $webRTCmode;
if ($streamProtocol) echo ' Protocol: '. $streamProtocol . ' Type: ' . get_post_meta($postID, 'stream-type', true) . ' Broadcast session updated: '. $updatedAge ;
echo '
- Broadcaster Settings
- Membership Levels
Banning Channel
get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $ban . "' and post_type='channel' LIMIT 0,1" );
if (!$postID) echo "
Channel post '$ban' not found!";
else
{
wp_delete_post($postID, true);
echo "
Channel post '$ban' was deleted.";
}
//delete room
$table_sessions = $wpdb->prefix . "vw_lsrooms";
$sql="DELETE FROM `$table_sessions` WHERE name = '$ban'";
$wpdb->query($sql);
echo "
Channel room '$ban' was deleted.";
//ban
$options['bannedNames'] .= ($options['bannedNames']?',':'') . $ban;
update_option('VWliveStreamingOptions', $options);
echo '
Current ban list: ' . $options['bannedNames'] . ' Edit';
}
//broadcast link if allowed by settings
if ($options['userChannels']||$options['anyChannels'])
{
$root_url = get_bloginfo( "url" ) . "/";
$userName = $options['userName']; if (!$userName) $userName='user_nicename';
$current_user = wp_get_current_user();
if ($current_user->$userName) $username = $current_user->$userName;
$username = sanitize_file_name($username);
$broadcast_url = admin_url() . 'admin-ajax.php?action=vwls_broadcast&n=';
?>
Channel '': Go Live
On some templates/setups you also need to add the page to site menu.
Recent Channels
Broadcast Live Video - Live Streaming by VideoWhisper.com
This solution involves special streaming hosting services: See hosting requirements and option pages from Support Resources section.
Quick Setup Tutorial
Installation URLs
https://broadcastlivevideo.com/setup-tutorial/#customize
https://videowhisper.com/tickets_submit.phpCustomize with Premium Plugins / Addons
ShortCodes
[videowhisper_watch channel="Channel Name" width="100%" height="100%" flash="0"]
Displays watch interface with video and discussion. If iOS is detected it shows HLS instead. Container style can be configured from plugin settings. Auto detection unless flash="1" forced.[videowhisper_htmlchat_playback channel="Channel Name" post_id="Channel Post ID" videowidth="480px" videoheight="360px"]
Displays html chat with HTML5 live stream.[videowhisper_video channel="Channel Name" width="480px" height="360px" html5="auto"]
Displays video only interface. Depending on device and settings will show HTML5. Set html5="always" to force html5 video.[videowhisper_hls channel="Channel Name" width="480px" height="360px"]
Displays HTML5 HLS (HTTP Live Streaming) video interface. Shows istead of watch and video interfaces if iOS is detected. Stream must be published in compatible format (H264,AAC) or transcoding must be enabled and active for stream to show.[videowhisper_mpeg channel="Channel Name" width="480px" height="360px"]
Displays HTML5 MPEG DASH video interface. Shows instead of watch and video interfaces if Android is detected. Stream must be published in compatible format (H264,AAC) or transcoding must be enabled and active for stream to show.[videowhisper_webrtc_playback channel="Channel Name" width="480px" height="360px"]
Displays WebRTC video playback interface.[videowhisper_broadcast channel="Channel Name" flash="0"]
Shows broadcasting interface. If not provided, channel name is detected depending on settings, post type, user. Only owner can access for channel posts. Auto detection unless flash="1" forced.
[videowhisper_channel_user]
Displays broadcasting interface for a channel with same name as user. Creates channel automatically if not existing. For single channel per user setups.
[videowhisper_webrtc_broadcast channel="Channel Name"]
Shows WebRTC broadcasting interface. If not provided, channel name is detected depending on settings, post type, user. Only owner can access for channel posts.
[videowhisper_external channel="Channel Name"] [videowhisper_external_broadcast channel="Channel Name"][videowhisper_external_playback channel="Channel Name"]
Shows settings for broadcasting/playback with external applications. Channel name is detected depending on settings, post type, user. Only owner can access for channel posts.
[videowhisper_channels per_page="8" perrow="" order_by="edate" category_id="" select_category="1" 'select_tags="1" select_name="1" select_order="1" select_page="1" include_css="1" ban="0" id=""]
Lists channels with snapshots, ordered by most recent online and with pagination.
[videowhisper_livesnapshots]
Older shortcode for backward compatibility. Displays full size snapshots of online channels. No pagination.
[videowhisper_channel_manage]
Displays channel management page.
Documentation, Support, Customizations
':'') .''. date('H:i:s',$chatRow->mdate) . ' ' . $chatRow->username .': '. $chatRow->message;
?>chatText=&updateTime=$userName) $username=urlencode($current_user->$userName);
$username=preg_replace("/[^0-9a-zA-Z]/","-",$username);
//access keys
if ($current_user)
{
$userkeys = $current_user->roles;
$userkeys[] = $current_user->user_login;
$userkeys[] = $current_user->ID;
$userkeys[] = $current_user->user_email;
}
$roomName=$_GET['room_name'];
sanV($roomName);
if ($username==$roomName) $username.="_".rand(10,99);//allow viewing own room - session names must be different
//check room
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$sql = "SELECT * FROM $table_channels where name='$roomName'";
$channel = $wpdb->get_row($sql);
// $wpdb->query($sql);
if (!$channel)
{
$msg = urlencode("Channel $roomName not found. Owner must broadcast first first!");
}
else
{
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$canWatch = $poptions['canWatchPremium'];
$watchList = $poptions['watchListPremium'];
$msgp = urlencode(" This is a premium channel.");
}
switch ($canWatch)
{
case "all":
$loggedin=1;
if (!$username)
{
$username="VW".base_convert((time()-1224350000).rand(0,10),10,36);
$visitor=1; //ask for username
}
break;
case "members":
if ($username) $loggedin=1;
else $msg=urlencode('' . __('You are not in the broadcasters list', 'ppv-live-webcams') . '. - ' . $username) . $msgp;
else $msg=urlencode('' . __('Please login first or register an account if you do not have one! Click here to return to website.', 'ppv-live-webcams') . '') . $msgp;
break;
}
//channel post
if ($loggedin) $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $roomName . "' and post_type='channel' LIMIT 0,1" );
if ($postID)
{
$accessList = get_post_meta($postID, 'vw_accessList', true);
if ($accessList) if (!VWliveStreaming::inList($userkeys, $accessList))
{
$loggedin = 0;
$msg .= urlencode("You are not in channel access list.");
}
$vw_logo = get_post_meta( $postID, 'vw_logo', true );
if (!$vw_logo) $vw_logo = 'global';
switch ($vw_logo)
{
case 'global':
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
break;
case 'hide':
$overLogo = '';
$overLink = '';
break;
case 'custom':
$overLogo = get_post_meta( $postID, 'vw_logoImage', true );
$overLink = get_post_meta( $postID, 'vw_logoLink', true );
break;
}
}
else
{
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
}
}
$s = $username;
$u = $username;
$r = $roomName;
$m = '';
if ($loggedin) VWliveStreaming::sessionUpdate($u, $r, 0, 1, 1);
$userType=0;
$clientIP = VWliveStreaming::get_ip_address();
if ($loggedin) VWliveStreaming::webSessionSave($username, 0, 'vv_login', $clientIP); //approve session for rtmp check
$parameters = html_entity_decode($options['parameters']);
?>firstParameter=fix&server=&serverAMF=&tokenKey=&serverRTMFP=&p2pGroup=&supportRTMP=&supportP2P=&alwaysRTMP=&alwaysP2P=&disableBandwidthDetection=&username=&userType=&msg=&loggedin=&visitor=&overLogo=&overLink=&loadstatus=1&debug=$userName) $username=urlencode($current_user->$userName);
$username=preg_replace("/[^0-9a-zA-Z]/","-",$username);
//access keys
if ($current_user)
{
$userkeys = $current_user->roles;
$userkeys[] = $current_user->user_login;
$userkeys[] = $current_user->ID;
$userkeys[] = $current_user->user_email;
$userkeys[] = $current_user->display_name;
}
$roomName=$_GET['room_name'];
sanV($roomName);
if ($username==$roomName) $username.="_".rand(10,99);//allow viewing own room - session names must be different
$ztime=time();
//check room
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$sql = "SELECT * FROM $table_channels where name='$roomName'";
$channel = $wpdb->get_row($sql);
$wpdb->query($sql);
if (!$channel)
{
$msg = urlencode("Channel $roomName not found!");
}
else
{
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$canWatch = $poptions['canWatchPremium'];
$watchList = $poptions['watchListPremium'];
$msgp = urlencode(" This is a premium channel.");
}
switch ($canWatch)
{
case "all":
$loggedin=1;
if (!$username)
{
$username="VW".base_convert((time()-1224350000).rand(0,10),10,36);
$visitor=1; //ask for username
$sendTip=0;
}
break;
case "members":
if ($username) $loggedin=1;
else $msg=urlencode('' . __('You are not in the broadcasters list', 'ppv-live-webcams') . '. - ' . $username) . $msgp;
else $msg=urlencode('' . __('Please login first or register an account if you do not have one! Click here to return to website.', 'ppv-live-webcams') . '') . $msgp;
break;
}
//channel features
$disableChat = 0;
$disableUsers = 0;
$writeText = 1;
$privateTextchat = 1;
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $roomName . "' and post_type='channel' LIMIT 0,1" );
if ($postID)
{
$accessList = get_post_meta($postID, 'vw_accessList', true);
if ($accessList) if (!VWliveStreaming::inList($userkeys, $accessList))
{
$loggedin = 0;
$msg .= urlencode("You are not in channel access list.");
}
//reload playlist if updated
$reloadPlaylist = 0;
if ($loggedin)
{
$playlistActive = get_post_meta( $postID, 'vw_playlistActive', true );
$playlistLoaded = get_post_meta( $postID, 'vw_playlistLoaded', true );
//activated or loaded and inactive
if ($playlistActive || $playlistLoaded)
{
$streamsPath = VWliveStreaming::fixPath($options['streamsPath']);
$smilPath = $streamsPath . 'playlist.smil';
if (filemtime($smilPath) > $playlistLoaded)
if (VWliveStreaming::timeTo($roomName . '/playlistReload', 5, $options))
{
$reloadPlaylist = 1;
update_post_meta( $postID, 'vw_playlistLoaded', time() );
}
}
}
//other permissions
foreach (array('chat','write','participants','privateChat') as $field)
{
$value = get_post_meta($postID, 'vw_'.$field.'List', true);
if ($value) if (!VWliveStreaming::inList($userkeys, $value))
switch ($field)
{
case 'chat':
$disableChat = 1;
break;
case 'write':
$writeText = 0;
break;
case 'participants':
$disableUsers = 1;
break;
case 'privateChat':
$privateTextchat = 0;
break;
}
}
$vw_logo = get_post_meta( $postID, 'vw_logo', true );
if (!$vw_logo) $vw_logo = 'global';
switch ($vw_logo)
{
case 'global':
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
break;
case 'hide':
$overLogo = '';
$overLink = '';
break;
case 'custom':
$overLogo = get_post_meta( $postID, 'vw_logoImage', true );
$overLink = get_post_meta( $postID, 'vw_logoLink', true );
break;
}
$vw_ads = get_post_meta( $postID, 'vw_ads', true );
if (!$vw_ads) $vw_ads = 'global';
switch ($vw_ads)
{
case 'global':
$adsServer =$options['adServer'];
break;
case 'hide':
$adsServer = '';
break;
case 'custom':
$adsServer = get_post_meta( $postID, 'vw_adsServer', true );
break;
}
}
else
{
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
$adsServer =$options['adServer'];
}
}
if ($loggedin)
{
//user picture and profile link
if ($current_user->ID > 0)
{
if ($options['userPicture'] == 'avatar') $userPicture = urlencode(get_avatar_url($current_user->ID, array('size' => 150) ));
if ($options['profilePrefix']) $userLink = urlencode($options['profilePrefix'] . $username);
}
}
//default stream to play
$streamName = $roomName;
//upgrade to compatible stream
$streamName = VWliveStreaming::responsiveStream($streamName, $postID, 'flash');
$s = $username;
$u = $username;
$m = '';
$r = $roomName;
if ($loggedin) VWliveStreaming::sessionUpdate($u, $r, 0, 1, 1);
$userType=0;
$canKick = 0;
$clientIP = VWliveStreaming::get_ip_address();
if ($loggedin) VWliveStreaming::webSessionSave($username, 0, 'vs_login', $clientIP); //approve session for rtmp check
//replace bad words or expressions
$filterRegex=urlencode("(?i)(fuck|cunt)(?-i)");
$filterReplace=urlencode(" ** ");
if (!$welcome) $welcome="Welcome on ".$roomName." live streaming channel!";
$parameters = html_entity_decode($options['parameters']);
$layoutCode = html_entity_decode($options['layoutCode']);
//user notifications
if ($current_user) if ($current_user->ID)
{
$watchRoleParameters = VWliveStreaming::userParameters($current_user, $options['watchRoleParameters']);
$parametersCode = VWliveStreaming::editParameters($parametersCode, $watchRoleParameters);
if ($sendTip)
{
$balance = self::balance($current_user->ID);
if ($balance>0) $welcome.= '
* You can send tips. Your starting balance is: ' . $balance;
else
{
$welcome.= '
* You can not send tips because you do not have any credits.';
$sendTip = 0;
}
}
if ($options['userWatchLimit'])
{
$userWatchTime = get_user_meta( $current_user->ID, 'vwls_watch', true );
if ($userWatchTime) $welcome.= '
* You watched ' . number_format($userWatchTime/60,2) . ' minutes since ' . date("F j, Y, g:i a", get_user_meta( $current_user->ID, 'vwls_watch_update', true )) .'.';
}
}
$parametersCode ='&disableChat=' . $disableChat . '&disableUsers=' . $disableUsers . '&writeText=<' . $writeText . '&privateTextchat=' . $privateTextchat . '&overLogo=' . urlencode($overLogo) . '&overLink=' . urlencode($overLink) . '&layoutCode=' . urlencode($layoutCode) . '&filterRegex=' . $filterRegex . '&filterReplace=' .$filterReplace . '&ws_ads=' . urlencode($adsServer) . '&sendTip=' . $sendTip . '&reloadPlaylist=' . $reloadPlaylist . '&loaderImage=' . urlencode($options['loaderImage']) . '&adsInterval=' . $options['adsInterval'].'&streamName=' . urlencode($streamName). $parameters;
if ($current_user) if ($current_user->ID)
{
$watchRoleParameters = VWliveStreaming::userParameters($current_user, $options['watchRoleParameters']);
$parametersCode = VWliveStreaming::editParameters($parametersCode, $watchRoleParameters);
}
?>firstParameter=fix&server=&serverAMF=&tokenKey=&serverRTMFP=&p2pGroup=&supportRTMP=&supportP2P=&alwaysRTMP=&alwaysP2P=&disableBandwidthDetection=&welcome=&username=&userType=&userPicture=&userLink=&msg=&loggedin=&visitor=&loadstatus=1get_var( $sql = 'SELECT ID FROM ' . $wpdb->posts . ' WHERE post_name = \'' . $room_name . '\' and post_type=\'' . $options['custom_post']. '\' LIMIT 0,1' );
if (!$postID) VWliveStreaming::rexit('success=0&failed=RoomNotFound-' . urlencode($room_name));
$post = get_post( $postID );
$current_user = wp_get_current_user();
$balance = self::balance($current_user->ID);
if ($amount > $balance) VWliveStreaming::rexit('success=0&failed=NotEnoughFunds-' . $balance);
$ztime = time();
//client cost
$paid = number_format($amount, 2, '.', '');
VWliveStreaming::transaction('ppv_tip', $current_user->ID, - $paid, 'Tip for ' . $room_name.'. (' .$label.')' , $ztime);
//performer earning
$received = number_format($amount * $options['tipRatio'], 2, '.', '');
VWliveStreaming::transaction('ppv_tip_earning', $post->post_author, $received , 'Tip from ' . $caller .' ('.$label.')', $ztime);
//update balance and report
$balance = self::balance($current_user->ID);
$ownMessage = 'After tip, your balance is: ' . $balance;
if ($sound) $soundCode = "sound://$sound;;";
$publicMessage = $soundCode. 'Tip from ' . $username . ': ' . $label . " ($paid)";
$privateMessage = '' . $username . ' (Tip '.$paid.'): ' . $message;
echo 'success=1&amount=' . $paid . '&balance=' . $balance. '&sound=' .urlencode($sound) . '&privateMessage=' .urlencode($privateMessage). '&publicMessage=' .urlencode($publicMessage) . '&ownMessage=' .urlencode($ownMessage);
break;
case 'vc_login':
//! vc_login - live_broadcast.swf
$options = get_option('VWliveStreamingOptions');
$rtmp_server = $options['rtmp_server'];
$rtmp_amf = $options['rtmp_amf'];
$canBroadcast = $options['canBroadcast'];
$broadcastList = $options['broadcastList'];
$tokenKey = $options['tokenKey'];
$webKey = $options['webKey'];
$serverRTMFP = $options['serverRTMFP'];
$p2pGroup = $options['p2pGroup'];
$supportRTMP = $options['supportRTMP'];
$supportP2P = $options['supportP2P'];
$alwaysRTMP = $options['alwaysRTMP'];
$alwaysP2P = $options['alwaysP2P'];
$disableBandwidthDetection = $options['disableBandwidthDetection'];
$camRes = explode('x',$options['camResolution']);
$current_user = wp_get_current_user();
$loggedin=0;
$msg="";
//username
$userName = $options['userName']; if (!$userName) $userName='user_nicename';
if ($current_user->$userName) $username=urlencode($current_user->$userName);
sanV($username);
//broadcaster room
$userlabel="";
$room_name=$_GET['room_name'];
sanV($room_name);
if ($room_name&&$room_name!=$username)
{
$userlabel=$username;
$username=$room_name;
$room=$room_name;
}
if (!$room) $room = $username;
//access keys
if ($current_user)
{
$userkeys = $current_user->roles;
$userkeys[] = $current_user->user_login;
$userkeys[] = $current_user->ID;
$userkeys[] = $current_user->user_email;
$userkeys[] = $current_user->display_name;
}
switch ($canBroadcast)
{
case "members":
if ($username) $loggedin=1;
else $msg=urlencode('' . __('You are not in the broadcasters list', 'ppv-live-webcams') . '. - ' . $username);
else $msg=urlencode('' . __('Please login first or register an account if you do not have one! Click here to return to website.', 'ppv-live-webcams') . '');
break;
}
//channel features
if ($loggedin) $postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $room . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" );
if ($postID)
{
$post_author_id = get_post_field( 'post_author', $postID );
if ($current_user->ID != $post_author_id)
{
$loggedin = 0;
$msg=urlencode('Room has different owner: ' . $room);
}
$vw_logo = get_post_meta( $postID, 'vw_logo', true );
if (!$vw_logo) $vw_logo = 'global';
switch ($vw_logo)
{
case 'global':
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
break;
case 'hide':
$overLogo = '';
$overLink = '';
break;
case 'custom':
$overLogo = get_post_meta( $postID, 'vw_logoImage', true );
$overLink = get_post_meta( $postID, 'vw_logoLink', true );
break;
}
}
else
{
$overLogo = $options['overLogo'];
$overLink = $options['overLink'];
}
$debug = "$postID-$vw_logo";
if (!$room)
{
$loggedin=0;
$msg=urlencode("Can't enter: Room missing!");
}
if (!$username)
{
$loggedin=0;
$msg=urlencode("Can't enter: Username missing!");
}
//channel name
if ($loggedin)
{
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$ztime=time();
//setup/update channel, premium & time reset
$poptions = VWliveStreaming::premiumOptions($userkeys, $options);
if ($poptions) //premium room
{
$rtype = 1 + $poptions['level'];
$camBandwidth = $poptions['pCamBandwidth'];
$camMaxBandwidth = $poptions['pCamMaxBandwidth'];
//if (!$options['pLogo']) $options['overLogo']=$options['overLink']='';
}else
{
$rtype=1;
$camBandwidth=$options['camBandwidth'];
$camMaxBandwidth=$options['camMaxBandwidth'];
}
$sql = "SELECT * FROM $table_channels where name='$room'";
$channel = $wpdb->get_row($sql);
if (!$channel)
$sql="INSERT INTO `$table_channels` ( `owner`, `name`, `sdate`, `edate`, `rdate`,`status`, `type`) VALUES ('$post_author_id', '$room', $ztime, $ztime, $ztime, 0, $rtype)";
elseif ($options['timeReset'] && $channel->rdate < $ztime - $options['timeReset']*24*3600) //time to reset in days
$sql="UPDATE `$table_channels` set edate=$ztime, type=$rtype, rdate=$ztime, wtime=0, btime=0 where name='$room'";
else
$sql="UPDATE `$table_channels` set edate=$ztime, type=$rtype where name='$room'";
$wpdb->query($sql);
}
if ($loggedin) VWliveStreaming::sessionUpdate($username, $room, 1, 1, 1);
$clientIP = VWliveStreaming::get_ip_address();
if ($loggedin) VWliveStreaming::webSessionSave($username, 1, 'vc_login', $clientIP); //approve session for rtmp check
if ($loggedin && $postID)
{
update_post_meta($postID, 'stream-protocol', 'rtmp');
update_post_meta($postID, 'stream-type', 'flash');
}
$uploadsPath = $options['uploadsPath'];
if (!$uploadsPath) { $upload_dir = wp_upload_dir(); $uploadsPath = $upload_dir['basedir'] . '/vwls'; }
$day = date("y-M-j",time());
$chatlog_url = VWliveStreaming::path2url($uploadsPath."/$room/Log$day.html");
$swfurlp = "&prefix=" . urlencode(admin_url() . 'admin-ajax.php?action=vwls&task=');
$swfurlp .= '&extension='.urlencode('_none_');
$swfurlp .= '&ws_res=' . urlencode( plugin_dir_url(__FILE__) . 'ls/');
$linkcode= VWliveStreaming::roomURL($username);
$imagecode=VWliveStreaming::path2url($uploadsPath."/_snapshots/".urlencode($username).".jpg");
if (!$options['noEmbeds'])
{
$base = plugin_dir_url(__FILE__) . "ls/";
$swfurl= plugin_dir_url(__FILE__) . "ls/live_watch.swf?ssl=1&n=".urlencode($username) . $swfurlp;
$swfurl2=plugin_dir_url(__FILE__) . "ls/live_video.swf?ssl=1&n=".urlencode($username) . $swfurlp;
$embedcode = VWliveStreaming::flash_watch($username);
$embedvcode = VWliveStreaming::flash_video($username);
}
if ($options['externalKeys']) $rtmp_server = VWliveStreaming::rtmp_address($current_user->ID, $postID, true, $stream, $stream);
$chatlog="The transcript log of this chat is available at $chatlog_url.";
if (!$welcome) $welcome="Welcome to broadcasting interface for channel '$room'! . $chatlog";
$parameters = html_entity_decode($options['parametersBroadcaster']);
if ($options['manualArchiving'])
{
$manualArchivingStart = $options['manualArchiving'] . '&action=startRecording&streamname=' . urlencode($username);
$manualArchivingStop = $options['manualArchiving'] . '&action=stopRecording&streamname=' . urlencode($username);
}
if ($current_user->ID > 0)
{
$userPicture = urlencode(get_the_post_thumbnail_url($postID));
if ($options['profilePrefixChannel']) $userLink = urlencode($options['profilePrefixChannel'] . $username);
else $userLink = $linkcode;
}
$layoutCodeBroadcaster = html_entity_decode($options['layoutCodeBroadcaster']);
//warn if HTTPS missing
if(empty($_SERVER['HTTPS']) || $_SERVER['HTTPS'] == "off")
$welcome.= '
Warning: HTTPS not detected. Some browsers like Chrome will not permit webcam access when accessing without SSL!';
?>firstParameter=fix&server=&serverAMF=&tokenKey=&serverRTMFP=&p2pGroup=&supportRTMP=&supportP2P=&alwaysRTMP=&alwaysP2P=&disableBandwidthDetection=&room=&welcome=&username=&userlabel=&userPicture=&userLink=&overLogo=&overLink=&userType=3&webserver=&msg=&loggedin=&linkcode=&embedcode=&embedvcode=&imagecode=&camWidth=&camHeight=&camFPS=&camBandwidth=&videoCodec=&codecProfile=&codecLevel=&soundCodec=&soundQuality=&micRate=&camMaxBandwidth=&manualArchivingStart=&manualArchivingStop=&onlyVideo=&loaderImage=&noEmbeds=&layoutCode=&loadstatus=1&debug=');
//generate same private room folder for both users
if ($private)
{
if ($private>$session) $proom=$session ."_". $private; else $proom=$private ."_". $session;
}
$options = get_option('VWliveStreamingOptions');
$dir=$options['uploadsPath'];
if (!file_exists($dir)) mkdir($dir);
@chmod($dir, 0777);
$dir.="/$room";
if (!file_exists($dir)) mkdir($dir);
@chmod($dir, 0777);
if ($proom) $dir.="/$proom";
if (!file_exists($dir)) mkdir($dir);
@chmod($dir, 0777);
$day=date("y-M-j",time());
$dfile = fopen($dir."/Log$day.html","a");
fputs($dfile,$message."
");
fclose($dfile);
//update html chat log
$pos = strpos($message,': ')+1;
$message = substr($message, $pos); //message without username
if ($message)
{
$table_chatlog = $wpdb->prefix . "vw_vwls_chatlog";
$ztime = time();
$sql="INSERT INTO `$table_chatlog` ( `username`, `room`, `message`, `mdate`, `type`) VALUES ('$username', '$room', '$message', $ztime, '1')";
$wpdb->query($sql);
}
?>loadstatus=1prefix . "vw_lwsessions";
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$ztime=time();
//room info
$sql = "SELECT * FROM $table_channels where name='$r'";
$channel = $wpdb->get_row($sql);
$wpdb->query($sql);
if (!$channel) $disconnect = urlencode("Channel $r not found!");
else
{
$ztime=time();
//update viewer online
$sql = "SELECT * FROM $table_sessions where session='$s' and status='1'";
$session = $wpdb->get_row($sql);
if (!$session)
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '$m', $ztime, $ztime, 1, 1)";
$wpdb->query($sql);
$session = $wpdb->get_row($sql);
}
else
{
$sql="UPDATE `$table_sessions` set edate=$ztime, room='$r', username='$u', message='$m' where session='$s' and status='1' and `type`='1'";
$wpdb->query($sql);
}
VWliveStreaming::cleanSessions(0);
//room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
$options = get_option('VWliveStreamingOptions');
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumWatchTime;
//update time
$expTime = $options['onlineExpiration0']+60;
$dS = floor(($currentTime-$lastTime)/1000);
if ($dS > $expTime || $dS<0) $disconnect = urlencode("Web server out of sync compared to online expiration setting: $dS/$expTime"); //Updates should be faster; fraud attempt?
else
{
$channel->wtime += $dS;
$timeUsed = $channel->wtime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $channel->btime ) $disconnect = urlencode("Allocated broadcasting time ended!");
if ($maximumWatchTime && $maximumWatchTime < $channel->wtime ) $disconnect = urlencode("Allocated watch time ended!");
$maximumSessionTime *=1000;
//update
$sql="UPDATE `$table_channels` set wtime = " . $channel->wtime . " where name='$r'";
$wpdb->query($sql);
//update post
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $r . "' and post_type='".$options['custom_post']."' LIMIT 0,1" );
if ($postID)
{
update_post_meta($postID, 'wtime', $channel->wtime);
}
//update user watch time, disconnect if exceeded limit
$current_user = wp_get_current_user();
if ($current_user)
if (VWliveStreaming::updateUserWatchtime($current_user, $dS, $options))
$disconnect = urlencode('Your user watch time limit was exceeded!');
}
}
?>timeTotal=&timeUsed=&lastTime=&disconnect=&dS=&loadstatus=1prefix . "vw_lsrooms";
$wpdb->flush();
$ztime=time();
$controlUsers = array();
$controlSessions = array();
//rtpsessions - WebRTC
$rtpsessiondata = stripslashes($_POST['rtpsessions']);
if (version_compare(phpversion(), '7.0', '<')) $rtpsessions = unserialize($rtpsessiondata); //request is from trusted server
else $rtpsessions = unserialize($rtpsessiondata, array());
$webrtc_test = 0;
if (is_array($rtpsessions))
foreach ($rtpsessions as $rtpsession)
{
$disconnect = "";
if (!$options['webrtc']) $disconnect = 'WebRTC is disabled.';
$stream = $rtpsession['streamName'];
$streamQuery = array();
if ($rtpsession['streamQuery'])
{
parse_str($rtpsession['streamQuery'], $streamQuery);
if ($userID = (int) $streamQuery['userID'] )
{
$user = get_userdata($userID);
$userName = $options['userName']; if (!$userName) $userName='user_nicename';
if ($user->$userName) $username = urlencode($user->$userName);
}
}
if ($channel_id = (int) $streamQuery['channel_id'] )
{
$post = get_post($channel_id);
} else $disconnect = 'No channel ID.';
$transcoding = $streamQuery['transcoding']; // just a transcoding
//WebRTC session vars
$r = $stream;
$u = $username;
if ($rtpsession['streamPublish'] == 'true' && $userID && !$disconnect && !$transcoding) //WebRTC broadcaster session
{
$s = $stream;
$m = 'WebRTC Broadcaster';
//webrtc broadcast test
if (!$webrtc_test)
{
self::requirementMet('webrtc_test');
$webrtc_test = 1;
}
$keyBroadcast = md5('vw' . $options['webKey'] . $userID . $channel_id);
if ($streamQuery['key'] != $keyBroadcast) $disconnect = 'WebRTC broadcast key mismatch.';
if (!$post) $disconnect = 'Channel post not found.';
elseif ($post->post_author != $userID) $disconnect = 'Only channel owner can broadcast.';
if (!$disconnect)
{
//sessionUpdate($username='', $room='', $broadcaster=0, $type=1, $strict=1);
$session = VWliveStreaming::sessionUpdate($s, $r, 1, 3, 1, 0);
/*
//user online
$table_sessions = $wpdb->prefix . "vw_sessions";
$sqlS = "SELECT * FROM $table_sessions WHERE session='$s' AND status='1' ORDER BY type DESC, edate DESC LIMIT 0,1";
$session = $wpdb->get_row($sqlS);
if (!$session)
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '$m', $ztime, $ztime, 1, 2)";
$wpdb->query($sql);
$session = $wpdb->get_row($sqlS);
}
//update session
$sql="UPDATE `$table_sessions` set edate=$ztime where id='".$session->id."'";
$wpdb->query($sql);
*/
//generate external snapshot for external broadcaster ??
VWliveStreaming::rtmpSnapshot($session);
$sqlC = "SELECT * FROM $table_channels WHERE name='" . $r . "' LIMIT 0,1";
$channel = $wpdb->get_row($sqlC);
if ($ban = VWliveStreaming::containsAny($channel->name, $options['bannedNames'])) $disconnect = "Room banned ($ban)!";
//calculate time in ms based on previous request
$lastTime = $session->edate * 1000;
$currentTime = $ztime * 1000;
$btime = intval($channel->btime);
//update time
$expTime = $options['onlineExpiration1'] + 60;
$dS = floor(($currentTime-$lastTime)/1000);
//if ($dS > $expTime || $dS<0) $disconnect = "Web server out of sync for webrtc broadcaster ($dS > $expTime) !"; //Updates should be faster; fraud attempt?
$btime += $dS;
//update room
$sql="UPDATE `$table_channels` set edate=$ztime, btime = " . $btime . " where id = '" . $channel->id. "'";
$wpdb->query($sql);
//update post
$postID = $channel_id;
if ($postID)
{
update_post_meta($postID, 'edate', $ztime);
update_post_meta($postID, 'btime', $btime);
update_post_meta($postID, 'stream-protocol', 'rtsp');
update_post_meta($postID, 'stream-type', 'webrtc');
self::updateViewers($postID, $r, $options);
}
//transcode stream (from RTSP)
if (!$disconnect) if ($options['transcodingAuto']>=2) VWliveStreaming::transcodeStreamWebRTC($session->room, $postID, $options);
// room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumBroadcastTime; //broadcaster
$timeUsed = $channel->btime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $btime ) $disconnect = "Allocated broadcasting time ended!";
if ($maximumWatchTime && $maximumWatchTime < $channel->wtime ) $disconnect = "Allocated watch time ended!";
$maximumSessionTime *=1000;
}
//end WebRTC broadcaster session
}
if ($rtpsession['streamPlay'] == 'true' && !$disconnect) //webRTC playback
{
$s = $username .'_'. $stream;
//sessionUpdate($username='', $room='', $broadcaster=0, $type=1, $strict=1, $updated=1);
$session = VWliveStreaming::sessionUpdate($s, $r, 0, 3, 1, 0);
/*
$table_sessions = $wpdb->prefix . "vw_lwsessions";
//update viewer online
$sqlS = "SELECT * FROM $table_sessions WHERE session='$s' AND status='1' ORDER BY type DESC, edate DESC LIMIT 0,1";
$session = $wpdb->get_row($sqlS);
if (!$session) //insert external viewer type=2
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '', $ztime, $ztime, 1, 2)";
$wpdb->query($sql);
$session = $wpdb->get_row($sqlS);
};
$sql="UPDATE `$table_sessions` set edate=$ztime where id='".$session->id."'";
$wpdb->query($sql);
*/
if ($session->type >= '2') //external viewer session: update here
{
$sqlC = "SELECT * FROM $table_channels WHERE name='" . $session->room . "' LIMIT 0,1";
$channel = $wpdb->get_row($sqlC);
//calculate time in ms based on previous request
$lastTime = $session->edate * 1000;
$currentTime = $ztime * 1000;
$wtime = intval($channel->wtime);
//update room time
$expTime = $options['onlineExpiration0']+40;
$dS = floor(($currentTime-$lastTime)/1000);
if ($dS > $expTime || $dS<0) $disconnect = "Web server out of sync ($dS > $expTime)!"; //Updates should be faster than 3 minutes; disconnected and returned on same session?
$wtime += $dS;
//update
$sql="UPDATE `$table_channels` set wtime = " . $wtime . " where id = '" . $channel->id. "'";
$wpdb->query($sql);
//update post
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $r . "' and post_type='channel' LIMIT 0,1" );
if ($postID)
{
update_post_meta($postID, 'wtime', $wtime);
}
//update user watch time, disconnect if exceeded limit
$user = get_user_by('login', $u);
if ($user)
if (VWliveStreaming::updateUserWatchtime($user, $dS, $options))
$disconnect = urlencode('User watch time limit exceeded!');
}
// room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumWatchTime;
$timeUsed = $channel->wtime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $channel->btime ) $disconnect = "Allocated broadcasting time ended!";
if ($maximumWatchTime && $maximumWatchTime < $wtime ) $disconnect = "Allocated watch time ended!";
$maximumSessionTime *=1000;
//end WebRTC playback
}
$controlSession['disconnect'] = $disconnect;
$controlSession['session'] = $s;
$controlSession['dS'] = $dS;
$controlSession['type'] = $session->type;
$controlSession['room'] = $r;
$controlSession['username'] = $u;
//$controlSession['query'] = $rtpsession['streamQuery'];
$controlSessions[$rtpsession['sessionId']] = $controlSession;
//end foreach ($rtpsessions as $rtpsession)
}
$controlSessionsS = serialize($controlSessions);
//debug update
fputs($dfile,"\r\nControl RTP Sessions: " . "\r\n" . $controlSessionsS);
//users - RTMP clients
$userdata = stripslashes($_POST['users']);
if (version_compare(phpversion(), '7.0', '<'))
$users = unserialize($userdata); //request is from trusted server
else $users = unserialize($userdata, array());
$rtmp_test = 0;
if (is_array($users))
foreach ($users as $user)
{
//$rooms = explode(',',$user['rooms']); $r = $rooms[0];
$r = $user['rooms'];
$s = $user['session'];
$u = $user['username'];
$ztime=time();
$disconnect = "";
if ($ban = VWliveStreaming::containsAny($s, $options['bannedNames'])) $disconnect = "Name banned ($s,$ban)!";
//kill snap/info sessions
if ($options['ffmpegTimeout'])
if ($user['runSeconds']) if ($user['runSeconds']>$options['ffmpegTimeout'])
if ( in_array(substr($user['session'],0,11), array('ffmpegSnap_', 'ffmpegInfo_')) )
{
$disconnect = 'FFMPEG timeout.';
}
if ($user['role'] == '1') //channel broadcaster
{
//an user is connected on rtmp: works
if (!$rtmp_test)
{
self::requirementMet('rtmp_test');
$rtmp_test = 1;
}
if (!$r) $r = $s; //use session as room if missing in older rtmp side
//sessionUpdate($username='', $room='', $broadcaster=0, $type=1, $strict=1, $updated=1);
$session = VWliveStreaming::sessionUpdate($s, $r, 1, 2, 0, 0); //not strict in case this is existing flash user
/*
//user online
$table_sessions = $wpdb->prefix . "vw_sessions";
$sqlS = "SELECT * FROM $table_sessions WHERE session='$s' AND status='1' ORDER BY type DESC, edate DESC LIMIT 0,1";
$session = $wpdb->get_row($sqlS);
if (!$session) //insert as external type=2
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '$m', $ztime, $ztime, 1, 2)";
$wpdb->query($sql);
$session = $wpdb->get_row($sqlS);
}
//
//update session
$sql="UPDATE `$table_sessions` set edate=$ztime where id='".$session->id."'";
$wpdb->query($sql);
*/
if ($session->type >= 2) //external broadcaster: update here, otherwise updates on calls from flash app
{
//generate external snapshot for external broadcaster
VWliveStreaming::rtmpSnapshot($session);
$sqlC = "SELECT * FROM $table_channels WHERE name='" . $session->room . "' LIMIT 0,1";
$channel = $wpdb->get_row($sqlC);
if ($ban = VWliveStreaming::containsAny($channel->name,$options['bannedNames'])) $disconnect = "Room banned ($ban)!";
//calculate time in ms based on previous request
$lastTime = $session->edate * 1000;
$currentTime = $ztime * 1000;
//update time
$expTime = $options['onlineExpiration1'] + 60;
$dS = floor(($currentTime-$lastTime)/1000);
//if ($dS > $expTime || $dS<0) $disconnect = "Web server out of sync for rtmp broadcaster ($dS > $expTime) !"; //Updates should be faster; fraud attempt?
$channel->btime += $dS;
//update room
$sql="UPDATE `$table_channels` set edate=$ztime, btime = " . $channel->btime . " where id = '" . $channel->id. "'";
$wpdb->query($sql);
//update post
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $session->room . "' and post_type='" . $options['custom_post']. "' LIMIT 0,1" );
//detect transcoding to avoid altering source info
$transcoding = 0;
$stream_webrtc = $session->room . '_webrtc';
$stream_hls = 'i_' . $session->room;
if ($s == $stream_hls || $s == $stream_webrtc) $transcoding = 1;
if ($postID && !$transcoding)
{
update_post_meta($postID, 'edate', $ztime);
update_post_meta($postID, 'btime', $channel->btime);
update_post_meta($postID, 'stream-protocol', 'rtmp');
update_post_meta($postID, 'stream-type', 'external');
update_post_meta($postID, 'stream-updated', $ztime);
self::updateViewers($postID, $session->room, $options);
}
//transcode stream (from RTMP)
if (!$disconnect) if ($options['transcodingAuto']>=2) VWliveStreaming::transcodeStream($session->room);
}
// room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumBroadcastTime; //broadcaster
$timeUsed = $channel->btime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $channel->btime ) $disconnect = "Allocated broadcasting time ended!";
if ($maximumWatchTime && $maximumWatchTime < $channel->wtime ) $disconnect = "Allocated watch time ended!";
$maximumSessionTime *=1000;
}
else //subscriber viewer
{
//sessionUpdate($username='', $room='', $broadcaster=0, $type=1, $strict=1, $updated=1);
$session = VWliveStreaming::sessionUpdate($s, $r, 0, 2, 0, 0); //not strict in case this is existing flash user
/*
$table_sessions = $wpdb->prefix . "vw_lwsessions";
//update viewer online
$sqlS = "SELECT * FROM $table_sessions WHERE session='$s' AND status='1' ORDER BY type DESC, edate DESC LIMIT 0,1";
$session = $wpdb->get_row($sqlS);
if (!$session) //insert external viewer type=2
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '', $ztime, $ztime, 1, 2)";
$wpdb->query($sql);
$session = $wpdb->get_row($sqlS);
};
$sql="UPDATE `$table_sessions` set edate=$ztime where id='".$session->id."'";
$wpdb->query($sql);
*/
if ($session->type >= '2') //external viewer session: update here
{
$sqlC = "SELECT * FROM $table_channels WHERE name='" . $session->room . "' LIMIT 0,1";
$channel = $wpdb->get_row($sqlC);
//calculate time in ms based on previous request
$lastTime = $session->edate * 1000;
$currentTime = $ztime * 1000;
//update room time
$expTime = $options['onlineExpiration0']+30;
$dS = floor(($currentTime-$lastTime)/1000);
if ($dS > $expTime || $dS<0) $disconnect = "Web server out of sync ($dS > $expTime)!"; //Updates should be faster than 3 minutes; fraud attempt?
$channel->wtime += $dS;
//update
$sql="UPDATE `$table_channels` set wtime = " . $channel->wtime . " where id = '" . $channel->id. "'";
$wpdb->query($sql);
//update post
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $r . "' and post_type='channel' LIMIT 0,1" );
if ($postID)
{
update_post_meta($postID, 'wtime', $channel->wtime);
}
//update user watch time, disconnect if exceeded limit
$user = get_user_by('login', $u);
if ($user)
if (VWliveStreaming::updateUserWatchtime($user, $dS, $options))
$disconnect = urlencode('User watch time limit exceeded!');
}
// room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumWatchTime;
$timeUsed = $channel->wtime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $channel->btime ) $disconnect = "Allocated broadcasting time ended!";
if ($maximumWatchTime && $maximumWatchTime < $channel->wtime ) $disconnect = "Allocated watch time ended!";
$maximumSessionTime *=1000;
}
$controlUser['disconnect'] = $disconnect;
$controlUser['session'] = $s;
$controlUser['dS'] = $dS;
$controlUser['type'] = $session->type;
$controlUser['room'] = $session->room;
$controlUser['username'] = $session->username;
$controlUsers[$user['session']] = $controlUser;
}
$controlUsersS = serialize($controlUsers);
//fputs($dfile,"\r\n rtpsessiondata: " . $rtpsessiondata );
// fputs($dfile,"\r\n rtpsessions rebuild 3: " . serialize(unserialize($rtpsessiondata, array())) );
//fputs($dfile,"\r\n rtpsessions: " . serialize($rtpsessions) );
fputs($dfile,"\r\nControl RTMP Users: ". "\r\n" . $controlUsersS);
fclose($dfile);
echo 'VideoWhisper=1&usersCount='.count($users)."&controlUsers=$controlUsersS&controlSessions=$controlSessionsS";
// rtmp_status end
break;
//! rtmp_logout
case 'rtmp_logout':
//rtmp server notifies client disconnect here
$session = $_GET['s'];
sanV($session);
if (!$session) exit;
$options = get_option('VWliveStreamingOptions');
$dir=$options['uploadsPath'];
echo "logout=";
$filename1 = $dir ."/_sessions/$session";
if (file_exists($filename1))
{
echo unlink($filename1); //remove session file
}
?>=5) $ip = $p[5]; //ip detected from streaming server
$postID = 0;
$ztime = time();
$options = get_option('VWliveStreamingOptions');
global $wpdb;
$wpdb->flush();
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . sanitize_file_name($channel) . "' and post_type='" . $options['custom_post']. "' LIMIT 0,1" );
//verify owner
$invalid = 0;
if ($broadcaster)
{
$post_author_id = get_post_field( 'post_author', $postID );
if ( $broadcasterID != $post_author_id)
{
$invalid = 1; //owner mismatch
}
}
$verified = 0;
//rtmp key login for external apps: only for external apps is validated based on secret key, local app sessions should be already validated
if (!$invalid)
if ($broadcaster=='1') //external broadcaster
{
$validKey = md5('vw' . $options['webKey'] . $broadcasterID . $postID);
if ($key == $validKey)
{
$verified = 1;
VWliveStreaming::webSessionSave($session, 1, 'rtmp_login_broadcaster', $ip);
//setup/update channel in sql
global $wpdb;
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$sql = "SELECT * FROM $table_channels where name='$room'";
$channelR = $wpdb->get_row($sql);
if (!$channelR)
$sql="INSERT INTO `$table_channels` ( `owner`, `name`, `sdate`, `edate`, `rdate`,`status`, `type`) VALUES ('$broadcasterID', '$room', $ztime, $ztime, $ztime, 0, 1)";
elseif ($options['timeReset'] && $channelR->rdate < $ztime - $options['timeReset']*24*3600) //time to reset in days
$sql="UPDATE `$table_channels` set edate=$ztime, type=1, rdate=$ztime, wtime=0, btime=0 where name='$room'";
else
$sql="UPDATE `$table_channels` set edate=$ztime where name='$room'";
$wpdb->query($sql);
//VWliveStreaming::sessionUpdate($username, $room, 1, 2, 1);
//detect transcoding to not alter source info
$transcoding = 0;
$stream_webrtc = $room . '_webrtc';
$stream_hls = 'i_' . $room;
if ($username == $stream_hls || $username == $stream_webrtc) $transcoding = 1;
if ($postID && !$transcoding)
{
update_post_meta($postID, 'stream-protocol', 'rtmp');
update_post_meta($postID, 'stream-type', 'external');
update_post_meta($postID, 'stream-updated', $ztime);
}
}
}
elseif ($broadcaster=='0') //external watcher
{
$validKeyView = md5('vw' . $options['webKey']. $postID);
if ($key == $validKeyView)
{
$verified = 1;
VWliveStreaming::webSessionSave($session, 0, 'rtmp_login_viewer', $ip);
//VWliveStreaming::sessionUpdate($username, $room, 0, 2, 1);
}
//VWliveStreaming::webSessionSave('error-'.$session, 0, "$channel-$session-$key-$postID-$validKeyView-".sanitize_file_name($channel) );
}
//after previously validaded session (above or by local apps login), returning result saved
//validate web login to streaming server
$dir = $options['uploadsPath'];
$filename1 = $dir ."/_sessions/$session";
if (file_exists($filename1)) //web login present
{
echo implode('', file($filename1));
if ($broadcaster) echo '&role=' . $broadcaster;
}
else
{
echo "VideoWhisper=1&login=0";
}
//also update RTMP server IP in settings after authentication
if ($verified)
{
if (in_array($options['webStatus'], array('auto','enabled'))) //in strict mode does not add IPs
{
$ip = VWliveStreaming::get_ip_address();;
if (!strstr($options['rtmp_restrict_ip'], $ip)) //add ip only if missing
{
$options['rtmp_restrict_ip'] .= ($options['rtmp_restrict_ip']?',':'') . $ip;
$updateOptions=1;
echo '&rtmp_restrict_ip=' . $options['rtmp_restrict_ip'];
}
}
//also enable webStatus if on auto (now secure with IP restriction enabled)
if ($options['webStatus'] == 'auto')
{
$options['webStatus'] = 'enabled';
$updateOptions=1;
echo '&webStatus=' . $options['webStatus'];
}
if ($updateOptions) update_option('VWliveStreamingOptions', $options);
}
?>prefix . "vw_sessions";
$table_channels = $wpdb->prefix . "vw_lsrooms";
$wpdb->flush();
$ztime=time();
//room info
$sql = "SELECT * FROM $table_channels where name='$r'";
$channel = $wpdb->get_row($sql);
$wpdb->query($sql);
if (!$channel) $disconnect = urlencode("Channel $r not found!");
else
{
//user online
$sql = "SELECT * FROM $table_sessions where session='$s' AND status='1' AND `type`='1'";
$session = $wpdb->get_row($sql);
if (!$session)
{
$sql="INSERT INTO `$table_sessions` ( `session`, `username`, `room`, `message`, `sdate`, `edate`, `status`, `type`) VALUES ('$s', '$u', '$r', '$m', $ztime, $ztime, 1, 1)";
$wpdb->query($sql);
}
else
{
$sql="UPDATE `$table_sessions` set edate=$ztime, room='$r', username='$u', message='$m' where session='$s' AND status='1' AND `type`='1'";
$wpdb->query($sql);
}
VWliveStreaming::cleanSessions(1);
//room usage
// options in minutes
// mysql in s
// flash in ms (minimise latency errors)
$options = get_option('VWliveStreamingOptions');
if ($ban = VWliveStreaming::containsAny($s, $options['bannedNames'])) $disconnect = "Name banned ($s, $ban)!";
if ($ban = VWliveStreaming::containsAny($r, $options['bannedNames'])) $disconnect = "Room banned ($r, $ban)!";
if ($channel->type>=2) //premium
{
$poptions = VWliveStreaming::channelOptions($channel->type, $options);
$maximumBroadcastTime = 60 * $poptions['pBroadcastTime'];
$maximumWatchTime = 60 * $poptions['pWatchTime'];
}
else
{
$maximumBroadcastTime = 60 * $options['broadcastTime'];
$maximumWatchTime = 60 * $options['watchTime'];
}
$maximumSessionTime = $maximumBroadcastTime; //broadcaster
//update time
$expTime = $options['onlineExpiration1']+30;
$dS = floor(($currentTime-$lastTime)/1000);
if ($dS>$expTime || $dS<0) $disconnect = urlencode("Web server out of sync! ($dS>$expTime)" ); //Updates should be faster than 3 minutes; fraud attempt?
else
{
$channel->btime += $dS;
$timeUsed = $channel->btime * 1000;
if ($maximumBroadcastTime && $maximumBroadcastTime < $channel->btime ) $disconnect = urlencode("Allocated broadcasting time ended!");
if ($maximumWatchTime && $maximumWatchTime < $channel->wtime ) $disconnect = urlencode("Allocated watch time ended!");
$maximumSessionTime *=1000;
//update
$sql="UPDATE `$table_channels` set edate=$ztime, btime = " . $channel->btime . " where name='$r'";
$wpdb->query($sql);
//transcode if necessary
if (!$disconnect) if ($options['transcodingAuto']>=2) VWliveStreaming::transcodeStream($r);
//update post
$postID = $wpdb->get_var( "SELECT ID FROM $wpdb->posts WHERE post_title = '" . $r . "' and post_type='" . $options['custom_post'] . "' LIMIT 0,1" );
if ($postID)
{
update_post_meta($postID, 'edate', $ztime);
update_post_meta($postID, 'btime', $channel->btime);
self::updateViewers($postID, $r, $options);
update_post_meta($postID, 'stream-protocol', 'rtmp');
update_post_meta($postID, 'stream-type', 'flash');
}
}
}
?>timeTotal=&timeUsed=&lastTime=&disconnect=&loadstatus=1
Start Broadcasting
View Channel