@@ -587,3 +587,23 @@ d_char *queue(snac *snac)
return list;
}
+
+d_char *dequeue(snac *snac, char *fn)
+/* dequeues a message */
+{
+ FILE *f;
+ d_char *obj = NULL;
+ if ((f = fopen(fn, "r")) != NULL) {
+ /* delete right now */
+ unlink(fn);
+ xs *j = xs_readall(f);
+ obj = xs_json_loads(j);
+ fclose(f);
+ }
+ return obj;
+}
@@ -21,7 +21,10 @@ int main(int argc, char *argv[])
p = list;
while (xs_list_iter(&p, &fn)) {
- printf("%s\n", fn);
+ xs *obj;
+ obj = dequeue(&snac, fn);
+ printf("%s\n", xs_dict_get(obj, "actor"));
@@ -60,3 +60,4 @@ int is_muted(snac *snac, char *actor);
void enqueue(snac *snac, char *actor, char *msg, int retries);
d_char *queue(snac *snac);
+d_char *dequeue(snac *snac, char *fn);