#ifndef RSPAMD_LUA_H #define RSPAMD_LUA_H #include "config.h" #ifdef WITH_LUA #include #include #include #include "rspamd.h" #include "ucl.h" #include "lua_ucl.h" #ifndef lua_open #define lua_open() luaL_newstate () #endif #ifndef luaL_reg #define luaL_reg luaL_Reg #endif #define LUA_ENUM(L, name, val) \ lua_pushlstring (L, # name, sizeof(# name) - 1); \ lua_pushnumber (L, val); \ lua_settable (L, -3); #if LUA_VERSION_NUM > 501 && !defined LUA_COMPAT_MODULE static inline void luaL_register (lua_State *L, const gchar *name, const struct luaL_reg *methods) { if (name != NULL) { lua_newtable (L); } luaL_setfuncs (L, methods, 0); if (name != NULL) { lua_pushvalue (L, -1); lua_setglobal (L, name); } } #endif /* Interface definitions */ #define LUA_FUNCTION_DEF(class, name) static gint lua_ ## class ## _ ## name ( \ lua_State * L) #define LUA_INTERFACE_DEF(class, name) { # name, lua_ ## class ## _ ## name } extern const luaL_reg null_reg[]; #define RSPAMD_LUA_API_VERSION 12 /* Locked lua state with mutex */ struct lua_locked_state { lua_State *L; rspamd_mutex_t *m; }; /** * Lua IP address structure */ struct rspamd_lua_ip { rspamd_inet_addr_t *addr; }; struct rspamd_lua_text { const gchar *start; guint len; gboolean own; }; struct rspamd_lua_url { struct rspamd_url *url; }; /* Common utility functions */ /** * Create and register new class */ void rspamd_lua_new_class (lua_State *L, const gchar *classname, const struct luaL_reg *methods); /** * Create and register new class with static methods */ void rspamd_lua_new_class_full (lua_State *L, const gchar *classname, const gchar *static_name, const struct luaL_reg *methods, const struct luaL_reg *func); /** * Set class name for object at @param objidx position */ void rspamd_lua_setclass (lua_State *L, const gchar *classname, gint objidx); /** * Set index of table to value (like t['index'] = value) */ void rspamd_lua_table_set (lua_State *L, const gchar *index, const gchar *value); /** * Get string value of index in a table (return t['index']) */ const gchar * rspamd_lua_table_get (lua_State *L, const gchar *index); /** * Convert classname to string */ gint rspamd_lua_class_tostring (lua_State *L); /** * Check whether the argument at specified index is of the specified class */ gpointer rspamd_lua_check_class (lua_State *L, gint index, const gchar *name); /** * Initialize lua and bindings */ lua_State * rspamd_lua_init (struct rspamd_config *cfg); /** * Load and initialize lua plugins */ gboolean rspamd_init_lua_filters (struct rspamd_config *cfg); /** * Initialize new locked lua_State structure */ struct lua_locked_state * rspamd_init_lua_locked (struct rspamd_config *cfg); /** * Free locked state structure */ void rspamd_free_lua_locked (struct lua_locked_state *st); /** * Push lua ip address */ void rspamd_lua_ip_push (lua_State *L, rspamd_inet_addr_t *addr); /** * Push rspamd task structure to lua */ void rspamd_lua_task_push (lua_State *L, struct rspamd_task *task); /** * Return lua ip structure at the specified address */ struct rspamd_lua_ip * lua_check_ip (lua_State * L, gint pos); struct rspamd_lua_text * lua_check_text (lua_State * L, gint pos); /** * Push specific header to lua */ gint rspamd_lua_push_header (lua_State * L, GHashTable *hdrs, const gchar *name, gboolean strong, gboolean full, gboolean raw); /** * Check for task at the specified position */ struct rspamd_task *lua_check_task (lua_State * L, gint pos); /** * Push ip address from a string (nil is pushed if a string cannot be converted) */ void rspamd_lua_ip_push_fromstring (lua_State *L, const gchar *ip_str); /** * Create type error */ int rspamd_lua_typerror (lua_State *L, int narg, const char *tname); /** * Open libraries functions */ /** * Add preload function */ void rspamd_lua_add_preload (lua_State *L, const gchar *name, lua_CFunction func); void luaopen_task (lua_State *L); void luaopen_config (lua_State *L); void luaopen_metric (lua_State *L); void luaopen_radix (lua_State *L); void luaopen_hash_table (lua_State *L); void luaopen_trie (lua_State * L); void luaopen_textpart (lua_State *L); void luaopen_mimepart (lua_State *L); void luaopen_image (lua_State *L); void luaopen_url (lua_State *L); void luaopen_classifier (lua_State *L); void luaopen_statfile (lua_State * L); void luaopen_regexp (lua_State *L); void luaopen_cdb (lua_State *L); void luaopen_xmlrpc (lua_State * L); void luaopen_http (lua_State * L); void luaopen_redis (lua_State * L); void luaopen_upstream (lua_State * L); void luaopen_mempool (lua_State * L); void luaopen_session (lua_State * L); void luaopen_io_dispatcher (lua_State * L); void luaopen_dns_resolver (lua_State * L); void luaopen_rsa (lua_State * L); void luaopen_ip (lua_State * L); void luaopen_expression (lua_State * L); void luaopen_logger (lua_State * L); void luaopen_text (lua_State *L); void luaopen_util (lua_State * L); void luaopen_tcp (lua_State * L); void luaopen_html (lua_State * L); gint rspamd_lua_call_filter (const gchar *function, struct rspamd_task *task); gint rspamd_lua_call_chain_filter (const gchar *function, struct rspamd_task *task, gint *marks, guint number); double rspamd_lua_consolidation_func (struct rspamd_task *task, const gchar *metric_name, const gchar *function_name); void rspamd_lua_call_post_filters (struct rspamd_task *task); void rspamd_lua_call_pre_filters (struct rspamd_task *task); void rspamd_lua_dostring (const gchar *line); /* Classify functions */ GList * rspamd_lua_call_cls_pre_callbacks (struct rspamd_classifier_config *ccf, struct rspamd_task *task, gboolean is_learn, gboolean is_spam, lua_State *L); double rspamd_lua_call_cls_post_callbacks (struct rspamd_classifier_config *ccf, struct rspamd_task *task, double in, lua_State *L); double rspamd_lua_normalize (struct rspamd_config *cfg, long double score, void *params); /* Config file functions */ void rspamd_lua_post_load_config (struct rspamd_config *cfg); gboolean rspamd_lua_handle_param (struct rspamd_task *task, gchar *mname, gchar *optname, enum lua_var_type expected_type, gpointer *res); gboolean rspamd_lua_check_condition (struct rspamd_config *cfg, const gchar *condition); void rspamd_lua_dumpstack (lua_State *L); /* Set lua path according to the configuration */ void rspamd_lua_set_path (lua_State *L, struct rspamd_config *cfg); struct memory_pool_s * rspamd_lua_check_mempool (lua_State * L, gint pos); struct rspamd_config * lua_check_config (lua_State * L, gint pos); /** * Extract an arguments from lua table according to format string. Supported arguments are: * key=[*]S|I|N|B|V|U{a-z};[key=...] * - S - const char * * - I - gint64_t * - N - double * - B - boolean * - V - size_t + const char * * - U{classname} - userdata of the following class (stored in gpointer) * * If any of format string is prefixed with `*` then it is treated as required argument * @param L lua state * @param pos at which pos start extraction * @param err error pointer * @param extraction_pattern static pattern * @return TRUE if a table has been parsed */ gboolean rspamd_lua_parse_table_arguments (lua_State *L, gint pos, GError **err, const gchar *extraction_pattern, ...); gint rspamd_lua_traceback (lua_State *L); #endif /* WITH_LUA */ #endif /* RSPAMD_LUA_H */