]> git.vomp.tv Git - jsonserver.git/blob - handler.c
Add an ignore file
[jsonserver.git] / handler.c
1 #include "handler.h"
2
3 #include <string.h>
4 #include <stdlib.h>
5 #include <jsoncpp/json/json.h>
6 #include <string>
7
8 #include <vdr/videodir.h>
9 #include <vdr/recording.h>
10 #include <vdr/menu.h>
11 #include <vdr/timers.h>
12
13 #include "log.h"
14
15 int jsonserver_request_handler(struct mg_connection *conn)
16 {
17   Log* log = Log::getInstance();
18   const struct mg_request_info *request_info = mg_get_request_info(conn);
19   
20   if (strcmp(request_info->uri, "/jsonserver")) return 0; // not for us
21
22   char wvrequest[20];
23   int wvrl = mg_get_var(request_info->query_string, strlen(request_info->query_string), "req", wvrequest, 20);
24   if (wvrl == -1)
25   {
26     log->log("JSONServer", Log::ERR, "Could not decode req");
27     return 0;
28   }
29
30 /*
31   if (!strcmp(request_info->request_method, "OPTIONS"))
32   {
33     mg_printf(conn, "%s", "HTTP/1.0 200 OK\r\n");
34     mg_printf(conn, "%s", "Access-Control-Allow-Origin: *\r\n");
35     mg_printf(conn, "%s", "Content-Type: text/plain\r\n\r\n");
36     return (void*)1;
37   }
38 */
39
40   // Get POST data
41   char postData[10000];
42   postData[0] = '\0';
43   if (!strcmp(request_info->request_method, "POST"))
44   {
45     const char* contentLength = mg_get_header(conn, "Content-Length");
46     int contentLengthI = atoi(contentLength);
47     log->log("JSONServer", Log::DEBUG, "POST data content length: %i", contentLengthI);
48     if (contentLengthI > 10000)
49     {
50       log->log("JSONServer", Log::DEBUG, "Length > 10000, rejecting");
51       return 0;
52     }
53
54     if (contentLengthI > 0)
55     {
56       // FIXME - assume for now that all post data will be small enough to have arrived immediately
57       int bytesRead = mg_read(conn, postData, contentLengthI);
58       if (bytesRead != contentLengthI)
59       {
60         log->log("JSONServer", Log::DEBUG, "Could not read up to contentLength");
61         return 0;
62       }
63     }
64   }
65
66   Json::Value js;
67   bool success = false;
68
69   if      (!strcmp(wvrequest, "reclist")) success = jsonserver_reclist(js);
70   else if (!strcmp(wvrequest, "recinfo")) success = jsonserver_recinfo(js, postData);
71   else if (!strcmp(wvrequest, "recdel")) success = jsonserver_recdel(js, postData);
72   else if (!strcmp(wvrequest, "recmove")) success = jsonserver_recmove(js, postData);
73   else if (!strcmp(wvrequest, "channellist")) success = jsonserver_channellist(js);
74   else if (!strcmp(wvrequest, "channelschedule")) success = jsonserver_channelschedule(js, postData);
75   else if (!strcmp(wvrequest, "timerlist")) success = jsonserver_timerlist(js);
76   else if (!strcmp(wvrequest, "timerdel")) success = jsonserver_timerdel(js, postData);
77   else if (!strcmp(wvrequest, "timerset")) success = jsonserver_timerset(js, postData);
78
79   if (!success) return 0; // the specific handler failed badly
80
81   // Now js will be filled
82
83   Json::StyledWriter sw;
84   std::string jsonout = sw.write(js);
85   mg_printf(conn, "%s", "HTTP/1.0 200 OK\r\n");
86   mg_printf(conn, "%s", "Content-Type: text/plain\r\n\r\n");
87   mg_write(conn, jsonout.c_str(), jsonout.length());
88   return 1;
89
90   
91 /*
92   else if (event == MG_EVENT_LOG)
93   {
94     if (request_info->status_code == 400) // bad request
95     {
96       log->log("Mongoose", Log::DEBUG, "400 BAD REQUEST:");
97       log->log("Mongoose", Log::DEBUG, request_info->request_method);
98       log->log("Mongoose", Log::DEBUG, request_info->uri);
99       log->log("Mongoose", Log::DEBUG, request_info->http_version);
100       log->log("Mongoose", Log::DEBUG, request_info->query_string);
101       log->log("Mongoose", Log::DEBUG, request_info->log_message);
102       for (int i = 0; i < request_info->num_headers; i++)
103       {
104         log->log("Mongoose", Log::DEBUG, "%s: %s", request_info->http_headers[i].name, request_info->http_headers[i].value);
105       }
106     }
107     else
108     {
109       log->log("Mongoose", Log::DEBUG, request_info->log_message);
110       log->log("Mongoose", Log::DEBUG, request_info->uri);
111     }
112     return (void*)1;
113   }
114   
115   // other events not handled:
116   // MG_HTTP_ERROR, MG_INIT_SSL
117   // Let mongoose do something with those
118
119   return NULL;
120
121 */
122   
123 }
124
125 bool jsonserver_reclist(Json::Value& js)
126 {
127   Log* log = Log::getInstance();
128   log->log("JSONServer", Log::DEBUG, "reclist");
129
130   int FreeMB;
131   int Percent = VideoDiskSpace(&FreeMB);
132   int Total = (FreeMB / (100 - Percent)) * 100;
133         
134   js["MBFree"] = FreeMB;
135   js["Percent"] = Percent;
136   js["Total"] = Total;
137   
138   Json::Value jsrecordings;
139   cRecordings Recordings;
140   Recordings.Load();
141   for (cRecording *recording = Recordings.First(); recording; recording = Recordings.Next(recording))
142   {
143     Json::Value oneRec;
144     oneRec["StartTime"] = (Json::UInt)recording->Start();
145     oneRec["Name"] = recording->Name();
146     oneRec["Filename"] = recording->FileName();
147     jsrecordings.append(oneRec);
148   }
149   js["Recordings"] = jsrecordings;
150   
151   return true;
152 }
153
154 bool jsonserver_recinfo(Json::Value& js, const char* postData)
155 {
156   // For now this returns just the string summary of the recording
157
158   Log* log = Log::getInstance();
159   log->log("JSONServer", Log::DEBUG, "recinfo");
160
161   char reqfilename[1000];
162   int mgv1 = mg_get_var(postData, strlen(postData), "filename", reqfilename, 1000);
163   if (mgv1 == -1)
164   {
165     log->log("JSONServer", Log::ERR, "Could not decode filename");
166     js["Result"] = false;
167     js["Error"] = "Could not decode filename";
168     return true;
169   }
170
171   log->log("JSONServer", Log::DEBUG, "%s", reqfilename);
172   
173   cRecordings Recordings;
174   Recordings.Load(); // probably have to do this
175   cRecording *recording = Recordings.GetByName(reqfilename);
176
177   if (recording)
178   {
179     const cRecordingInfo *Info = recording->Info();
180     char* summary = (char*)Info->ShortText();
181     if (isempty(summary)) summary = (char*)Info->Description();
182     js["Result"] = true;
183     js["Summary"] = summary;
184   }
185   else
186   {
187     log->log("JSONServer", Log::ERR, "recinfo found no recording");
188     js["Result"] = false;
189     js["Summary"] = "";
190   }  
191
192   return true;
193 }
194
195 bool jsonserver_recdel(Json::Value& js, const char* postData)
196 {
197   Log* log = Log::getInstance();
198   log->log("JSONServer", Log::DEBUG, "recdel");
199
200   char reqfilename[1000];
201   int mgv1 = mg_get_var(postData, strlen(postData), "filename", reqfilename, 1000);
202   if (mgv1 == -1)
203   {
204     log->log("JSONServer", Log::ERR, "Could not decode filename");
205     js["Result"] = false;
206     js["Error"] = "Could not decode filename";
207     return true;
208   }
209
210   log->log("JSONServer", Log::DEBUG, "%s", reqfilename);
211   
212   cRecordings Recordings;
213   Recordings.Load(); // probably have to do this
214   cRecording *recording = Recordings.GetByName(reqfilename);
215
216   if (!recording)
217   {
218     js["Result"] = false;
219     js["Error"] = "Could not find recording to delete";
220     return true;
221   }
222
223   log->log("JSONServer", Log::DEBUG, "Deleting recording: %s", recording->Name());
224   cRecordControl *rc = cRecordControls::GetRecordControl(recording->FileName());
225   if (rc)
226   {
227     js["Result"] = false;
228     js["Error"] = "This recording is still recording.. ho ho";
229     return true;
230   }
231
232   if (recording->Delete())
233   {
234     ::Recordings.DelByName(recording->FileName());
235     js["Result"] = true;
236   }
237   else
238   {
239     js["Result"] = false;
240     js["Error"] = "Failed to delete recording";
241   }
242
243   return true;
244 }
245
246 bool jsonserver_recmove(Json::Value& js, const char* postData)
247 {
248   Log* log = Log::getInstance();
249   log->log("JSONServer", Log::DEBUG, "recmove");
250
251   char sFileName[1000]; int mgv1 = mg_get_var(postData, strlen(postData), "filename", sFileName, 1000);  
252   char sNewPath[1000];  int mgv2 = mg_get_var(postData, strlen(postData), "newpath", sNewPath, 1000);  
253
254   if ( (mgv1 == -1) || (mgv2 == -1) || !strlen(sFileName) || !strlen(sNewPath) )
255   {
256     log->log("JSONServer", Log::ERR, "request mgvs: %i %i", mgv1, mgv2);
257     js["Result"] = false;
258     js["Error"] = "Bad request parameters";
259     return true;
260   }
261
262   cRecordings Recordings;
263   Recordings.Load(); // probably have to do this
264   cRecording* recording = Recordings.GetByName(sFileName);
265
266   if (!recording)
267   {
268     log->log("JSONServer", Log::ERR, "Could not find recording to move");
269     js["Result"] = false;
270     js["Error"] = "Bad filename";
271     return true;
272   }
273
274   cRecordControl *rc = cRecordControls::GetRecordControl(recording->FileName());
275   if (rc)
276   {
277     log->log("JSONServer", Log::ERR, "Could not move recording, it is still recording");
278     js["Result"] = false;
279     js["Error"] = "Cannot move recording in progress";
280     return true;
281   }
282   
283   log->log("JSONServer", Log::DEBUG, "moving recording: %s", recording->Name());
284   log->log("JSONServer", Log::DEBUG, "moving recording: %s", recording->FileName());
285   log->log("JSONServer", Log::DEBUG, "to: %s", sNewPath);
286
287   const char* t = recording->FileName();
288
289   char* dateDirName = NULL;   int k;
290   char* titleDirName = NULL;  int j;
291   char* newContainer = NULL;
292
293   // Find the datedirname
294   for(k = strlen(t) - 1; k >= 0; k--)
295   {
296     if (t[k] == '/')
297     {
298       log->log("JSONServer", Log::DEBUG, "l1: %i", strlen(&t[k+1]) + 1);
299       dateDirName = new char[strlen(&t[k+1]) + 1];
300       strcpy(dateDirName, &t[k+1]);
301       break;
302     }
303   }
304
305   // Find the titledirname
306
307   for(j = k-1; j >= 0; j--)
308   {
309     if (t[j] == '/')
310     {
311       log->log("JSONServer", Log::DEBUG, "l2: %i", (k - j - 1) + 1);
312       titleDirName = new char[(k - j - 1) + 1];
313       memcpy(titleDirName, &t[j+1], k - j - 1);
314       titleDirName[k - j - 1] = '\0';
315       break;
316     }
317   }
318
319   log->log("JSONServer", Log::DEBUG, "datedirname: %s", dateDirName);
320   log->log("JSONServer", Log::DEBUG, "titledirname: %s", titleDirName);
321   log->log("JSONServer", Log::DEBUG, "viddir: %s", VideoDirectory);
322
323   ExchangeChars(sNewPath, true);
324   log->log("JSONServer", Log::DEBUG, "EC: %s", sNewPath);
325
326   newContainer = new char[strlen(VideoDirectory) + strlen(sNewPath) + strlen(titleDirName) + 1];
327   log->log("JSONServer", Log::DEBUG, "l10: %i", strlen(VideoDirectory) + strlen(sNewPath) + strlen(titleDirName) + 1);
328   sprintf(newContainer, "%s%s%s", VideoDirectory, sNewPath, titleDirName);
329   log->log("JSONServer", Log::DEBUG, "%s", newContainer);
330
331   struct stat dstat;
332   int statret = stat(newContainer, &dstat);
333   if ((statret == -1) && (errno == ENOENT)) // Dir does not exist
334   {
335     log->log("JSONServer", Log::DEBUG, "new dir does not exist");
336     int mkdirret = mkdir(newContainer, 0755);
337     if (mkdirret != 0)
338     {
339       delete[] dateDirName;
340       delete[] titleDirName;
341       delete[] newContainer;
342
343       log->log("JSONServer", Log::ERR, "Failed to make new dir");
344       js["Result"] = false;
345       js["Error"] = "Failed to create new directory";
346       return true;
347     }
348   }
349   else if ((statret == 0) && (! (dstat.st_mode && S_IFDIR))) // Something exists but it's not a dir
350   {
351     delete[] dateDirName;
352     delete[] titleDirName;
353     delete[] newContainer;
354
355     log->log("JSONServer", Log::ERR, "Something already exists?");
356     js["Result"] = false;
357     js["Error"] = "Something already exists at the new path";
358     return true;
359   }
360
361   // Ok, the directory container has been made, or it pre-existed.
362
363   char* newDir = new char[strlen(newContainer) + 1 + strlen(dateDirName) + 1];
364   sprintf(newDir, "%s/%s", newContainer, dateDirName);
365
366   log->log("JSONServer", Log::DEBUG, "doing rename '%s' '%s'", t, newDir);
367   int renameret = rename(t, newDir);
368   if (renameret == 0)
369   {
370     // Success. Test for remove old dir containter
371     char* oldTitleDir = new char[k+1];
372     memcpy(oldTitleDir, t, k);
373     oldTitleDir[k] = '\0';
374     log->log("JSONServer", Log::DEBUG, "len: %i, cp: %i, strlen: %i, oldtitledir: %s", k+1, k, strlen(oldTitleDir), oldTitleDir);
375     rmdir(oldTitleDir); // can't do anything about a fail result at this point.
376     delete[] oldTitleDir;
377
378     ::Recordings.Update();
379     js["Result"] = true;
380   }
381   else
382   {
383     log->log("JSONServer", Log::ERR, "Rename failed");
384     js["Result"] = false;
385     js["Error"] = "Move failed";
386   }
387
388   delete[] dateDirName;
389   delete[] titleDirName;
390   delete[] newContainer;
391   delete[] newDir;
392
393   return true;
394 }
395
396 bool jsonserver_channellist(Json::Value& js)
397 {
398   Log* log = Log::getInstance();
399   log->log("JSONServer", Log::DEBUG, "channellist");
400
401   Json::Value jschannels;
402   
403   int type;
404   for (cChannel *channel = Channels.First(); channel; channel = Channels.Next(channel))
405   {
406     if (!channel->GroupSep())
407     {
408       log->log("JSONServer", Log::DEBUG, "name: '%s'", channel->Name());
409
410       if (channel->Vpid()) type = 1;
411       else if (channel->Apid(0)) type = 2;
412       else continue;
413
414       Json::Value oneChannel;
415       oneChannel["Number"] = channel->Number();
416       oneChannel["Type"] = type;
417       oneChannel["Name"] = channel->Name();
418 #if VDRVERSNUM < 10703
419       oneChannel["VType"] = 2;
420 #else
421       oneChannel["VType"] = channel->Vtype();
422 #endif
423       jschannels.append(oneChannel);    
424     }
425   }
426   js["Channels"] = jschannels;
427   
428   return true;
429 }
430
431 bool jsonserver_channelschedule(Json::Value& js, const char* postData)
432 {
433   Log* log = Log::getInstance();
434   log->log("JSONServer", Log::DEBUG, "channelschedule '%s'", postData);
435
436   char sChannelNumber[15];  int mgv1 = mg_get_var(postData, strlen(postData), "channelnumber", sChannelNumber, 15);  
437   char sStartTime[15];      int mgv2 = mg_get_var(postData, strlen(postData), "starttime", sStartTime, 15);  
438   char sDuration[15];       int mgv3 = mg_get_var(postData, strlen(postData), "duration", sDuration, 15);  
439
440   if ( (mgv1 == -1) || (mgv2 == -1) || (mgv3 == -1) )
441   {
442     log->log("JSONServer", Log::ERR, "request mgvs: %i %i %i", mgv1, mgv2, mgv3);
443     js["Result"] = false;
444     js["Error"] = "Bad request parameters";
445     return true;
446   }
447
448   int channelNumber = atoi(sChannelNumber);
449   int startTime = atoi(sStartTime); 
450   int duration = atoi(sDuration); 
451
452   cChannel* channel = NULL;
453   for (channel = Channels.First(); channel; channel = Channels.Next(channel))
454   {
455     if (channel->GroupSep()) continue;
456     if (channel->Number() == channelNumber) break;
457   }
458
459   if (!channel)
460   {
461     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
462     js["Result"] = false;
463     js["Error"] = "Could not find channel";
464     return true;
465   }
466
467   cSchedulesLock MutexLock;
468   const cSchedules *Schedules = cSchedules::Schedules(MutexLock);
469   if (!Schedules)
470   {
471     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
472     js["Result"] = false;
473     js["Error"] = "Internal schedules error (1)";
474     return true;
475   }
476   const cSchedule *Schedule = Schedules->GetSchedule(channel->GetChannelID());
477   if (!Schedule)     
478   {
479     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
480     js["Result"] = false;
481     js["Error"] = "Internal schedules error (2)";
482     return true;
483   }
484     
485   Json::Value jsevents;
486
487   for (const cEvent* event = Schedule->Events()->First(); event; event = Schedule->Events()->Next(event))
488   {
489     //in the past filter
490     if ((event->StartTime() + event->Duration()) < time(NULL)) continue;
491    //start time filter
492     if ((event->StartTime() + event->Duration()) <= startTime) continue;
493     //duration filter
494     if (event->StartTime() >= (startTime + duration)) continue;
495
496     Json::Value oneEvent;
497     oneEvent["ID"] = event->EventID();
498     oneEvent["Time"] = (Json::UInt)event->StartTime();
499     oneEvent["Duration"] = event->Duration();
500     oneEvent["Title"] = event->Title() ? event->Title() : "";
501     oneEvent["Description"] = event->Description() ? event->Description() : "";
502     jsevents.append(oneEvent);
503   }
504
505   js["Events"] = jsevents;
506   return true;
507 }
508
509 bool jsonserver_timerlist(Json::Value& js)
510 {
511   Log* log = Log::getInstance();
512   log->log("JSONServer", Log::DEBUG, "timerlist");
513
514   Json::Value jstimers;
515   
516   cTimer *timer;
517   int numTimers = Timers.Count();
518
519   for (int i = 0; i < numTimers; i++)
520   {
521     timer = Timers.Get(i);
522     Json::Value oneTimer;
523     oneTimer["Active"] = timer->HasFlags(tfActive);
524     oneTimer["Recording"] = timer->Recording();
525     oneTimer["Pending"] = timer->Pending();
526     oneTimer["Priority"] = timer->Priority();
527     oneTimer["Lifetime"] = timer->Lifetime();
528     oneTimer["ChannelNumber"] = timer->Channel()->Number();
529     oneTimer["StartTime"] = (int)timer->StartTime();
530     oneTimer["StopTime"] = (int)timer->StopTime();
531     oneTimer["Day"] = (int)timer->Day();
532     oneTimer["WeekDays"] = timer->WeekDays();
533     oneTimer["Name"] = timer->File();
534     jstimers.append(oneTimer);
535   }
536   
537   js["Timers"] = jstimers;
538   return true;
539 }
540
541 bool jsonserver_timerdel(Json::Value& js, const char* postData)
542 {
543   Log* log = Log::getInstance();
544   log->log("JSONServer", Log::DEBUG, "timerdel");
545
546   char sdelChannel[15];   int mgv1 = mg_get_var(postData, strlen(postData), "delchannel", sdelChannel, 15);  
547   char sdelWeekdays[15];  int mgv2 = mg_get_var(postData, strlen(postData), "delweekdays", sdelWeekdays, 15);  
548   char sdelDay[15];       int mgv3 = mg_get_var(postData, strlen(postData), "delday", sdelDay, 15);  
549   char sdelStart[15];     int mgv4 = mg_get_var(postData, strlen(postData), "delstart", sdelStart, 15);  
550   char sdelStop[15];      int mgv5 = mg_get_var(postData, strlen(postData), "delstop", sdelStop, 15);  
551
552   if ( (mgv1 == -1) || (mgv2 == -1) || (mgv3 == -1) || (mgv4 == -1) || (mgv5 == -1) )
553   {
554     log->log("JSONServer", Log::ERR, "request mgvs: %i %i %i %i %i", mgv1, mgv2, mgv3, mgv4, mgv5);
555     js["Result"] = false;
556     js["Error"] = "Bad request parameters";
557     return true;
558   }
559
560   int delChannel = atoi(sdelChannel); 
561   int delWeekdays = atoi(sdelWeekdays); 
562   int delDay = atoi(sdelDay); 
563   int delStart = atoi(sdelStart); 
564   int delStop = atoi(sdelStop); 
565
566   cTimer* ti = NULL;
567   for (ti = Timers.First(); ti; ti = Timers.Next(ti))
568   {
569     if  ( (ti->Channel()->Number() == delChannel)
570      &&   ((ti->WeekDays() && (ti->WeekDays() == delWeekdays)) || (!ti->WeekDays() && (ti->Day() == delDay)))
571      &&   (ti->StartTime() == delStart)
572      &&   (ti->StopTime() == delStop) )
573        break;
574   }
575   
576   if (!ti)
577   {
578     log->log("JSONServer", Log::ERR, "Could not find timer");
579     js["Result"] = false;
580     js["Error"] = "Could not find timer";
581     return true;
582   }
583
584   if (Timers.BeingEdited())
585   {
586     log->log("JSONServer", Log::ERR, "Unable to delete timer - timers being edited at VDR");
587     js["Result"] = false;
588     js["Error"] = "Timers being edited at VDR";
589     return true; 
590   }
591   
592   if (ti->Recording())
593   {
594     log->log("JSONServer", Log::ERR, "Unable to delete timer - timer is running");
595     js["Result"] = false;
596     js["Error"] = "Timer is running";
597     return true;
598   }
599   
600   Timers.Del(ti);
601   Timers.SetModified();
602   js["Result"] = true;
603     
604   return true;
605 }
606
607 bool jsonserver_timerset(Json::Value& js, const char* postData)
608 {
609   Log* log = Log::getInstance();
610   log->log("JSONServer", Log::DEBUG, "timerset");
611
612   char sTimerString[1024];   int mgv1 = mg_get_var(postData, strlen(postData), "timerstring", sTimerString, 1024);  
613
614   if (mgv1 == -1)
615   {
616     log->log("JSONServer", Log::ERR, "Could not get timerstring");
617     js["Result"] = false;
618     js["Error"] = "Bad request parameters";
619     return true;
620   }
621
622   log->log("JSONServer", Log::DEBUG, "'%s'", sTimerString);
623   cTimer *timer = new cTimer;
624   if (!timer->Parse(sTimerString))
625   {
626     delete timer;
627     js["Result"] = false;
628     js["Error"] = "Failed to parse timer request details";
629     return true;
630   }
631
632   cTimer *t = Timers.GetTimer(timer);
633   if (t)
634   {
635     delete timer;
636     js["Result"] = false;
637     js["Error"] = "Timer already exists";
638     return true;
639   }
640
641   Timers.Add(timer);
642   Timers.SetModified();
643   js["Result"] = true;
644   return true;
645 }
646