diff options
Diffstat (limited to 'database')
| -rw-r--r-- | database/eurephiadb-driver_template.c | 22 | ||||
| -rw-r--r-- | database/sqlite/eurephiadb-sqlite.c | 22 |
2 files changed, 44 insertions, 0 deletions
diff --git a/database/eurephiadb-driver_template.c b/database/eurephiadb-driver_template.c index d237c00..21ef986 100644 --- a/database/eurephiadb-driver_template.c +++ b/database/eurephiadb-driver_template.c @@ -935,3 +935,25 @@ char *eDBget_firewall_profile(eurephiaCTX *ctx, eurephiaSESSION *session) /* FREE SQL RESULT */ return ret; } + +eurephiaVALUES *eDBget_blacklisted_ip(eurephiaCTX *ctx) { + eurephiaVALUES *ret = NULL; + + DEBUG(ctx, 20, "Function call: eDBget_blacklisted_ip(ctx)"); + + /* WORK TO DO -- DO SQL: + SELECT remoteip FROM openvpn_blacklist + */ + if( /* IF SQL QUERY FAILED */ ) { + eurephia_log(ctx, LOG_FATAL, 0, + "Could not retrieve blacklisted IP addresses from the database"); + return NULL; + } + ret = eCreate_value_space(ctx, 21); + for( /* LOOP THROUGH ALL RECORDS */ ) { + eAdd_value(ctx, ret, /* GET remoteip FROM SQL RESULT */, NULL); + } + /* FREE SQL RESULT */ + + return ret; +} diff --git a/database/sqlite/eurephiadb-sqlite.c b/database/sqlite/eurephiadb-sqlite.c index 644815f..4bc61f4 100644 --- a/database/sqlite/eurephiadb-sqlite.c +++ b/database/sqlite/eurephiadb-sqlite.c @@ -873,3 +873,25 @@ char *eDBget_firewall_profile(eurephiaCTX *ctx, eurephiaSESSION *session) sqlite_free_results(res); return ret; } + +eurephiaVALUES *eDBget_blacklisted_ip(eurephiaCTX *ctx) { + eurephiaVALUES *ret = NULL; + dbresult *res = NULL; + int i = 0; + + DEBUG(ctx, 20, "Function call: eDBget_blacklisted_ip(ctx)"); + + res = sqlite_query(ctx, "SELECT remoteip FROM openvpn_blacklist"); + if( res == NULL ) { + eurephia_log(ctx, LOG_FATAL, 0, + "Could not retrieve blacklisted IP addresses from the database"); + return NULL; + } + ret = eCreate_value_space(ctx, 21); + for( i = 0; i < sqlite_get_numtuples(res); i++ ) { + eAdd_value(ctx, ret, sqlite_get_value(res, i, 0), NULL); + } + sqlite_free_results(res); + + return ret; +} |