From: Andreas Öman <andreas@lonelycoder.com>
Date: Thu, 1 May 2008 07:24:40 +0000 (+0000)
Subject: Add a redirector when HTTP clients loads page '/'.
X-Git-Tag: 2.12~1071
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=7085b134e05bde3260277b8aec6256a5273da532;p=thirdparty%2Ftvheadend.git

Add a redirector when HTTP clients loads page '/'.
The redirector will either send the client to the advanced AJAX ui
or a simpler html / form based (for mobile clients)
---

diff --git a/Makefile b/Makefile
index 45f6410c4..56d42c31a 100644
--- a/Makefile
+++ b/Makefile
@@ -29,6 +29,13 @@ SRCS += cwc.c krypt.c
 VPATH += ffdecsa
 SRCS += FFdecsa.c
 
+#
+# Primary web interface
+#
+
+VPATH  += webui
+SRCS   += webui.c
+
 #
 # Embedded AJAX user interface
 #
diff --git a/main.c b/main.c
index 769182f10..de7c207fa 100644
--- a/main.c
+++ b/main.c
@@ -60,6 +60,7 @@
 #include "ffmuxer.h"
 #include "xbmsp.h"
 #include "ajaxui/ajaxui.h"
+#include "webui/webui.h"
 #include "access.h"
 
 #include <libhts/htsparachute.h>
@@ -248,6 +249,9 @@ main(int argc, char **argv)
   subscriptions_init();
 
   //  htmlui_start();
+
+  webui_start();
+
   if(doajax)
     ajaxui_start();
 
diff --git a/webui/webui.c b/webui/webui.c
new file mode 100644
index 000000000..47ca43be0
--- /dev/null
+++ b/webui/webui.c
@@ -0,0 +1,434 @@
+/*
+ *  tvheadend, WEBUI / HTML user interface
+ *  Copyright (C) 2008 Andreas Öman
+ *
+ *  This program is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <pthread.h>
+#include <assert.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include "tvhead.h"
+#include "http.h"
+#include "webui.h"
+#include "access.h"
+#include "epg.h"
+#include "pvr.h"
+
+#define ACCESS_SIMPLE \
+(ACCESS_WEB_INTERFACE | ACCESS_RECORDER_VIEW | ACCESS_RECORDER_CHANGE)
+
+static struct strtab recstatustxt[] = {
+  { "Recording scheduled", HTSTV_PVR_STATUS_SCHEDULED      },
+  { "Recording",           HTSTV_PVR_STATUS_RECORDING      },
+  { "Recording completed", HTSTV_PVR_STATUS_DONE           },
+  { "Recording aborted",   HTSTV_PVR_STATUS_ABORTED        },
+  { "No transponder",      HTSTV_PVR_STATUS_NO_TRANSPONDER },
+  { "File error",          HTSTV_PVR_STATUS_FILE_ERROR     },
+  { "Disk full",           HTSTV_PVR_STATUS_DISK_FULL      },
+  { "Buffer error",        HTSTV_PVR_STATUS_BUFFER_ERROR   },
+};
+
+const char *days[7] = {
+  "Sunday",
+  "Monday",
+  "Tuesday",
+  "Wednesday",
+  "Thursday",
+  "Friday",
+  "Saturday",
+  };
+
+
+static int
+pvrcmp(const void *A, const void *B)
+{
+  const pvr_rec_t *a = *(const pvr_rec_t **)A;
+  const pvr_rec_t *b = *(const pvr_rec_t **)B;
+
+  return a->pvrr_start - b->pvrr_start;
+}
+
+/**
+ * Compare start for two events, used as argument to qsort(3)
+ */
+static int
+eventcmp(const void *A, const void *B)
+{
+  const event_t *a = *(const event_t **)A;
+  const event_t *b = *(const event_t **)B;
+
+  return a->e_start - b->e_start;
+}
+
+
+
+
+static int
+is_client_simple(http_connection_t *hc)
+{
+  char *c;
+
+  if((c = http_arg_get(&hc->hc_args, "UA-OS")) != NULL) {
+    if(strstr(c, "Windows CE") || strstr(c, "Pocket PC"))
+      return 1;
+  }
+
+  if((c = http_arg_get(&hc->hc_args, "x-wap-profile")) != NULL) {
+    return 1;
+  }
+  return 0;
+}
+
+
+
+/**
+ * Root page, we direct the client to different pages depending
+ * on if it is a full blown browser or just some mobile app
+ */
+static int
+page_root(http_connection_t *hc, http_reply_t *hr, 
+	  const char *remain, void *opaque)
+{
+  if(is_client_simple(hc)) {
+    http_redirect(hc, hr, "/simple.html");
+  } else {
+    http_redirect(hc, hr, "/ajax/index.html");
+  }
+  return 0;
+}
+
+/**
+ * Root page, we direct the client to different pages depending
+ * on if it is a full blown browser or just some mobile app
+ */
+static int
+page_simple(http_connection_t *hc, http_reply_t *hr, 
+	  const char *remain, void *opaque)
+{
+  tcp_queue_t *tq = &hr->hr_tq;
+  const char *s = http_arg_get(&hc->hc_req_args, "s");
+  struct event_list events;
+  event_t *e, **ev;
+  int c, k, i;
+  struct tm a, b, day;
+  time_t stop;
+  pvr_rec_t *pvrr, **pv;
+  const char *rstatus;
+
+  tcp_qprintf(tq, "<html>");
+  tcp_qprintf(tq, "<body>");
+
+  tcp_qprintf(tq, "<form>");
+  tcp_qprintf(tq, "Event: <input type=\"text\" ");
+  if(s != NULL)
+    tcp_qprintf(tq, "value=\"%s\" ", s);
+  
+  tcp_qprintf(tq, "name=\"s\">");
+  tcp_qprintf(tq, "<input type=\"submit\" value=\"Search\">");
+  
+  tcp_qprintf(tq, "</form><hr>");
+
+  if(s != NULL) {
+    
+    LIST_INIT(&events);
+    c = epg_search(&events, s, NULL, NULL, NULL);
+
+    if(c == -1) {
+      tcp_qprintf(tq, "<b>Event title: Regular expression syntax error</b>");
+    } else if(c == 0) {
+      tcp_qprintf(tq, "<b>No matching entries found</b>");
+    } else {
+
+      tcp_qprintf(tq, "<b>%d entries found", c);
+
+      ev = alloca(c * sizeof(event_t *));
+      c = 0;
+      LIST_FOREACH(e, &events, e_tmp_link)
+	ev[c++] = e;
+
+      qsort(ev, c, sizeof(event_t *), eventcmp);
+
+      if(c > 25) {
+	c = 25;
+	tcp_qprintf(tq, ", %d entries shown", c);
+      }
+
+      tcp_qprintf(tq, "</b>");
+
+      memset(&day, -1, sizeof(struct tm));
+      for(k = 0; k < c; k++) {
+	e = ev[k];
+      
+	localtime_r(&e->e_start, &a);
+        stop = e->e_start + e->e_duration;
+	localtime_r(&stop, &b);
+
+	if(a.tm_wday != day.tm_wday || a.tm_mday != day.tm_mday  ||
+	   a.tm_mon  != day.tm_mon  || a.tm_year != day.tm_year) {
+	  memcpy(&day, &a, sizeof(struct tm));
+	  tcp_qprintf(tq, 
+		      "<br><i>%s, %d/%d</i><br>",
+		      days[day.tm_wday], day.tm_mday, day.tm_mon + 1);
+	}
+
+	pvrr = pvr_get_by_entry(e);
+	rstatus = pvrr != NULL ? val2str(pvrr->pvrr_status,
+					 recstatustxt) : NULL;
+
+	tcp_qprintf(tq, 
+		    "<a href=\"/eventinfo/%d\">"
+		    "%02d:%02d-%02d:%02d&nbsp;%s%s%s</a><br>",
+		    e->e_tag,
+		    a.tm_hour, a.tm_min, b.tm_hour, b.tm_min,
+		    e->e_title,
+		    rstatus ? "&nbsp;" : "", rstatus ?: "");
+      }
+    }
+    tcp_qprintf(tq, "<hr>");
+  }
+
+  tcp_qprintf(tq, "<b>Recorder log:</b><br>\n");
+
+  c = 0;
+  LIST_FOREACH(pvrr, &pvrr_global_list, pvrr_global_link)
+    c++;
+
+  if(c == 0) {
+    tcp_qprintf(tq, "No entries<br>");
+  }
+
+  pv = alloca(c * sizeof(pvr_rec_t *));
+
+  i = 0;
+  LIST_FOREACH(pvrr, &pvrr_global_list, pvrr_global_link)
+    pv[i++] = pvrr;
+
+  qsort(pv, i, sizeof(pvr_rec_t *), pvrcmp);
+  memset(&day, -1, sizeof(struct tm));
+
+  for(i = 0; i < c; i++) {
+    pvrr = pv[i];
+
+    localtime_r(&pvrr->pvrr_start, &a);
+    localtime_r(&pvrr->pvrr_stop, &b);
+
+
+    if(a.tm_wday != day.tm_wday || a.tm_mday != day.tm_mday  ||
+       a.tm_mon  != day.tm_mon  || a.tm_year != day.tm_year) {
+      memcpy(&day, &a, sizeof(struct tm));
+      tcp_qprintf(tq, "<br><i>%s, %d/%d</i><br>",
+		  days[day.tm_wday], day.tm_mday, day.tm_mon + 1);
+    }
+
+    rstatus = val2str(pvrr->pvrr_status, recstatustxt);
+
+
+    tcp_qprintf(tq, "<a href=\"/pvrinfo/%d\">", pvrr->pvrr_ref);
+    
+    tcp_qprintf(tq, 
+		"%02d:%02d-%02d:%02d&nbsp; %s",
+		a.tm_hour, a.tm_min, b.tm_hour, b.tm_min, pvrr->pvrr_title);
+
+    tcp_qprintf(tq, "</a>");
+
+    tcp_qprintf(tq, "<br>(%s)<br><br>", rstatus);
+  }
+
+  tcp_qprintf(tq, "</body></html>");
+  http_output_html(hc, hr);
+  return 0;
+}
+
+/**
+ * Event info, deliver info about the given event
+ */
+static int
+page_einfo(http_connection_t *hc, http_reply_t *hr, 
+	   const char *remain, void *opaque)
+{
+  tcp_queue_t *tq = &hr->hr_tq;
+  event_t *e;
+  struct tm a, b;
+  time_t stop;
+  pvr_rec_t *pvrr = NULL;
+  tv_pvr_status_t pvrstatus;
+  const char *rstatus;
+
+  if(remain == NULL || (e = epg_event_find_by_tag(atoi(remain))) == NULL)
+    return 404;
+
+  pvrr = pvr_get_by_entry(e);
+
+  if((http_arg_get(&hc->hc_req_args, "rec")) != NULL) {
+    pvrr = pvr_schedule_by_event(e, hc->hc_username);
+  } else if(pvrr && (http_arg_get(&hc->hc_req_args, "clear")) != NULL) {
+    pvr_clear(pvrr);
+    pvrr = NULL;
+  } else if(pvrr && (http_arg_get(&hc->hc_req_args, "cancel")) != NULL) {
+    pvr_abort(pvrr);
+  }
+
+  tcp_qprintf(tq, "<html>");
+  tcp_qprintf(tq, "<body>");
+
+  localtime_r(&e->e_start, &a);
+  stop = e->e_start + e->e_duration;
+  localtime_r(&stop, &b);
+
+  tcp_qprintf(tq, 
+	      "%s, %d/%d %02d:%02d - %02d:%02d<br>",
+	      days[a.tm_wday], a.tm_mday, a.tm_mon + 1,
+	      a.tm_hour, a.tm_min, b.tm_hour, b.tm_min);
+
+  tcp_qprintf(tq, "<hr><b>\"%s\": \"%s\"</b><br><br>",
+	      e->e_ch->ch_name, e->e_title);
+  
+  pvrstatus = pvrr != NULL ? pvrr->pvrr_status : HTSTV_PVR_STATUS_NONE;
+
+  if((rstatus = val2str(pvrstatus, recstatustxt)) != NULL)
+    tcp_qprintf(tq, "Recording status: %s<br>", rstatus);
+
+  tcp_qprintf(tq, "<form method=\"post\" action=\"/eventinfo/%d\">", e->e_tag);
+
+  switch(pvrstatus) {
+  case HTSTV_PVR_STATUS_SCHEDULED:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"clear\" value=\"Remove from schedule\">");
+    break;
+    
+  case HTSTV_PVR_STATUS_RECORDING:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"cancel\" value=\"Cancel recording\">");
+    break;
+
+  case HTSTV_PVR_STATUS_NONE:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"rec\" value=\"Record\">");
+    break;
+
+  default:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"clear\" value=\"Clear error status\">");
+    break;
+  }
+
+  tcp_qprintf(tq, "</form>");
+  tcp_qprintf(tq, "%s", e->e_desc);
+
+  tcp_qprintf(tq, "<hr><a href=\"/simple.html\">New search</a><br>");
+  tcp_qprintf(tq, "</body></html>");
+  http_output_html(hc, hr);
+  return 0;
+}
+
+
+/**
+ * PVR info, deliver info about the given PVR entry
+ */
+static int
+page_pvrinfo(http_connection_t *hc, http_reply_t *hr, 
+	     const char *remain, void *opaque)
+{
+  tcp_queue_t *tq = &hr->hr_tq;
+  struct tm a, b;
+  time_t stop;
+  pvr_rec_t *pvrr = NULL;
+  tv_pvr_status_t pvrstatus;
+  const char *rstatus;
+
+  if(remain == NULL || (pvrr = pvr_get_tag_entry(atoi(remain))) == NULL)
+    return 404;
+
+  if((http_arg_get(&hc->hc_req_args, "clear")) != NULL) {
+    pvr_clear(pvrr);
+    pvrr = NULL;
+    http_redirect(hc, hr, "/simple.html");
+    return 0;
+  } else if((http_arg_get(&hc->hc_req_args, "cancel")) != NULL) {
+    pvr_abort(pvrr);
+  }
+
+  tcp_qprintf(tq, "<html>");
+  tcp_qprintf(tq, "<body>");
+
+  localtime_r(&pvrr->pvrr_start, &a);
+  stop = pvrr->pvrr_start + pvrr->pvrr_stop;
+  localtime_r(&stop, &b);
+
+  tcp_qprintf(tq, 
+	      "%s, %d/%d %02d:%02d - %02d:%02d<br>",
+	      days[a.tm_wday], a.tm_mday, a.tm_mon + 1,
+	      a.tm_hour, a.tm_min, b.tm_hour, b.tm_min);
+
+  tcp_qprintf(tq, "<hr><b>\"%s\": \"%s\"</b><br><br>",
+	      pvrr->pvrr_channel->ch_name, pvrr->pvrr_title);
+  
+  pvrstatus = pvrr->pvrr_status;
+
+  if((rstatus = val2str(pvrstatus, recstatustxt)) != NULL)
+    tcp_qprintf(tq, "Recording status: %s<br>", rstatus);
+
+  tcp_qprintf(tq, "<form method=\"post\" action=\"/pvrinfo/%d\">", 
+	      pvrr->pvrr_ref);
+
+  switch(pvrstatus) {
+  case HTSTV_PVR_STATUS_SCHEDULED:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"clear\" value=\"Remove from schedule\">");
+    break;
+    
+  case HTSTV_PVR_STATUS_RECORDING:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"cancel\" value=\"Cancel recording\">");
+    break;
+
+  case HTSTV_PVR_STATUS_DONE:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"clear\" value=\"Remove from log\">");
+    break;
+
+  default:
+    tcp_qprintf(tq, "<input type=\"submit\" "
+		"name=\"clear\" value=\"Clear error status\">");
+    break;
+  }
+
+  tcp_qprintf(tq, "</form>");
+  tcp_qprintf(tq, "%s", pvrr->pvrr_desc);
+
+  tcp_qprintf(tq, "<hr><a href=\"/simple.html\">New search</a><br>");
+  tcp_qprintf(tq, "</body></html>");
+  http_output_html(hc, hr);
+  return 0;
+}
+
+
+/**
+ * WEB user interface
+ */
+void
+webui_start(void)
+{
+  http_path_add("/", NULL, page_root, ACCESS_WEB_INTERFACE);
+
+  http_path_add("/simple.html", NULL, page_simple,  ACCESS_SIMPLE);
+  http_path_add("/eventinfo",   NULL, page_einfo,   ACCESS_SIMPLE);
+  http_path_add("/pvrinfo",     NULL, page_pvrinfo, ACCESS_SIMPLE);
+  
+}
diff --git a/webui/webui.h b/webui/webui.h
new file mode 100644
index 000000000..8fe43ebe1
--- /dev/null
+++ b/webui/webui.h
@@ -0,0 +1,24 @@
+/*
+ *  tvheadend, web user interface
+ *  Copyright (C) 2008 Andreas Öman
+ *
+ *  This program is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program.  If not, see <htmlui://www.gnu.org/licenses/>.
+ */
+
+#ifndef WEBUI_H_
+#define WEBUI_H_
+
+void webui_start(void);
+
+#endif /* WEBUI_H_ */