manage-subscriber

#!/usr/bin/env php
<?php
require 'vendor/autoload.php';
use GuzzleHttp\Client;

const BASE_URL = 'https://api.aweber.com/1.0/';

// Create a Guzzle client
$client = new GuzzleHttp\Client();

// Load credentials
$credentials = parse_ini_file('credentials.ini');
$accessToken = $credentials['accessToken'];

/**
 * Get all of the entries for a collection
 *
 * @param Client $client HTTP Client used to make a GET request
 * @param string $accessToken Access token to pass in as an authorization header
 * @param string $url Full url to make the request
 * @return array Every entry in the collection
 */
function getCollection($client, $accessToken, $url) {
    $collection = array();
    while (isset($url)) {
        $request = $client->get($url,
            ['headers' => ['Authorization' => 'Bearer ' . $accessToken]]
        );
        $body = $request->getBody();
        $page = json_decode($body, true);
        $collection = array_merge($page['entries'], $collection);
        $url = isset($page['next_collection_link']) ? $page['next_collection_link'] : null;
    }
    return $collection;
}

// get all the accounts entries
$accounts = getCollection($client, $accessToken, BASE_URL . 'accounts');
$accountUrl = $accounts[0]['self_link'];

// get all the list entries for the first account
$listsUrl = $accounts[0]['lists_collection_link'];
$lists = getCollection($client, $accessToken, $listsUrl);

// find out if a subscriber exists on the first list
$email = 'example@example.com';
$params = array(
    'ws.op' => 'find',
    'email' => $email
);
$subsUrl = $lists[0]['subscribers_collection_link'];
$findUrl = $subsUrl . '?' . http_build_query($params);
$foundSubscribers = getCollection($client, $accessToken, $findUrl);
echo 'Found subscribers: ';
print_r($foundSubscribers);

if (isset($foundSubscribers[0]['self_link'])) {
    // update the subscriber if they are on the first list
    $data = array(
        'custom_fields' => array('awesomeness' => 'really awesome'),
        'tags' => array('add' => array('prospect'))
    );
    $subscriberUrl = $foundSubscribers[0]['self_link'];
    $subscriberResponse = $client->patch($subscriberUrl, [
            'json' => $data, 
            'headers' => ['Authorization' => 'Bearer ' . $accessToken]
        ])->getBody();
    $subscriber = json_decode($subscriberResponse, true);
    echo 'Updated Subscriber: ';
} else {
    // add the subscriber if they are not already on the first list
    $data = array(
        'email' => $email,
        'custom_fields' => array('awesomeness' => 'somewhat'),
        'tags' => array('prospect')
    );
    $body = $client->post($subsUrl, [
            'json' => $data, 
            'headers' => ['Authorization' => 'Bearer ' . $accessToken]
        ]);

    // get the subscriber entry using the Location header from the post request
    $subscriberUrl = $body->getHeader('Location')[0];
    $subscriberResponse = $client->get($subscriberUrl,
        ['headers' => ['Authorization' => 'Bearer ' . $accessToken]])->getBody();
    $subscriber = json_decode($subscriberResponse, true);
    echo 'Created Subscriber: ';
}
print_r($subscriber);

// get the activity for the subscriber
$params = array('ws.op' => 'getActivity');
$activityUrl = $subscriberUrl . '?' . http_build_query($params);
$activity = $client->get($activityUrl,
    ['headers' => ['Authorization' => 'Bearer ' . $accessToken]])->getBody();
echo 'Subscriber Activity: ';
print_r(json_decode($activity, true));

// delete the subscriber; this can only be performed on confirmed subscribers
// or a 405 Method Not Allowed will be returned
if ($subscriber['status'] == 'subscribed') {
    $client->delete($subscriberUrl, 
        ['headers' => ['Authorization' => 'Bearer ' . $accessToken]])->getBody();
    echo 'Deleted subscriber with email: ' . $email;
}