From 39d22ea2818375546a21546dfbac05e899bc691d Mon Sep 17 00:00:00 2001 From: Michael Vogel Date: Sat, 3 May 2014 11:56:57 +0200 Subject: [PATCH] New Addon "buffer": With this you can post to Google+-Pages, App.net or LinkedIn via bufferapp.com --- buffer/README.md | 5 + buffer/buffer.css | 15 ++ buffer/buffer.php | 375 +++++++++++++++++++++++++++++++++++++ buffer/bufferapp.php | 205 ++++++++++++++++++++ buffer/templates/admin.tpl | 3 + 5 files changed, 603 insertions(+) create mode 100644 buffer/README.md create mode 100755 buffer/buffer.css create mode 100644 buffer/buffer.php create mode 100644 buffer/bufferapp.php create mode 100644 buffer/templates/admin.tpl diff --git a/buffer/README.md b/buffer/README.md new file mode 100644 index 000000000..d46ade85e --- /dev/null +++ b/buffer/README.md @@ -0,0 +1,5 @@ +The addon uses the library from [https://github.com/thewebguy/bufferapp-php](https://github.com/thewebguy/bufferapp-php) + +Please register an app at [http://bufferapp.com/developers/api](http://bufferapp.com/developers/api) + +Please use (your server address)/buffer/connect as Callback URL. diff --git a/buffer/buffer.css b/buffer/buffer.css new file mode 100755 index 000000000..67a285654 --- /dev/null +++ b/buffer/buffer.css @@ -0,0 +1,15 @@ +#buffer-enable-label, #buffer-bydefault-label, #buffer-delete-label { + float: left; + width: 200px; + margin-top: 10px; +} + +#buffer-checkbox, #buffer-bydefault, #buffer-delete { + float: left; + margin-top: 10px; +} + +#buffer-submit { + margin-top: 15px; +} + diff --git a/buffer/buffer.php b/buffer/buffer.php new file mode 100644 index 000000000..76156e16f --- /dev/null +++ b/buffer/buffer.php @@ -0,0 +1,375 @@ + + */ +require('addon/buffer/bufferapp.php'); + +function buffer_install() { + register_hook('post_local', 'addon/buffer/buffer.php', 'buffer_post_local'); + register_hook('notifier_normal', 'addon/buffer/buffer.php', 'buffer_send'); + register_hook('jot_networks', 'addon/buffer/buffer.php', 'buffer_jot_nets'); + register_hook('connector_settings', 'addon/buffer/buffer.php', 'buffer_settings'); + register_hook('connector_settings_post', 'addon/buffer/buffer.php', 'buffer_settings_post'); +} + +function buffer_uninstall() { + unregister_hook('post_local', 'addon/buffer/buffer.php', 'buffer_post_local'); + unregister_hook('notifier_normal', 'addon/buffer/buffer.php', 'buffer_send'); + unregister_hook('jot_networks', 'addon/buffer/buffer.php', 'buffer_jot_nets'); + unregister_hook('connector_settings', 'addon/buffer/buffer.php', 'buffer_settings'); + unregister_hook('connector_settings_post', 'addon/buffer/buffer.php', 'buffer_settings_post'); +} + +function buffer_module() {} + +function buffer_content(&$a) { + + if(! local_user()) { + notice( t('Permission denied.') . EOL); + return ''; + } + + require_once("mod/settings.php"); + settings_init($a); + + if (isset($a->argv[1])) + switch ($a->argv[1]) { + case "connect": + $o = buffer_connect($a); + break; + default: + $o = print_r($a->argv, true); + break; + } + else + $o = buffer_connect($a); + + return $o; +} + +function buffer_plugin_admin(&$a, &$o){ + $t = get_markup_template( "admin.tpl", "addon/buffer/" ); + + $o = replace_macros($t, array( + '$submit' => t('Save Settings'), + // name, label, value, help, [extra values] + '$client_id' => array('client_id', t('Client ID'), get_config('buffer', 'client_id' ), ''), + '$client_secret' => array('client_secret', t('Client Secret'), get_config('buffer', 'client_secret' ), ''), + )); +} + +function buffer_connect(&$a) { + + if (isset($_REQUEST["error"])) { + $o = t('Error when registering buffer connection:')." ".$_REQUEST["error"]; + return $o; + } + // Start a session. This is necessary to hold on to a few keys the callback script will also need + session_start(); + + // Define the needed keys + $client_id = get_config('buffer','client_id'); + $client_secret = get_config('buffer','client_secret'); + + // The callback URL is the script that gets called after the user authenticates with buffer + $callback_url = $a->get_baseurl()."/buffer/connect"; + + $buffer = new BufferApp($client_id, $client_secret, $callback_url); + + if (!$buffer->ok) { + $o .= 'Connect to Buffer!'; + } else { + logger("buffer_connect: authenticated"); + $o .= t("You are now authenticated to buffer. "); + $o .= '
'.t("return to the connector page").''; + set_pconfig(local_user(), 'buffer','access_token', $buffer->access_token); + } + + return($o); +} + +function buffer_jot_nets(&$a,&$b) { + if(! local_user()) + return; + + $buffer_post = get_pconfig(local_user(),'buffer','post'); + if(intval($buffer_post) == 1) { + $buffer_defpost = get_pconfig(local_user(),'buffer','post_by_default'); + $selected = ((intval($buffer_defpost) == 1) ? ' checked="checked" ' : ''); + $b .= '
' + . t('Post to Buffer') . '
'; + } +} + +function buffer_settings(&$a,&$s) { + + if(! local_user()) + return; + + /* Add our stylesheet to the page so we can make our settings look nice */ + + $a->page['htmlhead'] .= '' . "\r\n"; + + /* Get the current state of our config variables */ + + $enabled = get_pconfig(local_user(),'buffer','post'); + $checked = (($enabled) ? ' checked="checked" ' : ''); + $css = (($enabled) ? '' : '-disabled'); + + $def_enabled = get_pconfig(local_user(),'buffer','post_by_default'); + $def_checked = (($def_enabled) ? ' checked="checked" ' : ''); + + /* Add some HTML to the existing form */ + + $s .= ''; + $s .= '

'. t('Buffer Export').'

'; + $s .= ''; + $s .= ''; + +} + + +function buffer_settings_post(&$a,&$b) { + + if(x($_POST,'buffer-submit')) { + if(x($_POST,'buffer_delete')) { + set_pconfig(local_user(),'buffer','access_token',''); + set_pconfig(local_user(),'buffer','post',false); + set_pconfig(local_user(),'buffer','post_by_default',false); + } else { + // filtering the username if it is filled wrong + $user = $_POST['buffer_user']; + if (strstr($user, "@")) { + $pos = strpos($user, "@"); + if ($pos > 0) + $user = substr($user, 0, $pos); + } + + // Filtering the hostname if someone is entering it with "http" + $host = $_POST['buffer_host']; + $host = trim($host); + $host = str_replace(array("https://", "http://"), array("", ""), $host); + + set_pconfig(local_user(),'buffer','post',intval($_POST['buffer'])); + set_pconfig(local_user(),'buffer','post_by_default',intval($_POST['buffer_bydefault'])); + + //header("Location: ".$a->get_baseurl()."/buffer/connect"); + } + } +} + +function buffer_post_local(&$a,&$b) { + + if((! local_user()) || (local_user() != $b['uid'])) + return; + + $buffer_post = intval(get_pconfig(local_user(),'buffer','post')); + + $buffer_enable = (($buffer_post && x($_REQUEST,'buffer_enable')) ? intval($_REQUEST['buffer_enable']) : 0); + + if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'buffer','post_by_default'))) + $buffer_enable = 1; + + if(! $buffer_enable) + return; + + if(strlen($b['postopts'])) + $b['postopts'] .= ','; + + $b['postopts'] .= 'buffer'; +} + +function buffer_send(&$a,&$b) { + + if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) + return; + + logger("buffer_send: parameter ".print_r($b, true), LOGGER_DATA); + + if(! strstr($b['postopts'],'buffer')) + return; + + if($b['parent'] != $b['id']) + return; + + // if post comes from buffer don't send it back + if($b['app'] == "Buffer") + return; + + $client_id = get_config("buffer", "client_id"); + $client_secret = get_config("buffer", "client_secret"); + $access_token = get_pconfig($b['uid'], "buffer","access_token"); + + if($access_token) { + $buffer = new BufferApp($client_id, $client_secret, $callback_url, $access_token); + + $result = q("SELECT `installed` FROM `addon` WHERE `name` = 'privacy_image_cache' AND `installed`"); + $image_cache = (count($result) > 0); + + require_once("include/plaintext.php"); + require_once("include/network.php"); + + $profiles = $buffer->go('/profiles'); + if (is_array($profiles)) { + foreach ($profiles as $profile) { + if (!$profile->default) + continue; + + switch ($profile->service) { + case 'appdotnet': + $limit = 256; + $markup = false; + $includedlinks = true; + break; + case 'facebook': + $limit = 0; + $markup = false; + $includedlinks = false; + break; + case 'google': + $limit = 0; + $markup = true; + $includedlinks = false; + break; + case 'twitter': + $limit = 140; + $markup = false; + $includedlinks = true; + break; + case 'linkedin': + $limit = 700; + $markup = false; + $includedlinks = true; + break; + } + + $item = $b; + + // Markup for Google+ + if ($markup) { + if ($item["title"] != "") + $item["title"] = "*".$item["title"]."*"; + + $item["body"] = preg_replace("(\[b\](.*?)\[\/b\])ism",'*$1*',$item["body"]); + $item["body"] = preg_replace("(\[i\](.*?)\[\/i\])ism",'_$1_',$item["body"]); + $item["body"] = preg_replace("(\[s\](.*?)\[\/s\])ism",'-$1-',$item["body"]); + } + + $post = plaintext($a, $item, $limit, $includedlinks); + logger("buffer_send: converted message ".$b["id"]." result: ".print_r($post, true), LOGGER_DEBUG); + + // The image cache is used as a sanitizer. Buffer seems to be really picky about pictures + if ($image_cache) { + require_once("addon/privacy_image_cache/privacy_image_cache.php"); + if (isset($post["image"])) + $post["image"] = $a->get_baseurl() . "/privacy_image_cache/".privacy_image_cache_cachename($post["image"]); + + if (isset($post["preview"])) + $post["preview"] = $a->get_baseurl() . "/privacy_image_cache/".privacy_image_cache_cachename($post["preview"]); + } + + //if ($includedlinks AND isset($post["url"])) + // $post["url"] = short_link($post["url"]); + + // Seems like a bug to me + // Buffer doesn't add links to Twitter and App.net (but pictures) + if ($includedlinks AND isset($post["url"])) + $post["text"] .= " ".short_link($post["url"]); + + //if ($includedlinks AND ($post["type"] == "link")) + // $post["text"] .= " ".$post["url"]; + + //if ($includedlinks AND ($post["type"] == "video")) + // $post["text"] .= " ".$post["url"]; + + //print_r($post); + + $message = array(); + $message["text"] = $post["text"]; + $message["profile_ids[]"] = $profile->id; + $message["shorten"] = false; + $message["now"] = true; + + if (isset($post["title"])) + $message["media[title]"] = $post["title"]; + + if (isset($post["description"])) + $message["media[description]"] = $post["description"]; + + if (isset($post["url"])) + $message["media[link]"] = $post["url"]; + + if (isset($post["image"])) { + $message["media[picture]"] = $post["image"]; + if ($post["type"] == "photo") + $message["media[thumbnail]"] = $post["image"]; + } + + if (isset($post["preview"])) + $message["media[thumbnail]"] = $post["preview"]; + + //print_r($message); + $ret = $buffer->go('/updates/create', $message); + logger("buffer_send: send message ".$b["id"]." result: ".print_r($ret, true), LOGGER_DEBUG); + } + } + } +} diff --git a/buffer/bufferapp.php b/buffer/bufferapp.php new file mode 100644 index 000000000..63953c075 --- /dev/null +++ b/buffer/bufferapp.php @@ -0,0 +1,205 @@ + 'get', + + '/profiles' => 'get', + '/profiles/:id' => 'get', + '/profiles/:id/schedules' => 'get', + '/profiles/:id/schedules/update' => 'post', // Array schedules [0][days][]=mon, [0][times][]=12:00 + + '/updates/:id' => 'get', + '/profiles/:id/updates/pending' => 'get', + '/profiles/:id/updates/sent' => 'get', + '/updates/:id/interactions' => 'get', + + '/profiles/:id/updates/reorder' => 'post', // Array order, int offset, bool utc + '/profiles/:id/updates/shuffle' => 'post', + '/updates/create' => 'post', // String text, Array profile_ids, Aool shorten, Bool now, Array media ['link'], ['description'], ['picture'] + '/updates/:id/update' => 'post', // String text, Bool now, Array media ['link'], ['description'], ['picture'], Bool utc + '/updates/:id/share' => 'post', + '/updates/:id/destroy' => 'post', + '/updates/:id/move_to_top' => 'post', + + '/links/shares' => 'get', + + '/info/configuration' => 'get', + + ); + + public $errors = array( + 'invalid-endpoint' => 'The endpoint you supplied does not appear to be valid.', + + '403' => 'Permission denied.', + '404' => 'Endpoint not found.', + '405' => 'Method not allowed.', + '1000' => 'An unknown error occurred.', + '1001' => 'Access token required.', + '1002' => 'Not within application scope.', + '1003' => 'Parameter not recognized.', + '1004' => 'Required parameter missing.', + '1005' => 'Unsupported response format.', + '1006' => 'Parameter value not within bounds.', + '1010' => 'Profile could not be found.', + '1011' => 'No authorization to access profile.', + '1012' => 'Profile did not save successfully.', + '1013' => 'Profile schedule limit reached.', + '1014' => 'Profile limit for user has been reached.', + '1015' => 'Profile could not be destroyed.', + '1016' => 'Profile buffer could not be emptied.', + '1020' => 'Update could not be found.', + '1021' => 'No authorization to access update.', + '1022' => 'Update did not save successfully.', + '1023' => 'Update limit for profile has been reached.', + '1024' => 'Update limit for team profile has been reached.', + '1025' => "Update was recently posted, can't post duplicate content.", + '1026' => 'Update must be in error status to requeue.', + '1027' => 'Update must be in buffer and not custom scheduled in order to move to top.', + '1028' => 'Update soft limit for profile reached.', + '1029' => 'Event type not supported.', + '1030' => 'Media filetype not supported.', + '1031' => 'Media filesize out of acceptable range.', + '1032' => 'Unable to post image to LinkedIn group(s).', + '1033' => 'Comments can only be posted to Facebook at this time.', + '1034' => 'Cannot schedule updates in the past.', + '1042' => 'User did not save successfully.', + '1050' => 'Client could not be found.', + '1051' => 'No authorization to access client.', + ); + + function __construct($client_id = '', $client_secret = '', $callback_url = '', $access_token = '') { + if ($client_id) $this->set_client_id($client_id); + if ($client_secret) $this->set_client_secret($client_secret); + if ($callback_url) $this->set_callback_url($callback_url); + if ($access_token) $this->access_token = $access_token; + + if (isset($_GET['code']) AND $_GET['code']) { + $this->code = $_GET['code']; + $this->create_access_token_url(); + } + + if (!$access_token) + $this->retrieve_access_token(); + } + + function go($endpoint = '', $data = '') { + if (in_array($endpoint, array_keys($this->endpoints))) { + $done_endpoint = $endpoint; + } else { + $ok = false; + + foreach (array_keys($this->endpoints) as $done_endpoint) { + if (preg_match('/' . preg_replace('/(\:\w+)/i', '(\w+)', str_replace('/', '\/', $done_endpoint)) . '/i', $endpoint, $match)) { + $ok = true; + break; + } + } + + if (!$ok) return $this->error('invalid-endpoint'); + } + + if (!$data || !is_array($data)) $data = array(); + $data['access_token'] = $this->access_token; + + $method = $this->endpoints[$done_endpoint]; //get() or post() + return $this->$method($this->buffer_url . $endpoint . '.json', $data); + } + + function store_access_token() { + $_SESSION['oauth']['buffer']['access_token'] = $this->access_token; + } + + function retrieve_access_token() { + $this->access_token = $_SESSION['oauth']['buffer']['access_token']; + + if ($this->access_token) { + $this->ok = true; + } + } + + function error($error) { + return (object) array('error' => $this->errors[$error]); + } + + function create_access_token_url() { + $data = array( + 'code' => $this->code, + 'grant_type' => 'authorization_code', + 'client_id' => $this->client_id, + 'client_secret' => $this->client_secret, + 'redirect_uri' => $this->callback_url, + ); + + $obj = $this->post($this->access_token_url, $data); + $this->access_token = $obj->access_token; + + $this->store_access_token(); + } + + function req($url = '', $data = '', $post = true) { + if (!$url) return false; + if (!$data || !is_array($data)) $data = array(); + + $options = array(CURLOPT_RETURNTRANSFER => true, CURLOPT_HEADER => false); + + if ($post) { + $options += array( + CURLOPT_POST => $post, + CURLOPT_POSTFIELDS => $data + ); + } else { + $url .= '?' . http_build_query($data); + } + + $ch = curl_init($url); + curl_setopt_array($ch, $options); + $rs = curl_exec($ch); + + $code = curl_getinfo($ch, CURLINFO_HTTP_CODE); + if ($code >= 400) { + return $this->error($code); + } + + return json_decode($rs); + } + + function get($url = '', $data = '') { + return $this->req($url, $data, false); + } + + function post($url = '', $data = '') { + return $this->req($url, $data, true); + } + + function get_login_url() { + return $this->authorize_url . '?' + . 'client_id=' . $this->client_id + . '&redirect_uri=' . urlencode($this->callback_url) + . '&response_type=code'; + } + + function set_client_id($client_id) { + $this->client_id = $client_id; + } + + function set_client_secret($client_secret) { + $this->client_secret = $client_secret; + } + + function set_callback_url($callback_url) { + $this->callback_url = $callback_url; + } + } +?> diff --git a/buffer/templates/admin.tpl b/buffer/templates/admin.tpl new file mode 100644 index 000000000..b4cc3651f --- /dev/null +++ b/buffer/templates/admin.tpl @@ -0,0 +1,3 @@ +{{include file="field_input.tpl" field=$client_id}} +{{include file="field_input.tpl" field=$client_secret}} +