tvheadend: remove rpc.[ch]

No longer used.

diff --git a/rpc.c b/rpc.c
deleted file mode 100644 (file)
index e60d1b3..0000000
--- a/rpc.c
+++ /dev/null
@@ -1,364 +0,0 @@
-/*
- *  tvheadend, RPC 
- *  Copyright (C) 2007 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 <stdarg.h>
-#include <fcntl.h>
-#include <errno.h>
-#include <netinet/in.h>
-#include <netinet/tcp.h>
-#include <arpa/inet.h>
-#include <libhts/htsmsg.h>
-
-#include "tvhead.h"
-#include "channels.h"
-#include "subscriptions.h"
-#include "dispatch.h"
-#include "epg.h"
-#include "pvr.h"
-#include "rpc.h"
-#include "access.h"
-
-
-/** 
- * Build a channel information message
- */
-static htsmsg_t *
-rpc_build_channel_msg(channel_t *ch)
-{
-  htsmsg_t *m;
-
-  m = htsmsg_create();
-
-  htsmsg_add_str(m, "name", ch->ch_name);
-  htsmsg_add_u32(m, "id", ch->ch_id);
-  if(ch->ch_icon)
-    htsmsg_add_str(m, "icon", ch->ch_icon);
-  return m;
-}
-
-
-
-
-
-
-
-/** 
- * Simple function to respond 'ok' 
- */
-htsmsg_t *
-rpc_ok(rpc_session_t *ses)
-{
-  htsmsg_t *r = htsmsg_create();
-  htsmsg_add_u32(r, "seq", ses->rs_seq);
-  return r;
-}
-
-
-
-/** 
- * Simple function to respond with an error
- */
-htsmsg_t *
-rpc_error(rpc_session_t *ses, const char *err)
-{
-  htsmsg_t *r = htsmsg_create();
-  htsmsg_add_u32(r, "seq", ses->rs_seq);
-  htsmsg_add_str(r, "_error", err);
-  return r;
-}
-
-
-
-/** 
- * Simple function to respond with an error
- */
-htsmsg_t *
-rpc_unauthorized(rpc_session_t *ses)
-{
-  htsmsg_t *r = htsmsg_create();
-  htsmsg_add_u32(r, "seq", ses->rs_seq);
-  htsmsg_add_u32(r, "_noaccess", 1);
-  return r;
-}
-
-
-
-
-/**
- * Auth peer
- */
-static htsmsg_t *
-rpc_auth(rpc_session_t *ses, htsmsg_t *in, void *opaque)
-{
-  const char *user = htsmsg_get_str(in, "username");
-  const char *pass = htsmsg_get_str(in, "password");
-
-  if(user != NULL && pass != NULL) {
-    free(ses->rs_username);
-    free(ses->rs_password);
-
-    ses->rs_username = strdup(user);
-    ses->rs_password = strdup(pass);
-  }
-
-  return rpc_ok(ses);
-}
-
-/**
- * Set client in async mode
- */
-static htsmsg_t *
-rpc_async(rpc_session_t *ses, htsmsg_t *in, void *opaque)
-{
-  ses->rs_is_async = 1;
-  return rpc_ok(ses);
-}
-
-
-/*
- * channelsList method
- */
-static htsmsg_t *
-rpc_channels_list(rpc_session_t *ses, htsmsg_t *in, void *opaque)
-{
-  htsmsg_t *out;
-  channel_t *ch;
-
-  out = htsmsg_create();
-  htsmsg_add_u32(out, "seq", ses->rs_seq);
-
-  RB_FOREACH(ch, &channel_name_tree, ch_name_link)
-    htsmsg_add_msg(out, "channel", rpc_build_channel_msg(ch));
-
-  return out;
-}
-
-/*
- * eventInfo method
- */
-static htsmsg_t *
-rpc_event_info(rpc_session_t *ses, htsmsg_t *in, void *opaque)
-{
-  htsmsg_t *out;
-  channel_t *ch;
-  uint32_t u32;
-  const char *s, *errtxt = NULL;
-  event_t *e = NULL, *x;
-  uint32_t tag, prev, next;
-  pvr_rec_t *pvrr;
-
-  out = htsmsg_create();
-  htsmsg_add_u32(out, "seq", ses->rs_seq);
-
-  if(htsmsg_get_u32(in, "tag", &u32) >= 0) {
-    e = epg_event_find_by_tag(u32);
-  } else if((s = htsmsg_get_str(in, "channel")) != NULL) {
-    if((ch = channel_find_by_name(s, 0)) == NULL) {
-      errtxt = "Channel not found";
-    } else {
-      if(htsmsg_get_u32(in, "time", &u32) < 0) {
-       e = epg_event_get_current(ch);
-      } else {
-       e = epg_event_find_by_time(ch, u32);
-      }
-    }
-  } else {
-    errtxt = "Invalid arguments";
-  }
-  
-  if(e == NULL) {
-    errtxt = "Event not found";
-  }
-
-  if(errtxt != NULL) {
-    htsmsg_add_str(out, "_error", errtxt);
-  } else {
-    tag = e->e_tag;
-    x = TAILQ_PREV(e, event_queue, e_channel_link);
-    prev = x != NULL ? x->e_tag : 0;
-    
-    x = TAILQ_NEXT(e, e_channel_link);
-    next = x != NULL ? x->e_tag : 0;
-
-    htsmsg_add_u32(out, "start", e->e_start);
-    htsmsg_add_u32(out, "stop",  e->e_start + e->e_duration);
-
-    if(e->e_title != NULL)
-      htsmsg_add_str(out, "title", e->e_title);
-
-    if(e->e_desc != NULL)
-      htsmsg_add_str(out, "desc", e->e_desc);
-       
-    htsmsg_add_u32(out, "tag", tag);
-    if(prev)
-      htsmsg_add_u32(out, "prev", prev);
-    if(next)
-      htsmsg_add_u32(out, "next", next);
-
-    if((pvrr = pvr_get_by_entry(e)) != NULL)
-      htsmsg_add_u32(out, "pvrstatus", pvrr->pvrr_status);
-  }
-
-  return out;
-}
-
-#if 0
-
-
-/**
- * record method
- */
-static htsmsg_t *
-rpc_record(rpc_session_t *ses, htsmsg_t *in, void *opaque)
-{
-  htsp_msg_t *r;
-  uint32_t u32;
-  const char *s, *errtxt = NULL;
-  event_t *e = NULL;
-  recop_t op;
-
-  r = htsp_create_msg();
-  htsp_add_u32(r, "seq", hc->hc_seq);
-
-  epg_lock();
-
-  s = htsp_get_string(m, "command");
-  if(s == NULL) {
-    errtxt = "Missing 'command' field";
-  } else {
-    op = pvr_op2int(s);
-    if(op == -1) {
-      errtxt = "Invalid 'command' field";
-    } else {
-
-      if((u32 = htsp_get_u32(m, "tag")) != 0) {
-       e = epg_event_find_by_tag(u32);
-      
-       if(e != NULL) {
-         pvr_event_record_op(e->e_ch, e, op);
-         errtxt = NULL;
-       } else {
-         errtxt = "Event not found";
-       }
-      } else {
-       errtxt = "Missing identifier";
-      }
-    }
-  }
-
-  epg_unlock();
-  
-  if(errtxt)
-    htsp_add_string(r, "_error", errtxt);
-
-  htsp_send_msg(hc, NULL, r);
-  htsp_free_msg(r);
-}
-#endif
-
-/**
- * Common methods and their required auth level
- */
-static rpc_cmd_t common_rpc[] = {
-  { "auth",         rpc_auth,          0 },
-  { "async",        rpc_async,         ACCESS_STREAMING },
-  { "channelsList", rpc_channels_list, ACCESS_STREAMING },
-  { "eventInfo",    rpc_event_info,    ACCESS_STREAMING },
-  { NULL,           NULL,              0 },
-};
-
-
-/**
- *
- */
-static int
-rpc_dispatch_set(rpc_session_t *ses, htsmsg_t *in, rpc_cmd_t *cmds,
-                void *opaque, const char *method, struct sockaddr *peer,
-                htsmsg_t **outp)
-{
-  for(; cmds->rc_name; cmds++) {
-    if(strcmp(cmds->rc_name, method))
-      continue;
-    if(access_verify(ses->rs_username, ses->rs_password, peer, 
-                    cmds->rc_privmask)) {
-      *outp = rpc_unauthorized(ses);
-      return 0;
-    }
-
-    *outp = cmds->rc_func(ses, in, opaque);
-    return 0;
-  }
-  return -1;
-}
-
-
-/*
- *
- */
-htsmsg_t *
-rpc_dispatch(rpc_session_t *ses, htsmsg_t *in, rpc_cmd_t *cmds, void *opaque,
-            struct sockaddr *peer)
-{
-  const char *method;
-  htsmsg_t *out;
-  int r;
-
-  if(htsmsg_get_u32(in, "seq", &ses->rs_seq))
-    ses->rs_seq = 0;
-
-  if((method = htsmsg_get_str(in, "method")) == NULL)
-    return rpc_error(ses, "Method not specified");
-
-  r = rpc_dispatch_set(ses, in, common_rpc, opaque, method, peer, &out);
-  if(r == -1 && cmds != NULL) 
-    r = rpc_dispatch_set(ses, in, cmds, opaque, method, peer, &out);
-
-  if(r == -1)
-    return rpc_error(ses, "Method not found");
-
-  return out;
-}
-
-
-/*
- *
- */
-void
-rpc_init(rpc_session_t *ses, const char *logname)
-{
-  memset(ses, 0, sizeof(rpc_session_t));
-  ses->rs_logname = strdup(logname);
-}
-
-/*
- *
- */
-void
-rpc_deinit(rpc_session_t *ses)
-{
-  free(ses->rs_username);
-  free(ses->rs_password);
-
-  free((void *)ses->rs_logname);
-}

diff --git a/rpc.h b/rpc.h
deleted file mode 100644 (file)
index 71e6fc7..0000000
--- a/rpc.h
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- *  tvheadend, RPC interface
- *  Copyright (C) 2007 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/>.
- */
-
-#ifndef RPC_H_
-#define RPC_H_
-
-#include <libhts/htsmsg.h>
-
-typedef struct rpc_session {
-
-  const char *rs_logname;
-
-  uint32_t rs_seq;
-
-  unsigned int rs_maxweight;
-  unsigned int rs_is_async;
-
-  struct th_subscription_list rs_subscriptions;
-
-  char *rs_username;
-  char *rs_password;
-
-} rpc_session_t;
-
-
-typedef struct rpc_cmd {
-  const char *rc_name;
-  htsmsg_t *(*rc_func)(rpc_session_t *ses, htsmsg_t *in, void *opaque);
-  int rc_privmask;
-} rpc_cmd_t;
-
-
-
-void rpc_init(rpc_session_t *ses, const char *logname);
-
-void rpc_deinit(rpc_session_t *ses);
-
-htsmsg_t *rpc_dispatch(rpc_session_t *ses, htsmsg_t *in, rpc_cmd_t *cmds,
-                      void *opaque, struct sockaddr *peer);
-
-htsmsg_t *rpc_ok(rpc_session_t *ses);
-htsmsg_t *rpc_error(rpc_session_t *ses, const char *err);
-htsmsg_t *rpc_unauthorized(rpc_session_t *ses);
-
-
-#endif /* RPC_H_ */