Legion::Extensions::Esphome

A Legion Extension to process messages coming from the ESPHome Project

Installation

Add this line to your application's Gemfile:

gem 'lex-esphome'

And then execute:

$ bundle install

Or install it yourself as:

$ gem install lex-esphome

Adding to Legion

You can manually install with a gem install lex-esphome command or by adding it into your settings with something like this

{
  "extensions": {
    "esphome": {
      "enabled": true, "workers": 1
    }
  }
}

Example shoveler definition to get data over from / to /legion when using RabbitMQ + MQTT

{
  "permissions": [{
    "user": "legion",
    "vhost": "/",
    "read": "to_legion"
  }],
  "parameters": [{
    "value": {
      "dest-exchange": "esphome",
      "dest-protocol": "amqp091",
      "dest-uri": "amqp://legion@/legion",
      "src-delete-after": "never",
      "src-protocol": "amqp091",
      "src-queue": "to_legion",
      "src-uri": "amqp://"
    },
    "vhost": "legion",
    "component": "shovel",
    "name": "ESPHome -> Legion"
  }],
    "queues": [{
      "name": "to_legion",
      "vhost": "/",
      "durable": true,
    }],
    "bindings": [{
      "source": "amq.topic",
      "vhost": "/",
      "destination": "to_legion",
      "destination_type": "queue",
      "routing_key": "#.sensor.#.state",
      "arguments": {}
    }, {
      "source": "amq.topic",
      "vhost": "/",
      "destination": "to_legion",
      "destination_type": "queue",
      "routing_key": "esphome.logs.#",
      "arguments": {}
    }]
}

Usage

There are two passive runners within this Lex. One to process log entries, the other to process sensor data

runner	function	value	routing key	timestamp_in_ms
Logs	process	required	required	X
Sensors	process	required	required	optional

Relationship examples

Send the data to an InfluxDB instance. Requires Legion::Extensions::Influxdb

{
  "name": "esphome sensor to influxdb",
  "enabled": 1,
  "transformation": "{
                        "host": "localhost",
                        "port": 8086,
                        "database": "esphome",
                        "metrics": "{
                          \"values\":{\"<%= results[:sub_type] %>\":<%= results[:value].to_f %>},
                          \"tags\":{\"name\":\"<%= results[:name] %>\", \"type\": \"<%= results[:type] %>\",\"sub_type\": \"<%= results[:sub_type] %>\",\"item\": \"<%= results[:item] %>\"}
                        }",
                     }"
}

Development

After checking out the repo, run bin/setup to install dependencies. Then, run rake spec to run the tests. You can also run bin/console for an interactive prompt that will allow you to experiment.

To install this gem onto your local machine, run bundle exec rake install. To release a new version, update the version number in version.rb, and then run bundle exec rake release, which will create a git tag for the version, push git commits and tags, and push the .gem file to rubygems.org.