-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #26 from omnisend/contact-sync
Contact sync
- Loading branch information
Showing
8 changed files
with
194 additions
and
10 deletions.
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,126 @@ | ||
| <?php | ||
| /** | ||
| * Omnisend Contact Utils | ||
| * | ||
| * @package OmnisendClient | ||
| */ | ||
|
|
||
| namespace Omnisend\Internal; | ||
|
|
||
| use Omnisend\SDK\V1\Contact; | ||
| use Omnisend\SDK\V1\Omnisend; | ||
|
|
||
| ! defined( 'ABSPATH' ) && die( 'no direct access' ); | ||
|
|
||
| class Sync { | ||
|
|
||
| /** | ||
| * Listens for 'user_register' hook https://developer.wordpress.org/reference/hooks/user_register/ | ||
| * | ||
| * @param $user_id | ||
| * @return void | ||
| */ | ||
| public static function hook_user_register( $user_id ): void { | ||
| if ( \Omnisend_Core_Bootstrap::is_omnisend_woocommerce_plugin_connected() ) { | ||
| return; // do not sync if omni woo plugin is active. | ||
| } | ||
|
|
||
| $user = get_userdata( $user_id ); | ||
| if ( $user ) { | ||
| self::sync_contact( $user ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Listens for 'profile_update' hook https://developer.wordpress.org/reference/hooks/profile_update/ | ||
| * | ||
| * @param $user_id | ||
| * @return void | ||
| */ | ||
| public static function hook_profile_update( $user_id ): void { | ||
| if ( \Omnisend_Core_Bootstrap::is_omnisend_woocommerce_plugin_connected() ) { | ||
| return; // do not sync if omni woo plugin is active. | ||
| } | ||
|
|
||
| $user = get_userdata( $user_id ); | ||
| if ( $user ) { | ||
| self::sync_contact( $user ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @param int $limit number of users to sync | ||
| */ | ||
| public static function sync_contacts( int $limit = 100 ): void { | ||
| $wp_user_query = new \WP_User_Query( | ||
| array( | ||
| 'number' => $limit, | ||
| 'meta_query' => array( // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_query | ||
| 'relation' => 'OR', | ||
| array( | ||
| 'key' => UserMetaData::LAST_SYNC, | ||
| 'compare' => 'NOT EXISTS', | ||
| 'value' => '', | ||
| ), | ||
| ), | ||
| ) | ||
| ); | ||
| $users = $wp_user_query->get_results(); | ||
|
|
||
| if ( empty( $users ) ) { | ||
| wp_clear_scheduled_hook( OMNISEND_CORE_CRON_SYNC_CONTACT ); | ||
| return; | ||
| } | ||
|
|
||
| foreach ( $users as $user ) { | ||
| self::sync_contact( $user ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @param \WP_User $user | ||
| * @return void | ||
| */ | ||
| private static function sync_contact( $user ): void { | ||
| $contact = new Contact(); | ||
| $contact->add_tag( 'WordPress' ); | ||
|
|
||
| if ( ! filter_var( $user->user_email, FILTER_VALIDATE_EMAIL ) ) { | ||
| UserMetaData::mark_sync_skipped( $user->ID ); | ||
| return; | ||
| } | ||
|
|
||
| $contact->set_email( $user->user_email ); | ||
|
|
||
| $first_name = get_user_meta( $user->ID, 'first_name', true ); | ||
| if ( $first_name ) { | ||
| $contact->set_first_name( $first_name ); | ||
| } | ||
|
|
||
| $last_name = get_user_meta( $user->ID, 'last_name', true ); | ||
| if ( $last_name ) { | ||
| $contact->set_last_name( $last_name ); | ||
| } | ||
|
|
||
| $roles = get_user_meta( $user->ID, 'wp_capabilities', true ); | ||
| $parsed_roles = array(); | ||
| if ( is_array( $roles ) ) { | ||
| foreach ( $roles as $role => $active ) { | ||
| if ( $active ) { | ||
| $parsed_roles[] = $role; | ||
| } | ||
| } | ||
|
|
||
| if ( ! empty( $parsed_roles ) ) { | ||
| $contact->add_custom_property( 'wordpress_roles', array_unique( $parsed_roles ) ); | ||
| } | ||
| } | ||
|
|
||
| $response = Omnisend::get_client( OMNISEND_CORE_PLUGIN_NAME, OMNISEND_CORE_PLUGIN_VERSION )->create_contact( $contact ); | ||
| if ( $response->get_contact_id() ) { | ||
| UserMetaData::mark_synced( $user->ID ); | ||
| } else { | ||
| UserMetaData::mark_sync_error( $user->ID ); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,26 @@ | ||
| <?php | ||
| /** | ||
| * Omnisend plugin | ||
| * | ||
| * @package OmnisendPlugin | ||
| */ | ||
|
|
||
| namespace Omnisend\Internal; | ||
|
|
||
| defined( 'ABSPATH' ) || die( 'no direct access' ); | ||
|
|
||
| class UserMetaData { | ||
| public const LAST_SYNC = 'omni_send_core_last_sync'; | ||
|
|
||
| public static function mark_synced( $user_id ) { | ||
| update_user_meta( $user_id, self::LAST_SYNC, gmdate( DATE_ATOM, time() ) ); | ||
| } | ||
|
|
||
| public static function mark_sync_error( $user_id ) { | ||
| update_user_meta( $user_id, self::LAST_SYNC, 'ERROR' ); | ||
| } | ||
|
|
||
| public static function mark_sync_skipped( $user_id ) { | ||
| update_user_meta( $user_id, self::LAST_SYNC, 'SKIPPED' ); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters