config = $config;
$this->prefs = $prefs;
}
/**
* All site administrators — role query, NOT a capability query (unreliable).
* @return WP_User[]
*/
private function get_recipients(): array {
return get_users( [ 'role__in' => [ 'administrator' ] ] );
}
/**
* News emails: per-admin, only items neither dismissed nor already emailed,
* filtered through the site + per-admin channel/category/relevance matrix.
*
* Items flagged `standalone` on the proxy bypass the digest and go out as
* their own email (subject = item title). Everything else is combined into
* ONE digest, each item rendered inside its category card; a single-item
* digest uses that item's title as the subject (dynamic subject).
*/
public function send_news_digest( array $payload ): void {
$items = [];
$now = time();
foreach( (array) ( $payload['news'] ?? [] ) as $item ) {
if( ! empty( $item['expires_at'] ) && strtotime( $item['expires_at'] ) <= $now ) continue;
$items[ $item['id'] ] = $item;
}
$recommendations = is_array( $payload['recommendations'] ?? null ) ? $payload['recommendations'] : [];
$cross_sell = is_array( $payload['cross_sell'] ?? null ) ? $payload['cross_sell'] : null;
if( empty( $items ) && empty( $recommendations ) ) return;
$wrapper = ! empty( $payload['email_wrapper'] ) ? $payload['email_wrapper'] : $this->fallback_wrapper();
$card_tpl = ! empty( $wrapper['item_card'] ) ? $wrapper['item_card'] : $this->fallback_card();
$emailed_meta_key = $this->config->get_emailed_news_meta();
$dismissed_meta_key = $this->config->get_dismissed_news_meta();
$recs_meta_key = $this->config->get_emailed_recs_meta();
foreach( $this->get_recipients() as $user ) {
$emailed = get_user_meta( $user->ID, $emailed_meta_key, true );
$emailed = is_array( $emailed ) ? $emailed : [];
$dismissed = get_user_meta( $user->ID, $dismissed_meta_key, true );
$dismissed = is_array( $dismissed ) ? $dismissed : [];
$unseen = array_diff_key( $items, array_flip( array_merge( $emailed, $dismissed ) ) );
// Site + per-admin matrix (category, relevance, unsubscribe). Filtered
// items are NOT recorded as emailed — re-enabling resumes delivery.
foreach( $unseen as $id => $item ) {
if( ! $this->prefs->news_item_allowed( $item, PrefsService::CHANNEL_EMAILS, $user->ID ) ) {
unset( $unseen[ $id ] );
}
}
// Cross-sell: not-yet-recommended, not-installed addons for THIS admin
$recs = $this->fresh_recommendations_for( $user, $recommendations );
$rec_section = ! empty( $recs ) ? $this->render_recs_section( $recs, $cross_sell ) : '';
if( empty( $unseen ) && $rec_section === '' ) continue;
$standalone = [];
$digest = [];
foreach( $unseen as $item ) {
if( ! empty( $item['standalone'] ) ) $standalone[] = $item;
else $digest[] = $item;
}
$sent_ids = [];
// Standalone items: one email each, the item title as the subject
foreach( $standalone as $item ) {
$content = $this->render_news_card( $item, '', $card_tpl );
$body = str_replace( [ '{news_content}', '{news_count}' ], [ $content, '1' ], $wrapper['body_html'] );
$subject = $item['title'] !== '' ? $item['title'] : $wrapper['subject'];
if( $this->send( $user, $subject, $body ) ) {
$sent_ids[] = $item['id'];
}
}
// Digest: every remaining item in its own category card, numbered when
// multiple; the recommendations section (if any) rides at the bottom.
if( ! empty( $digest ) ) {
$count = count( $digest );
$content = '';
$i = 0;
foreach( $digest as $item ) {
$i++;
$counter = $count > 1 ? $i . ' / ' . $count : '';
$content .= $this->render_news_card( $item, $counter, $card_tpl );
}
$content .= $rec_section;
$body = str_replace( [ '{news_content}', '{news_count}' ], [ $content, (string) $count ], $wrapper['body_html'] );
// Dynamic subject: a single-item digest reads like a dedicated email
if( $count === 1 && $digest[0]['title'] !== '' ) {
$subject = $digest[0]['title'];
} else {
$subject = str_replace( '{news_count}', (string) $count, $wrapper['subject'] );
}
$subject = $subject !== '' ? $subject : __( 'News from gVectors', 'gvectors' );
if( $this->send( $user, $subject, $body ) ) {
$sent_ids = array_merge( $sent_ids, array_column( $digest, 'id' ) );
$this->record_emailed_recs( $user->ID, $recs_meta_key, $recs );
}
} elseif( $rec_section !== '' ) {
// No news today — the recommendations go out as their own email,
// in the minimal local shell (the news wrapper's "what's new"
// copy would read wrong with zero items).
$shell = $this->fallback_wrapper();
$body = str_replace( [ '{news_content}', '{news_count}' ], [ $rec_section, '0' ], $shell['body_html'] );
$subject = ! empty( $cross_sell['subject'] ) ? $cross_sell['subject'] : __( 'Addons picked for your site', 'gvectors' );
if( $this->send( $user, $subject, $body ) ) {
$this->record_emailed_recs( $user->ID, $recs_meta_key, $recs );
}
}
if( ! empty( $sent_ids ) ) {
update_user_meta( $user->ID, $emailed_meta_key, array_values( array_unique( array_merge( $emailed, $sent_ids ) ) ) );
}
}
}
/**
* Recommendations this admin should still hear about: category allowed by
* BOTH scopes, never emailed to them before, addon not installed locally.
*/
private function fresh_recommendations_for( WP_User $user, array $recommendations ): array {
if( empty( $recommendations ) ) return [];
if( ! $this->prefs->allows( $user->ID, PrefsService::CHANNEL_EMAILS, 'recommendations' ) ) return [];
$emailed = get_user_meta( $user->ID, $this->config->get_emailed_recs_meta(), true );
$emailed = is_array( $emailed ) ? $emailed : [];
$fresh = [];
foreach( $recommendations as $rec ) {
if( in_array( $rec['plugin_slug'], $emailed, true ) ) continue;
if( $this->prefs->is_addon_installed( $rec['plugin_slug'] ) ) continue;
$fresh[] = $rec;
}
return $fresh;
}
/**
* Render the "Recommended for you" section from the proxy templates
* (local fallbacks when the payload didn't carry them).
*/
private function render_recs_section( array $recs, ?array $cross_sell ): string {
$item_tpl = ! empty( $cross_sell['item'] ) ? $cross_sell['item']
: ''
. '
{product_name}
'
. '
{reason}
'
. '
'
. esc_html__( 'Recommended for you', 'gvectors' ) . '
{items}
'
. '
'
. '
Hi {admin_name},
'
. '
Your payment was received and {license_count} license(s) have been activated on {site_name}.
'
. '
Transaction ID: {transaction_id}
'
. '{license_rows}'
. '
Keep this email — you will need these license keys to activate your addons on another domain (e.g. when moving from staging to production).
'
. '
'
. '
{product_name}
'
. '
{license_key}
'
. '
Valid until: {expires_at}
'
. '
' . nl2br( esc_html( $item['body'] ) ) . '
'
: '';
}
if( ! empty( $item['link_url'] ) ) {
$label = ! empty( $item['link_label'] ) ? $item['link_label'] : __( 'Learn more', 'gvectors' );
$content .= '';
}
$content = wp_kses( $content, $this->email_allowed_html() );
$meta = $this->item_type_meta( $item );
return str_replace(
[ '{type_label}', '{badge_bg}', '{badge_color}', '{title}', '{content}', '{item_counter}' ],
[ esc_html( $meta['label'] ), $meta['badge_bg'], $meta['badge_color'], esc_html( $item['title'] ), $content, esc_html( $counter ) ],
$card_tpl
);
}
/**
* Display meta for an item: prefer proxy-provided label/colors (source of
* truth), validated; fall back to the local map for older proxies.
*/
private function item_type_meta( array $item ): array {
$meta = self::TYPE_META_FALLBACK[ $item['type'] ?? '' ] ?? self::TYPE_META_FALLBACK['announcement'];
if( ! empty( $item['type_label'] ) && is_string( $item['type_label'] ) ) {
$meta['label'] = $item['type_label'];
}
foreach( [ 'badge_bg', 'badge_color' ] as $key ) {
if( ! empty( $item[ $key ] ) && is_string( $item[ $key ] ) && preg_match( '/^#[0-9a-fA-F]{3,8}$/', $item[ $key ] ) ) {
$meta[ $key ] = $item[ $key ];
}
}
return $meta;
}
/**
* Minimal local card used only when the proxy wrapper didn't ship one.
*/
private function fallback_card(): string {
return ''
. '
'
. '{type_label}'
. '{item_counter}'
. '
'
. '
'
. '
{title}
'
. '
{content}
'
. '
'
. '
'
. '
'
. '
Hi {admin_name},
'
. '{news_content}'
. '