Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/gg.corals.io/wp-content/plugins/custom-facebook-feed/inc/Builder/ |
<?php
/**
* Custom Facebook Feed Source
*
* @since 4.0
*/
namespace CustomFacebookFeed\Builder;
use CustomFacebookFeed\CFF_Response;
use CustomFacebookFeed\CFF_Utils;
class CFF_Source {
const BATCH_SIZE = 15;
/**
* AJAX hooks for various feed data related functionality
*
* @since 4.0
*/
public static function hooks() {
add_action( 'wp_ajax_cff_source_builder_update', array( 'CustomFacebookFeed\Builder\CFF_Source', 'builder_update' ) );
add_action( 'wp_ajax_cff_source_builder_update_multiple', array( 'CustomFacebookFeed\Builder\CFF_Source', 'builder_update_multiple' ) );
add_action( 'wp_ajax_cff_source_get_page', array( 'CustomFacebookFeed\Builder\CFF_Source', 'get_page' ) );
add_action( 'wp_ajax_cff_source_get_featured_post_preview', array( 'CustomFacebookFeed\Builder\CFF_Source', 'get_featured_post_preview' ) );
add_action( 'wp_ajax_cff_source_get_playlist_post_preview', array( 'CustomFacebookFeed\Builder\CFF_Source', 'get_playlist_post_preview' ) );
add_action( 'admin_init', array( 'CustomFacebookFeed\Builder\CFF_Source', 'batch_process_legacy_source_queue' ) );
}
/**
* Used in an AJAX call to update sources based on selections or
* input from a user. Makes an API request to add additiona info
* about the connected source.
*
* @since 4.0
*/
public static function builder_update() {
$action = 'cff-admin';
if ( ! empty( $_POST['settings_page'] ) ) {
$action = 'cff_admin_nonce';
}
check_ajax_referer( $action , 'nonce');
$cap = current_user_can( 'manage_custom_facebook_feed_options' ) ? 'manage_custom_facebook_feed_options' : 'manage_options';
$cap = apply_filters( 'cff_settings_pages_capability', $cap );
if ( ! current_user_can( $cap ) ) {
wp_send_json_error(); // This auto-dies.
}
$source_data = array(
'access_token' => sanitize_text_field( $_POST['access_token'] ),
'id' => sanitize_text_field( $_POST['id'] ),
'type' => sanitize_text_field( $_POST['type'] ),
'privilege' => isset( $_POST['privilege'] ) ? sanitize_text_field( $_POST['privilege'] ) : '',
);
if ( ! empty( $_POST['name'] ) ) {
$source_data['name'] = sanitize_text_field( $_POST['name'] );
}
$return = CFF_Source::process_connecting_source_data( $source_data );
echo $return;
wp_die();
}
/**
* Add our update a source from raw API data.
*
* @param $source_data
*
* @return string
*/
public static function process_connecting_source_data( $source_data ) {
$header_details = \CustomFacebookFeed\CFF_Utils::fetch_header_data( $source_data['id'], $source_data['type'] === 'group', $source_data['access_token'], 0, false, '' );
if ( ! isset( $header_details->name ) ) {
$message = __( 'There was a problem connecting this account. Please make sure your access token and ID are correct.');
$details = '';
if ( isset( $header_details->cached_error ) ) {
$details = $header_details->cached_error->message;
$details = '<span class="sb-caption">API Response: ' . esc_html( $details ) . '</span>';
} elseif ( isset( $header_details->error ) ) {
$details = $header_details->error->message;
$details = '<span class="sb-caption">API Response: ' . esc_html( $details ) . '</span>';
}
$return_html = '<div class="cff-groups-connect-actions sb-alerts-wrap"><div class="sb-alert">
<svg width="18" height="18" viewBox="0 0 18 18" fill="none" xmlns="http://www.w3.org/2000/svg">
<path d="M8.99935 0.666504C4.39935 0.666504 0.666016 4.39984 0.666016 8.99984C0.666016 13.5998 4.39935 17.3332 8.99935 17.3332C13.5993 17.3332 17.3327 13.5998 17.3327 8.99984C17.3327 4.39984 13.5993 0.666504 8.99935 0.666504ZM9.83268 13.1665H8.16602V11.4998H9.83268V13.1665ZM9.83268 9.83317H8.16602V4.83317H9.83268V9.83317Z" fill="#995C00"/>
</svg>
<span><strong>' . esc_html( $message ) . '</strong></span><br>
' . $details . '
</div></div>';
$return = array(
'success' => false,
'message' => $return_html
);
return \CustomFacebookFeed\CFF_Utils::cff_json_encode( $return );
}
if ( isset( $header_details->shortcode_options ) ) {
unset( $header_details->shortcode_options );
}
if ( isset( $header_details->name ) ) {
$source_data['name'] = $header_details->name;
}
$source_data['info'] = $header_details;
// don't update or insert the access token if there is an API error
if ( ! isset( $header_details->error ) && ! isset( $header_details->cached_error ) ) {
$source_data['error'] = '';
$source_data['info']->connected_version = CFFVER;
CFF_Source::update_or_insert( $source_data );
}
return \CustomFacebookFeed\CFF_Utils::cff_json_encode( CFF_Feed_Builder::get_source_list() );
}
/**
* Used in an AJAX call to update Multiple sources based on selections or
* input from a user. Makes an API request to add additiona info
* about the connected source.
*
* @since 4.0
*/
public static function builder_update_multiple() {
if(check_ajax_referer( 'cff_admin_nonce' , 'nonce', false) || check_ajax_referer( 'cff-admin' , 'nonce', false) ){
$cap = current_user_can( 'manage_custom_facebook_feed_options' ) ? 'manage_custom_facebook_feed_options' : 'manage_options';
$cap = apply_filters( 'cff_settings_pages_capability', $cap );
if ( ! current_user_can( $cap ) ) {
wp_send_json_error(); // This auto-dies.
}
$has_error = false;
if(isset($_POST['sourcesList']) && !empty($_POST['sourcesList']) && is_array($_POST['sourcesList'])){
foreach ($_POST['sourcesList'] as $single_source):
$source_data = array(
'access_token' => sanitize_text_field( $single_source['access_token'] ),
'id' => sanitize_text_field( $single_source['account_id'] ),
'name' => isset($single_source['name']) ? sanitize_text_field($single_source['name']) : '',
'type' => sanitize_text_field( $_POST['type'] ),
'privilege' => isset( $single_source['privilege'] ) ? sanitize_text_field( $single_source['privilege'] ) : '',
);
$header_details = \CustomFacebookFeed\CFF_Utils::fetch_header_data( $source_data['id'], $source_data['type'] === 'group', $source_data['access_token'], 0, false, '' );
if ( isset( $header_details->shortcode_options ) ) {
unset( $header_details->shortcode_options );
}
if ( isset( $header_details->name ) ) {
$source_data['name'] = $header_details->name;
}
$source_data['info'] = $header_details;
// don't update or insert the access token if there is an API error
if ( ! isset( $header_details->error ) ) {
$source_data['error'] = '';
$source_data['info']->connected_version = CFFVER;
CFF_Source::update_or_insert( $source_data );
}else{
$has_error = true;
}
endforeach;
}
$response = [
'sourcesList' => CFF_Feed_Builder::get_source_list()
];
if( $has_error ){
$response['hasError'] = true;
}
echo \CustomFacebookFeed\CFF_Utils::cff_json_encode( $response );
}
wp_die();
}
/**
* Get a list of sources with a limit and offset like a page
*
* @since 4.0
*/
public static function get_page() {
check_ajax_referer( 'cff-admin' , 'nonce');
$cap = current_user_can( 'manage_custom_facebook_feed_options' ) ? 'manage_custom_facebook_feed_options' : 'manage_options';
$cap = apply_filters( 'cff_settings_pages_capability', $cap );
if ( ! current_user_can( $cap ) ) {
wp_send_json_error(); // This auto-dies.
}
$args = array( 'page' => $_POST['page'] );
$source_data = CFF_Db::source_query( $args );
echo \CustomFacebookFeed\CFF_Utils::cff_json_encode( $source_data );
wp_die();
}
/**
* Using the URL and source ID, info about a single post is returned
*
* @since 4.0
*/
public static function get_featured_post_preview() {
check_ajax_referer( 'cff-admin' , 'nonce');
$cap = current_user_can( 'manage_custom_facebook_feed_options' ) ? 'manage_custom_facebook_feed_options' : 'manage_options';
$cap = apply_filters( 'cff_settings_pages_capability', $cap );
if ( ! current_user_can( $cap ) ) {
wp_send_json_error(); // This auto-dies.
}
$query_args = array(
'id' => sanitize_text_field( $_POST['source_id'] )
);
$results = CFF_Db::source_query( $query_args );
if ( ! isset( $results[0] ) ) {
echo '{"error":{"message":"No valid ID found"}}';
wp_die();
}
$access_token = $results[0]['access_token'];
$url_or_post_id = $_POST['url_or_id'];
$id = CFF_Source::extract_id( $url_or_post_id, 'album' );
if ( isset( $id ) ) {
$data = CFF_Source::fetch_featured( $id, sanitize_text_field( $_POST['source_id'] ), $access_token );
echo $data;
} else {
echo '{"error":{"message":"No valid ID found"}}';
}
wp_die();
}
/**
* Using the URL or ID, info about a single playlist is returned
*
* @since 4.0
*/
public static function get_playlist_post_preview() {
check_ajax_referer( 'cff-admin' , 'nonce');
$cap = current_user_can( 'manage_custom_facebook_feed_options' ) ? 'manage_custom_facebook_feed_options' : 'manage_options';
$cap = apply_filters( 'cff_settings_pages_capability', $cap );
if ( ! current_user_can( $cap ) ) {
wp_send_json_error(); // This auto-dies.
}
$query_args = array(
'id' => sanitize_text_field( $_POST['source_id'] )
);
$results = CFF_Db::source_query( $query_args );
if ( ! isset( $results[0] ) ) {
echo '{"error":{"message":"No valid ID found"}}';
wp_die();
}
$access_token = $results[0]['access_token'];
$url_or_post_id = $_POST['url_or_id'];
$id = CFF_Source::extract_id( $url_or_post_id, 'playlist' );
if ( ! empty( $id ) ) {
$data = CFF_Source::fetch_playlist( $id, $access_token );
echo $data;
} else {
echo '{"error":{"message":"Not a valid playlist for this account"}}';
}
wp_die();
}
/**
* Makes an API request to the featured post endpoint
*
* @param $post_id $url
* @param string $source_id
* @param string $access_token
*
* @return bool|string
*
* @since 4.0
*/
public static function fetch_featured( $post_id, $source_id, $access_token ) {
// need a connected business account for this to work
if ( empty( $access_token ) ) {
return false;
}
$full_id = $source_id . '_' . $post_id;
if ( function_exists( 'cff_featured_post_id' ) ) {
$featured_post_url = cff_featured_post_id( $full_id, $access_token);
} else {
$featured_post_url = 'https://graph.facebook.com/v4.0/'.$full_id.'?fields=id,from{picture,id,name,link},message,message_tags,story,story_tags,picture,full_picture,status_type,created_time,backdated_time,attachments{title,description,media_type,unshimmed_url,target{id},multi_share_end_card,media{source,image},subattachments},shares,comments.summary(true){message,created_time},likes.summary(true).limit(0),call_to_action,privacy&access_token=' . $access_token;
}
if ( function_exists( 'cff_featured_event_id' ) ) {
$featured_event_url = cff_featured_event_id( $full_id, $access_token);
} else {
$featured_event_url = 'https://graph.facebook.com/v4.0/'.$full_id.'?fields=id,name,attending_count,ticket_uri,cover,start_time,end_time,timezone,place,description,interested_count&access_token='.$access_token;
}
$response = wp_remote_get( $featured_post_url );
$return = '{}';
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_wp_error( $response ) ) {
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_fb_error( $response['body'] ) ) {
return $response['body'];
} else {
$return = $response['body'];
}
}
$response = wp_remote_get( $featured_event_url );
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_wp_error( $response ) ) {
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_fb_error( $response['body'] ) ) {
return $response['body'];
}
} else {
return '{"error":{"message":"HTTP request error"}}';
}
return $return;
}
/**
* Makes an API request to the playlist endpoint
*
* @param $playlist_id $url
* @param string $access_token
*
* @return bool|string
*
* @since 4.0
*/
public static function fetch_playlist( $playlist_id, $access_token ) {
// need a connected business account for this to work
if ( empty( $access_token ) ) {
return false;
}
$url = 'https://graph.facebook.com/v3.2/'.$playlist_id.'/videos/?access_token='.$access_token.'&fields=published,source,updated_time,created_time,title,description,embed_html,format{picture}&locale=en_US&limit=5';
$response = wp_remote_get( $url );
$return = '{}';
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_wp_error( $response ) ) {
if ( ! \CustomFacebookFeed\CFF_Utils::cff_is_fb_error( $response['body'] ) ) {
return json_encode(
array_merge(
json_decode($response['body'], true),
[
'playlistID' => $playlist_id
]
), true
);
} else {
$return = $response['body'];
}
}
return $return;
}
/**
* Connection URLs are based on the website connecting accounts so that is
* configured here and returned
*
* @return array
*
* @since 4.0
*/
public static function get_connection_urls($is_settings = false) {
$urls = array();
$admin_url_state = $is_settings ? admin_url('admin.php?page=cff-settings') : admin_url('admin.php?page=cff-feed-builder');
$sb_admin_email = get_option('admin_email');
$nonce = wp_create_nonce('cff_con');
$sw_flag = !empty($_GET['sw-feed']) ? true : false;
$groups_number = CFF_Db::check_group_source() > 0 ? true : false;
//If the admin_url isn't returned correctly then use a fallback
if ($admin_url_state == '/wp-admin/admin.php?page=cff-feed-builder'
|| $admin_url_state == '/wp-admin/admin.php?page=cff-feed-builder&tab=configuration') {
$admin_url_state = "http://$_SERVER[HTTP_HOST]$_SERVER[REQUEST_URI]";
}
$urls['page'] = [
'connect' => CFF_CONNECT_URL,
'wordpress_user' => $sb_admin_email,
'v' => 'free',
'vn' => CFFVER,
'has_group' => $groups_number,
'cff_con' => $nonce,
'sw_feed' => $sw_flag
];
$urls['group'] = [
'connect' => CFF_CONNECT_URL,
'wordpress_user' => $sb_admin_email,
'v' => 'free',
'vn' => CFFVER,
'has_group' => $groups_number,
'cff_con' => $nonce,
'sw_feed' => $sw_flag
];
$urls['stateURL'] = $admin_url_state;
return $urls;
}
/**
* Used as a listener for the account connection process. If
* data is returned from the account connection processed it's used
* to generate the list of possible sources to chose from.
*
* @return array|bool
*
* @since 4.0
*/
public static function maybe_source_connection_data() {
$nonce = !empty($_GET['cff_con']) ? sanitize_key($_GET['cff_con']) : '';
if (!wp_verify_nonce($nonce, 'cff_con')) {
return false;
}
if ( isset( $_GET['cff_access_token'] )
&& isset( $_GET['cff_final_response'] )
&& $_GET['cff_final_response'] == 'true' ) {
// clear access token errors since the user is reconnecting accounts
$reporter = \CustomFacebookFeed\CFF_Utils::cff_is_pro_version() ? cff_main_pro()->cff_error_reporter : cff_main()->cff_error_reporter;
$reporter->remove_error( 'accesstoken' );
$access_token = sanitize_text_field( $_GET['cff_access_token'] );
if ( isset( $_GET['cff_group'] ) ) {
$return = CFF_Source::retrieve_available_groups( $access_token );
} else {
$return = CFF_Source::retrieve_available_pages( $access_token );
}
if ( $return ) {
return $return;
} else {
return array( 'error' => __( 'Unable to connect to Facebook to retrieve account information.', 'custom-facebook-feed' ) );
}
}
return false;
}
/**
* Uses the Facebook API to retrieve a list of pages for the
* access token
*
* @param string $access_token
*
* @return array|bool
*
* @since 4.0
*/
public static function retrieve_available_pages( $access_token ) {
//Get User Info
$user_url = 'https://graph.facebook.com/me?fields=name,id,picture&access_token=' . $access_token;
$user_id_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $user_url );
$user_id_data_arr = json_decode( $user_id_data );
$url = 'https://graph.facebook.com/me/accounts?fields=access_token,name,id&limit=500&access_token=' . $access_token;
$pages_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $url );
$pages_data_arr = json_decode( $pages_data, true );
if ( isset( $pages_data_arr['data'] ) ) {
$return = array(
'user' => $user_id_data_arr,
'pages' => $pages_data_arr['data'],
);
return $return;
} else if ( isset( $pages_data_arr['error'] ) ) {
return $pages_data_arr;
} else {
return [
'error' => [
'code' => 'HTTP Request',
'message' => __( 'Your server could not complete a remote request to Facebook\'s API. Your host may be blocking access or there may be a problem with your server.', 'custom-facebook-feed' )
]
];
}
}
/**
* Uses the Facebook API to retrieve a list of groups for the
* access token split into "admin" and "member" groupings
*
* @param string $access_token
*
* @return array|bool
*
* @since 4.0
*/
public static function retrieve_available_groups( $access_token ) {
//Extend the user token by making a call to /me/accounts. User must be an admin of a page for this to work as won't work if the response is empty.
$url = 'https://graph.facebook.com/me/accounts?limit=500&access_token=' . $access_token;
$accounts_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $url );
if ( empty( $accounts_data ) ) {
return [
'error' => [
'code' => 'HTTP Request',
'message' => __( 'Your server could not complete a remote request to Facebook\'s API. Your host may be blocking access or there may be a problem with your server.', 'custom-facebook-feed' )
]
];
}
$accounts_data_arr = json_decode( $accounts_data );
$cff_token_expiration = 'never';
if ( empty( $accounts_data_arr->data ) ) {
$cff_token_expiration = '60 days';
}
if ( ! empty( $accounts_data_arr->error ) ) {
return $accounts_data_arr;
}
//Get User Info
$user_url = 'https://graph.facebook.com/me?fields=name,id,picture&access_token=' . $access_token;
$user_id_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $user_url );
if ( ! empty( $user_id_data ) ) {
$user_id_data_arr = json_decode( $user_id_data );
$user_id = $user_id_data_arr->id;
$admin_ids = [];
//Get groups they're admin of
$groups_admin_url = 'https://graph.facebook.com/' . $user_id . '/groups?admin_only=true&fields=name,id,picture&access_token=' . $access_token;
$groups_admin_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $groups_admin_url );
$groups_admin_data_arr = json_decode( $groups_admin_data, true );
$admin_groups = array();
if ( isset( $groups_admin_data_arr['data'] ) ) {
foreach ( $groups_admin_data_arr['data'] as $single_group ) {
$single_group['expiration'] = $cff_token_expiration;
$single_group['access_token'] = $access_token;
$admin_groups[] = $single_group;
$admin_ids[] = $single_group['id'];
}
}
//Get member groups
$groups_url = 'https://graph.facebook.com/' . $user_id . '/groups?admin_only=false&fields=name,id,picture&access_token=' . $access_token;
$groups_data = \CustomFacebookFeed\CFF_Utils::cff_fetchUrl( $groups_url );
$groups_data_arr = json_decode( $groups_data, true );
$member_groups = array();
if ( isset( $groups_data_arr['data'] ) ) {
foreach ( $groups_data_arr['data'] as $single_group ) {
if ( ! in_array( $single_group['id'], $admin_ids, true ) ) {
$single_group['expiration'] = $cff_token_expiration;
$single_group['access_token'] = $access_token;
$member_groups[] = $single_group;
}
}
}
$return = array(
'user' => $user_id_data_arr,
'admin' => $admin_groups,
'member' => $member_groups
);
return $return;
} else if ( isset( $accounts_data_arr['error'] ) ) {
return $accounts_data;
} else {
return [
'error' => [
'code' => 'HTTP Request',
'message' => __( 'Your server could not complete a remote request to Facebook\'s API. Your host may be blocking access or there may be a problem with your server.', 'custom-facebook-feed' )
]
];
}
}
/**
* Used to update or insert connected accounts (sources)
*
* @param array $source_data
*
* @return bool
*
* @since 4.0
*/
public static function update_or_insert( $source_data ) {
if ( ! isset( $source_data['id'] ) ) {
return false;
}
if ( isset( $source_data['info'] ) ) {
// data from an API request related to the source is saved as a JSON string
if ( is_object( $source_data['info'] ) || is_array( $source_data['info'] ) ) {
$source_data['info'] = \CustomFacebookFeed\CFF_Utils::cff_json_encode( $source_data['info'] );
}
}
if ( CFF_Source::exists_in_database( $source_data ) ) {
$source_data['last_updated'] = date( 'Y-m-d H:i:s' );
CFF_Source::update( $source_data );
} else {
if ( ! isset( $source_data['access_token'] ) ) {
return false;
}
CFF_Source::insert( $source_data );
}
CFF_Source::after_update_or_insert( $source_data );
}
/**
* Whether or not the source exists in the database
*
* @param array $args
*
* @return bool
*
* @since 4.0
*/
public static function exists_in_database( $args ) {
$results = CFF_Db::source_query( $args );
return isset( $results[0] );
}
/**
* Add a new source as a row in the cff_sources table
*
* @param array $source_data
*
* @return false|int
*
* @since 4.0
*/
public static function insert( $source_data ) {
$source_data['username'] = $source_data['name'];
$data = $source_data;
return CFF_Db::source_insert( $data );
}
/**
* Update info in rows that match the source data
*
* @param array $source_data
*
* @return false|int
*
* @since 4.0
*/
public static function update( $source_data, $where_privilige = true ) {
$where = array( 'id' => $source_data['id'] );
unset( $source_data['id'] );
if ( $where_privilige && isset( $source_data['privilege'] ) ) {
$where['privilege'] = $source_data['privilege'];
}
// usernames are more common in the other plugins so
// that is the name of the column that is used as the
// page or group "name" data
if ( isset( $source_data['name'] ) ) {
$source_data['username'] = $source_data['name'];
}
$data = $source_data;
return CFF_Db::source_update( $data, $where );
}
/**
* Do something after a source is updated or inserted
*
* @param array $source_data
* @since 4.0.6/4.0.9
*/
public static function after_update_or_insert( $source_data ) {
// check to see if all groups updated
$cff_statuses_option = get_option( 'cff_statuses', array() );
if ( empty( $cff_statuses_option['groups_need_update'] ) ) {
return;
}
$groups = \CustomFacebookFeed\Builder\CFF_Db::source_query( array( 'type' => 'group' ) );
$cff_statuses_option['groups_need_update'] = false;
if ( empty( $groups ) ) {
update_option( 'cff_statuses', $cff_statuses_option, false );
} else {
$encryption = new \CustomFacebookFeed\SB_Facebook_Data_Encryption();
$groups_need_update = false;
foreach ( $groups as $source ) {
$info = ! empty( $source['info'] ) ? json_decode( $encryption->decrypt( $source['info'] ) ) : array();
if ( \CustomFacebookFeed\Builder\CFF_Source::needs_update( $source, $info ) ) {
$groups_need_update = true;
}
}
$cff_statuses_option['groups_need_update'] = $groups_need_update;
update_option( 'cff_statuses', $cff_statuses_option, false );
}
}
/**
* @param array $source
* @param array $source_info
*
* @return bool
* @since 4.0.6/4.0.9
*/
public static function needs_update( $source, $source_info ) {
if ( 'group' === $source['account_type'] ) {
$connected_version = is_object( $source_info ) && isset( $source_info->connected_version ) ? $source_info->connected_version : 0;
if ( version_compare( $connected_version, '4.0.9', '<' ) ) {
return true;
}
}
return false;
}
/**
* Attempts to find the album or playlist ID from
* a Facebook URL
*
* @param string $url_or_post_id
* @param string $type
*
* @return bool|mixed|string
*
* @since 4.0
*/
public static function extract_id( $url_or_post_id, $type ) {
$id = false;
if ( $type === 'album' ) {
if ( strpos( $url_or_post_id, '/' ) === false ) {
$id = sanitize_text_field( $url_or_post_id );
} elseif( strpos( $url_or_post_id, '&set=a.' ) !== false ) {
$things = explode( '&set=a.', $url_or_post_id );
$id = $things[1];
} else {
$regex = '/(?:https?:\/\/)?(?:www\.)?facebook\.com\/(?:(?:\w\.)*#!\/)?(?:pages\/)?(?:[\w\-\.]*\/)*([\w\-\.]*)/';
if ( preg_match( $regex, $url_or_post_id, $matches ) ) {
if ( isset( $matches[0] ) ) {
$id = end( $matches );
}
}
}
} elseif ( $type === 'playlist') {
if ( strpos( $url_or_post_id, '/' ) === false ) {
$id = sanitize_text_field( $url_or_post_id );
} else { //https://www.facebook.com/watch/539051002877739/1979731855647067/?more=less // https://www.facebook.com/videos/vl.1234567890/
$regex = "~(?:vl\.\d+/)?(\d+)~i";
if ( stripos( $url_or_post_id, 'videos' ) !== false && preg_match( $regex, $url_or_post_id, $matches ) ) {
if ( isset( $matches[0] ) ) {
$id_pieces = end( $matches );
if ( strpos( $id_pieces, '.' ) !== false ) {
$id = explode( '.', $id_pieces )[1];
} else {
$id = $matches[0];
}
}
} else {
if ( strpos( $url_or_post_id, '?' ) !== false ) {
$url_or_post_id = explode( '?', $url_or_post_id )[0];
}
$parts = explode( '/', $url_or_post_id );
$id = $parts[ count( $parts ) - 1 ];
if ( empty( $id ) ) {
$id = $parts[ count( $parts ) - 2 ];
}
$id = (int) filter_var( $id, FILTER_SANITIZE_NUMBER_INT );
}
}
}
return $id;
}
/**
* Creates a queue of connected accounts that need to be added to
* the sources table
*
* @since 4.0.3
*/
public static function set_legacy_source_queue() {
$cff_statuses_option = get_option( 'cff_statuses', array() );
$connected_accounts = (array)json_decode(stripcslashes(get_option( 'cff_connected_accounts' )), true);
$cff_statuses_option['legacy_source_queue'] = array_chunk( array_keys( $connected_accounts ), CFF_Source::BATCH_SIZE );
update_option( 'cff_statuses', $cff_statuses_option );
}
/**
* Whether or not there are still sources in the queue and
* this isn't disabled
*
* @return bool
*
* @since 4.0.3
*/
public static function should_do_source_updates() {
$cff_statuses_option = get_option( 'cff_statuses', array() );
$should_do_source_updates = isset( $cff_statuses_option['legacy_source_queue'] ) ? ! empty( $cff_statuses_option['legacy_source_queue'] ) : false;
return apply_filters( 'should_do_source_updates', $should_do_source_updates );
}
/**
* Processes one set of connected accounts
*
* @since 4.0.3
*/
public static function batch_process_legacy_source_queue() {
if ( ! CFF_Source::should_do_source_updates() ) {
return;
}
$cff_statuses_option = get_option( 'cff_statuses', array() );
$batch = array_shift( $cff_statuses_option['legacy_source_queue'] );
update_option( 'cff_statuses', $cff_statuses_option ); // updated early just in case there is a fatal error
if ( empty( $batch ) ) {
return;
}
$connected_accounts = (array)json_decode(stripcslashes(get_option( 'cff_connected_accounts' )), true);
foreach ( $batch as $account_key ) {
$connected_account = isset( $connected_accounts[ $account_key ] ) ? $connected_accounts[ $account_key ] : false;
if ( $connected_account ) {
CFF_Source::update_single_source( $connected_account );
}
}
}
/**
* Transfer data from a connected account to the sources table
* after it's been validated with an API call
*
* @param array $connected_account
*
* @since 4.0.3
*/
public static function update_single_source( $connected_account ) {
$cff_page_slugs = get_option( 'cff_page_slugs', array() );
$access_token = str_replace("02Sb981f26534g75h091287a46p5l63","", $connected_account['accesstoken'] );
$id = str_replace( ' ', '', $connected_account['id'] );
$header_details = \CustomFacebookFeed\CFF_Utils::fetch_header_data( $id, $connected_account['pagetype'] === 'group', $access_token, 0, false, '' );
$source_data = array(
'access_token' => $connected_account['accesstoken'],
'id' => $connected_account['id'],
'type' => $connected_account['pagetype'],
'name' => $connected_account['name'],
'privilege' => '', // see if events token?
);
if ( ! is_numeric( $id ) ) {
if ( ! isset( $cff_page_slugs[ $id ] ) ) {
$cff_page_slugs[ $id ] = $header_details->id;
update_option( 'cff_page_slugs', $cff_page_slugs );
}
$source_data['id'] = $header_details->id;
}
if ( isset( $header_details->shortcode_options ) ) {
unset( $header_details->shortcode_options );
}
if ( isset( $header_details->name ) ) {
$source_data['name'] = $header_details->name;
}
$source_data['info'] = $header_details;
$source_data['error'] = '';
if ( isset( $header_details->error ) || isset( $header_details->cached_error ) ) {
$source_data['error'] = isset( $header_details->error ) ? \CustomFacebookFeed\CFF_Utils::cff_json_encode( $header_details->error ) : \CustomFacebookFeed\CFF_Utils::cff_json_encode( $header_details->cached_error );
}
CFF_Source::update_or_insert( $source_data );
$source_data['record_id'] = 0;
$source_data['account_id'] = $connected_account['id'];
$source_data['account_type'] = $connected_account['pagetype'];
$source_data['username'] = $source_data['name'];
return $source_data;
}
/**
* Creates a source from the access token and
* source ID saved in 3.x settings
*
* @since 4.0.3
*/
public static function update_source_from_legacy_settings() {
$db_access_token_option = get_option( 'cff_access_token' );
$db_page_access_token = get_option( 'cff_page_access_token' );
$db_page_id_option = get_option( 'cff_page_id' );
$db_page_type = get_option( 'cff_page_type' );
$cff_page_slugs = get_option( 'cff_page_slugs', array() );
if ( (! empty( $db_access_token_option ) || ! empty( $db_page_access_token ))
&& ! empty( $db_page_id_option ) ) {
$db_access_tokens = explode(',', str_replace( ' ', '', $db_access_token_option ) );
$db_page_ids = explode(',', str_replace( ' ', '', $db_page_id_option ) );
$i = 0;
foreach ( $db_access_tokens as $db_access_token ){
if ( strpos( $db_access_token, ':' ) !== false ) {
$id_at_arr = explode( ':', $db_access_token );
$db_page_id = $id_at_arr[0];
$db_access_token = $id_at_arr[1];
} else {
$db_page_id = $db_page_ids[ $i ];
}
$source_data = array(
'access_token' => ! empty( $db_page_access_token ) ? $db_page_access_token : $db_access_token,
'id' => $db_page_id,
'type' => $db_page_type === 'group' ? 'group' : 'page',
'name' => $db_page_id,
'privilege' => '', // see if events token?
);
$header_details = \CustomFacebookFeed\CFF_Utils::fetch_header_data( $source_data['id'], $source_data['type'] === 'group', $source_data['access_token'], 0, false, '' );
if ( isset( $header_details->shortcode_options ) ) {
unset( $header_details->shortcode_options );
}
if ( isset( $header_details->name ) ) {
$source_data['name'] = $header_details->name;
}
if ( ! is_numeric( $source_data['id'] ) && isset( $header_details->id ) ) {
if ( ! isset( $cff_page_slugs[ $source_data['id'] ] ) ) {
$cff_page_slugs[ $source_data['id'] ] = $header_details->id;
update_option( 'cff_page_slugs', $cff_page_slugs );
}
$source_data['id'] = $header_details->id;
}
$source_data['info'] = $header_details;
// don't update or insert the access token if there is an API error
if ( ! isset( $header_details->error ) && ! isset( $header_details->cached_error ) ) {
\CustomFacebookFeed\Builder\CFF_Source::update_or_insert( $source_data );
} else {
if ( ! empty( $db_page_access_token ) && ! empty( $db_access_token ) ) {
$source_data = array(
'access_token' => $db_access_token,
'id' => $db_page_id,
'type' => $db_page_type === 'group' ? 'group' : 'page',
'name' => $db_page_id,
'privilege' => '', // see if events token?
);
$header_details = \CustomFacebookFeed\CFF_Utils::fetch_header_data( $source_data['id'], $source_data['type'] === 'group', $source_data['access_token'], 0, false, '' );
if ( isset( $header_details->shortcode_options ) ) {
unset( $header_details->shortcode_options );
}
if ( isset( $header_details->name ) ) {
$source_data['name'] = $header_details->name;
}
$source_data['info'] = $header_details;
if ( ! isset( $header_details->error ) && ! isset( $header_details->cached_error ) ) {
\CustomFacebookFeed\Builder\CFF_Source::update_or_insert( $source_data );
}
}
}
$i++;
}
}
}
/**
* If the plugin is still updating legacy sources this function
* can be used to udpate a single source if needed before
* the update is done.
*
* @param string $slug_or_id
*
* @return array|bool
*/
public static function maybe_one_off_connected_account_update( $slug_or_id ) {
if ( ! CFF_Source::should_do_source_updates() ) {
return false;
}
$connected_accounts = (array)json_decode(stripcslashes(get_option( 'cff_connected_accounts' )), true);
$connected_account = isset( $connected_accounts[ $slug_or_id ] ) ? $connected_accounts[ $slug_or_id ] : false;
if ( $connected_account ) {
return CFF_Source::update_single_source( $connected_account );
}
return false;
}
/**
* Get the Facebook ID using an alphanumeric page "slug" if
* it has been created in the DB
*
* @param string $slug
*
* @return bool|string
*
* @since 4.0.3
*/
public static function get_id_from_slug( $slug ) {
$cff_page_slugs = get_option( 'cff_page_slugs', array() );
if ( isset( $cff_page_slugs[ $slug ] ) ) {
return $cff_page_slugs[ $slug ];
}
return false;
}
/**
* Clears the "error" column in the cff_sources table for a specific
* account
*
* @param string $account_id
*
* @return bool
*
* @since 4.0.3
*/
public static function clear_error( $account_id ) {
$source_data = array(
'id' => $account_id,
'error' => ''
);
return \CustomFacebookFeed\Builder\CFF_Source::update_or_insert( $source_data );
}
/**
* Adds an error to the error table by account ID
*
* @param string $account_id
* @param string|object|array $error
*
* @return bool
*
* @since 4.0.3
*/
public static function add_error( $account_id, $error ) {
$source_data = array(
'id' => $account_id,
'error' => is_string( $error ) ? $error : \CustomFacebookFeed\CFF_Utils::cff_json_encode( $error )
);
return \CustomFacebookFeed\Builder\CFF_Source::update_or_insert( $source_data );
}
/**
* Add error to the option table "cff_error_reporter"
*
* @param string $account_id
* @param string|object|array $error
*
* @return bool
*
* @since 4.0.3
*/
public static function add_report_error_option( $account) {
$errors = get_option( 'cff_error_reporter', [] );
$add_error = (isset( $errors['connection'] ) && isset( $errors['connection']['error_id'] ) && $errors['connection']['error_id'] == 190) ? false : true;
if( $add_error ){
$url = 'https://graph.facebook.com/v4.0/'.$account['account_id'].'/posts?fields=id,updated_time,from{picture,id,name,link},message,message_tags,story,story_tags,status_type,created_time,backdated_time,call_to_action,attachments{title,description,media_type,unshimmed_url,target{id},media{source}}&access_token='. $account['access_token'].'&limit=7&locale=en_US';
CFF_Utils::cff_fetchUrl($url, false);
}
}
/**
* Get single source info By Id
*
* @since 4.2.0
*/
public static function get_single_source_info($source_id)
{
$query_args = array(
'id' => sanitize_text_field(wp_unslash($source_id))
);
$results = CFF_Db::source_query_byid($query_args);
if (!isset($results[0])) {
return false;
}
return $results[0];
}
/**
* Should show group Notice
*
* @since 4.2.0
*/
public static function should_show_group_deprecation()
{
$cff_statuses = get_option( 'cff_statuses', array() );
return (
!isset($cff_statuses['cff_group_deprecation_dismiss']) ||
$cff_statuses['cff_group_deprecation_dismiss'] !== true
) && CFF_Db::check_group_source() > 0;
}
}