snac2/main.c
2023-02-05 19:54:41 +01:00

308 lines
7.2 KiB
C

/* snac - A simple, minimalistic ActivityPub instance */
/* copyright (c) 2022 - 2023 grunfink / MIT license */
#include "xs.h"
#include "xs_io.h"
#include "xs_encdec.h"
#include "xs_json.h"
#include "snac.h"
int usage(void)
{
printf("snac " VERSION " - A simple, minimalistic ActivityPub instance\n");
printf("Copyright (c) 2022 - 2023 grunfink / MIT license\n");
printf("\n");
printf("Commands:\n");
printf("\n");
printf("init [{basedir}] Initializes the data storage\n");
printf("upgrade {basedir} Upgrade to a new version\n");
printf("adduser {basedir} [{uid}] Adds a new user\n");
printf("httpd {basedir} Starts the HTTPD daemon\n");
printf("purge {basedir} Purges old data\n");
printf("webfinger {basedir} {user} Queries about a @user@host or actor\n");
printf("queue {basedir} {uid} Processes a user queue\n");
printf("follow {basedir} {uid} {actor} Follows an actor\n");
printf("unfollow {basedir} {uid} {actor} Unfollows an actor\n");
printf("request {basedir} {uid} {url} Requests an object\n");
printf("actor {basedir} {uid} {url} Requests an actor\n");
printf("note {basedir} {uid} {'text'} Sends a note to followers\n");
printf("resetpwd {basedir} {uid} Resets the password of a user\n");
return 1;
}
char *get_argv(int *argi, int argc, char *argv[])
{
if (*argi < argc)
return argv[(*argi)++];
else
return NULL;
}
#define GET_ARGV() get_argv(&argi, argc, argv)
d_char *html_timeline(snac *snac, char *list, int local);
int main(int argc, char *argv[])
{
char *cmd;
char *basedir;
char *user;
char *url;
int argi = 1;
snac snac;
if ((cmd = GET_ARGV()) == NULL)
return usage();
if (strcmp(cmd, "init") == 0) {
/* initialize the data storage */
/* ... */
basedir = GET_ARGV();
return snac_init(basedir);
}
if (strcmp(cmd, "upgrade") == 0) {
int ret;
/* upgrade */
if ((basedir = GET_ARGV()) == NULL)
return usage();
if ((ret = srv_open(basedir, 1)) == 1)
srv_log(xs_dup("OK"));
return ret;
}
if (strcmp(cmd, "markdown") == 0) {
/* undocumented, for testing only */
xs *c = xs_readall(stdin);
xs *fc = not_really_markdown(c);
printf("<html>\n%s\n</html>\n", fc);
return 0;
}
if ((basedir = GET_ARGV()) == NULL)
return usage();
if (!srv_open(basedir, 0)) {
srv_log(xs_fmt("error opening data storage at %s", basedir));
return 1;
}
if (strcmp(cmd, "adduser") == 0) {
user = GET_ARGV();
return adduser(user);
return 0;
}
if (strcmp(cmd, "httpd") == 0) {
httpd();
srv_free();
return 0;
}
if (strcmp(cmd, "purge") == 0) {
purge_all();
return 0;
}
if ((user = GET_ARGV()) == NULL)
return usage();
if (strcmp(cmd, "webfinger") == 0) {
xs *actor = NULL;
xs *uid = NULL;
int status;
status = webfinger_request(user, &actor, &uid);
printf("status: %d\n", status);
if (actor != NULL)
printf("actor: %s\n", actor);
if (uid != NULL)
printf("uid: %s\n", uid);
return 0;
}
if (!user_open(&snac, user)) {
printf("error in user '%s'\n", user);
return 1;
}
if (strcmp(cmd, "resetpwd") == 0) {
return resetpwd(&snac);
}
if (strcmp(cmd, "queue") == 0) {
process_user_queue(&snac);
return 0;
}
if (strcmp(cmd, "timeline") == 0) {
#if 0
xs *list = local_list(&snac, XS_ALL);
xs *body = html_timeline(&snac, list, 1);
printf("%s\n", body);
user_free(&snac);
srv_free();
#endif
xs *idx = xs_fmt("%s/private.idx", snac.basedir);
xs *list = index_list_desc(idx, 0, 256);
xs *tl = timeline_top_level(list);
xs *j = xs_json_dumps_pp(tl, 4);
printf("%s\n", j);
return 0;
}
if ((url = GET_ARGV()) == NULL)
return usage();
if (strcmp(cmd, "announce") == 0) {
xs *msg = msg_admiration(&snac, url, "Announce");
if (msg != NULL) {
enqueue_message(&snac, msg);
if (dbglevel) {
xs *j = xs_json_dumps_pp(msg, 4);
printf("%s\n", j);
}
}
return 0;
}
if (strcmp(cmd, "follow") == 0) {
xs *msg = msg_follow(&snac, url);
if (msg != NULL) {
char *actor = xs_dict_get(msg, "object");
following_add(&snac, actor, msg);
enqueue_output_by_actor(&snac, msg, actor, 0);
if (dbglevel) {
xs *j = xs_json_dumps_pp(msg, 4);
printf("%s\n", j);
}
}
return 0;
}
if (strcmp(cmd, "unfollow") == 0) {
xs *object = NULL;
if (valid_status(following_get(&snac, url, &object))) {
xs *msg = msg_undo(&snac, xs_dict_get(object, "object"));
following_del(&snac, url);
enqueue_output_by_actor(&snac, msg, url, 0);
snac_log(&snac, xs_fmt("unfollowed actor %s", url));
}
else
snac_log(&snac, xs_fmt("actor is not being followed %s", url));
return 0;
}
if (strcmp(cmd, "request") == 0) {
int status;
xs *data = NULL;
status = activitypub_request(&snac, url, &data);
printf("status: %d\n", status);
if (valid_status(status)) {
xs *j = xs_json_dumps_pp(data, 4);
printf("%s\n", j);
}
return 0;
}
if (strcmp(cmd, "actor") == 0) {
int status;
xs *data = NULL;
status = actor_request(&snac, url, &data);
printf("status: %d\n", status);
if (valid_status(status)) {
xs *j = xs_json_dumps_pp(data, 4);
printf("%s\n", j);
}
return 0;
}
if (strcmp(cmd, "note") == 0) {
xs *content = NULL;
xs *msg = NULL;
xs *c_msg = NULL;
char *in_reply_to = GET_ARGV();
if (strcmp(url, "-e") == 0) {
/* get the content from an editor */
FILE *f;
unlink("/tmp/snac-edit.txt");
system("$EDITOR /tmp/snac-edit.txt");
if ((f = fopen("/tmp/snac-edit.txt", "r")) != NULL) {
content = xs_readall(f);
fclose(f);
unlink("/tmp/snac-edit.txt");
}
else {
printf("Nothing to send\n");
return 1;
}
}
else
if (strcmp(url, "-") == 0) {
/* get the content from stdin */
content = xs_readall(stdin);
}
else
content = xs_dup(url);
msg = msg_note(&snac, content, NULL, in_reply_to, NULL);
c_msg = msg_create(&snac, msg);
if (dbglevel) {
xs *j = xs_json_dumps_pp(c_msg, 4);
printf("%s\n", j);
}
enqueue_message(&snac, c_msg);
timeline_add(&snac, xs_dict_get(msg, "id"), msg);
return 0;
}
return 0;
}