Raspberry Pi Ant+

sudo apt-get update
sudo apt-get upgrade

sudo apt-get install nodejs npm

pi@powerraspi01:~ $ node -v
v10.15.2

pi@powerraspi01:~ $ npm -v
5.8.0

pi@powerraspi01:~ $ lsusb
Bus 001 Device 004: ID 0fcf:1009 Dynastream Innovations, Inc. ANTUSB-m Stick
Bus 001 Device 003: ID 0424:ec00 Standard Microsystems Corp. SMSC9512/9514 Fast Ethernet Adapter
Bus 001 Device 002: ID 0424:9512 Standard Microsystems Corp. SMC9512/9514 USB Hub
Bus 001 Device 001: ID 1d6b:0002 Linux Foundation 2.0 root hub

sudo nano /etc/udev/rules.d/ant-usb-m.rules

SUBSYSTEM=="usb", ATTRS{idVendor}=="0fcf", ATTRS{idProduct}=="1009", RUN+="/sbin/modprobe usbserial vendor=0x0fcf product=0x1009", MODE="0666", OWNER="pi", GROUP="root"

mkdir npm
cd npm 
mkdir zwiftapp
cd zwiftapp

sudo apt-get install build-essential libudev-dev

npm install
npm install mqtt
npm install ant-plus

sudo nano heartrate_power_mqtt_V2.js

/* Wattwert und Herzfrequenz per ANT+ auslesen und 
   an einen MQTT-Broker senden R.R. 21.11.2019

Script: heartrate_power_mqtt_V2.js
Autor: infinityflow.ch
NODE  Verson: v10.15.2
NPM Version: 5.8.0


zusaetzliche Libarys:

ant-plus https://www.npmjs.com/package/ant-plus
mqtt https://www.npmjs.com/package/mqtt

*/

// Variablen fuer mqtt:

var mqtt = require('mqtt')

// IP des MQTT-Broker anpassen
var client = mqtt.connect('mqtt://10.0.0.21')

// Intervall fuer das Senden der Daten an den MQTT-Broker in ms z.B. alle 10s = 10000
var mqttsendeintervall = setInterval(mqttsend, 10000);

// MQTT Topics fuer den Wattwert und die Herzfrequenz
var topic_watt = "fancontroll/power";
var topic_heartrate = "fancontroll/heartrate";

// Hilfsvariablen fuer das Senden per MQTT
var powermqtt = "0";
var heartratemqtt = "0";

// Variablen fuer mqtt Ende


// Wattwert und Herzfrequenz per ant-plus auslesen:

var Ant = require('ant-plus');

function openStick(stick, stickid) {
        var sensor1 = new Ant.HeartRateSensor(stick);

        var dev_id = 0;

        sensor1.on('hbdata', function(data) {
                console.log(stickid, 'sensor 1: ', data.DeviceID, data.ComputedHeartRate);
                heartratemqtt = data.ComputedHeartRate;
        });

        sensor1.on('attached', function() { console.log(stickid, 'sensor1 attached'); });

        var sensor2 = new Ant.BicyclePowerSensor(stick);

        sensor2.on('powerData', function(data) {
                console.log(stickid, 'sensor 2: ', data.DeviceID, data.Power);
                powermqtt = data.Power;
        });

        sensor2.on('attached', function() { console.log(stickid, 'sensor2 attached'); });


        stick.on('startup', function() {
                console.log(stickid, 'startup');

                console.log(stickid, 'Max channels:', stick.maxChannels);

                sensor1.attach(0, 0);

                sensor2.attach(1, 0);
        });


        function tryOpen(stick) {
                let token = stick.openAsync((err) => {
                        token = null;
                        if (err) {
                                console.error(stickid, err);
                        } else {
                                console.log(stickid, 'Stick found');
                        }
                });

                return token;
        }

tryOpen(stick);

}

openStick(new Ant.GarminStick2(), 1);
openStick(new Ant.GarminStick2(), 2);
openStick(new Ant.GarminStick3(), 3);

openStick(new Ant.GarminStick2(), 4);
openStick(new Ant.GarminStick2(), 5);
openStick(new Ant.GarminStick3(), 6);

// Wattwert und die Herzfrequenz per ant-plus auslesen Ende


// Wattwert und die Herzfrequenz per MQTT an den iobroker senden

function mqttsend() {
        var power_string = powermqtt.toString();
        var heartrate_string = heartratemqtt.toString();
        client.publish(topic_heartrate, heartrate_string);
        client.publish(topic_watt, power_string);
        console.log("Wert der Variable heartrate_string:" ,heartrate_string, "Hz");
        console.log("Wert der Variable power_string:" ,power_string, "Watt");
}

mqttsend();

// Wattwert und die Herzfrequenz per MQTT an den iobroker senden Ende

sudo nano /etc/init.d/power_mqtt

dir="/home/pi/npm/zwiftapp"
cmd="node heartrate_power_mqtt_V2.js"
user="root"

sudo chmod 755 /etc/init.d/power_mqtt

sudo update-rc.d power_mqtt defaults

sudo /etc/init.d/power_mqtt start
sudo /etc/init.d/power_mqtt stop
sudo /etc/init.d/power_mqtt restart