sfeed_gopher.c (raw) (4404B)
1 #include <stdio.h> 2 #include <stdlib.h> 3 #include <string.h> 4 #include <time.h> 5 6 #include "util.h" 7 8 static char *prefixpath = "/", *host = "127.0.0.1", *port = "70"; /* default */ 9 static char *line; 10 static size_t linesize; 11 static time_t comparetime; 12 13 /* Escape characters in gopher, CR and LF are ignored */ 14 static void 15 gophertext(FILE *fp, const char *s) 16 { 17 for (; *s; s++) { 18 switch (*s) { 19 case '\r': /* ignore CR */ 20 case '\n': /* ignore LF */ 21 break; 22 case '\t': 23 fputs(" ", fp); 24 break; 25 default: 26 putc(*s, fp); 27 break; 28 } 29 } 30 } 31 32 static void 33 printfeed(FILE *fpitems, FILE *fpin, struct feed *f) 34 { 35 struct uri u; 36 char *fields[FieldLast]; 37 char *itemhost, *itemport, *itempath, *itemquery, *itemfragment; 38 ssize_t linelen; 39 unsigned int isnew; 40 struct tm rtm, *tm; 41 time_t parsedtime; 42 int itemtype; 43 44 if (f->name[0]) { 45 fprintf(fpitems, "i%s\t\t%s\t%s\r\n", f->name, host, port); 46 fprintf(fpitems, "i\t\t%s\t%s\r\n", host, port); 47 } 48 49 while ((linelen = getline(&line, &linesize, fpin)) > 0 && 50 !ferror(fpitems)) { 51 if (line[linelen - 1] == '\n') 52 line[--linelen] = '\0'; 53 parseline(line, fields); 54 55 itemhost = host; 56 itemport = port; 57 itemtype = 'i'; 58 itempath = fields[FieldLink]; 59 itemquery = ""; 60 itemfragment = ""; 61 62 if (fields[FieldLink][0]) { 63 itemtype = 'h'; 64 /* if it is a gopher URL then change it into a DirEntity */ 65 if (!strncmp(fields[FieldLink], "gopher://", 9) && 66 uri_parse(fields[FieldLink], &u) != -1) { 67 itemhost = u.host; 68 itemport = u.port[0] ? u.port : "70"; 69 itemtype = '1'; 70 itempath = u.path; 71 itemquery = u.query; 72 itemfragment = u.fragment; 73 74 if (itempath[0] == '/') { 75 itempath++; 76 if (*itempath) { 77 itemtype = *itempath; 78 itempath++; 79 } 80 } 81 } 82 } 83 84 parsedtime = 0; 85 if (!strtotime(fields[FieldUnixTimestamp], &parsedtime) && 86 (tm = localtime_r(&parsedtime, &rtm))) { 87 isnew = (parsedtime >= comparetime) ? 1 : 0; 88 f->totalnew += isnew; 89 90 fprintf(fpitems, "%c%c %04d-%02d-%02d %02d:%02d ", 91 itemtype, 92 isnew ? 'N' : ' ', 93 tm->tm_year + 1900, tm->tm_mon + 1, tm->tm_mday, 94 tm->tm_hour, tm->tm_min); 95 } else { 96 fprintf(fpitems, "%c ", itemtype); 97 } 98 f->total++; 99 100 gophertext(fpitems, fields[FieldTitle]); 101 fputs("\t", fpitems); 102 if (itemtype == 'h' && fields[FieldLink] == itempath) 103 fputs("URL:", fpitems); 104 gophertext(fpitems, itempath); 105 if (itemquery[0]) { 106 fputs("?", fpitems); 107 gophertext(fpitems, itemquery); 108 } 109 if (itemfragment[0]) { 110 fputs("#", fpitems); 111 gophertext(fpitems, itemfragment); 112 } 113 fprintf(fpitems, "\t%s\t%s\r\n", itemhost, itemport); 114 } 115 fputs(".\r\n", fpitems); 116 } 117 118 int 119 main(int argc, char *argv[]) 120 { 121 struct feed f = { 0 }; 122 FILE *fpitems, *fpindex, *fp; 123 char *name, *p; 124 int i; 125 126 if (argc == 1) { 127 if (pledge("stdio", NULL) == -1) 128 err(1, "pledge"); 129 } else { 130 if (unveil("/", "r") == -1) 131 err(1, "unveil: /"); 132 if (unveil(".", "rwc") == -1) 133 err(1, "unveil: ."); 134 if (pledge("stdio rpath wpath cpath", NULL) == -1) 135 err(1, "pledge"); 136 } 137 138 if ((comparetime = getcomparetime()) == (time_t)-1) 139 errx(1, "getcomparetime"); 140 141 if ((p = getenv("SFEED_GOPHER_HOST"))) 142 host = p; 143 if ((p = getenv("SFEED_GOPHER_PORT"))) 144 port = p; 145 146 if (argc == 1) { 147 f.name = ""; 148 printfeed(stdout, stdin, &f); 149 checkfileerror(stdin, "<stdin>", 'r'); 150 checkfileerror(stdout, "<stdout>", 'w'); 151 } else { 152 if ((p = getenv("SFEED_GOPHER_PATH"))) 153 prefixpath = p; 154 155 /* write main index page */ 156 if (!(fpindex = fopen("index", "wb"))) 157 err(1, "fopen: index"); 158 159 for (i = 1; i < argc; i++) { 160 memset(&f, 0, sizeof(f)); 161 name = ((name = strrchr(argv[i], '/'))) ? name + 1 : argv[i]; 162 f.name = name; 163 164 if (!(fp = fopen(argv[i], "r"))) 165 err(1, "fopen: %s", argv[i]); 166 if (!(fpitems = fopen(name, "wb"))) 167 err(1, "fopen"); 168 printfeed(fpitems, fp, &f); 169 checkfileerror(fp, argv[i], 'r'); 170 checkfileerror(fpitems, name, 'w'); 171 fclose(fp); 172 fclose(fpitems); 173 174 /* append directory item to index */ 175 fputs("1", fpindex); 176 gophertext(fpindex, name); 177 fprintf(fpindex, " (%lu/%lu)\t", f.totalnew, f.total); 178 gophertext(fpindex, prefixpath); 179 gophertext(fpindex, name); 180 fprintf(fpindex, "\t%s\t%s\r\n", host, port); 181 } 182 fputs(".\r\n", fpindex); 183 checkfileerror(fpindex, "index", 'w'); 184 fclose(fpindex); 185 } 186 187 return 0; 188 }