summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--main.c14
-rw-r--r--snac.h1
-rw-r--r--utils.c118
3 files changed, 129 insertions, 4 deletions
diff --git a/main.c b/main.c
index 64de82c..18c7c22 100644
--- a/main.c
+++ b/main.c
@@ -16,6 +16,7 @@ int usage(void)
printf("Commands:\n");
printf("\n");
printf("init [{basedir}] Initializes the database\n");
+ printf("adduser {basedir} [{uid}] Adds a new user\n");
printf("httpd {basedir} Starts the HTTPD daemon\n");
printf("webfinger {basedir} {user} Queries about a @user@host or actor\n");
printf("queue {basedir} {uid} Processes a user queue\n");
@@ -23,7 +24,6 @@ int usage(void)
// printf("check {basedir} [{uid}] Checks the database\n");
// printf("purge {basedir} [{uid}] Purges old data\n");
-// printf("adduser {basedir} [{uid}] Adds a new user\n");
// printf("update {basedir} {uid} Sends a user update to followers\n");
// printf("passwd {basedir} {uid} Sets the password for {uid}\n");
@@ -71,9 +71,7 @@ int main(int argc, char *argv[])
/* ... */
basedir = GET_ARGV();
- initdb(basedir);
-
- return 0;
+ return initdb(basedir);
}
if ((basedir = GET_ARGV()) == NULL)
@@ -84,6 +82,14 @@ int main(int argc, char *argv[])
return 1;
}
+ if (strcmp(cmd, "adduser") == 0) {
+ user = GET_ARGV();
+
+ return adduser(user);
+
+ return 0;
+ }
+
if (strcmp(cmd, "httpd") == 0) {
httpd();
return 0;
diff --git a/snac.h b/snac.h
index d9b2e3b..9a387ad 100644
--- a/snac.h
+++ b/snac.h
@@ -134,3 +134,4 @@ int html_post_handler(d_char *req, char *q_path, d_char *payload, int p_size,
char **body, int *b_size, char **ctype);
int initdb(const char *_basedir);
+int adduser(char *uid);
diff --git a/utils.c b/utils.c
index 028f863..422c907 100644
--- a/utils.c
+++ b/utils.c
@@ -5,10 +5,13 @@
#include "xs_io.h"
#include "xs_encdec.h"
#include "xs_json.h"
+#include "xs_time.h"
+#include "xs_openssl.h"
#include "snac.h"
#include <sys/stat.h>
+#include <stdlib.h>
const char *default_srv_config = "{"
"\"host\": \"\","
@@ -172,3 +175,118 @@ int initdb(const char *basedir)
printf("Done.\n");
return 0;
}
+
+
+int adduser(char *uid)
+/* creates a new user */
+{
+ snac snac;
+ xs *config = xs_dict_new();
+ xs *date = xs_str_utctime(0, "%Y-%m-%dT%H:%M:%SZ");
+ int rndbuf[3];
+ xs *pwd = NULL;
+ xs *pwd_f = NULL;
+ xs *key = NULL;
+ FILE *f;
+
+ if (uid == NULL) {
+ printf("User id:\n");
+ uid = xs_strip(xs_readline(stdin));
+ }
+
+ if (!validate_uid(uid)) {
+ printf("ERROR: only alphanumeric characters and _ are allowed in user ids.\n");
+ return 1;
+ }
+
+ if (user_open(&snac, uid)) {
+ printf("ERROR: user '%s' already exists\n", uid);
+ return 1;
+ }
+
+ srandom(time(NULL) ^ getpid());
+ rndbuf[0] = random() & 0xffffffff;
+ rndbuf[1] = random() & 0xffffffff;
+ rndbuf[2] = random() & 0xffffffff;
+
+ pwd = xs_base64_enc((char *)rndbuf, sizeof(rndbuf));
+ pwd_f = hash_password(uid, pwd, NULL);
+
+ config = xs_dict_append(config, "uid", uid);
+ config = xs_dict_append(config, "name", uid);
+ config = xs_dict_append(config, "avatar", "");
+ config = xs_dict_append(config, "bio", "");
+ config = xs_dict_append(config, "published", date);
+ config = xs_dict_append(config, "password", pwd_f);
+
+ xs *basedir = xs_fmt("%s/user/%s", srv_basedir, uid);
+
+ if (mkdir(basedir, 0755) == -1) {
+ printf("ERROR: cannot create directory '%s'\n", basedir);
+ return 0;
+ }
+
+ const char *dirs[] = {
+ "actors", "followers", "following", "local", "muted",
+ "queue", "static", "timeline", "history", NULL };
+ int n;
+
+ for (n = 0; dirs[n]; n++) {
+ xs *d = xs_fmt("%s/%s", basedir, dirs[n]);
+ mkdir(d, 0755);
+ }
+
+ xs *scssfn = xs_fmt("%s/style.css", srv_basedir);
+ xs *ucssfn = xs_fmt("%s/static/style.css", basedir);
+
+ if ((f = fopen(scssfn, "r")) != NULL) {
+ FILE *i;
+
+ if ((i = fopen(ucssfn, "w")) == NULL) {
+ printf("ERROR: cannot create file '%s'\n", ucssfn);
+ return 1;
+ }
+ else {
+ xs *c = xs_readall(f);
+ fwrite(c, strlen(c), 1, i);
+
+ fclose(i);
+ }
+
+ fclose(f);
+ }
+
+ xs *cfn = xs_fmt("%s/user.json", basedir);
+
+ if ((f = fopen(cfn, "w")) == NULL) {
+ printf("ERROR: cannot create '%s'\n", cfn);
+ return 1;
+ }
+ else {
+ xs *j = xs_json_dumps_pp(config, 4);
+ fwrite(j, strlen(j), 1, f);
+ fclose(f);
+ }
+
+ printf("\nCreating RSA key...\n");
+ key = xs_rsa_genkey(4096);
+ printf("Done.\n");
+
+ xs *kfn = xs_fmt("%s/key.json", basedir);
+
+ if ((f = fopen(kfn, "w")) == NULL) {
+ printf("ERROR: cannot create '%s'\n", kfn);
+ return 1;
+ }
+ else {
+ xs *j = xs_json_dumps_pp(key, 4);
+ fwrite(j, strlen(j), 1, f);
+ fclose(f);
+ }
+
+ printf("\nUser password is %s\n", pwd);
+
+ printf("\nGo to %s/%s and keep configuring your user.\n", srv_baseurl, uid);
+
+ return 0;
+}