pcrf_json_dbi #1
|
@ -0,0 +1,17 @@
|
|||
[
|
||||
{
|
||||
"id": 4660,
|
||||
"qci": 8,
|
||||
"priority": 5,
|
||||
"pre_emption_capability": 0,
|
||||
"pre_emption_vulnerability": 1,
|
||||
"ambr": {
|
||||
"up": 999,
|
||||
"down": 1000
|
||||
},
|
||||
"gmbr": {
|
||||
"up": 500,
|
||||
"down": 500
|
||||
}
|
||||
}
|
||||
]
|
|
@ -0,0 +1,32 @@
|
|||
[
|
||||
{
|
||||
"id": -1,
|
||||
"qci": 5,
|
||||
"priority": 5,
|
||||
"pre_emption_capability": 0,
|
||||
"pre_emption_vulnerability": 1,
|
||||
"ambr": {
|
||||
"up": 1000,
|
||||
"down": 10000
|
||||
},
|
||||
"gmbr": {
|
||||
"up": 500,
|
||||
"down": 500
|
||||
}
|
||||
},
|
||||
{
|
||||
"id": 4660,
|
||||
"qci": 5,
|
||||
"priority": 5,
|
||||
"pre_emption_capability": 0,
|
||||
"pre_emption_vulnerability": 1,
|
||||
"ambr": {
|
||||
"up": 1000,
|
||||
"down": 10000
|
||||
},
|
||||
"gmbr": {
|
||||
"up": 500,
|
||||
"down": 500
|
||||
}
|
||||
}
|
||||
]
|
|
@ -0,0 +1,55 @@
|
|||
# db_json
|
||||
# allow to use json templates for the policy
|
||||
# a * will be used if the apn isn't defined. it can be omitted.
|
||||
db_json:
|
||||
internet: @sysconfdir@/open5gs/pcrf-internet.json
|
||||
"*": @sysconfdir@/open5gs/pcrf-default.json
|
||||
|
||||
#
|
||||
# logger:
|
||||
#
|
||||
# o Set OGS_LOG_INFO to all domain level
|
||||
# - If `level` is omitted, the default level is OGS_LOG_INFO)
|
||||
# - If `domain` is omitted, the all domain level is set from 'level'
|
||||
# (Nothing is needed)
|
||||
#
|
||||
# o Set OGS_LOG_ERROR to all domain level
|
||||
# - `level` can be set with none, fatal, error, warn, info, debug, trace
|
||||
# level: error
|
||||
#
|
||||
# o Set OGS_LOG_DEBUG to mme/emm domain level
|
||||
# level: debug
|
||||
# domain: mme,emm
|
||||
#
|
||||
# o Set OGS_LOG_TRACE to all domain level
|
||||
# level: trace
|
||||
# domain: core,fd,pcrf,event,mem,sock
|
||||
logger:
|
||||
file: @localstatedir@/log/open5gs/pcrf.log
|
||||
|
||||
pcrf:
|
||||
freeDiameter: @sysconfdir@/freeDiameter/pcrf.conf
|
||||
|
||||
#
|
||||
# parameter:
|
||||
#
|
||||
# o Disable use of IPv4 addresses (only IPv6)
|
||||
# no_ipv4: true
|
||||
#
|
||||
# o Disable use of IPv6 addresses (only IPv4)
|
||||
# no_ipv6: true
|
||||
#
|
||||
# o Prefer IPv4 instead of IPv6 for estabishing new GTP connections.
|
||||
# prefer_ipv4: true
|
||||
#
|
||||
parameter:
|
||||
|
||||
#
|
||||
# max:
|
||||
#
|
||||
# o Maximum Number of UE
|
||||
# ue: 1024
|
||||
# o Maximum Number of Peer(S1AP/NGAP, DIAMETER, GTP, PFCP or SBI)
|
||||
# peer: 64
|
||||
#
|
||||
max:
|
|
@ -252,6 +252,25 @@ int ogs_app_context_parse_config(void)
|
|||
ogs_assert(root_key);
|
||||
if (!strcmp(root_key, "db_uri")) {
|
||||
self.db_uri = ogs_yaml_iter_value(&root_iter);
|
||||
} else if (!strcmp(root_key, "db_json")) {
|
||||
ogs_yaml_iter_t dbjson_iter;
|
||||
ogs_yaml_iter_recurse(&root_iter, &dbjson_iter);
|
||||
int apns = 0;
|
||||
while (ogs_yaml_iter_next(&dbjson_iter)) {
|
||||
const char *apn = ogs_yaml_iter_key(&dbjson_iter);
|
||||
const char *apn_filepath;
|
||||
|
||||
if (apns >= OGS_APP_DB_JSON_MAX_APNS) {
|
||||
ogs_error("db_json: too many apns defined!");
|
||||
return OGS_ERROR;
|
||||
}
|
||||
ogs_assert(apn);
|
||||
apn_filepath = ogs_yaml_iter_value(&dbjson_iter);
|
||||
ogs_assert(apn_filepath);
|
||||
self.db_json[apns].apn = apn;
|
||||
self.db_json[apns].filepath = apn_filepath;
|
||||
apns++;
|
||||
}
|
||||
} else if (!strcmp(root_key, "logger")) {
|
||||
ogs_yaml_iter_t logger_iter;
|
||||
ogs_yaml_iter_recurse(&root_iter, &logger_iter);
|
||||
|
|
|
@ -28,6 +28,8 @@
|
|||
extern "C" {
|
||||
#endif
|
||||
|
||||
#define OGS_APP_DB_JSON_MAX_APNS 16
|
||||
|
||||
typedef struct ogs_app_context_s {
|
||||
const char *version;
|
||||
|
||||
|
@ -35,6 +37,11 @@ typedef struct ogs_app_context_s {
|
|||
void *document;
|
||||
|
||||
const char *db_uri;
|
||||
struct {
|
||||
const char *apn;
|
||||
const char *filepath;
|
||||
} db_json[OGS_APP_DB_JSON_MAX_APNS];
|
||||
|
||||
struct {
|
||||
const char *file;
|
||||
const char *level;
|
||||
|
|
|
@ -0,0 +1,58 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#if !defined(OGS_DBI_INSIDE) && !defined(OGS_DBI_COMPILATION)
|
||||
#error "This header cannot be included directly."
|
||||
#endif
|
||||
|
||||
#ifndef OGS_DBI_PRIVATE_H
|
||||
#define OGS_DBI_PRIVATE_H
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif
|
||||
|
||||
struct ogs_dbi_s {
|
||||
const char *name;
|
||||
void (*final)(void);
|
||||
/* session */
|
||||
int (*session_data)(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
int32_t charging_char, ogs_session_data_t *data);
|
||||
/* ims */
|
||||
int (*msisdn_data)(char *imsi_or_msisdn_bcd, ogs_msisdn_data_t *msisdn_data);
|
||||
int (*ims_data)(char *supi, ogs_ims_data_t *ims_data);
|
||||
/* subscription */
|
||||
int (*auth_info)(char *supi, ogs_dbi_auth_info_t *auth_info);
|
||||
int (*update_sqn)(char *supi, uint64_t sqn);
|
||||
int (*increment_sqn)(char *supi);
|
||||
int (*update_imeisv)(char *supi, char *imeisv);
|
||||
int (*subscription_data)(char *supi,
|
||||
ogs_subscription_data_t *subscription_data);
|
||||
};
|
||||
typedef struct ogs_dbi_s ogs_dbi_t;
|
||||
|
||||
int ogs_dbi_deselect_interface(void);
|
||||
int ogs_dbi_select_interface(const char *dbi_name);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif /* OGS_DBI_PRIVATE_H */
|
|
@ -0,0 +1,144 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
|
||||
#include "dbi-private.h"
|
||||
#include "dbi-config-private.h"
|
||||
|
||||
#ifdef WITH_MONGOC
|
||||
#include "mongo/mongo-private.h"
|
||||
#endif
|
||||
#include "json/json-private.h"
|
||||
|
||||
int __ogs_dbi_domain;
|
||||
|
||||
static ogs_dbi_t *dbi_interfaces[] = {
|
||||
#ifdef WITH_MONGOC
|
||||
&ogs_dbi_mongo_interface,
|
||||
#endif
|
||||
&ogs_dbi_json_interface,
|
||||
NULL,
|
||||
};
|
||||
|
||||
static ogs_dbi_t *dbi_selected;
|
||||
|
||||
int ogs_dbi_deselect_interface()
|
||||
{
|
||||
dbi_selected = NULL;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int ogs_dbi_select_interface(const char *dbi_name)
|
||||
{
|
||||
ogs_dbi_t *dbi;
|
||||
int i;
|
||||
ogs_assert(dbi_name);
|
||||
|
||||
for (i = 0; i < OGS_ARRAY_SIZE(dbi_interfaces); i++) {
|
||||
dbi = dbi_interfaces[i];
|
||||
if (!ogs_strcasecmp(dbi->name, dbi_name)) {
|
||||
dbi_selected = dbi;
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
ogs_error("Couldn't find dbi interface %s", dbi_name);
|
||||
return -1;
|
||||
}
|
||||
|
||||
void ogs_dbi_final(void)
|
||||
{
|
||||
if (!dbi_selected)
|
||||
return;
|
||||
|
||||
dbi_selected->final();
|
||||
}
|
||||
|
||||
/* ims */
|
||||
int ogs_dbi_msisdn_data(
|
||||
char *imsi_or_msisdn_bcd, ogs_msisdn_data_t *msisdn_data)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->msisdn_data)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->msisdn_data(imsi_or_msisdn_bcd, msisdn_data);
|
||||
}
|
||||
|
||||
int ogs_dbi_ims_data(char *supi, ogs_ims_data_t *ims_data)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->ims_data)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->ims_data(supi, ims_data);
|
||||
}
|
||||
|
||||
/* session */
|
||||
int ogs_dbi_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
int32_t charging_char, ogs_session_data_t *session_data)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->session_data)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->session_data(supi, s_nssai, dnn, charging_char, session_data);
|
||||
}
|
||||
|
||||
/* subscription */
|
||||
int ogs_dbi_auth_info(char *supi, ogs_dbi_auth_info_t *auth_info)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->auth_info)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->auth_info(supi, auth_info);
|
||||
}
|
||||
|
||||
int ogs_dbi_update_sqn(char *supi, uint64_t sqn)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->update_sqn)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->update_sqn(supi, sqn);
|
||||
}
|
||||
|
||||
int ogs_dbi_increment_sqn(char *supi)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->increment_sqn)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->increment_sqn(supi);
|
||||
}
|
||||
|
||||
int ogs_dbi_update_imeisv(char *supi, char *imeisv)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->update_imeisv)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->update_imeisv(supi, imeisv);
|
||||
}
|
||||
|
||||
int ogs_dbi_subscription_data(char *supi,
|
||||
ogs_subscription_data_t *subscription_data)
|
||||
{
|
||||
ogs_assert(dbi_selected);
|
||||
if (!dbi_selected->subscription_data)
|
||||
return OGS_ERROR;
|
||||
return dbi_selected->subscription_data(supi, subscription_data);
|
||||
}
|
File diff suppressed because it is too large
Load Diff
|
@ -0,0 +1,300 @@
|
|||
/*
|
||||
Copyright (c) 2009-2017 Dave Gamble and cJSON contributors
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in
|
||||
all copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
THE SOFTWARE.
|
||||
*/
|
||||
|
||||
#ifndef cJSON__h
|
||||
#define cJSON__h
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C"
|
||||
{
|
||||
#endif
|
||||
|
||||
#if !defined(__WINDOWS__) && (defined(WIN32) || defined(WIN64) || defined(_MSC_VER) || defined(_WIN32))
|
||||
#define __WINDOWS__
|
||||
#endif
|
||||
|
||||
#ifdef __WINDOWS__
|
||||
|
||||
/* When compiling for windows, we specify a specific calling convention to avoid issues where we are being called from a project with a different default calling convention. For windows you have 3 define options:
|
||||
|
||||
CJSON_HIDE_SYMBOLS - Define this in the case where you don't want to ever dllexport symbols
|
||||
CJSON_EXPORT_SYMBOLS - Define this on library build when you want to dllexport symbols (default)
|
||||
CJSON_IMPORT_SYMBOLS - Define this if you want to dllimport symbol
|
||||
|
||||
For *nix builds that support visibility attribute, you can define similar behavior by
|
||||
|
||||
setting default visibility to hidden by adding
|
||||
-fvisibility=hidden (for gcc)
|
||||
or
|
||||
-xldscope=hidden (for sun cc)
|
||||
to CFLAGS
|
||||
|
||||
then using the CJSON_API_VISIBILITY flag to "export" the same symbols the way CJSON_EXPORT_SYMBOLS does
|
||||
|
||||
*/
|
||||
|
||||
#define CJSON_CDECL __cdecl
|
||||
#define CJSON_STDCALL __stdcall
|
||||
|
||||
/* export symbols by default, this is necessary for copy pasting the C and header file */
|
||||
#if !defined(CJSON_HIDE_SYMBOLS) && !defined(CJSON_IMPORT_SYMBOLS) && !defined(CJSON_EXPORT_SYMBOLS)
|
||||
#define CJSON_EXPORT_SYMBOLS
|
||||
#endif
|
||||
|
||||
#if defined(CJSON_HIDE_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) type CJSON_STDCALL
|
||||
#elif defined(CJSON_EXPORT_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) __declspec(dllexport) type CJSON_STDCALL
|
||||
#elif defined(CJSON_IMPORT_SYMBOLS)
|
||||
#define CJSON_PUBLIC(type) __declspec(dllimport) type CJSON_STDCALL
|
||||
#endif
|
||||
#else /* !__WINDOWS__ */
|
||||
#define CJSON_CDECL
|
||||
#define CJSON_STDCALL
|
||||
|
||||
#if (defined(__GNUC__) || defined(__SUNPRO_CC) || defined (__SUNPRO_C)) && defined(CJSON_API_VISIBILITY)
|
||||
#define CJSON_PUBLIC(type) __attribute__((visibility("default"))) type
|
||||
#else
|
||||
#define CJSON_PUBLIC(type) type
|
||||
#endif
|
||||
#endif
|
||||
|
||||
/* project version */
|
||||
#define CJSON_VERSION_MAJOR 1
|
||||
#define CJSON_VERSION_MINOR 7
|
||||
#define CJSON_VERSION_PATCH 15
|
||||
|
||||
#include <stddef.h>
|
||||
|
||||
/* cJSON Types: */
|
||||
#define cJSON_Invalid (0)
|
||||
#define cJSON_False (1 << 0)
|
||||
#define cJSON_True (1 << 1)
|
||||
#define cJSON_NULL (1 << 2)
|
||||
#define cJSON_Number (1 << 3)
|
||||
#define cJSON_String (1 << 4)
|
||||
#define cJSON_Array (1 << 5)
|
||||
#define cJSON_Object (1 << 6)
|
||||
#define cJSON_Raw (1 << 7) /* raw json */
|
||||
|
||||
#define cJSON_IsReference 256
|
||||
#define cJSON_StringIsConst 512
|
||||
|
||||
/* The cJSON structure: */
|
||||
typedef struct cJSON
|
||||
{
|
||||
/* next/prev allow you to walk array/object chains. Alternatively, use GetArraySize/GetArrayItem/GetObjectItem */
|
||||
struct cJSON *next;
|
||||
struct cJSON *prev;
|
||||
/* An array or object item will have a child pointer pointing to a chain of the items in the array/object. */
|
||||
struct cJSON *child;
|
||||
|
||||
/* The type of the item, as above. */
|
||||
int type;
|
||||
|
||||
/* The item's string, if type==cJSON_String and type == cJSON_Raw */
|
||||
char *valuestring;
|
||||
/* writing to valueint is DEPRECATED, use cJSON_SetNumberValue instead */
|
||||
int valueint;
|
||||
/* The item's number, if type==cJSON_Number */
|
||||
double valuedouble;
|
||||
|
||||
/* The item's name string, if this item is the child of, or is in the list of subitems of an object. */
|
||||
char *string;
|
||||
} cJSON;
|
||||
|
||||
typedef struct cJSON_Hooks
|
||||
{
|
||||
/* malloc/free are CDECL on Windows regardless of the default calling convention of the compiler, so ensure the hooks allow passing those functions directly. */
|
||||
void *(CJSON_CDECL *malloc_fn)(size_t sz);
|
||||
void (CJSON_CDECL *free_fn)(void *ptr);
|
||||
} cJSON_Hooks;
|
||||
|
||||
typedef int cJSON_bool;
|
||||
|
||||
/* Limits how deeply nested arrays/objects can be before cJSON rejects to parse them.
|
||||
* This is to prevent stack overflows. */
|
||||
#ifndef CJSON_NESTING_LIMIT
|
||||
#define CJSON_NESTING_LIMIT 1000
|
||||
#endif
|
||||
|
||||
/* returns the version of cJSON as a string */
|
||||
CJSON_PUBLIC(const char*) cJSON_Version(void);
|
||||
|
||||
/* Supply malloc, realloc and free functions to cJSON */
|
||||
CJSON_PUBLIC(void) cJSON_InitHooks(cJSON_Hooks* hooks);
|
||||
|
||||
/* Memory Management: the caller is always responsible to free the results from all variants of cJSON_Parse (with cJSON_Delete) and cJSON_Print (with stdlib free, cJSON_Hooks.free_fn, or cJSON_free as appropriate). The exception is cJSON_PrintPreallocated, where the caller has full responsibility of the buffer. */
|
||||
/* Supply a block of JSON, and this returns a cJSON object you can interrogate. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_Parse(const char *value);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithLength(const char *value, size_t buffer_length);
|
||||
/* ParseWithOpts allows you to require (and check) that the JSON is null terminated, and to retrieve the pointer to the final byte parsed. */
|
||||
/* If you supply a ptr in return_parse_end and parsing fails, then return_parse_end will contain a pointer to the error so will match cJSON_GetErrorPtr(). */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithOpts(const char *value, const char **return_parse_end, cJSON_bool require_null_terminated);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_ParseWithLengthOpts(const char *value, size_t buffer_length, const char **return_parse_end, cJSON_bool require_null_terminated);
|
||||
|
||||
/* Render a cJSON entity to text for transfer/storage. */
|
||||
CJSON_PUBLIC(char *) cJSON_Print(const cJSON *item);
|
||||
/* Render a cJSON entity to text for transfer/storage without any formatting. */
|
||||
CJSON_PUBLIC(char *) cJSON_PrintUnformatted(const cJSON *item);
|
||||
/* Render a cJSON entity to text using a buffered strategy. prebuffer is a guess at the final size. guessing well reduces reallocation. fmt=0 gives unformatted, =1 gives formatted */
|
||||
CJSON_PUBLIC(char *) cJSON_PrintBuffered(const cJSON *item, int prebuffer, cJSON_bool fmt);
|
||||
/* Render a cJSON entity to text using a buffer already allocated in memory with given length. Returns 1 on success and 0 on failure. */
|
||||
/* NOTE: cJSON is not always 100% accurate in estimating how much memory it will use, so to be safe allocate 5 bytes more than you actually need */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_PrintPreallocated(cJSON *item, char *buffer, const int length, const cJSON_bool format);
|
||||
/* Delete a cJSON entity and all subentities. */
|
||||
CJSON_PUBLIC(void) cJSON_Delete(cJSON *item);
|
||||
|
||||
/* Returns the number of items in an array (or object). */
|
||||
CJSON_PUBLIC(int) cJSON_GetArraySize(const cJSON *array);
|
||||
/* Retrieve item number "index" from array "array". Returns NULL if unsuccessful. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetArrayItem(const cJSON *array, int index);
|
||||
/* Get item "string" from object. Case insensitive. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetObjectItem(const cJSON * const object, const char * const string);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_GetObjectItemCaseSensitive(const cJSON * const object, const char * const string);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_HasObjectItem(const cJSON *object, const char *string);
|
||||
/* For analysing failed parses. This returns a pointer to the parse error. You'll probably need to look a few chars back to make sense of it. Defined when cJSON_Parse() returns 0. 0 when cJSON_Parse() succeeds. */
|
||||
CJSON_PUBLIC(const char *) cJSON_GetErrorPtr(void);
|
||||
|
||||
/* Check item type and return its value */
|
||||
CJSON_PUBLIC(char *) cJSON_GetStringValue(const cJSON * const item);
|
||||
CJSON_PUBLIC(double) cJSON_GetNumberValue(const cJSON * const item);
|
||||
|
||||
/* These functions check the type of an item */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsInvalid(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsFalse(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsTrue(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsBool(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsNull(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsNumber(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsString(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsArray(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsObject(const cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_IsRaw(const cJSON * const item);
|
||||
|
||||
/* These calls create a cJSON item of the appropriate type. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateNull(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateTrue(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateFalse(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateBool(cJSON_bool boolean);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateNumber(double num);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateString(const char *string);
|
||||
/* raw json */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateRaw(const char *raw);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateArray(void);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateObject(void);
|
||||
|
||||
/* Create a string where valuestring references a string so
|
||||
* it will not be freed by cJSON_Delete */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateStringReference(const char *string);
|
||||
/* Create an object/array that only references it's elements so
|
||||
* they will not be freed by cJSON_Delete */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateObjectReference(const cJSON *child);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateArrayReference(const cJSON *child);
|
||||
|
||||
/* These utilities create an Array of count items.
|
||||
* The parameter count cannot be greater than the number of elements in the number array, otherwise array access will be out of bounds.*/
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateIntArray(const int *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateFloatArray(const float *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateDoubleArray(const double *numbers, int count);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_CreateStringArray(const char *const *strings, int count);
|
||||
|
||||
/* Append item to the specified array/object. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToArray(cJSON *array, cJSON *item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToObject(cJSON *object, const char *string, cJSON *item);
|
||||
/* Use this when string is definitely const (i.e. a literal, or as good as), and will definitely survive the cJSON object.
|
||||
* WARNING: When this function was used, make sure to always check that (item->type & cJSON_StringIsConst) is zero before
|
||||
* writing to `item->string` */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemToObjectCS(cJSON *object, const char *string, cJSON *item);
|
||||
/* Append reference to item to the specified array/object. Use this when you want to add an existing cJSON to a new cJSON, but don't want to corrupt your existing cJSON. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemReferenceToArray(cJSON *array, cJSON *item);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_AddItemReferenceToObject(cJSON *object, const char *string, cJSON *item);
|
||||
|
||||
/* Remove/Detach items from Arrays/Objects. */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemViaPointer(cJSON *parent, cJSON * const item);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromArray(cJSON *array, int which);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromArray(cJSON *array, int which);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromObject(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(cJSON *) cJSON_DetachItemFromObjectCaseSensitive(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromObject(cJSON *object, const char *string);
|
||||
CJSON_PUBLIC(void) cJSON_DeleteItemFromObjectCaseSensitive(cJSON *object, const char *string);
|
||||
|
||||
/* Update array items. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_InsertItemInArray(cJSON *array, int which, cJSON *newitem); /* Shifts pre-existing items to the right. */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemViaPointer(cJSON * const parent, cJSON * const item, cJSON * replacement);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInArray(cJSON *array, int which, cJSON *newitem);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInObject(cJSON *object,const char *string,cJSON *newitem);
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_ReplaceItemInObjectCaseSensitive(cJSON *object,const char *string,cJSON *newitem);
|
||||
|
||||
/* Duplicate a cJSON item */
|
||||
CJSON_PUBLIC(cJSON *) cJSON_Duplicate(const cJSON *item, cJSON_bool recurse);
|
||||
/* Duplicate will create a new, identical cJSON item to the one you pass, in new memory that will
|
||||
* need to be released. With recurse!=0, it will duplicate any children connected to the item.
|
||||
* The item->next and ->prev pointers are always zero on return from Duplicate. */
|
||||
/* Recursively compare two cJSON items for equality. If either a or b is NULL or invalid, they will be considered unequal.
|
||||
* case_sensitive determines if object keys are treated case sensitive (1) or case insensitive (0) */
|
||||
CJSON_PUBLIC(cJSON_bool) cJSON_Compare(const cJSON * const a, const cJSON * const b, const cJSON_bool case_sensitive);
|
||||
|
||||
/* Minify a strings, remove blank characters(such as ' ', '\t', '\r', '\n') from strings.
|
||||
* The input pointer json cannot point to a read-only address area, such as a string constant,
|
||||
* but should point to a readable and writable address area. */
|
||||
CJSON_PUBLIC(void) cJSON_Minify(char *json);
|
||||
|
||||
/* Helper functions for creating and adding items to an object at the same time.
|
||||
* They return the added item or NULL on failure. */
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddNullToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddTrueToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddFalseToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddBoolToObject(cJSON * const object, const char * const name, const cJSON_bool boolean);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddNumberToObject(cJSON * const object, const char * const name, const double number);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddStringToObject(cJSON * const object, const char * const name, const char * const string);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddRawToObject(cJSON * const object, const char * const name, const char * const raw);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddObjectToObject(cJSON * const object, const char * const name);
|
||||
CJSON_PUBLIC(cJSON*) cJSON_AddArrayToObject(cJSON * const object, const char * const name);
|
||||
|
||||
/* When assigning an integer value, it needs to be propagated to valuedouble too. */
|
||||
#define cJSON_SetIntValue(object, number) ((object) ? (object)->valueint = (object)->valuedouble = (number) : (number))
|
||||
/* helper for the cJSON_SetNumberValue macro */
|
||||
CJSON_PUBLIC(double) cJSON_SetNumberHelper(cJSON *object, double number);
|
||||
#define cJSON_SetNumberValue(object, number) ((object != NULL) ? cJSON_SetNumberHelper(object, (double)number) : (number))
|
||||
/* Change the valuestring of a cJSON_String object, only takes effect when type of object is cJSON_String */
|
||||
CJSON_PUBLIC(char*) cJSON_SetValuestring(cJSON *object, const char *valuestring);
|
||||
|
||||
/* If the object is not a boolean type this does nothing and returns cJSON_Invalid else it returns the new type*/
|
||||
#define cJSON_SetBoolValue(object, boolValue) ( \
|
||||
(object != NULL && ((object)->type & (cJSON_False|cJSON_True))) ? \
|
||||
(object)->type=((object)->type &(~(cJSON_False|cJSON_True)))|((boolValue)?cJSON_True:cJSON_False) : \
|
||||
cJSON_Invalid\
|
||||
)
|
||||
|
||||
/* Macro for iterating over an array or object */
|
||||
#define cJSON_ArrayForEach(element, array) for(element = (array != NULL) ? (array)->child : NULL; element != NULL; element = element->next)
|
||||
|
||||
/* malloc/free objects using the malloc/free functions that have been set with cJSON_InitHooks */
|
||||
CJSON_PUBLIC(void *) cJSON_malloc(size_t size);
|
||||
CJSON_PUBLIC(void) cJSON_free(void *object);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif
|
|
@ -0,0 +1,40 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#if !defined(OGS_DBI_INSIDE) && !defined(OGS_DBI_COMPILATION)
|
||||
#error "This header cannot be included directly."
|
||||
#endif
|
||||
|
||||
#ifndef OGS_DBI_JSON_PRIVATE_H
|
||||
#define OGS_DBI_JSON_PRIVATE_H
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif
|
||||
|
||||
#include "dbi-private.h"
|
||||
|
||||
extern ogs_dbi_t ogs_dbi_json_interface;
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif /* OGS_DBI_JSON_PRIVATE_H */
|
|
@ -0,0 +1,417 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
#include "json-private.h"
|
||||
|
||||
#include <cjson/cJSON.h>
|
||||
|
||||
#define MAX_DB_PROFILES 256
|
||||
#define MAX_DB_APNS 10
|
||||
typedef struct ogs_json_apn_profile_s {
|
||||
int32_t id;
|
||||
ogs_qos_t qos;
|
||||
bool valid;
|
||||
} ogs_json_apn_profile_t;
|
||||
|
||||
typedef struct ogs_json_apn_s {
|
||||
char *apn;
|
||||
ogs_json_apn_profile_t profiles[MAX_DB_PROFILES];
|
||||
ogs_bitrate_t ambr; /* APN-AMBR */
|
||||
bool valid;
|
||||
} ogs_json_apn_t;
|
||||
|
||||
ogs_json_apn_t g_apns[MAX_DB_APNS];
|
||||
|
||||
static ogs_json_apn_profile_t *ogs_dbi_static_alloc_db_entry(ogs_json_apn_t *db_apn)
|
||||
{
|
||||
int i = 0;
|
||||
ogs_assert(db_apn);
|
||||
ogs_json_apn_profile_t *entry;
|
||||
|
||||
for (i = 0; i < MAX_DB_PROFILES; i++) {
|
||||
entry = &db_apn->profiles[i];
|
||||
if (entry->valid)
|
||||
continue;
|
||||
|
||||
return entry;
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static ogs_json_apn_profile_t *ogs_dbi_static_get_apn_profile(ogs_json_apn_t *db_apn, int profile_id)
|
||||
{
|
||||
int i = 0;
|
||||
ogs_assert(db_apn);
|
||||
|
||||
for (i = 0; i < MAX_DB_PROFILES; i++) {
|
||||
ogs_json_apn_profile_t *entry = &db_apn->profiles[i];
|
||||
if (!entry->valid)
|
||||
continue;
|
||||
|
||||
if (entry->id != profile_id)
|
||||
continue;
|
||||
|
||||
return entry;
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static ogs_json_apn_t *ogs_dbi_static_get_apn(const char *apn)
|
||||
{
|
||||
int i;
|
||||
for (i = 0; i < MAX_DB_APNS; i++) {
|
||||
ogs_json_apn_t *entry = &g_apns[i];
|
||||
if (!entry->valid)
|
||||
continue;
|
||||
|
||||
if (!ogs_strcasecmp(entry->apn, apn))
|
||||
return entry;
|
||||
}
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
static ogs_json_apn_t *ogs_dbi_static_alloc_apn(void)
|
||||
{
|
||||
int i = 0;
|
||||
ogs_json_apn_t *apn;
|
||||
|
||||
for (i = 0; i < MAX_DB_APNS; i++) {
|
||||
apn = &g_apns[i];
|
||||
if (apn->valid)
|
||||
continue;
|
||||
|
||||
return apn;
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static int cjson_get_uint64_t(const cJSON * const top, const char *item_chr, int required, uint64_t min, uint64_t max, uint64_t *value)
|
||||
{
|
||||
uint64_t number;
|
||||
|
||||
ogs_assert(value);
|
||||
|
||||
cJSON *item = cJSON_GetObjectItem(top, item_chr);
|
||||
if (!item) {
|
||||
if (!required)
|
||||
return 0;
|
||||
|
||||
ogs_error("Could not find mandatory field %s\n", item_chr);
|
||||
return -ENOENT;
|
||||
}
|
||||
|
||||
if (!cJSON_IsNumber(item)) {
|
||||
ogs_error("Invalid value for %s. It must be a number!\n", item_chr);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
number = cJSON_GetNumberValue(item);
|
||||
if (!(min <= number && number <= max)) {
|
||||
ogs_error("Invalid value for %s: %ld. It must be %ld <= x <= %ld\n", item_chr, number, min, max);
|
||||
return -ERANGE;
|
||||
}
|
||||
|
||||
*value = number;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int cjson_get_int(const cJSON * const top, const char *item_chr, int required, int min, int max, int *value)
|
||||
{
|
||||
int number;
|
||||
|
||||
ogs_assert(value);
|
||||
|
||||
cJSON *item = cJSON_GetObjectItem(top, item_chr);
|
||||
if (!item) {
|
||||
if (!required)
|
||||
return 0;
|
||||
|
||||
ogs_error("Could not find mandatory field %s\n", item_chr);
|
||||
return -ENOENT;
|
||||
}
|
||||
|
||||
if (!cJSON_IsNumber(item)) {
|
||||
ogs_error("Invalid value for %s. It must be a number!\n", item_chr);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
number = cJSON_GetNumberValue(item);
|
||||
if (!(min <= number && number <= max)) {
|
||||
ogs_error("Invalid value for %s: %d. It must be %d <= x <= %d\n", item_chr, number, min, max);
|
||||
return -ERANGE;
|
||||
}
|
||||
|
||||
*value = number;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int get_bandwidth(cJSON *top, const char *mbr, ogs_bitrate_t *bitrate)
|
||||
{
|
||||
int ret;
|
||||
ogs_assert(mbr);
|
||||
ogs_assert(top);
|
||||
ogs_assert(bitrate);
|
||||
|
||||
cJSON *obj = cJSON_GetObjectItem(top, mbr);
|
||||
if (!obj)
|
||||
return 0;
|
||||
|
||||
if (!cJSON_IsObject(obj)) {
|
||||
ogs_error("%s has the wrong type. It is not an object!\n", mbr);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
/* TODO: this will break close to 2 gbit */
|
||||
ret = cjson_get_uint64_t(obj, "up", 0, 0, UINT64_MAX, &bitrate->uplink);
|
||||
if (ret)
|
||||
return ret;
|
||||
|
||||
ret = cjson_get_uint64_t(obj, "down", 0, 0, UINT32_MAX, &bitrate->downlink);
|
||||
if (ret)
|
||||
return ret;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int ogs_dbi_json_init(const char *filepath, const char *apn)
|
||||
{
|
||||
int ret = 0;
|
||||
long filesize = -1;
|
||||
ssize_t mem_read;
|
||||
ogs_json_apn_t *db_apn = ogs_dbi_static_get_apn(apn);
|
||||
FILE *filefp;
|
||||
char *buf = NULL;
|
||||
int profile_id;
|
||||
|
||||
ogs_dbi_select_interface("json");
|
||||
|
||||
if (db_apn) {
|
||||
return -EALREADY;
|
||||
}
|
||||
|
||||
filefp = fopen(filepath, "r");
|
||||
if (!filefp) {
|
||||
return -ENOENT;
|
||||
}
|
||||
|
||||
if (fseek(filefp, 0L, SEEK_END) < 0) {
|
||||
ret = -ENOENT;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
filesize = ftell(filefp);
|
||||
if (filesize < 0) {
|
||||
ret = -ENOENT;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
buf = ogs_malloc(filesize);
|
||||
if (!buf) {
|
||||
ret = -ENOMEM;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
if (fseek(filefp, 0L, SEEK_SET) < 0) {
|
||||
ret = -ENOENT;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
mem_read = fread(buf, filesize, 1, filefp);
|
||||
if (mem_read != 1 && !feof(filefp)) {
|
||||
ret = -1;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
cJSON *profiles = cJSON_ParseWithLength(buf, filesize);
|
||||
if (!profiles) {
|
||||
const char *error_ptr = cJSON_GetErrorPtr();
|
||||
if (error_ptr != NULL)
|
||||
{
|
||||
ogs_error("Error before: %s\n", error_ptr);
|
||||
}
|
||||
|
||||
ret = -1;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
if (!cJSON_IsArray(profiles)) {
|
||||
ogs_error("Profile root object must be an array");
|
||||
ret = -2;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
db_apn = ogs_dbi_static_alloc_apn();
|
||||
if (!db_apn) {
|
||||
ogs_error("Too many APNs\n");
|
||||
ret = -ENOENT;
|
||||
goto fail;
|
||||
}
|
||||
memset(db_apn, '\0', sizeof(*db_apn));
|
||||
db_apn->apn = ogs_strdup(apn);
|
||||
db_apn->valid = 1;
|
||||
|
||||
cJSON *profile;
|
||||
cJSON_ArrayForEach(profile, profiles) {
|
||||
int number;
|
||||
ogs_json_apn_profile_t *entry;
|
||||
|
||||
ret = cjson_get_int(profile, "id", 1, 0, 65535, &profile_id);
|
||||
if (ret)
|
||||
goto fail;
|
||||
|
||||
entry = ogs_dbi_static_get_apn_profile(db_apn, profile_id);
|
||||
if (entry) {
|
||||
ogs_error("Doublicated profile with id %d\n", profile_id);
|
||||
ret = -1;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
entry = ogs_dbi_static_alloc_db_entry(db_apn);
|
||||
if (!entry) {
|
||||
ogs_error("Tooo many db entries for apn %s\n", apn);
|
||||
ret = -1;
|
||||
goto fail;
|
||||
}
|
||||
|
||||
ogs_info("Loading json profile for apn: \"%s\" / charging id \"%d\"", apn, profile_id);
|
||||
entry->id = profile_id;
|
||||
|
||||
ret = cjson_get_int(profile, "qci", 1, 0, 16, &number);
|
||||
if (ret)
|
||||
goto fail;
|
||||
|
||||
entry->qos.index = number & 0xff;
|
||||
ret = get_bandwidth(profile, "ambr", &entry->qos.mbr);
|
||||
if (ret)
|
||||
goto fail;
|
||||
|
||||
ret = get_bandwidth(profile, "gbr", &entry->qos.gbr);
|
||||
if (ret)
|
||||
goto fail;
|
||||
|
||||
/* TODO: check boundary check for fields */
|
||||
ret = cjson_get_int(profile, "priority", 1, 0, 15, &number);
|
||||
if (ret)
|
||||
goto fail;
|
||||
entry->qos.arp.priority_level = number & 0xff;
|
||||
|
||||
ret = cjson_get_int(profile, "pre_emption_capability", 1, 0, 1, &number);
|
||||
if (ret)
|
||||
goto fail;
|
||||
if (number)
|
||||
entry->qos.arp.pre_emption_capability = OGS_5GC_PRE_EMPTION_ENABLED;
|
||||
else
|
||||
entry->qos.arp.pre_emption_capability = OGS_5GC_PRE_EMPTION_DISABLED;
|
||||
|
||||
ret = cjson_get_int(profile, "pre_emption_vulnerability", 1, 0, 1, &number);
|
||||
if (ret)
|
||||
goto fail;
|
||||
if (number)
|
||||
entry->qos.arp.pre_emption_vulnerability = OGS_5GC_PRE_EMPTION_ENABLED;
|
||||
else
|
||||
entry->qos.arp.pre_emption_vulnerability = OGS_5GC_PRE_EMPTION_DISABLED;
|
||||
entry->valid = true;
|
||||
}
|
||||
|
||||
if (profiles)
|
||||
cJSON_Delete(profiles);
|
||||
|
||||
if (buf)
|
||||
ogs_free(buf);
|
||||
|
||||
return 0;
|
||||
|
||||
fail:
|
||||
if (db_apn->apn)
|
||||
ogs_free(db_apn->apn);
|
||||
|
||||
if (profiles)
|
||||
cJSON_Delete(profiles);
|
||||
|
||||
if (buf)
|
||||
ogs_free(buf);
|
||||
|
||||
fclose(filefp);
|
||||
return ret;
|
||||
}
|
||||
|
||||
static int json_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
int32_t charging_char, ogs_session_data_t *session_data)
|
||||
{
|
||||
ogs_session_t *session = &session_data->session;
|
||||
ogs_json_apn_profile_t *profile;
|
||||
ogs_json_apn_t *db_apn = ogs_dbi_static_get_apn(dnn);
|
||||
|
||||
if (!db_apn)
|
||||
db_apn = ogs_dbi_static_get_apn("*");
|
||||
|
||||
if (!db_apn) {
|
||||
ogs_error("Couldn't find a profile for dnn (%s)", dnn);
|
||||
return OGS_ERROR;
|
||||
}
|
||||
|
||||
profile = ogs_dbi_static_get_apn_profile(db_apn, charging_char);
|
||||
/* try default profile */
|
||||
if (!profile && charging_char != -1)
|
||||
profile = ogs_dbi_static_get_apn_profile(db_apn, -1);
|
||||
|
||||
if (!profile) {
|
||||
ogs_error("Couldn't find a profile for dnn (%s) with charging characteristic %d", dnn, charging_char);
|
||||
return OGS_ERROR;
|
||||
}
|
||||
|
||||
session->name = ogs_strndup("json_profile", strlen("json_profile"));
|
||||
/* FIXME: the ambr shouldn't be qos.mbr, instead it should be from apn.ambr, but neither PCRF nor PCEF support it this way */
|
||||
session->ambr = profile->qos.mbr;
|
||||
session->qos = profile->qos;
|
||||
|
||||
return OGS_OK;
|
||||
}
|
||||
|
||||
static void json_final(void) {
|
||||
int i;
|
||||
for (i = 0; i < MAX_DB_APNS; i++) {
|
||||
ogs_json_apn_t *db_apn = &g_apns[i];
|
||||
if (!db_apn->valid)
|
||||
continue;
|
||||
db_apn->valid = 0;
|
||||
|
||||
if (db_apn->apn) {
|
||||
ogs_free(db_apn->apn);
|
||||
db_apn->apn = NULL;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
ogs_dbi_t ogs_dbi_json_interface = {
|
||||
.name = "json",
|
||||
/* session */
|
||||
.session_data = json_session_data,
|
||||
.final = json_final,
|
||||
};
|
||||
|
|
@ -15,30 +15,67 @@
|
|||
# You should have received a copy of the GNU General Public License
|
||||
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
|
||||
libdbi_sources = files('''
|
||||
libdbi_conf = configuration_data()
|
||||
libdbi_deps = [libcrypt_dep]
|
||||
|
||||
dbi_sources = files('''
|
||||
ogs-dbi.h
|
||||
dbi.c
|
||||
'''.split())
|
||||
libdbi_sources = [dbi_sources]
|
||||
|
||||
ogs-mongoc.h
|
||||
|
||||
ogs-mongoc.c
|
||||
subscription.c
|
||||
session.c
|
||||
ims.c
|
||||
mongo_sources = files('''
|
||||
mongo/ogs-mongoc.h
|
||||
mongo/ogs-mongoc.c
|
||||
mongo/subscription.c
|
||||
mongo/session.c
|
||||
mongo/ims.c
|
||||
'''.split())
|
||||
|
||||
libmongoc_dep = dependency('libmongoc-1.0')
|
||||
without_mongo_sources = files('''
|
||||
mongo/dummy.c
|
||||
mongo/ogs-mongoc.h
|
||||
'''.split())
|
||||
|
||||
json_sources = files('''
|
||||
json/json.c
|
||||
external/cjson/cJSON.c
|
||||
'''.split())
|
||||
libdbi_sources += [json_sources]
|
||||
cjson_inc = include_directories('./external/')
|
||||
|
||||
mongodb_optval = get_option('mongodb')
|
||||
if mongodb_optval
|
||||
libmongoc_dep = dependency('libmongoc-1.0', required: true)
|
||||
if libmongoc_dep.found()
|
||||
libdbi_conf.set('WITH_MONGOC', 1)
|
||||
libdbi_sources += [mongo_sources]
|
||||
libdbi_deps += [libmongoc_dep]
|
||||
endif
|
||||
else
|
||||
libdbi_sources += [without_mongo_sources]
|
||||
endif
|
||||
|
||||
configure_file(output : 'dbi-config-private.h', configuration : libdbi_conf)
|
||||
|
||||
libdbi_inc = include_directories('.')
|
||||
|
||||
dbi_cc_flags = ['-DOGS_DBI_COMPILATION']
|
||||
if cc.get_id() == 'gcc' or cc.get_id() == 'clang'
|
||||
dbi_cc_flags += cc.get_supported_arguments([
|
||||
'-Wno-float-equal',
|
||||
])
|
||||
endif
|
||||
|
||||
libdbi = library('ogsdbi',
|
||||
sources : libdbi_sources,
|
||||
version : libogslib_version,
|
||||
c_args : '-DOGS_DBI_COMPILATION',
|
||||
include_directories : [libdbi_inc, libinc],
|
||||
dependencies : [libcrypt_dep, libmongoc_dep],
|
||||
c_args : dbi_cc_flags,
|
||||
include_directories : [libdbi_inc, libinc, cjson_inc],
|
||||
dependencies : libdbi_deps,
|
||||
install : true)
|
||||
|
||||
libdbi_dep = declare_dependency(
|
||||
link_with : libdbi,
|
||||
include_directories : [libdbi_inc, libinc],
|
||||
dependencies : [libcrypt_dep, libmongoc_dep])
|
||||
dependencies : libdbi_deps)
|
||||
|
|
|
@ -0,0 +1,48 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
/* This file will be used when build without mongodb support to support the old api */
|
||||
#include "ogs-dbi.h"
|
||||
|
||||
int ogs_dbi_init(const char *db_uri)
|
||||
{
|
||||
return -ENODEV;
|
||||
}
|
||||
|
||||
int ogs_dbi_mongo_init(const char *db_uri)
|
||||
{
|
||||
return -ENODEV;
|
||||
}
|
||||
|
||||
int ogs_mongoc_init(const char *db_uri)
|
||||
{
|
||||
return -ENODEV;
|
||||
}
|
||||
|
||||
void ogs_mongoc_final(void)
|
||||
{
|
||||
}
|
||||
|
||||
ogs_mongoc_t *ogs_mongoc(void)
|
||||
{
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
|
@ -17,9 +17,12 @@
|
|||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
#include <mongoc.h>
|
||||
|
||||
int ogs_dbi_msisdn_data(
|
||||
#include "ogs-dbi.h"
|
||||
#include "mongo-private.h"
|
||||
|
||||
int ogs_dbi_mongo_msisdn_data(
|
||||
char *imsi_or_msisdn_bcd, ogs_msisdn_data_t *msisdn_data)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
|
@ -117,7 +120,7 @@ out:
|
|||
return rv;
|
||||
}
|
||||
|
||||
int ogs_dbi_ims_data(char *supi, ogs_ims_data_t *ims_data)
|
||||
int ogs_dbi_mongo_ims_data(char *supi, ogs_ims_data_t *ims_data)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
mongoc_cursor_t *cursor = NULL;
|
|
@ -0,0 +1,57 @@
|
|||
/*
|
||||
* Copyright (C) 2022 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
|
||||
* Author: Alexander Couzens <lynxis@fe80.eu>
|
||||
*
|
||||
* This file is part of Open5GS.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#if !defined(OGS_DBI_INSIDE) && !defined(OGS_DBI_COMPILATION)
|
||||
#error "This header cannot be included directly."
|
||||
#endif
|
||||
|
||||
#ifndef OGS_DBI_MONGO_PRIVATE_H
|
||||
#define OGS_DBI_MONGO_PRIVATE_H
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif
|
||||
|
||||
#include "dbi-private.h"
|
||||
|
||||
extern ogs_dbi_t ogs_dbi_mongo_interface;
|
||||
|
||||
/* ims */
|
||||
int ogs_dbi_mongo_msisdn_data(
|
||||
char *imsi_or_msisdn_bcd, ogs_msisdn_data_t *msisdn_data);
|
||||
int ogs_dbi_mongo_ims_data(char *supi, ogs_ims_data_t *ims_data);
|
||||
|
||||
/* session */
|
||||
int ogs_dbi_mongo_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
int32_t charging_char, ogs_session_data_t *session_data);
|
||||
|
||||
/* subscription */
|
||||
int ogs_dbi_mongo_auth_info(char *supi, ogs_dbi_auth_info_t *auth_info);
|
||||
int ogs_dbi_mongo_update_sqn(char *supi, uint64_t sqn);
|
||||
int ogs_dbi_mongo_update_imeisv(char *supi, char *imeisv);
|
||||
int ogs_dbi_mongo_increment_sqn(char *supi);
|
||||
int ogs_dbi_mongo_subscription_data(char *supi,
|
||||
ogs_subscription_data_t *subscription_data);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif /* OGS_DBI_MONGO_PRIVATE_H */
|
|
@ -20,8 +20,8 @@
|
|||
#include <mongoc.h>
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
|
||||
int __ogs_dbi_domain;
|
||||
#include "dbi-private.h"
|
||||
#include "mongo-private.h"
|
||||
|
||||
static ogs_mongoc_t self;
|
||||
|
||||
|
@ -134,6 +134,10 @@ int ogs_mongoc_init(const char *db_uri)
|
|||
|
||||
void ogs_mongoc_final(void)
|
||||
{
|
||||
if (self.collection.subscriber) {
|
||||
mongoc_collection_destroy(self.collection.subscriber);
|
||||
}
|
||||
|
||||
if (self.database) {
|
||||
mongoc_database_destroy(self.database);
|
||||
self.database = NULL;
|
||||
|
@ -158,11 +162,34 @@ ogs_mongoc_t *ogs_mongoc(void)
|
|||
return &self;
|
||||
}
|
||||
|
||||
ogs_dbi_t ogs_dbi_mongo_interface = {
|
||||
.name = "mongo",
|
||||
/* final */
|
||||
.final = ogs_mongoc_final,
|
||||
/* session */
|
||||
.session_data = ogs_dbi_mongo_session_data,
|
||||
/* ims */
|
||||
.msisdn_data = ogs_dbi_mongo_msisdn_data,
|
||||
.ims_data = ogs_dbi_mongo_ims_data,
|
||||
/* subscription */
|
||||
.auth_info = ogs_dbi_mongo_auth_info,
|
||||
.update_sqn = ogs_dbi_mongo_update_sqn,
|
||||
.increment_sqn = ogs_dbi_mongo_increment_sqn,
|
||||
.update_imeisv = ogs_dbi_mongo_update_imeisv,
|
||||
.subscription_data = ogs_dbi_mongo_subscription_data,
|
||||
};
|
||||
|
||||
int ogs_dbi_init(const char *db_uri)
|
||||
{
|
||||
return ogs_dbi_mongo_init(db_uri);
|
||||
}
|
||||
|
||||
int ogs_dbi_mongo_init(const char *db_uri)
|
||||
{
|
||||
int rv;
|
||||
|
||||
ogs_assert(db_uri);
|
||||
ogs_dbi_select_interface("mongo");
|
||||
|
||||
rv = ogs_mongoc_init(db_uri);
|
||||
if (rv != OGS_OK) return rv;
|
||||
|
@ -173,14 +200,6 @@ int ogs_dbi_init(const char *db_uri)
|
|||
ogs_assert(self.collection.subscriber);
|
||||
}
|
||||
|
||||
|
||||
return OGS_OK;
|
||||
}
|
||||
|
||||
void ogs_dbi_final()
|
||||
{
|
||||
if (self.collection.subscriber) {
|
||||
mongoc_collection_destroy(self.collection.subscriber);
|
||||
}
|
||||
|
||||
ogs_mongoc_final();
|
||||
}
|
|
@ -24,8 +24,6 @@
|
|||
#ifndef OGS_MONGOC_H
|
||||
#define OGS_MONGOC_H
|
||||
|
||||
#include <mongoc.h>
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif /* __cplusplus */
|
||||
|
@ -49,6 +47,7 @@ void ogs_mongoc_final(void);
|
|||
ogs_mongoc_t *ogs_mongoc(void);
|
||||
|
||||
int ogs_dbi_init(const char *db_uri);
|
||||
int ogs_dbi_mongo_init(const char *db_uri);
|
||||
void ogs_dbi_final(void);
|
||||
|
||||
#ifdef __cplusplus
|
|
@ -17,10 +17,13 @@
|
|||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
#include <mongoc.h>
|
||||
|
||||
int ogs_dbi_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
ogs_session_data_t *session_data)
|
||||
#include "ogs-dbi.h"
|
||||
#include "mongo-private.h"
|
||||
|
||||
int ogs_dbi_mongo_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
int32_t charging_char, ogs_session_data_t *session_data)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
mongoc_cursor_t *cursor = NULL;
|
|
@ -17,9 +17,12 @@
|
|||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "ogs-dbi.h"
|
||||
#include <mongoc.h>
|
||||
|
||||
int ogs_dbi_auth_info(char *supi, ogs_dbi_auth_info_t *auth_info)
|
||||
#include "ogs-dbi.h"
|
||||
#include "mongo-private.h"
|
||||
|
||||
int ogs_dbi_mongo_auth_info(char *supi, ogs_dbi_auth_info_t *auth_info)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
mongoc_cursor_t *cursor = NULL;
|
||||
|
@ -109,7 +112,7 @@ out:
|
|||
return rv;
|
||||
}
|
||||
|
||||
int ogs_dbi_update_sqn(char *supi, uint64_t sqn)
|
||||
int ogs_dbi_mongo_update_sqn(char *supi, uint64_t sqn)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
bson_t *query = NULL;
|
||||
|
@ -148,7 +151,7 @@ int ogs_dbi_update_sqn(char *supi, uint64_t sqn)
|
|||
return rv;
|
||||
}
|
||||
|
||||
int ogs_dbi_update_imeisv(char *supi, char *imeisv)
|
||||
int ogs_dbi_mongo_update_imeisv(char *supi, char *imeisv)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
bson_t *query = NULL;
|
||||
|
@ -189,7 +192,7 @@ int ogs_dbi_update_imeisv(char *supi, char *imeisv)
|
|||
return rv;
|
||||
}
|
||||
|
||||
int ogs_dbi_increment_sqn(char *supi)
|
||||
int ogs_dbi_mongo_increment_sqn(char *supi)
|
||||
{
|
||||
int rv = OGS_OK;
|
||||
bson_t *query = NULL;
|
||||
|
@ -243,7 +246,7 @@ out:
|
|||
return rv;
|
||||
}
|
||||
|
||||
int ogs_dbi_subscription_data(char *supi,
|
||||
int ogs_dbi_mongo_subscription_data(char *supi,
|
||||
ogs_subscription_data_t *subscription_data)
|
||||
{
|
||||
int rv = OGS_OK;
|
|
@ -24,7 +24,9 @@
|
|||
|
||||
#define OGS_DBI_INSIDE
|
||||
|
||||
#include "dbi/ogs-mongoc.h"
|
||||
/* TODO: remove ogs-mongoc.h as soon the test cases don't depend on it */
|
||||
#include "dbi/mongo/ogs-mongoc.h"
|
||||
|
||||
#include "dbi/subscription.h"
|
||||
#include "dbi/session.h"
|
||||
#include "dbi/ims.h"
|
||||
|
@ -37,6 +39,9 @@ extern "C" {
|
|||
|
||||
extern int __ogs_dbi_domain;
|
||||
|
||||
/* can be called multiple times for every apn */
|
||||
int ogs_dbi_json_init(const char *filepath, const char *apn);
|
||||
|
||||
#undef OGS_LOG_DOMAIN
|
||||
#define OGS_LOG_DOMAIN __ogs_dbi_domain
|
||||
|
||||
|
|
|
@ -28,8 +28,10 @@
|
|||
extern "C" {
|
||||
#endif
|
||||
|
||||
#define OGS_DBI_NO_CHARGING_CHAR -1
|
||||
|
||||
int ogs_dbi_session_data(char *supi, ogs_s_nssai_t *s_nssai, char *dnn,
|
||||
ogs_session_data_t *session_data);
|
||||
int32_t charging_char, ogs_session_data_t *session_data);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
|
|
|
@ -120,7 +120,8 @@ subdir('lib')
|
|||
subdir('src')
|
||||
subdir('misc')
|
||||
# Don't build the tests unless we can run them (either natively or in an exe wrapper)
|
||||
build_tests = not meson.is_cross_build() or (meson.is_cross_build() and meson.has_exe_wrapper())
|
||||
# tests also depend on mongodb
|
||||
build_tests = get_option('mongodb') and (not meson.is_cross_build() or (meson.is_cross_build() and meson.has_exe_wrapper()))
|
||||
if build_tests
|
||||
subdir('tests')
|
||||
endif
|
||||
|
|
|
@ -1 +1,2 @@
|
|||
option('metrics_impl', type : 'combo', choices : ['void', 'prometheus'], value : 'void', description : 'libogsmetrics implementation')
|
||||
option('mongodb', type : 'boolean', value : 'true', description : 'build with mongodb support')
|
||||
|
|
|
@ -123,7 +123,8 @@ bool pcf_nbsf_management_handle_register(
|
|||
ogs_sbi_header_free(&header);
|
||||
|
||||
rv = ogs_dbi_session_data(
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, &session_data);
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, OGS_DBI_NO_CHARGING_CHAR,
|
||||
&session_data);
|
||||
if (rv != OGS_OK) {
|
||||
strerror = ogs_msprintf("[%s:%d] Cannot find SUPI in DB",
|
||||
pcf_ue->supi, sess->psi);
|
||||
|
|
|
@ -567,7 +567,7 @@ bool pcf_npcf_policyauthorization_handle_create(pcf_sess_t *sess,
|
|||
|
||||
memset(&session_data, 0, sizeof(ogs_session_data_t));
|
||||
rv = ogs_dbi_session_data(
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, &session_data);
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, OGS_DBI_NO_CHARGING_CHAR, &session_data);
|
||||
if (rv != OGS_OK) {
|
||||
strerror = ogs_msprintf("[%s:%d] Cannot find SUPI in DB",
|
||||
pcf_ue->supi, sess->psi);
|
||||
|
@ -980,7 +980,8 @@ bool pcf_npcf_policyauthorization_handle_update(
|
|||
|
||||
memset(&session_data, 0, sizeof(ogs_session_data_t));
|
||||
rv = ogs_dbi_session_data(
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, &session_data);
|
||||
pcf_ue->supi, &sess->s_nssai, sess->dnn, OGS_DBI_NO_CHARGING_CHAR,
|
||||
&session_data);
|
||||
if (rv != OGS_OK) {
|
||||
strerror = ogs_msprintf("[%s:%d] Cannot find SUPI in DB",
|
||||
pcf_ue->supi, sess->psi);
|
||||
|
|
|
@ -267,7 +267,7 @@ int pcrf_context_parse_config(void)
|
|||
}
|
||||
|
||||
int pcrf_db_qos_data(
|
||||
char *imsi_bcd, char *apn, ogs_session_data_t *session_data)
|
||||
char *imsi_bcd, char *apn, int32_t charging_char, ogs_session_data_t *session_data)
|
||||
{
|
||||
int rv, i;
|
||||
char *supi = NULL;
|
||||
|
@ -281,7 +281,9 @@ int pcrf_db_qos_data(
|
|||
ogs_assert(supi);
|
||||
|
||||
/* For EPC, we'll use [S_NSSAI = NULL] */
|
||||
rv = ogs_dbi_session_data(supi, NULL, apn, session_data);
|
||||
rv = ogs_dbi_session_data(supi, NULL, apn, charging_char, session_data);
|
||||
if (rv)
|
||||
goto fail;
|
||||
|
||||
/* For EPC, we need to inialize Flow-Status in Pcc-Rule */
|
||||
for (i = 0; i < session_data->num_of_pcc_rule; i++) {
|
||||
|
@ -292,6 +294,11 @@ int pcrf_db_qos_data(
|
|||
ogs_free(supi);
|
||||
ogs_thread_mutex_unlock(&self.db_lock);
|
||||
|
||||
return 0;
|
||||
|
||||
fail:
|
||||
ogs_thread_mutex_unlock(&self.db_lock);
|
||||
ogs_free(supi);
|
||||
return rv;
|
||||
}
|
||||
|
||||
|
|
|
@ -54,7 +54,7 @@ pcrf_context_t *pcrf_self(void);
|
|||
int pcrf_context_parse_config(void);
|
||||
|
||||
int pcrf_db_qos_data(char *imsi_bcd, char *apn,
|
||||
ogs_session_data_t *session_data);
|
||||
int32_t charging_char, ogs_session_data_t *session_data);
|
||||
|
||||
void pcrf_sess_set_ipv4(const void *key, uint8_t *sid);
|
||||
void pcrf_sess_set_ipv6(const void *key, uint8_t *sid);
|
||||
|
|
|
@ -39,11 +39,13 @@ struct sess_state {
|
|||
char *imsi_bcd;
|
||||
char *apn;
|
||||
|
||||
ED3(uint8_t ipv4:1;,
|
||||
ED4(uint8_t ipv4:1;,
|
||||
uint8_t ipv6:1;,
|
||||
uint8_t reserved:6;)
|
||||
uint8_t charging:1;,
|
||||
uint8_t reserved:5;)
|
||||
uint32_t addr; /* Framed-IPv4-Address */
|
||||
uint8_t addr6[OGS_IPV6_LEN]; /* Framed-IPv6-Prefix */
|
||||
int32_t charging_chr;
|
||||
|
||||
ogs_list_t rx_list;
|
||||
|
||||
|
@ -352,6 +354,23 @@ static int pcrf_gx_ccr_cb( struct msg **msg, struct avp *avp,
|
|||
sess_data->ipv6 = 1;
|
||||
}
|
||||
|
||||
/* Get 3GPP-Charging-Characteristics */
|
||||
sess_data->charging_chr = -1;
|
||||
ret = fd_msg_search_avp(qry, ogs_diam_gx_3gpp_charging_characteristics, &avp);
|
||||
ogs_assert(ret == 0);
|
||||
if (avp) {
|
||||
ret = fd_msg_avp_hdr(avp, &hdr);
|
||||
ogs_assert(ret == 0);
|
||||
char charging_bin[OGS_CHRGCHARS_LEN];
|
||||
memcpy(charging_bin,
|
||||
OGS_HEX(hdr->avp_value->os.data, (int)hdr->avp_value->os.len, charging_bin), OGS_CHRGCHARS_LEN);
|
||||
if (hdr->avp_value->os.len == 1)
|
||||
sess_data->charging_chr = charging_bin[0];
|
||||
else
|
||||
sess_data->charging_chr = charging_bin[0] << 8 | charging_bin[1];
|
||||
sess_data->charging = 1;
|
||||
}
|
||||
|
||||
/* Get IMSI + APN */
|
||||
ret = fd_msg_search_avp(qry, ogs_diam_subscription_id, &avp);
|
||||
ogs_assert(ret == 0);
|
||||
|
@ -416,10 +435,10 @@ static int pcrf_gx_ccr_cb( struct msg **msg, struct avp *avp,
|
|||
|
||||
/* Retrieve QoS Data from Database */
|
||||
rv = pcrf_db_qos_data(
|
||||
sess_data->imsi_bcd, sess_data->apn, &gx_message.session_data);
|
||||
sess_data->imsi_bcd, sess_data->apn, sess_data->charging_chr, &gx_message.session_data);
|
||||
if (rv != OGS_OK) {
|
||||
ogs_error("Cannot get data for IMSI(%s)+APN(%s)'",
|
||||
sess_data->imsi_bcd, sess_data->apn);
|
||||
ogs_error("Cannot get data for IMSI(%s)+APN(%s)+ChargingChr(%d)'",
|
||||
sess_data->imsi_bcd, sess_data->apn, sess_data->charging_chr);
|
||||
result_code = OGS_DIAM_UNKNOWN_SESSION_ID;
|
||||
goto out;
|
||||
}
|
||||
|
@ -725,7 +744,7 @@ int pcrf_gx_send_rar(
|
|||
|
||||
/* Retrieve QoS Data from Database */
|
||||
rv = pcrf_db_qos_data(
|
||||
sess_data->imsi_bcd, sess_data->apn, &gx_message.session_data);
|
||||
sess_data->imsi_bcd, sess_data->apn, sess_data->charging_chr, &gx_message.session_data);
|
||||
if (rv != OGS_OK) {
|
||||
ogs_error("Cannot get data for IMSI(%s)+APN(%s)'",
|
||||
sess_data->imsi_bcd, sess_data->apn);
|
||||
|
|
|
@ -35,8 +35,21 @@ int pcrf_initialize(void)
|
|||
ogs_app()->logger.domain, ogs_app()->logger.level);
|
||||
if (rv != OGS_OK) return rv;
|
||||
|
||||
rv = ogs_dbi_init(ogs_app()->db_uri);
|
||||
if (ogs_app()->db_uri) {
|
||||
rv = ogs_dbi_mongo_init(ogs_app()->db_uri);
|
||||
if (rv != OGS_OK) return rv;
|
||||
} else if (ogs_app()->db_json[0].apn) {
|
||||
int i;
|
||||
for (i = 0; i < OGS_APP_DB_JSON_MAX_APNS; i++) {
|
||||
if (ogs_app()->db_json[i].apn && ogs_app()->db_json[i].filepath) {
|
||||
rv = ogs_dbi_json_init(ogs_app()->db_json[i].filepath, ogs_app()->db_json[i].apn);
|
||||
if (rv != OGS_OK) return rv;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
ogs_error("No database selected!");
|
||||
return OGS_ERROR;
|
||||
}
|
||||
|
||||
rv = pcrf_fd_init();
|
||||
if (rv != OGS_OK) return OGS_ERROR;
|
||||
|
|
|
@ -17,6 +17,8 @@
|
|||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include <mongoc.h>
|
||||
|
||||
#include "test-config-private.h"
|
||||
#include "test-common.h"
|
||||
|
||||
|
|
|
@ -24,6 +24,8 @@
|
|||
#ifndef TEST_COMMON_CONTEXT_H
|
||||
#define TEST_COMMON_CONTEXT_H
|
||||
|
||||
#include <mongoc.h>
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif
|
||||
|
|
Loading…
Reference in New Issue