mirror of
https://github.com/Koenkk/zigbee2mqtt.git
synced 2024-11-15 18:08:32 -07:00
483 lines
24 KiB
JavaScript
483 lines
24 KiB
JavaScript
const path = require('path');
|
|
|
|
const data = require('./stub/data');
|
|
const logger = require('./stub/logger');
|
|
const zigbeeHerdsman = require('./stub/zigbeeHerdsman');
|
|
const MQTT = require('./stub/mqtt');
|
|
const settings = require('../lib/util/settings');
|
|
const Controller = require('../lib/controller');
|
|
const flushPromises = require('./lib/flushPromises');
|
|
const zigbeeHerdsmanConverters = require('zigbee-herdsman-converters');
|
|
const stringify = require('json-stable-stringify-without-jsonify');
|
|
const zigbeeOTA = require('zigbee-herdsman-converters/lib/ota/zigbeeOTA');
|
|
|
|
const spyUseIndexOverride = jest.spyOn(zigbeeOTA, 'useIndexOverride');
|
|
|
|
|
|
describe('OTA update', () => {
|
|
let controller;
|
|
|
|
let resetExtension = async () => {
|
|
await controller.enableDisableExtension(false, 'OTAUpdate');
|
|
await controller.enableDisableExtension(true, 'OTAUpdate');
|
|
}
|
|
|
|
const mockClear = (mapped) => {
|
|
mapped.ota.updateToLatest = jest.fn();
|
|
mapped.ota.isUpdateAvailable = jest.fn();
|
|
}
|
|
|
|
beforeAll(async () => {
|
|
data.writeDefaultConfiguration();
|
|
settings.reRead();
|
|
data.writeDefaultConfiguration();
|
|
settings.set(['ota', 'ikea_ota_use_test_url'], true);
|
|
settings.reRead();
|
|
jest.useFakeTimers();
|
|
controller = new Controller(jest.fn(), jest.fn());
|
|
await controller.start();
|
|
await flushPromises();
|
|
});
|
|
|
|
afterEach(async () => {
|
|
settings.set(['ota', 'disable_automatic_update_check'], false);
|
|
jest.runOnlyPendingTimers();
|
|
});
|
|
|
|
afterAll(async () => {
|
|
jest.useRealTimers();
|
|
});
|
|
|
|
beforeEach(async () => {
|
|
const extension = controller.extensions.find((e) => e.constructor.name === 'OTAUpdate');
|
|
extension.lastChecked = {};
|
|
extension.inProgress = new Set();
|
|
controller.state.state = {};
|
|
MQTT.publish.mockClear();
|
|
});
|
|
|
|
it('Should OTA update a device', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
let count = 0;
|
|
endpoint.read.mockImplementation(() => {
|
|
count++;
|
|
return {swBuildId: count, dateCode: '2019010' + count}
|
|
});
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
logger.info.mockClear();
|
|
device.save.mockClear();
|
|
mapped.ota.updateToLatest.mockImplementationOnce((a, b, onUpdate) => {
|
|
onUpdate(0, null);
|
|
onUpdate(10, 3600.2123);
|
|
});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/update', 'bulb');
|
|
await flushPromises();
|
|
expect(logger.info).toHaveBeenCalledWith(`Updating 'bulb' to latest firmware`);
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(0);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledWith(device, logger, expect.any(Function));
|
|
expect(logger.info).toHaveBeenCalledWith(`Update of 'bulb' at 0.00%`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Update of 'bulb' at 10.00%, ≈ 60 minutes remaining`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Finished update of 'bulb'`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Device 'bulb' was updated from '{"dateCode":"20190101","softwareBuildID":1}' to '{"dateCode":"20190103","softwareBuildID":3}'`);
|
|
expect(device.save).toHaveBeenCalledTimes(2);
|
|
expect(endpoint.read).toHaveBeenCalledWith('genBasic', ['dateCode', 'swBuildId'], {'sendWhen': 'immediate'});
|
|
expect(endpoint.read).toHaveBeenCalledWith('genBasic', ['dateCode', 'swBuildId'], {'sendWhen': 'active'});
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":false,"update":{"state":"updating","progress":0}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":false,"update":{"state":"updating","progress":10,"remaining":3600}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":false,"update":{"state":"idle"}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/update',
|
|
stringify({"data":{"from":{"date_code":"20190101","software_build_id":1},"id":"bulb","to":{"date_code":"20190103","software_build_id":3}},"status":"ok"}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/devices',
|
|
expect.any(String),
|
|
{ retain: true, qos: 0 },
|
|
expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should handle when OTA update fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
endpoint.read.mockImplementation(() => {return {swBuildId: 1, dateCode: '2019010'}});
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
device.save.mockClear();
|
|
mapped.ota.updateToLatest.mockImplementationOnce((a, b, onUpdate) => {
|
|
throw new Error('Update failed');
|
|
});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/update', stringify({id: "bulb"}));
|
|
await flushPromises();
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":true,"update":{"state":"available"}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/update',
|
|
stringify({"data":{"id": "bulb"},"status":"error","error":"Update of 'bulb' failed (Update failed)"}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should be able to check if OTA update is available', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(false);
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "bulb");
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "bulb","updateAvailable":false},"status":"ok"}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
|
|
MQTT.publish.mockClear();
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(true);
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "bulb");
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(2);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "bulb","updateAvailable":true},"status":"ok"}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should handle if OTA update check fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
mapped.ota.isUpdateAvailable.mockImplementationOnce(() => {throw new Error('RF singals disturbed because of dogs barking')});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "bulb");
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "bulb"},"status":"error","error": `Failed to check if update available for 'bulb' (RF singals disturbed because of dogs barking)`}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should fail when device does not exist', async () => {
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "not_existing_deviceooo");
|
|
await flushPromises();
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "not_existing_deviceooo"},"status":"error","error": `Device 'not_existing_deviceooo' does not exist`}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should not check for OTA when device does not support it', async () => {
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "dimmer_wall_switch");
|
|
await flushPromises();
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "dimmer_wall_switch"},"status":"error","error": `Device 'dimmer_wall_switch' does not support OTA updates`}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should refuse to check/update when already in progress', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
|
|
mapped.ota.isUpdateAvailable.mockImplementationOnce(() => {
|
|
return new Promise((resolve, reject) => {setTimeout(() => resolve(), 99999)})
|
|
});
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "bulb");
|
|
await flushPromises();
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/check', "bulb");
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
jest.runOnlyPendingTimers();
|
|
await flushPromises();
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/check',
|
|
stringify({"data":{"id": "bulb"},"status":"error","error": `Update or check for update already in progress for 'bulb'`}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Shouldnt crash when read modelID before/after OTA update fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
endpoint.read.mockImplementation(() => {throw new Error('Failed!')});
|
|
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
MQTT.events.message('zigbee2mqtt/bridge/request/device/ota_update/update', "bulb");
|
|
await flushPromises();
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bridge/response/device/ota_update/update',
|
|
stringify({"data":{"id":"bulb","from":null,"to":null},"status":"ok"}),
|
|
{retain: false, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should check for update when device requests it', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
device.endpoints[0].commandResponse.mockClear();
|
|
const data = {imageType: 12382};
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(true);
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
logger.info.mockClear();
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledWith(device, logger, {"imageType": 12382});
|
|
expect(logger.info).toHaveBeenCalledWith(`Update available for 'bulb'`);
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledTimes(1);
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledWith("genOta", "queryNextImageResponse", {"status": 0x98});
|
|
|
|
// Should not request again when device asks again after a short time
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
|
|
logger.info.mockClear();
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(false);
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(logger.info).not.toHaveBeenCalledWith(`Update available for 'bulb'`);
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":true,"update":{"state":"available"}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should respond with NO_IMAGE_AVAILABLE when update available request fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
device.endpoints[0].commandResponse.mockClear();
|
|
const data = {imageType: 12382};
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
mapped.ota.isUpdateAvailable.mockImplementationOnce(() => {throw new Error('Nothing to find here')})
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
logger.info.mockClear();
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledWith(device, logger, {"imageType": 12382});
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledTimes(1);
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledWith("genOta", "queryNextImageResponse", {"status": 0x98});
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":false,"update":{"state":"idle"}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should check for update when device requests it and it is not available', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
device.endpoints[0].commandResponse.mockClear();
|
|
const data = {imageType: 12382};
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(false);
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
logger.info.mockClear();
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledWith(device, logger, {"imageType": 12382});
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledTimes(1);
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledWith("genOta", "queryNextImageResponse", {"status": 0x98});
|
|
expect(MQTT.publish).toHaveBeenCalledWith(
|
|
'zigbee2mqtt/bulb',
|
|
stringify({"update_available":false,"update":{"state":"idle"}}),
|
|
{retain: true, qos: 0}, expect.any(Function)
|
|
);
|
|
});
|
|
|
|
it('Should not check for update when device requests it and disable_automatic_update_check is set to true', async () => {
|
|
settings.set(['ota', 'disable_automatic_update_check'], true);
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const data = {imageType: 12382};
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(true);
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
logger.info.mockClear();
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(0);
|
|
});
|
|
|
|
it('Should respond with NO_IMAGE_AVAILABLE when not supporting OTA', async () => {
|
|
const device = zigbeeHerdsman.devices.HGZB04D;
|
|
const data = {imageType: 12382};
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledTimes(1);
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledWith("genOta", "queryNextImageResponse", {"status": 152});
|
|
});
|
|
|
|
it('Shouldnt respond with NO_IMAGE_AVAILABLE when not supporting OTA and device has no OTA endpoint', async () => {
|
|
const device = zigbeeHerdsman.devices.SV01;
|
|
const data = {imageType: 12382};
|
|
const payload = {data, cluster: 'genOta', device, endpoint: device.getEndpoint(1), type: 'commandQueryNextImageRequest', linkquality: 10};
|
|
logger.error.mockClear();
|
|
await zigbeeHerdsman.events.message(payload);
|
|
await flushPromises();
|
|
expect(device.endpoints[0].commandResponse).toHaveBeenCalledTimes(0);
|
|
expect(logger.error).toHaveBeenCalledTimes(0);
|
|
});
|
|
|
|
it('Legacy api: Should OTA update a device', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
let count = 0;
|
|
endpoint.read.mockImplementation(() => {
|
|
count++;
|
|
return {swBuildId: count, dateCode: '2019010' + count}
|
|
});
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
logger.info.mockClear();
|
|
logger.error.mockClear();
|
|
device.save.mockClear();
|
|
mapped.ota.updateToLatest.mockImplementationOnce((a, b, onUpdate) => {
|
|
onUpdate(0, null);
|
|
onUpdate(10, 3600);
|
|
});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/update', 'bulb');
|
|
await flushPromises();
|
|
expect(logger.info).toHaveBeenCalledWith(`Updating 'bulb' to latest firmware`);
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(0);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledWith(device, logger, expect.any(Function));
|
|
expect(logger.info).toHaveBeenCalledWith(`Update of 'bulb' at 0.00%`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Update of 'bulb' at 10.00%, ≈ 60 minutes remaining`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Finished update of 'bulb'`);
|
|
expect(logger.info).toHaveBeenCalledWith(`Device 'bulb' was updated from '{"dateCode":"20190101","softwareBuildID":1}' to '{"dateCode":"20190103","softwareBuildID":3}'`);
|
|
expect(logger.error).toHaveBeenCalledTimes(0);
|
|
expect(device.save).toHaveBeenCalledTimes(2);
|
|
expect(endpoint.read).toHaveBeenCalledWith('genBasic', ['dateCode', 'swBuildId'], {'sendWhen': 'immediate'});
|
|
});
|
|
|
|
it('Legacy api: Should handle when OTA update fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
endpoint.read.mockImplementation(() => {return {swBuildId: 1, dateCode: '2019010'}});
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
logger.info.mockClear();
|
|
logger.error.mockClear();
|
|
device.save.mockClear();
|
|
mapped.ota.updateToLatest.mockImplementationOnce((a, b, onUpdate) => {
|
|
throw new Error('Update failed');
|
|
});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/update', 'bulb');
|
|
await flushPromises();
|
|
expect(logger.error).toHaveBeenCalledTimes(1);
|
|
expect(logger.error).toHaveBeenCalledWith(`Update of 'bulb' failed (Update failed)`);
|
|
});
|
|
|
|
it('Legacy api: Should be able to check if OTA update is available', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
|
|
logger.info.mockClear();
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(false);
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/check', 'bulb');
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(logger.info).toHaveBeenCalledWith(`No update available for 'bulb'`);
|
|
|
|
logger.info.mockClear();
|
|
mapped.ota.isUpdateAvailable.mockReturnValueOnce(true);
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/check', 'bulb');
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(2);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(logger.info).toHaveBeenCalledWith(`Update available for 'bulb'`);
|
|
});
|
|
|
|
it('Legacy api: Should handle if OTA update check fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
logger.error.mockClear();
|
|
mapped.ota.isUpdateAvailable.mockImplementationOnce(() => {throw new Error('RF singals disturbed because of dogs barking')});
|
|
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/check', 'bulb');
|
|
await flushPromises();
|
|
expect(mapped.ota.isUpdateAvailable).toHaveBeenCalledTimes(1);
|
|
expect(mapped.ota.updateToLatest).toHaveBeenCalledTimes(0);
|
|
expect(logger.error).toHaveBeenCalledWith(`Failed to check if update available for 'bulb' (RF singals disturbed because of dogs barking)`);
|
|
});
|
|
|
|
it('Legacy api: Should not check for OTA when device does not support it', async () => {
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/check', 'dimmer_wall_switch');
|
|
await flushPromises();
|
|
expect(logger.error).toHaveBeenCalledWith(`Device 'dimmer_wall_switch' does not support OTA updates`);
|
|
});
|
|
|
|
it('Legacy api: Shouldnt crash when read modelID after OTA update fails', async () => {
|
|
const device = zigbeeHerdsman.devices.bulb;
|
|
const endpoint = device.endpoints[0];
|
|
let count = 0;
|
|
endpoint.read.mockImplementation(() => {
|
|
if (count === 1) throw new Error('Failed!')
|
|
count++;
|
|
return {swBuildId: 1, dateCode: '2019010'}
|
|
});
|
|
|
|
const mapped = zigbeeHerdsmanConverters.findByDevice(device)
|
|
mockClear(mapped);
|
|
logger.info.mockClear();
|
|
MQTT.events.message('zigbee2mqtt/bridge/ota_update/update', 'bulb');
|
|
await flushPromises();
|
|
expect(logger.info).toHaveBeenCalledWith(`Finished update of 'bulb'`);
|
|
});
|
|
|
|
it('Set zigbee_ota_override_index_location', async () => {
|
|
settings.set(['ota', 'zigbee_ota_override_index_location'], 'local.index.json');
|
|
await resetExtension();
|
|
expect(spyUseIndexOverride).toHaveBeenCalledWith(path.join(data.mockDir, 'local.index.json'));
|
|
spyUseIndexOverride.mockClear();
|
|
|
|
settings.set(['ota', 'zigbee_ota_override_index_location'], 'http://my.site/index.json');
|
|
await resetExtension();
|
|
expect(spyUseIndexOverride).toHaveBeenCalledWith('http://my.site/index.json');
|
|
spyUseIndexOverride.mockClear();
|
|
});
|
|
});
|