<?php
/**
 * Rest API
 *
 * @package     AutomatorWP\Webhooks\Rest_API
 * @author      AutomatorWP <contact@automatorwp.com>, Ruben Garcia <rubengcdev@gmail.com>
 * @since       1.0.0
 */
// Exit if accessed directly
if( !defined( 'ABSPATH' ) ) exit;

/**
 * Register receive data from activecampaign endpoints on the WordPress Rest API
 *
 * @since 1.0.0
 */
function automatorwp_activecampaign_rest_api_init() {

    register_rest_route( 'activecampaign/webhooks', automatorwp_activecampaign_get_webhook_slug(), array(
        'methods' => 'POST',
        'callback' => 'automatorwp_activecampaign_rest_api_cb',
        'permission_callback' => '__return_true',
    ) );

}
add_action( 'rest_api_init', 'automatorwp_activecampaign_rest_api_init');

/**
 * Callback used to handle activecampaign received requests
 *
 * @since 1.0.0
 *
 * @param WP_REST_Request $data
 *
 * @return WP_REST_Response
 */
function automatorwp_activecampaign_rest_api_cb( $data ) {

    // Request response received from ActiveCampaign
    $params = $data->get_params();

    if ( ! isset( $params ) ) {
        return new WP_REST_Response( array( 'success' => false, 'message' => __( 'No parameters received', 'automatorwp' ) ), 400 );
    }

    // Sanitize params array
    $params = map_deep( $params, 'sanitize_text_field' );

    // Sanitize specific fields
    if ( isset( $params['contact'] ) && is_array( $params['contact'] ) ) {
    
        $params['contact']['id'] = absint( $params['contact']['id'] );
        $params['contact']['email'] = sanitize_email( $params['contact']['email'] );
        
        if ( isset( $params['contact']['fields'] ) && is_array( $params['contact']['fields'] ) ) {
            $params['contact']['fields'] = map_deep( $params['contact']['fields'], 'sanitize_text_field' );
        }
    }

    $type = $params['type'];
    $email = $params['contact']['email'];
    $user = get_user_by( 'email', $email );
    
    // Actions when a user/contact is subscribed
    if ( $type === 'subscribe' ) {
        do_action( 'automatorwp_activecampaign_contact_subscribed', $params, ( $user ? $user->ID : 0 ) );
    }

    // Actions when a tag is added to user/contact
    if ( $type === 'contact_tag_added') {
        do_action( 'automatorwp_activecampaign_contact_tag_added', $params, ( $user ? $user->ID : 0 ) );
    }

    return new WP_REST_Response( array( 'success' => true ), 200 );

}