Dirk-Willem van Gulik (NXP/mbed) / Mbed 2 deprecated AmpereMeter

Example self-announcing webserver which controls a servo through a smallHTML userinterface.

Dependencies:   mbed

services/http/client/HTTPClient.h@0:a259777c45a3, 2010-08-14 (annotated)

Committer:
dirkx
Date:
Sat Aug 14 15:56:01 2010 +0000
Revision:
0:a259777c45a3

        

        
Who changed what in which revision?

        

            
                
UserRevisionLine numberNew contents of line

            
            


dirkx

0:a259777c45a3


     1







dirkx

0:a259777c45a3


     2

/*





dirkx

0:a259777c45a3


     3

Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)





dirkx

0:a259777c45a3


     4

 





dirkx

0:a259777c45a3


     5

Permission is hereby granted, free of charge, to any person obtaining a copy





dirkx

0:a259777c45a3


     6

of this software and associated documentation files (the "Software"), to deal





dirkx

0:a259777c45a3


     7

in the Software without restriction, including without limitation the rights





dirkx

0:a259777c45a3


     8

to use, copy, modify, merge, publish, distribute, sublicense, and/or sell





dirkx

0:a259777c45a3


     9

copies of the Software, and to permit persons to whom the Software is





dirkx

0:a259777c45a3


    10

furnished to do so, subject to the following conditions:





dirkx

0:a259777c45a3


    11

 





dirkx

0:a259777c45a3


    12

The above copyright notice and this permission notice shall be included in





dirkx

0:a259777c45a3


    13

all copies or substantial portions of the Software.





dirkx

0:a259777c45a3


    14

 





dirkx

0:a259777c45a3


    15

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR





dirkx

0:a259777c45a3


    16

IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,





dirkx

0:a259777c45a3


    17

FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE





dirkx

0:a259777c45a3


    18

AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER





dirkx

0:a259777c45a3


    19

LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,





dirkx

0:a259777c45a3


    20

OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN





dirkx

0:a259777c45a3


    21

THE SOFTWARE.





dirkx

0:a259777c45a3


    22

*/





dirkx

0:a259777c45a3


    23







dirkx

0:a259777c45a3


    24

#ifndef HTTP_CLIENT_H





dirkx

0:a259777c45a3


    25

#define HTTP_CLIENT_H





dirkx

0:a259777c45a3


    26







dirkx

0:a259777c45a3


    27

class HTTPData;





dirkx

0:a259777c45a3


    28







dirkx

0:a259777c45a3


    29

#include "if/net/net.h"





dirkx

0:a259777c45a3


    30

#include "api/TCPSocket.h"





dirkx

0:a259777c45a3


    31

#include "api/DNSRequest.h"





dirkx

0:a259777c45a3


    32

#include "HTTPData.h"





dirkx

0:a259777c45a3


    33

#include "mbed.h"





dirkx

0:a259777c45a3


    34







dirkx

0:a259777c45a3


    35

#include <string>





dirkx

0:a259777c45a3


    36

using std::string;





dirkx

0:a259777c45a3


    37







dirkx

0:a259777c45a3


    38

#include <map>





dirkx

0:a259777c45a3


    39

using std::map;





dirkx

0:a259777c45a3


    40







dirkx

0:a259777c45a3


    41

enum HTTPResult





dirkx

0:a259777c45a3


    42

{





dirkx

0:a259777c45a3


    43

  HTTP_OK,





dirkx

0:a259777c45a3


    44

  HTTP_PROCESSING,





dirkx

0:a259777c45a3


    45

  HTTP_PARSE, //URI Parse error





dirkx

0:a259777c45a3


    46

  HTTP_DNS, //Could not resolve name





dirkx

0:a259777c45a3


    47

  HTTP_PRTCL, //Protocol error





dirkx

0:a259777c45a3


    48

  HTTP_NOTFOUND, //404 Error





dirkx

0:a259777c45a3


    49

  HTTP_REFUSED, //403 Error





dirkx

0:a259777c45a3


    50

  HTTP_ERROR, //xxx error





dirkx

0:a259777c45a3


    51

  HTTP_TIMEOUT, //Connection timeout





dirkx

0:a259777c45a3


    52

  HTTP_CONN //Connection error





dirkx

0:a259777c45a3


    53

};





dirkx

0:a259777c45a3


    54







dirkx

0:a259777c45a3


    55







dirkx

0:a259777c45a3


    56







dirkx

0:a259777c45a3


    57

class HTTPClient : protected NetService





dirkx

0:a259777c45a3


    58

{





dirkx

0:a259777c45a3


    59

public:





dirkx

0:a259777c45a3


    60

  HTTPClient();





dirkx

0:a259777c45a3


    61

  virtual ~HTTPClient();





dirkx

0:a259777c45a3


    62

  





dirkx

0:a259777c45a3


    63

  void basicAuth(const char* user, const char* password); //Basic Authentification





dirkx

0:a259777c45a3


    64

  





dirkx

0:a259777c45a3


    65

  //High Level setup functions





dirkx

0:a259777c45a3


    66

  HTTPResult get(const char* uri, HTTPData* pDataIn); //Blocking





dirkx

0:a259777c45a3


    67

  HTTPResult get(const char* uri, HTTPData* pDataIn, void (*pMethod)(HTTPResult)); //Non blocking





dirkx

0:a259777c45a3


    68

  template<class T> 





dirkx

0:a259777c45a3


    69

  HTTPResult get(const char* uri, HTTPData* pDataIn, T* pItem, void (T::*pMethod)(HTTPResult)) //Non blocking





dirkx

0:a259777c45a3


    70

  {





dirkx

0:a259777c45a3


    71

    setOnResult(pItem, pMethod);





dirkx

0:a259777c45a3


    72

    doGet(uri, pDataIn);





dirkx

0:a259777c45a3


    73

    return HTTP_PROCESSING;





dirkx

0:a259777c45a3


    74

  }





dirkx

0:a259777c45a3


    75

  





dirkx

0:a259777c45a3


    76

  HTTPResult post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn); //Blocking





dirkx

0:a259777c45a3


    77

  HTTPResult post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn, void (*pMethod)(HTTPResult)); //Non blocking





dirkx

0:a259777c45a3


    78

  template<class T> 





dirkx

0:a259777c45a3


    79

  HTTPResult post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn, T* pItem, void (T::*pMethod)(HTTPResult)) //Non blocking  





dirkx

0:a259777c45a3


    80

  {





dirkx

0:a259777c45a3


    81

    setOnResult(pItem, pMethod);





dirkx

0:a259777c45a3


    82

    doPost(uri, dataOut, pDataIn);





dirkx

0:a259777c45a3


    83

    return HTTP_PROCESSING;





dirkx

0:a259777c45a3


    84

  }





dirkx

0:a259777c45a3


    85

  





dirkx

0:a259777c45a3


    86

  void doGet(const char* uri, HTTPData* pDataIn);  





dirkx

0:a259777c45a3


    87

  void doPost(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn); 





dirkx

0:a259777c45a3


    88

  





dirkx

0:a259777c45a3


    89

  void setOnResult( void (*pMethod)(HTTPResult) );





dirkx

0:a259777c45a3


    90

  class CDummy;





dirkx

0:a259777c45a3


    91

  template<class T> 





dirkx

0:a259777c45a3


    92

  //Linker bug : Must be defined here :(





dirkx

0:a259777c45a3


    93

  void setOnResult( T* pItem, void (T::*pMethod)(HTTPResult) )





dirkx

0:a259777c45a3


    94

  {





dirkx

0:a259777c45a3


    95

    m_pCb = NULL;





dirkx

0:a259777c45a3


    96

    m_pCbItem = (CDummy*) pItem;





dirkx

0:a259777c45a3


    97

    m_pCbMeth = (void (CDummy::*)(HTTPResult)) pMethod;





dirkx

0:a259777c45a3


    98

  }





dirkx

0:a259777c45a3


    99

  





dirkx

0:a259777c45a3


   100

  void setTimeout(int ms);





dirkx

0:a259777c45a3


   101

  





dirkx

0:a259777c45a3


   102

  virtual void poll(); //Called by NetServices





dirkx

0:a259777c45a3


   103

  





dirkx

0:a259777c45a3


   104

  int getHTTPResponseCode();





dirkx

0:a259777c45a3


   105

  void setRequestHeader(const string& header, const string& value);





dirkx

0:a259777c45a3


   106

  string& getResponseHeader(const string& header);





dirkx

0:a259777c45a3


   107

  void resetRequestHeaders();





dirkx

0:a259777c45a3


   108

  





dirkx

0:a259777c45a3


   109

protected:





dirkx

0:a259777c45a3


   110

  void resetTimeout();





dirkx

0:a259777c45a3


   111

  





dirkx

0:a259777c45a3


   112

  void init();





dirkx

0:a259777c45a3


   113

  void close();





dirkx

0:a259777c45a3


   114

  





dirkx

0:a259777c45a3


   115

  void setup(const char* uri, HTTPData* pDataOut, HTTPData* pDataIn); //Setup request, make DNS Req if necessary





dirkx

0:a259777c45a3


   116

  void connect(); //Start Connection





dirkx

0:a259777c45a3


   117

  





dirkx

0:a259777c45a3


   118

  int  tryRead(); //Read data and try to feed output





dirkx

0:a259777c45a3


   119

  void readData(); //Data has been read





dirkx

0:a259777c45a3


   120

  void writeData(); //Data has been written & buf is free





dirkx

0:a259777c45a3


   121

  





dirkx

0:a259777c45a3


   122

  void onTCPSocketEvent(TCPSocketEvent e);





dirkx

0:a259777c45a3


   123

  void onDNSReply(DNSReply r);





dirkx

0:a259777c45a3


   124

  void onResult(HTTPResult r); //Called when exchange completed or on failure





dirkx

0:a259777c45a3


   125

  void onTimeout(); //Connection has timed out





dirkx

0:a259777c45a3


   126

  





dirkx

0:a259777c45a3


   127

private:





dirkx

0:a259777c45a3


   128

  HTTPResult blockingProcess(); //Called in blocking mode, calls Net::poll() until return code is available





dirkx

0:a259777c45a3


   129







dirkx

0:a259777c45a3


   130

  bool readHeaders(); //Called first when receiving data





dirkx

0:a259777c45a3


   131

  bool writeHeaders(); //Called to create req





dirkx

0:a259777c45a3


   132

  int readLine(char* str, int maxLen, bool* pIncomplete = NULL);





dirkx

0:a259777c45a3


   133

  





dirkx

0:a259777c45a3


   134

  enum HTTP_METH





dirkx

0:a259777c45a3


   135

  {





dirkx

0:a259777c45a3


   136

    HTTP_GET,





dirkx

0:a259777c45a3


   137

    HTTP_POST,





dirkx

0:a259777c45a3


   138

    HTTP_HEAD





dirkx

0:a259777c45a3


   139

  };





dirkx

0:a259777c45a3


   140

  





dirkx

0:a259777c45a3


   141

  HTTP_METH m_meth;





dirkx

0:a259777c45a3


   142

  





dirkx

0:a259777c45a3


   143

  CDummy* m_pCbItem;





dirkx

0:a259777c45a3


   144

  void (CDummy::*m_pCbMeth)(HTTPResult);





dirkx

0:a259777c45a3


   145

  





dirkx

0:a259777c45a3


   146

  void (*m_pCb)(HTTPResult);





dirkx

0:a259777c45a3


   147

  





dirkx

0:a259777c45a3


   148

  TCPSocket* m_pTCPSocket;





dirkx

0:a259777c45a3


   149

  map<string, string> m_reqHeaders;





dirkx

0:a259777c45a3


   150

  map<string, string> m_respHeaders;





dirkx

0:a259777c45a3


   151

  





dirkx

0:a259777c45a3


   152

  Timer m_watchdog;





dirkx

0:a259777c45a3


   153

  int m_timeout;





dirkx

0:a259777c45a3


   154

  





dirkx

0:a259777c45a3


   155

  DNSRequest* m_pDnsReq;





dirkx

0:a259777c45a3


   156

  





dirkx

0:a259777c45a3


   157

  Host m_server;





dirkx

0:a259777c45a3


   158

  string m_path;





dirkx

0:a259777c45a3


   159

  





dirkx

0:a259777c45a3


   160

  bool m_closed;





dirkx

0:a259777c45a3


   161

  





dirkx

0:a259777c45a3


   162

  enum HTTPStep





dirkx

0:a259777c45a3


   163

  {





dirkx

0:a259777c45a3


   164

   // HTTP_INIT,





dirkx

0:a259777c45a3


   165

    HTTP_WRITE_HEADERS,





dirkx

0:a259777c45a3


   166

    HTTP_WRITE_DATA,





dirkx

0:a259777c45a3


   167

    HTTP_READ_HEADERS,





dirkx

0:a259777c45a3


   168

    HTTP_READ_DATA,





dirkx

0:a259777c45a3


   169

    HTTP_READ_DATA_INCOMPLETE,





dirkx

0:a259777c45a3


   170

    HTTP_DONE,





dirkx

0:a259777c45a3


   171

    HTTP_CLOSED





dirkx

0:a259777c45a3


   172

  };





dirkx

0:a259777c45a3


   173

  





dirkx

0:a259777c45a3


   174

  HTTPStep m_state;





dirkx

0:a259777c45a3


   175

  





dirkx

0:a259777c45a3


   176

  HTTPData* m_pDataOut;





dirkx

0:a259777c45a3


   177

  HTTPData* m_pDataIn;





dirkx

0:a259777c45a3


   178

  





dirkx

0:a259777c45a3


   179

  bool m_dataChunked; //Data is encoded as chunks





dirkx

0:a259777c45a3


   180

  int m_dataPos; //Position in data





dirkx

0:a259777c45a3


   181

  int m_dataLen; //Data length





dirkx

0:a259777c45a3


   182

  char* m_buf;





dirkx

0:a259777c45a3


   183

  char* m_pBufRemaining; //Remaining





dirkx

0:a259777c45a3


   184

  int m_bufRemainingLen; //Data length in m_pBufRemaining





dirkx

0:a259777c45a3


   185

  





dirkx

0:a259777c45a3


   186

  int m_httpResponseCode;





dirkx

0:a259777c45a3


   187

  





dirkx

0:a259777c45a3


   188

  HTTPResult m_blockingResult; //Result if blocking mode





dirkx

0:a259777c45a3


   189

  





dirkx

0:a259777c45a3


   190

};





dirkx

0:a259777c45a3


   191







dirkx

0:a259777c45a3


   192

//Including data containers here for more convenience





dirkx

0:a259777c45a3


   193

#include "data/HTTPFile.h"





dirkx

0:a259777c45a3


   194

#include "data/HTTPStream.h"





dirkx

0:a259777c45a3


   195

#include "data/HTTPText.h"





dirkx

0:a259777c45a3


   196

#include "data/HTTPMap.h"





dirkx

0:a259777c45a3


   197







dirkx

0:a259777c45a3


   198

#endif