session: start to manage concurrency
[src/app-framework-binder.git] / src / afb-context.c
1 /*
2  * Copyright (C) 2015, 2016, 2017 "IoT.bzh"
3  * Author "Fulup Ar Foll"
4  * Author José Bollo <jose.bollo@iot.bzh>
5  *
6  * Licensed under the Apache License, Version 2.0 (the "License");
7  * you may not use this file except in compliance with the License.
8  * You may obtain a copy of the License at
9  *
10  *   http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18
19 #define _GNU_SOURCE
20
21 #include <assert.h>
22 #include <stdlib.h>
23 #include <stdint.h>
24
25 #include "afb-session.h"
26 #include "afb-context.h"
27
28 static void init_context(struct afb_context *context, struct afb_session *session, const char *token)
29 {
30         assert(session != NULL);
31
32         /* reset the context for the session */
33         context->session = session;
34         context->flags = 0;
35         context->super = NULL;
36         context->api_key = NULL;
37
38         /* check the token */
39         if (token != NULL) {
40                 if (afb_session_check_token(session, token))
41                         context->validated = 1;
42                 else
43                         context->invalidated = 1;
44         }
45 }
46
47 void afb_context_init(struct afb_context *context, struct afb_session *session, const char *token)
48 {
49         init_context(context, afb_session_addref(session), token);
50 }
51
52 void afb_context_subinit(struct afb_context *context, struct afb_context *super)
53 {
54         *context = *super;
55         context->super = super;
56 }
57
58 int afb_context_connect(struct afb_context *context, const char *uuid, const char *token)
59 {
60         int created;
61         struct afb_session *session;
62
63         session = afb_session_get (uuid, &created);
64         if (session == NULL)
65                 return -1;
66         init_context(context, session, token);
67         if (created) {
68                 context->created = 1;
69                 /* context->refreshing = 1; */
70         }
71         return 0;
72 }
73
74 void afb_context_disconnect(struct afb_context *context)
75 {
76         if (context->session && !context->super) {
77                 if (context->refreshing && !context->refreshed) {
78                         afb_session_new_token (context->session);
79                         context->refreshed = 1;
80                 }
81                 if (context->closing && !context->closed) {
82                         afb_session_close(context->session);
83                         context->closed = 1;
84                 }
85                 afb_session_unref(context->session);
86                 context->session = NULL;
87         }
88 }
89
90 const char *afb_context_sent_token(struct afb_context *context)
91 {
92         if (context->session == NULL || context->closing || context->super)
93                 return NULL;
94         if (!context->refreshing)
95                 return NULL;
96         if (!context->refreshed) {
97                 afb_session_new_token (context->session);
98                 context->refreshed = 1;
99         }
100         return afb_session_token(context->session);
101 }
102
103 const char *afb_context_sent_uuid(struct afb_context *context)
104 {
105         if (context->session == NULL || context->closing || context->super)
106                 return NULL;
107         if (!context->created)
108                 return NULL;
109         return afb_session_uuid(context->session);
110 }
111
112 void *afb_context_data(struct afb_context *context, void *(*make_value)(void), void (*free_value)(void*))
113 {
114         assert(context->session != NULL);
115         return afb_session_cookie(context->session, context->api_key, make_value, free_value);
116 }
117
118 void *afb_context_get(struct afb_context *context)
119 {
120         assert(context->session != NULL);
121         return afb_session_get_cookie(context->session, context->api_key);
122 }
123
124 void afb_context_set(struct afb_context *context, void *value, void (*free_value)(void*))
125 {
126         int rc;
127         assert(context->session != NULL);
128         rc = afb_session_set_cookie(context->session, context->api_key, value, free_value);
129         (void)rc; /* TODO */
130 }
131
132 void afb_context_close(struct afb_context *context)
133 {
134         if (context->super)
135                 afb_context_close(context->super);
136         else
137                 context->closing = 1;
138 }
139
140 void afb_context_refresh(struct afb_context *context)
141 {
142         if (context->super)
143                 afb_context_refresh(context->super);
144         else {
145                 assert(context->validated);
146                 context->refreshing = 1;
147         }
148 }
149
150 int afb_context_check(struct afb_context *context)
151 {
152         if (context->super)
153                 return afb_context_check(context);
154         return context->validated;
155 }
156
157 int afb_context_check_loa(struct afb_context *context, unsigned loa)
158 {
159         return afb_context_get_loa(context) >= loa;
160 }
161
162 static inline void *loa_key(struct afb_context *context)
163 {
164         return (void*)(1+(intptr_t)(context->api_key));
165 }
166
167 static inline void *loa2ptr(unsigned loa)
168 {
169         return (void*)(intptr_t)loa;
170 }
171
172 static inline unsigned ptr2loa(void *ptr)
173 {
174         return (unsigned)(intptr_t)ptr;
175 }
176
177 int afb_context_change_loa(struct afb_context *context, unsigned loa)
178 {
179         if (!context->validated || loa > 7)
180                 return 0;
181
182         return 0 <= afb_session_set_cookie(context->session, loa_key(context), loa2ptr(loa), NULL);
183 }
184
185 unsigned afb_context_get_loa(struct afb_context *context)
186 {
187         assert(context->session != NULL);
188         return ptr2loa(afb_session_get_cookie(context->session, loa_key(context)));
189 }
190
191