Merge 0.8->trunk
[prosody.git] / util-src / pposix.c
index 993e6e876becf361d6f098382c20700fc6078d55..ffd2128835ddb9124cc8fb858a23be23e8e2734a 100644 (file)
@@ -1,8 +1,8 @@
-/* Prosody IM v0.4
--- Copyright (C) 2008-2009 Matthew Wild
--- Copyright (C) 2008-2009 Waqas Hussain
+/* Prosody IM
+-- Copyright (C) 2008-2010 Matthew Wild
+-- Copyright (C) 2008-2010 Waqas Hussain
 -- Copyright (C) 2009 Tobias Markmann
--- 
+--
 -- This project is MIT/X11 licensed. Please see the
 -- COPYING file in the source package for more information.
 --
 * POSIX support functions for Lua
 */
 
-#define MODULE_VERSION "0.3.0"
+#define MODULE_VERSION "0.3.5"
 
 #include <stdlib.h>
+#include <math.h>
 #include <unistd.h>
 #include <libgen.h>
 #include <sys/resource.h>
 #include <sys/types.h>
 #include <sys/stat.h>
+#include <sys/utsname.h>
 #include <fcntl.h>
 
 #include <syslog.h>
@@ -38,14 +40,14 @@ static int lc_daemonize(lua_State *L)
 {
 
        pid_t pid;
-       
+
        if ( getppid() == 1 )
        {
                lua_pushboolean(L, 0);
                lua_pushstring(L, "already-daemonized");
                return 2;
        }
-       
+
        /* Attempt initial fork */
        if((pid = fork()) < 0)
        {
@@ -61,7 +63,7 @@ static int lc_daemonize(lua_State *L)
                lua_pushnumber(L, pid);
                return 2;
        }
-       
+
        /* and we are the child process */
        if(setsid() == -1)
        {
@@ -91,10 +93,14 @@ static int lc_daemonize(lua_State *L)
 
 const char * const facility_strings[] = {
                                        "auth",
+#if !(defined(sun) || defined(__sun))
                                        "authpriv",
+#endif
                                        "cron",
                                        "daemon",
+#if !(defined(sun) || defined(__sun))
                                        "ftp",
+#endif
                                        "kern",
                                        "local0",
                                        "local1",
@@ -113,10 +119,14 @@ const char * const facility_strings[] = {
                                };
 int facility_constants[] =     {
                                        LOG_AUTH,
+#if !(defined(sun) || defined(__sun))
                                        LOG_AUTHPRIV,
+#endif
                                        LOG_CRON,
                                        LOG_DAEMON,
+#if !(defined(sun) || defined(__sun))
                                        LOG_FTP,
+#endif
                                        LOG_KERN,
                                        LOG_LOCAL0,
                                        LOG_LOCAL1,
@@ -142,7 +152,7 @@ int facility_constants[] =  {
        exist,  the  results  are  undefined.  Most portable is to use a string
        constant.
    " -- syslog manpage
-*/ 
+*/
 char* syslog_ident = NULL;
 
 int lc_syslog_open(lua_State* L)
@@ -151,12 +161,12 @@ int lc_syslog_open(lua_State* L)
        facility = facility_constants[facility];
 
        luaL_checkstring(L, 1);
-       
+
        if(syslog_ident)
                free(syslog_ident);
-       
+
        syslog_ident = strdup(lua_tostring(L, 1));
-       
+
        openlog(syslog_ident, LOG_PID, facility);
        return 0;
 }
@@ -256,7 +266,7 @@ int lc_setuid(lua_State* L)
        {
                uid = lua_tonumber(L, 1);
        }
-       
+
        if(uid>-1)
        {
                /* Ok, attempt setuid */
@@ -285,7 +295,7 @@ int lc_setuid(lua_State* L)
                        return 1;
                }
        }
-       
+
        /* Seems we couldn't find a valid UID to switch to */
        lua_pushboolean(L, 0);
        lua_pushstring(L, "invalid-uid");
@@ -314,7 +324,7 @@ int lc_setgid(lua_State* L)
        {
                gid = lua_tonumber(L, 1);
        }
-       
+
        if(gid>-1)
        {
                /* Ok, attempt setgid */
@@ -343,20 +353,103 @@ int lc_setgid(lua_State* L)
                        return 1;
                }
        }
-       
+
        /* Seems we couldn't find a valid GID to switch to */
        lua_pushboolean(L, 0);
        lua_pushstring(L, "invalid-gid");
        return 2;
 }
 
+int lc_initgroups(lua_State* L)
+{
+       int ret;
+       gid_t gid;
+       struct passwd *p;
+
+       if(!lua_isstring(L, 1))
+       {
+               lua_pushnil(L);
+               lua_pushstring(L, "invalid-username");
+               return 2;
+       }
+       p = getpwnam(lua_tostring(L, 1));
+       if(!p)
+       {
+               lua_pushnil(L);
+               lua_pushstring(L, "no-such-user");
+               return 2;
+       }
+       if(lua_gettop(L) < 2)
+               lua_pushnil(L);
+       switch(lua_type(L, 2))
+       {
+       case LUA_TNIL:
+               gid = p->pw_gid;
+               break;
+       case LUA_TNUMBER:
+               gid = lua_tointeger(L, 2);
+               break;
+       default:
+               lua_pushnil(L);
+               lua_pushstring(L, "invalid-gid");
+               return 2;
+       }
+       ret = initgroups(lua_tostring(L, 1), gid);
+       switch(errno)
+       {
+       case 0:
+               lua_pushboolean(L, 1);
+               lua_pushnil(L);
+               break;
+       case ENOMEM:
+               lua_pushnil(L);
+               lua_pushstring(L, "no-memory");
+               break;
+       case EPERM:
+               lua_pushnil(L);
+               lua_pushstring(L, "permission-denied");
+               break;
+       default:
+               lua_pushnil(L);
+               lua_pushstring(L, "unknown-error");
+       }
+       return 2;
+}
+
+int lc_umask(lua_State* L)
+{
+       char old_mode_string[7];
+       mode_t old_mode = umask(strtoul(luaL_checkstring(L, 1), NULL, 8));
+
+       snprintf(old_mode_string, sizeof(old_mode_string), "%03o", old_mode);
+       old_mode_string[sizeof(old_mode_string)-1] = 0;
+       lua_pushstring(L, old_mode_string);
+
+       return 1;
+}
+
+int lc_mkdir(lua_State* L)
+{
+       int ret = mkdir(luaL_checkstring(L, 1), S_IRUSR | S_IWUSR | S_IXUSR
+               | S_IRGRP | S_IWGRP | S_IXGRP
+               | S_IROTH | S_IXOTH); /* mode 775 */
+
+       lua_pushboolean(L, ret==0);
+       if(ret)
+       {
+               lua_pushstring(L, strerror(errno));
+               return 2;
+       }
+       return 1;
+}
+
 /*     Like POSIX's setrlimit()/getrlimit() API functions.
- *     
+ *
  *     Syntax:
  *     pposix.setrlimit( resource, soft limit, hard limit)
- *     
+ *
  *     Any negative limit will be replace with the current limit by an additional call of getrlimit().
- *     
+ *
  *     Example usage:
  *     pposix.setrlimit("NOFILE", 1000, 2000)
  */
@@ -365,11 +458,13 @@ int string2resource(const char *s) {
        if (!strcmp(s, "CPU")) return RLIMIT_CPU;
        if (!strcmp(s, "DATA")) return RLIMIT_DATA;
        if (!strcmp(s, "FSIZE")) return RLIMIT_FSIZE;
-       if (!strcmp(s, "MEMLOCK")) return RLIMIT_MEMLOCK;
        if (!strcmp(s, "NOFILE")) return RLIMIT_NOFILE;
+       if (!strcmp(s, "STACK")) return RLIMIT_STACK;
+#if !(defined(sun) || defined(__sun))
+       if (!strcmp(s, "MEMLOCK")) return RLIMIT_MEMLOCK;
        if (!strcmp(s, "NPROC")) return RLIMIT_NPROC;
        if (!strcmp(s, "RSS")) return RLIMIT_RSS;
-       if (!strcmp(s, "STACK")) return RLIMIT_STACK;
+#endif
        return -1;
 }
 
@@ -383,16 +478,16 @@ int lc_setrlimit(lua_State *L) {
                lua_pushboolean(L, 0);
                lua_pushstring(L, "incorrect-arguments");
        }
-       
+
        resource = luaL_checkstring(L, 1);
        softlimit = luaL_checkinteger(L, 2);
        hardlimit = luaL_checkinteger(L, 3);
-       
+
        rid = string2resource(resource);
        if (rid != -1) {
                struct rlimit lim;
                struct rlimit lim_current;
-               
+
                if (softlimit < 0 || hardlimit < 0) {
                        if (getrlimit(rid, &lim_current)) {
                                lua_pushboolean(L, 0);
@@ -400,12 +495,12 @@ int lc_setrlimit(lua_State *L) {
                                return 2;
                        }
                }
-               
+
                if (softlimit < 0) lim.rlim_cur = lim_current.rlim_cur;
                        else lim.rlim_cur = softlimit;
                if (hardlimit < 0) lim.rlim_max = lim_current.rlim_max;
                        else lim.rlim_max = hardlimit;
-               
+
                if (setrlimit(rid, &lim)) {
                        lua_pushboolean(L, 0);
                        lua_pushstring(L, "setrlimit-failed");
@@ -426,13 +521,13 @@ int lc_getrlimit(lua_State *L) {
        const char *resource = NULL;
        int rid = -1;
        struct rlimit lim;
-       
+
        if (arguments != 1) {
                lua_pushboolean(L, 0);
                lua_pushstring(L, "invalid-arguments");
                return 2;
        }
-       
+
        resource = luaL_checkstring(L, 1);
        rid = string2resource(resource);
        if (rid != -1) {
@@ -453,51 +548,76 @@ int lc_getrlimit(lua_State *L) {
        return 3;
 }
 
+int lc_abort(lua_State* L)
+{
+       abort();
+       return 0;
+}
+
+int lc_uname(lua_State* L)
+{
+       struct utsname uname_info;
+       if(uname(&uname_info) != 0)
+       {
+               lua_pushnil(L);
+               lua_pushstring(L, strerror(errno));
+               return 2;
+       }
+       lua_newtable(L);
+       lua_pushstring(L, uname_info.sysname);
+       lua_setfield(L, -2, "sysname");
+       lua_pushstring(L, uname_info.nodename);
+       lua_setfield(L, -2, "nodename");
+       lua_pushstring(L, uname_info.release);
+       lua_setfield(L, -2, "release");
+       lua_pushstring(L, uname_info.version);
+       lua_setfield(L, -2, "version");
+       lua_pushstring(L, uname_info.machine);
+       lua_setfield(L, -2, "machine");
+       return 1;
+}
+
 /* Register functions */
 
 int luaopen_util_pposix(lua_State *L)
 {
-       lua_newtable(L);
+       luaL_Reg exports[] = {
+               { "abort", lc_abort },
 
-       lua_pushcfunction(L, lc_daemonize);
-       lua_setfield(L, -2, "daemonize");
+               { "daemonize", lc_daemonize },
 
-       lua_pushcfunction(L, lc_syslog_open);
-       lua_setfield(L, -2, "syslog_open");
+               { "syslog_open", lc_syslog_open },
+               { "syslog_close", lc_syslog_close },
+               { "syslog_log", lc_syslog_log },
+               { "syslog_setminlevel", lc_syslog_setmask },
 
-       lua_pushcfunction(L, lc_syslog_close);
-       lua_setfield(L, -2, "syslog_close");
+               { "getpid", lc_getpid },
+               { "getuid", lc_getuid },
+               { "getgid", lc_getgid },
 
-       lua_pushcfunction(L, lc_syslog_log);
-       lua_setfield(L, -2, "syslog_log");
+               { "setuid", lc_setuid },
+               { "setgid", lc_setgid },
+               { "initgroups", lc_initgroups },
 
-       lua_pushcfunction(L, lc_syslog_setmask);
-       lua_setfield(L, -2, "syslog_setminlevel");
+               { "umask", lc_umask },
 
-       lua_pushcfunction(L, lc_getpid);
-       lua_setfield(L, -2, "getpid");
+               { "mkdir", lc_mkdir },
 
-       lua_pushcfunction(L, lc_getuid);
-       lua_setfield(L, -2, "getuid");
-       lua_pushcfunction(L, lc_getgid);
-       lua_setfield(L, -2, "getgid");
+               { "setrlimit", lc_setrlimit },
+               { "getrlimit", lc_getrlimit },
 
-       lua_pushcfunction(L, lc_setuid);
-       lua_setfield(L, -2, "setuid");
-       lua_pushcfunction(L, lc_setgid);
-       lua_setfield(L, -2, "setgid");
-       
-       lua_pushcfunction(L, lc_setrlimit);
-       lua_setfield(L, -2, "setrlimit");
-       
-       lua_pushcfunction(L, lc_getrlimit);
-       lua_setfield(L, -2, "getrlimit");
+               { "uname", lc_uname },
+
+               { NULL, NULL }
+       };
+
+       luaL_register(L, "pposix",  exports);
 
        lua_pushliteral(L, "pposix");
        lua_setfield(L, -2, "_NAME");
 
        lua_pushliteral(L, MODULE_VERSION);
        lua_setfield(L, -2, "_VERSION");
-       
+
        return 1;
-};
+}