'use strict'; function MspHelper () { } MspHelper.prototype.process_data = function(dataHandler) { var self = this; var data = dataHandler.dataView; // DataView (allowing us to view arrayBuffer as struct/union) var code = dataHandler.code; var message_length = data.byteLength; if (!dataHandler.unsupported) switch (code) { case MSPCodes.MSP_STATUS: CONFIG.cycleTime = data.getUint16(0, 1); CONFIG.i2cError = data.getUint16(2, 1); CONFIG.activeSensors = data.getUint16(4, 1); CONFIG.mode = data.getUint32(6, 1); CONFIG.profile = data.getUint8(10); TABS.pid_tuning.checkUpdateProfile(false); sensor_status(CONFIG.activeSensors); $('span.i2c-error').text(CONFIG.i2cError); $('span.cycle-time').text(CONFIG.cycleTime); break; case MSPCodes.MSP_STATUS_EX: CONFIG.cycleTime = data.getUint16(0, 1); CONFIG.i2cError = data.getUint16(2, 1); CONFIG.activeSensors = data.getUint16(4, 1); CONFIG.mode = data.getUint32(6, 1); CONFIG.profile = data.getUint8(10); CONFIG.cpuload = data.getUint16(11, 1); if (semver.gt(CONFIG.flightControllerVersion, "2.9.1")) { CONFIG.numProfiles = data.getUint8(13); CONFIG.rateProfile = data.getUint8(14); TABS.pid_tuning.checkUpdateProfile(true); } sensor_status(CONFIG.activeSensors); $('span.i2c-error').text(CONFIG.i2cError); $('span.cycle-time').text(CONFIG.cycleTime); $('span.cpu-load').text(chrome.i18n.getMessage('statusbar_cpu_load', [CONFIG.cpuload])); break; case MSPCodes.MSP_RAW_IMU: // 512 for mpu6050, 256 for mma // currently we are unable to differentiate between the sensor types, so we are goign with 512 SENSOR_DATA.accelerometer[0] = data.getInt16(0, 1) / 512; SENSOR_DATA.accelerometer[1] = data.getInt16(2, 1) / 512; SENSOR_DATA.accelerometer[2] = data.getInt16(4, 1) / 512; // properly scaled SENSOR_DATA.gyroscope[0] = data.getInt16(6, 1) * (4 / 16.4); SENSOR_DATA.gyroscope[1] = data.getInt16(8, 1) * (4 / 16.4); SENSOR_DATA.gyroscope[2] = data.getInt16(10, 1) * (4 / 16.4); // no clue about scaling factor SENSOR_DATA.magnetometer[0] = data.getInt16(12, 1) / 1090; SENSOR_DATA.magnetometer[1] = data.getInt16(14, 1) / 1090; SENSOR_DATA.magnetometer[2] = data.getInt16(16, 1) / 1090; break; case MSPCodes.MSP_SERVO: var servoCount = message_length / 2; var needle = 0; for (var i = 0; i < servoCount; i++) { SERVO_DATA[i] = data.getUint16(needle, 1); needle += 2; } break; case MSPCodes.MSP_MOTOR: var motorCount = message_length / 2; var needle = 0; for (var i = 0; i < motorCount; i++) { MOTOR_DATA[i] = data.getUint16(needle, 1); needle += 2; } break; case MSPCodes.MSP_RC: RC.active_channels = message_length / 2; for (var i = 0; i < RC.active_channels; i++) { RC.channels[i] = data.getUint16((i * 2), 1); } break; case MSPCodes.MSP_RAW_GPS: GPS_DATA.fix = data.getUint8(0); GPS_DATA.numSat = data.getUint8(1); GPS_DATA.lat = data.getInt32(2, 1); GPS_DATA.lon = data.getInt32(6, 1); GPS_DATA.alt = data.getUint16(10, 1); GPS_DATA.speed = data.getUint16(12, 1); GPS_DATA.ground_course = data.getUint16(14, 1); break; case MSPCodes.MSP_COMP_GPS: GPS_DATA.distanceToHome = data.getUint16(0, 1); GPS_DATA.directionToHome = data.getUint16(2, 1); GPS_DATA.update = data.getUint8(4); break; case MSPCodes.MSP_ATTITUDE: SENSOR_DATA.kinematics[0] = data.getInt16(0, 1) / 10.0; // x SENSOR_DATA.kinematics[1] = data.getInt16(2, 1) / 10.0; // y SENSOR_DATA.kinematics[2] = data.getInt16(4, 1); // z break; case MSPCodes.MSP_ALTITUDE: SENSOR_DATA.altitude = parseFloat((data.getInt32(0, 1) / 100.0).toFixed(2)); // correct scale factor break; case MSPCodes.MSP_SONAR: SENSOR_DATA.sonar = data.getInt32(0, 1); break; case MSPCodes.MSP_ANALOG: ANALOG.voltage = data.getUint8(0) / 10.0; ANALOG.mAhdrawn = data.getUint16(1, 1); ANALOG.rssi = data.getUint16(3, 1); // 0-1023 ANALOG.amperage = data.getInt16(5, 1) / 100; // A ANALOG.last_received_timestamp = Date.now(); break; case MSPCodes.MSP_RC_TUNING: var offset = 0; RC_tuning.RC_RATE = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.RC_EXPO = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); if (semver.lt(CONFIG.apiVersion, "1.7.0")) { RC_tuning.roll_pitch_rate = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.pitch_rate = 0; RC_tuning.roll_rate = 0; } else { RC_tuning.roll_pitch_rate = 0; RC_tuning.roll_rate = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.pitch_rate = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); } RC_tuning.yaw_rate = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.dynamic_THR_PID = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.throttle_MID = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); RC_tuning.throttle_EXPO = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); if (semver.gte(CONFIG.apiVersion, "1.7.0")) { RC_tuning.dynamic_THR_breakpoint = data.getUint16(offset, 1); offset += 2; } else { RC_tuning.dynamic_THR_breakpoint = 0; } if (semver.gte(CONFIG.apiVersion, "1.10.0")) { RC_tuning.RC_YAW_EXPO = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); if (semver.gte(CONFIG.flightControllerVersion, "2.9.1")) { RC_tuning.rcYawRate = parseFloat((data.getUint8(offset++) / 100).toFixed(2)); } else if (semver.lt(CONFIG.flightControllerVersion, "2.9.0")) { RC_tuning.rcYawRate = 0; } } else { RC_tuning.RC_YAW_EXPO = 0; } break; case MSPCodes.MSP_PID: // PID data arrived, we need to scale it and save to appropriate bank / array for (var i = 0, needle = 0; i < (message_length / 3); i++, needle += 3) { // main for loop selecting the pid section switch (i) { case 0: case 1: case 2: case 3: case 7: case 8: case 9: PIDs[i][0] = data.getUint8(needle); PIDs[i][1] = data.getUint8(needle + 1); PIDs[i][2] = data.getUint8(needle + 2); break; case 4: PIDs[i][0] = data.getUint8(needle); PIDs[i][1] = data.getUint8(needle + 1); PIDs[i][2] = data.getUint8(needle + 2); break; case 5: case 6: PIDs[i][0] = data.getUint8(needle); PIDs[i][1] = data.getUint8(needle + 1); PIDs[i][2] = data.getUint8(needle + 2); break; } } break; case MSPCodes.MSP_ARMING_CONFIG: if (semver.gte(CONFIG.apiVersion, "1.8.0")) { ARMING_CONFIG.auto_disarm_delay = data.getUint8(0, 1); ARMING_CONFIG.disarm_kill_switch = data.getUint8(1); } break; case MSPCodes.MSP_LOOP_TIME: if (semver.gte(CONFIG.apiVersion, "1.8.0")) { FC_CONFIG.loopTime = data.getInt16(0, 1); } break; case MSPCodes.MSP_MISC: // 22 bytes var offset = 0; MISC.midrc = data.getInt16(offset, 1); offset += 2; MISC.minthrottle = data.getUint16(offset, 1); // 0-2000 offset += 2; MISC.maxthrottle = data.getUint16(offset, 1); // 0-2000 offset += 2; MISC.mincommand = data.getUint16(offset, 1); // 0-2000 offset += 2; MISC.failsafe_throttle = data.getUint16(offset, 1); // 1000-2000 offset += 2; MISC.gps_type = data.getUint8(offset++); MISC.gps_baudrate = data.getUint8(offset++); MISC.gps_ubx_sbas = data.getInt8(offset++); MISC.multiwiicurrentoutput = data.getUint8(offset++); MISC.rssi_channel = data.getUint8(offset++); MISC.placeholder2 = data.getUint8(offset++); if (semver.lt(CONFIG.apiVersion, "1.18.0")) MISC.mag_declination = data.getInt16(offset, 1) / 10; // -1800-1800 else MISC.mag_declination = data.getInt16(offset, 1) / 100; // -18000-18000 offset += 2; MISC.vbatscale = data.getUint8(offset++, 1); // 10-200 MISC.vbatmincellvoltage = data.getUint8(offset++, 1) / 10; // 10-50 MISC.vbatmaxcellvoltage = data.getUint8(offset++, 1) / 10; // 10-50 MISC.vbatwarningcellvoltage = data.getUint8(offset++, 1) / 10; // 10-50 break; case MSPCodes.MSP_3D: var offset = 0; _3D.deadband3d_low = data.getUint16(offset, 1); offset += 2; _3D.deadband3d_high = data.getUint16(offset, 1); offset += 2; _3D.neutral3d = data.getUint16(offset, 1); if (semver.lt(CONFIG.apiVersion, "1.17.0")) { offset += 2; _3D.deadband3d_throttle = data.getUint16(offset, 1); } break; case MSPCodes.MSP_BOXNAMES: AUX_CONFIG = []; // empty the array as new data is coming in var buff = []; for (var i = 0; i < data.byteLength; i++) { if (data.getUint8(i) == 0x3B) { // ; (delimeter char) AUX_CONFIG.push(String.fromCharCode.apply(null, buff)); // convert bytes into ASCII and save as strings // empty buffer buff = []; } else { buff.push(data.getUint8(i)); } } break; case MSPCodes.MSP_PIDNAMES: PID_names = []; // empty the array as new data is coming in var buff = []; for (var i = 0; i < data.byteLength; i++) { if (data.getUint8(i) == 0x3B) { // ; (delimeter char) PID_names.push(String.fromCharCode.apply(null, buff)); // convert bytes into ASCII and save as strings // empty buffer buff = []; } else { buff.push(data.getUint8(i)); } } break; case MSPCodes.MSP_BOXIDS: AUX_CONFIG_IDS = []; // empty the array as new data is coming in for (var i = 0; i < data.byteLength; i++) { AUX_CONFIG_IDS.push(data.getUint8(i)); } break; case MSPCodes.MSP_SERVO_MIX_RULES: break; case MSPCodes.MSP_SERVO_CONFIGURATIONS: SERVO_CONFIG = []; // empty the array as new data is coming in if (semver.gte(CONFIG.apiVersion, "1.12.0")) { if (data.byteLength % 14 == 0) { for (var i = 0; i < data.byteLength; i += 14) { var arr = { 'min': data.getInt16(i + 0, 1), 'max': data.getInt16(i + 2, 1), 'middle': data.getInt16(i + 4, 1), 'rate': data.getInt8(i + 6), 'angleAtMin': data.getInt8(i + 7), 'angleAtMax': data.getInt8(i + 8), 'indexOfChannelToForward': data.getInt8(i + 9), 'reversedInputSources': data.getUint32(i + 10) }; SERVO_CONFIG.push(arr); } } } else { if (data.byteLength % 7 == 0) { for (var i = 0; i < data.byteLength; i += 7) { var arr = { 'min': data.getInt16(i + 0, 1), 'max': data.getInt16(i + 2, 1), 'middle': data.getInt16(i + 4, 1), 'rate': data.getInt8(i + 6), 'angleAtMin': 45, 'angleAtMax': 45, 'indexOfChannelToForward': undefined, 'reversedInputSources': 0 }; SERVO_CONFIG.push(arr); } } if (semver.eq(CONFIG.apiVersion, '1.10.0')) { // drop two unused servo configurations due to MSP rx buffer to small) while (SERVO_CONFIG.length > 8) { SERVO_CONFIG.pop(); } } } break; case MSPCodes.MSP_RC_DEADBAND: var offset = 0; RC_deadband.deadband = data.getUint8(offset++, 1); RC_deadband.yaw_deadband = data.getUint8(offset++, 1); RC_deadband.alt_hold_deadband = data.getUint8(offset++, 1); if (semver.gte(CONFIG.apiVersion, "1.17.0")) { _3D.deadband3d_throttle = data.getUint16(offset, 1); offset += 2; } break; case MSPCodes.MSP_SENSOR_ALIGNMENT: var offset = 0; SENSOR_ALIGNMENT.align_gyro = data.getUint8(offset++, 1); SENSOR_ALIGNMENT.align_acc = data.getUint8(offset++, 1); SENSOR_ALIGNMENT.align_mag = data.getUint8(offset++, 1); break; case MSPCodes.MSP_SET_RAW_RC: break; case MSPCodes.MSP_SET_PID: console.log('PID settings saved'); break; case MSPCodes.MSP_SET_RC_TUNING: console.log('RC Tuning saved'); break; case MSPCodes.MSP_ACC_CALIBRATION: console.log('Accel calibration executed'); break; case MSPCodes.MSP_MAG_CALIBRATION: console.log('Mag calibration executed'); break; case MSPCodes.MSP_SET_MISC: console.log('MISC Configuration saved'); break; case MSPCodes.MSP_RESET_CONF: console.log('Settings Reset'); break; case MSPCodes.MSP_SELECT_SETTING: console.log('Profile selected'); break; case MSPCodes.MSP_SET_SERVO_CONFIGURATION: console.log('Servo Configuration saved'); break; case MSPCodes.MSP_EEPROM_WRITE: console.log('Settings Saved in EEPROM'); break; case MSPCodes.MSP_DEBUG: for (var i = 0; i < 4; i++) SENSOR_DATA.debug[i] = data.getInt16((2 * i), 1); break; case MSPCodes.MSP_SET_MOTOR: console.log('Motor Speeds Updated'); break; // Additional baseflight commands that are not compatible with MultiWii case MSPCodes.MSP_UID: CONFIG.uid[0] = data.getUint32(0, 1); CONFIG.uid[1] = data.getUint32(4, 1); CONFIG.uid[2] = data.getUint32(8, 1); break; case MSPCodes.MSP_ACC_TRIM: CONFIG.accelerometerTrims[0] = data.getInt16(0, 1); // pitch CONFIG.accelerometerTrims[1] = data.getInt16(2, 1); // roll break; case MSPCodes.MSP_SET_ACC_TRIM: console.log('Accelerometer trimms saved.'); break; case MSPCodes.MSP_GPS_SV_INFO: if (data.byteLength > 0) { var numCh = data.getUint8(0); var needle = 1; for (var i = 0; i < numCh; i++) { GPS_DATA.chn[i] = data.getUint8(needle); GPS_DATA.svid[i] = data.getUint8(needle + 1); GPS_DATA.quality[i] = data.getUint8(needle + 2); GPS_DATA.cno[i] = data.getUint8(needle + 3); needle += 4; } } break; case MSPCodes.MSP_RX_MAP: RC_MAP = []; // empty the array as new data is coming in for (var i = 0; i < data.byteLength; i++) { RC_MAP.push(data.getUint8(i)); } break; case MSPCodes.MSP_SET_RX_MAP: console.log('RCMAP saved'); break; case MSPCodes.MSP_BF_CONFIG: BF_CONFIG.mixerConfiguration = data.getUint8(0); BF_CONFIG.features.setMask(data.getUint32(1, 1)); BF_CONFIG.serialrx_type = data.getUint8(5); BF_CONFIG.board_align_roll = data.getInt16(6, 1); // -180 - 360 BF_CONFIG.board_align_pitch = data.getInt16(8, 1); // -180 - 360 BF_CONFIG.board_align_yaw = data.getInt16(10, 1); // -180 - 360 BF_CONFIG.currentscale = data.getInt16(12, 1); BF_CONFIG.currentoffset = data.getUint16(14, 1); updateTabList(BF_CONFIG.features); break; case MSPCodes.MSP_SET_BF_CONFIG: break; case MSPCodes.MSP_SET_REBOOT: console.log('Reboot request accepted'); break; case MSPCodes.MSP_API_VERSION: var offset = 0; CONFIG.mspProtocolVersion = data.getUint8(offset++); CONFIG.apiVersion = data.getUint8(offset++) + '.' + data.getUint8(offset++) + '.0'; break; case MSPCodes.MSP_FC_VARIANT: var identifier = ''; var offset; for (offset = 0; offset < 4; offset++) { identifier += String.fromCharCode(data.getUint8(offset)); } CONFIG.flightControllerIdentifier = identifier; break; case MSPCodes.MSP_FC_VERSION: var offset = 0; var flightControllerVersion = CONFIG.flightControllerVersion; CONFIG.flightControllerVersion = data.getUint8(offset++) + '.' + data.getUint8(offset++) + '.' + data.getUint8(offset++); break; case MSPCodes.MSP_BUILD_INFO: var offset = 0; var dateLength = 11; var buff = []; for (var i = 0; i < dateLength; i++) { buff.push(data.getUint8(offset++)); } buff.push(32); // ascii space var timeLength = 8; for (var i = 0; i < timeLength; i++) { buff.push(data.getUint8(offset++)); } CONFIG.buildInfo = String.fromCharCode.apply(null, buff); break; case MSPCodes.MSP_BOARD_INFO: var identifier = ''; var offset; for (offset = 0; offset < 4; offset++) { identifier += String.fromCharCode(data.getUint8(offset)); } CONFIG.boardIdentifier = identifier; CONFIG.boardVersion = data.getUint16(offset, 1); offset+=2; break; case MSPCodes.MSP_NAME: var offset = 0; var name = ''; while (offset> 8) & 0xF; var functions = []; for (var baseFunctionLetterIndex = 0; baseFunctionLetterIndex < ledBaseFunctionLetters.length; baseFunctionLetterIndex++) { if (functionId == baseFunctionLetterIndex) { functions.push(ledBaseFunctionLetters[baseFunctionLetterIndex]); break; } } var overlayMask = (mask >> 12) & 0x3F; for (var overlayLetterIndex = 0; overlayLetterIndex < ledOverlayLetters.length; overlayLetterIndex++) { if (bit_check(overlayMask, overlayLetterIndex)) { functions.push(ledOverlayLetters[overlayLetterIndex]); } } var directionMask = (mask >> 22) & 0x3F; var directions = []; for (var directionLetterIndex = 0; directionLetterIndex < ledDirectionLetters.length; directionLetterIndex++) { if (bit_check(directionMask, directionLetterIndex)) { directions.push(ledDirectionLetters[directionLetterIndex]); } } var led = { y: (mask) & 0xF, x: (mask >> 4) & 0xF, functions: functions, color: (mask >> 18) & 0xF, directions: directions, parameters: (mask >> 28) & 0xF }; LED_STRIP.push(led); } } break; case MSPCodes.MSP_SET_LED_STRIP_CONFIG: console.log('Led strip config saved'); break; case MSPCodes.MSP_LED_COLORS: LED_COLORS = []; var colorCount = data.byteLength / 4; var offset = 0; for (var i = 0; offset < data.byteLength && i < colorCount; i++) { var h = data.getUint16(offset, 1); var s = data.getUint8(offset + 2, 1); var v = data.getUint8(offset + 3, 1); offset += 4; var color = { h: h, s: s, v: v }; LED_COLORS.push(color); } break; case MSPCodes.MSP_SET_LED_COLORS: console.log('Led strip colors saved'); break; case MSPCodes.MSP_LED_STRIP_MODECOLOR: if (semver.gte(CONFIG.apiVersion, "1.19.0")) { LED_MODE_COLORS = []; var colorCount = data.byteLength / 3; var offset = 0; for (var i = 0; offset < data.byteLength && i < colorCount; i++) { var mode = data.getUint8(offset++, 1); var direction = data.getUint8(offset++, 1); var color = data.getUint8(offset++, 1); var mode_color = { mode: mode, direction: direction, color: color }; LED_MODE_COLORS.push(mode_color); } } break; case MSPCodes.MSP_SET_LED_STRIP_MODECOLOR: console.log('Led strip mode colors saved'); break; case MSPCodes.MSP_DATAFLASH_SUMMARY: if (data.byteLength >= 13) { var flags = data.getUint8(0); DATAFLASH.ready = (flags & 1) != 0; DATAFLASH.supported = (flags & 2) != 0 || DATAFLASH.ready; DATAFLASH.sectors = data.getUint32(1, 1); DATAFLASH.totalSize = data.getUint32(5, 1); DATAFLASH.usedSize = data.getUint32(9, 1); } else { // Firmware version too old to support MSP_DATAFLASH_SUMMARY DATAFLASH.ready = false; DATAFLASH.supported = false; DATAFLASH.sectors = 0; DATAFLASH.totalSize = 0; DATAFLASH.usedSize = 0; } update_dataflash_global(); break; case MSPCodes.MSP_DATAFLASH_READ: // No-op, let callback handle it break; case MSPCodes.MSP_DATAFLASH_ERASE: console.log("Data flash erase begun..."); break; case MSPCodes.MSP_SDCARD_SUMMARY: var flags = data.getUint8(0); SDCARD.supported = (flags & 0x01) != 0; SDCARD.state = data.getUint8(1); SDCARD.filesystemLastError = data.getUint8(2); SDCARD.freeSizeKB = data.getUint32(3, 1); SDCARD.totalSizeKB = data.getUint32(7, 1); break; case MSPCodes.MSP_BLACKBOX_CONFIG: BLACKBOX.supported = (data.getUint8(0) & 1) != 0; BLACKBOX.blackboxDevice = data.getUint8(1); BLACKBOX.blackboxRateNum = data.getUint8(2); BLACKBOX.blackboxRateDenom = data.getUint8(3); break; case MSPCodes.MSP_SET_BLACKBOX_CONFIG: console.log("Blackbox config saved"); break; case MSPCodes.MSP_TRANSPONDER_CONFIG: var offset = 0; TRANSPONDER.supported = (data.getUint8(offset++) & 1) != 0; TRANSPONDER.data = []; var bytesRemaining = data.byteLength - offset; for (var i = 0; i < bytesRemaining; i++) { TRANSPONDER.data.push(data.getUint8(offset++)); } break; case MSPCodes.MSP_SET_TRANSPONDER_CONFIG: console.log("Transponder config saved"); break; case MSPCodes.MSP_SET_MODE_RANGE: console.log('Mode range saved'); break; case MSPCodes.MSP_SET_ADJUSTMENT_RANGE: console.log('Adjustment range saved'); break; case MSPCodes.MSP_PID_CONTROLLER: PID.controller = data.getUint8(0, 1); break; case MSPCodes.MSP_SET_PID_CONTROLLER: console.log('PID controller changed'); break; case MSPCodes.MSP_SET_LOOP_TIME: console.log('Looptime saved'); break; case MSPCodes.MSP_SET_ARMING_CONFIG: console.log('Arming config saved'); break; case MSPCodes.MSP_SET_RESET_CURR_PID: console.log('Current PID profile reset'); break; case MSPCodes.MSP_SET_3D: console.log('3D settings saved'); break; case MSPCodes.MSP_SET_RC_DEADBAND: console.log('Rc controls settings saved'); break; case MSPCodes.MSP_SET_SENSOR_ALIGNMENT: console.log('Sensor alignment saved'); break; case MSPCodes.MSP_SET_RX_CONFIG: console.log('Rx config saved'); break; case MSPCodes.MSP_SET_RXFAIL_CONFIG: console.log('Rxfail config saved'); break; case MSPCodes.MSP_SET_FAILSAFE_CONFIG: console.log('Failsafe config saved'); break; case MSPCodes.MSP_OSD_CONFIG: break; case MSPCodes.MSP_SET_OSD_CONFIG: console.log('OSD config set'); break; case MSPCodes.MSP_OSD_CHAR_READ: break; case MSPCodes.MSP_OSD_CHAR_WRITE: console.log('OSD char uploaded'); break; case MSPCodes.MSP_VTX_CONFIG: break; case MSPCodes.MSP_SET_VTX_CONFIG: break; case MSPCodes.MSP_SET_NAME: console.log('Name set'); break; case MSPCodes.MSP_SET_FILTER_CONFIG: console.log('Filter config set'); break; case MSPCodes.MSP_SET_ADVANCED_TUNING: console.log('Advanced tuning parameters set'); break; case MSPCodes.MSP_SET_SPECIAL_PARAMETERS: console.log('Special parameters set'); break; default: console.log('Unknown code detected: ' + code); } else { console.log('FC reports unsupported message error: ' + code); } // trigger callbacks, cleanup/remove callback after trigger for (var i = dataHandler.callbacks.length - 1; i >= 0; i--) { // itterating in reverse because we use .splice which modifies array length if (dataHandler.callbacks[i].code == code) { // save callback reference var callback = dataHandler.callbacks[i].callback; // remove timeout clearInterval(dataHandler.callbacks[i].timer); // remove object from array dataHandler.callbacks.splice(i, 1); // fire callback if (callback) callback({'command': code, 'data': data, 'length': data.byteLength}); } } } /** * Encode the request body for the MSP request with the given code and return it as an array of bytes. */ MspHelper.prototype.crunch = function(code) { var buffer = []; var self = this; switch (code) { case MSPCodes.MSP_SET_BF_CONFIG: var featureMask = BF_CONFIG.features.getMask(); buffer.push(BF_CONFIG.mixerConfiguration); buffer.push(specificByte(featureMask, 0)); buffer.push(specificByte(featureMask, 1)); buffer.push(specificByte(featureMask, 2)); buffer.push(specificByte(featureMask, 3)); buffer.push(BF_CONFIG.serialrx_type); buffer.push(specificByte(BF_CONFIG.board_align_roll, 0)); buffer.push(specificByte(BF_CONFIG.board_align_roll, 1)); buffer.push(specificByte(BF_CONFIG.board_align_pitch, 0)); buffer.push(specificByte(BF_CONFIG.board_align_pitch, 1)); buffer.push(specificByte(BF_CONFIG.board_align_yaw, 0)); buffer.push(specificByte(BF_CONFIG.board_align_yaw, 1)); buffer.push(lowByte(BF_CONFIG.currentscale)); buffer.push(highByte(BF_CONFIG.currentscale)); buffer.push(lowByte(BF_CONFIG.currentoffset)); buffer.push(highByte(BF_CONFIG.currentoffset)); break; case MSPCodes.MSP_SET_PID_CONTROLLER: buffer.push(PID.controller); break; case MSPCodes.MSP_SET_PID: for (var i = 0; i < PIDs.length; i++) { switch (i) { case 0: case 1: case 2: case 3: case 7: case 8: case 9: buffer.push(parseInt(PIDs[i][0])); buffer.push(parseInt(PIDs[i][1])); buffer.push(parseInt(PIDs[i][2])); break; case 4: buffer.push(parseInt(PIDs[i][0])); buffer.push(parseInt(PIDs[i][1])); buffer.push(parseInt(PIDs[i][2])); break; case 5: case 6: buffer.push(parseInt(PIDs[i][0])); buffer.push(parseInt(PIDs[i][1])); buffer.push(parseInt(PIDs[i][2])); break; } } break; case MSPCodes.MSP_SET_RC_TUNING: buffer.push(Math.round(RC_tuning.RC_RATE * 100)); buffer.push(Math.round(RC_tuning.RC_EXPO * 100)); if (semver.lt(CONFIG.apiVersion, "1.7.0")) { buffer.push(Math.round(RC_tuning.roll_pitch_rate * 100)); } else { buffer.push(Math.round(RC_tuning.roll_rate * 100)); buffer.push(Math.round(RC_tuning.pitch_rate * 100)); } buffer.push(Math.round(RC_tuning.yaw_rate * 100)); buffer.push(Math.round(RC_tuning.dynamic_THR_PID * 100)); buffer.push(Math.round(RC_tuning.throttle_MID * 100)); buffer.push(Math.round(RC_tuning.throttle_EXPO * 100)); if (semver.gte(CONFIG.apiVersion, "1.7.0")) { buffer.push(lowByte(RC_tuning.dynamic_THR_breakpoint)); buffer.push(highByte(RC_tuning.dynamic_THR_breakpoint)); } if (semver.gte(CONFIG.apiVersion, "1.10.0")) { buffer.push(Math.round(RC_tuning.RC_YAW_EXPO * 100)); if (semver.gte(CONFIG.flightControllerVersion, "2.9.1")) { buffer.push(Math.round(RC_tuning.rcYawRate * 100)); } } break; case MSPCodes.MSP_SET_RX_MAP: for (var i = 0; i < RC_MAP.length; i++) { buffer.push(RC_MAP[i]); } break; case MSPCodes.MSP_SET_ACC_TRIM: buffer.push(lowByte(CONFIG.accelerometerTrims[0])); buffer.push(highByte(CONFIG.accelerometerTrims[0])); buffer.push(lowByte(CONFIG.accelerometerTrims[1])); buffer.push(highByte(CONFIG.accelerometerTrims[1])); break; case MSPCodes.MSP_SET_ARMING_CONFIG: buffer.push(ARMING_CONFIG.auto_disarm_delay); buffer.push(ARMING_CONFIG.disarm_kill_switch); break; case MSPCodes.MSP_SET_LOOP_TIME: buffer.push(lowByte(FC_CONFIG.loopTime)); buffer.push(highByte(FC_CONFIG.loopTime)); break; case MSPCodes.MSP_SET_MISC: buffer.push(lowByte(MISC.midrc)); buffer.push(highByte(MISC.midrc)); buffer.push(lowByte(MISC.minthrottle)); buffer.push(highByte(MISC.minthrottle)); buffer.push(lowByte(MISC.maxthrottle)); buffer.push(highByte(MISC.maxthrottle)); buffer.push(lowByte(MISC.mincommand)); buffer.push(highByte(MISC.mincommand)); buffer.push(lowByte(MISC.failsafe_throttle)); buffer.push(highByte(MISC.failsafe_throttle)); buffer.push(MISC.gps_type); buffer.push(MISC.gps_baudrate); buffer.push(MISC.gps_ubx_sbas); buffer.push(MISC.multiwiicurrentoutput); buffer.push(MISC.rssi_channel); buffer.push(MISC.placeholder2); if (semver.lt(CONFIG.apiVersion, "1.18.0")) { buffer.push(lowByte(Math.round(MISC.mag_declination * 10))); buffer.push(highByte(Math.round(MISC.mag_declination * 10))); } else { buffer.push(lowByte(Math.round(MISC.mag_declination * 100))); buffer.push(highByte(Math.round(MISC.mag_declination * 100))); } buffer.push(MISC.vbatscale); buffer.push(Math.round(MISC.vbatmincellvoltage * 10)); buffer.push(Math.round(MISC.vbatmaxcellvoltage * 10)); buffer.push(Math.round(MISC.vbatwarningcellvoltage * 10)); break; case MSPCodes.MSP_SET_RX_CONFIG: buffer.push(RX_CONFIG.serialrx_provider); buffer.push(lowByte(RX_CONFIG.maxcheck)); buffer.push(highByte(RX_CONFIG.maxcheck)); buffer.push(lowByte(RX_CONFIG.midrc)); buffer.push(highByte(RX_CONFIG.midrc)); buffer.push(lowByte(RX_CONFIG.mincheck)); buffer.push(highByte(RX_CONFIG.mincheck)); buffer.push(RX_CONFIG.spektrum_sat_bind); buffer.push(lowByte(RX_CONFIG.rx_min_usec)); buffer.push(highByte(RX_CONFIG.rx_min_usec)); buffer.push(lowByte(RX_CONFIG.rx_max_usec)); buffer.push(highByte(RX_CONFIG.rx_max_usec)); if (semver.gte(CONFIG.apiVersion, "1.20.0")) { buffer.push(RX_CONFIG.rcInterpolation); buffer.push(RX_CONFIG.rcInterpolationInterval); buffer.push(lowByte(RX_CONFIG.airModeActivateThreshold)); buffer.push(highByte(RX_CONFIG.airModeActivateThreshold)); } break; case MSPCodes.MSP_SET_FAILSAFE_CONFIG: buffer.push(FAILSAFE_CONFIG.failsafe_delay); buffer.push(FAILSAFE_CONFIG.failsafe_off_delay); buffer.push(lowByte(FAILSAFE_CONFIG.failsafe_throttle)); buffer.push(highByte(FAILSAFE_CONFIG.failsafe_throttle)); if (semver.gte(CONFIG.apiVersion, "1.15.0")) { buffer.push(FAILSAFE_CONFIG.failsafe_kill_switch); buffer.push(lowByte(FAILSAFE_CONFIG.failsafe_throttle_low_delay)); buffer.push(highByte(FAILSAFE_CONFIG.failsafe_throttle_low_delay)); buffer.push(FAILSAFE_CONFIG.failsafe_procedure); } break; case MSPCodes.MSP_SET_TRANSPONDER_CONFIG: for (var i = 0; i < TRANSPONDER.data.length; i++) { buffer.push(TRANSPONDER.data[i]); } break; case MSPCodes.MSP_SET_CHANNEL_FORWARDING: for (var i = 0; i < SERVO_CONFIG.length; i++) { var out = SERVO_CONFIG[i].indexOfChannelToForward; if (out == undefined) { out = 255; // Cleanflight defines "CHANNEL_FORWARDING_DISABLED" as "(uint8_t)0xFF" } buffer.push(out); } break; case MSPCodes.MSP_SET_CF_SERIAL_CONFIG: var supportedBaudRates = [ // 0 based index. 'AUTO', '9600', '19200', '38400', '57600', '115200', '230400', '250000', ]; //TODO, instead of lookuptable, this should be sent as uint32 var serialPortFunctions = { 'MSP': 0, 'GPS': 1, 'TELEMETRY_FRSKY': 2, 'TELEMETRY_HOTT': 3, 'TELEMETRY_MSP': 4, 'TELEMETRY_LTM': 4, // LTM replaced MSP 'TELEMETRY_SMARTPORT': 5, 'RX_SERIAL': 6, 'BLACKBOX': 7, 'TELEMETRY_MAVLINK': 8, }; if (semver.lt(CONFIG.apiVersion, "1.6.0")) { for (var i = 0; i < SERIAL_CONFIG.ports.length; i++) { buffer.push(SERIAL_CONFIG.ports[i].scenario); } buffer.push(specificByte(SERIAL_CONFIG.mspBaudRate, 0)); buffer.push(specificByte(SERIAL_CONFIG.mspBaudRate, 1)); buffer.push(specificByte(SERIAL_CONFIG.mspBaudRate, 2)); buffer.push(specificByte(SERIAL_CONFIG.mspBaudRate, 3)); buffer.push(specificByte(SERIAL_CONFIG.cliBaudRate, 0)); buffer.push(specificByte(SERIAL_CONFIG.cliBaudRate, 1)); buffer.push(specificByte(SERIAL_CONFIG.cliBaudRate, 2)); buffer.push(specificByte(SERIAL_CONFIG.cliBaudRate, 3)); buffer.push(specificByte(SERIAL_CONFIG.gpsBaudRate, 0)); buffer.push(specificByte(SERIAL_CONFIG.gpsBaudRate, 1)); buffer.push(specificByte(SERIAL_CONFIG.gpsBaudRate, 2)); buffer.push(specificByte(SERIAL_CONFIG.gpsBaudRate, 3)); buffer.push(specificByte(SERIAL_CONFIG.gpsPassthroughBaudRate, 0)); buffer.push(specificByte(SERIAL_CONFIG.gpsPassthroughBaudRate, 1)); buffer.push(specificByte(SERIAL_CONFIG.gpsPassthroughBaudRate, 2)); buffer.push(specificByte(SERIAL_CONFIG.gpsPassthroughBaudRate, 3)); } else { for (var i = 0; i < SERIAL_CONFIG.ports.length; i++) { var serialPort = SERIAL_CONFIG.ports[i]; buffer.push(serialPort.identifier); var functionMask = self.serialPortFunctionsToMask(serialPort.functions); buffer.push(specificByte(functionMask, 0)); buffer.push(specificByte(functionMask, 1)); buffer.push(supportedBaudRates.indexOf(serialPort.msp_baudrate)); buffer.push(supportedBaudRates.indexOf(serialPort.gps_baudrate)); buffer.push(supportedBaudRates.indexOf(serialPort.telemetry_baudrate)); buffer.push(supportedBaudRates.indexOf(serialPort.blackbox_baudrate)); } } break; case MSPCodes.MSP_SET_3D: buffer.push(lowByte(_3D.deadband3d_low)); buffer.push(highByte(_3D.deadband3d_low)); buffer.push(lowByte(_3D.deadband3d_high)); buffer.push(highByte(_3D.deadband3d_high)); buffer.push(lowByte(_3D.neutral3d)); buffer.push(highByte(_3D.neutral3d)); if (semver.lt(CONFIG.apiVersion, "1.17.0")) { buffer.push(lowByte(_3D.deadband3d_throttle)); buffer.push(highByte(_3D.deadband3d_throttle)); } break; case MSPCodes.MSP_SET_RC_DEADBAND: buffer.push(RC_deadband.deadband); buffer.push(RC_deadband.yaw_deadband); buffer.push(RC_deadband.alt_hold_deadband); if (semver.gte(CONFIG.apiVersion, "1.17.0")) { buffer.push(lowByte(_3D.deadband3d_throttle)); buffer.push(highByte(_3D.deadband3d_throttle)); } break; case MSPCodes.MSP_SET_SENSOR_ALIGNMENT: buffer.push(SENSOR_ALIGNMENT.align_gyro); buffer.push(SENSOR_ALIGNMENT.align_acc); buffer.push(SENSOR_ALIGNMENT.align_mag); break case MSPCodes.MSP_SET_ADVANCED_CONFIG: buffer.push(PID_ADVANCED_CONFIG.gyro_sync_denom); buffer.push(PID_ADVANCED_CONFIG.pid_process_denom); buffer.push(PID_ADVANCED_CONFIG.use_unsyncedPwm); buffer.push(PID_ADVANCED_CONFIG.fast_pwm_protocol); buffer.push(lowByte(PID_ADVANCED_CONFIG.motor_pwm_rate)); buffer.push(highByte(PID_ADVANCED_CONFIG.motor_pwm_rate)); break; case MSPCodes.MSP_SET_FILTER_CONFIG: buffer.push8(FILTER_CONFIG.gyro_soft_lpf_hz) .push16(FILTER_CONFIG.dterm_lpf_hz) .push16(FILTER_CONFIG.yaw_lpf_hz); if (semver.gte(CONFIG.apiVersion, "1.20.0")) { buffer.push16(FILTER_CONFIG.gyro_soft_notch_hz) .push16(FILTER_CONFIG.gyro_soft_notch_cutoff) .push16(FILTER_CONFIG.dterm_notch_hz) .push16(FILTER_CONFIG.dterm_notch_cutoff); } break; case MSPCodes.MSP_SET_PID_ADVANCED: if (semver.gte(CONFIG.flightControllerVersion, "3.0.0")) { buffer.push16(ADVANCED_TUNING.rollPitchItermIgnoreRate) .push16(ADVANCED_TUNING.yawItermIgnoreRate) .push16(ADVANCED_TUNING.yaw_p_limit) .push8(ADVANCED_TUNING.deltaMethod) .push8(ADVANCED_TUNING.vbatPidCompensation) .push8(ADVANCED_TUNING.ptermSetpointWeight) .push8(ADVANCED_TUNING.dtermSetpointWeight) .push8(ADVANCED_TUNING.toleranceBand) .push8(ADVANCED_TUNING.toleranceBandReduction) .push8(ADVANCED_TUNING.itermThrottleGain) .push16(ADVANCED_TUNING.pidMaxVelocity) .push16(ADVANCED_TUNING.pidMaxVelocityYaw); } // only supports 1 version pre bf 3.0 else { buffer.push16(ADVANCED_TUNING.rollPitchItermIgnoreRate) .push16(ADVANCED_TUNING.yawItermIgnoreRate) .push16(ADVANCED_TUNING.yaw_p_limit) .push8(ADVANCED_TUNING.deltaMethod) .push8(ADVANCED_TUNING.vbatPidCompensation); } break; case MSPCodes.MSP_SET_SPECIAL_PARAMETERS: if (semver.lt(CONFIG.flightControllerVersion, "2.9.1")) { buffer.push(Math.round(RC_tuning.rcYawRate * 100)); if (semver.gte(CONFIG.flightControllerVersion, "2.8.2")) { buffer.push16(RX_CONFIG.airModeActivateThreshold); buffer.push(RX_CONFIG.rcSmoothInterval); buffer.push16(SPECIAL_PARAMETERS.escDesyncProtection); } } break; case MSPCodes.MSP_SET_SENSOR_CONFIG: buffer.push(SENSOR_CONFIG.acc_hardware); buffer.push(SENSOR_CONFIG.baro_hardware); buffer.push(SENSOR_CONFIG.mag_hardware); break; case MSPCodes.MSP_SET_NAME: var MSP_BUFFER_SIZE = 64; for (var i = 0; i> 8) & 0xFF, (address >> 16) & 0xFF, (address >> 24) & 0xFF], false, function(response) { var chunkAddress = response.data.getUint32(0, 1); // Verify that the address of the memory returned matches what the caller asked for if (chunkAddress == address) { /* Strip that address off the front of the reply and deliver it separately so the caller doesn't have to * figure out the reply format: */ onDataCallback(address, new DataView(response.data.buffer, response.data.byteOffset + 4, response.data.buffer.byteLength - 4)); } else { // Report error onDataCallback(address, null); } }); }; MspHelper.prototype.sendServoConfigurations = function(onCompleteCallback) { var nextFunction = send_next_servo_configuration; var servoIndex = 0; if (SERVO_CONFIG.length == 0) { onCompleteCallback(); } else { nextFunction(); } function send_next_servo_configuration() { var buffer = []; if (semver.lt(CONFIG.apiVersion, "1.12.0")) { // send all in one go // 1.9.0 had a bug where the MSP input buffer was too small, limit to 8. for (var i = 0; i < SERVO_CONFIG.length && i < 8; i++) { buffer.push(lowByte(SERVO_CONFIG[i].min)); buffer.push(highByte(SERVO_CONFIG[i].min)); buffer.push(lowByte(SERVO_CONFIG[i].max)); buffer.push(highByte(SERVO_CONFIG[i].max)); buffer.push(lowByte(SERVO_CONFIG[i].middle)); buffer.push(highByte(SERVO_CONFIG[i].middle)); buffer.push(lowByte(SERVO_CONFIG[i].rate)); } nextFunction = send_channel_forwarding; } else { // send one at a time, with index var servoConfiguration = SERVO_CONFIG[servoIndex]; buffer.push(servoIndex); buffer.push(lowByte(servoConfiguration.min)); buffer.push(highByte(servoConfiguration.min)); buffer.push(lowByte(servoConfiguration.max)); buffer.push(highByte(servoConfiguration.max)); buffer.push(lowByte(servoConfiguration.middle)); buffer.push(highByte(servoConfiguration.middle)); buffer.push(lowByte(servoConfiguration.rate)); buffer.push(servoConfiguration.angleAtMin); buffer.push(servoConfiguration.angleAtMax); var out = servoConfiguration.indexOfChannelToForward; if (out == undefined) { out = 255; // Cleanflight defines "CHANNEL_FORWARDING_DISABLED" as "(uint8_t)0xFF" } buffer.push(out); buffer.push(specificByte(servoConfiguration.reversedInputSources, 0)); buffer.push(specificByte(servoConfiguration.reversedInputSources, 1)); buffer.push(specificByte(servoConfiguration.reversedInputSources, 2)); buffer.push(specificByte(servoConfiguration.reversedInputSources, 3)); // prepare for next iteration servoIndex++; if (servoIndex == SERVO_CONFIG.length) { nextFunction = onCompleteCallback; } } MSP.send_message(MSPCodes.MSP_SET_SERVO_CONFIGURATION, buffer, false, nextFunction); } function send_channel_forwarding() { var buffer = []; for (var i = 0; i < SERVO_CONFIG.length; i++) { var out = SERVO_CONFIG[i].indexOfChannelToForward; if (out == undefined) { out = 255; // Cleanflight defines "CHANNEL_FORWARDING_DISABLED" as "(uint8_t)0xFF" } buffer.push(out); } nextFunction = onCompleteCallback; MSP.send_message(MSPCodes.MSP_SET_CHANNEL_FORWARDING, buffer, false, nextFunction); } }; MspHelper.prototype.sendModeRanges = function(onCompleteCallback) { var nextFunction = send_next_mode_range; var modeRangeIndex = 0; if (MODE_RANGES.length == 0) { onCompleteCallback(); } else { send_next_mode_range(); } function send_next_mode_range() { var modeRange = MODE_RANGES[modeRangeIndex]; var buffer = []; buffer.push(modeRangeIndex); buffer.push(modeRange.id); buffer.push(modeRange.auxChannelIndex); buffer.push((modeRange.range.start - 900) / 25); buffer.push((modeRange.range.end - 900) / 25); // prepare for next iteration modeRangeIndex++; if (modeRangeIndex == MODE_RANGES.length) { nextFunction = onCompleteCallback; } MSP.send_message(MSPCodes.MSP_SET_MODE_RANGE, buffer, false, nextFunction); } }; MspHelper.prototype.sendAdjustmentRanges = function(onCompleteCallback) { var nextFunction = send_next_adjustment_range; var adjustmentRangeIndex = 0; if (ADJUSTMENT_RANGES.length == 0) { onCompleteCallback(); } else { send_next_adjustment_range(); } function send_next_adjustment_range() { var adjustmentRange = ADJUSTMENT_RANGES[adjustmentRangeIndex]; var buffer = []; buffer.push(adjustmentRangeIndex); buffer.push(adjustmentRange.slotIndex); buffer.push(adjustmentRange.auxChannelIndex); buffer.push((adjustmentRange.range.start - 900) / 25); buffer.push((adjustmentRange.range.end - 900) / 25); buffer.push(adjustmentRange.adjustmentFunction); buffer.push(adjustmentRange.auxSwitchChannelIndex); // prepare for next iteration adjustmentRangeIndex++; if (adjustmentRangeIndex == ADJUSTMENT_RANGES.length) { nextFunction = onCompleteCallback; } MSP.send_message(MSPCodes.MSP_SET_ADJUSTMENT_RANGE, buffer, false, nextFunction); } }; MspHelper.prototype.sendLedStripConfig = function(onCompleteCallback) { var nextFunction = send_next_led_strip_config; var ledIndex = 0; if (LED_STRIP.length == 0) { onCompleteCallback(); } else { send_next_led_strip_config(); } function send_next_led_strip_config() { var led = LED_STRIP[ledIndex]; var ledDirectionLetters = ['n', 'e', 's', 'w', 'u', 'd']; // in LSB bit order var ledFunctionLetters = ['i', 'w', 'f', 'a', 't', 'r', 'c', 'g', 's', 'b', 'l']; // in LSB bit order var ledBaseFunctionLetters = ['c', 'f', 'a', 'l', 's', 'g', 'r']; // in LSB bit var ledOverlayLetters = ['t', 'o', 'b', 'n', 'i', 'w']; // in LSB bit /* var led = { directions: directions, functions: functions, x: data.getUint8(offset++, 1), y: data.getUint8(offset++, 1), color: data.getUint8(offset++, 1) }; */ var buffer = []; buffer.push(ledIndex); if (semver.lt(CONFIG.apiVersion, "1.20.0")) { var directionMask = 0; for (var directionLetterIndex = 0; directionLetterIndex < led.directions.length; directionLetterIndex++) { var bitIndex = ledDirectionLetters.indexOf(led.directions[directionLetterIndex]); if (bitIndex >= 0) { directionMask = bit_set(directionMask, bitIndex); } } buffer.push(specificByte(directionMask, 0)); buffer.push(specificByte(directionMask, 1)); var functionMask = 0; for (var functionLetterIndex = 0; functionLetterIndex < led.functions.length; functionLetterIndex++) { var bitIndex = ledFunctionLetters.indexOf(led.functions[functionLetterIndex]); if (bitIndex >= 0) { functionMask = bit_set(functionMask, bitIndex); } } buffer.push(specificByte(functionMask, 0)); buffer.push(specificByte(functionMask, 1)); buffer.push(led.x); buffer.push(led.y); buffer.push(led.color); } else { var mask = 0; mask |= (led.y << 0); mask |= (led.x << 4); for (var functionLetterIndex = 0; functionLetterIndex < led.functions.length; functionLetterIndex++) { var fnIndex = ledBaseFunctionLetters.indexOf(led.functions[functionLetterIndex]); if (fnIndex >= 0) { mask |= (fnIndex << 8); break; } } for (var overlayLetterIndex = 0; overlayLetterIndex < led.functions.length; overlayLetterIndex++) { var bitIndex = ledOverlayLetters.indexOf(led.functions[overlayLetterIndex]); if (bitIndex >= 0) { mask |= bit_set(mask, bitIndex + 12); } } mask |= (led.color << 18); for (var directionLetterIndex = 0; directionLetterIndex < led.directions.length; directionLetterIndex++) { var bitIndex = ledDirectionLetters.indexOf(led.directions[directionLetterIndex]); if (bitIndex >= 0) { mask |= bit_set(mask, bitIndex + 22); } } mask |= (0 << 28); // parameters buffer.push(specificByte(mask, 0)); buffer.push(specificByte(mask, 1)); buffer.push(specificByte(mask, 2)); buffer.push(specificByte(mask, 3)); } // prepare for next iteration ledIndex++; if (ledIndex == LED_STRIP.length) { nextFunction = onCompleteCallback; } MSP.send_message(MSPCodes.MSP_SET_LED_STRIP_CONFIG, buffer, false, nextFunction); } } MspHelper.prototype.sendLedStripColors = function(onCompleteCallback) { if (LED_COLORS.length == 0) { onCompleteCallback(); } else { var buffer = []; for (var colorIndex = 0; colorIndex < LED_COLORS.length; colorIndex++) { var color = LED_COLORS[colorIndex]; buffer.push(specificByte(color.h, 0)); buffer.push(specificByte(color.h, 1)); buffer.push(color.s); buffer.push(color.v); } MSP.send_message(MSPCodes.MSP_SET_LED_COLORS, buffer, false, onCompleteCallback); } } MspHelper.prototype.sendLedStripModeColors = function(onCompleteCallback) { var nextFunction = send_next_led_strip_mode_color; var index = 0; if (LED_MODE_COLORS.length == 0) { onCompleteCallback(); } else { send_next_led_strip_mode_color(); } function send_next_led_strip_mode_color() { var buffer = []; var mode_color = LED_MODE_COLORS[index]; buffer.push(mode_color.mode); buffer.push(mode_color.direction); buffer.push(mode_color.color); // prepare for next iteration index++; if (index == LED_MODE_COLORS.length) { nextFunction = onCompleteCallback; } MSP.send_message(MSPCodes.MSP_SET_LED_STRIP_MODECOLOR, buffer, false, nextFunction); } } MspHelper.prototype.serialPortFunctionMaskToFunctions = function(functionMask) { var functions = []; var serialPortFunctions = { 'MSP': 0, 'GPS': 1, 'TELEMETRY_FRSKY': 2, 'TELEMETRY_HOTT': 3, 'TELEMETRY_MSP': 4, 'TELEMETRY_LTM': 4, // LTM replaced MSP 'TELEMETRY_SMARTPORT': 5, 'RX_SERIAL': 6, 'BLACKBOX': 7, 'TELEMETRY_MAVLINK': 8, }; var keys = Object.keys(serialPortFunctions); for (var index = 0; index < keys.length; index++) { var key = keys[index]; var bit = serialPortFunctions[key]; if (bit_check(functionMask, bit)) { functions.push(key); } } return functions; } MspHelper.prototype.serialPortFunctionsToMask = function(functions) { var mask = 0; var serialPortFunctions = { 'MSP': 0, 'GPS': 1, 'TELEMETRY_FRSKY': 2, 'TELEMETRY_HOTT': 3, 'TELEMETRY_MSP': 4, 'TELEMETRY_LTM': 4, // LTM replaced MSP 'TELEMETRY_SMARTPORT': 5, 'RX_SERIAL': 6, 'BLACKBOX': 7, 'TELEMETRY_MAVLINK': 8, }; var keys = Object.keys(serialPortFunctions); for (var index = 0; index < functions.length; index++) { var key = functions[index]; var bitIndex = serialPortFunctions[key]; if (bitIndex >= 0) { mask = bit_set(mask, bitIndex); } } return mask; } MspHelper.prototype.sendRxFailConfig = function(onCompleteCallback) { var nextFunction = send_next_rxfail_config; var rxFailIndex = 0; if (RXFAIL_CONFIG.length == 0) { onCompleteCallback(); } else { send_next_rxfail_config(); } function send_next_rxfail_config() { var rxFail = RXFAIL_CONFIG[rxFailIndex]; var buffer = []; buffer.push(rxFailIndex); buffer.push(rxFail.mode); buffer.push(lowByte(rxFail.value)); buffer.push(highByte(rxFail.value)); // prepare for next iteration rxFailIndex++; if (rxFailIndex == RXFAIL_CONFIG.length) { nextFunction = onCompleteCallback; } MSP.send_message(MSPCodes.MSP_SET_RXFAIL_CONFIG, buffer, false, nextFunction); } } MSP.SDCARD_STATE_NOT_PRESENT = 0; //TODO, move these to better place MSP.SDCARD_STATE_FATAL = 1; MSP.SDCARD_STATE_CARD_INIT = 2; MSP.SDCARD_STATE_FS_INIT = 3; MSP.SDCARD_STATE_READY = 4;