grim/purple-spasm

Lot's of updates, login cleanup, some other stuff...

2017-05-11, Gary Kramlich
2c1f2ed65b14
Lot's of updates, login cleanup, some other stuff...
/*
* PurpleSpasm - A Twitch Protocol Plugin
* Copyright (C) 2017 Gary Kramlich <grim@reaperworld.com>
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/
#include <libsoup/soup.h>
#include "spasm-const.h"
#include "spasm-rest.h"
/******************************************************************************
* Types
*****************************************************************************/
typedef struct {
PurpleSpasmAccount *sa;
PurpleSpasmRestCallback cb;
gpointer data;
} PurpleSpasmRestCallbackData;
/******************************************************************************
* Callbacks
*****************************************************************************/
static void
_purple_spasm_request_cb(GObject *obj, GAsyncResult *res,
gpointer data)
{
GInputStream *istream = NULL;
GError *error = NULL;
JsonParser *parser = NULL;
PurpleSpasmRestCallbackData *cb_data = (PurpleSpasmRestCallbackData *)data;
istream = soup_session_send_finish(SOUP_SESSION(obj), res, &error);
if(error) {
cb_data->cb(cb_data->sa, NULL, error, cb_data->data);
g_free(cb_data);
return;
}
parser = json_parser_new();
json_parser_load_from_stream(parser, istream, NULL, &error);
if(error) {
cb_data->cb(cb_data->sa, NULL, error, cb_data->data);
g_free(cb_data);
return;
}
cb_data->cb(cb_data->sa, parser, NULL, cb_data->data);
}
/******************************************************************************
* API
*****************************************************************************/
void
purple_spasm_rest_request(PurpleSpasmAccount *sa, const gchar *method,
const gchar *path, const gchar *body,
PurpleSpasmRestCallback callback, gpointer data)
{
PurpleSpasmRestCallbackData *cb;
SoupMessage *msg = NULL;
SoupSession *session = NULL;
gchar *url = NULL, *auth = NULL;
g_return_if_fail(sa);
url = g_build_filename(PURPLE_SPASM_BASE_URL, path, NULL);
msg = soup_message_new(method, url);
g_free(url);
// Set the Client-ID header
soup_message_headers_replace(
msg->request_headers,
"Client-ID",
PURPLE_SPASM_OAUTH2_CLIENT_ID
);
// Set the Accept header
soup_message_headers_replace(
msg->request_headers,
"Accept",
PURPLE_SPASM_CONTENT_TYPE
);
// Set the authorization header to the access token
auth = g_strdup_printf("OAuth %s", purple_spasm_account_get_access_token(sa));
soup_message_headers_replace(
msg->request_headers,
"Authorization", auth
);
g_free(auth);
cb = g_new0(PurpleSpasmRestCallbackData, 1);
cb->sa = sa;
cb->cb = callback;
cb->data = data;
session = purple_spasm_account_get_session(sa);
soup_session_send_async(
session,
msg,
NULL,
_purple_spasm_request_cb,
cb
);
g_object_unref(G_OBJECT(session));
}