aboutsummaryrefslogtreecommitdiffstats
path: root/src/lua/lua_spf.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/lua/lua_spf.c')
-rw-r--r--src/lua/lua_spf.c406
1 files changed, 202 insertions, 204 deletions
diff --git a/src/lua/lua_spf.c b/src/lua/lua_spf.c
index f6ce4905e..a67a267fa 100644
--- a/src/lua/lua_spf.c
+++ b/src/lua/lua_spf.c
@@ -24,32 +24,32 @@
#define SPF_RECORD_CLASS "rspamd{spf_record}"
-LUA_FUNCTION_DEF (spf, resolve);
-LUA_FUNCTION_DEF (spf, config);
+LUA_FUNCTION_DEF(spf, resolve);
+LUA_FUNCTION_DEF(spf, config);
-LUA_FUNCTION_DEF (spf_record, check_ip);
-LUA_FUNCTION_DEF (spf_record, dtor);
-LUA_FUNCTION_DEF (spf_record, get_domain);
-LUA_FUNCTION_DEF (spf_record, get_elts);
-LUA_FUNCTION_DEF (spf_record, get_ttl);
-LUA_FUNCTION_DEF (spf_record, get_timestamp);
-LUA_FUNCTION_DEF (spf_record, get_digest);
+LUA_FUNCTION_DEF(spf_record, check_ip);
+LUA_FUNCTION_DEF(spf_record, dtor);
+LUA_FUNCTION_DEF(spf_record, get_domain);
+LUA_FUNCTION_DEF(spf_record, get_elts);
+LUA_FUNCTION_DEF(spf_record, get_ttl);
+LUA_FUNCTION_DEF(spf_record, get_timestamp);
+LUA_FUNCTION_DEF(spf_record, get_digest);
static luaL_reg rspamd_spf_f[] = {
- LUA_INTERFACE_DEF (spf, resolve),
- LUA_INTERFACE_DEF (spf, config),
- {NULL, NULL},
+ LUA_INTERFACE_DEF(spf, resolve),
+ LUA_INTERFACE_DEF(spf, config),
+ {NULL, NULL},
};
static luaL_reg rspamd_spf_record_m[] = {
- LUA_INTERFACE_DEF (spf_record, check_ip),
- LUA_INTERFACE_DEF (spf_record, get_domain),
- LUA_INTERFACE_DEF (spf_record, get_ttl),
- LUA_INTERFACE_DEF (spf_record, get_digest),
- LUA_INTERFACE_DEF (spf_record, get_elts),
- LUA_INTERFACE_DEF (spf_record, get_timestamp),
- {"__gc", lua_spf_record_dtor},
- {NULL, NULL},
+ LUA_INTERFACE_DEF(spf_record, check_ip),
+ LUA_INTERFACE_DEF(spf_record, get_domain),
+ LUA_INTERFACE_DEF(spf_record, get_ttl),
+ LUA_INTERFACE_DEF(spf_record, get_digest),
+ LUA_INTERFACE_DEF(spf_record, get_elts),
+ LUA_INTERFACE_DEF(spf_record, get_timestamp),
+ {"__gc", lua_spf_record_dtor},
+ {NULL, NULL},
};
struct rspamd_lua_spf_cbdata {
@@ -61,148 +61,148 @@ struct rspamd_lua_spf_cbdata {
};
static gint
-lua_load_spf (lua_State * L)
+lua_load_spf(lua_State *L)
{
- lua_newtable (L);
+ lua_newtable(L);
/* Create integer arguments to check SPF results */
- lua_newtable (L);
- lua_pushinteger (L, SPF_FAIL);
- lua_setfield (L, -2, "fail");
- lua_pushinteger (L, SPF_PASS);
- lua_setfield (L, -2, "pass");
- lua_pushinteger (L, SPF_NEUTRAL);
- lua_setfield (L, -2, "neutral");
- lua_pushinteger (L, SPF_SOFT_FAIL);
- lua_setfield (L, -2, "soft_fail");
-
- lua_setfield (L, -2, "policy");
+ lua_newtable(L);
+ lua_pushinteger(L, SPF_FAIL);
+ lua_setfield(L, -2, "fail");
+ lua_pushinteger(L, SPF_PASS);
+ lua_setfield(L, -2, "pass");
+ lua_pushinteger(L, SPF_NEUTRAL);
+ lua_setfield(L, -2, "neutral");
+ lua_pushinteger(L, SPF_SOFT_FAIL);
+ lua_setfield(L, -2, "soft_fail");
+
+ lua_setfield(L, -2, "policy");
/* Flags stuff */
- lua_newtable (L);
+ lua_newtable(L);
- lua_pushinteger (L, RSPAMD_SPF_RESOLVED_TEMP_FAILED);
- lua_setfield (L, -2, "temp_fail");
- lua_pushinteger (L, RSPAMD_SPF_RESOLVED_NA);
- lua_setfield (L, -2, "na");
- lua_pushinteger (L, RSPAMD_SPF_RESOLVED_PERM_FAILED);
- lua_setfield (L, -2, "perm_fail");
- lua_pushinteger (L, RSPAMD_SPF_FLAG_CACHED);
- lua_setfield (L, -2, "cached");
+ lua_pushinteger(L, RSPAMD_SPF_RESOLVED_TEMP_FAILED);
+ lua_setfield(L, -2, "temp_fail");
+ lua_pushinteger(L, RSPAMD_SPF_RESOLVED_NA);
+ lua_setfield(L, -2, "na");
+ lua_pushinteger(L, RSPAMD_SPF_RESOLVED_PERM_FAILED);
+ lua_setfield(L, -2, "perm_fail");
+ lua_pushinteger(L, RSPAMD_SPF_FLAG_CACHED);
+ lua_setfield(L, -2, "cached");
- lua_setfield (L, -2, "flags");
+ lua_setfield(L, -2, "flags");
- luaL_register (L, NULL, rspamd_spf_f);
+ luaL_register(L, NULL, rspamd_spf_f);
return 1;
}
-void luaopen_spf (lua_State *L)
+void luaopen_spf(lua_State *L)
{
- rspamd_lua_new_class (L, SPF_RECORD_CLASS, rspamd_spf_record_m);
- lua_pop (L, 1); /* No need in metatable... */
+ rspamd_lua_new_class(L, SPF_RECORD_CLASS, rspamd_spf_record_m);
+ lua_pop(L, 1); /* No need in metatable... */
- rspamd_lua_add_preload (L, "rspamd_spf", lua_load_spf);
- lua_settop (L, 0);
+ rspamd_lua_add_preload(L, "rspamd_spf", lua_load_spf);
+ lua_settop(L, 0);
}
static void
-lua_spf_push_result (struct rspamd_lua_spf_cbdata *cbd, gint code_flags,
- struct spf_resolved *resolved, const gchar *err)
+lua_spf_push_result(struct rspamd_lua_spf_cbdata *cbd, gint code_flags,
+ struct spf_resolved *resolved, const gchar *err)
{
- g_assert (cbd != NULL);
- REF_RETAIN (cbd);
+ g_assert(cbd != NULL);
+ REF_RETAIN(cbd);
- lua_pushcfunction (cbd->L, &rspamd_lua_traceback);
- gint err_idx = lua_gettop (cbd->L);
+ lua_pushcfunction(cbd->L, &rspamd_lua_traceback);
+ gint err_idx = lua_gettop(cbd->L);
- lua_rawgeti (cbd->L, LUA_REGISTRYINDEX, cbd->cbref);
+ lua_rawgeti(cbd->L, LUA_REGISTRYINDEX, cbd->cbref);
if (resolved) {
struct spf_resolved **presolved;
- presolved = lua_newuserdata (cbd->L, sizeof (*presolved));
- rspamd_lua_setclass (cbd->L, SPF_RECORD_CLASS, -1);
- *presolved = spf_record_ref (resolved);
+ presolved = lua_newuserdata(cbd->L, sizeof(*presolved));
+ rspamd_lua_setclass(cbd->L, SPF_RECORD_CLASS, -1);
+ *presolved = spf_record_ref(resolved);
}
else {
- lua_pushnil (cbd->L);
+ lua_pushnil(cbd->L);
}
- lua_pushinteger (cbd->L, code_flags);
+ lua_pushinteger(cbd->L, code_flags);
if (err) {
- lua_pushstring (cbd->L, err);
+ lua_pushstring(cbd->L, err);
}
else {
- lua_pushnil (cbd->L);
+ lua_pushnil(cbd->L);
}
- if (lua_pcall (cbd->L, 3, 0, err_idx) != 0) {
+ if (lua_pcall(cbd->L, 3, 0, err_idx) != 0) {
struct rspamd_task *task = cbd->task;
- msg_err_task ("cannot call callback function for spf: %s",
- lua_tostring (cbd->L, -1));
+ msg_err_task("cannot call callback function for spf: %s",
+ lua_tostring(cbd->L, -1));
}
- lua_settop (cbd->L, err_idx - 1);
+ lua_settop(cbd->L, err_idx - 1);
- REF_RELEASE (cbd);
+ REF_RELEASE(cbd);
}
static void
-lua_spf_dtor (struct rspamd_lua_spf_cbdata *cbd)
+lua_spf_dtor(struct rspamd_lua_spf_cbdata *cbd)
{
if (cbd) {
- luaL_unref (cbd->L, LUA_REGISTRYINDEX, cbd->cbref);
+ luaL_unref(cbd->L, LUA_REGISTRYINDEX, cbd->cbref);
if (cbd->item) {
- rspamd_symcache_item_async_dec_check (cbd->task, cbd->item,
- "lua_spf");
+ rspamd_symcache_item_async_dec_check(cbd->task, cbd->item,
+ "lua_spf");
}
}
}
static void
-spf_lua_lib_callback (struct spf_resolved *record, struct rspamd_task *task,
+spf_lua_lib_callback(struct spf_resolved *record, struct rspamd_task *task,
gpointer ud)
{
- struct rspamd_lua_spf_cbdata *cbd = (struct rspamd_lua_spf_cbdata *)ud;
+ struct rspamd_lua_spf_cbdata *cbd = (struct rspamd_lua_spf_cbdata *) ud;
if (record) {
if ((record->flags & RSPAMD_SPF_RESOLVED_NA)) {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_NA, NULL,
- "no SPF record");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_NA, NULL,
+ "no SPF record");
}
else if (record->elts->len == 0) {
if (record->flags & RSPAMD_SPF_RESOLVED_PERM_FAILED) {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
- "bad SPF record");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
+ "bad SPF record");
}
else if ((record->flags & RSPAMD_SPF_RESOLVED_TEMP_FAILED)) {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_TEMP_FAILED, NULL,
- "temporary DNS error");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_TEMP_FAILED, NULL,
+ "temporary DNS error");
}
else {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
- "empty SPF record");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
+ "empty SPF record");
}
}
else if (record->domain) {
- spf_record_ref (record);
- lua_spf_push_result (cbd, record->flags, record, NULL);
- spf_record_unref (record);
+ spf_record_ref(record);
+ lua_spf_push_result(cbd, record->flags, record, NULL);
+ spf_record_unref(record);
}
else {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
- "internal error: non empty record for no domain");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
+ "internal error: non empty record for no domain");
}
}
else {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
- "internal error: no record");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_PERM_FAILED, NULL,
+ "internal error: no record");
}
- REF_RELEASE (cbd);
+ REF_RELEASE(cbd);
}
/***
@@ -211,95 +211,94 @@ spf_lua_lib_callback (struct spf_resolved *record, struct rspamd_task *task,
* @param {rspamd_task} task task
* @param {function} callback callback that is called on spf resolution
*/
-gint
-lua_spf_resolve (lua_State * L)
+gint lua_spf_resolve(lua_State *L)
{
- struct rspamd_task *task = lua_check_task (L, 1);
+ struct rspamd_task *task = lua_check_task(L, 1);
- if (task && lua_isfunction (L, 2)) {
- struct rspamd_lua_spf_cbdata *cbd = rspamd_mempool_alloc0 (task->task_pool,
- sizeof (*cbd));
+ if (task && lua_isfunction(L, 2)) {
+ struct rspamd_lua_spf_cbdata *cbd = rspamd_mempool_alloc0(task->task_pool,
+ sizeof(*cbd));
struct rspamd_spf_cred *spf_cred;
cbd->task = task;
cbd->L = L;
- lua_pushvalue (L, 2);
- cbd->cbref = luaL_ref (L, LUA_REGISTRYINDEX);
+ lua_pushvalue(L, 2);
+ cbd->cbref = luaL_ref(L, LUA_REGISTRYINDEX);
/* TODO: make it as an optional parameter */
- spf_cred = rspamd_spf_get_cred (task);
- cbd->item = rspamd_symcache_get_cur_item (task);
+ spf_cred = rspamd_spf_get_cred(task);
+ cbd->item = rspamd_symcache_get_cur_item(task);
if (cbd->item) {
- rspamd_symcache_item_async_inc (task, cbd->item, "lua_spf");
+ rspamd_symcache_item_async_inc(task, cbd->item, "lua_spf");
}
- REF_INIT_RETAIN (cbd, lua_spf_dtor);
+ REF_INIT_RETAIN(cbd, lua_spf_dtor);
- if (!rspamd_spf_resolve (task, spf_lua_lib_callback, cbd, spf_cred)) {
- msg_info_task ("cannot make spf request for %s",
- spf_cred ? spf_cred->domain : "empty domain");
+ if (!rspamd_spf_resolve(task, spf_lua_lib_callback, cbd, spf_cred)) {
+ msg_info_task("cannot make spf request for %s",
+ spf_cred ? spf_cred->domain : "empty domain");
if (spf_cred) {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_TEMP_FAILED,
- NULL, "DNS failed");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_TEMP_FAILED,
+ NULL, "DNS failed");
}
else {
- lua_spf_push_result (cbd, RSPAMD_SPF_RESOLVED_NA,
- NULL, "No domain");
+ lua_spf_push_result(cbd, RSPAMD_SPF_RESOLVED_NA,
+ NULL, "No domain");
}
- REF_RELEASE (cbd);
+ REF_RELEASE(cbd);
}
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 0;
}
static gint
-lua_spf_record_dtor (lua_State *L)
+lua_spf_record_dtor(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
- spf_record_unref (record);
+ spf_record_unref(record);
}
return 0;
}
static void
-lua_spf_push_spf_addr (lua_State *L, struct spf_addr *addr)
+lua_spf_push_spf_addr(lua_State *L, struct spf_addr *addr)
{
gchar *addr_mask;
- lua_createtable (L, 0, 4);
+ lua_createtable(L, 0, 4);
- lua_pushinteger (L, addr->mech);
- lua_setfield (L, -2, "result");
- lua_pushinteger (L, addr->flags);
- lua_setfield (L, -2, "flags");
+ lua_pushinteger(L, addr->mech);
+ lua_setfield(L, -2, "result");
+ lua_pushinteger(L, addr->flags);
+ lua_setfield(L, -2, "flags");
if (addr->spf_string) {
- lua_pushstring (L, addr->spf_string);
- lua_setfield (L, -2, "str");
+ lua_pushstring(L, addr->spf_string);
+ lua_setfield(L, -2, "str");
}
- addr_mask = spf_addr_mask_to_string (addr);
+ addr_mask = spf_addr_mask_to_string(addr);
if (addr_mask) {
- lua_pushstring (L, addr_mask);
- lua_setfield (L, -2, "addr");
- g_free (addr_mask);
+ lua_pushstring(L, addr_mask);
+ lua_setfield(L, -2, "addr");
+ g_free(addr_mask);
}
}
static gint
-spf_check_element (lua_State *L, struct spf_resolved *rec, struct spf_addr *addr,
- struct rspamd_lua_ip *ip)
+spf_check_element(lua_State *L, struct spf_resolved *rec, struct spf_addr *addr,
+ struct rspamd_lua_ip *ip)
{
gboolean res = FALSE;
const guint8 *s, *d;
@@ -312,18 +311,18 @@ spf_check_element (lua_State *L, struct spf_resolved *rec, struct spf_addr *addr
return -1;
}
- af = rspamd_inet_address_get_af (ip->addr);
+ af = rspamd_inet_address_get_af(ip->addr);
/* Basic comparing algorithm */
if (((addr->flags & RSPAMD_SPF_FLAG_IPV6) && af == AF_INET6) ||
((addr->flags & RSPAMD_SPF_FLAG_IPV4) && af == AF_INET)) {
- d = rspamd_inet_address_get_hash_key (ip->addr, &addrlen);
+ d = rspamd_inet_address_get_hash_key(ip->addr, &addrlen);
if (af == AF_INET6) {
- s = (const guint8 *)addr->addr6;
+ s = (const guint8 *) addr->addr6;
mask = addr->m.dual.mask_v6;
}
else {
- s = (const guint8 *)addr->addr4;
+ s = (const guint8 *) addr->addr4;
mask = addr->m.dual.mask_v4;
}
@@ -332,7 +331,7 @@ spf_check_element (lua_State *L, struct spf_resolved *rec, struct spf_addr *addr
if (mask > addrlen * CHAR_BIT) {
/* XXX: add logging */
}
- else if (memcmp (s, d, bmask) == 0) {
+ else if (memcmp(s, d, bmask) == 0) {
if (bmask * CHAR_BIT < mask) {
/* Compare the remaining bits */
s += bmask;
@@ -360,25 +359,25 @@ spf_check_element (lua_State *L, struct spf_resolved *rec, struct spf_addr *addr
if (res) {
if (addr->flags & RSPAMD_SPF_FLAG_ANY) {
if (rec->flags & RSPAMD_SPF_RESOLVED_PERM_FAILED) {
- lua_pushboolean (L, false);
- lua_pushinteger (L, RSPAMD_SPF_RESOLVED_PERM_FAILED);
- lua_pushfstring (L, "%cany", spf_mech_char (addr->mech));
+ lua_pushboolean(L, false);
+ lua_pushinteger(L, RSPAMD_SPF_RESOLVED_PERM_FAILED);
+ lua_pushfstring(L, "%cany", spf_mech_char(addr->mech));
}
else if (rec->flags & RSPAMD_SPF_RESOLVED_TEMP_FAILED) {
- lua_pushboolean (L, false);
- lua_pushinteger (L, RSPAMD_SPF_RESOLVED_TEMP_FAILED);
- lua_pushfstring (L, "%cany", spf_mech_char (addr->mech));
+ lua_pushboolean(L, false);
+ lua_pushinteger(L, RSPAMD_SPF_RESOLVED_TEMP_FAILED);
+ lua_pushfstring(L, "%cany", spf_mech_char(addr->mech));
}
else {
- lua_pushboolean (L, true);
- lua_pushinteger (L, addr->mech);
- lua_spf_push_spf_addr (L, addr);
+ lua_pushboolean(L, true);
+ lua_pushinteger(L, addr->mech);
+ lua_spf_push_spf_addr(L, addr);
}
}
else {
- lua_pushboolean (L, true);
- lua_pushinteger (L, addr->mech);
- lua_spf_push_spf_addr (L, addr);
+ lua_pushboolean(L, true);
+ lua_pushinteger(L, addr->mech);
+ lua_spf_push_spf_addr(L, addr);
}
return 3;
@@ -398,29 +397,29 @@ spf_check_element (lua_State *L, struct spf_resolved *rec, struct spf_addr *addr
* @return {result,flag_or_policy,error_or_addr} - triplet
*/
static gint
-lua_spf_record_check_ip (lua_State *L)
+lua_spf_record_check_ip(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
struct rspamd_lua_ip *ip = NULL;
gint nres = 0;
gboolean need_free_ip = FALSE;
- if (lua_type (L, 2) == LUA_TUSERDATA) {
- ip = lua_check_ip (L, 2);
+ if (lua_type(L, 2) == LUA_TUSERDATA) {
+ ip = lua_check_ip(L, 2);
}
- else if (lua_type (L, 2) == LUA_TSTRING) {
+ else if (lua_type(L, 2) == LUA_TSTRING) {
const gchar *ip_str;
gsize iplen;
- ip = g_malloc0 (sizeof (struct rspamd_lua_ip));
- ip_str = lua_tolstring (L, 2, &iplen);
+ ip = g_malloc0(sizeof(struct rspamd_lua_ip));
+ ip_str = lua_tolstring(L, 2, &iplen);
- if (!rspamd_parse_inet_address (&ip->addr,
- ip_str, iplen, RSPAMD_INET_ADDRESS_PARSE_DEFAULT)) {
- g_free (ip);
+ if (!rspamd_parse_inet_address(&ip->addr,
+ ip_str, iplen, RSPAMD_INET_ADDRESS_PARSE_DEFAULT)) {
+ g_free(ip);
ip = NULL;
}
else {
@@ -429,11 +428,11 @@ lua_spf_record_check_ip (lua_State *L)
}
if (record && ip && ip->addr) {
- for (guint i = 0; i < record->elts->len; i ++) {
- struct spf_addr *addr = &g_array_index (record->elts, struct spf_addr, i);
- if ((nres = spf_check_element (L, record, addr, ip)) > 0) {
+ for (guint i = 0; i < record->elts->len; i++) {
+ struct spf_addr *addr = &g_array_index(record->elts, struct spf_addr, i);
+ if ((nres = spf_check_element(L, record, addr, ip)) > 0) {
if (need_free_ip) {
- g_free (ip);
+ g_free(ip);
}
return nres;
@@ -442,14 +441,14 @@ lua_spf_record_check_ip (lua_State *L)
}
else {
if (need_free_ip) {
- g_free (ip);
+ g_free(ip);
}
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
if (need_free_ip) {
- g_free (ip);
+ g_free(ip);
}
/* If we are here it means that there is no ALL record */
@@ -463,9 +462,9 @@ lua_spf_record_check_ip (lua_State *L)
fake_all.flags = RSPAMD_SPF_FLAG_ANY;
fake_all.spf_string = "all";
- lua_pushboolean (L, true);
- lua_pushinteger (L, SPF_NEUTRAL);
- lua_spf_push_spf_addr (L, &fake_all);
+ lua_pushboolean(L, true);
+ lua_pushinteger(L, SPF_NEUTRAL);
+ lua_spf_push_spf_addr(L, &fake_all);
return 3;
}
@@ -475,18 +474,18 @@ lua_spf_record_check_ip (lua_State *L)
* Returns domain for the specific spf record
*/
static gint
-lua_spf_record_get_domain (lua_State *L)
+lua_spf_record_get_domain(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
- lua_pushstring (L, record->domain);
+ lua_pushstring(L, record->domain);
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 1;
@@ -497,18 +496,18 @@ lua_spf_record_get_domain (lua_State *L)
* Returns ttl for the specific spf record
*/
static gint
-lua_spf_record_get_ttl (lua_State *L)
+lua_spf_record_get_ttl(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
- lua_pushinteger (L, record->ttl);
+ lua_pushinteger(L, record->ttl);
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 1;
@@ -519,18 +518,18 @@ lua_spf_record_get_ttl (lua_State *L)
* Returns ttl for the specific spf record
*/
static gint
-lua_spf_record_get_timestamp (lua_State *L)
+lua_spf_record_get_timestamp(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
- lua_pushnumber (L, record->timestamp);
+ lua_pushnumber(L, record->timestamp);
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 1;
@@ -541,21 +540,21 @@ lua_spf_record_get_timestamp (lua_State *L)
* Returns string hex representation of the record digest (fast hash function)
*/
static gint
-lua_spf_record_get_digest (lua_State *L)
+lua_spf_record_get_digest(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
gchar hexbuf[64];
- rspamd_snprintf (hexbuf, sizeof (hexbuf), "%xuL", record->digest);
- lua_pushstring (L, hexbuf);
+ rspamd_snprintf(hexbuf, sizeof(hexbuf), "%xuL", record->digest);
+ lua_pushstring(L, hexbuf);
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 1;
@@ -572,29 +571,29 @@ lua_spf_record_get_digest (lua_State *L)
* - str - string representation (if available)
*/
static gint
-lua_spf_record_get_elts (lua_State *L)
+lua_spf_record_get_elts(lua_State *L)
{
struct spf_resolved *record;
RSPAMD_LUA_CHECK_UDATA_PTR_OR_RETURN(L, 1, SPF_RECORD_CLASS,
- struct spf_resolved,
- record);
+ struct spf_resolved,
+ record);
if (record) {
guint i;
struct spf_addr *addr;
- lua_createtable (L, record->elts->len, 0);
+ lua_createtable(L, record->elts->len, 0);
- for (i = 0; i < record->elts->len; i ++) {
- addr = (struct spf_addr *)&g_array_index (record->elts,
- struct spf_addr, i);
- lua_spf_push_spf_addr (L, addr);
+ for (i = 0; i < record->elts->len; i++) {
+ addr = (struct spf_addr *) &g_array_index(record->elts,
+ struct spf_addr, i);
+ lua_spf_push_spf_addr(L, addr);
- lua_rawseti (L, -2, i + 1);
+ lua_rawseti(L, -2, i + 1);
}
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 1;
@@ -605,17 +604,16 @@ lua_spf_record_get_elts (lua_State *L)
* Configures SPF library according to the UCL config
* @param {table} object configuration object
*/
-gint
-lua_spf_config (lua_State * L)
+gint lua_spf_config(lua_State *L)
{
- ucl_object_t *config_obj = ucl_object_lua_import (L, 1);
+ ucl_object_t *config_obj = ucl_object_lua_import(L, 1);
if (config_obj) {
- spf_library_config (config_obj);
- ucl_object_unref (config_obj); /* As we copy data all the time */
+ spf_library_config(config_obj);
+ ucl_object_unref(config_obj); /* As we copy data all the time */
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 0;
generated by cgit v1.2.3 (git 2.39.1) at 2025-04-26 14:44:01 +0000