data.c 47 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048
  1. /* snac - A simple, minimalistic ActivityPub instance */
  2. /* copyright (c) 2022 - 2023 grunfink / MIT license */
  3. #include "xs.h"
  4. #include "xs_io.h"
  5. #include "xs_json.h"
  6. #include "xs_openssl.h"
  7. #include "xs_glob.h"
  8. #include "xs_set.h"
  9. #include "xs_time.h"
  10. #include "snac.h"
  11. #include <time.h>
  12. #include <sys/stat.h>
  13. #include <sys/file.h>
  14. #include <fcntl.h>
  15. #include <pthread.h>
  16. double disk_layout = 2.7;
  17. /* storage serializer */
  18. pthread_mutex_t data_mutex = {0};
  19. int snac_upgrade(d_char **error);
  20. int srv_open(char *basedir, int auto_upgrade)
  21. /* opens a server */
  22. {
  23. int ret = 0;
  24. xs *cfg_file = NULL;
  25. FILE *f;
  26. d_char *error = NULL;
  27. pthread_mutex_init(&data_mutex, NULL);
  28. srv_basedir = xs_str_new(basedir);
  29. if (xs_endswith(srv_basedir, "/"))
  30. srv_basedir = xs_crop_i(srv_basedir, 0, -1);
  31. cfg_file = xs_fmt("%s/server.json", basedir);
  32. if ((f = fopen(cfg_file, "r")) == NULL)
  33. error = xs_fmt("ERROR: cannot opening '%s'", cfg_file);
  34. else {
  35. xs *cfg_data;
  36. /* read full config file */
  37. cfg_data = xs_readall(f);
  38. fclose(f);
  39. /* parse */
  40. srv_config = xs_json_loads(cfg_data);
  41. if (srv_config == NULL)
  42. error = xs_fmt("ERROR: cannot parse '%s'", cfg_file);
  43. else {
  44. char *host;
  45. char *prefix;
  46. char *dbglvl;
  47. host = xs_dict_get(srv_config, "host");
  48. prefix = xs_dict_get(srv_config, "prefix");
  49. dbglvl = xs_dict_get(srv_config, "dbglevel");
  50. if (host == NULL || prefix == NULL)
  51. error = xs_str_new("ERROR: cannot get server data");
  52. else {
  53. srv_baseurl = xs_fmt("https://%s%s", host, prefix);
  54. dbglevel = (int) xs_number_get(dbglvl);
  55. if ((dbglvl = getenv("DEBUG")) != NULL) {
  56. dbglevel = atoi(dbglvl);
  57. error = xs_fmt("DEBUG level set to %d from environment", dbglevel);
  58. }
  59. if (auto_upgrade)
  60. ret = snac_upgrade(&error);
  61. else {
  62. if (xs_number_get(xs_dict_get(srv_config, "layout")) < disk_layout)
  63. error = xs_fmt("ERROR: disk layout changed - execute 'snac upgrade' first");
  64. else
  65. ret = 1;
  66. }
  67. }
  68. }
  69. }
  70. if (error != NULL)
  71. srv_log(error);
  72. /* create the queue/ subdir, just in case */
  73. xs *qdir = xs_fmt("%s/queue", srv_basedir);
  74. mkdirx(qdir);
  75. xs *ibdir = xs_fmt("%s/inbox", srv_basedir);
  76. mkdirx(ibdir);
  77. #ifdef __OpenBSD__
  78. char *v = xs_dict_get(srv_config, "disable_openbsd_security");
  79. if (v && xs_type(v) == XSTYPE_TRUE) {
  80. srv_debug(1, xs_dup("OpenBSD security disabled by admin"));
  81. }
  82. else {
  83. srv_debug(1, xs_fmt("Calling unveil()"));
  84. unveil(basedir, "rwc");
  85. unveil("/usr/sbin/sendmail", "x");
  86. unveil("/etc/resolv.conf", "r");
  87. unveil("/etc/hosts", "r");
  88. unveil("/etc/ssl/openssl.cnf", "r");
  89. unveil("/etc/ssl/cert.pem", "r");
  90. unveil("/usr/share/zoneinfo", "r");
  91. unveil(NULL, NULL);
  92. srv_debug(1, xs_fmt("Calling pledge()"));
  93. pledge("stdio rpath wpath cpath flock inet proc exec dns fattr", NULL);
  94. }
  95. #endif /* __OpenBSD__ */
  96. return ret;
  97. }
  98. void srv_free(void)
  99. {
  100. xs_free(srv_basedir);
  101. xs_free(srv_config);
  102. xs_free(srv_baseurl);
  103. pthread_mutex_destroy(&data_mutex);
  104. }
  105. void user_free(snac *snac)
  106. /* frees a user snac */
  107. {
  108. xs_free(snac->uid);
  109. xs_free(snac->basedir);
  110. xs_free(snac->config);
  111. xs_free(snac->config_o);
  112. xs_free(snac->key);
  113. xs_free(snac->actor);
  114. xs_free(snac->md5);
  115. }
  116. int user_open(snac *snac, const char *uid)
  117. /* opens a user */
  118. {
  119. int ret = 0;
  120. memset(snac, '\0', sizeof(struct _snac));
  121. if (validate_uid(uid)) {
  122. xs *cfg_file;
  123. FILE *f;
  124. snac->uid = xs_str_new(uid);
  125. snac->basedir = xs_fmt("%s/user/%s", srv_basedir, uid);
  126. cfg_file = xs_fmt("%s/user.json", snac->basedir);
  127. if ((f = fopen(cfg_file, "r")) != NULL) {
  128. xs *cfg_data;
  129. /* read full config file */
  130. cfg_data = xs_readall(f);
  131. fclose(f);
  132. if ((snac->config = xs_json_loads(cfg_data)) != NULL) {
  133. xs *key_file = xs_fmt("%s/key.json", snac->basedir);
  134. if ((f = fopen(key_file, "r")) != NULL) {
  135. xs *key_data;
  136. key_data = xs_readall(f);
  137. fclose(f);
  138. if ((snac->key = xs_json_loads(key_data)) != NULL) {
  139. snac->actor = xs_fmt("%s/%s", srv_baseurl, uid);
  140. snac->md5 = xs_md5_hex(snac->actor, strlen(snac->actor));
  141. /* everything is ok right now */
  142. ret = 1;
  143. /* does it have a configuration override? */
  144. xs *cfg_file_o = xs_fmt("%s/user_o.json", snac->basedir);
  145. if ((f = fopen(cfg_file_o, "r")) != NULL) {
  146. xs *j = xs_readall(f);
  147. fclose(f);
  148. if ((snac->config_o = xs_json_loads(j)) == NULL)
  149. srv_log(xs_fmt("error parsing '%s'", cfg_file_o));
  150. }
  151. if (snac->config_o == NULL)
  152. snac->config_o = xs_dict_new();
  153. }
  154. else
  155. srv_log(xs_fmt("error parsing '%s'", key_file));
  156. }
  157. else
  158. srv_log(xs_fmt("error opening '%s' %d", key_file, errno));
  159. }
  160. else
  161. srv_log(xs_fmt("error parsing '%s'", cfg_file));
  162. }
  163. else
  164. srv_debug(2, xs_fmt("error opening '%s' %d", cfg_file, errno));
  165. }
  166. else
  167. srv_debug(1, xs_fmt("invalid user '%s'", uid));
  168. if (!ret)
  169. user_free(snac);
  170. return ret;
  171. }
  172. d_char *user_list(void)
  173. /* returns the list of user ids */
  174. {
  175. xs *spec = xs_fmt("%s/user/" "*", srv_basedir);
  176. return xs_glob(spec, 1, 0);
  177. }
  178. double mtime_nl(const char *fn, int *n_link)
  179. /* returns the mtime and number of links of a file or directory, or 0.0 */
  180. {
  181. struct stat st;
  182. double r = 0.0;
  183. int n = 0;
  184. if (fn && stat(fn, &st) != -1) {
  185. r = (double) st.st_mtim.tv_sec;
  186. n = st.st_nlink;
  187. }
  188. if (n_link)
  189. *n_link = n;
  190. return r;
  191. }
  192. #define MIN(v1, v2) ((v1) < (v2) ? (v1) : (v2))
  193. double f_ctime(const char *fn)
  194. /* returns the ctime of a file or directory, or 0.0 */
  195. {
  196. struct stat st;
  197. double r = 0.0;
  198. if (fn && stat(fn, &st) != -1) {
  199. /* return the lowest of ctime and mtime;
  200. there are operations that change the ctime, like link() */
  201. r = (double) MIN(st.st_ctim.tv_sec, st.st_mtim.tv_sec);
  202. }
  203. return r;
  204. }
  205. /** database 2.1+ **/
  206. /** indexes **/
  207. int index_add_md5(const char *fn, const char *md5)
  208. /* adds an md5 to an index */
  209. {
  210. int status = 201; /* Created */
  211. FILE *f;
  212. pthread_mutex_lock(&data_mutex);
  213. if ((f = fopen(fn, "a")) != NULL) {
  214. flock(fileno(f), LOCK_EX);
  215. /* ensure the position is at the end after getting the lock */
  216. fseek(f, 0, SEEK_END);
  217. fprintf(f, "%s\n", md5);
  218. fclose(f);
  219. }
  220. else
  221. status = 500;
  222. pthread_mutex_unlock(&data_mutex);
  223. return status;
  224. }
  225. int index_add(const char *fn, const char *id)
  226. /* adds an id to an index */
  227. {
  228. xs *md5 = xs_md5_hex(id, strlen(id));
  229. return index_add_md5(fn, md5);
  230. }
  231. int index_gc(const char *fn)
  232. /* garbage-collects an index, deleting objects that are not here */
  233. {
  234. FILE *i, *o;
  235. int gc = -1;
  236. pthread_mutex_lock(&data_mutex);
  237. if ((i = fopen(fn, "r")) != NULL) {
  238. xs *nfn = xs_fmt("%s.new", fn);
  239. char line[256];
  240. if ((o = fopen(nfn, "w")) != NULL) {
  241. gc = 0;
  242. while (fgets(line, sizeof(line), i) != NULL) {
  243. line[32] = '\0';
  244. if (object_here_by_md5(line))
  245. fprintf(o, "%s\n", line);
  246. else
  247. gc++;
  248. }
  249. fclose(o);
  250. xs *ofn = xs_fmt("%s.bak", fn);
  251. unlink(ofn);
  252. link(fn, ofn);
  253. rename(nfn, fn);
  254. }
  255. fclose(i);
  256. }
  257. pthread_mutex_unlock(&data_mutex);
  258. return gc;
  259. }
  260. int index_in_md5(const char *fn, const char *md5)
  261. /* checks if the md5 is already in the index */
  262. {
  263. FILE *f;
  264. int ret = 0;
  265. if ((f = fopen(fn, "r")) != NULL) {
  266. flock(fileno(f), LOCK_SH);
  267. char line[256];
  268. while (!ret && fgets(line, sizeof(line), f) != NULL) {
  269. line[32] = '\0';
  270. if (strcmp(line, md5) == 0)
  271. ret = 1;
  272. }
  273. fclose(f);
  274. }
  275. return ret;
  276. }
  277. int index_in(const char *fn, const char *id)
  278. /* checks if the object id is already in the index */
  279. {
  280. xs *md5 = xs_md5_hex(id, strlen(id));
  281. return index_in_md5(fn, md5);
  282. }
  283. int index_first(const char *fn, char *line, int size)
  284. /* reads the first entry of an index */
  285. {
  286. FILE *f;
  287. int ret = 0;
  288. if ((f = fopen(fn, "r")) != NULL) {
  289. flock(fileno(f), LOCK_SH);
  290. if (fgets(line, size, f) != NULL) {
  291. line[32] = '\0';
  292. ret = 1;
  293. }
  294. fclose(f);
  295. }
  296. return ret;
  297. }
  298. int index_len(const char *fn)
  299. /* returns the number of elements in an index */
  300. {
  301. struct stat st;
  302. int len = 0;
  303. if (stat(fn, &st) != -1)
  304. len = st.st_size / 33;
  305. return len;
  306. }
  307. d_char *index_list(const char *fn, int max)
  308. /* returns an index as a list */
  309. {
  310. d_char *list = NULL;
  311. FILE *f;
  312. int n = 0;
  313. if ((f = fopen(fn, "r")) != NULL) {
  314. flock(fileno(f), LOCK_SH);
  315. char line[256];
  316. list = xs_list_new();
  317. while (n < max && fgets(line, sizeof(line), f) != NULL) {
  318. line[32] = '\0';
  319. list = xs_list_append(list, line);
  320. n++;
  321. }
  322. fclose(f);
  323. }
  324. return list;
  325. }
  326. d_char *index_list_desc(const char *fn, int skip, int show)
  327. /* returns an index as a list, in reverse order */
  328. {
  329. d_char *list = NULL;
  330. FILE *f;
  331. int n = 0;
  332. if ((f = fopen(fn, "r")) != NULL) {
  333. flock(fileno(f), LOCK_SH);
  334. char line[256];
  335. list = xs_list_new();
  336. /* move to the end minus one entry (or more, if skipping entries) */
  337. if (!fseek(f, 0, SEEK_END) && !fseek(f, (skip + 1) * -33, SEEK_CUR)) {
  338. while (n < show && fgets(line, sizeof(line), f) != NULL) {
  339. line[32] = '\0';
  340. list = xs_list_append(list, line);
  341. n++;
  342. /* move backwards 2 entries */
  343. if (fseek(f, -66, SEEK_CUR) == -1)
  344. break;
  345. }
  346. }
  347. fclose(f);
  348. }
  349. return list;
  350. }
  351. /** objects **/
  352. d_char *_object_fn_by_md5(const char *md5)
  353. {
  354. xs *bfn = xs_fmt("%s/object/%c%c", srv_basedir, md5[0], md5[1]);
  355. mkdirx(bfn);
  356. return xs_fmt("%s/%s.json", bfn, md5);
  357. }
  358. d_char *_object_fn(const char *id)
  359. {
  360. xs *md5 = xs_md5_hex(id, strlen(id));
  361. return _object_fn_by_md5(md5);
  362. }
  363. int object_here_by_md5(char *id)
  364. /* checks if an object is already downloaded */
  365. {
  366. xs *fn = _object_fn_by_md5(id);
  367. return mtime(fn) > 0.0;
  368. }
  369. int object_here(char *id)
  370. /* checks if an object is already downloaded */
  371. {
  372. xs *fn = _object_fn(id);
  373. return mtime(fn) > 0.0;
  374. }
  375. int object_get_by_md5(const char *md5, xs_dict **obj)
  376. /* returns a stored object, optionally of the requested type */
  377. {
  378. int status = 404;
  379. xs *fn = _object_fn_by_md5(md5);
  380. FILE *f;
  381. if ((f = fopen(fn, "r")) != NULL) {
  382. flock(fileno(f), LOCK_SH);
  383. xs *j = xs_readall(f);
  384. fclose(f);
  385. *obj = xs_json_loads(j);
  386. if (*obj)
  387. status = 200;
  388. }
  389. else
  390. *obj = NULL;
  391. return status;
  392. }
  393. int object_get(const char *id, xs_dict **obj)
  394. /* returns a stored object, optionally of the requested type */
  395. {
  396. xs *md5 = xs_md5_hex(id, strlen(id));
  397. return object_get_by_md5(md5, obj);
  398. }
  399. int _object_add(const char *id, d_char *obj, int ow)
  400. /* stores an object */
  401. {
  402. int status = 201; /* Created */
  403. xs *fn = _object_fn(id);
  404. FILE *f;
  405. if (!ow && mtime(fn) > 0.0) {
  406. /* object already here */
  407. srv_debug(1, xs_fmt("object_add object already here %s", id));
  408. return 204; /* No content */
  409. }
  410. if ((f = fopen(fn, "w")) != NULL) {
  411. flock(fileno(f), LOCK_EX);
  412. xs *j = xs_json_dumps_pp(obj, 4);
  413. fwrite(j, strlen(j), 1, f);
  414. fclose(f);
  415. /* does this object has a parent? */
  416. char *in_reply_to = xs_dict_get(obj, "inReplyTo");
  417. if (!xs_is_null(in_reply_to) && *in_reply_to) {
  418. /* update the children index of the parent */
  419. xs *c_idx = _object_fn(in_reply_to);
  420. c_idx = xs_replace_i(c_idx, ".json", "_c.idx");
  421. if (!index_in(c_idx, id)) {
  422. index_add(c_idx, id);
  423. srv_debug(1, xs_fmt("object_add added child %s to %s", id, c_idx));
  424. }
  425. else
  426. srv_debug(1, xs_fmt("object_add %s child already in %s", id, c_idx));
  427. /* create a one-element index with the parent */
  428. xs *p_idx = xs_replace(fn, ".json", "_p.idx");
  429. if (mtime(p_idx) == 0.0) {
  430. index_add(p_idx, in_reply_to);
  431. srv_debug(1, xs_fmt("object_add added parent %s to %s", in_reply_to, p_idx));
  432. }
  433. }
  434. }
  435. else {
  436. srv_log(xs_fmt("object_add error writing %s (errno: %d)", fn, errno));
  437. status = 500;
  438. }
  439. srv_debug(1, xs_fmt("object_add %s %s %d", id, fn, status));
  440. return status;
  441. }
  442. int object_add(const char *id, d_char *obj)
  443. /* stores an object */
  444. {
  445. return _object_add(id, obj, 0);
  446. }
  447. int object_add_ow(const char *id, d_char *obj)
  448. /* stores an object (overwriting allowed) */
  449. {
  450. return _object_add(id, obj, 1);
  451. }
  452. int object_del_by_md5(const char *md5)
  453. /* deletes an object by its md5 */
  454. {
  455. int status = 404;
  456. xs *fn = _object_fn_by_md5(md5);
  457. if (unlink(fn) != -1) {
  458. status = 200;
  459. /* also delete associated indexes */
  460. xs *spec = xs_dup(fn);
  461. spec = xs_replace_i(spec, ".json", "*.idx");
  462. xs *files = xs_glob(spec, 0, 0);
  463. char *p, *v;
  464. p = files;
  465. while (xs_list_iter(&p, &v)) {
  466. srv_debug(1, xs_fmt("object_del index %s", v));
  467. unlink(v);
  468. }
  469. }
  470. srv_debug(1, xs_fmt("object_del %s %d", fn, status));
  471. return status;
  472. }
  473. int object_del(const char *id)
  474. /* deletes an object */
  475. {
  476. xs *md5 = xs_md5_hex(id, strlen(id));
  477. return object_del_by_md5(md5);
  478. }
  479. int object_del_if_unref(const char *id)
  480. /* deletes an object if its n_links < 2 */
  481. {
  482. xs *fn = _object_fn(id);
  483. int n_links;
  484. int ret = 0;
  485. if (mtime_nl(fn, &n_links) > 0.0 && n_links < 2)
  486. ret = object_del(id);
  487. return ret;
  488. }
  489. double object_ctime_by_md5(const char *md5)
  490. {
  491. xs *fn = _object_fn_by_md5(md5);
  492. return f_ctime(fn);
  493. }
  494. double object_ctime(const char *id)
  495. {
  496. xs *md5 = xs_md5_hex(id, strlen(id));
  497. return object_ctime_by_md5(md5);
  498. }
  499. d_char *_object_index_fn(const char *id, const char *idxsfx)
  500. /* returns the filename of an object's index */
  501. {
  502. d_char *fn = _object_fn(id);
  503. return xs_replace_i(fn, ".json", idxsfx);
  504. }
  505. int object_likes_len(const char *id)
  506. /* returns the number of likes (without reading the index) */
  507. {
  508. xs *fn = _object_index_fn(id, "_l.idx");
  509. return index_len(fn);
  510. }
  511. int object_announces_len(const char *id)
  512. /* returns the number of announces (without reading the index) */
  513. {
  514. xs *fn = _object_index_fn(id, "_a.idx");
  515. return index_len(fn);
  516. }
  517. d_char *object_children(const char *id)
  518. /* returns the list of an object's children */
  519. {
  520. xs *fn = _object_index_fn(id, "_c.idx");
  521. return index_list(fn, XS_ALL);
  522. }
  523. d_char *object_likes(const char *id)
  524. {
  525. xs *fn = _object_index_fn(id, "_l.idx");
  526. return index_list(fn, XS_ALL);
  527. }
  528. d_char *object_announces(const char *id)
  529. {
  530. xs *fn = _object_index_fn(id, "_a.idx");
  531. return index_list(fn, XS_ALL);
  532. }
  533. int object_parent(const char *id, char *buf, int size)
  534. /* returns the object parent, if any */
  535. {
  536. xs *fn = _object_fn_by_md5(id);
  537. fn = xs_replace_i(fn, ".json", "_p.idx");
  538. return index_first(fn, buf, size);
  539. }
  540. int object_admire(const char *id, const char *actor, int like)
  541. /* actor likes or announces this object */
  542. {
  543. int status = 200;
  544. xs *fn = _object_fn(id);
  545. fn = xs_replace_i(fn, ".json", like ? "_l.idx" : "_a.idx");
  546. if (!index_in(fn, actor)) {
  547. status = index_add(fn, actor);
  548. srv_debug(1, xs_fmt("object_admire (%s) %s %s", like ? "Like" : "Announce", actor, fn));
  549. }
  550. return status;
  551. }
  552. int _object_user_cache(snac *snac, const char *id, const char *cachedir, int del)
  553. /* adds or deletes from a user cache */
  554. {
  555. xs *ofn = _object_fn(id);
  556. xs *l = xs_split(ofn, "/");
  557. xs *cfn = xs_fmt("%s/%s/%s", snac->basedir, cachedir, xs_list_get(l, -1));
  558. xs *idx = xs_fmt("%s/%s.idx", snac->basedir, cachedir);
  559. int ret;
  560. if (del) {
  561. ret = unlink(cfn);
  562. }
  563. else {
  564. if ((ret = link(ofn, cfn)) != -1)
  565. index_add(idx, id);
  566. }
  567. return ret;
  568. }
  569. int object_user_cache_add(snac *snac, const char *id, const char *cachedir)
  570. /* caches an object into a user cache */
  571. {
  572. return _object_user_cache(snac, id, cachedir, 0);
  573. }
  574. int object_user_cache_del(snac *snac, const char *id, const char *cachedir)
  575. /* deletes an object from a user cache */
  576. {
  577. return _object_user_cache(snac, id, cachedir, 1);
  578. }
  579. int object_user_cache_in(snac *snac, const char *id, const char *cachedir)
  580. /* checks if an object is stored in a cache */
  581. {
  582. xs *md5 = xs_md5_hex(id, strlen(id));
  583. xs *cfn = xs_fmt("%s/%s/%s.json", snac->basedir, cachedir, md5);
  584. return !!(mtime(cfn) != 0.0);
  585. }
  586. d_char *object_user_cache_list(snac *snac, const char *cachedir, int max)
  587. /* returns the objects in a cache as a list */
  588. {
  589. xs *idx = xs_fmt("%s/%s.idx", snac->basedir, cachedir);
  590. return index_list(idx, max);
  591. }
  592. /** specialized functions **/
  593. /** followers **/
  594. int follower_add(snac *snac, const char *actor)
  595. /* adds a follower */
  596. {
  597. int ret = object_user_cache_add(snac, actor, "followers");
  598. snac_debug(snac, 2, xs_fmt("follower_add %s", actor));
  599. return ret == -1 ? 500 : 200;
  600. }
  601. int follower_del(snac *snac, const char *actor)
  602. /* deletes a follower */
  603. {
  604. int ret = object_user_cache_del(snac, actor, "followers");
  605. snac_debug(snac, 2, xs_fmt("follower_del %s", actor));
  606. return ret == -1 ? 404 : 200;
  607. }
  608. int follower_check(snac *snac, const char *actor)
  609. /* checks if someone is a follower */
  610. {
  611. return object_user_cache_in(snac, actor, "followers");
  612. }
  613. d_char *follower_list(snac *snac)
  614. /* returns the list of followers */
  615. {
  616. xs *list = object_user_cache_list(snac, "followers", XS_ALL);
  617. d_char *fwers = xs_list_new();
  618. char *p, *v;
  619. /* resolve the list of md5 to be a list of actors */
  620. p = list;
  621. while (xs_list_iter(&p, &v)) {
  622. xs *a_obj = NULL;
  623. if (valid_status(object_get_by_md5(v, &a_obj))) {
  624. char *actor = xs_dict_get(a_obj, "id");
  625. if (!xs_is_null(actor))
  626. fwers = xs_list_append(fwers, actor);
  627. }
  628. }
  629. return fwers;
  630. }
  631. /** timeline **/
  632. double timeline_mtime(snac *snac)
  633. {
  634. xs *fn = xs_fmt("%s/private.idx", snac->basedir);
  635. return mtime(fn);
  636. }
  637. xs_str *timeline_fn_by_md5(snac *snac, const char *md5)
  638. /* get the filename of an entry by md5 from any timeline */
  639. {
  640. xs_str *fn = xs_fmt("%s/private/%s.json", snac->basedir, md5);
  641. if (mtime(fn) == 0.0) {
  642. fn = xs_free(fn);
  643. fn = xs_fmt("%s/public/%s.json", snac->basedir, md5);
  644. if (mtime(fn) == 0.0)
  645. fn = xs_free(fn);
  646. }
  647. return fn;
  648. }
  649. int timeline_here(snac *snac, const char *md5)
  650. /* checks if an object is in the user cache */
  651. {
  652. xs *fn = timeline_fn_by_md5(snac, md5);
  653. return !(fn == NULL);
  654. }
  655. int timeline_get_by_md5(snac *snac, const char *md5, xs_dict **msg)
  656. /* gets a message from the timeline */
  657. {
  658. int status = 404;
  659. FILE *f = NULL;
  660. xs *fn = timeline_fn_by_md5(snac, md5);
  661. if (fn != NULL && (f = fopen(fn, "r")) != NULL) {
  662. flock(fileno(f), LOCK_SH);
  663. xs *j = xs_readall(f);
  664. fclose(f);
  665. if ((*msg = xs_json_loads(j)) != NULL)
  666. status = 200;
  667. }
  668. return status;
  669. }
  670. int timeline_del(snac *snac, char *id)
  671. /* deletes a message from the timeline */
  672. {
  673. /* delete from the user's caches */
  674. object_user_cache_del(snac, id, "public");
  675. object_user_cache_del(snac, id, "private");
  676. /* try to delete the object if it's not used elsewhere */
  677. return object_del_if_unref(id);
  678. }
  679. void timeline_update_indexes(snac *snac, const char *id)
  680. /* updates the indexes */
  681. {
  682. object_user_cache_add(snac, id, "private");
  683. if (xs_startswith(id, snac->actor)) {
  684. xs *msg = NULL;
  685. if (valid_status(object_get(id, &msg))) {
  686. /* if its ours and is public, also store in public */
  687. if (is_msg_public(snac, msg))
  688. object_user_cache_add(snac, id, "public");
  689. }
  690. }
  691. }
  692. int timeline_add(snac *snac, char *id, char *o_msg)
  693. /* adds a message to the timeline */
  694. {
  695. int ret = object_add(id, o_msg);
  696. timeline_update_indexes(snac, id);
  697. snac_debug(snac, 1, xs_fmt("timeline_add %s", id));
  698. return ret;
  699. }
  700. void timeline_admire(snac *snac, char *id, char *admirer, int like)
  701. /* updates a timeline entry with a new admiration */
  702. {
  703. /* if we are admiring this, add to both timelines */
  704. if (!like && strcmp(admirer, snac->actor) == 0) {
  705. object_user_cache_add(snac, id, "public");
  706. object_user_cache_add(snac, id, "private");
  707. }
  708. object_admire(id, admirer, like);
  709. snac_debug(snac, 1, xs_fmt("timeline_admire (%s) %s %s",
  710. like ? "Like" : "Announce", id, admirer));
  711. }
  712. xs_list *timeline_top_level(snac *snac, xs_list *list)
  713. /* returns the top level md5 entries from this index */
  714. {
  715. xs_set seen;
  716. xs_list *p;
  717. xs_str *v;
  718. xs_set_init(&seen);
  719. p = list;
  720. while (xs_list_iter(&p, &v)) {
  721. char line[256] = "";
  722. strcpy(line, v);
  723. for (;;) {
  724. char line2[256];
  725. /* if it doesn't have a parent, use this */
  726. if (!object_parent(line, line2, sizeof(line2)))
  727. break;
  728. /* well, there is a parent... but is it here? */
  729. if (!timeline_here(snac, line2))
  730. break;
  731. /* it's here! try again with its own parent */
  732. strcpy(line, line2);
  733. }
  734. xs_set_add(&seen, line);
  735. }
  736. return xs_set_result(&seen);
  737. }
  738. d_char *timeline_simple_list(snac *snac, const char *idx_name, int skip, int show)
  739. /* returns a timeline (with all entries) */
  740. {
  741. int c_max;
  742. /* maximum number of items in the timeline */
  743. c_max = xs_number_get(xs_dict_get(srv_config, "max_timeline_entries"));
  744. /* never more timeline entries than the configured maximum */
  745. if (show > c_max)
  746. show = c_max;
  747. xs *idx = xs_fmt("%s/%s.idx", snac->basedir, idx_name);
  748. return index_list_desc(idx, skip, show);
  749. }
  750. d_char *timeline_list(snac *snac, const char *idx_name, int skip, int show)
  751. /* returns a timeline (only top level entries) */
  752. {
  753. xs *list = timeline_simple_list(snac, idx_name, skip, show);
  754. return timeline_top_level(snac, list);
  755. }
  756. /** following **/
  757. /* this needs special treatment and cannot use the object db as is,
  758. with a link to a cached author, because we need the Follow object
  759. in case we need to unfollow (Undo + original Follow) */
  760. d_char *_following_fn(snac *snac, char *actor)
  761. {
  762. xs *md5 = xs_md5_hex(actor, strlen(actor));
  763. return xs_fmt("%s/following/%s.json", snac->basedir, md5);
  764. }
  765. int following_add(snac *snac, char *actor, char *msg)
  766. /* adds to the following list */
  767. {
  768. int ret = 201; /* created */
  769. xs *fn = _following_fn(snac, actor);
  770. FILE *f;
  771. if ((f = fopen(fn, "w")) != NULL) {
  772. xs *j = xs_json_dumps_pp(msg, 4);
  773. fwrite(j, 1, strlen(j), f);
  774. fclose(f);
  775. }
  776. else
  777. ret = 500;
  778. snac_debug(snac, 2, xs_fmt("following_add %s %s", actor, fn));
  779. return ret;
  780. }
  781. int following_del(snac *snac, char *actor)
  782. /* we're not following this actor any longer */
  783. {
  784. xs *fn = _following_fn(snac, actor);
  785. unlink(fn);
  786. snac_debug(snac, 2, xs_fmt("following_del %s %s", actor, fn));
  787. return 200;
  788. }
  789. int following_check(snac *snac, char *actor)
  790. /* checks if we are following this actor */
  791. {
  792. xs *fn = _following_fn(snac, actor);
  793. return !!(mtime(fn) != 0.0);
  794. }
  795. int following_get(snac *snac, char *actor, d_char **data)
  796. /* returns the 'Follow' object */
  797. {
  798. xs *fn = _following_fn(snac, actor);
  799. FILE *f;
  800. int status = 200;
  801. if ((f = fopen(fn, "r")) != NULL) {
  802. xs *j = xs_readall(f);
  803. fclose(f);
  804. *data = xs_json_loads(j);
  805. }
  806. else
  807. status = 404;
  808. return status;
  809. }
  810. d_char *following_list(snac *snac)
  811. /* returns the list of people being followed */
  812. {
  813. xs *spec = xs_fmt("%s/following/" "*.json", snac->basedir);
  814. xs *glist = xs_glob(spec, 0, 0);
  815. char *p, *v;
  816. d_char *list = xs_list_new();
  817. /* iterate the list of files */
  818. p = glist;
  819. while (xs_list_iter(&p, &v)) {
  820. FILE *f;
  821. /* load the follower data */
  822. if ((f = fopen(v, "r")) != NULL) {
  823. xs *j = xs_readall(f);
  824. fclose(f);
  825. if (j != NULL) {
  826. xs *o = xs_json_loads(j);
  827. if (o != NULL) {
  828. char *type = xs_dict_get(o, "type");
  829. if (!xs_is_null(type) && strcmp(type, "Accept") == 0) {
  830. char *actor = xs_dict_get(o, "actor");
  831. if (!xs_is_null(actor))
  832. list = xs_list_append(list, actor);
  833. }
  834. }
  835. }
  836. }
  837. }
  838. return list;
  839. }
  840. d_char *_muted_fn(snac *snac, char *actor)
  841. {
  842. xs *md5 = xs_md5_hex(actor, strlen(actor));
  843. return xs_fmt("%s/muted/%s", snac->basedir, md5);
  844. }
  845. void mute(snac *snac, char *actor)
  846. /* mutes a moron */
  847. {
  848. xs *fn = _muted_fn(snac, actor);
  849. FILE *f;
  850. if ((f = fopen(fn, "w")) != NULL) {
  851. fprintf(f, "%s\n", actor);
  852. fclose(f);
  853. snac_debug(snac, 2, xs_fmt("muted %s %s", actor, fn));
  854. }
  855. }
  856. void unmute(snac *snac, char *actor)
  857. /* actor is no longer a moron */
  858. {
  859. xs *fn = _muted_fn(snac, actor);
  860. unlink(fn);
  861. snac_debug(snac, 2, xs_fmt("unmuted %s %s", actor, fn));
  862. }
  863. int is_muted(snac *snac, char *actor)
  864. /* check if someone is muted */
  865. {
  866. xs *fn = _muted_fn(snac, actor);
  867. return !!(mtime(fn) != 0.0);
  868. }
  869. d_char *_hidden_fn(snac *snac, const char *id)
  870. {
  871. xs *md5 = xs_md5_hex(id, strlen(id));
  872. return xs_fmt("%s/hidden/%s", snac->basedir, md5);
  873. }
  874. void hide(snac *snac, const char *id)
  875. /* hides a message tree */
  876. {
  877. xs *fn = _hidden_fn(snac, id);
  878. FILE *f;
  879. if ((f = fopen(fn, "w")) != NULL) {
  880. fprintf(f, "%s\n", id);
  881. fclose(f);
  882. snac_debug(snac, 2, xs_fmt("hidden %s %s", id, fn));
  883. /* hide all the children */
  884. xs *chld = object_children(id);
  885. char *p, *v;
  886. p = chld;
  887. while (xs_list_iter(&p, &v)) {
  888. xs *co = NULL;
  889. /* resolve to get the id */
  890. if (valid_status(object_get_by_md5(v, &co))) {
  891. if ((v = xs_dict_get(co, "id")) != NULL)
  892. hide(snac, v);
  893. }
  894. }
  895. }
  896. }
  897. int is_hidden(snac *snac, const char *id)
  898. /* check is id is hidden */
  899. {
  900. xs *fn = _hidden_fn(snac, id);
  901. return !!(mtime(fn) != 0.0);
  902. }
  903. int actor_add(snac *snac, const char *actor, d_char *msg)
  904. /* adds an actor */
  905. {
  906. return object_add_ow(actor, msg);
  907. }
  908. int actor_get(snac *snac, const char *actor, d_char **data)
  909. /* returns an already downloaded actor */
  910. {
  911. int status = 200;
  912. d_char *d;
  913. if (strcmp(actor, snac->actor) == 0) {
  914. /* this actor */
  915. if (data)
  916. *data = msg_actor(snac);
  917. return status;
  918. }
  919. /* read the object */
  920. if (!valid_status(status = object_get(actor, &d)))
  921. return status;
  922. if (data)
  923. *data = d;
  924. else
  925. d = xs_free(d);
  926. xs *fn = _object_fn(actor);
  927. double max_time;
  928. /* maximum time for the actor data to be considered stale */
  929. max_time = 3600.0 * 36.0;
  930. if (mtime(fn) + max_time < (double) time(NULL)) {
  931. /* actor data exists but also stinks */
  932. FILE *f;
  933. if ((f = fopen(fn, "a")) != NULL) {
  934. /* write a blank at the end to 'touch' the file */
  935. fwrite(" ", 1, 1, f);
  936. fclose(f);
  937. }
  938. status = 205; /* "205: Reset Content" "110: Response Is Stale" */
  939. }
  940. return status;
  941. }
  942. d_char *_static_fn(snac *snac, const char *id)
  943. /* gets the filename for a static file */
  944. {
  945. return xs_fmt("%s/static/%s", snac->basedir, id);
  946. }
  947. int static_get(snac *snac, const char *id, d_char **data, int *size)
  948. /* returns static content */
  949. {
  950. xs *fn = _static_fn(snac, id);
  951. FILE *f;
  952. int status = 404;
  953. *size = XS_ALL;
  954. if ((f = fopen(fn, "rb")) != NULL) {
  955. *data = xs_read(f, size);
  956. fclose(f);
  957. status = 200;
  958. }
  959. return status;
  960. }
  961. void static_put(snac *snac, const char *id, const char *data, int size)
  962. /* writes status content */
  963. {
  964. xs *fn = _static_fn(snac, id);
  965. FILE *f;
  966. if ((f = fopen(fn, "wb")) != NULL) {
  967. fwrite(data, size, 1, f);
  968. fclose(f);
  969. }
  970. }
  971. d_char *_history_fn(snac *snac, char *id)
  972. /* gets the filename for the history */
  973. {
  974. return xs_fmt("%s/history/%s", snac->basedir, id);
  975. }
  976. double history_mtime(snac *snac, char * id)
  977. {
  978. double t = 0.0;
  979. xs *fn = _history_fn(snac, id);
  980. if (fn != NULL)
  981. t = mtime(fn);
  982. return t;
  983. }
  984. void history_add(snac *snac, char *id, char *content, int size)
  985. /* adds something to the history */
  986. {
  987. xs *fn = _history_fn(snac, id);
  988. FILE *f;
  989. if ((f = fopen(fn, "w")) != NULL) {
  990. fwrite(content, size, 1, f);
  991. fclose(f);
  992. }
  993. }
  994. d_char *history_get(snac *snac, char *id)
  995. {
  996. d_char *content = NULL;
  997. xs *fn = _history_fn(snac, id);
  998. FILE *f;
  999. if ((f = fopen(fn, "r")) != NULL) {
  1000. content = xs_readall(f);
  1001. fclose(f);
  1002. }
  1003. return content;
  1004. }
  1005. int history_del(snac *snac, char *id)
  1006. {
  1007. xs *fn = _history_fn(snac, id);
  1008. return unlink(fn);
  1009. }
  1010. d_char *history_list(snac *snac)
  1011. {
  1012. xs *spec = xs_fmt("%s/history/" "*.html", snac->basedir);
  1013. return xs_glob(spec, 1, 0);
  1014. }
  1015. void lastlog_write(snac *snac)
  1016. /* writes the last time the user logged in */
  1017. {
  1018. xs *fn = xs_fmt("%s/lastlog.txt", snac->basedir);
  1019. FILE *f;
  1020. if ((f = fopen(fn, "w")) != NULL) {
  1021. fprintf(f, "%lf\n", ftime());
  1022. fclose(f);
  1023. }
  1024. }
  1025. /** inbox collection **/
  1026. void inbox_add(const char *inbox)
  1027. /* collects a shared inbox */
  1028. {
  1029. xs *md5 = xs_md5_hex(inbox, strlen(inbox));
  1030. xs *fn = xs_fmt("%s/inbox/%s", srv_basedir, md5);
  1031. FILE *f;
  1032. if (strlen(inbox) < 256 && (f = fopen(fn, "w")) != NULL) {
  1033. pthread_mutex_lock(&data_mutex);
  1034. fprintf(f, "%s\n", inbox);
  1035. fclose(f);
  1036. pthread_mutex_unlock(&data_mutex);
  1037. }
  1038. }
  1039. void inbox_add_by_actor(const xs_dict *actor)
  1040. /* collects an actor's shared inbox, if it has one */
  1041. {
  1042. char *v;
  1043. if (!xs_is_null(v = xs_dict_get(actor, "endpoints")) &&
  1044. !xs_is_null(v = xs_dict_get(v, "sharedInbox")))
  1045. inbox_add(v);
  1046. }
  1047. xs_list *inbox_list(void)
  1048. /* returns the collected inboxes as a list */
  1049. {
  1050. xs_list *ibl = xs_list_new();
  1051. xs *spec = xs_fmt("%s/inbox/" "*", srv_basedir);
  1052. xs *files = xs_glob(spec, 0, 0);
  1053. xs_list *p = files;
  1054. xs_val *v;
  1055. while (xs_list_iter(&p, &v)) {
  1056. FILE *f;
  1057. if ((f = fopen(v, "r")) != NULL) {
  1058. char line[256];
  1059. if (fgets(line, sizeof(line), f)) {
  1060. fclose(f);
  1061. int i = strlen(line);
  1062. if (i) {
  1063. line[i - 1] = '\0';
  1064. ibl = xs_list_append(ibl, line);
  1065. }
  1066. }
  1067. }
  1068. }
  1069. return ibl;
  1070. }
  1071. /** notifications **/
  1072. void notify_add(snac *snac, const char *type, const char *utype,
  1073. const char *actor, const char *objid)
  1074. /* adds a new notification */
  1075. {
  1076. xs *ntid = tid(0);
  1077. xs *fn = xs_fmt("%s/notify/", snac->basedir);
  1078. xs *date = xs_str_utctime(0, "%Y-%m-%dT%H:%M:%SZ");
  1079. FILE *f;
  1080. /* create the directory */
  1081. mkdirx(fn);
  1082. fn = xs_str_cat(fn, ntid);
  1083. fn = xs_str_cat(fn, ".json");
  1084. xs *noti = xs_dict_new();
  1085. noti = xs_dict_append(noti, "id", ntid);
  1086. noti = xs_dict_append(noti, "type", type);
  1087. noti = xs_dict_append(noti, "utype", utype);
  1088. noti = xs_dict_append(noti, "actor", actor);
  1089. noti = xs_dict_append(noti, "objid", objid);
  1090. noti = xs_dict_append(noti, "date", date);
  1091. if ((f = fopen(fn, "w")) != NULL) {
  1092. xs *j = xs_json_dumps_pp(noti, 4);
  1093. fwrite(j, strlen(j), 1, f);
  1094. fclose(f);
  1095. }
  1096. }
  1097. /** the queue **/
  1098. static xs_dict *_enqueue_put(const char *fn, xs_dict *msg)
  1099. /* writes safely to the queue */
  1100. {
  1101. xs *tfn = xs_fmt("%s.tmp", fn);
  1102. FILE *f;
  1103. if ((f = fopen(tfn, "w")) != NULL) {
  1104. xs *j = xs_json_dumps_pp(msg, 4);
  1105. fwrite(j, strlen(j), 1, f);
  1106. fclose(f);
  1107. rename(tfn, fn);
  1108. }
  1109. return msg;
  1110. }
  1111. static xs_dict *_new_qmsg(const char *type, const xs_val *msg, int retries)
  1112. /* creates a queue message */
  1113. {
  1114. int qrt = xs_number_get(xs_dict_get(srv_config, "queue_retry_minutes"));
  1115. xs *ntid = tid(retries * 60 * qrt);
  1116. xs *rn = xs_number_new(retries);
  1117. xs_dict *qmsg = xs_dict_new();
  1118. qmsg = xs_dict_append(qmsg, "type", type);
  1119. qmsg = xs_dict_append(qmsg, "message", msg);
  1120. qmsg = xs_dict_append(qmsg, "retries", rn);
  1121. qmsg = xs_dict_append(qmsg, "ntid", ntid);
  1122. return qmsg;
  1123. }
  1124. void enqueue_input(snac *snac, xs_dict *msg, xs_dict *req, int retries)
  1125. /* enqueues an input message */
  1126. {
  1127. xs *qmsg = _new_qmsg("input", msg, retries);
  1128. char *ntid = xs_dict_get(qmsg, "ntid");
  1129. xs *fn = xs_fmt("%s/queue/%s.json", snac->basedir, ntid);
  1130. qmsg = xs_dict_append(qmsg, "req", req);
  1131. qmsg = _enqueue_put(fn, qmsg);
  1132. snac_debug(snac, 1, xs_fmt("enqueue_input %s", fn));
  1133. }
  1134. void enqueue_output_raw(const char *keyid, const char *seckey,
  1135. xs_dict *msg, xs_str *inbox, int retries)
  1136. /* enqueues an output message to an inbox */
  1137. {
  1138. xs *qmsg = _new_qmsg("output", msg, retries);
  1139. char *ntid = xs_dict_get(qmsg, "ntid");
  1140. xs *fn = xs_fmt("%s/queue/%s.json", srv_basedir, ntid);
  1141. qmsg = xs_dict_append(qmsg, "inbox", inbox);
  1142. qmsg = xs_dict_append(qmsg, "keyid", keyid);
  1143. qmsg = xs_dict_append(qmsg, "seckey", seckey);
  1144. /* if it's to be sent right now, bypass the disk queue and post the job */
  1145. if (retries == 0 && job_fifo_ready())
  1146. job_post(qmsg, 0);
  1147. else {
  1148. qmsg = _enqueue_put(fn, qmsg);
  1149. srv_debug(1, xs_fmt("enqueue_output %s %s %d", inbox, fn, retries));
  1150. }
  1151. }
  1152. void enqueue_output(snac *snac, xs_dict *msg, xs_str *inbox, int retries)
  1153. /* enqueues an output message to an inbox */
  1154. {
  1155. if (xs_startswith(inbox, snac->actor)) {
  1156. snac_debug(snac, 1, xs_str_new("refusing enqueue to myself"));
  1157. return;
  1158. }
  1159. char *seckey = xs_dict_get(snac->key, "secret");
  1160. enqueue_output_raw(snac->actor, seckey, msg, inbox, retries);
  1161. }
  1162. void enqueue_output_by_actor(snac *snac, xs_dict *msg, xs_str *actor, int retries)
  1163. /* enqueues an output message for an actor */
  1164. {
  1165. xs *inbox = get_actor_inbox(snac, actor);
  1166. if (!xs_is_null(inbox))
  1167. enqueue_output(snac, msg, inbox, retries);
  1168. else
  1169. snac_log(snac, xs_fmt("enqueue_output_by_actor cannot get inbox %s", actor));
  1170. }
  1171. void enqueue_email(xs_str *msg, int retries)
  1172. /* enqueues an email message to be sent */
  1173. {
  1174. xs *qmsg = _new_qmsg("email", msg, retries);
  1175. char *ntid = xs_dict_get(qmsg, "ntid");
  1176. xs *fn = xs_fmt("%s/queue/%s.json", srv_basedir, ntid);
  1177. qmsg = _enqueue_put(fn, qmsg);
  1178. srv_debug(1, xs_fmt("enqueue_email %d", retries));
  1179. }
  1180. void enqueue_telegram(const xs_str *msg, const char *bot, const char *chat_id)
  1181. /* enqueues a message to be sent via Telegram */
  1182. {
  1183. xs *qmsg = _new_qmsg("telegram", msg, 0);
  1184. char *ntid = xs_dict_get(qmsg, "ntid");
  1185. xs *fn = xs_fmt("%s/queue/%s.json", srv_basedir, ntid);
  1186. qmsg = xs_dict_append(qmsg, "bot", bot);
  1187. qmsg = xs_dict_append(qmsg, "chat_id", chat_id);
  1188. qmsg = _enqueue_put(fn, qmsg);
  1189. srv_debug(1, xs_fmt("enqueue_email %s %s", bot, chat_id));
  1190. }
  1191. void enqueue_message(snac *snac, xs_dict *msg)
  1192. /* enqueues an output message */
  1193. {
  1194. xs *qmsg = _new_qmsg("message", msg, 0);
  1195. char *ntid = xs_dict_get(qmsg, "ntid");
  1196. xs *fn = xs_fmt("%s/queue/%s.json", snac->basedir, ntid);
  1197. qmsg = _enqueue_put(fn, qmsg);
  1198. snac_debug(snac, 0, xs_fmt("enqueue_message %s", xs_dict_get(msg, "id")));
  1199. }
  1200. xs_list *user_queue(snac *snac)
  1201. /* returns a list with filenames that can be dequeued */
  1202. {
  1203. xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
  1204. xs_list *list = xs_list_new();
  1205. time_t t = time(NULL);
  1206. xs_list *p;
  1207. xs_val *v;
  1208. xs *fns = xs_glob(spec, 0, 0);
  1209. p = fns;
  1210. while (xs_list_iter(&p, &v)) {
  1211. /* get the retry time from the basename */
  1212. char *bn = strrchr(v, '/');
  1213. time_t t2 = atol(bn + 1);
  1214. if (t2 > t)
  1215. snac_debug(snac, 2, xs_fmt("user_queue not yet time for %s [%ld]", v, t));
  1216. else {
  1217. list = xs_list_append(list, v);
  1218. snac_debug(snac, 2, xs_fmt("user_queue ready for %s", v));
  1219. }
  1220. }
  1221. return list;
  1222. }
  1223. xs_list *queue(void)
  1224. /* returns a list with filenames that can be dequeued */
  1225. {
  1226. xs *spec = xs_fmt("%s/queue/" "*.json", srv_basedir);
  1227. xs_list *list = xs_list_new();
  1228. time_t t = time(NULL);
  1229. xs_list *p;
  1230. xs_val *v;
  1231. xs *fns = xs_glob(spec, 0, 0);
  1232. p = fns;
  1233. while (xs_list_iter(&p, &v)) {
  1234. /* get the retry time from the basename */
  1235. char *bn = strrchr(v, '/');
  1236. time_t t2 = atol(bn + 1);
  1237. if (t2 > t)
  1238. srv_debug(2, xs_fmt("queue not yet time for %s [%ld]", v, t));
  1239. else {
  1240. list = xs_list_append(list, v);
  1241. srv_debug(2, xs_fmt("queue ready for %s", v));
  1242. }
  1243. }
  1244. return list;
  1245. }
  1246. xs_dict *dequeue(const char *fn)
  1247. /* dequeues a message */
  1248. {
  1249. FILE *f;
  1250. xs_dict *obj = NULL;
  1251. if ((f = fopen(fn, "r")) != NULL) {
  1252. /* delete right now */
  1253. unlink(fn);
  1254. xs *j = xs_readall(f);
  1255. obj = xs_json_loads(j);
  1256. fclose(f);
  1257. }
  1258. return obj;
  1259. }
  1260. /** the purge **/
  1261. static int _purge_file(const char *fn, time_t mt)
  1262. /* purge fn if it's older than days */
  1263. {
  1264. int ret = 0;
  1265. if (mtime(fn) < mt) {
  1266. /* older than the minimum time: delete it */
  1267. unlink(fn);
  1268. srv_debug(2, xs_fmt("purged %s", fn));
  1269. ret = 1;
  1270. }
  1271. return ret;
  1272. }
  1273. static void _purge_dir(const char *dir, int days)
  1274. /* purges all files in a directory older than days */
  1275. {
  1276. int cnt = 0;
  1277. if (days) {
  1278. time_t mt = time(NULL) - days * 24 * 3600;
  1279. xs *spec = xs_fmt("%s/" "*", dir);
  1280. xs *list = xs_glob(spec, 0, 0);
  1281. xs_list *p;
  1282. xs_str *v;
  1283. p = list;
  1284. while (xs_list_iter(&p, &v))
  1285. cnt += _purge_file(v, mt);
  1286. srv_debug(1, xs_fmt("purge: %s %d", dir, cnt));
  1287. }
  1288. }
  1289. static void _purge_user_subdir(snac *snac, const char *subdir, int days)
  1290. /* purges all files in a user subdir older than days */
  1291. {
  1292. xs *u_subdir = xs_fmt("%s/%s", snac->basedir, subdir);
  1293. _purge_dir(u_subdir, days);
  1294. }
  1295. void purge_server(void)
  1296. /* purge global server data */
  1297. {
  1298. xs *spec = xs_fmt("%s/object/??", srv_basedir);
  1299. xs *dirs = xs_glob(spec, 0, 0);
  1300. xs_list *p;
  1301. xs_str *v;
  1302. int cnt = 0;
  1303. int icnt = 0;
  1304. time_t mt = time(NULL) - 7 * 24 * 3600;
  1305. p = dirs;
  1306. while (xs_list_iter(&p, &v)) {
  1307. xs_list *p2;
  1308. xs_str *v2;
  1309. {
  1310. xs *spec2 = xs_fmt("%s/" "*.json", v);
  1311. xs *files = xs_glob(spec2, 0, 0);
  1312. p2 = files;
  1313. while (xs_list_iter(&p2, &v2)) {
  1314. int n_link;
  1315. /* old and with no hard links? */
  1316. if (mtime_nl(v2, &n_link) < mt && n_link < 2) {
  1317. xs *s1 = xs_replace(v2, ".json", "");
  1318. xs *l = xs_split(s1, "/");
  1319. char *md5 = xs_list_get(l, -1);
  1320. object_del_by_md5(md5);
  1321. cnt++;
  1322. }
  1323. }
  1324. }
  1325. {
  1326. /* look for stray indexes */
  1327. xs *speci = xs_fmt("%s/" "*_?.idx", v);
  1328. xs *idxfs = xs_glob(speci, 0, 0);
  1329. p2 = idxfs;
  1330. while (xs_list_iter(&p2, &v2)) {
  1331. /* old enough to consider? */
  1332. if (mtime(v2) < mt) {
  1333. /* check if the indexed object is here */
  1334. xs *o = xs_dup(v2);
  1335. char *ext = strchr(o, '_');
  1336. if (ext) {
  1337. *ext = '\0';
  1338. o = xs_str_cat(o, ".json");
  1339. if (mtime(o) == 0.0) {
  1340. /* delete */
  1341. unlink(v2);
  1342. srv_debug(1, xs_fmt("purged %s", v2));
  1343. icnt++;
  1344. }
  1345. }
  1346. }
  1347. }
  1348. }
  1349. }
  1350. /* purge collected inboxes */
  1351. xs *ib_dir = xs_fmt("%s/inbox", srv_basedir);
  1352. _purge_dir(ib_dir, 7);
  1353. srv_debug(1, xs_fmt("purge: global (obj: %d, idx: %d)", cnt, icnt));
  1354. }
  1355. void purge_user(snac *snac)
  1356. /* do the purge for this user */
  1357. {
  1358. int priv_days, pub_days, user_days = 0;
  1359. char *v;
  1360. int n;
  1361. priv_days = xs_number_get(xs_dict_get(srv_config, "timeline_purge_days"));
  1362. pub_days = xs_number_get(xs_dict_get(srv_config, "local_purge_days"));
  1363. if ((v = xs_dict_get(snac->config_o, "purge_days")) != NULL ||
  1364. (v = xs_dict_get(snac->config, "purge_days")) != NULL)
  1365. user_days = xs_number_get(v);
  1366. if (user_days) {
  1367. /* override admin settings only if they are lesser */
  1368. if (priv_days == 0 || user_days < priv_days)
  1369. priv_days = user_days;
  1370. if (pub_days == 0 || user_days < pub_days)
  1371. pub_days = user_days;
  1372. }
  1373. _purge_user_subdir(snac, "hidden", priv_days);
  1374. _purge_user_subdir(snac, "private", priv_days);
  1375. _purge_user_subdir(snac, "public", pub_days);
  1376. const char *idxs[] = { "followers.idx", "private.idx", "public.idx", NULL };
  1377. for (n = 0; idxs[n]; n++) {
  1378. xs *idx = xs_fmt("%s/%s", snac->basedir, idxs[n]);
  1379. int gc = index_gc(idx);
  1380. snac_debug(snac, 1, xs_fmt("purge: %s %d", idx, gc));
  1381. }
  1382. }
  1383. void purge_all(void)
  1384. /* purge all users */
  1385. {
  1386. snac snac;
  1387. xs *list = user_list();
  1388. char *p, *uid;
  1389. p = list;
  1390. while (xs_list_iter(&p, &uid)) {
  1391. if (user_open(&snac, uid)) {
  1392. purge_user(&snac);
  1393. user_free(&snac);
  1394. }
  1395. }
  1396. purge_server();
  1397. }
  1398. /** archive **/
  1399. void srv_archive(const char *direction, const char *url, xs_dict *req,
  1400. const char *payload, int p_size,
  1401. int status, xs_dict *headers,
  1402. const char *body, int b_size)
  1403. /* archives a connection */
  1404. {
  1405. /* obsessive archiving */
  1406. xs *date = tid(0);
  1407. xs *dir = xs_fmt("%s/archive/%s_%s", srv_basedir, date, direction);
  1408. FILE *f;
  1409. if (mkdirx(dir) != -1) {
  1410. xs *meta_fn = xs_fmt("%s/_META", dir);
  1411. if ((f = fopen(meta_fn, "w")) != NULL) {
  1412. xs *j1 = xs_json_dumps_pp(req, 4);
  1413. xs *j2 = xs_json_dumps_pp(headers, 4);
  1414. fprintf(f, "dir: %s\n", direction);
  1415. if (url)
  1416. fprintf(f, "url: %s\n", url);
  1417. fprintf(f, "req: %s\n", j1);
  1418. fprintf(f, "p_size: %d\n", p_size);
  1419. fprintf(f, "status: %d\n", status);
  1420. fprintf(f, "response: %s\n", j2);
  1421. fprintf(f, "b_size: %d\n", b_size);
  1422. fclose(f);
  1423. }
  1424. if (p_size && payload) {
  1425. xs *payload_fn = NULL;
  1426. xs *payload_fn_raw = NULL;
  1427. char *v = xs_dict_get(req, "content-type");
  1428. if (v && xs_str_in(v, "json") != -1) {
  1429. payload_fn = xs_fmt("%s/payload.json", dir);
  1430. if ((f = fopen(payload_fn, "w")) != NULL) {
  1431. xs *v1 = xs_json_loads(payload);
  1432. xs *j1 = NULL;
  1433. if (v1 != NULL)
  1434. j1 = xs_json_dumps_pp(v1, 4);
  1435. if (j1 != NULL)
  1436. fwrite(j1, strlen(j1), 1, f);
  1437. else
  1438. fwrite(payload, p_size, 1, f);
  1439. fclose(f);
  1440. }
  1441. }
  1442. payload_fn_raw = xs_fmt("%s/payload", dir);
  1443. if ((f = fopen(payload_fn_raw, "w")) != NULL) {
  1444. fwrite(payload, p_size, 1, f);
  1445. fclose(f);
  1446. }
  1447. }
  1448. if (b_size && body) {
  1449. xs *body_fn = NULL;
  1450. char *v = xs_dict_get(headers, "content-type");
  1451. if (v && xs_str_in(v, "json") != -1) {
  1452. body_fn = xs_fmt("%s/body.json", dir);
  1453. if ((f = fopen(body_fn, "w")) != NULL) {
  1454. xs *v1 = xs_json_loads(body);
  1455. xs *j1 = NULL;
  1456. if (v1 != NULL)
  1457. j1 = xs_json_dumps_pp(v1, 4);
  1458. if (j1 != NULL)
  1459. fwrite(j1, strlen(j1), 1, f);
  1460. else
  1461. fwrite(body, b_size, 1, f);
  1462. fclose(f);
  1463. }
  1464. }
  1465. else {
  1466. body_fn = xs_fmt("%s/body", dir);
  1467. if ((f = fopen(body_fn, "w")) != NULL) {
  1468. fwrite(body, b_size, 1, f);
  1469. fclose(f);
  1470. }
  1471. }
  1472. }
  1473. }
  1474. }
  1475. void srv_archive_error(const char *prefix, const xs_str *err,
  1476. const xs_dict *req, const xs_val *data)
  1477. /* archives an error */
  1478. {
  1479. xs *ntid = tid(0);
  1480. xs *fn = xs_fmt("%s/error/%s_%s", srv_basedir, prefix, ntid);
  1481. FILE *f;
  1482. if ((f = fopen(fn, "w")) != NULL) {
  1483. fprintf(f, "Error: %s\n", err);
  1484. if (req) {
  1485. fprintf(f, "Request headers:\n");
  1486. xs *j = xs_json_dumps_pp(req, 4);
  1487. fwrite(j, strlen(j), 1, f);
  1488. fprintf(f, "\n");
  1489. }
  1490. if (data) {
  1491. fprintf(f, "Data:\n");
  1492. if (xs_type(data) == XSTYPE_LIST || xs_type(data) == XSTYPE_DICT) {
  1493. xs *j = xs_json_dumps_pp(data, 4);
  1494. fwrite(j, strlen(j), 1, f);
  1495. }
  1496. else
  1497. fprintf(f, "%s", data);
  1498. fprintf(f, "\n");
  1499. }
  1500. fclose(f);
  1501. }
  1502. }