package http_parser;



import primitive.collection.ByteList;

public class ParserSettings extends http_parser.lolevel.ParserSettings {
  
  public HTTPCallback       on_message_begin;
  public HTTPDataCallback   on_path;
  public HTTPDataCallback   on_query_string;
  public HTTPDataCallback   on_url;
  public HTTPDataCallback   on_fragment;
  public HTTPDataCallback   on_header_field;
  public HTTPDataCallback   on_header_value;
 
  public HTTPCallback       on_headers_complete;
  public HTTPDataCallback   on_body;
  public HTTPCallback       on_message_complete;
  
  public HTTPErrorCallback  on_error;
  
  private HTTPCallback      _on_message_begin;
  private HTTPDataCallback  _on_path;
  private HTTPDataCallback  _on_query_string;
  private HTTPDataCallback  _on_url;
  private HTTPDataCallback  _on_fragment;
  private HTTPDataCallback  _on_header_field;
  private HTTPDataCallback  _on_header_value;
  private HTTPHeadersCompleteCallback      _on_headers_complete;
  private HTTPDataCallback  _on_body;
  private HTTPCallback      _on_message_complete;
  private HTTPErrorCallback _on_error;
  
  private http_parser.lolevel.ParserSettings settings;
  
  protected ByteList field = new ByteList();
  protected ByteList value = new ByteList();
  protected ByteList body  = new ByteList();
  
  public ParserSettings() {
    this.settings = new http_parser.lolevel.ParserSettings();
    createMirrorCallbacks();
    attachCallbacks();
  }
  
  protected http_parser.lolevel.ParserSettings getLoLevelSettings() {
    return this.settings;
  }

  private void createMirrorCallbacks() {
    this._on_message_begin = new HTTPCallback() {
      public int cb(HTTPParser p) {
        if (null != ParserSettings.this.on_message_begin) {
          return ParserSettings.this.on_message_begin.cb(p);
        }
        return 0;
      }
    };
    this._on_path = new HTTPDataCallback() {
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        if (null != ParserSettings.this.on_path) {
          return ParserSettings.this.on_path.cb(p, by, pos, len);
        }
        return 0;
      }
    };
    this._on_query_string = new HTTPDataCallback() {
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        if (null != ParserSettings.this.on_query_string) {
          return ParserSettings.this.on_query_string.cb(p, by, pos, len);
        }
        return 0;
      }
    };
    this._on_url = new HTTPDataCallback() {
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        if (null != ParserSettings.this.on_url) {
          return ParserSettings.this.on_url.cb(p, by, pos, len);
        }
        return 0;
      }
    };
    this._on_fragment = new HTTPDataCallback() {
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        if (null != ParserSettings.this.on_fragment) {
          return ParserSettings.this.on_fragment.cb(p, by, pos, len);
        }
        return 0;
      }
    };
    this._on_error = new HTTPErrorCallback() {    
      @Override
      public void cb(HTTPParser parser, String error) {
        if (null != ParserSettings.this.on_error) {
          ParserSettings.this.on_error.cb(parser, error);
        } else {
          throw new HTTPException(error);
        }
        
      }
    };
      
      

//    (on_header_field and on_header_value shortened to on_h_*)
//    ------------------------ ------------ --------------------------------------------
//   | State (prev. callback) | Callback   | Description/action                         |
//    ------------------------ ------------ --------------------------------------------
//   | nothing (first call)   | on_h_field | Allocate new buffer and copy callback data |
//   |                        |            | into it                                    |
//    ------------------------ ------------ --------------------------------------------
//   | value                  | on_h_field | New header started.                        |
//   |                        |            | Copy current name,value buffers to headers |
//   |                        |            | list and allocate new buffer for new name  |
//    ------------------------ ------------ --------------------------------------------
//   | field                  | on_h_field | Previous name continues. Reallocate name   |
//   |                        |            | buffer and append callback data to it      |
//    ------------------------ ------------ --------------------------------------------
//   | field                  | on_h_value | Value for current header started. Allocate |
//   |                        |            | new buffer and copy callback data to it    |
//    ------------------------ ------------ --------------------------------------------
//   | value                  | on_h_value | Value continues. Reallocate value buffer   |
//   |                        |            | and append callback data to it             |
//    ------------------------ ------------ --------------------------------------------
    this._on_header_field = new HTTPDataCallback() {
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        // previous value complete, call on_value with full value, reset value.
        if (0 != ParserSettings.this.value.size()) {
          // check we're even interested...
          if (null != ParserSettings.this.on_header_value) {
            byte [] valueArr = ParserSettings.this.value.toArray();
            int ret = ParserSettings.this.on_header_value.cb(p, valueArr, 0, valueArr.length);
            if (0 != ret) {
              return ret;
            }
            ParserSettings.this.value.clear();
          }
        }
        
        if (null == ParserSettings.this.on_header_field) {
          return 0;
        }
        
        ParserSettings.this.field.addAll(by);
        return 0;
      }
    };
    this._on_header_value = new HTTPDataCallback() {    
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        
        // previous field complete, call on_field with full field value, reset field.
        if (0 != ParserSettings.this.field.size()) {
          // check we're even interested...
          if (null != ParserSettings.this.on_header_field) {
            byte [] fieldArr = ParserSettings.this.field.toArray();
            int ret = ParserSettings.this.on_header_field.cb(p, fieldArr, 0, fieldArr.length);
            if (0 != ret) {
              return ret;
            }
            ParserSettings.this.field.clear();
          }
        }
        
        if (null == ParserSettings.this.on_header_value) {
          return 0;
        }
        ParserSettings.this.value.addAll(by);
        return 0;
      }
    };
    this._on_headers_complete = new HTTPHeadersCompleteCallback() {
      @Override
      public int cb(HTTPParser parser) {
        // is there an uncompleted value ... ?
        if (0 != ParserSettings.this.value.size()) {
          // check we're even interested...
          if (null != ParserSettings.this.on_header_value) {
            byte [] valueArr = ParserSettings.this.value.toArray();
            int ret = ParserSettings.this.on_header_value.cb(parser, valueArr, 0, valueArr.length);
            if (0 != ret) {
              return ret;
            }
            ParserSettings.this.value.clear();
          }
        }
        if (null != ParserSettings.this.on_headers_complete) {
          return ParserSettings.this.on_headers_complete.cb(parser);
        }
        return 0;
      }
      
    };
    this._on_body = new HTTPDataCallback() {    
      @Override
      public int cb(HTTPParser p, byte[] by, int pos, int len) {
        if (null != ParserSettings.this.on_body) {
          ParserSettings.this.body.addAll(by, pos, len);
        }
        return 0;
      }
    };
    
    this._on_message_complete = new HTTPCallback() {     
      @Override
      public int cb(HTTPParser parser) {
        if (null != ParserSettings.this.on_body) {
          byte [] body = ParserSettings.this.body.toArray();
          int ret = ParserSettings.this.on_body.cb(parser, body, 0, body.length);
          if (0!=ret) {
            return ret;
          }
          ParserSettings.this.body.clear();
        }
        if (null != ParserSettings.this.on_message_complete) {
          return ParserSettings.this.on_message_complete.cb(parser);
        }
        return 0;
      }
    };
    
  }

  private void attachCallbacks() {
    // these are certainly set, because we mirror them ...
    this.settings.on_message_begin    = this._on_message_begin;
    this.settings.on_path             = this._on_path;
    this.settings.on_query_string     = this._on_query_string;
    this.settings.on_url              = this._on_url;
    this.settings.on_fragment         = this._on_fragment;
    this.settings.on_header_field     = this._on_header_field;
    this.settings.on_header_value     = this._on_header_value; 
    this.settings.on_headers_complete = this._on_headers_complete;
    this.settings.on_body             = this._on_body;
    this.settings.on_message_complete = this._on_message_complete;
    this.settings.on_error            = this._on_error;
  }
}
//import http_parser.HTTPException;
//public class ParserSettings extends http_parser.lolevel.ParserSettings{
//	
//  
//  
//  
//  public HTTPCallback       on_message_begin;
//  public HTTPDataCallback 	on_path;
//  public HTTPDataCallback 	on_query_string;
//  public HTTPDataCallback 	on_url;
//  public HTTPDataCallback 	on_fragment;
//  public HTTPDataCallback 	on_header_field;
//  public HTTPDataCallback 	on_header_value;
//  public HTTPCallback       on_headers_complete;
//  public HTTPDataCallback 	on_body;
//  public HTTPCallback       on_message_complete;
//  public HTTPErrorCallback  on_error;
//
//	void call_on_message_begin (HTTPParser p) {
//		call_on(on_message_begin, p);
//	}
//
//	void call_on_message_complete (HTTPParser p) {
//		call_on(on_message_complete, p);
//	}
//  
//  // this one is a little bit different:
//  // the current `position` of the buffer is the location of the
//  // error, `ini_pos` indicates where the position of
//  // the buffer when it was passed to the `execute` method of the parser, i.e.
//  // using this information and `limit` we'll know all the valid data
//  // in the buffer around the error we can use to print pretty error
//  // messages.
//  void call_on_error (HTTPParser p, String mes, ByteBuffer buf, int ini_pos) {
//    if (null != on_error) {
//      on_error.cb(p, mes, buf, ini_pos);
//    }
//    // if on_error gets called it MUST throw an exception, else the parser 
//    // will attempt to continue parsing, which it can't because it's
//    // in an invalid state.
//    throw new HTTPException(mes);
//	}
//
//	void call_on_header_field (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_header_field, p, buf, pos, len);
//	}
//	void call_on_query_string (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_query_string, p, buf, pos, len);
//	}
//	void call_on_fragment (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_fragment, p, buf, pos, len);
//	}
//	void call_on_path (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_path, p, buf, pos, len);
//	}
//	void call_on_header_value (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_header_value, p, buf, pos, len);
//	}
//	void call_on_url (HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_url, p, buf, pos, len);
//	}
//	void call_on_body(HTTPParser p, ByteBuffer buf, int pos, int len) {
//		call_on(on_body, p, buf, pos, len);
//	}
//	void call_on_headers_complete(HTTPParser p) {
//		call_on(on_headers_complete, p);
//	} 
//	void call_on (HTTPCallback cb, HTTPParser p) {
//		// cf. CALLBACK2 macro
//		if (null != cb) {
//			cb.cb(p);
//		}
//	}
//	void call_on (HTTPDataCallback cb, HTTPParser p, ByteBuffer buf, int pos, int len) {
//		if (null != cb && -1 != pos) {
//			cb.cb(p,buf,pos,len);
//		}
//	}
//}