summaryrefslogtreecommitdiffstats
path: root/binding
diff options
context:
space:
mode:
authorJosé Bollo <jose.bollo@iot.bzh>2017-10-31 10:50:24 +0100
committerJosé Bollo <jose.bollo@iot.bzh>2017-10-31 10:50:24 +0100
commit2ca7f3a4a03db3e7d7fa15504fa3d69e1c6bd217 (patch)
tree7dc6ff7e6efab4eeca79681efb672ed07061a545 /binding
parent2ffcc61a750a2bf4598662b4612283fdc9d2a4e4 (diff)
Split in two: agl-identity-service and uds-ble-id-init-service
The binding is splitted in two parts and packeged as widgets. The two parts are: - uds-ble-id-init-service This service provides a UDS (User Data Service) over BLE. It detects writes to the email of the user to initiate the authentication process. - agl-identity-service This service queries the Forgerock's Edge Controller to fill user data and make it available. The actual code is not fully functionnal. Signed-off-by: José Bollo <jose.bollo@iot.bzh>
Diffstat (limited to 'binding')
-rw-r--r--binding/CMakeLists.txt53
-rw-r--r--binding/agl-identity-binding.c391
-rw-r--r--binding/aia-get.c252
-rw-r--r--binding/aia-get.h28
-rw-r--r--binding/aia-uds-bluez.c607
-rw-r--r--binding/aia-uds-bluez.h46
-rw-r--r--binding/authorization.c43
-rw-r--r--binding/authorization.h23
-rw-r--r--binding/base64.c108
-rw-r--r--binding/base64.h51
-rw-r--r--binding/config.json22
-rw-r--r--binding/curl-wrap.c211
-rw-r--r--binding/curl-wrap.h45
-rw-r--r--binding/escape.c428
-rw-r--r--binding/escape.h23
-rw-r--r--binding/export.map1
-rw-r--r--binding/memo.txt11
-rw-r--r--binding/oidc-agent.c812
-rw-r--r--binding/oidc-agent.h119
-rw-r--r--binding/test-aia-uds-bluez.c65
20 files changed, 0 insertions, 3339 deletions
diff --git a/binding/CMakeLists.txt b/binding/CMakeLists.txt
deleted file mode 100644
index b244009..0000000
--- a/binding/CMakeLists.txt
+++ /dev/null
@@ -1,53 +0,0 @@
-###########################################################################
-# Copyright 2016 IoT.bzh
-#
-# author: José Bollo <jose.bollo@iot.bzh>
-# author: Stéphane Desneux <stephane.desneux@iot.bzh>
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###########################################################################
-
-cmake_minimum_required(VERSION 3.3)
-
-###########################################################################
-
-include(FindPkgConfig)
-
-pkg_check_modules(EXTRAS REQUIRED json-c afb-daemon libcurl systemd)
-add_compile_options(${EXTRAS_CFLAGS} -DFOR_AFB_BINDING)
-include_directories(${EXTRAS_INCLUDE_DIRS})
-link_libraries(${EXTRAS_LIBRARIES})
-
-add_library(${PROJECT_NAME} MODULE
- agl-identity-binding.c
- aia-get.c
- aia-uds-bluez.c
- authorization.c
- base64.c
- curl-wrap.c
- escape.c
- oidc-agent.c
-)
-set_target_properties(${PROJECT_NAME} PROPERTIES
- PREFIX ""
- LINK_FLAGS "-Wl,--version-script=${CMAKE_CURRENT_SOURCE_DIR}/export.map"
-)
-
-install(TARGETS ${PROJECT_NAME} DESTINATION ${PROJECT_DESTINATION})
-
-INSTALL(FILES
- ${CMAKE_CURRENT_SOURCE_DIR}/config.json
- DESTINATION
- ${PROJECT_DESTINATION}
- )
-
diff --git a/binding/agl-identity-binding.c b/binding/agl-identity-binding.c
deleted file mode 100644
index 3e3f5b4..0000000
--- a/binding/agl-identity-binding.c
+++ /dev/null
@@ -1,391 +0,0 @@
-/*
- * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <errno.h>
-#include <stdint.h>
-#include <unistd.h>
-#include <stdlib.h>
-#include <string.h>
-#include <fcntl.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-
-#include <json-c/json.h>
-#include <systemd/sd-bus.h>
-
-#define AFB_BINDING_VERSION 2
-#include <afb/afb-binding.h>
-
-#include "oidc-agent.h"
-#include "aia-get.h"
-#include "aia-uds-bluez.h"
-
-#if !defined(AUTO_START_ADVISE)
-#define AUTO_START_ADVISE 1
-#endif
-
-static int expiration_delay = 5;
-
-static int advising;
-
-static struct afb_event event;
-
-static struct json_object *current_identity;
-
-static const char default_endpoint[] = "https://agl-graphapi.forgerocklabs.org/getuserprofilefromtoken";
-static const char default_vin[] = "4T1BF1FK5GU260429";
-static const char *oidc_name;
-static char *vin;
-static char *endpoint;
-static int autoadvise = AUTO_START_ADVISE;
-
-/***** configuration ********************************************/
-
-static struct json_object *readjson(int fd)
-{
- char *buffer;
- struct stat s;
- struct json_object *result = NULL;
- int rc;
-
- rc = fstat(fd, &s);
- if (rc == 0 && S_ISREG(s.st_mode)) {
- buffer = alloca((size_t)(s.st_size)+1);
- if (read(fd, buffer, (size_t)s.st_size) == (ssize_t)s.st_size) {
- buffer[s.st_size] = 0;
- result = json_tokener_parse(buffer);
- }
- }
- close(fd);
-
- return result;
-}
-
-static struct json_object *get_global_config(const char *name, const char *locale)
-{
- int fd = afb_daemon_rootdir_open_locale(name, O_RDONLY, locale);
- return fd < 0 ? NULL : readjson(fd);
-}
-
-static struct json_object *get_local_config(const char *name)
-{
- int fd = openat(AT_FDCWD, name, O_RDONLY, 0);
- return fd < 0 ? NULL : readjson(fd);
-}
-
-static void confsetstr(struct json_object *conf, const char *name, char **value, const char *def)
-{
- struct json_object *v;
- const char *s;
- char *p;
-
- s = conf && json_object_object_get_ex(conf, name, &v) ? json_object_get_string(v) : def;
- p = *value;
- if (s && p != s) {
- *value = strdup(s);
- free(p);
- }
-}
-
-static void confsetint(struct json_object *conf, const char *name, int *value, int def)
-{
- struct json_object *v;
-
- *value = conf && json_object_object_get_ex(conf, name, &v) ? json_object_get_int(v) : def;
-}
-
-static void confsetoidc(struct json_object *conf, const char *name)
-{
- struct json_object *idp, *appli;
-
- if (conf
- && json_object_object_get_ex(conf, "idp", &idp)
- && json_object_object_get_ex(conf, "appli", &appli)) {
- if (oidc_idp_set(name, idp) && oidc_appli_set(name, name, appli, 1)) {
- oidc_name = name;
- }
- }
-}
-
-static void setconfig(struct json_object *conf)
-{
- confsetstr(conf, "endpoint", &endpoint, endpoint ? : default_endpoint);
- confsetstr(conf, "vin", &vin, vin ? : default_vin);
- confsetint(conf, "delay", &expiration_delay, expiration_delay);
- confsetint(conf, "autoadvise", &autoadvise, autoadvise);
- confsetoidc(conf, "oidc-aia");
-}
-
-static void readconfig()
-{
- setconfig(get_global_config("config.json", NULL));
- setconfig(get_local_config("/etc/agl/identity-agent-config.json"));
- setconfig(get_local_config("config.json"));
-}
-
-/****************************************************************/
-
-static struct json_object *make_event_object(const char *name, const char *id, const char *nick)
-{
- struct json_object *object = json_object_new_object();
-
- /* TODO: errors */
- json_object_object_add(object, "eventName", json_object_new_string(name));
- json_object_object_add(object, "accountid", json_object_new_string(id));
- if (nick)
- json_object_object_add(object, "nickname", json_object_new_string(nick));
- return object;
-}
-
-static int send_event_object(const char *name, const char *id, const char *nick)
-{
- return afb_event_push(event, make_event_object(name, id, nick));
-}
-
-static void do_login(struct json_object *desc)
-{
- struct json_object *object;
-
- /* switching the user */
- AFB_INFO("Switching to user %s", desc ? json_object_to_json_string(desc) : "null");
- object = current_identity;
- current_identity = json_object_get(desc);
- json_object_put(object);
-
- if (!json_object_object_get_ex(desc, "name", &object))
- object = 0;
- send_event_object("login", !object ? "null" : json_object_get_string(object)? : "?", 0);
-}
-
-static void do_logout()
-{
- struct json_object *object;
-
- AFB_INFO("Switching to no user");
- object = current_identity;
- current_identity = 0;
- json_object_put(object);
-
- send_event_object("logout", "null", 0);
-}
-
-/****************************************************************/
-
-static char *get_upload_url(const char *key)
-{
- int rc;
- char *result;
-
- rc = asprintf(&result, "%s?vin=%s&keytoken=%s", endpoint, vin, key);
- return rc >= 0 ? result : NULL;
-}
-
-static void uploaded(void *closure, int status, const void *buffer, size_t size)
-{
- struct json_object *object, *subobj;
- char *url = closure;
-
- /* checks whether discarded */
- if (status == 0 && !buffer)
- goto end; /* discarded */
-
- /* scan for the status */
- if (status == 0 || !buffer) {
- AFB_ERROR("uploading %s failed %s", url ? : "?", (const char*)buffer ? : "");
- goto end;
- }
-
- /* get the object */
- AFB_DEBUG("received data: %.*s", (int)size, (char*)buffer);
- object = json_tokener_parse(buffer); /* okay because 0 appended */
-
- /* extract useful part */
- subobj = NULL;
- if (object && !json_object_object_get_ex(object, "results", &subobj))
- subobj = NULL;
- if (subobj)
- subobj = json_object_array_get_idx(subobj, 0);
- if (subobj && !json_object_object_get_ex(subobj, "data", &subobj))
- subobj = NULL;
- if (subobj)
- subobj = json_object_array_get_idx(subobj, 0);
- if (subobj && !json_object_object_get_ex(subobj, "row", &subobj))
- subobj = NULL;
- if (subobj)
- subobj = json_object_array_get_idx(subobj, 0);
-
- /* is it a recognized user ? */
- if (!subobj) {
- /* not recognized!! */
- AFB_INFO("unrecognized key for %s", url ? : "?");
- json_object_put(object);
- goto end;
- }
-
- do_login(subobj);
- json_object_put(object);
-end:
- free(url);
-}
-
-static void upload_request(const char *address)
-{
- char *url = get_upload_url(address);
- if (url)
- aia_get(url, expiration_delay, oidc_name, oidc_name, uploaded, url);
- else
- AFB_ERROR("out of memory");
-}
-
-static void on_uds_change(const struct aia_uds *uds)
-{
- AFB_INFO("UDS changed"
- " first-name%s[%.*s]"
- " last-name%s[%.*s]"
- " email%s[%.*s]"
- " language%s[%.*s]",
- uds->first_name.changed ? "*" : "", (int)uds->first_name.length, uds->first_name.data ?:"",
- uds->last_name.changed ? "*" : "", (int)uds->last_name.length, uds->last_name.data ?:"",
- uds->email.changed ? "*" : "", (int)uds->email.length, uds->email.data ?:"",
- uds->language.changed ? "*" : "", (int)uds->language.length, uds->language.data ?:"");
- if (uds->email.changed) {
- upload_request(uds->email.data);
- send_event_object("incoming", uds->email.data, uds->email.data);
- }
-}
-
-static void advise (struct afb_req request)
-{
- int rc;
-
- if (!advising) {
- rc = aia_uds_advise(1, NULL, NULL);
- if (rc < 0) {
-/*
-TODO: solve the issue
- afb_req_fail(request, "failed", "start scan failed");
- return;
-*/
- AFB_ERROR("Ignoring scan start failed, because probably already in progress");
- }
- advising = 1;
- }
- afb_req_success(request, NULL, NULL);
-}
-
-
-static void unadvise (struct afb_req request)
-{
- aia_uds_advise(0, NULL, NULL);
- advising = 0;
- afb_req_success(request, NULL, NULL);
-}
-
-static void subscribe (struct afb_req request)
-{
- int rc;
-
- rc = afb_req_subscribe(request, event);
- if (rc < 0)
- afb_req_fail(request, "failed", "subscribtion failed");
- else
- afb_req_success(request, NULL, NULL);
-}
-
-static void unsubscribe (struct afb_req request)
-{
- afb_req_unsubscribe(request, event);
- afb_req_success(request, NULL, NULL);
-}
-
-static void login (struct afb_req request)
-{
- afb_req_fail(request, "not-implemented-yet", NULL);
-}
-
-static void logout (struct afb_req request)
-{
- do_logout();
- afb_req_success(request, NULL, NULL);
-}
-
-static void get (struct afb_req request)
-{
- afb_req_success(request, json_object_get(current_identity), NULL);
-}
-
-static void success (struct afb_req request)
-{
- afb_req_success(request, NULL, NULL);
-}
-
-static int service_init()
-{
- sd_bus *bus;
- int rc;
-
- bus = afb_daemon_get_system_bus();
- rc = bus ? aia_uds_init(bus) : -ENOTSUP;
- if (rc < 0) {
- errno = -rc;
- return -1;
- }
-
- aia_uds_set_on_change(on_uds_change);
-
- event = afb_daemon_make_event("event");
- if (!afb_event_is_valid(event))
- return -1;
-
- readconfig();
-
- rc = aia_uds_advise(autoadvise, NULL, NULL);
- return rc < 0 ? rc : 0;
-}
-
-
-// NOTE: this sample does not use session to keep test a basic as possible
-// in real application most APIs should be protected with AFB_SESSION_CHECK
-static const struct afb_verb_v2 verbs[]=
-{
- {"subscribe" , subscribe , NULL, "subscribe to events" , AFB_SESSION_NONE },
- {"unsubscribe", unsubscribe , NULL, "unsubscribe to events" , AFB_SESSION_NONE },
- {"login" , login , NULL, "log a user in" , AFB_SESSION_NONE },
- {"logout" , logout , NULL, "log the current user out", AFB_SESSION_NONE },
- {"get" , get , NULL, "get data" , AFB_SESSION_NONE },
- {"advise" , advise , NULL, "start advising uds" , AFB_SESSION_NONE },
- {"unadvise" , unadvise , NULL, "stop advising uds" , AFB_SESSION_NONE },
- {"scan" , success , NULL, "legacy" , AFB_SESSION_NONE },
- {"unscan" , success , NULL, "legacy" , AFB_SESSION_NONE },
- {NULL}
-};
-
-const struct afb_binding_v2 afbBindingV2 =
-{
- .api = "agl-identity-agent",
- .specification = NULL,
- .info = "AGL identity agent service",
- .verbs = verbs,
- .preinit = NULL,
- .init = service_init,
- .onevent = NULL,
- .noconcurrency = 0
-};
-
-/* vim: set colorcolumn=80: */
-
diff --git a/binding/aia-get.c b/binding/aia-get.c
deleted file mode 100644
index 93d9470..0000000
--- a/binding/aia-get.c
+++ /dev/null
@@ -1,252 +0,0 @@
-/*
- * Copyright (C) 2015, 2016 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <stdlib.h>
-#include <string.h>
-#include <time.h>
-#include <pthread.h>
-
-#include <json-c/json.h>
-#include <curl/curl.h>
-
-#include "curl-wrap.h"
-#include "oidc-agent.h"
-
-/*
-#include <errno.h>
-#include <stdint.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-
-#include <json-c/json.h>
-
-#include <afb/afb-binding.h>
-#include <afb/afb-req-itf.h>
-#include <afb/afb-event-itf.h>
-#include <afb/afb-service-itf.h>
-
-
-#include "u2f-bluez.h"
-*/
-
-
-struct keyrequest {
- struct keyrequest *next;
- int dead;
- time_t expiration;
- const char *url;
- const char *appli;
- const char *idp;
- void (*callback)(void *closure, int status, const void *buffer, size_t size);
- void *closure;
- json_object *token;
- pthread_t tid;
-};
-
-static struct keyrequest *keyrequests = 0;
-
-static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
-
-static int curl_initialized = 0;
-
-
-
-
-
-
-
-
-static void perform_query_callback(void *closure, int status, CURL *curl, const char *result, size_t size)
-{
- struct keyrequest *kr = closure;
- kr->callback(kr->closure, status, result, size);
-}
-
-static void perform_query(struct keyrequest *kr)
-{
- CURL *curl;
-
- curl = curl_wrap_prepare_get_url(kr->url);
- if (!curl)
- kr->callback(kr->closure, 0, "out of memory", 0);
- else {
- oidc_add_bearer(curl, kr->token);
- curl_wrap_do(curl, perform_query_callback, kr);
- }
-}
-
-static void token_success(void *closure, struct json_object *token)
-{
- struct keyrequest *kr = closure;
- kr->token = token;
- perform_query(kr);
-}
-
-static void token_error(void *closure, const char *message, const char *indice)
-{
- struct keyrequest *kr = closure;
- kr->callback(kr->closure, 0, message, 0);
-}
-
-static void *kr_get_thread(void *closure)
-{
- struct oidc_grant_cb cb;
- struct keyrequest *kr = closure;
-
- if (!kr->appli)
- perform_query(kr);
- else {
- cb.closure = kr;
- cb.success = token_success;
- cb.error = token_error;
- oidc_grant_owner_password(kr->appli, kr->idp, NULL, &cb);
- }
- kr->dead = 1;
- return NULL;
-}
-
-static void kr_free(struct keyrequest *kr)
-{
- json_object_put(kr->token);
- free(kr);
-}
-
-static struct keyrequest *kr_alloc(
- const char *url,
- time_t expiration,
- const char *appli,
- const char *idp,
- void (*callback)(void *closure, int status, const void *buffer, size_t size),
- void *closure
-)
-{
- struct keyrequest *result;
- char *buf;
- size_t surl, sappli, sidp;
-
- surl = 1 + strlen(url);
- sappli = appli ? 1 + strlen(appli) : 0;
- sidp = idp ? 1 + strlen(idp) : 0;
-
- result = calloc(1, surl + sappli + sidp + sizeof *result);
- if (result) {
- result->next = NULL;
- result->dead = 0;
- result->expiration = expiration;
- result->callback = callback;
- result->closure = closure;
- result->token = NULL;
- result->tid = 0;
-
- buf = (char*)(&result[1]);
- result->url = buf;
- buf = mempcpy(buf, url, surl);
- if (!appli)
- result->appli = NULL;
- else {
- result->appli = buf;
- buf = mempcpy(buf, appli, sappli);
- }
- if (!idp)
- result->idp = NULL;
- else {
- result->idp = buf;
- buf = mempcpy(buf, idp, sidp);
- }
- }
- return result;
-}
-
-void aia_get(
- const char *url,
- int delay,
- const char *appli,
- const char *idp,
- void (*callback)(void *closure, int status, const void *buffer, size_t size),
- void *closure
-)
-{
- int rc;
- time_t now;
- struct keyrequest **pkr, *kr, *found_kr;
-
- /* initialize CURL component */
- pthread_mutex_lock(&mutex);
- if (!curl_initialized) {
- curl_initialized = 1;
- curl_global_init(CURL_GLOBAL_DEFAULT);
- }
-
- /* search for the same request and also cleanup deads */
- now = time(NULL);
- found_kr = 0;
- pkr = &keyrequests;
- kr = *pkr;
- while (kr) {
- if (now > kr->expiration) {
- if (kr->dead) {
- *pkr = kr->next;
- kr_free(kr);
- } else {
- pkr = &kr->next;
- }
- } else {
- if (!strcmp(url, kr->url))
- found_kr = kr;
- pkr = &kr->next;
- }
- kr = *pkr;
- }
-
- /* check if found and pending */
- if (found_kr) {
- /* found -> cancel */
- pthread_mutex_unlock(&mutex);
- callback(closure, 0, NULL, 0);
- return;
- }
-
- /* allocates the keyrequest */
- kr = kr_alloc(url, now + delay, appli, idp, callback, closure);
- if (!kr) {
- pthread_mutex_unlock(&mutex);
- callback(closure, 0, "Out of memory", 0);
- return;
- }
-
- /* link the request */
- kr->next = keyrequests;
- keyrequests = kr;
-
- /* makes the request in a new thread */
- rc = pthread_create(&kr->tid, 0, kr_get_thread, kr);
- if (rc != 0) {
- /* error, unlink */
- keyrequests = kr->next;
- pthread_mutex_unlock(&mutex);
- kr_free(kr);
- callback(closure, 0, "Can't create a new thread", 0);
- return;
- }
- pthread_mutex_unlock(&mutex);
-}
-
-/* vim: set colorcolumn=80: */
-
diff --git a/binding/aia-get.h b/binding/aia-get.h
deleted file mode 100644
index be1a1f8..0000000
--- a/binding/aia-get.h
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#pragma once
-
-extern void aia_get(
- const char *url,
- int delay,
- const char *appli,
- const char *idp,
- void (*callback)(void *closure, int status, const void *buffer, size_t size),
- void *closure
-);
-
diff --git a/binding/aia-uds-bluez.c b/binding/aia-uds-bluez.c
deleted file mode 100644
index 35ba61d..0000000
--- a/binding/aia-uds-bluez.c
+++ /dev/null
@@ -1,607 +0,0 @@
-/*
- * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <stdlib.h>
-#include <stdint.h>
-#include <string.h>
-#include <errno.h>
-
-#include <systemd/sd-bus.h>
-
-#include "aia-uds-bluez.h"
-
-#define ROOT "/uds"
-
-#define ITF_SERVICE "org.bluez.GattService1"
-#define ITF_CHARACTERISTIC "org.bluez.GattCharacteristic1"
-#define ITF_DESCRIPTOR "org.bluez.GattDescriptor1"
-
-/****** internal types **********/
-
-struct item
-{
- const char *uuid;
- const char *path;
- struct item *parent;
- struct aia_uds_value *value;
-};
-
-/****** internal data **********/
-
-static sd_bus *busini;
-static int activation;
-
-static aia_uds_on_change on_change_callback;
-
-static struct aia_uds uds;
-
-static struct aia_uds uds_descs =
-{
- .first_name = { .data = "First name of the user" },
- .last_name = { .data = "Last name of the user" },
- .email = { .data = "Email of the user" },
- .language = { .data = "The Language definition is based on ISO639-1" }
-};
-
-static struct aia_uds_value woutf8 = { .data = "\031\000\047\000\001\000\000", .length = 7 };
-
-static struct item services[1] =
-{
- {
- .uuid = "0000181C-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0"
- }
-};
-
-static struct item characteristics[4] =
-{
- {
- .uuid = "00002A8A-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char0",
- .parent = &services[0],
- .value = &uds.first_name
- }, {
- .uuid = "00002A90-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char1",
- .parent = &services[0],
- .value = &uds.last_name
- }, {
- .uuid = "00002A87-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char2",
- .parent = &services[0],
- .value = &uds.email
- }, {
- .uuid = "00002AA2-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char3",
- .parent = &services[0],
- .value = &uds.language
- }
-};
-
-static struct item descriptors[8] =
-{
- {
- .uuid = "00002901-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char0/desc0",
- .parent = &characteristics[0],
- .value = &uds_descs.first_name
- }, {
- .uuid = "00002904-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char0/desc1",
- .parent = &characteristics[0],
- .value = &woutf8
- }, {
- .uuid = "00002901-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char1/desc0",
- .parent = &characteristics[1],
- .value = &uds_descs.last_name
- }, {
- .uuid = "00002904-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char1/desc1",
- .parent = &characteristics[1],
- .value = &woutf8
- }, {
- .uuid = "00002901-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char2/desc0",
- .parent = &characteristics[2],
- .value = &uds_descs.email
- }, {
- .uuid = "00002904-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char2/desc1",
- .parent = &characteristics[2],
- .value = &woutf8
- }, {
- .uuid = "00002901-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char3/desc0",
- .parent = &characteristics[3],
- .value = &uds_descs.language
- }, {
- .uuid = "00002904-0000-1000-8000-00805f9b34fb",
- .path = ROOT"/service0/char3/desc1",
- .parent = &characteristics[3],
- .value = &woutf8
- }
-};
-
-/****** utility ***********/
-
-static uint16_t get_offset(sd_bus_message *m)
-{
- uint16_t offset;
- const char *key;
-
- if (0 < sd_bus_message_enter_container(m, SD_BUS_TYPE_DICT_ENTRY, "sv")) {
- while (sd_bus_message_read_basic(m, 's', &key) > 0) {
- if (strcmp(key,"offset"))
- sd_bus_message_skip(m, "v");
- else {
- if (sd_bus_message_enter_container(m, SD_BUS_TYPE_VARIANT, "q")) {
- sd_bus_message_read_basic(m, 'q', &offset);
- sd_bus_message_exit_container(m);
- return offset;
- }
- }
- }
- sd_bus_message_exit_container(m);
- }
- return 0;
-}
-
-static int message_append_strings(sd_bus_message *m, const char **s)
-{
- int rc = sd_bus_message_open_container(m, SD_BUS_TYPE_ARRAY, "s");
- while (rc >= 0 && *s)
- rc = sd_bus_message_append_basic(m, 's', *s++);
- if (rc >= 0)
- rc = sd_bus_message_close_container(m);
- return rc;
-}
-
-/****** common callbacks ***********/
-
-static int get_uuid(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- struct item *item = userdata;
- return sd_bus_message_append_basic(reply, 's', item->uuid);
-}
-
-static int get_parent(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- struct item *item = userdata;
- return sd_bus_message_append_basic(reply, 'o', item->parent->path);
-}
-
-static int get_children(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- size_t i, n;
- int rc;
-
- rc = sd_bus_message_open_container(reply, SD_BUS_TYPE_ARRAY, "o");
- n = sizeof characteristics / sizeof *characteristics;
- i = 0;
- while (rc >= 0 && i < n) {
- if (characteristics[i].parent == userdata)
- rc = sd_bus_message_append_basic(reply, 'o', characteristics[i].path);
- i++;
- }
- n = sizeof descriptors / sizeof *descriptors;
- i = 0;
- while (rc >= 0 && i < n) {
- if (descriptors[i].parent == userdata)
- rc = sd_bus_message_append_basic(reply, 'o', descriptors[i].path);
- i++;
- }
- if (rc >= 0)
- rc = sd_bus_message_close_container(reply);
- return rc;
-}
-
-static int read_value_offset(
- struct item *item,
- size_t offset,
- sd_bus_message *reply)
-{
- struct aia_uds_value *value = item->value;
- const char *data = value ? value->data : NULL;
- size_t size = !value ? 0 : value->length ? value->length : data ? strlen(data) : 0;
- return sd_bus_message_append_array(reply, 'y', &data[offset], offset > size ? 0 : size - offset);
-}
-
-static int read_value(
- sd_bus_message *m,
- void *userdata,
- sd_bus_error *ret_error)
-{
- int rc;
- sd_bus_message *r;
-
- rc = sd_bus_message_new_method_return(m, &r);
- rc = read_value_offset(userdata, get_offset(m), r);
- rc = sd_bus_send(NULL, r, NULL);
- return 1;
-}
-
-static int write_value_offset(
- struct item *item,
- size_t offset,
- const char *buffer,
- size_t length)
-{
- struct aia_uds_value *value = item->value;
- const char *data = value ? value->data : NULL;
- size_t size = !value ? 0 : value->length ? value->length : data ? strlen(data) : 0;
-
-
- char *next = malloc(offset + length + 1);
- if (!next)
- return -ENOMEM;
- if (offset) {
- if (size >= offset)
- memcpy(next, data, offset);
- else {
- memcpy(next, data, size);
- memset(&next[size], 0, offset - size);
- }
- }
- memcpy(&next[offset], buffer, length);
- next[offset + length] = 0;
- value->data = next;
- value->length = offset + length;
- free((char*)data);
-
- return 0;
-}
-
-static int write_value(
- sd_bus_message *m,
- void *userdata,
- sd_bus_error *ret_error)
-{
- int rc;
- struct item *item = userdata;
- const void *data;
- size_t size;
- sd_bus_message *r;
-
- rc = sd_bus_message_read_array(m, 'y', &data, &size);
- rc = write_value_offset(item, get_offset(m), data, size);
-
- rc = sd_bus_message_new_method_return(m, &r);
- rc = sd_bus_send(NULL, r, NULL);
-
- sd_bus_emit_properties_changed(sd_bus_message_get_bus(m), item->path, ITF_CHARACTERISTIC, "Value", NULL);
-
- if (on_change_callback) {
- item->value->changed = 1;
- on_change_callback(&uds);
- item->value->changed = 0;
- }
-
- return 1;
-}
-
-static int get_value(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- return read_value_offset(userdata, 0, reply);
-}
-
-static int get_true(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- int v = 1;
- return sd_bus_message_append_basic(reply, 'b', &v);
-}
-
-static int get_false(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- int v = 0;
- return sd_bus_message_append_basic(reply, 'b', &v);
-}
-
-static int not_supported(
- sd_bus_message *m,
- void *userdata,
- sd_bus_error *ret_error)
-{
- return sd_bus_reply_method_errorf(m, "org.bluez.Error.NotSupported", "not supported");
-}
-
-static int not_permitted(
- sd_bus_message *m,
- void *userdata,
- sd_bus_error *ret_error)
-{
- return sd_bus_reply_method_errorf(m, "org.bluez.Error.NotPermitted", "not permitted");
-}
-
-static int failed(
- sd_bus_message *m,
- void *userdata,
- sd_bus_error *ret_error)
-{
- return sd_bus_reply_method_errorf(m, "org.bluez.Error.Failed", "failed");
-}
-
-/****** service's callbacks ***********/
-
-static int get_srv_includes(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- int rc = sd_bus_message_open_container(reply, SD_BUS_TYPE_ARRAY, "o");
- if (rc >= 0)
- rc = sd_bus_message_close_container(reply);
- return rc;
-}
-
-/****** characteristic's callbacks ***********/
-
-static int get_char_flags(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- static const char *flags[] = { "read", "write", NULL };
- return message_append_strings(reply, flags);
-}
-
-/****** descriptor's callbacks ***********/
-
-static int get_desc_flags(
- struct sd_bus *bus,
- const char *path,
- const char *interface,
- const char *property,
- sd_bus_message *reply,
- void *userdata,
- sd_bus_error *ret_error)
-{
- static const char *flags[] = { "read", NULL };
- return message_append_strings(reply, flags);
-}
-
-/****** description ***********/
-
-static struct sd_bus_vtable vservice[] = {
- SD_BUS_VTABLE_START(0),
-
- SD_BUS_PROPERTY("UUID", "s", get_uuid, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Primary", "b", get_true, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Includes", "ao", get_srv_includes, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Characteristics", "ao", get_children, 0, SD_BUS_VTABLE_PROPERTY_CONST),
-
- SD_BUS_VTABLE_END
-};
-
-
-static struct sd_bus_vtable vcharacteristic[] = {
- SD_BUS_VTABLE_START(0),
-
- SD_BUS_METHOD("ReadValue", "a{sv}", "ay", read_value, 0),
- SD_BUS_METHOD("WriteValue", "aya{sv}", "", write_value, 0),
- SD_BUS_METHOD("StartNotify", "", "", not_supported, 0),
- SD_BUS_METHOD("StopNotify", "", "", failed, 0),
-
- SD_BUS_PROPERTY("UUID", "s", get_uuid, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Service", "o", get_parent, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Value", "ay", get_value, 0, 0),
- SD_BUS_PROPERTY("WriteAcquired", "b", get_false, 0, 0),
- SD_BUS_PROPERTY("NotifyAcquired", "b", get_false, 0, 0),
- SD_BUS_PROPERTY("Notifying", "b", get_false, 0, 0),
- SD_BUS_PROPERTY("Flags", "as", get_char_flags, 0, 0),
- SD_BUS_PROPERTY("Descriptors", "ao", get_children, 0, 0),
-
- SD_BUS_VTABLE_END
-};
-
-
-static struct sd_bus_vtable vdescriptor[] = {
- SD_BUS_VTABLE_START(0),
-
- SD_BUS_METHOD("ReadValue", "a{sv}", "ay", read_value, 0),
- SD_BUS_METHOD("WriteValue", "aya{sv}", "", not_permitted, 0),
-
- SD_BUS_PROPERTY("UUID", "s", get_uuid, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Characteristic", "o", get_parent, 0, SD_BUS_VTABLE_PROPERTY_CONST),
- SD_BUS_PROPERTY("Value", "ay", get_value, 0, 0),
- SD_BUS_PROPERTY("Flags", "as", get_desc_flags, 0, 0),
-
- SD_BUS_VTABLE_END
-};
-
-
-/******** Integration ***************/
-
-aia_uds_on_change aia_uds_set_on_change(aia_uds_on_change callback)
-{
- aia_uds_on_change prev = on_change_callback;
- on_change_callback = callback;
- return prev;
-}
-
-int aia_uds_init(struct sd_bus *bus)
-{
- int rc;
-
- if (busini)
- return 0;
-
- rc = sd_bus_add_object_manager(bus, NULL, ROOT);
-
- rc = sd_bus_add_object_vtable(bus, NULL, services[0].path,
- ITF_SERVICE, vservice, &services[0]);
-
- rc = sd_bus_add_object_vtable(bus, NULL, characteristics[0].path,
- ITF_CHARACTERISTIC, vcharacteristic, &characteristics[0]);
- rc = sd_bus_add_object_vtable(bus, NULL, characteristics[1].path,
- ITF_CHARACTERISTIC, vcharacteristic, &characteristics[1]);
- rc = sd_bus_add_object_vtable(bus, NULL, characteristics[2].path,
- ITF_CHARACTERISTIC, vcharacteristic, &characteristics[2]);
- rc = sd_bus_add_object_vtable(bus, NULL, characteristics[3].path,
- ITF_CHARACTERISTIC, vcharacteristic, &characteristics[3]);
-
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[0].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[0]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[1].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[1]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[2].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[2]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[3].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[3]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[4].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[4]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[5].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[5]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[6].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[6]);
- rc = sd_bus_add_object_vtable(bus, NULL, descriptors[7].path,
- ITF_DESCRIPTOR, vdescriptor, &descriptors[7]);
-
- busini = sd_bus_ref(bus);
- return 0;
-}
-
-struct cb {
- void *callback;
- void *closure;
- int onoff;
-};
-
-static struct cb *alloccb(void *callback, void *closure, int onoff)
-{
- struct cb *cb = malloc(sizeof *cb);
- if (cb) {
- cb->callback = callback;
- cb->closure = closure;
- }
- return cb;
-}
-
-static int register_uds_cb(sd_bus_message *m, void *userdata, sd_bus_error *ret_error)
-{
- struct cb *cb = userdata;
- void (*callback)(void *closure, int error, int state);
- int iserr;
-
- iserr = sd_bus_message_is_method_error(m, NULL);
- if (!iserr)
- activation = cb->onoff;
- callback = cb->callback;
- if (callback)
- callback(cb->closure, iserr, activation);
- free(cb);
-
- return 1;
-}
-
-static int register_uds(int onoff, void *data)
-{
- int rc;
- sd_bus_message *m;
-
- rc = sd_bus_message_new_method_call(busini, &m, "org.bluez",
- "/org/bluez/hci0", "org.bluez.GattManager1",
- onoff ? "RegisterApplication" : "UnregisterApplication" );
- rc = sd_bus_message_append_basic(m, 'o', ROOT);
- if (onoff) {
- rc = sd_bus_message_open_container(m, 'a', "{sv}");
- rc = sd_bus_message_close_container(m);
- }
- rc = sd_bus_call_async(busini, NULL, m, register_uds_cb, data, 5*1000*1000);
- sd_bus_message_unref(m);
- return rc;
-}
-
-int aia_uds_activate(int onoff, void (*callback)(void *closure, int error, int state), void *closure)
-{
- int rc;
- struct cb *cb;
-
- if (!busini)
- return -EINVAL;
-
- onoff = !!onoff;
- if (activation == onoff)
- return 0;
-
- cb = alloccb(callback, closure, onoff);
- if (!cb)
- return -ENOMEM;
-
- rc = register_uds(onoff, cb);
- if (rc < 0)
- free(cb);
-
- return rc < 0 ? rc : 1;
-}
-
-int aia_uds_advise(int onoff, void (*callback)(void *closure, int error, int state), void *closure)
-{
- return aia_uds_activate(onoff, callback, closure);
-}
-
diff --git a/binding/aia-uds-bluez.h b/binding/aia-uds-bluez.h
deleted file mode 100644
index 856da4e..0000000
--- a/binding/aia-uds-bluez.h
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-
-#pragma once
-
-struct aia_uds_value
-{
- const char *data;
- size_t length;
- int changed;
-};
-
-struct aia_uds
-{
- struct aia_uds_value first_name;
- struct aia_uds_value last_name;
- struct aia_uds_value email;
- struct aia_uds_value language;
-};
-
-typedef void (*aia_uds_on_change)(const struct aia_uds *);
-
-extern aia_uds_on_change aia_uds_set_on_change(aia_uds_on_change callback);
-
-extern int aia_uds_activate(int onoff, void (*callback)(void *closure, int error, int state), void *closure);
-
-extern int aia_uds_advise(int onoff, void (*callback)(void *closure, int error, int state), void *closure);
-
-extern int aia_uds_init(struct sd_bus *bus);
-
diff --git a/binding/authorization.c b/binding/authorization.c
deleted file mode 100644
index ae00923..0000000
--- a/binding/authorization.c
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#define _GNU_SOURCE
-
-#include <stdlib.h>
-#include <stdio.h>
-
-#include "base64.h"
-
-char *authorization_basic_make(const char *user, const char *password)
-{
- const char *array[3] = { user, ":", password };
- return base64_encode_array(array, 3);
-}
-
-char *authorization_basic_make_header(const char *user, const char *password)
-{
- char *key, *result;
-
- key = authorization_basic_make(user, password);
- if (!key || asprintf(&result, "Authorization: Basic %s", key) < 0)
- result = NULL;
- free(key);
- return result;
-}
-
-/* vim: set colorcolumn=80: */
-
diff --git a/binding/authorization.h b/binding/authorization.h
deleted file mode 100644
index bd26c1a..0000000
--- a/binding/authorization.h
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#pragma once
-
-extern char *authorization_basic_make(const char *user, const char *password);
-extern char *authorization_basic_make_header(const char *user, const char *password);
-
-/* vim: set colorcolumn=80: */
diff --git a/binding/base64.c b/binding/base64.c
deleted file mode 100644
index 0841aba..0000000
--- a/binding/base64.c
+++ /dev/null
@@ -1,108 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include <stdlib.h>
-#include <stdint.h>
-#include <string.h>
-
-const char base64_variant_standard[] = "+/=";
-const char base64_variant_url[] = "-_=";
-const char base64_variant_trunc[] = "+/";
-const char base64_variant_url_trunc[] = "-_";
-
-static char eb64(int x, const char *variant)
-{
- if (x < 52)
- return (char)(x + (x < 26 ? 'A' : 'a'-26));
- else
- return x < 62 ? (char)(x + '0' - 52) : variant[x - 62];
-}
-
-char *base64_encode_array_variant(const char * const *args, size_t count, const char *variant)
-{
- const char *v, *s;
- char *buffer, c;
- size_t i, j, n;
- uint16_t x;
-
- /* compute size and allocate */
- i = n = 0;
- while (n < count)
- i += strlen(args[n++]);
- buffer = malloc(5 + ((i / 3) << 2));
- if (!buffer)
- return NULL;
-
- /* encode */
- v = variant ? : base64_variant_standard;
- n = 0;
- j = 0;
- x = 0;
- while (n < count) {
- s = args[n++];
- c = s[i = 0];
- while (c) {
- x = (uint16_t)((uint16_t)(x << 8) | (uint16_t)(uint8_t)c);
- switch (j & 3) {
- case 0:
- buffer[j++] = eb64((x >> 2) & 63, v);
- break;
- case 1:
- buffer[j++] = eb64((x >> 4) & 63, v);
- break;
- case 2:
- buffer[j++] = eb64((x >> 6) & 63, v);
- buffer[j++] = eb64(x & 63, v);
- break;
- }
- c = s[++i];
- }
- }
-
- /* pad */
- if (v[2]) {
- switch (j & 3) {
- case 1:
- buffer[j++] = eb64((x << 4) & 63, v);
- buffer[j++] = v[2];
- buffer[j++] = v[2];
- break;
- case 2:
- buffer[j++] = eb64((x << 2) & 63, v);
- buffer[j++] = v[2];
- break;
- }
- }
-
- /* done */
- buffer[j] = 0;
- return buffer;
-}
-
-char *base64_encode_multi_variant(const char * const *args, const char *variant)
-{
- size_t count;
-
- for (count = 0 ; args[count] ; count++);
- return base64_encode_array_variant(args, count, variant);
-}
-
-char *base64_encode_variant(const char *arg, const char *variant)
-{
- return base64_encode_array_variant(&arg, !!arg, variant);
-}
-
diff --git a/binding/base64.h b/binding/base64.h
deleted file mode 100644
index 5a944df..0000000
--- a/binding/base64.h
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#pragma once
-
-extern const char base64_variant_standard[];
-extern const char base64_variant_trunc[];
-
-extern const char base64_variant_url[];
-extern const char base64_variant_url_trunc[];
-
-extern char *base64_encode_array_variant(const char * const *args, size_t count, const char *variant);
-extern char *base64_encode_multi_variant(const char * const *args, const char *variant);
-extern char *base64_encode_variant(const char *arg, const char *variant);
-
-#define base64_encode_array(args,count) base64_encode_array_variant(args,count,base64_variant_standard)
-#define base64_encode_multi(args) base64_encode_multi_variant(args,base64_variant_standard)
-#define base64_encode(arg) base64_encode_variant(arg,base64_variant_standard)
-
-#define base64_encode_array_standard(args,count) base64_encode_array_variant(args,count,base64_variant_standard)
-#define base64_encode_multi_standard(args) base64_encode_multi_variant(args,base64_variant_standard)
-#define base64_encode_standard(arg) base64_encode_variant(arg,base64_variant_standard)
-
-#define base64_encode_array_url(args,count) base64_encode_array_variant(args,count,base64_variant_url)
-#define base64_encode_multi_url(args) base64_encode_multi_variant(args,base64_variant_url)
-#define base64_encode_url(arg) base64_encode_variant(arg,base64_variant_url)
-
-#define base64_encode_array_trunc(args,count) base64_encode_array_variant(args,count,base64_variant_trunc)
-#define base64_encode_multi_trunc(args) base64_encode_multi_variant(args,base64_variant_trunc)
-#define base64_encode_trunc(arg) base64_encode_variant(arg,base64_variant_trunc)
-
-#define base64_encode_array_url_trunc(args,count) base64_encode_array_variant(args,count,base64_variant_url_trunc)
-#define base64_encode_multi_url_trunc(args) base64_encode_multi_variant(args,base64_variant_url_trunc)
-#define base64_encode_url_trunc(arg) base64_encode_variant(arg,base64_variant_url_trunc)
-
-
-
diff --git a/binding/config.json b/binding/config.json
deleted file mode 100644
index 613fc7a..0000000
--- a/binding/config.json
+++ /dev/null
@@ -1,22 +0,0 @@
-{
- "endpoint": "https://agl-graphapi.forgerocklabs.org/getuserprofilefromtoken",
- "vin": "4T1BF1FK5GU260429",
- "autoadvise": true,
- "delay": 5,
- "idp": {
- "authorization_endpoint": "",
- "token_endpoint": "https://agl-am.forgerocklabs.org:8043/openam/oauth2/stateless/access_token"
- },
- "appli": {
- "authorization": "Basic c3RhdGVsZXNzOnBhc3N3b3JkMg==",
- "username": "bjensen",
- "password": "Passw0rd",
- "scope": "openid profile email cn sn givenName ou mail postalAddress departmentNumber physicalDeliveryOfficeName facsimileTelephoneNumber"
- }
-}
-/*
- "endpoint": "https://frdemo-graphapi.forgerocklabs.org/getuserprofilefromtoken",
- "vin": "JTEBU4BF6EK189816",
- "delay": 10
-*/
-
diff --git a/binding/curl-wrap.c b/binding/curl-wrap.c
deleted file mode 100644
index 986b69f..0000000
--- a/binding/curl-wrap.c
+++ /dev/null
@@ -1,211 +0,0 @@
-/*
- * Copyright (C) 2015, 2016 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <stdint.h>
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#include <pthread.h>
-
-#include <curl/curl.h>
-
-#include "curl-wrap.h"
-#include "escape.h"
-
-
-/* internal representation of buffers */
-struct buffer {
- size_t size;
- char *data;
-};
-
-/* write callback for filling buffers with the response */
-static size_t write_callback(char *ptr, size_t size, size_t nmemb, void *userdata)
-{
- struct buffer *buffer = userdata;
- size_t sz = size * nmemb;
- size_t old_size = buffer->size;
- size_t new_size = old_size + sz;
- char *data = realloc(buffer->data, new_size + 1);
- if (!data)
- return 0;
- memcpy(&data[old_size], ptr, sz);
- data[new_size] = 0;
- buffer->size = new_size;
- buffer->data = data;
- return sz;
-}
-
-/*
- * Perform the CURL operation for 'curl' and put the result in
- * memory. If 'result' isn't NULL it receives the returned content
- * that then must be freed. If 'size' isn't NULL, it receives the
- * size of the returned content. Note that if not NULL, the real
- * content is one byte greater than the read size and the last byte
- * zero. This facility allows to handle the returned content as a
- * null terminated C-string.
- */
-int curl_wrap_perform(CURL *curl, char **result, size_t *size)
-{
- int rc;
- struct buffer buffer;
- CURLcode code;
-
- /* init tthe buffer */
- buffer.size = 0;
- buffer.data = NULL;
-
- /* Perform the request, res will get the return code */
- curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
- curl_easy_setopt(curl, CURLOPT_WRITEDATA, &buffer);
-
- /* Perform the request, res will get the return code */
- code = curl_easy_perform(curl);
- rc = code == CURLE_OK;
-
- /* Check for no errors */
- if (rc) {
- /* no error */
- if (size)
- *size = buffer.size;
- if (result)
- *result = buffer.data;
- else
- free(buffer.data);
- } else {
- /* had error */
- if (size)
- *size = 0;
- if (result)
- *result = NULL;
- free(buffer.data);
- }
-
- return rc;
-}
-
-void curl_wrap_do(CURL *curl, void (*callback)(void *closure, int status, CURL *curl, const char *result, size_t size), void *closure)
-{
- int rc;
- char *result;
- size_t size;
- char errbuf[CURL_ERROR_SIZE];
-
- curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, errbuf);
- rc = curl_wrap_perform(curl, &result, &size);
- if (rc)
- callback(closure, rc, curl, result, size);
- else
- callback(closure, rc, curl, errbuf, 0);
- free(result);
- curl_easy_cleanup(curl);
-}
-
-int curl_wrap_content_type_is(CURL *curl, const char *value)
-{
- char *actual;
- CURLcode code;
-
- code = curl_easy_getinfo(curl, CURLINFO_CONTENT_TYPE, &actual);
- if (code != CURLE_OK || !actual)
- return 0;
-
- return !strncasecmp(actual, value, strcspn(actual, "; "));
-}
-
-CURL *curl_wrap_prepare_get_url(const char *url)
-{
- CURL *curl;
- CURLcode code;
-
- curl = curl_easy_init();
- if(curl) {
- code = curl_easy_setopt(curl, CURLOPT_URL, url);
- if (code == CURLE_OK)
- return curl;
- curl_easy_cleanup(curl);
- }
- return NULL;
-}
-
-CURL *curl_wrap_prepare_get(const char *base, const char *path, const char * const *args)
-{
- CURL *res;
- char *url;
-
- url = escape_url(base, path, args, NULL);
- res = url ? curl_wrap_prepare_get_url(url) : NULL;
- free(url);
- return res;
-}
-
-int curl_wrap_add_header(CURL *curl, const char *header)
-{
- int rc;
- struct curl_slist *list;
-
- list = curl_slist_append(NULL, header);
- rc = list ? curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list) == CURLE_OK : 0;
-/*
- curl_slist_free_all(list);
-*/
- return rc;
-}
-
-int curl_wrap_add_header_value(CURL *curl, const char *name, const char *value)
-{
- char *h;
- int rc;
-
- rc = asprintf(&h, "%s: %s", name, value);
- rc = rc < 0 ? 0 : curl_wrap_add_header(curl, h);
- free(h);
- return rc;
-}
-
-
-CURL *curl_wrap_prepare_post_url_data(const char *url, const char *datatype, const char *data, size_t szdata)
-{
- CURL *curl;
-
- curl = curl_easy_init();
- if (curl
- && CURLE_OK == curl_easy_setopt(curl, CURLOPT_URL, url)
- && (!szdata || CURLE_OK == curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, szdata))
- && CURLE_OK == curl_easy_setopt(curl, CURLOPT_POSTFIELDS, data)
- && (!datatype || curl_wrap_add_header_value(curl, "content-type", datatype)))
- return curl;
- curl_easy_cleanup(curl);
- return NULL;
-}
-
-CURL *curl_wrap_prepare_post(const char *base, const char *path, const char * const *args)
-{
- CURL *res;
- char *url;
- char *data;
- size_t szdata;
-
- url = escape_url(base, path, NULL, NULL);
- data = escape_args(args, &szdata);
- res = url ? curl_wrap_prepare_post_url_data(url, NULL, data, szdata) : NULL;
- free(url);
- return res;
-}
-
-/* vim: set colorcolumn=80: */
diff --git a/binding/curl-wrap.h b/binding/curl-wrap.h
deleted file mode 100644
index 2e44f47..0000000
--- a/binding/curl-wrap.h
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * Copyright (C) 2015, 2016 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-#pragma once
-
-#include <curl/curl.h>
-
-extern char *curl_wrap_url (const char *base, const char *path,
- const char *const *query, size_t * size);
-
-extern int curl_wrap_perform (CURL * curl, char **result, size_t * size);
-
-extern void curl_wrap_do(CURL *curl, void (*callback)(void *closure, int status, CURL *curl, const char *result, size_t size), void *closure);
-
-extern int curl_wrap_content_type_is (CURL * curl, const char *value);
-
-extern CURL *curl_wrap_prepare_get_url(const char *url);
-
-extern CURL *curl_wrap_prepare_get(const char *base, const char *path, const char * const *args);
-
-extern CURL *curl_wrap_prepare_post_url_data(const char *url, const char *datatype, const char *data, size_t szdata);
-
-extern CURL *curl_wrap_prepare_post(const char *base, const char *path, const char * const *args);
-
-extern int curl_wrap_add_header(CURL *curl, const char *header);
-
-extern int curl_wrap_add_header_value(CURL *curl, const char *name, const char *value);
-
-/* vim: set colorcolumn=80: */
-
diff --git a/binding/escape.c b/binding/escape.c
deleted file mode 100644
index 3bb25c2..0000000
--- a/binding/escape.c
+++ /dev/null
@@ -1,428 +0,0 @@
-/*
- * Copyright (C) 2015, 2016 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <stdint.h>
-#include <stdlib.h>
-#include <string.h>
-
-/*
- * Test if 'c' is to be escaped or not.
- * Any character that is not in [-.0-9A-Z_a-z~]
- * must be escaped.
- * Note that space versus + is not managed here.
- */
-static inline int should_escape(char c)
-{
-/* ASCII CODES OF UNESCAPED CHARS
-car hx/oct idx
-'-' 2d/055 1
-'.' 2e/056 2
-'0' 30/060 3
-... ..
-'9' 39/071 12
-'A' 41/101 13
-... ..
-'Z' 5a/132 38
-'_' 5f/137 39
-'a' 61/141 40
-... ..
-'z' 7a/172 65
-'~' 7e/176 66
-*/
- /* [-.0-9A-Z_a-z~] */
- if (c <= 'Z') {
- /* [-.0-9A-Z] */
- if (c < '0') {
- /* [-.] */
- return c != '-' && c != '.';
- } else {
- /* [0-9A-Z] */
- return c < 'A' && c > '9';
- }
- } else {
- /* [_a-z~] */
- if (c <= 'z') {
- /* [_a-z] */
- return c < 'a' && c != '_';
- } else {
- /* [~] */
- return c != '~';
- }
- }
-}
-
-/*
- * returns the ASCII char for the hexadecimal
- * digit of the binary value 'f'.
- * returns 0 if f isn't in [0 ... 15].
- */
-static inline char bin2hex(int f)
-{
- if ((f & 15) != f)
- f = 0;
- else if (f < 10)
- f += '0';
- else
- f += 'A' - 10;
- return (char)f;
-}
-
-/*
- * returns the binary value for the hexadecimal
- * digit whose char is 'c'.
- * returns -1 if c isn't i n[0-9A-Fa-f]
- */
-static inline int hex2bin(char c)
-{
- /* [0-9A-Fa-f] */
- if (c <= 'F') {
- /* [0-9A-F] */
- if (c <= '9') {
- /* [0-9] */
- if (c >= '0') {
- return (int)(c - '0');
- }
- } else if (c >= 'A') {
- /* [A-F] */
- return (int)(c - ('A' - 10));
- }
- } else {
- /* [a-f] */
- if (c >= 'a' && c <= 'f') {
- return (int)(c - ('a' - 10));
- }
- }
- return -1;
-}
-
-/*
- * returns the length that will have the text 'itext' of length
- * 'ilen' when escaped. When 'ilen' == 0, strlen is used to
- * compute the size of 'itext'.
- */
-static size_t escaped_length(const char *itext, size_t ilen)
-{
- char c;
- size_t i, r;
-
- if (!ilen)
- ilen = strlen(itext);
- c = itext[i = r = 0];
- while (i < ilen) {
- r += c != ' ' && should_escape(c) ? 3 : 1;
- c = itext[++i];
- }
- return r;
-}
-
-/*
- * Escapes the text 'itext' of length 'ilen'.
- * When 'ilen' == 0, strlen is used to compute the size of 'itext'.
- * The escaped text is put in 'otext' of length 'olen'.
- * Returns the length of the escaped text (it can be greater than 'olen').
- * When 'olen' is greater than the needed length, an extra null terminator
- * is appened to the escaped string.
- */
-static size_t escape_to(const char *itext, size_t ilen, char *otext, size_t olen)
-{
- char c;
- size_t i, r;
-
- if (!ilen)
- ilen = strlen(itext);
- c = itext[i = r = 0];
- while (i < ilen) {
- if (c == ' ')
- c = '+';
- else if (should_escape(c)) {
- if (r < olen)
- otext[r] = '%';
- r++;
- if (r < olen)
- otext[r] = bin2hex((c >> 4) & 15);
- r++;
- c = bin2hex(c & 15);
- }
- if (r < olen)
- otext[r] = c;
- r++;
- c = itext[++i];
- }
- if (r < olen)
- otext[r] = 0;
- return r;
-}
-
-/*
- * returns the length of 'itext' of length 'ilen' that can be unescaped.
- * compute the size of 'itext' when 'ilen' == 0.
- */
-static size_t unescapable_length(const char *itext, size_t ilen)
-{
- char c;
- size_t i;
-
- c = itext[i = 0];
- while (i < ilen) {
- if (c != '%')
- i++;
- else {
- if (i + 3 > ilen
- || hex2bin(itext[i + 1]) < 0
- || hex2bin(itext[i + 2]) < 0)
- break;
- i += 3;
- }
- c = itext[i];
- }
- return i;
-}
-
-/*
- * returns the length that will have the text 'itext' of length
- * 'ilen' when escaped. When 'ilen' == 0, strlen is used to
- * compute the size of 'itext'.
- */
-static size_t unescaped_length(const char *itext, size_t ilen)
-{
- char c;
- size_t i, r;
-
- c = itext[i = r = 0];
- while (i < ilen) {
- i += (size_t)(1 + ((c == '%') << 1));
- r++;
- c = itext[i];
- }
- return r;
-}
-
-static size_t unescape_to(const char *itext, size_t ilen, char *otext, size_t olen)
-{
- char c;
- size_t i, r;
- int h, l;
-
- ilen = unescapable_length(itext, ilen);
- c = itext[i = r = 0];
- while (i < ilen) {
- if (c != '%') {
- if (c == '+')
- c = ' ';
- i++;
- } else {
- if (i + 2 >= ilen)
- break;
- h = hex2bin(itext[i + 1]);
- l = hex2bin(itext[i + 2]);
- c = (char)((h << 4) | l);
- i += 3;
- }
- if (r < olen)
- otext[r] = c;
- r++;
- c = itext[i];
- }
- if (r < olen)
- otext[r] = 0;
- return r;
-}
-
-/* create an url */
-char *escape_url(const char *base, const char *path, const char * const *args, size_t *length)
-{
- int i;
- size_t lb, lp, lq, l, L;
- const char *null;
- char *result;
-
- /* ensure args */
- if (!args) {
- null = NULL;
- args = &null;
- }
-
- /* compute lengths */
- lb = base ? strlen(base) : 0;
- lp = path ? strlen(path) : 0;
- lq = 0;
- i = 0;
- while (args[i]) {
- lq += 1 + escaped_length(args[i], strlen(args[i]));
- i++;
- if (args[i])
- lq += 1 + escaped_length(args[i], strlen(args[i]));
- i++;
- }
-
- /* allocation */
- L = lb + lp + lq + 1;
- result = malloc(L + 1);
- if (result) {
- /* make the resulting url */
- l = lb;
- if (lb) {
- memcpy(result, base, lb);
- if (result[l - 1] != '/' && path && path[0] != '/')
- result[l++] = '/';
- }
- if (lp) {
- memcpy(result + l, path, lp);
- l += lp;
- }
- i = 0;
- while (args[i]) {
- if (i) {
- result[l++] = '&';
- } else if (base || path) {
- result[l] = memchr(result, '?', l) ? '&' : '?';
- l++;
- }
- l += escape_to(args[i], strlen(args[i]), result + l, L - l);
- i++;
- if (args[i]) {
- result[l++] = '=';
- l += escape_to(args[i], strlen(args[i]), result + l, L - l);
- }
- i++;
- }
- result[l] = 0;
- if (length)
- *length = l;
- }
- return result;
-}
-
-char *escape_args(const char * const *args, size_t *length)
-{
- return escape_url(NULL, NULL, args, length);
-}
-
-const char **unescape_args(const char *args)
-{
- const char **r, **q;
- char c, *p;
- size_t j, z, l, n, lt;
-
- lt = n = 0;
- if (args[0]) {
- z = 0;
- do {
- l = strcspn(&args[z], "&=");
- j = 1 + unescaped_length(&args[z], l);
- lt += j;
- z += l;
- c = args[z++];
- if (c == '=') {
- l = strcspn(&args[z], "&");
- j = 1 + unescaped_length(&args[z], l);
- lt += j;
- z += l;
- c = args[z++];
- }
- n++;
- } while(c);
- }
-
- l = lt + (2 * n + 1) * sizeof(char *);
- r = malloc(l);
- if (!r)
- return r;
-
- q = r;
- p = (void*)&r[2 * n + 1];
- if (args[0]) {
- z = 0;
- do {
- q[0] = p;
- l = strcspn(&args[z], "&=");
- j = 1 + unescape_to(&args[z], l, p, lt);
- lt -= j;
- p += j;
- z += l;
- c = args[z++];
- if (c != '=')
- q[1] = NULL;
- else {
- q[1] = p;
- l = strcspn(&args[z], "&");
- j = 1 + unescape_to(&args[z], l, p, lt);
- lt -= j;
- p += j;
- z += l;
- c = args[z++];
- }
- q = &q[2];
- } while(c);
- }
- q[0] = NULL;
- return r;
-}
-
-char *escape(const char *text, size_t textlen, size_t *reslength)
-{
- size_t len;
- char *result;
-
- len = 1 + escaped_length(text, textlen);
- result = malloc(len);
- if (result)
- escape_to(text, textlen, result, len);
- if (reslength)
- *reslength = len - 1;
- return result;
-}
-
-char *unescape(const char *text, size_t textlen, size_t *reslength)
-{
- size_t len;
- char *result;
-
- len = 1 + unescaped_length(text, textlen);
- result = malloc(len);
- if (result)
- unescape_to(text, textlen, result, len);
- if (reslength)
- *reslength = len - 1;
- return result;
-}
-
-#if 1
-#include <stdio.h>
-int main(int ac, char **av)
-{
- int i;
- char *x = escape_args((void*)++av, NULL);
- char *y = escape(x, strlen(x), NULL);
- char *z = unescape(y, strlen(y), NULL);
- const char **v = unescape_args(x);
-
- printf("%s\n%s\n%s\n", x, y, z);
- free(x);
- free(y);
- free(z);
- i = 0;
- while(v[i]) {
- printf("%s=%s / %s=%s\n", av[i], av[i+1], v[i], v[i+1]);
- i += 2;
- }
- free(v);
- return 0;
-}
-#endif
-/* vim: set colorcolumn=80: */
diff --git a/binding/escape.h b/binding/escape.h
deleted file mode 100644
index 7d548db..0000000
--- a/binding/escape.h
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#pragma once
-
-extern char *escape_url(const char *base, const char *path, const char * const *args, size_t *length);
-extern char *escape_args(const char * const *args, size_t *length);
-extern const char **unescape_args(const char *args);
-
-/* vim: set colorcolumn=80: */
diff --git a/binding/export.map b/binding/export.map
deleted file mode 100644
index ee2f413..0000000
--- a/binding/export.map
+++ /dev/null
@@ -1 +0,0 @@
-{ global: afbBindingV*; local: *; };
diff --git a/binding/memo.txt b/binding/memo.txt
deleted file mode 100644
index 3a6ed50..0000000
--- a/binding/memo.txt
+++ /dev/null
@@ -1,11 +0,0 @@
-
-gcc --shared -fPIC -o aia.so [^t]*.c -lcurl -lsystemd -ljson-c
-
-afb-daemon --rootdir=. --ldpaths=. --port=1212 --token= --verbose --verbose --verbose
-
-
-afb-client-demo localhost:1212/api?token=t
-agl-identity-agent subscribe
-
-
-gcc -o taia *aia-uds-bluez.c -lsystemd
diff --git a/binding/oidc-agent.c b/binding/oidc-agent.c
deleted file mode 100644
index 1f09e7a..0000000
--- a/binding/oidc-agent.c
+++ /dev/null
@@ -1,812 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#define _GNU_SOURCE
-
-#include <stdlib.h>
-#include <stdio.h>
-#include <stdint.h>
-#include <string.h>
-#include <pthread.h>
-
-#include <json-c/json.h>
-
-#include "oidc-agent.h"
-#include "escape.h"
-#include "curl-wrap.h"
-
-/***************** utilities *************************/
-
-static const char string_empty[] = "";
-static const char string_authorization_endpoint[] = "authorization_endpoint";
-static const char string_token_endpoint[] = "token_endpoint";
-#if 0
-static const char string_issuer[] = "issuer";
-static const char string_userinfo_endpoint[] = "userinfo_endpoint";
-static const char string_revocation_endpoint[] = "revocation_endpoint";
-static const char string_jwks_uri[] = "jwks_uri";
-#endif
-
-#define MAX_IDP_COUNT 20
-#define MAX_APPLI_COUNT 100
-
-static struct json_object *idps;
-static struct json_object *applis;
-
-static pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER;
-
-/***************** utilities *************************/
-
-/*
- * Get the object of 'name' in the 'container' and return it.
- * Creates the result if needed and add it to the container.
- * When 'maxcount' isn't zero the final count will not exceed 'maxcount'.
- */
-static struct json_object *j_container_item(struct json_object *container, const char *name, int maxcount)
-{
- struct json_object *result;
-
- /* ensure object of 'name' exists */
- if (!json_object_object_get_ex(container, name, &result)) {
- if (maxcount && json_object_object_length(container) >= maxcount)
- return NULL;
- result = json_object_new_object();
- if (!result)
- return NULL;
- json_object_object_add (container, name, result);
- }
- return result;
-}
-
-/*
- * Like 'j_container_item' but also creates the 'container' if needed.
- */
-static struct json_object *j_container_item_make(struct json_object **container, const char *name, int maxcount)
-{
- struct json_object *cont;
-
- /* ensure container exists */
- cont = *container;
- if (!cont) {
- cont = json_object_new_object();
- if (!cont)
- return NULL;
- *container = cont;
- }
- return j_container_item(cont, name, maxcount);
-}
-
-/*
- * Adds in 'dest' the fields of 'src'
- * Also when the value of a field of 'src' is null, delete the field of 'dst'
- */
-static void j_merge(struct json_object *dest, struct json_object *src)
-{
- struct json_object_iter i;
- json_object_object_foreachC(src, i) {
- if (json_object_is_type(i.val, json_type_null))
- json_object_object_del(dest, i.key);
- else
- json_object_object_add(dest, i.key, json_object_get(i.val));
- }
-}
-
-/***************** IDP **************************/
-
-/*
- * Set the values of 'desc' for the idp of 'name'.
- * Return 0 on error or 1 on success.
- */
-int oidc_idp_set(const char *name, struct json_object *desc)
-{
- struct json_object *idp;
- int result = 0;
-
- pthread_rwlock_wrlock(&rwlock);
- idp = j_container_item_make(&idps, name, MAX_IDP_COUNT);
- if (idp) {
- j_merge(idp, desc);
- result = 1;
- }
- pthread_rwlock_unlock(&rwlock);
- return result;
-}
-
-/*
- * Return 1 if idp of 'name' exists or 0 otherwise.
- */
-int oidc_idp_exists(const char *name)
-{
- int result;
-
- pthread_rwlock_rdlock(&rwlock);
- result = json_object_object_get_ex(idps, name, NULL);
- pthread_rwlock_unlock(&rwlock);
-
- return result;
-}
-
-/*
- * Deletes the idp of 'name'.
- */
-void oidc_idp_delete(const char *name)
-{
- pthread_rwlock_wrlock(&rwlock);
- json_object_object_del(idps, name);
- pthread_rwlock_unlock(&rwlock);
-}
-
-/***************** APPLI **************************/
-
-/*
- * Returns the name of the idp of the 'appli'.
- * Returns NULL when appli isn't set or default idp isn't set.
- */
-static const char *get_default_idp(const char *appli)
-{
- struct json_object *a, *i;
-
- if (!json_object_object_get_ex(applis, appli, &a))
- return NULL;
- if (!json_object_object_get_ex(a, string_empty, &i))
- return NULL;
- return json_object_get_string(i);
-}
-
-/*
- * Returns the application data related to the 'appli' for the 'idp'.
- * If 'ja' isn't null, returns in it the object for the application 'appli'.
- * Returns NULL in case of error.
- */
-static struct json_object *get_appli_idp(const char *appli, const char *idp, struct json_object **ja)
-{
- struct json_object *a, *i;
-
- if (!json_object_object_get_ex(applis, appli, &a) || !json_object_object_get_ex(a, idp, &i))
- return NULL;
- if (ja)
- *ja = a;
- return i;
-}
-
-/*
- * Set the description 'desc' for the application of 'name' and
- * the 'idp'. When 'make_default' is set it, make it the default idp
- * for the application.
- * Return 0 on error or 1 on success.
- */
-int oidc_appli_set(const char *name, const char *idp, struct json_object *desc, int make_default)
-{
- struct json_object *a, *ai;
- int result = 0;
-
- pthread_rwlock_wrlock(&rwlock);
- a = j_container_item_make(&applis, name, MAX_APPLI_COUNT);
- if (a) {
- ai = j_container_item(a, idp, 0);
- if (ai) {
- j_merge(ai, desc);
- if (make_default || !json_object_object_get_ex(a, string_empty, NULL))
- json_object_object_add(a, string_empty, json_object_new_string(idp));
- result = 1;
- }
- }
- pthread_rwlock_unlock(&rwlock);
- return result;
-}
-
-/*
- * Is the appli of 'name' defined?
- * Return 1 if answer is yes or 0 for no.
- */
-int oidc_appli_exists(const char *name)
-{
- int result;
-
- pthread_rwlock_rdlock(&rwlock);
- result = json_object_object_get_ex(applis, name, NULL);
- pthread_rwlock_unlock(&rwlock);
-
- return result;
-}
-
-/*
- * Does the appli of 'name' has the 'idp' defined?
- * Return 1 if answer is yes or 0 for no.
- */
-int oidc_appli_has_idp(const char *name, const char *idp)
-{
- int result;
-
- pthread_rwlock_rdlock(&rwlock);
- result = !!get_appli_idp(name, idp, NULL);
- pthread_rwlock_unlock(&rwlock);
-
- return result;
-}
-
-/*
- * Set 'idp' as default for the application of 'name'.
- * Returns 0 on error (appli or idp for appli not existing)
- * or 1 in case of success.
- */
-int oidc_appli_set_default_idp(const char *name, const char *idp)
-{
- struct json_object *a, *i;
-
- pthread_rwlock_wrlock(&rwlock);
- i = get_appli_idp(name, idp, &a);
- if (i)
- json_object_object_add(a, string_empty, json_object_new_string(idp));
- pthread_rwlock_unlock(&rwlock);
-
- return !!i;
-}
-
-/*
- * Deletes the application of 'name'
- */
-void oidc_appli_delete(const char *name)
-{
- pthread_rwlock_wrlock(&rwlock);
- json_object_object_del(applis, name);
- pthread_rwlock_unlock(&rwlock);
-}
-
-/***************** AUTHORISATION **************************/
-
-/* parameters */
-enum param
-{
- Param_Access_Token,
- Param_Acr_Values,
- Param_Authorization,
- Param_Client_Id,
- Param_Client_Secret,
- Param_Code,
- Param_Display,
- Param_Error,
- Param_Error_Description,
- Param_Error_Uri,
- Param_Expires_In,
- Param_Grant_Type,
- Param_Id_Token,
- Param_Id_Token_Hint,
- Param_Login_Hint,
- Param_Max_Age,
- Param_Nonce,
- Param_Password,
- Param_Prompt,
- Param_Redirect_Uri,
- Param_Refresh_Token,
- Param_Response_Type,
- Param_Scope,
- Param_State,
- Param_Token_Type,
- Param_Ui_Locales,
- Param_Username,
- PARAM_COUNT
-};
-
-#if PARAM_COUNT > 30
-# error "Too much parameters"
-#endif
-#define PARAM(p) ((uint32_t)((uint32_t)1 << (Param_##p)))
-
-/* args of authorization requests */
-struct args
-{
- struct json_object *appli;
- struct json_object *idp;
- struct json_object *args;
- struct oidc_grant_cb cb;
- int locked;
- int refresh;
- uint32_t mandatory;
- uint32_t all;
- struct json_object *header;
- struct json_object *query;
-};
-
-/* Release the lock if needed */
-static void args_unlock(struct args *args)
-{
- if (!args->locked) {
- pthread_rwlock_unlock(&rwlock);
- args->locked = 0;
- }
-}
-
-/* Release the memory needed by args */
-static void args_destroy(struct args *args)
-{
- json_object_put(args->appli);
- json_object_put(args->idp);
- json_object_put(args->header);
- json_object_put(args->query);
- free(args);
-}
-
-/* Send the success event with the gained tokens */
-static void args_send_success(struct args *args, struct json_object *result)
-{
- args_unlock(args);
- args->cb.success(args->cb.closure, result);
- args_destroy(args);
-}
-
-/* Sends the error event with the indice to the client of args */
-static void args_send_error(struct args *args, const char *message, const char *indice)
-{
- args_unlock(args);
- args->cb.error(args->cb.closure, message, indice);
- args_destroy(args);
-}
-
-/* Send the error and also return NULL */
-static inline struct args *args_send_error_null(struct args *args, const char *message, const char *indice)
-{
- args_send_error(args, message, indice);
- return NULL;
-}
-
-/* creates a struct args from the arguments, returns NULL on error */
-struct args *mkargs(const char *appli, const char *idp, struct json_object *args, const struct oidc_grant_cb *cb)
-{
- struct args *result;
- struct json_object *obj;
-
- /* allocates the args */
- result = calloc(1, sizeof *result);
- if (!result) {
- cb->error(cb->closure, "Out of memory", NULL);
- return NULL;
- }
-
- /* init of the structure */
- result->cb = *cb;
- result->args = args;
- result->header = json_object_new_object();
- result->query = json_object_new_object();
-
- /* lock in read */
- pthread_rwlock_rdlock(&rwlock);
- result->locked = 1;
-
- /* check previous allocations */
- if (!result->query || !result->header) {
- return args_send_error_null(result, "Out of memory", NULL);
- }
-
- /* check whether default idp */
- if (!idp) {
- idp = get_default_idp(appli);
- if (!idp)
- return args_send_error_null(result, "No default IDP", NULL);
- }
-
- /* get the IDP */
- if (!json_object_object_get_ex(idps, idp, &obj))
- return args_send_error_null(result, "Unknown IDP", idp);
- result->idp = json_object_get(obj);
-
- /* get the appli */
- obj = get_appli_idp(appli, idp, NULL);
- if (!obj)
- return args_send_error_null(result, "Unknown APPLI for IDP", appli);
- result->appli = json_object_get(obj);
-
- return result;
-}
-
-/* get a value for a struct args */
-static struct json_object *args_object(struct args *args, const char *name)
-{
- struct json_object *result;
-
- if (!json_object_object_get_ex(args->appli, name, &result)
- && !json_object_object_get_ex(args->idp, name, &result)
- && !json_object_object_get_ex(args->args, name, &result))
- result = NULL;
- return result;
-}
-
-/* get a string value for a struct args */
-static const char *args_string(struct args *args, const char *name)
-{
- struct json_object *object = args_object(args, name);
- return object ? json_object_get_string(object) : NULL;
-}
-
-/* add a data */
-static int args_add(struct args *args, uint32_t val, const char *name, int query)
-{
- struct json_object *obj, *dest;
-
- if (val & args->all) {
- obj = args_object(args, name);
- if (obj) {
- dest = query ? args->query : args->header;
- json_object_object_add(dest, name, json_object_get(obj));
- }
- else if (val & args->mandatory) {
- args_send_error(args, "Mandatory field missing", name);
- return 0;
- }
- }
-
- return 1;
-}
-
-/*
- * Makes the CURL object for the given 'url' for either GET or POST depending
- * on 'post' with the added 'header' fields and the given query parameters.
- * Returns NULL on error.
- * Ex:
- *
- * curl_json("http://iot.bzh/api", 0, {"X-Index": "no"}, {"fast":true,"item":"2345-hellfest"})
- *
- * produces the query:
- *
- * GET /api?fast=true&item=2345-hellfest HTTP/1.1
- * Host: iot.bzh
- * X-Index: no
- *
- * while the same but with post not null produces:
- *
- * POST /api HTTP/1.1
- * Host: iot.bzh
- * X-Index: no
- * Content-Type: application/x-www-form-urlencoded
- *
- * fast=true&item=2345-hellfest
- *
- */
-static CURL *curl_json(const char *url, int post, struct json_object *header, struct json_object *query)
-{
- const char **args, *str;
- struct json_object_iter i;
- int idx;
- CURL *result;
-
- /* create args array */
- idx = 1 + (json_object_object_length(query) << 1);
- args = malloc((unsigned)idx * sizeof *args);
- if (!args)
- return NULL;
-
- /* fill the args array */
- args[--idx] = NULL;
- json_object_object_foreachC(query, i) {
- str = json_object_get_string(i.val);
- args[--idx] = str;
- args[--idx] = i.key;
- }
-
- /* prepare the query */
- if (post)
- result = curl_wrap_prepare_post(url, NULL, args);
- else
- result = curl_wrap_prepare_get(url, NULL, args);
- free(args);
- if(!result)
- return NULL;
-
- /* add headers */
- if (header) {
- json_object_object_foreachC(header, i) {
- str = json_object_get_string(i.val);
- if (!curl_wrap_add_header_value(result, i.key, str)) {
- curl_easy_cleanup(result);
- return NULL;
- }
- }
- }
- return result;
-}
-
-/*
- * Extract from the answer of 'curl' whose 'content' has 'size' bytes the
- * embeded JSON object (if any).
- * Returns it or returns NULL if the answer can't be interpreted.
- */
-static struct json_object *decode_perform_result(CURL *curl, const char *content, size_t size)
-{
- int i;
- const char **args;
- struct json_object *result;
-
- /* is it an url encoded answer? */
- if (curl_wrap_content_type_is(curl, "application/x-www-form-urlencoded")) {
- /* yes, unescape as an array of strings */
- args = unescape_args(content);
- if (!args)
- result = NULL;
- else {
- /* wrap the key=value pairs in an object */
- result = json_object_new_object();
- if (result) {
- for (i = 0 ; args[i] ; i += 2)
- json_object_object_add(result, args[i],
- json_object_new_string(args[i+1]));
- }
- free(args);
- }
- } else if (curl_wrap_content_type_is(curl, "application/json")) {
- /* interpret the json */
- result = json_tokener_parse (content);
- } else {
- /* by default, still try to interpret the answer as if json */
- result = json_tokener_parse (content);
- }
- return result;
-}
-
-/*
- * Treats the result of the query 'curl' of 'content' of 'size' bytes for the 'args'
- */
-static void perform_result(struct args *args, CURL *curl, const char *content, size_t size)
-{
- struct json_object *obj, *at, *tt;
- char *txt;
-
- /* get answer */
- obj = decode_perform_result(curl, content, size);
- if (!obj)
- return args_send_error(args, "unable to extract answer", content);
-
- /* process the answer */
- if (json_object_object_get_ex(obj, "access_token", &at) && json_object_object_get_ex(obj, "token_type", &tt)) {
- if (!strcmp(json_object_get_string(tt), "bearer")) {
- if (asprintf(&txt, "Bearer %s", json_object_get_string(at)) > 0) {
- json_object_object_add(obj, "authorization", json_object_new_string(txt));
- free(txt);
- }
- }
- }
-
- /* merge the answer to the token args in case of refresh */
- if (args->refresh)
- j_merge(args->args, obj);
-
- /* send the answer */
- args_send_success(args, obj);
-}
-
-/*
- * Treats the redirect answer of the query 'curl' of 'content' of 'size' bytes for the 'args'
- */
-static void perform_redirect(struct args *args, CURL *curl, const char *content, size_t size)
-{
- /* TODO: handle redirection for the normal flow */
- return args_send_error(args, "unhandled redirection", content);
-}
-
-/*
- * Handle the result of the query 'curl' of 'status'. If a data is returned, it is available in
- * 'content' of 'size' bytes.
- * When 'status' is 0, an error occured. Otherwise, 'statu' isn't zero.
- */
-static void perform_callback(void *closure, int status, CURL *curl, const char *content, size_t size)
-{
- long code;
- struct args *args = closure;
-
- /* query error ? */
- if (!status
- || curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &code) != CURLE_OK)
- return args_send_error(args, "query error", NULL); /* TODO: IMPROVE? */
-
- /* get the returned code */
- switch (code) {
- case 200:
- return perform_result(args, curl, content, size);
- case 302:
- return perform_redirect(args, curl, content, size);
- case 400:
- case 401:
- return args_send_error(args, content ? : "returned code error", content ? "returned code error" : content);
- default:
- return args_send_error(args, content ? : "unexpected code error", content ? "unexpected code error" : content);
- }
-}
-
-/*
- * Main function for performing OAuth2/OpenId Connect transactions.
- * The structure 'args' is filled with the needed values:
- * Application data as json object, IDP data as json object
- * Contextual arguments for the transaction.
- * 'endpoint' must be the name of an endpoint in the context of 'args'.
- * 'operation' is the value that will get either response_type or grant_type,
- * depending on the nature of the required parameters 'mandatory'.
- * 'mandatory' designates the mandatory parameters.
- * 'optional' designate the optional parameters.
- */
-static void perform(struct args *args, const char *endpoint, const char *operation, uint32_t mandatory, uint32_t optional)
-{
- int post;
- const char *url, *type;
- CURL *curl;
-
- /* set the flags */
- args->mandatory = mandatory;
- args->all = mandatory | optional;
-
- /* get the endpoint */
- url = args_string(args, endpoint);
- if (!url)
- return args_send_error(args, "No endpoint", endpoint);
-
- /* get the operation type */
- if ((mandatory & PARAM(Response_Type)) == PARAM(Response_Type)) {
- type = "response_type";
- post = 0; /* can be 1 sometimes so not risk here */
- } else if ((mandatory & PARAM(Grant_Type)) == PARAM(Grant_Type)) {
- type = "grant_type";
- post = 1; /* must be 1 */
- } else
- return args_send_error(args, "Unexpected operation Type", NULL);
-
- json_object_object_add(args->query, type, json_object_new_string(operation));
-
- /* get the arguments */
- if (1
- && args_add(args, PARAM(Access_Token), "access_token", 1)
- && args_add(args, PARAM(Acr_Values), "acr_values", 1)
- && args_add(args, PARAM(Authorization), "authorization", 0)
- && args_add(args, PARAM(Client_Id), "client_id", 1)
- && args_add(args, PARAM(Client_Secret), "client_secret", 1)
- && args_add(args, PARAM(Code), "code", 1)
- && args_add(args, PARAM(Display), "display", 1)
- && args_add(args, PARAM(Expires_In), "expires_in", 1)
- && args_add(args, PARAM(Id_Token_Hint), "id_token_hint", 1)
- && args_add(args, PARAM(Login_Hint), "login_hint", 1)
- && args_add(args, PARAM(Max_Age), "max_age", 1)
- && args_add(args, PARAM(Nonce), "nonce", 1)
- && args_add(args, PARAM(Password), "password", 1)
- && args_add(args, PARAM(Prompt), "prompt", 1)
- && args_add(args, PARAM(Redirect_Uri), "redirect_uri", 1)
- && args_add(args, PARAM(Refresh_Token), "refresh_token", 1)
- && args_add(args, PARAM(Scope), "scope", 1)
- && args_add(args, PARAM(State), "state", 1)
- && args_add(args, PARAM(Token_Type), "token_type", 1)
- && args_add(args, PARAM(Ui_Locales), "ui_locales", 1)
- && args_add(args, PARAM(Username), "username", 1)
- ) {
- /* creates the curl query */
- curl = curl_json(url, post, args->header, args->query);
- if (!curl)
- return args_send_error(args, "out of memory", NULL);
-
- /* release data */
- args_unlock(args);
-
- /* perform the request to the server */
- curl_wrap_do(curl, perform_callback, args);
- }
-}
-
-/* perform a grant of flow Flow_Resource_Owner_Password_Credentials_Grant */
-static void grant_owner_password(struct args *args)
-{
- perform(args, string_token_endpoint, "password",
- PARAM(Grant_Type) | PARAM(Username) | PARAM(Password),
- PARAM(Scope) | PARAM(Authorization)
- );
-}
-
-/* perform a grant of flow Flow_Client_Credentials_Grant */
-static void grant_client_credentials(struct args *args)
-{
- perform(args, string_token_endpoint, "client_credentials",
- PARAM(Grant_Type),
- PARAM(Scope) | PARAM(Authorization)
- );
-}
-
-/* switches the requests depending on 'flow' */
-static void grant(struct args *args, enum oidc_grant_flow flow)
-{
- /* ensure args is valid */
- if (!args)
- return;
-
- /* process for flow */
- switch(flow) {
-
- case Flow_Resource_Owner_Password_Credentials_Grant:
- grant_owner_password(args);
- break;
-
- case Flow_Client_Credentials_Grant:
- grant_client_credentials(args);
- break;
-
- case Flow_Authorization_Code_Grant:
- case Flow_Implicit_Grant:
- case Flow_Extension_Grant:
- args_send_error(args, "Unsupported flow", NULL);
- break;
-
- case Flow_Invalid:
- default:
- args_send_error(args, "Invalid flow", NULL);
- break;
- }
-}
-
-/*
- * Initiates a grant with the given 'flow'.
- * 'appli' and 'idp' designates the appli and the idp that have been recorded.
- * when idp == NULL or idp == "", the default idp of 'appli' is used.
- * 'args' contains parameters expected in plus for the grant transaction.
- * 'cb' describes the callback actions that are called before
- * the function returns.
- */
-void oidc_grant(const char *appli, const char *idp, struct json_object *args, const struct oidc_grant_cb *cb, enum oidc_grant_flow flow)
-{
- grant(mkargs(appli, idp, args, cb), flow);
-}
-
-/*
- * Like oidc_grant for flow Flow_Resource_Owner_Password_Credentials_Grant
- */
-void oidc_grant_owner_password(const char *appli, const char *idp, struct json_object *args, const struct oidc_grant_cb *cb)
-{
- grant(mkargs(appli, idp, args, cb), Flow_Resource_Owner_Password_Credentials_Grant);
-}
-
-/*
- * Like oidc_grant for flow Flow_Client_Credentials_Grant
- */
-void oidc_grant_client_credentials(const char *appli, const char *idp, struct json_object *args, const struct oidc_grant_cb *cb)
-{
- grant(mkargs(appli, idp, args, cb), Flow_Client_Credentials_Grant);
-}
-
-/*
- * Refreshes the 'token' for the 'appli' and the 'idp'.
- * 'cb' describes the callback actions that are called before
- * the function returns.
- */
-void oidc_token_refresh(const char *appli, const char *idp, struct json_object *token, const struct oidc_grant_cb *cb)
-{
- struct args *args;
-
- args = mkargs(appli, idp, token, cb);
- if (!args)
- return;
- args->refresh = 1;
- perform(args, string_token_endpoint, "refresh_token",
- PARAM(Grant_Type) | PARAM(Refresh_Token),
- PARAM(Scope) | PARAM(Authorization)
- );
-}
-
-/*
- * Adds the header "authorisation" with the bearer access_token of 'token'.
- * Return 1 on case of success or 0 otherwise.
- */
-int oidc_add_bearer(CURL *curl, struct json_object *token)
-{
- struct json_object *bearer;
-
- return json_object_object_get_ex(token, "authorization", &bearer)
- && curl_wrap_add_header_value(curl, "authorization", json_object_get_string(bearer));
-}
-
-
diff --git a/binding/oidc-agent.h b/binding/oidc-agent.h
deleted file mode 100644
index de5918d..0000000
--- a/binding/oidc-agent.h
+++ /dev/null
@@ -1,119 +0,0 @@
-/*
- * Copyright (C) 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#pragma once
-
-struct json_object;
-#include <curl/curl.h>
-
-/***************** IDP **************************/
-
-extern int oidc_idp_set(
- const char *name,
- struct json_object *desc
- );
-
-extern int oidc_idp_exists(
- const char *name
- );
-
-extern void oidc_idp_delete(
- const char *name
- );
-
-
-/***************** APPLI **************************/
-
-extern int oidc_appli_set(
- const char *name,
- const char *idp,
- struct json_object *desc,
- int make_default
- );
-
-extern int oidc_appli_exists(
- const char *name
- );
-
-extern int oidc_appli_has_idp(
- const char *name,
- const char *idp
- );
-
-extern int oidc_appli_set_default_idp(
- const char *name,
- const char *idp
- );
-
-extern void oidc_appli_delete(
- const char *name
- );
-
-/***************** APPLI **************************/
-
-struct oidc_grant_cb
-{
- void *closure;
- void (*success)(void *closure, struct json_object *result);
- void (*error)(void *closure, const char *message, const char *indice);
-};
-
-enum oidc_grant_flow
-{
- Flow_Invalid,
- Flow_Authorization_Code_Grant,
- Flow_Implicit_Grant,
- Flow_Resource_Owner_Password_Credentials_Grant,
- Flow_Client_Credentials_Grant,
- Flow_Extension_Grant
-};
-
-
-extern void oidc_grant(
- const char *appli,
- const char *idp,
- struct json_object *args,
- const struct oidc_grant_cb *cb,
- enum oidc_grant_flow flow
- );
-
-extern void oidc_grant_owner_password(
- const char *appli,
- const char *idp,
- struct json_object *args,
- const struct oidc_grant_cb *cb
- );
-
-extern void oidc_grant_client_credentials(
- const char *appli,
- const char *idp,
- struct json_object *args,
- const struct oidc_grant_cb *cb
- );
-
-extern void oidc_token_refresh(
- const char *appli,
- const char *idp,
- struct json_object *token,
- const struct oidc_grant_cb *cb
- );
-
-extern int oidc_add_bearer(
- CURL *curl,
- struct json_object *token
- );
-
diff --git a/binding/test-aia-uds-bluez.c b/binding/test-aia-uds-bluez.c
deleted file mode 100644
index 4a084a5..0000000
--- a/binding/test-aia-uds-bluez.c
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
- * Author: José Bollo <jose.bollo@iot.bzh>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#define _GNU_SOURCE
-
-#include <stdlib.h>
-#include <stdio.h>
-#include <stdint.h>
-#include <string.h>
-#include <errno.h>
-
-#include <systemd/sd-bus.h>
-
-#include "aia-uds-bluez.h"
-
-
-void p(const char *tag, const struct aia_uds_value *value)
-{
- printf("%10s %c %.*s\n", tag, value->changed?'*':' ', (int)value->length, value->data);
-}
-
-void onchg(const struct aia_uds *uds)
-{
- printf("\n");
- p("first name", &uds->first_name);
- p("last name", &uds->last_name);
- p("email", &uds->email);
- p("language", &uds->language);
-}
-
-int main()
-{
- sd_bus *bus;
- sd_id128_t id;
- int rc;
-
- aia_uds_set_on_change(onchg);
- rc = sd_bus_default_system(&bus);
- rc = sd_id128_randomize(&id);
- rc = sd_bus_set_server(bus, 1, id);
- rc = sd_bus_start(bus);
- rc = aia_uds_init(bus);
- rc = aia_uds_advise(1, NULL, NULL);
- for (;;) {
- rc = sd_bus_process(bus, NULL);
- if (rc < 0)
- break;
- else if (rc == 0)
- rc = sd_bus_wait(bus, (uint64_t) -1);
- }
-}
-