import axios from 'axios';
import awsIot from 'aws-iot-device-sdk';

// Retrieve the jwt access token for the user to be able to authorize ourselves.
axios
.post('/auth/jwt', {
email: 'email@example.com',
password: 'Longer passwords are more secure than a horse',
})
.then((res) => {
// User token received.
// This can be saved on the client to use in multiple api calls,
// but in this example it is only used for the next one.
const userToken = res.data.token;

// Retrieve the access token for the MQTT data stream.
return axios.get(`/api/companies/r2d2i5b43/iotAccess`, {
headers: {
Authorization: 'JWT ' + userToken,
},
});
})
.then((res) => {
// These response hold the access keys and info about where to connect.
const iotCredentials = res.data;

// Connect to the MQTT stream.
const client = awsIot.device(iotCredentials);

// Listen to messages from all the ports of the company.
// The # is a catch all and can be placed in other parts of the topic too.
client.subscribe('/ports/r2d2i5b43/#');

// This is the function that runs when messages are received.
client.on('message', (topic, message) => {
// message is a Uint8Array, use toString to get it as an actual string.
// The string should be a JSON, parse it into object form.
const payload = JSON.parse(message.toString());

// In this example the message is printed to the console,
// but this is where to add your code that operates on the MQTT stream.
console.log(topic, payload);
});

// When a connection fails.
client.on('error', (error) => {
// In this example the error is simply printed to console.
console.warn(error);
});

// See more events here: https://github.com/mqttjs/MQTT.js/blob/master/README.md#client

// Publish an action telling a port to change light level:
client.publish('/action/r2d2i5b43///', JSON.stringify({
id: '',
data: {
portId: '',
device: {
lamp: {
level: 10,
},
},
},
}));

// When the connection is no longer needed, make sure to end it:
// client.end();
});