diff options
Diffstat (limited to 'responsefile.c')
| -rw-r--r-- | responsefile.c | 174 |
1 files changed, 174 insertions, 0 deletions
diff --git a/responsefile.c b/responsefile.c new file mode 100644 index 0000000..9724957 --- /dev/null +++ b/responsefile.c @@ -0,0 +1,174 @@ +/* + * responsefile.c: VDR on Smart TV plugin + * + * Copyright (C) 2012, 2013 T. Lohmar + * + * 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 2 + * 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, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + * Or, point your browser to http://www.gnu.org/licenses/old-licenses/gpl-2.0.html + * + */ + + +#include "responsefile.h" +#include "httpresource.h" + +#include <vector> +#include <sys/stat.h> + +//#define MAXLEN 4096 +#define DEBUGPREFIX "mReqId= " << mRequest->mReqId << " fd= " << mRequest->mFd +#define OKAY 0 +#define ERROR (-1) +#define DEBUG + + +cResponseFile::cResponseFile(cHttpResource* req) : cResponseBase(req), mFile(NULL), mFileSize(0) { +} + +cResponseFile::~cResponseFile() { + if (mFile != NULL) { + *(mLog->log())<< DEBUGPREFIX + << " ERROR: mFile still open. Closing now..." << endl; + fclose(mFile); + mFile = NULL; + } +} + + +const char *cResponseFile::getMimeType(const char *name) { + char *ext = strrchr((char*)name, '.'); + if (!ext) + return NULL; + // if (ext.compare(".html") || ext.compare(".htm")) return "text/html"; + if (strcmp(ext, ".html") == 0 || strcmp(ext, ".htm") == 0) return "text/html"; + if (strcmp(ext, ".jpg") == 0 || strcmp(ext, ".jpeg") == 0) return "image/jpeg"; + if (strcmp(ext, ".gif") == 0) return "image/gif"; + if (strcmp(ext, ".png") == 0) return "image/png"; + if (strcmp(ext, ".xml") == 0) return "application/xml"; + if (strcmp(ext, ".css") == 0) return "text/css"; + if (strcmp(ext, ".js") == 0) return "text/javascript"; + if (strcmp(ext, ".au") == 0) return "audio/basic"; + if (strcmp(ext, ".wav") == 0) return "audio/wav"; + if (strcmp(ext, ".avi") == 0) return "video/x-msvideo"; + if (strcmp(ext, ".mp4") == 0) return "video/mp4"; + if (strcmp(ext, ".vdr") == 0) return "video/mpeg"; + if (strcmp(ext, ".ts") == 0) return "video/mpeg"; + if (strcmp(ext, ".mpeg") == 0 || strcmp(ext, ".mpg") == 0) return "video/mpeg"; + if (strcmp(ext, ".mp3") == 0) return "audio/mpeg"; + if (strcmp(ext, ".mpd") == 0) return "application/dash+xml"; + if (strcmp(ext, ".m3u8") == 0) return "application/x-mpegURL"; + + return NULL; +} + + +int cResponseFile::sendFile() { + // Send the First Datachunk, incl all headers + + if (isHeadRequest()) + return OKAY; + + struct stat64 statbuf; + + if (stat64((mRequest->mPath).c_str(), &statbuf) < 0) { + sendError(404, "Not Found", NULL, "File not found."); + return OKAY; + } + *(mLog->log())<< DEBUGPREFIX + << " SendFile mPath= " << mRequest->mPath + << endl; + + char f[400]; + + if (openFile((mRequest->mPath).c_str()) == ERROR) { + sendError(403, "Forbidden", NULL, "Access denied."); + return OKAY; + } + + mFile = fopen((mRequest->mPath).c_str(), "r"); + + if (!mFile) { + sendError(403, "Forbidden", NULL, "Access denied."); + return OKAY; + } + + mFileSize = S_ISREG(statbuf.st_mode) ? statbuf.st_size : -1; + + *(mLog->log())<< "fd= " << mRequest->mFd << " mReqId= "<< mRequest->mReqId + << " mFileSize= " <<mFileSize << endl; + + if (!(mRequest->rangeHdr).isRangeRequest) { + mRemLength = mFileSize; + sendHeaders(200, "OK", NULL, getMimeType((mRequest->mPath).c_str()), mFileSize, statbuf.st_mtime); + } + else { // Range request + fseeko64(mFile, (mRequest->rangeHdr).begin, SEEK_SET); + if ((mRequest->rangeHdr).end == 0) + (mRequest->rangeHdr).end = mFileSize; + mRemLength = ((mRequest->rangeHdr).end-(mRequest->rangeHdr).begin); + *(mLog->log())<< "fd= " << mRequest->mFd << " mReqId= "<< mRequest->mReqId + << " rangeHdr.begin= " <<(mRequest->rangeHdr).begin << " rangeHdr.end= " << (mRequest->rangeHdr).end + << " Content-Length= " << mRemLength << endl; + + snprintf(f, sizeof(f), "Content-Range: bytes %lld-%lld/%lld", (mRequest->rangeHdr).begin, ((mRequest->rangeHdr).end -1), mFileSize); + sendHeaders(206, "Partial Content", f, getMimeType((mRequest->mPath).c_str()), ((mRequest->rangeHdr).end-(mRequest->rangeHdr).begin), statbuf.st_mtime); + } + +#ifndef DEBUG + *(mLog->log())<< "fd= " << mRequest->mFd << " mReqId= "<< mRequest->mReqId + << ": Done mRemLength= "<< mRemLength + << endl; +#endif + mRequest->mConnState = SERVING; + + return OKAY; + +} + + +int cResponseFile::openFile(const char *name) { + mFile = fopen(name, "r"); + if (!mFile) { + *(mLog->log())<< DEBUGPREFIX + << " fopen failed pathbuf= " << name + << endl; + // sendError(403, "Forbidden", NULL, "Access denied."); + return ERROR; + } + return OKAY; +} + + +int cResponseFile::fillDataBlk() { + // char pathbuf[4096]; + mBlkPos = 0; + int to_read = 0; + + if (mError) + return ERROR; + + to_read = ((mRemLength > MAXLEN) ? MAXLEN : mRemLength); + mBlkLen = fread(mBlkData, 1, to_read, mFile); + mRemLength -= mBlkLen; + if (mBlkLen == 0) { + + // read until EOF + fclose(mFile); + mFile = NULL; + return ERROR; + } + return OKAY; +} + |