Diff: mbed/ModLocalFileSystem.cpp

Revision:

17:f29e1ca90e3d

Child:

18:1970fec78229

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mbed/ModLocalFileSystem.cpp	Fri Apr 26 05:26:34 2013 +0000
@@ -0,0 +1,142 @@
+#include "ModLocalFileSystem.h"
+#include "HttpdConnection.h"
+#include "NyLPC_net.h"
+#include "UrlReader.h"
+#include <stdio.h>
+#include <stdlib.h>
+#include <typeinfo>
+#include "mbed.h"
+#include "FATDirHandle.h"
+#define ModLocalFile_SIZE_OF_BUF 256
+static char buf[ModLocalFile_SIZE_OF_BUF];
+
+
+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;
+        }
+        //Httpd lock
+        i_connection.lockHttpd();            
+
+        //set file path
+        {
+            //call ModUrl
+            NyLPC_TcModUrl_t mod;
+            NyLPC_cModUrl_initialize(&mod);
+            if(!NyLPC_cModUrl_execute2(&mod,i_connection._ref_inst,buf,ModLocalFile_SIZE_OF_BUF,0)){
+                NyLPC_cModUrl_finalize(&mod);
+                i_connection.releaseHttpd();
+                return true;
+            }
+            NyLPC_cModUrl_finalize(&mod);
+        }
+        // if path has '/?list' query key,return directory information
+        //otherwise FILE.
+        UrlReader url(buf);
+        if(url.hasQueryKey("list")){
+            //directory-list
+            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(NyLPC_cHttpdUtils_sendJsonHeader((i_connection._ref_inst))){
+                if ( d != NULL )
+                {
+                    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(",");                        
+                    }
+                    closedir(d);
+                    i_connection.sendBodyF("]}");
+                }else{
+                    i_connection.sendBodyF("{\"dir\":\"%s\",\"status\":404,\"list\":[]}",buf);
+                }
+            }
+        }else{
+            {//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){
+                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)){
+                    for(;;){
+                        sz=fread(buf,1,ModLocalFile_SIZE_OF_BUF,fp);
+                        if(sz<1){
+                            break;
+                        }
+                        if(!i_connection.sendBody(buf,sz)){
+                            break;
+                        }
+//                        //switch transport thread
+/*                        i_connection.releaseHttpd();
+                        NyLPC_cThread_yield();
+                        i_connection.lockHttpd();                        
+*/                    }
+                }
+                fclose(fp);
+            }else{
+                i_connection.sendHeader(404,"text/html",NULL);
+                i_connection.sendBodyF("<html><body>'%s' not found.</body></html>",buf);
+            }            
+        }
+        //Httpd unlock
+        i_connection.releaseHttpd();
+        return true;
+        
+    }
+}