Method write

Sming/Libraries/OtaUpgrade/OtaUpgrade/BasicStream.cpp:128–200

}

size_t BasicStream::write(const uint8_t* data, size_t size)
{
	const size_t origSize = size;

	while(!hasError() && (size > 0)) {
		switch(state) {
		case State::Header:
			if(consume(data, size)) {
				if(fileHeader.magic == expectedHeaderMagic) {
#ifndef ENABLE_OTA_DOWNGRADE
					const auto buildTimestampFirmware = FSTR::readValue(&BuildTimestamp);
					debug_i("Build timestamp of current firmware: %ull", buildTimestampFirmware);
					uint64_t buildTimestampUpgrade =
						((uint64_t)fileHeader.buildTimestampHigh << 32) | fileHeader.buildTimestampLow;
					debug_i("Build timestamp of OTA upgrade file: %ull", buildTimestampUpgrade);
					if(buildTimestampUpgrade < buildTimestampFirmware) {
						setError(Error::DowngradeNotAllowed);
						break;
					}
#endif
					debug_i("Starting firmware upgrade, receive %u image(s)", fileHeader.romCount);
					nextRom();
				} else {
					setError(Error::InvalidFormat);
				}
			}
			break;

		case State::RomHeader:
			if(consume(data, size)) {
				processRomHeader();
			}
			break;

		case State::WriteRom: {
			bool ok = ota.write(data, std::min(remainingBytes, size));
			if(ok) {
				if(consume(data, size)) {
					ok = slot.updated = ota.end();
					nextRom();
				}
			}
			if(!ok) {
				setError(Error::FlashWriteFailed);
			}
		} break;

		case State::SkipRom:
			if(consume(data, size)) {
				nextRom();
			}
			break;

		case State::VerifyRoms:
			if(consume(data, size)) {
				verifyRoms();
			}
			break;