]> git.vomp.tv Git - jsonserver.git/blob - handler.c
Add file size to recordings list
[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       postData[contentLengthI] = '\0';
64     }
65   }
66
67   Json::Value js;
68   bool success = false;
69
70   if      (!strcmp(wvrequest, "reclist")) success = jsonserver_reclist(js);
71   else if (!strcmp(wvrequest, "recinfo")) success = jsonserver_recinfo(js, postData);
72   else if (!strcmp(wvrequest, "recdel")) success = jsonserver_recdel(js, postData);
73   else if (!strcmp(wvrequest, "recmove")) success = jsonserver_recmove(js, postData);
74   else if (!strcmp(wvrequest, "recstop")) success = jsonserver_recstop(js, postData);
75   else if (!strcmp(wvrequest, "channellist")) success = jsonserver_channellist(js);
76   else if (!strcmp(wvrequest, "channelschedule")) success = jsonserver_channelschedule(js, postData);
77   else if (!strcmp(wvrequest, "timerlist")) success = jsonserver_timerlist(js);
78   else if (!strcmp(wvrequest, "timerdel")) success = jsonserver_timerdel(js, postData);
79   else if (!strcmp(wvrequest, "timerset")) success = jsonserver_timerset(js, postData);
80
81   if (!success) return 0; // the specific handler failed badly
82
83   // Now js will be filled
84
85   Json::StyledWriter sw;
86   std::string jsonout = sw.write(js);
87   mg_printf(conn, "%s", "HTTP/1.0 200 OK\r\n");
88   mg_printf(conn, "%s", "Content-Type: text/plain\r\n\r\n");
89   mg_write(conn, jsonout.c_str(), jsonout.length());
90   return 1;
91
92   
93 /*
94   else if (event == MG_EVENT_LOG)
95   {
96     if (request_info->status_code == 400) // bad request
97     {
98       log->log("Mongoose", Log::DEBUG, "400 BAD REQUEST:");
99       log->log("Mongoose", Log::DEBUG, request_info->request_method);
100       log->log("Mongoose", Log::DEBUG, request_info->uri);
101       log->log("Mongoose", Log::DEBUG, request_info->http_version);
102       log->log("Mongoose", Log::DEBUG, request_info->query_string);
103       log->log("Mongoose", Log::DEBUG, request_info->log_message);
104       for (int i = 0; i < request_info->num_headers; i++)
105       {
106         log->log("Mongoose", Log::DEBUG, "%s: %s", request_info->http_headers[i].name, request_info->http_headers[i].value);
107       }
108     }
109     else
110     {
111       log->log("Mongoose", Log::DEBUG, request_info->log_message);
112       log->log("Mongoose", Log::DEBUG, request_info->uri);
113     }
114     return (void*)1;
115   }
116   
117   // other events not handled:
118   // MG_HTTP_ERROR, MG_INIT_SSL
119   // Let mongoose do something with those
120
121   return NULL;
122
123 */
124   
125 }
126
127 bool jsonserver_reclist(Json::Value& js)
128 {
129   Log* log = Log::getInstance();
130   log->log("JSONServer", Log::DEBUG, "reclist");
131
132   int FreeMB;
133   int Percent = VideoDiskSpace(&FreeMB);
134   int Total = (FreeMB / (100 - Percent)) * 100;
135         
136   js["MBFree"] = FreeMB;
137   js["Percent"] = Percent;
138   js["Total"] = Total;
139   
140   Json::Value jsrecordings;
141   cRecordings Recordings;
142   Recordings.Load();
143   for (cRecording *recording = Recordings.First(); recording; recording = Recordings.Next(recording))
144   {
145     Json::Value oneRec;
146     oneRec["StartTime"] = (Json::UInt)recording->Start();
147     oneRec["Length"] = (Json::UInt)recording->LengthInSeconds();
148     oneRec["IsNew"] = recording->IsNew();
149     oneRec["Name"] = recording->Name();
150     oneRec["Filename"] = recording->FileName();
151     oneRec["FileSizeMB"] = recording->FileSizeMB();
152     jsrecordings.append(oneRec);
153   }
154   js["Recordings"] = jsrecordings;
155   
156   return true;
157 }
158
159 bool jsonserver_recinfo(Json::Value& js, const char* postData)
160 {
161   Log* log = Log::getInstance();
162   log->log("JSONServer", Log::DEBUG, "recinfo");
163
164   char reqfilename[1000];
165   int mgv1 = mg_get_var(postData, strlen(postData), "filename", reqfilename, 1000);
166   if (mgv1 == -1)
167   {
168     log->log("JSONServer", Log::ERR, "Could not decode filename");
169     js["Result"] = false;
170     js["Error"] = "Could not decode filename";
171     return true;
172   }
173
174   log->log("JSONServer", Log::DEBUG, "%s", reqfilename);
175   
176   cRecordings Recordings;
177   Recordings.Load(); // probably have to do this
178   cRecording *recording = Recordings.GetByName(reqfilename);
179
180   if (!recording)
181   {
182     log->log("JSONServer", Log::ERR, "recinfo found no recording");
183     js["Result"] = false;
184     return true;
185   }
186
187   js["IsNew"] = recording->IsNew();
188   js["LengthInSeconds"] = recording->LengthInSeconds();
189   js["FileSizeMB"] = recording->FileSizeMB();
190   js["Name"] = recording->Name() ? recording->Name() : Json::Value::null;
191   js["Priority"] = recording->Priority();
192   js["LifeTime"] = recording->Lifetime();
193   js["Start"] = (Json::UInt)recording->Start();
194
195   js["ResumePoint"] = 0;
196   cResumeFile ResumeFile(recording->FileName(), recording->IsPesRecording());
197   if (ResumeFile.Read() >= 0) js["ResumePoint"] = ResumeFile.Read();
198
199   js["CurrentlyRecordingStart"] = 0;
200   js["CurrentlyRecordingStop"] = 0;
201   cRecordControl *rc = cRecordControls::GetRecordControl(recording->FileName());
202   if (rc)
203   {
204     js["CurrentlyRecordingStart"] = (Json::UInt)rc->Timer()->StartTime();
205     js["CurrentlyRecordingStop"] = (Json::UInt)rc->Timer()->StopTime();
206   }
207
208   const cRecordingInfo *info = recording->Info();
209   if (info)
210   {
211     js["ChannelName"] = info->ChannelName() ? info->ChannelName() : Json::Value::null;
212     js["Title"] = info->Title() ? info->Title() : Json::Value::null;
213     js["ShortText"] = info->ShortText() ? info->ShortText() : Json::Value::null;
214     js["Description"] = info->Description() ? info->Description() : Json::Value::null;
215
216     const cComponents* components = info->Components();
217     if (!components)
218     {
219       js["Components"] = Json::Value::null;
220     }
221     else
222     {
223       Json::Value jscomponents;
224
225       tComponent* component;
226       for (int i = 0; i < components->NumComponents(); i++)
227       {
228         component = components->Component(i);
229
230         Json::Value oneComponent;
231         oneComponent["Stream"] = component->stream;
232         oneComponent["Type"] = component->type;
233         oneComponent["Language"] = component->language ? component->language : Json::Value::null;
234         oneComponent["Description"] = component->description ? component->description : Json::Value::null;
235         jscomponents.append(oneComponent);
236       }
237
238       js["Components"] = jscomponents;
239     }
240   }
241
242   js["Result"] = true;
243   return true;
244 }
245
246 bool jsonserver_recstop(Json::Value& js, const char* postData)
247 {
248   Log* log = Log::getInstance();
249   log->log("JSONServer", Log::DEBUG, "recstop");
250   
251   char reqfilename[1000];
252   int mgv1 = mg_get_var(postData, strlen(postData), "filename", reqfilename, 1000);
253   if (mgv1 == -1)
254   {
255     log->log("JSONServer", Log::ERR, "Could not decode filename");
256     js["Result"] = false;
257     js["Error"] = "Could not decode filename";
258     return true;
259   }
260   
261   log->log("JSONServer", Log::DEBUG, "%s", reqfilename);
262   
263   cRecordings Recordings;
264   Recordings.Load(); // probably have to do this
265   cRecording *recording = Recordings.GetByName(reqfilename);
266   
267   if (!recording)
268   {
269     log->log("JSONServer", Log::ERR, "recstop found no recording");
270     js["Result"] = false;
271     return true;
272   }
273
274   cRecordControl *rc = cRecordControls::GetRecordControl(recording->FileName());
275   if (!rc)
276   {
277     log->log("JSONServer", Log::ERR, "recstop - not currently recording");
278     js["Result"] = false;
279     return true;
280   }
281
282   if (Timers.BeingEdited())
283   {
284     log->log("JSONServer", Log::ERR, "recstop - timers being edited elsewhere");
285     js["Result"] = false;
286     return true;
287   }
288
289   cTimer* timer = rc->Timer();
290   if (!timer)
291   {
292     log->log("JSONServer", Log::ERR, "recstop - timer not found");
293     js["Result"] = false;
294     return true;
295   }
296   
297   timer->ClrFlags(tfActive);
298   Timers.SetModified();
299   
300   js["Result"] = true;
301   return true;
302 }  
303   
304 bool jsonserver_recdel(Json::Value& js, const char* postData)
305 {
306   Log* log = Log::getInstance();
307   log->log("JSONServer", Log::DEBUG, "recdel");
308
309   char reqfilename[1000];
310   int mgv1 = mg_get_var(postData, strlen(postData), "filename", reqfilename, 1000);
311   if (mgv1 == -1)
312   {
313     log->log("JSONServer", Log::ERR, "Could not decode filename");
314     js["Result"] = false;
315     js["Error"] = "Could not decode filename";
316     return true;
317   }
318
319   log->log("JSONServer", Log::DEBUG, "%s", reqfilename);
320   
321   cRecordings Recordings;
322   Recordings.Load(); // probably have to do this
323   cRecording *recording = Recordings.GetByName(reqfilename);
324
325   if (!recording)
326   {
327     js["Result"] = false;
328     js["Error"] = "Could not find recording to delete";
329     return true;
330   }
331
332   log->log("JSONServer", Log::DEBUG, "Deleting recording: %s", recording->Name());
333   cRecordControl *rc = cRecordControls::GetRecordControl(recording->FileName());
334   if (rc)
335   {
336     js["Result"] = false;
337     js["Error"] = "This recording is still recording.. ho ho";
338     return true;
339   }
340
341   if (recording->Delete())
342   {
343     ::Recordings.DelByName(recording->FileName());
344     js["Result"] = true;
345   }
346   else
347   {
348     js["Result"] = false;
349     js["Error"] = "Failed to delete recording";
350   }
351
352   return true;
353 }
354
355 bool jsonserver_recmove(Json::Value& js, const char* postData)
356 {
357   Log* log = Log::getInstance();
358   log->log("JSONServer", Log::DEBUG, "recmove");
359
360   char* fileNameToMove = NULL;
361   char* requestedNewPath = NULL;
362   char* dateDirName = NULL;
363   char* titleDirName = NULL;
364   char* folderName = NULL;
365   char* newContainer = NULL;
366   char* newDir = NULL;
367   
368   try
369   {
370     int postDataLen = strlen(postData)+1;
371     fileNameToMove = new char[postDataLen];
372     int mgv1 = mg_get_var(postData, postDataLen-1, "filename", fileNameToMove, postDataLen);
373     requestedNewPath = new char[postDataLen];
374     int mgv2 = mg_get_var(postData, postDataLen-1, "newpath", requestedNewPath, postDataLen);
375
376     if ((mgv1 == -1) || (mgv2 == -1) || !strlen(fileNameToMove) || !strlen(requestedNewPath))
377     {
378       log->log("JSONServer", Log::ERR, "request mgvs: %i %i", mgv1, mgv2);
379       throw 1;
380     }
381
382     cRecordings Recordings;
383     Recordings.Load(); // probably have to do this
384     cRecording* recordingObj = Recordings.GetByName(fileNameToMove);
385     if (!recordingObj) throw 2;
386     
387     cRecordControl *rc = cRecordControls::GetRecordControl(recordingObj->FileName());
388     if (rc) throw 3;
389
390     log->log("JSONServer", Log::DEBUG, "moving recording: %s", recordingObj->Name());
391     log->log("JSONServer", Log::DEBUG, "moving recording: %s", recordingObj->FileName());
392     log->log("JSONServer", Log::DEBUG, "to: %s", requestedNewPath);
393
394     const char* t = recordingObj->FileName();
395
396     int k, j, m;
397
398     // Find the datedirname
399     for(k = strlen(t) - 1; k >= 0; k--)
400     {
401       if (t[k] == '/')
402       {
403         log->log("JSONServer", Log::DEBUG, "l1: %i", strlen(&t[k+1]) + 1);
404         dateDirName = new char[strlen(&t[k+1]) + 1];
405         strcpy(dateDirName, &t[k+1]);
406         break;
407       }
408     }
409
410     // Find the titledirname
411
412     for(j = k-1; j >= 0; j--)
413     {
414       if (t[j] == '/')
415       {
416         log->log("JSONServer", Log::DEBUG, "l2: %i", k - j);
417         titleDirName = new char[k - j];
418         memcpy(titleDirName, &t[j+1], k - j - 1);
419         titleDirName[k - j - 1] = '\0';
420         break;
421       }
422     }
423
424     // Find the foldername
425
426     log->log("JSONServer", Log::DEBUG, "j = %u, strlenvd = %u", j, strlen(VideoDirectory));
427     if (j > strlen(VideoDirectory)) // Rec is in a subfolder now
428     {
429       for(m = j-1; m >= 0; m--)
430       {
431         if (t[m] == '/')
432         {
433           log->log("JSONServer", Log::DEBUG, "l3: %i", j - m);
434           folderName = new char[j - m];
435           memcpy(folderName, &t[m+1], j - m - 1);
436           folderName[j - m - 1] = '\0';
437           break;
438         }
439       }
440     }
441
442     ExchangeChars(requestedNewPath, true);
443
444     log->log("JSONServer", Log::DEBUG, "datedirname: %s", dateDirName);
445     log->log("JSONServer", Log::DEBUG, "titledirname: %s", titleDirName);
446     log->log("JSONServer", Log::DEBUG, "viddir: %s", VideoDirectory);
447     if (folderName) log->log("JSONServer", Log::DEBUG, "folderName: %s", folderName);
448     log->log("JSONServer", Log::DEBUG, "EC: %s", requestedNewPath);
449
450     // Could be a new path - construct that first and test
451     newContainer = new char[strlen(VideoDirectory) + strlen(requestedNewPath) + strlen(titleDirName) + 1];
452     sprintf(newContainer, "%s%s", VideoDirectory, requestedNewPath);
453     log->log("JSONServer", Log::DEBUG, "NPT: %s", newContainer);
454     struct stat dstat;
455     int statret = stat(newContainer, &dstat);
456     if ((statret == -1) && (errno == ENOENT)) // Dir does not exist
457     {
458       log->log("JSONServer", Log::DEBUG, "new path does not exist (1)");
459       int mkdirret = mkdir(newContainer, 0755);
460       if (mkdirret != 0) throw 4;
461     }
462     else if ((statret == 0) && (! (dstat.st_mode && S_IFDIR)))
463     {
464       // Something exists but it's not a dir
465       throw 5;
466     }
467
468     // New path now created or was there already
469
470     sprintf(newContainer, "%s%s%s", VideoDirectory, requestedNewPath, titleDirName);
471     log->log("JSONServer", Log::DEBUG, "%s", newContainer);
472
473     statret = stat(newContainer, &dstat);
474     if ((statret == -1) && (errno == ENOENT)) // Dir does not exist
475     {
476       log->log("JSONServer", Log::DEBUG, "new dir does not exist (2)");
477       int mkdirret = mkdir(newContainer, 0755);
478       if (mkdirret != 0) throw 6;
479     }
480     else if ((statret == 0) && (! (dstat.st_mode && S_IFDIR)))
481     {
482       // Something exists but it's not a dir
483       throw 7;
484     }
485
486     // Ok, the directory container has been made, or it pre-existed.
487
488     newDir = new char[strlen(newContainer) + 1 + strlen(dateDirName) + 1];
489     sprintf(newDir, "%s/%s", newContainer, dateDirName);
490
491     log->log("JSONServer", Log::DEBUG, "doing rename '%s' '%s'", t, newDir);
492     if (rename(t, newDir) != 0) throw 8;
493     
494     // Success. Test for remove old dir containter
495     char* tempOldTitleDir = new char[k+1];
496     memcpy(tempOldTitleDir, t, k);
497     tempOldTitleDir[k] = '\0';
498     log->log("JSONServer", Log::DEBUG, "len: %i, cp: %i, strlen: %i, oldtitledir: %s", k+1, k, strlen(tempOldTitleDir), tempOldTitleDir);
499     rmdir(tempOldTitleDir); // can't do anything about a fail result at this point.
500     delete[] tempOldTitleDir;
501
502     // Test for remove old foldername
503     if (folderName)
504     {
505       char* tempOldFolderName = new char[j+1];
506       memcpy(tempOldFolderName, t, j);
507       tempOldFolderName[j] = '\0';
508       log->log("JSONServer", Log::DEBUG, "len: %i, cp: %i, strlen: %i, oldfoldername: %s", j+1, j, strlen(tempOldFolderName), tempOldFolderName);
509       /*
510       DESCRIPTION
511       rmdir() deletes a directory, which must be empty.
512       ENOTEMPTY - pathname  contains  entries  other than . and ..
513       So, should be safe to call rmdir on non-empty dir
514       */
515       rmdir(tempOldFolderName); // can't do anything about a fail result at this point.
516       delete[] tempOldFolderName;
517     }
518
519     ::Recordings.Update();
520     js["Result"] = true;
521     js["NewRecordingFileName"] = newDir;
522   }
523   catch (int e)
524   {
525     js["Result"] = false;
526     if (e == 1)
527     {
528       log->log("JSONServer", Log::ERR, "Bad parameters");
529       js["Error"] = "Bad request parameters";
530     }
531     else if (e == 2)
532     {
533       log->log("JSONServer", Log::ERR, "Could not find recording to move");
534       js["Error"] = "Bad filename";
535     }
536     else if (e == 3)
537     {
538       log->log("JSONServer", Log::ERR, "Could not move recording, it is still recording");
539       js["Error"] = "Cannot move recording in progress";
540     }
541     else if (e == 4)
542     {
543       log->log("JSONServer", Log::ERR, "Failed to make new dir (1)");
544       js["Error"] = "Failed to create new directory (1)";
545     }
546     else if (e == 5)
547     {
548       log->log("JSONServer", Log::ERR, "Something already exists? (1)");
549       js["Error"] = "Something already exists at the new path (1)";
550     }
551     else if (e == 6)
552     {
553       log->log("JSONServer", Log::ERR, "Failed to make new dir (2)");
554       js["Error"] = "Failed to create new directory (2)";
555     }
556     else if (e == 7)
557     {
558       log->log("JSONServer", Log::ERR, "Something already exists?");
559       js["Error"] = "Something already exists at the new path";
560     }
561     else if (e == 8)
562     {
563       log->log("JSONServer", Log::ERR, "Rename failed");
564       js["Error"] = "Move failed";
565     }
566   }
567
568   if (fileNameToMove)   delete[] fileNameToMove;
569   if (requestedNewPath) delete[] requestedNewPath;
570   if (dateDirName)      delete[] dateDirName;
571   if (titleDirName)     delete[] titleDirName;
572   if (folderName)       delete[] folderName;
573   if (newContainer)     delete[] newContainer;
574   if (newDir)           delete[] newDir;
575
576   return true;
577 }
578
579 bool jsonserver_channellist(Json::Value& js)
580 {
581   Log* log = Log::getInstance();
582   log->log("JSONServer", Log::DEBUG, "channellist");
583
584   Json::Value jschannels;
585   
586   int type;
587   for (cChannel *channel = Channels.First(); channel; channel = Channels.Next(channel))
588   {
589     if (!channel->GroupSep())
590     {
591       log->log("JSONServer", Log::DEBUG, "name: '%s'", channel->Name());
592
593       if (channel->Vpid()) type = 1;
594       else if (channel->Apid(0)) type = 2;
595       else continue;
596
597       Json::Value oneChannel;
598       oneChannel["Number"] = channel->Number();
599       oneChannel["Type"] = type;
600       oneChannel["Name"] = channel->Name();
601 #if VDRVERSNUM < 10703
602       oneChannel["VType"] = 2;
603 #else
604       oneChannel["VType"] = channel->Vtype();
605 #endif
606       jschannels.append(oneChannel);    
607     }
608   }
609   js["Channels"] = jschannels;
610   
611   return true;
612 }
613
614 bool jsonserver_channelschedule(Json::Value& js, const char* postData)
615 {
616   Log* log = Log::getInstance();
617   log->log("JSONServer", Log::DEBUG, "channelschedule '%s'", postData);
618
619   char sChannelNumber[15];  int mgv1 = mg_get_var(postData, strlen(postData), "channelnumber", sChannelNumber, 15);  
620   char sStartTime[15];      int mgv2 = mg_get_var(postData, strlen(postData), "starttime", sStartTime, 15);  
621   char sDuration[15];       int mgv3 = mg_get_var(postData, strlen(postData), "duration", sDuration, 15);  
622
623   if ( (mgv1 == -1) || (mgv2 == -1) || (mgv3 == -1) )
624   {
625     log->log("JSONServer", Log::ERR, "request mgvs: %i %i %i", mgv1, mgv2, mgv3);
626     js["Result"] = false;
627     js["Error"] = "Bad request parameters";
628     return true;
629   }
630
631   int channelNumber = atoi(sChannelNumber);
632   int startTime = atoi(sStartTime); 
633   int duration = atoi(sDuration); 
634
635   cChannel* channel = NULL;
636   for (channel = Channels.First(); channel; channel = Channels.Next(channel))
637   {
638     if (channel->GroupSep()) continue;
639     if (channel->Number() == channelNumber) break;
640   }
641
642   if (!channel)
643   {
644     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
645     js["Result"] = false;
646     js["Error"] = "Could not find channel";
647     return true;
648   }
649
650   cSchedulesLock MutexLock;
651   const cSchedules *Schedules = cSchedules::Schedules(MutexLock);
652   if (!Schedules)
653   {
654     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
655     js["Result"] = false;
656     js["Error"] = "Internal schedules error (1)";
657     return true;
658   }
659   const cSchedule *Schedule = Schedules->GetSchedule(channel->GetChannelID());
660   if (!Schedule)     
661   {
662     log->log("JSONServer", Log::ERR, "Could not find requested channel: %i", channelNumber);
663     js["Result"] = false;
664     js["Error"] = "Internal schedules error (2)";
665     return true;
666   }
667     
668   Json::Value jsevents;
669
670   for (const cEvent* event = Schedule->Events()->First(); event; event = Schedule->Events()->Next(event))
671   {
672     //in the past filter
673     if ((event->StartTime() + event->Duration()) < time(NULL)) continue;
674    //start time filter
675     if ((event->StartTime() + event->Duration()) <= startTime) continue;
676     //duration filter
677     if (event->StartTime() >= (startTime + duration)) continue;
678
679     Json::Value oneEvent;
680     oneEvent["ID"] = event->EventID();
681     oneEvent["Time"] = (Json::UInt)event->StartTime();
682     oneEvent["Duration"] = event->Duration();
683     oneEvent["Title"] = event->Title() ? event->Title() : "";
684     oneEvent["Description"] = event->Description() ? event->Description() : "";
685     jsevents.append(oneEvent);
686   }
687
688   js["Events"] = jsevents;
689   return true;
690 }
691
692 bool jsonserver_timerlist(Json::Value& js)
693 {
694   Log* log = Log::getInstance();
695   log->log("JSONServer", Log::DEBUG, "timerlist");
696
697   Json::Value jstimers;
698   
699   cTimer *timer;
700   int numTimers = Timers.Count();
701
702   for (int i = 0; i < numTimers; i++)
703   {
704     timer = Timers.Get(i);
705     Json::Value oneTimer;
706     oneTimer["Active"] = timer->HasFlags(tfActive);
707     oneTimer["Recording"] = timer->Recording();
708     oneTimer["Pending"] = timer->Pending();
709     oneTimer["Priority"] = timer->Priority();
710     oneTimer["Lifetime"] = timer->Lifetime();
711     oneTimer["ChannelNumber"] = timer->Channel()->Number();
712     oneTimer["StartTime"] = (int)timer->StartTime();
713     oneTimer["StopTime"] = (int)timer->StopTime();
714     oneTimer["Day"] = (int)timer->Day();
715     oneTimer["WeekDays"] = timer->WeekDays();
716     oneTimer["Name"] = timer->File();
717     jstimers.append(oneTimer);
718   }
719   
720   js["Timers"] = jstimers;
721   return true;
722 }
723
724 bool jsonserver_timerdel(Json::Value& js, const char* postData)
725 {
726   Log* log = Log::getInstance();
727   log->log("JSONServer", Log::DEBUG, "timerdel");
728
729   char sdelChannel[15];   int mgv1 = mg_get_var(postData, strlen(postData), "delchannel", sdelChannel, 15);  
730   char sdelWeekdays[15];  int mgv2 = mg_get_var(postData, strlen(postData), "delweekdays", sdelWeekdays, 15);  
731   char sdelDay[15];       int mgv3 = mg_get_var(postData, strlen(postData), "delday", sdelDay, 15);  
732   char sdelStart[15];     int mgv4 = mg_get_var(postData, strlen(postData), "delstart", sdelStart, 15);  
733   char sdelStop[15];      int mgv5 = mg_get_var(postData, strlen(postData), "delstop", sdelStop, 15);  
734
735   if ( (mgv1 == -1) || (mgv2 == -1) || (mgv3 == -1) || (mgv4 == -1) || (mgv5 == -1) )
736   {
737     log->log("JSONServer", Log::ERR, "request mgvs: %i %i %i %i %i", mgv1, mgv2, mgv3, mgv4, mgv5);
738     js["Result"] = false;
739     js["Error"] = "Bad request parameters";
740     return true;
741   }
742
743   int delChannel = atoi(sdelChannel); 
744   int delWeekdays = atoi(sdelWeekdays); 
745   int delDay = atoi(sdelDay); 
746   int delStart = atoi(sdelStart); 
747   int delStop = atoi(sdelStop); 
748
749   cTimer* ti = NULL;
750   for (ti = Timers.First(); ti; ti = Timers.Next(ti))
751   {
752     if  ( (ti->Channel()->Number() == delChannel)
753      &&   ((ti->WeekDays() && (ti->WeekDays() == delWeekdays)) || (!ti->WeekDays() && (ti->Day() == delDay)))
754      &&   (ti->StartTime() == delStart)
755      &&   (ti->StopTime() == delStop) )
756        break;
757   }
758   
759   if (!ti)
760   {
761     log->log("JSONServer", Log::ERR, "Could not find timer");
762     js["Result"] = false;
763     js["Error"] = "Could not find timer";
764     return true;
765   }
766
767   if (Timers.BeingEdited())
768   {
769     log->log("JSONServer", Log::ERR, "Unable to delete timer - timers being edited at VDR");
770     js["Result"] = false;
771     js["Error"] = "Timers being edited at VDR";
772     return true; 
773   }
774   
775   if (ti->Recording())
776   {
777     log->log("JSONServer", Log::ERR, "Unable to delete timer - timer is running");
778     js["Result"] = false;
779     js["Error"] = "Timer is running";
780     return true;
781   }
782   
783   Timers.Del(ti);
784   Timers.SetModified();
785   js["Result"] = true;
786     
787   return true;
788 }
789
790 bool jsonserver_timerset(Json::Value& js, const char* postData)
791 {
792   Log* log = Log::getInstance();
793   log->log("JSONServer", Log::DEBUG, "timerset");
794
795   char sTimerString[1024];   int mgv1 = mg_get_var(postData, strlen(postData), "timerstring", sTimerString, 1024);  
796
797   if (mgv1 == -1)
798   {
799     log->log("JSONServer", Log::ERR, "Could not get timerstring");
800     js["Result"] = false;
801     js["Error"] = "Bad request parameters";
802     return true;
803   }
804
805   log->log("JSONServer", Log::DEBUG, "'%s'", sTimerString);
806   cTimer *timer = new cTimer;
807   if (!timer->Parse(sTimerString))
808   {
809     delete timer;
810     js["Result"] = false;
811     js["Error"] = "Failed to parse timer request details";
812     return true;
813   }
814
815   cTimer *t = Timers.GetTimer(timer);
816   if (t)
817   {
818     delete timer;
819     js["Result"] = false;
820     js["Error"] = "Timer already exists";
821     return true;
822   }
823
824   Timers.Add(timer);
825   Timers.SetModified();
826   js["Result"] = true;
827   return true;
828 }
829