#include <termios.h>
#include <dlfcn.h>
#include <oauth.h>
-
+#include "bti.h"
#define zalloc(size) calloc(size, 1)
static int debug;
-static int verbose;
-
-enum host {
- HOST_TWITTER = 0,
- HOST_IDENTICA = 1,
- HOST_CUSTOM = 2
-};
-
-enum action {
- ACTION_UPDATE = 0,
- ACTION_FRIENDS = 1,
- ACTION_USER = 2,
- ACTION_REPLIES = 4,
- ACTION_PUBLIC = 8,
- ACTION_GROUP = 16,
- ACTION_UNKNOWN = 32
-};
-
-struct session {
- char *password;
- char *account;
- char *consumer_key;
- char *consumer_secret;
- char *access_token_key;
- char *access_token_secret;
- char *tweet;
- char *proxy;
- char *time;
- char *homedir;
- char *logfile;
- char *user;
- char *group;
- char *hosturl;
- char *hostname;
- char *configfile;
- char *replyto;
- int bash;
- int background;
- int interactive;
- int shrink_urls;
- int dry_run;
- int page;
- int no_oauth;
- enum host host;
- enum action action;
- void *readline_handle;
- char *(*readline)(const char *);
-};
-
-struct bti_curl_buffer {
- char *data;
- enum action action;
- int length;
-};
static void display_help(void)
{
" --logfile logfile\n"
" --config configfile\n"
" --replyto ID\n"
+ " --retweet ID\n"
" --shrink-urls\n"
" --page PAGENUMBER\n"
" --bash\n"
{
if (!session)
return;
+ free(session->retweet);
free(session->replyto);
free(session->password);
free(session->account);
static const char friends_uri[] = "/friends_timeline.xml";
static const char mentions_uri[] = "/mentions.xml";
static const char replies_uri[] = "/replies.xml";
+static const char retweet_uri[] = "/retweet/";
static const char group_uri[] = "/../statusnet/groups/timeline/";
static CURL *curl_init(void)
return curl;
}
-static void parse_statuses(xmlDocPtr doc, xmlNodePtr current)
+static void parse_statuses(struct session *session,
+ xmlDocPtr doc, xmlNodePtr current)
{
xmlChar *text = NULL;
xmlChar *user = NULL;
}
if (user && text && created && id) {
- if (verbose)
+ if (session->verbose)
printf("[%s] {%s} (%.16s) %s\n",
user, id, created, text);
else
return;
}
-static void parse_timeline(char *document)
+static void parse_timeline(char *document, struct session *session)
{
xmlDocPtr doc;
xmlNodePtr current;
current = current->xmlChildrenNode;
while (current != NULL) {
if ((!xmlStrcmp(current->name, (const xmlChar *)"status")))
- parse_statuses(doc, current);
+ parse_statuses(session, doc, current);
current = current->next;
}
xmlFreeDoc(doc);
memcpy(&curl_buf->data[curl_buf->length], (char *)buffer, buffer_size);
curl_buf->length += buffer_size;
if (curl_buf->action)
- parse_timeline(curl_buf->data);
+ parse_timeline(curl_buf->data, curl_buf->session);
dbg("%s\n", curl_buf->data);
if (!session->hosturl)
session->hosturl = strdup(twitter_host);
- if (session->no_oauth) {
+ if (session->no_oauth || session->guest) {
curl_buf = bti_curl_buffer_alloc(session->action);
if (!curl_buf)
return -ENOMEM;
+ curl_buf->session = session;
curl = curl_init();
if (!curl)
switch (session->action) {
case ACTION_UPDATE:
escaped_tweet = oauth_url_escape(session->tweet);
- sprintf(endpoint, "%s%s?status=%s", session->hosturl,
- update_uri, escaped_tweet);
+ if (session->replyto) {
+ sprintf(endpoint,
+ "%s%s?status=%s&in_reply_to_status_id=%s",
+ session->hosturl, update_uri,
+ escaped_tweet, session->replyto);
+ } else {
+ sprintf(endpoint, "%s%s?status=%s",
+ session->hosturl, update_uri,
+ escaped_tweet);
+ }
+
is_post = 1;
break;
case ACTION_USER:
sprintf(endpoint, "%s%s?page=%d", session->hosturl,
friends_uri, session->page);
break;
+ case ACTION_RETWEET:
+ sprintf(endpoint, "%s%s%s.xml", session->hosturl,
+ retweet_uri, session->retweet);
+ is_post = 1;
+ break;
default:
break;
}
- if (is_post) {
- req_url = oauth_sign_url2(endpoint, &postarg, OA_HMAC,
- NULL, session->consumer_key,
- session->consumer_secret,
- session->access_token_key,
- session->access_token_secret);
- reply = oauth_http_post(req_url, postarg);
- } else {
- req_url = oauth_sign_url2(endpoint, NULL, OA_HMAC, NULL,
- session->consumer_key,
- session->consumer_secret,
- session->access_token_key,
- session->access_token_secret);
- reply = oauth_http_get(req_url, postarg);
- }
+ dbg("%s\n", endpoint);
+ if (!session->dry_run) {
+ if (is_post) {
+ req_url = oauth_sign_url2(endpoint, &postarg, OA_HMAC,
+ NULL, session->consumer_key,
+ session->consumer_secret,
+ session->access_token_key,
+ session->access_token_secret);
+ reply = oauth_http_post(req_url, postarg);
+ } else {
+ req_url = oauth_sign_url2(endpoint, NULL, OA_HMAC, NULL,
+ session->consumer_key,
+ session->consumer_secret,
+ session->access_token_key,
+ session->access_token_secret);
+ reply = oauth_http_get(req_url, postarg);
+ }
- dbg("%s\n", req_url);
- dbg("%s\n", reply);
- if (req_url)
- free(req_url);
+ dbg("%s\n", req_url);
+ dbg("%s\n", reply);
+ if (req_url)
+ free(req_url);
+ }
- if (session->action != ACTION_UPDATE)
- parse_timeline(reply);
+ if ((session->action != ACTION_UPDATE) &&
+ (session->action != ACTION_RETWEET))
+ parse_timeline(reply, session);
}
return 0;
}
char *action = NULL;
char *user = NULL;
char *replyto = NULL;
+ char *retweet = NULL;
int shrink_urls = 0;
config_file = fopen(session->configfile, "r");
c += 8;
if (!strncasecmp(c, "true", 4) ||
!strncasecmp(c, "yes", 3))
- verbose = 1;
+ session->verbose = 1;
+ } else if (!strncasecmp(c,"retweet", 7) &&
+ (c[7] == '=')) {
+ c += 8;
+ if (c[0] != '\0')
+ retweet = strdup(c);
}
} while (!feof(config_file));
session->logfile = logfile;
if (replyto)
session->replyto = replyto;
+ if (retweet)
+ session->retweet = retweet;
if (action) {
if (strcasecmp(action, "update") == 0)
session->action = ACTION_UPDATE;
{ "version", 0, NULL, 'v' },
{ "config", 1, NULL, 'c' },
{ "replyto", 1, NULL, 'r' },
+ { "retweet", 1, NULL, 'w' },
{ }
};
struct session *session;
pid_t child;
char *tweet;
+ char *retweet;
static char password[80];
int retval = 0;
int option;
int page_nr;
debug = 0;
- verbose = 0;
session = session_alloc();
if (!session) {
debug = 1;
break;
case 'V':
- verbose = 1;
+ session->verbose = 1;
break;
case 'a':
if (session->account)
session->replyto = strdup(optarg);
dbg("in_reply_to_status_id = %s\n", session->replyto);
break;
+ case 'w':
+ session->retweet = strdup(optarg);
+ dbg("Retweet ID = %s\n", session->retweet);
+ break;
case 'p':
if (session->password)
free(session->password);
session->action = ACTION_PUBLIC;
else if (strcasecmp(optarg, "group") == 0)
session->action = ACTION_GROUP;
+ else if (strcasecmp(optarg,"retweet") == 0)
+ session->action = ACTION_RETWEET;
else
session->action = ACTION_UNKNOWN;
dbg("action = %d\n", session->action);
if (session->host == HOST_TWITTER) {
if (!session->consumer_key || !session->consumer_secret) {
- fprintf(stderr,
- "Twitter no longer supports HTTP basic authentication.\n"
- "Both consumer key, and consumer secret are required"
- " for bti in order to behave as an OAuth consumer.\n");
- goto exit;
+ if (session->action == ACTION_USER ||
+ session->action == ACTION_PUBLIC) {
+ /* Some actions may still work without authentication */
+ session->guest = 1;
+ } else {
+ fprintf(stderr,
+ "Twitter no longer supports HTTP basic authentication.\n"
+ "Both consumer key, and consumer secret are required"
+ " for bti in order to behave as an OAuth consumer.\n");
+ goto exit;
+ }
}
if (session->action == ACTION_GROUP) {
fprintf(stderr, "Groups only work in Identi.ca.\n");
session->hostname);
session->password = strdup(password);
}
- } else {
+ } else if (!session->guest) {
if (!session->access_token_key ||
!session->access_token_secret) {
request_access_token(session);
session->group = session->readline(NULL);
}
+ if (session->action == ACTION_RETWEET) {
+ fprintf(stdout, "Status ID to retweet: ");
+ retweet = get_string_from_stdin();
+
+ if (!retweet || strlen(retweet) == 0) {
+ dbg("no retweet?\n");
+ return -1;
+ }
+
+ session->retweet = zalloc(strlen(retweet) + 10);
+ sprintf(session->retweet,"%s", retweet);
+ free(retweet);
+ dbg("retweet ID = %s\n", session->retweet);
+ }
+
if (session->action == ACTION_UPDATE) {
if (session->background || !session->interactive)
tweet = get_string_from_stdin();
ToastFreeware / gregoa / bti.git / blobdiff