jybe2R63

1const getIotDevice = ({ IdentityId, Credentials }) => {
2		const device = new AwsIot.device({
3			protocol: 'wss',
4			secretKey: Credentials.secretAccessKey,
5			accessKeyId: Credentials.accessKeyId,
6			clientId: IdentityId,
7			host: config.aws.mqttHost,
8			sessionToken: Credentials.sessionToken,
9			clean: true,
10			resubscribe: true
11		});
12		console.log('getIotDevice', state);
13		device.on('connect', onConnect);
14		device.on('message', onMessage);
15		device.on('error', onError);
16		device.on('offline', onDisconnect);
17		device.on('close', onClose);
18		return device;
19	};
20
21/*
22	function onMessage(topic, message) {
23		let msg;
24		try {
25			msg = JSON.parse(message.toString());
26		} catch (err) {
27			msg = message.toString();
28		}
29		console.log('Msg', msg, state);
30	}
31*/
32
33const onMessage = (topic, message) => {
34		let msg;
35		try {
36			msg = JSON.parse(message.toString());
37		} catch (err) {
38			msg = message.toString();
39		}
40		console.log('Msg', msg, state);
41	}