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)
111 /* printf("===== EOF\n"); */
112 /* event_loopbreak(); */
116 dispatch_imsg(int fd, short ev, void *d)
122 if ((n = imsg_read(ibuf)) == -1) {
123 if (errno == EAGAIN || errno == EWOULDBLOCK)
129 fprintf(stderr, "other side is dead\n");
134 if ((n = imsg_get(ibuf, &imsg)) == -1)
138 datalen = imsg.hdr.len - IMSG_HEADER_SIZE;
139 handlers[imsg.hdr.type](&imsg, datalen);
148 const char *url = "about:new";
149 /* const char *url = "gemini://localhost/cgi/slow-out"; */
151 if ((tab = calloc(1, sizeof(*tab))) == NULL)
154 TAILQ_INSERT_HEAD(&tabshead, tab, tabs);
156 tab->id = tab_counter++;
157 TAILQ_INIT(&tab->page.head);
158 gemtext_initparser(&tab->page);
160 imsg_compose(ibuf, IMSG_GET, tab->id, 0, -1, url, strlen(url)+1);
169 struct imsgbuf main_ibuf, network_ibuf;
172 signal(SIGCHLD, SIG_IGN);
173 signal(SIGINT, SIG_IGN);
175 if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
176 err(1, "socketpair");
183 setproctitle("client");
185 imsg_init(&network_ibuf, imsg_fds[1]);
186 exit(client_main(&network_ibuf));
190 imsg_init(&main_ibuf, imsg_fds[0]);
193 TAILQ_INIT(&tabshead);
197 event_set(&imsgev, ibuf->fd, EV_READ | EV_PERSIST, dispatch_imsg, ibuf);
198 event_add(&imsgev, NULL);
206 imsg_compose(ibuf, IMSG_QUIT, 0, 0, -1, NULL, 0);