Method messageHandler

MonaCore/sources/FlashMainStream.cpp:55–165

}

void FlashMainStream::messageHandler(const string& name,AMFReader& message,FlashWriter& writer) {
	if(name=="connect") {
		message.stopReferencing();
		
		
		ParameterWriter parameterWriter(peer.properties());

		if(message.read(AMFReader::OBJECT,parameterWriter)) {

			if (peer.properties().getString("tcUrl",_buffer)) {
				string serverAddress;
				Util::UnpackUrl(_buffer, serverAddress,(string&)peer.path,(string&)peer.query);
				peer.setServerAddress(serverAddress);
				Util::UnpackQuery(peer.query, peer.properties());
			}

			if (peer.properties().getNumber<UInt32,3>("objectEncoding")==0) {
				writer.amf0 = true;
				WARN("Client ",peer.protocol," not compatible with AMF3, few complex object can be not supported");
			}
		}

		message.startReferencing();

		
		// Check if the client is authorized
		AMFWriter& response = writer.writeAMFSuccess("NetConnection.Connect.Success","Connection succeeded",true);
		response.amf0 = true;
		response.writeNumberProperty("objectEncoding",writer.amf0 ? 0.0 : 3.0);
		response.amf0 = writer.amf0;
		Exception ex;
		peer.onConnection(ex, writer,message,response);
		if (ex) {
			switch(ex.code()) {
				case Exception::SOFTWARE:
					writer.writeAMFError("NetConnection.Connect.Rejected",ex.error());
					break;
				case Exception::APPLICATION:
					writer.writeAMFError("NetConnection.Connect.InvalidApp",ex.error());
					break;
				default:
					writer.writeAMFError("NetConnection.Connect.Failed",ex.error());
			}
			writer.writeInvocation("close");
			writer.close();
			return;
		}
			
		response.endObject();

	} else if(name == "setPeerInfo") {

		peer.localAddresses.clear();
		while(message.available()) {
			SocketAddress address;
			Exception ex;
			_buffer.clear();
			if (!message.readString(_buffer) || _buffer.empty())