Refactoring requests and context handling

Also adds a first (untested) implmentation of
the afb services over dbus.

Change-Id: Id1bdeccf75f3a70d3658bdaf0510d6e7b97f6c32
Signed-off-by: José Bollo <jose.bollo@iot.bzh>

1 files changed, 122 insertions, 0 deletions

diff --git a/src/afb-context.c b/src/afb-context.c
new file mode 100644
index 00000000..2f391dec
--- /dev/null
+++ b/src/afb-context.c
@@ -0,0 +1,122 @@
+/*
+ * Copyright (C) 2015 "IoT.bzh"
+ * Author "Fulup Ar Foll"
+ *
+ * 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 <assert.h>
+#include <stdlib.h>
+
+#include "session.h"
+#include "afb-context.h"
+
+
+void afb_context_init(struct afb_context *context, struct AFB_clientCtx *session, const char *token)
+{
+	assert(session != NULL);
+
+	/* reset the context for the session */
+	context->session = session;
+	context->flags = 0;
+	context->api_index = -1;
+
+	/* check the token */
+	if (token != NULL) {
+		if (ctxTokenCheck(session, token))
+			context->validated = 1;
+		else
+			context->invalidated = 1;
+	}
+}
+
+int afb_context_connect(struct afb_context *context, const char *uuid, const char *token)
+{
+	int created;
+	struct AFB_clientCtx *session;
+
+	session = ctxClientGetSession (uuid, &created);
+	if (session == NULL)
+		return -1;
+	afb_context_init(context, session, token);
+	if (created)
+		context->created = 1;
+	return 0;
+}
+
+void afb_context_disconnect(struct afb_context *context)
+{
+	if (context->session != NULL) {
+		if (context->closing && !context->closed) {
+			context->closed = 1;
+			ctxClientClose(context->session);
+		}
+		ctxClientUnref(context->session);
+	}
+}
+
+const char *afb_context_sent_token(struct afb_context *context)
+{
+	if (context->session == NULL || context->closing)
+		return NULL;
+	if (!(context->created || context->refreshing))
+		return NULL;
+	if (!context->refreshed) {
+		ctxTokenNew (context->session);
+		context->refreshed = 1;
+	}
+	return ctxClientGetToken(context->session);
+}
+
+const char *afb_context_sent_uuid(struct afb_context *context)
+{
+	if (context->session == NULL || context->closing)
+		return NULL;
+	if (!context->created)
+		return NULL;
+	return ctxClientGetUuid(context->session);
+}
+
+void *afb_context_get(struct afb_context *context)
+{
+	assert(context->session != NULL);
+	return ctxClientValueGet(context->session, context->api_index);
+}
+
+void afb_context_set(struct afb_context *context, void *value, void (*free_value)(void*))
+{
+	assert(context->session != NULL);
+	return ctxClientValueSet(context->session, context->api_index, value, free_value);
+}
+
+void afb_context_close(struct afb_context *context)
+{
+	context->closing = 1;
+}
+
+void afb_context_refresh(struct afb_context *context)
+{
+	context->refreshing = 1;
+}
+
+int afb_context_check(struct afb_context *context)
+{
+	return context->validated;
+}
+
+int afb_context_create(struct afb_context *context)
+{
+	return context->created;
+}