3 #include <sys/socket.h>
15 struct tabshead tabshead;
17 static struct imsgbuf *ibuf;
18 static uint32_t tab_counter;
20 static void handle_imsg_err(struct imsg*, size_t);
21 static void handle_imsg_check_cert(struct imsg*, size_t);
22 static void handle_imsg_got_code(struct imsg*, size_t);
23 static void handle_imsg_got_meta(struct imsg*, size_t);
24 static void handle_imsg_buf(struct imsg*, size_t);
25 static void handle_imsg_eof(struct imsg*, size_t);
27 static imsg_handlerfn *handlers[] = {
28 [IMSG_ERR] = handle_imsg_err,
29 [IMSG_CHECK_CERT] = handle_imsg_check_cert,
30 [IMSG_GOT_CODE] = handle_imsg_got_code,
31 [IMSG_GOT_META] = handle_imsg_got_meta,
32 [IMSG_BUF] = handle_imsg_buf,
33 [IMSG_EOF] = handle_imsg_eof,
36 static void __attribute__((__noreturn__))
43 tab_by_id(uint32_t id)
47 TAILQ_FOREACH(t, &tabshead, tabs) {
56 handle_imsg_err(struct imsg *imsg, size_t datalen)
58 /* write(2, imsg->data, datalen); */
59 /* fprintf(stderr, "\nEOF\n"); */
60 /* event_loopbreak(); */
64 handle_imsg_check_cert(struct imsg *imsg, size_t datalen)
68 imsg_compose(ibuf, IMSG_CERT_STATUS, imsg->hdr.peerid, 0, -1, &tofu_res, sizeof(tofu_res));
73 handle_imsg_got_code(struct imsg *imsg, size_t datalen)
77 if (sizeof(code) != datalen)
80 memcpy(&code, imsg->data, sizeof(code));
82 /* fprintf(stderr, "got status code: %d\n", code); */
86 handle_imsg_got_meta(struct imsg *imsg, size_t datalen)
88 /* fprintf(stderr, "got meta: "); */
90 /* write(2, imsg->data, datalen); */
91 /* fprintf(stderr, "\n"); */
95 handle_imsg_buf(struct imsg *imsg, size_t datalen)
100 t = tab_by_id(imsg->hdr.peerid);
102 if (!t->page.parse(&t->page, imsg->data, datalen))
105 ui_on_tab_refresh(t);
109 handle_imsg_eof(struct imsg *imsg, size_t datalen)
113 t = tab_by_id(imsg->hdr.peerid);
114 if (!t->page.free(&t->page))
117 ui_on_tab_refresh(t);
121 dispatch_imsg(int fd, short ev, void *d)
127 if ((n = imsg_read(ibuf)) == -1) {
128 if (errno == EAGAIN || errno == EWOULDBLOCK)
134 fprintf(stderr, "other side is dead\n");
139 if ((n = imsg_get(ibuf, &imsg)) == -1)
143 datalen = imsg.hdr.len - IMSG_HEADER_SIZE;
144 handlers[imsg.hdr.type](&imsg, datalen);
153 const char *url = "about:new";
154 /* const char *url = "gemini://localhost/cgi/slow-out"; */
156 if ((tab = calloc(1, sizeof(*tab))) == NULL)
159 TAILQ_INSERT_HEAD(&tabshead, tab, tabs);
161 tab->id = tab_counter++;
162 TAILQ_INIT(&tab->page.head);
163 gemtext_initparser(&tab->page);
165 imsg_compose(ibuf, IMSG_GET, tab->id, 0, -1, url, strlen(url)+1);
174 struct imsgbuf main_ibuf, network_ibuf;
177 signal(SIGCHLD, SIG_IGN);
178 signal(SIGINT, SIG_IGN);
180 if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
181 err(1, "socketpair");
188 setproctitle("client");
190 imsg_init(&network_ibuf, imsg_fds[1]);
191 exit(client_main(&network_ibuf));
195 imsg_init(&main_ibuf, imsg_fds[0]);
198 TAILQ_INIT(&tabshead);
202 event_set(&imsgev, ibuf->fd, EV_READ | EV_PERSIST, dispatch_imsg, ibuf);
203 event_add(&imsgev, NULL);
211 imsg_compose(ibuf, IMSG_QUIT, 0, 0, -1, NULL, 0);