tvheadend: remove rpc.[ch]
No longer used.
This commit is contained in:
Andreas Öman
parent
9f02d07545
commit
41212c6028
2 changed files with 0 additions and 425 deletions
364
rpc.c
364
rpc.c
|
|
@ -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);
|
||||
}
|
||||
61
rpc.h
61
rpc.h
|
|
@ -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_ */
|
||||
Loading…
Add table
Reference in a new issue