Compare commits
16 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9917b41381 | ||
|
|
d23d12fbb2 | ||
|
|
948a8b565d | ||
|
|
479bd008b6 | ||
|
|
d67afe7eda | ||
|
|
9950622314 | ||
|
|
72decbcc05 | ||
|
|
e75365fc26 | ||
|
|
4562f5d31d | ||
|
|
5623e60da7 | ||
|
|
93f239feeb | ||
|
|
cbb3b4734b | ||
|
|
bd18f74507 | ||
|
|
cfa7b00135 | ||
|
|
f10c04b006 | ||
|
|
5014f702fd |
8
.github/workflows/publish.yml
vendored
8
.github/workflows/publish.yml
vendored
@@ -12,7 +12,7 @@ jobs:
|
||||
runs-on: ubuntu-20.04
|
||||
steps:
|
||||
- name: Checkout code
|
||||
uses: actions/checkout@v2.4.0
|
||||
uses: actions/checkout@v3
|
||||
- name: Bump version
|
||||
uses: remorses/bump-version@js
|
||||
id: version
|
||||
@@ -21,7 +21,7 @@ jobs:
|
||||
env:
|
||||
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||
- name: Checkout code
|
||||
uses: actions/checkout@v2.4.0
|
||||
uses: actions/checkout@v3
|
||||
with:
|
||||
ref: main
|
||||
- name: Set up QEMU
|
||||
@@ -31,12 +31,12 @@ jobs:
|
||||
- name: Set up Docker Buildx
|
||||
uses: docker/setup-buildx-action@v1.6.0
|
||||
- name: Login to DockerHub
|
||||
uses: docker/login-action@v1.12.0
|
||||
uses: docker/login-action@v1.14.1
|
||||
with:
|
||||
username: ${{ secrets.DOCKER_USERNAME }}
|
||||
password: ${{ secrets.DOCKER_PASSWORD }}
|
||||
- name: Build and push
|
||||
uses: docker/build-push-action@v2.7.0
|
||||
uses: docker/build-push-action@v2.10.0
|
||||
with:
|
||||
context: .
|
||||
push: true
|
||||
|
||||
12
README.md
12
README.md
@@ -20,7 +20,7 @@ It supports the following environment variables:
|
||||
- `MQTT_TLS_KEY` (required if using TLS) - path to the private key
|
||||
- `HOME_ASSISTANT` (optional, default = false)
|
||||
- `HOME_ASSISTANT_PREFIX` (optional, default = 'homeassistant')
|
||||
- `STORAGE_POLL_INTERVAL` (optional, default = 3600) - how often to fetch storage data (in seconds)
|
||||
- `STORAGE_POLL_INTERVAL` (optional, default = 3600) - how often to fetch storage data (in seconds) (set to 0 to disable functionality)
|
||||
- `DEVICE_NAME` (optional) - override the default device name used in the Amcrest app
|
||||
|
||||
It exposes events to the following topics:
|
||||
@@ -70,6 +70,16 @@ The app will not support multiple devices. You can run multiple instances of the
|
||||
|
||||
Docker is the only supported way of deploying the application. The app should run directly via Python but this is not supported.
|
||||
|
||||
### Home Assistant Addons
|
||||
|
||||
There are a couple of Home Assistant Addons that use my code to be able to port this software into Supervised versions of Home Assistant. I do not specifically support the add-ons themselves, only the base software in the original docker format. Please contact the authors of those add-ons for support if using that method.
|
||||
|
||||
https://github.com/ikifar2012/amcrest2mqtt-addon/blob/master/README.md
|
||||
[](https://my.home-assistant.io/redirect/supervisor_add_addon_repository/?repository_url=https%3A%2F%2Fgithub.com%2Fikifar2012%2Fha-addons)
|
||||
|
||||
https://github.com/robsonke/hassio-addons/blob/master/amcrest2mqtt/README.md
|
||||
[](https://my.home-assistant.io/redirect/supervisor_add_addon_repository/?repository_url=https%3A%2F%2Fgithub.com%2Frobsonke%2Fhassio-addons)
|
||||
|
||||
## Buy Me A ~~Coffee~~ Beer 🍻
|
||||
|
||||
A few people have kindly requested a way to donate a small amount of money. If you feel so inclined I've set up a "Buy Me A Coffee"
|
||||
|
||||
@@ -1,3 +1,3 @@
|
||||
amcrest==1.9.3
|
||||
amcrest==1.9.7
|
||||
paho-mqtt==1.6.1
|
||||
python-slugify==5.0.2
|
||||
python-slugify==6.1.1
|
||||
|
||||
@@ -8,6 +8,7 @@ from json import dumps
|
||||
import signal
|
||||
from threading import Timer
|
||||
import ssl
|
||||
import asyncio
|
||||
|
||||
is_exiting = False
|
||||
mqtt_client = None
|
||||
@@ -59,8 +60,8 @@ def mqtt_publish(topic, payload, exit_on_error=True, json=False):
|
||||
)
|
||||
|
||||
if msg.rc == mqtt.MQTT_ERR_SUCCESS:
|
||||
msg.wait_for_publish()
|
||||
return msg
|
||||
msg.wait_for_publish(2)
|
||||
return
|
||||
|
||||
log(f"Error publishing MQTT message: {mqtt.error_string(msg.rc)}", level="ERROR")
|
||||
|
||||
@@ -79,7 +80,6 @@ def exit_gracefully(rc, skip_mqtt=False):
|
||||
|
||||
if mqtt_client is not None and mqtt_client.is_connected() and skip_mqtt == False:
|
||||
mqtt_publish(topics["status"], "offline", exit_on_error=False)
|
||||
mqtt_client.loop_stop(force=True)
|
||||
mqtt_client.disconnect()
|
||||
|
||||
# Use os._exit instead of sys.exit to ensure an MQTT disconnect event causes the program to exit correctly as they
|
||||
@@ -104,14 +104,6 @@ def refresh_storage_sensors():
|
||||
def to_gb(total):
|
||||
return str(round(float(total[0]) / 1024 / 1024 / 1024, 2))
|
||||
|
||||
def ping_camera():
|
||||
Timer(30, ping_camera).start()
|
||||
response = os.system(f"ping -c1 -W100 {amcrest_host} >/dev/null 2>&1")
|
||||
|
||||
if response != 0:
|
||||
log("Ping unsuccessful", level="ERROR")
|
||||
exit_gracefully(1)
|
||||
|
||||
def signal_handler(sig, frame):
|
||||
# exit immediately upon receiving a second SIGINT
|
||||
global is_exiting
|
||||
@@ -162,6 +154,10 @@ try:
|
||||
exit_gracefully(1)
|
||||
|
||||
sw_version = camera.software_information[0].replace("version=", "").strip()
|
||||
build_version = camera.software_information[1].strip()
|
||||
|
||||
amcrest_version = f"{sw_version} ({build_version})"
|
||||
|
||||
if not device_name:
|
||||
device_name = camera.machine_name.replace("name=", "").strip()
|
||||
|
||||
@@ -172,7 +168,7 @@ except AmcrestError as error:
|
||||
|
||||
log(f"Device type: {device_type}")
|
||||
log(f"Serial number: {serial_number}")
|
||||
log(f"Software version: {sw_version}")
|
||||
log(f"Software version: {amcrest_version}")
|
||||
log(f"Device name: {device_name}")
|
||||
|
||||
# MQTT topics
|
||||
@@ -186,7 +182,7 @@ topics = {
|
||||
"storage_used": f"amcrest2mqtt/{serial_number}/storage/used",
|
||||
"storage_used_percent": f"amcrest2mqtt/{serial_number}/storage/used_percent",
|
||||
"storage_total": f"amcrest2mqtt/{serial_number}/storage/total",
|
||||
"home_assistant": {
|
||||
"home_assistant_legacy": {
|
||||
"doorbell": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/{device_slug}_doorbell/config",
|
||||
"human": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/{device_slug}_human/config",
|
||||
"motion": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/{device_slug}_motion/config",
|
||||
@@ -197,6 +193,17 @@ topics = {
|
||||
"host": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/{device_slug}_host/config",
|
||||
"serial_number": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/{device_slug}_serial_number/config",
|
||||
},
|
||||
"home_assistant": {
|
||||
"doorbell": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/doorbell/config",
|
||||
"human": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/human/config",
|
||||
"motion": f"{home_assistant_prefix}/binary_sensor/amcrest2mqtt-{serial_number}/motion/config",
|
||||
"storage_used": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/storage_used/config",
|
||||
"storage_used_percent": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/storage_used_percent/config",
|
||||
"storage_total": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/storage_total/config",
|
||||
"version": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/version/config",
|
||||
"host": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/host/config",
|
||||
"serial_number": f"{home_assistant_prefix}/sensor/amcrest2mqtt-{serial_number}/serial_number/config",
|
||||
},
|
||||
}
|
||||
|
||||
# Connect to MQTT
|
||||
@@ -245,12 +252,15 @@ if home_assistant:
|
||||
"manufacturer": "Amcrest",
|
||||
"model": device_type,
|
||||
"identifiers": serial_number,
|
||||
"sw_version": sw_version,
|
||||
"sw_version": amcrest_version,
|
||||
"via_device": "amcrest2mqtt",
|
||||
},
|
||||
}
|
||||
|
||||
if is_doorbell:
|
||||
doorbell_name = "Doorbell" if device_name == "Doorbell" else f"{device_name} Doorbell"
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["doorbell"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["doorbell"],
|
||||
base_config
|
||||
@@ -259,13 +269,14 @@ if home_assistant:
|
||||
"payload_on": "on",
|
||||
"payload_off": "off",
|
||||
"icon": "mdi:doorbell",
|
||||
"name": f"{device_name} Doorbell",
|
||||
"name": doorbell_name,
|
||||
"unique_id": f"{serial_number}.doorbell",
|
||||
},
|
||||
json=True,
|
||||
)
|
||||
|
||||
if is_ad410:
|
||||
mqtt_publish(topics["home_assistant_legacy"]["human"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["human"],
|
||||
base_config
|
||||
@@ -280,6 +291,7 @@ if home_assistant:
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["motion"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["motion"],
|
||||
base_config
|
||||
@@ -294,6 +306,7 @@ if home_assistant:
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["version"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["version"],
|
||||
base_config
|
||||
@@ -309,6 +322,7 @@ if home_assistant:
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["serial_number"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["serial_number"],
|
||||
base_config
|
||||
@@ -324,6 +338,7 @@ if home_assistant:
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["host"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["host"],
|
||||
base_config
|
||||
@@ -340,6 +355,7 @@ if home_assistant:
|
||||
)
|
||||
|
||||
if storage_poll_interval > 0:
|
||||
mqtt_publish(topics["home_assistant_legacy"]["storage_used_percent"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["storage_used_percent"],
|
||||
base_config
|
||||
@@ -348,12 +364,14 @@ if home_assistant:
|
||||
"unit_of_measurement": "%",
|
||||
"icon": "mdi:micro-sd",
|
||||
"name": f"{device_name} Storage Used %",
|
||||
"object_id": f"{device_slug}_storage_used_percent",
|
||||
"unique_id": f"{serial_number}.storage_used_percent",
|
||||
"entity_category": "diagnostic",
|
||||
},
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["storage_used"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["storage_used"],
|
||||
base_config
|
||||
@@ -368,6 +386,7 @@ if home_assistant:
|
||||
json=True,
|
||||
)
|
||||
|
||||
mqtt_publish(topics["home_assistant_legacy"]["storage_total"], "")
|
||||
mqtt_publish(
|
||||
topics["home_assistant"]["storage_total"],
|
||||
base_config
|
||||
@@ -388,7 +407,7 @@ mqtt_publish(topics["config"], {
|
||||
"version": version,
|
||||
"device_type": device_type,
|
||||
"device_name": device_name,
|
||||
"sw_version": sw_version,
|
||||
"sw_version": amcrest_version,
|
||||
"serial_number": serial_number,
|
||||
"host": amcrest_host,
|
||||
}, json=True)
|
||||
@@ -396,12 +415,11 @@ mqtt_publish(topics["config"], {
|
||||
if storage_poll_interval > 0:
|
||||
refresh_storage_sensors()
|
||||
|
||||
ping_camera()
|
||||
|
||||
log("Listening for events...")
|
||||
|
||||
async def main():
|
||||
try:
|
||||
for code, payload in camera.event_actions("All", retries=5, timeout_cmd=(10.00, 3600)):
|
||||
async for code, payload in camera.async_event_actions("All"):
|
||||
if (is_ad110 and code == "ProfileAlarmTransmit") or (code == "VideoMotion" and not is_ad110):
|
||||
motion_payload = "on" if payload["action"] == "Start" else "off"
|
||||
mqtt_publish(topics["motion"], motion_payload)
|
||||
@@ -416,5 +434,7 @@ try:
|
||||
log(str(payload))
|
||||
|
||||
except AmcrestError as error:
|
||||
log(f"Amcrest error {error}", level="ERROR")
|
||||
log(f"Amcrest error: {error}", level="ERROR")
|
||||
exit_gracefully(1)
|
||||
|
||||
asyncio.run(main())
|
||||
|
||||
Reference in New Issue
Block a user