Jun Furutani
/
libMiMic
Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Fork of
libMiMic
by 
Ryo Iizuka
mbed/ModLocalFileSystem.cpp
- Committer:
- nyatla
- Date:
- 2013-04-27
- Revision:
- 19:33b9ba0859ee
- Parent:
- 18:1970fec78229
- Child:
- 20:3b0b444b4deb
File content as of revision 19:33b9ba0859ee:
#include "ModLocalFileSystem.h"
#include "HttpdConnection.h"
#include "UrlReader.h"
#include "Http.h"
#include "Httpd.h"
#include "NyLPC_net.h"
#include <stdio.h>
#include <stdlib.h>
#include <typeinfo>
#include "mbed.h"
#include "FATDirHandle.h"
using namespace MiMic;
static void retDirJson(UrlReader& url,char* buf,HttpdConnection& i_connection)
{
//assert(HEAD or GET)
//directory-list json
if(!NyLPC_cHttpdUtils_sendJsonHeader((i_connection._ref_inst))){
return;
}
if(!i_connection.isMethodType(Http::MT_GET)){
return;
}
const char* t;
int l;
url.getPath(t,l);
buf[l]='\0';//split path
//remove '/'
if(buf[l-1]=='/'){
buf[l-1]='\0';
}
DIR* d=opendir(buf);
if ( d == NULL )
{
i_connection.sendBodyF("{\"dir\":\"%s\",\"status\":404,\"list\":[]}",buf);
return;
}
if(!i_connection.isMethodType(Http::MT_GET)){
//nothing to do
}else{
bool is_fatfs=(typeid(*d) == typeid(FATDirHandle));
struct dirent *p;
p = readdir(d);
i_connection.sendBodyF("{\"dir\":\"%s\",\"status\":200,\"list\":[",buf);
for(;;)
{
if(is_fatfs){
bool isdir=(((struct direntFAT*)(p))->fattrib & AM_DIR)!=0;
i_connection.sendBodyF("{\"name\":\"%s\",\"mtype\":\"%s\",\"size\":%u}",
p->d_name,isdir?"directory":NyLPC_cMiMeType_getFileName2MimeType(p->d_name),
isdir?0:((struct direntFAT*)(p))->fsize);
}else{
i_connection.sendBodyF("{\"name\":\"%s\",\"mtype\":\"%s\",\"size\":undefined}",
p->d_name,NyLPC_cMiMeType_getFileName2MimeType(p->d_name));
}
p = readdir(d);
if(p==NULL){
break;
}
i_connection.sendBodyF(",");
}
i_connection.sendBodyF("]}");
}
closedir(d);
}
static void retDirHtml(UrlReader& url,char* buf,HttpdConnection& i_connection)
{
//assert(HEAD or GET)
buf[strlen(buf)-1]='\0';//convert to dir path
DIR* d=opendir(buf);
if(d==NULL){
i_connection.sendHeader(403,"text/html",NULL);
if(!i_connection.isMethodType(Http::MT_GET)){
return;
}
i_connection.sendBodyF("<!DOCTYPE html><html><body><h1>403 Forbidden</h1><hr/>'%s'</body></html>",buf);
return;
}
if(!i_connection.sendHeader(200,"text/html",NULL)){
//nothing to do
}else{
if(!i_connection.isMethodType(Http::MT_GET)){
//nothing to do.
}else{
bool is_fatfs=(typeid(*d) == typeid(FATDirHandle));
struct dirent *p;
p = readdir(d);
i_connection.sendBodyF(
"<!DOCTYPE html><html><body><h1>Index of %s</h1><hr/>\n"
"<ul>\n"
,buf);
for(;;)
{
if(is_fatfs){
if((((struct direntFAT*)(p))->fattrib & AM_DIR)!=0){
//dir
i_connection.sendBodyF("<li><a href=\"./%s/\">[DIR]%s</a></li>\n",p->d_name,p->d_name);
}else{
//file
i_connection.sendBodyF("<li><a href=\"./%s\">%s</a></li>\n",p->d_name,p->d_name);
}
}else{
i_connection.sendBodyF("<li><a href=\"./%s\">%s</a></li>\n",
p->d_name,p->d_name);
}
p = readdir(d);
if(p==NULL){
break;
}
}
i_connection.sendBodyF("</ul></body></html>",buf);
}
}
closedir(d);
}
static void retFile(UrlReader& url,char* buf,HttpdConnection& i_connection)
{
//file contents
{//split URL path and query
const char* t;
int l;
url.getPath(t,l);
buf[l]='\0';
}
//return content
FILE *fp;
size_t sz;
//size
fp = fopen(buf, "r");
if(fp==NULL){
i_connection.sendHeader(404,"text/html",NULL);
if(!i_connection.isMethodType(Http::MT_GET)){
return;
}
i_connection.sendBodyF("<!DOCTYPE html><html><body>'%s' not found.</body></html>",buf);
return;
}
fseek(fp, 0, SEEK_END); // seek to end of file
sz = ftell(fp); // get current file pointer
fseek(fp, 0, SEEK_SET); // seek back to beginning of file
if(i_connection.sendHeader(200,NyLPC_cMiMeType_getFileName2MimeType(buf),NULL,sz)){
if(!i_connection.isMethodType(Http::MT_GET)){
//nothing to do
}else{
{DigitalOut led(LED1);led=0;}
{DigitalOut led(LED2);led=0;}
{DigitalOut led(LED3);led=0;}
{DigitalOut led(LED4);led=1;}
for(;;){
sz=fread(buf,1,Httpd::SIZE_OF_HTTP_BUF,fp);
if(sz<1){
break;
}
if(!i_connection.sendBody(buf,sz)){
{DigitalOut led(LED1);led=1;}
break;
}
//switch transport thread
/*
i_connection.releaseHttpd();
NyLPC_cThread_yield();
i_connection.lockHttpd();
*/
}
}
}
{DigitalOut led(LED2);led=1;}
fclose(fp);
}
namespace MiMic
{
ModLocalFileSystem::ModLocalFileSystem(const char* i_path):ModBaseClass(i_path)
{
}
ModLocalFileSystem::ModLocalFileSystem():ModBaseClass()
{
}
ModLocalFileSystem::~ModLocalFileSystem()
{
}
void ModLocalFileSystem::setParam(const char* i_path)
{
ModBaseClass::setParam(i_path);
}
bool ModLocalFileSystem::execute(HttpdConnection& i_connection)
{
//check platform
//<write here! />
//check prefix
if(!this->canHandle(i_connection)){
return false;
}
//check Method type
{
int mt=i_connection.getMethodType();
if(mt!=Http::MT_GET && mt!=Http::MT_HEAD){
//method not allowed.
i_connection.sendHeader(405,"text/html",NULL);
return true;
}
}
//Httpd lock
i_connection.lockHttpd();
char* buf=Httpd::_shared_buf;
//set file path
{
//call ModUrl
NyLPC_TcModUrl_t mod;
NyLPC_cModUrl_initialize(&mod);
if(!NyLPC_cModUrl_execute2(&mod,i_connection._ref_inst,buf,Httpd::SIZE_OF_HTTP_BUF,0,NyLPC_cModUrl_ParseMode_ALL)){
NyLPC_cModUrl_finalize(&mod);
i_connection.unlockHttpd();
return true;
}
NyLPC_cModUrl_finalize(&mod);
}
UrlReader url(buf);
if(url.hasQueryKey("list")){
// if path has '/?list' query key,return directory information
retDirJson(url,buf,i_connection);
}else if(strchr(buf,'?')==NULL && strchr(buf,'#')==NULL && buf[strlen(buf)-1]=='/'){
//return directory html when URL has not bookmark and URL query and terminated by '/'.
retDirHtml(url,buf,i_connection);
}else{
retFile(url,buf,i_connection);
}
//Httpd unlock
i_connection.unlockHttpd();
return true;
}
}