Skip to content

Commit

Permalink
db2_ldap: clang-format for coherent indentation and coding style
Browse files Browse the repository at this point in the history
  • Loading branch information
linuxmaniac committed May 18, 2023
1 parent 4940fd2 commit 4f10a61
Show file tree
Hide file tree
Showing 13 changed files with 1,306 additions and 1,213 deletions.
295 changes: 134 additions & 161 deletions src/modules/db2_ldap/db2_ldap_mod.c
Expand Up @@ -59,156 +59,124 @@ MODULE_VERSION
/*
* LDAP module interface
*/
static cmd_export_t cmds[] = {
{"db_ctx", (cmd_function)NULL, 0, 0, 0, 0},
{"db_con", (cmd_function)ld_con, 0, 0, 0, 0},
{"db_uri", (cmd_function)ld_uri, 0, 0, 0, 0},
{"db_cmd", (cmd_function)ld_cmd, 0, 0, 0, 0},
{"db_put", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_del", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_get", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_upd", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_sql", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_res", (cmd_function)ld_res, 0, 0, 0, 0},
{"db_fld", (cmd_function)ld_fld, 0, 0, 0, 0},
{"db_first", (cmd_function)ld_cmd_first, 0, 0, 0, 0},
{"db_next", (cmd_function)ld_cmd_next, 0, 0, 0, 0},
{"db_setopt", (cmd_function)ld_cmd_setopt, 0, 0, 0, 0},
{"db_getopt", (cmd_function)NULL, 0, 0, 0, 0},
{0, 0, 0, 0, 0, 0}
};
static cmd_export_t cmds[] = {{"db_ctx", (cmd_function)NULL, 0, 0, 0, 0},
{"db_con", (cmd_function)ld_con, 0, 0, 0, 0},
{"db_uri", (cmd_function)ld_uri, 0, 0, 0, 0},
{"db_cmd", (cmd_function)ld_cmd, 0, 0, 0, 0},
{"db_put", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_del", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_get", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_upd", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_sql", (cmd_function)ld_cmd_exec, 0, 0, 0, 0},
{"db_res", (cmd_function)ld_res, 0, 0, 0, 0},
{"db_fld", (cmd_function)ld_fld, 0, 0, 0, 0},
{"db_first", (cmd_function)ld_cmd_first, 0, 0, 0, 0},
{"db_next", (cmd_function)ld_cmd_next, 0, 0, 0, 0},
{"db_setopt", (cmd_function)ld_cmd_setopt, 0, 0, 0, 0},
{"db_getopt", (cmd_function)NULL, 0, 0, 0, 0}, {0, 0, 0, 0, 0, 0}};


/*
* Exported parameters
*/
static param_export_t params[] = {
{"config", PARAM_STR, &ld_cfg_file},
{"reconnect_attempt", PARAM_INT, &ld_reconnect_attempt},
{0, 0, 0}
};
static param_export_t params[] = {{"config", PARAM_STR, &ld_cfg_file},
{"reconnect_attempt", PARAM_INT, &ld_reconnect_attempt}, {0, 0, 0}};


struct module_exports exports = {
"db2_ldap", /* module name */
DEFAULT_DLFLAGS, /* dlopen flags */
cmds, /* cmd (cfg function) exports */
params, /* param exports */
0, /* RPC method exports */
0, /* pseudo-variables exports */
0, /* response handling function */
ld_mod_init, /* module init function */
0, /* per-child init function */
ld_mod_destroy /* module destroy function */
"db2_ldap", /* module name */
DEFAULT_DLFLAGS, /* dlopen flags */
cmds, /* cmd (cfg function) exports */
params, /* param exports */
0, /* RPC method exports */
0, /* pseudo-variables exports */
0, /* response handling function */
ld_mod_init, /* module init function */
0, /* per-child init function */
ld_mod_destroy /* module destroy function */
};


#ifdef LD_TEST
int ldap_test(void)
{
int i, row;
db_ctx_t* db;
db_cmd_t* put, *del, *get;
db_res_t* result;
db_rec_t* rec;
char* times;

db_fld_t int_vals[] = {
{.name = "col_bool", .type = DB_INT},
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_inet", .type = DB_INT},
{.name = "col_timestamp", .type = DB_INT},
{.name = "col_bit", .type = DB_INT},
{.name = "col_varbit", .type = DB_INT},
{.name = NULL}
};

db_fld_t datetime_vals[] = {
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_timestamp", .type = DB_INT},
{.name = NULL}
};


db_fld_t bitmap_vals[] = {
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_bit", .type = DB_INT},
{.name = "col_varbit", .type = DB_INT},
{.name = NULL}
};

db_fld_t float_vals[] = {
{.name = "col_float4", .type = DB_FLOAT},
{.name = "col_float8", .type = DB_FLOAT},
{.name = NULL}
};
db_ctx_t *db;
db_cmd_t *put, *del, *get;
db_res_t *result;
db_rec_t *rec;
char *times;

db_fld_t int_vals[] = {{.name = "col_bool", .type = DB_INT},
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_inet", .type = DB_INT},
{.name = "col_timestamp", .type = DB_INT},
{.name = "col_bit", .type = DB_INT},
{.name = "col_varbit", .type = DB_INT}, {.name = NULL}};

db_fld_t datetime_vals[] = {{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_timestamp", .type = DB_INT}, {.name = NULL}};


db_fld_t bitmap_vals[] = {{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_bit", .type = DB_INT},
{.name = "col_varbit", .type = DB_INT}, {.name = NULL}};

db_fld_t float_vals[] = {{.name = "col_float4", .type = DB_FLOAT},
{.name = "col_float8", .type = DB_FLOAT}, {.name = NULL}};

db_fld_t double_vals[] = {
{.name = "col_float8", .type = DB_DOUBLE},
{.name = NULL}
};

db_fld_t str_vals[] = {
{.name = "col_varchar", .type = DB_STR},
{.name = "col_bytea", .type = DB_STR},
{.name = "col_text", .type = DB_STR},
{.name = "col_bpchar", .type = DB_STR},
{.name = "col_char", .type = DB_STR},
{.name = NULL}
};

db_fld_t cstr_vals[] = {
{.name = "col_varchar", .type = DB_CSTR},
{.name = "col_bytea", .type = DB_CSTR},
{.name = "col_text", .type = DB_CSTR},
{.name = "col_bpchar", .type = DB_CSTR},
{.name = "col_char", .type = DB_CSTR},
{.name = NULL}
};
{.name = "col_float8", .type = DB_DOUBLE}, {.name = NULL}};

db_fld_t str_vals[] = {{.name = "col_varchar", .type = DB_STR},
{.name = "col_bytea", .type = DB_STR},
{.name = "col_text", .type = DB_STR},
{.name = "col_bpchar", .type = DB_STR},
{.name = "col_char", .type = DB_STR}, {.name = NULL}};

db_fld_t cstr_vals[] = {{.name = "col_varchar", .type = DB_CSTR},
{.name = "col_bytea", .type = DB_CSTR},
{.name = "col_text", .type = DB_CSTR},
{.name = "col_bpchar", .type = DB_CSTR},
{.name = "col_char", .type = DB_CSTR}, {.name = NULL}};

db_fld_t blob_vals[] = {
{.name = "col_bytea", .type = DB_BLOB},
{.name = NULL}
};


db_fld_t res[] = {
{.name = "col_bool", .type = DB_INT},
{.name = "col_bytea", .type = DB_BLOB},
{.name = "col_char", .type = DB_STR},
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_int2", .type = DB_INT},
{.name = "col_text", .type = DB_STR},
{.name = "col_float4", .type = DB_FLOAT},
{.name = "col_float8", .type = DB_DOUBLE},
{.name = "col_inet", .type = DB_INT},
{.name = "col_bpchar", .type = DB_STR},
{.name = "col_varchar", .type = DB_STR},
{.name = "col_timestamp", .type = DB_DATETIME},
{.name = "col_bit", .type = DB_BITMAP},
{.name = "col_varbit", .type = DB_BITMAP},
{.name = NULL}
};

db_fld_t cred[] = {
{.name = "auth_username", .type = DB_CSTR},
{.name = "realm", .type = DB_CSTR},
{.name = NULL}
};
{.name = "col_bytea", .type = DB_BLOB}, {.name = NULL}};


db_fld_t res[] = {{.name = "col_bool", .type = DB_INT},
{.name = "col_bytea", .type = DB_BLOB},
{.name = "col_char", .type = DB_STR},
{.name = "col_int8", .type = DB_INT},
{.name = "col_int4", .type = DB_INT},
{.name = "col_int2", .type = DB_INT},
{.name = "col_text", .type = DB_STR},
{.name = "col_float4", .type = DB_FLOAT},
{.name = "col_float8", .type = DB_DOUBLE},
{.name = "col_inet", .type = DB_INT},
{.name = "col_bpchar", .type = DB_STR},
{.name = "col_varchar", .type = DB_STR},
{.name = "col_timestamp", .type = DB_DATETIME},
{.name = "col_bit", .type = DB_BITMAP},
{.name = "col_varbit", .type = DB_BITMAP}, {.name = NULL}};

db_fld_t cred[] = {{.name = "auth_username", .type = DB_CSTR},
{.name = "realm", .type = DB_CSTR}, {.name = NULL}};


db = db_ctx("ldap");
if (db == NULL) {
if(db == NULL) {
ERR("Error while initializing database layer\n");
goto error;
}
if (db_add_db(db, "ldap://127.0.0.1") < 0) goto error;
if(db_add_db(db, "ldap://127.0.0.1") < 0)
goto error;

if (db_connect(db) < 0) goto error;
if(db_connect(db) < 0)
goto error;

/*
del = db_cmd(DB_DEL, db, "test", NULL, NULL, NULL);
Expand Down Expand Up @@ -437,15 +405,15 @@ int ldap_test(void)
*/

get = db_cmd(DB_GET, db, "credentials", res, cred, NULL);
if (get == NULL) {
if(get == NULL) {
ERR("Error while building select query\n");
goto error;
}

get->match[0].v.cstr = "jan";
get->match[1].v.cstr = "iptel.org";

if (db_exec(&result, get)) {
if(db_exec(&result, get)) {
ERR("Error while executing select query\n");
goto error;
}
Expand All @@ -462,36 +430,38 @@ int ldap_test(void)
while(rec) {
ERR("row: %d\n", row);
for(i = 0; !DB_FLD_LAST(rec->fld[i]); i++) {
if (rec->fld[i].flags & DB_NULL) {
if(rec->fld[i].flags & DB_NULL) {
ERR("%s: NULL\n", rec->fld[i].name);
} else {
switch(rec->fld[i].type) {
case DB_INT:
case DB_BITMAP:
ERR("%s: %d\n", rec->fld[i].name, rec->fld[i].v.int4);
break;

case DB_DATETIME:
times = ctime(&rec->fld[i].v.time);
ERR("%s: %d:%.*s\n", rec->fld[i].name, rec->fld[i].v.time, strlen(times) - 1, times);
break;

case DB_DOUBLE:
ERR("%s: %f\n", rec->fld[i].name, rec->fld[i].v.dbl);
break;

case DB_FLOAT:
ERR("%s: %f\n", rec->fld[i].name, rec->fld[i].v.flt);
break;

case DB_STR:
case DB_BLOB:
ERR("%s: %.*s\n", rec->fld[i].name, rec->fld[i].v.lstr.len, rec->fld[i].v.lstr.s);
break;

case DB_CSTR:
ERR("%s: %s\n", rec->fld[i].name, rec->fld[i].v.cstr);
break;
case DB_INT:
case DB_BITMAP:
ERR("%s: %d\n", rec->fld[i].name, rec->fld[i].v.int4);
break;

case DB_DATETIME:
times = ctime(&rec->fld[i].v.time);
ERR("%s: %d:%.*s\n", rec->fld[i].name,
rec->fld[i].v.time, strlen(times) - 1, times);
break;

case DB_DOUBLE:
ERR("%s: %f\n", rec->fld[i].name, rec->fld[i].v.dbl);
break;

case DB_FLOAT:
ERR("%s: %f\n", rec->fld[i].name, rec->fld[i].v.flt);
break;

case DB_STR:
case DB_BLOB:
ERR("%s: %.*s\n", rec->fld[i].name,
rec->fld[i].v.lstr.len, rec->fld[i].v.lstr.s);
break;

case DB_CSTR:
ERR("%s: %s\n", rec->fld[i].name, rec->fld[i].v.cstr);
break;
}
}
}
Expand All @@ -507,10 +477,13 @@ int ldap_test(void)
db_ctx_free(db);
return 0;

error:
if (get) db_cmd_free(get);
if (put) db_cmd_free(put);
if (del) db_cmd_free(del);
error:
if(get)
db_cmd_free(get);
if(put)
db_cmd_free(put);
if(del)
db_cmd_free(del);
db_disconnect(db);
db_ctx_free(db);
return -1;
Expand All @@ -526,13 +499,13 @@ static void ld_mod_destroy(void)

static int ld_mod_init(void)
{
if (ld_load_cfg(&ld_cfg_file)) {
ERR("ldap: Error while loading configuration file\n");
return -1;
if(ld_load_cfg(&ld_cfg_file)) {
ERR("ldap: Error while loading configuration file\n");
return -1;
}

#ifdef LD_TEST
if (ldap_test() == 0) {
if(ldap_test() == 0) {
ERR("ldap: Testing successful\n");
} else {
ERR("ldap: Testing failed\n");
Expand Down

0 comments on commit 4f10a61

Please sign in to comment.