mirror of
https://github.com/jomjol/AI-on-the-edge-device.git
synced 2025-12-08 20:46:52 +03:00
Compare commits
29 Commits
v16.0.0-RC
...
clarify-pa
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
74e150cfab | ||
|
|
b1c65c0a71 | ||
|
|
00091fc3f9 | ||
|
|
69a43fb068 | ||
|
|
82f28cb5bc | ||
|
|
34818c0dc1 | ||
|
|
0b3a6e1057 | ||
|
|
f06ef7b80e | ||
|
|
962a674058 | ||
|
|
c57cd83948 | ||
|
|
6991c41060 | ||
|
|
8bb274cd84 | ||
|
|
168ec5b485 | ||
|
|
7a0a34e32e | ||
|
|
64bf79b288 | ||
|
|
61085d3861 | ||
|
|
8494f36069 | ||
|
|
3e67aeec0d | ||
|
|
e85e92762e | ||
|
|
eb9bf3c7c1 | ||
|
|
f542d842cf | ||
|
|
5bbc2f3da5 | ||
|
|
2831478e02 | ||
|
|
1e0cdfaba1 | ||
|
|
bfebcd5d15 | ||
|
|
cf96d49bd0 | ||
|
|
94a53b38b8 | ||
|
|
00ac2130c2 | ||
|
|
cd1165e547 |
30
.github/workflows/build.yaml
vendored
30
.github/workflows/build.yaml
vendored
@@ -1,6 +1,10 @@
|
|||||||
name: Build and Pack
|
name: Build and Pack
|
||||||
|
|
||||||
on: [push, pull_request]
|
on:
|
||||||
|
push:
|
||||||
|
pull_request:
|
||||||
|
release:
|
||||||
|
types: [released] # Only trigger on published releases (not drafts or pre-released)
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
#########################################################################################
|
#########################################################################################
|
||||||
@@ -84,6 +88,7 @@ jobs:
|
|||||||
cd ../..
|
cd ../..
|
||||||
|
|
||||||
cp -r ./sd-card/html/* ./html/
|
cp -r ./sd-card/html/* ./html/
|
||||||
|
rm -f ./html/edit_config_template.html # Remove the config page template, it is no longer needed
|
||||||
|
|
||||||
echo "Replacing variables..."
|
echo "Replacing variables..."
|
||||||
cd html
|
cd html
|
||||||
@@ -285,8 +290,9 @@ jobs:
|
|||||||
rm -rf ./sd-card/html
|
rm -rf ./sd-card/html
|
||||||
rm -rf ./sd-card/demo
|
rm -rf ./sd-card/demo
|
||||||
cp -r ./html ./sd-card/ # Overwrite the Web UI with the preprocessed files
|
cp -r ./html ./sd-card/ # Overwrite the Web UI with the preprocessed files
|
||||||
|
rm -f ./sd-card/Readme.md
|
||||||
cp -r ./demo ./sd-card/
|
cp -r ./demo ./sd-card/
|
||||||
cd sd-card; zip -r ../manual_setup/sd-card.zip *; cd ..
|
cd sd-card; rm -rf html/param-tooltips; zip -r ../manual_setup/sd-card.zip *; cd ..
|
||||||
cd ./manual_setup
|
cd ./manual_setup
|
||||||
|
|
||||||
- name: Upload manual_setup.zip artifact (Firmware + Bootloader + Partitions + Web UI)
|
- name: Upload manual_setup.zip artifact (Firmware + Bootloader + Partitions + Web UI)
|
||||||
@@ -302,7 +308,7 @@ jobs:
|
|||||||
prepare-release:
|
prepare-release:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
needs: [pack-for-update, pack-for-manual_setup, pack-for-remote_setup]
|
needs: [pack-for-update, pack-for-manual_setup, pack-for-remote_setup]
|
||||||
if: startsWith(github.ref, 'refs/tags/')
|
if: github.event_name == 'release' # Only run when the trigger is a release
|
||||||
|
|
||||||
# Sets permissions of the GITHUB_TOKEN to allow updating the branches
|
# Sets permissions of the GITHUB_TOKEN to allow updating the branches
|
||||||
permissions:
|
permissions:
|
||||||
@@ -404,7 +410,7 @@ jobs:
|
|||||||
#########################################################################################
|
#########################################################################################
|
||||||
# Make sure to also update update-webinstaller.yml!
|
# Make sure to also update update-webinstaller.yml!
|
||||||
update-web-installer:
|
update-web-installer:
|
||||||
if: github.event_name == 'release' && github.event.action == 'published' # Only run on release but not on prerelease
|
if: github.event_name == 'release' # Only run when the trigger is a release
|
||||||
needs: [prepare-release]
|
needs: [prepare-release]
|
||||||
environment:
|
environment:
|
||||||
name: github-pages
|
name: github-pages
|
||||||
@@ -433,22 +439,22 @@ jobs:
|
|||||||
- name: Add binary to Web Installer and update manifest
|
- name: Add binary to Web Installer and update manifest
|
||||||
run: |
|
run: |
|
||||||
echo "Updating Web installer to use firmware from ${{ steps.last_release.outputs.tag_name }}..."
|
echo "Updating Web installer to use firmware from ${{ steps.last_release.outputs.tag_name }}..."
|
||||||
rm -f docs/binary/firmware.bin
|
rm -f webinstaller/binary/firmware.bin
|
||||||
wget ${{ github.server_url }}/${{ github.repository }}/releases/download/${{ steps.last_release.outputs.tag_name }}/AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
wget ${{ github.server_url }}/${{ github.repository }}/releases/download/${{ steps.last_release.outputs.tag_name }}/AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
||||||
unzip AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
unzip AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
||||||
cp -f firmware.bin docs/binary/firmware.bin
|
cp -f firmware.bin webinstaller/binary/firmware.bin
|
||||||
echo "Updating index and manifest file..."
|
echo "Updating index and manifest file..."
|
||||||
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' docs/index.html
|
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' webinstaller/index.html
|
||||||
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' docs/manifest.json
|
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' webinstaller/manifest.json
|
||||||
|
|
||||||
- name: Setup Pages
|
- name: Setup Pages
|
||||||
uses: actions/configure-pages@v4
|
uses: actions/configure-pages@v5
|
||||||
|
|
||||||
- name: Upload artifact
|
- name: Upload artifact
|
||||||
uses: actions/upload-pages-artifact@v2
|
uses: actions/upload-pages-artifact@v3
|
||||||
with:
|
with:
|
||||||
path: 'docs'
|
path: 'webinstaller'
|
||||||
|
|
||||||
- name: Deploy to GitHub Pages
|
- name: Deploy to GitHub Pages
|
||||||
id: deployment
|
id: deployment
|
||||||
uses: actions/deploy-pages@v3 # Note: v4 does not work!
|
uses: actions/deploy-pages@v4.0.5 # Note: v4 does not work!
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
# This updates the Web Installer with the files from the docs folder and the binary of the latest release
|
# This updates the Web Installer with the files from the webinstaller folder and the binary of the latest release
|
||||||
# it only gets run on:
|
# it only gets run on:
|
||||||
# - Manually triggered
|
# - Manually triggered
|
||||||
# Make sure to also update the lower part of build.yml!
|
# Make sure to also update the lower part of build.yml!
|
||||||
@@ -11,7 +11,7 @@ on:
|
|||||||
# branches:
|
# branches:
|
||||||
# - rolling
|
# - rolling
|
||||||
# paths:
|
# paths:
|
||||||
# - docs # The path filter somehow does not work, so lets run it on every change to rolling
|
# - webinstaller # The path filter somehow does not work, so lets run it on every change to rolling
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
manually-update-web-installer:
|
manually-update-web-installer:
|
||||||
@@ -42,13 +42,13 @@ jobs:
|
|||||||
- name: Add binary to Web Installer and update manifest
|
- name: Add binary to Web Installer and update manifest
|
||||||
run: |
|
run: |
|
||||||
echo "Updating Web installer to use firmware from ${{ steps.last_release.outputs.tag_name }}..."
|
echo "Updating Web installer to use firmware from ${{ steps.last_release.outputs.tag_name }}..."
|
||||||
rm -f docs/binary/firmware.bin
|
rm -f webinstaller/binary/firmware.bin
|
||||||
wget https://github.com/jomjol/AI-on-the-edge-device/releases/download/${{ steps.last_release.outputs.tag_name }}/AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
wget ${{ github.server_url }}/${{ github.repository }}/releases/download/${{ steps.last_release.outputs.tag_name }}/AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
||||||
unzip AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
unzip AI-on-the-edge-device__update__${{ steps.last_release.outputs.tag_name }}.zip
|
||||||
cp -f firmware.bin docs/binary/firmware.bin
|
cp -f firmware.bin webinstaller/binary/firmware.bin
|
||||||
echo "Updating index and manifest file..."
|
echo "Updating index and manifest file..."
|
||||||
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' docs/index.html
|
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' webinstaller/index.html
|
||||||
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' docs/manifest.json
|
sed -i 's/$VERSION/${{ steps.last_release.outputs.tag_name }}/g' webinstaller/manifest.json
|
||||||
|
|
||||||
- name: Setup Pages
|
- name: Setup Pages
|
||||||
uses: actions/configure-pages@v5
|
uses: actions/configure-pages@v5
|
||||||
@@ -56,7 +56,7 @@ jobs:
|
|||||||
- name: Upload artifact
|
- name: Upload artifact
|
||||||
uses: actions/upload-pages-artifact@v3
|
uses: actions/upload-pages-artifact@v3
|
||||||
with:
|
with:
|
||||||
path: 'docs'
|
path: 'webinstaller'
|
||||||
|
|
||||||
- name: Deploy to GitHub Pages
|
- name: Deploy to GitHub Pages
|
||||||
id: deployment
|
id: deployment
|
||||||
|
|||||||
2
.github/workflows/reply-bot.yaml
vendored
2
.github/workflows/reply-bot.yaml
vendored
@@ -18,7 +18,7 @@ permissions:
|
|||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
comment:
|
comment:
|
||||||
runs-on: ubuntu-20.04
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
|
|
||||||
|
|||||||
432
Changelog.md
432
Changelog.md
File diff suppressed because it is too large
Load Diff
@@ -4,7 +4,7 @@
|
|||||||
```
|
```
|
||||||
git clone https://github.com/jomjol/AI-on-the-edge-device.git
|
git clone https://github.com/jomjol/AI-on-the-edge-device.git
|
||||||
cd AI-on-the-edge-device
|
cd AI-on-the-edge-device
|
||||||
git checkout rolling
|
git checkout main
|
||||||
git submodule update --init
|
git submodule update --init
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -12,10 +12,10 @@ git submodule update --init
|
|||||||
```
|
```
|
||||||
cd /components/submodule-name (e.g. tflite-micro-example)
|
cd /components/submodule-name (e.g. tflite-micro-example)
|
||||||
git checkout VERSION (e.g. HASH of latest tflite-micro-example build)
|
git checkout VERSION (e.g. HASH of latest tflite-micro-example build)
|
||||||
cd ../../ (auf Ebene von code)
|
cd ../../ (at the code level)
|
||||||
git submodule update --init
|
git submodule update --init
|
||||||
```
|
```
|
||||||
Evt. muss man vorher noch einige Verzeichnisse in compenents von Hand löschen, da sie beim checkout nicht gelöscht wurden (vor update -- init)
|
You may need to manually delete some directories in the 'components' folder beforehand, as they were not deleted during checkout (before update -- init)
|
||||||
|
|
||||||
## Build and Flash within terminal
|
## Build and Flash within terminal
|
||||||
See further down to build it within an IDE.
|
See further down to build it within an IDE.
|
||||||
@@ -51,7 +51,7 @@ pio device monitor -p /dev/ttyUSB0
|
|||||||
```
|
```
|
||||||
git clone https://github.com/jomjol/AI-on-the-edge-device.git
|
git clone https://github.com/jomjol/AI-on-the-edge-device.git
|
||||||
cd AI-on-the-edge-device
|
cd AI-on-the-edge-device
|
||||||
git checkout rolling
|
git checkout main
|
||||||
git submodule update --init
|
git submodule update --init
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|||||||
226
code/components/jomjol_fileserver_ota/md5.cpp
Normal file
226
code/components/jomjol_fileserver_ota/md5.cpp
Normal file
@@ -0,0 +1,226 @@
|
|||||||
|
/* Src: https://github.com/Zunawe/md5-c, commit: f3529b6
|
||||||
|
* License: Unlicense */
|
||||||
|
/*
|
||||||
|
* Derived from the RSA Data Security, Inc. MD5 Message-Digest Algorithm
|
||||||
|
* and modified slightly to be functionally identical but condensed into control structures.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "md5.h"
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Constants defined by the MD5 algorithm
|
||||||
|
*/
|
||||||
|
#define A 0x67452301
|
||||||
|
#define B 0xefcdab89
|
||||||
|
#define C 0x98badcfe
|
||||||
|
#define D 0x10325476
|
||||||
|
|
||||||
|
static uint32_t S[] = {7, 12, 17, 22, 7, 12, 17, 22, 7, 12, 17, 22, 7, 12, 17, 22,
|
||||||
|
5, 9, 14, 20, 5, 9, 14, 20, 5, 9, 14, 20, 5, 9, 14, 20,
|
||||||
|
4, 11, 16, 23, 4, 11, 16, 23, 4, 11, 16, 23, 4, 11, 16, 23,
|
||||||
|
6, 10, 15, 21, 6, 10, 15, 21, 6, 10, 15, 21, 6, 10, 15, 21};
|
||||||
|
|
||||||
|
static uint32_t K[] = {0xd76aa478, 0xe8c7b756, 0x242070db, 0xc1bdceee,
|
||||||
|
0xf57c0faf, 0x4787c62a, 0xa8304613, 0xfd469501,
|
||||||
|
0x698098d8, 0x8b44f7af, 0xffff5bb1, 0x895cd7be,
|
||||||
|
0x6b901122, 0xfd987193, 0xa679438e, 0x49b40821,
|
||||||
|
0xf61e2562, 0xc040b340, 0x265e5a51, 0xe9b6c7aa,
|
||||||
|
0xd62f105d, 0x02441453, 0xd8a1e681, 0xe7d3fbc8,
|
||||||
|
0x21e1cde6, 0xc33707d6, 0xf4d50d87, 0x455a14ed,
|
||||||
|
0xa9e3e905, 0xfcefa3f8, 0x676f02d9, 0x8d2a4c8a,
|
||||||
|
0xfffa3942, 0x8771f681, 0x6d9d6122, 0xfde5380c,
|
||||||
|
0xa4beea44, 0x4bdecfa9, 0xf6bb4b60, 0xbebfbc70,
|
||||||
|
0x289b7ec6, 0xeaa127fa, 0xd4ef3085, 0x04881d05,
|
||||||
|
0xd9d4d039, 0xe6db99e5, 0x1fa27cf8, 0xc4ac5665,
|
||||||
|
0xf4292244, 0x432aff97, 0xab9423a7, 0xfc93a039,
|
||||||
|
0x655b59c3, 0x8f0ccc92, 0xffeff47d, 0x85845dd1,
|
||||||
|
0x6fa87e4f, 0xfe2ce6e0, 0xa3014314, 0x4e0811a1,
|
||||||
|
0xf7537e82, 0xbd3af235, 0x2ad7d2bb, 0xeb86d391};
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Padding used to make the size (in bits) of the input congruent to 448 mod 512
|
||||||
|
*/
|
||||||
|
static uint8_t PADDING[] = {0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
||||||
|
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Bit-manipulation functions defined by the MD5 algorithm
|
||||||
|
*/
|
||||||
|
#define F(X, Y, Z) ((X & Y) | (~X & Z))
|
||||||
|
#define G(X, Y, Z) ((X & Z) | (Y & ~Z))
|
||||||
|
#define H(X, Y, Z) (X ^ Y ^ Z)
|
||||||
|
#define I(X, Y, Z) (Y ^ (X | ~Z))
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Rotates a 32-bit word left by n bits
|
||||||
|
*/
|
||||||
|
uint32_t rotateLeft(uint32_t x, uint32_t n){
|
||||||
|
return (x << n) | (x >> (32 - n));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Initialize a context
|
||||||
|
*/
|
||||||
|
void md5Init(MD5Context *ctx){
|
||||||
|
ctx->size = (uint64_t)0;
|
||||||
|
|
||||||
|
ctx->buffer[0] = (uint32_t)A;
|
||||||
|
ctx->buffer[1] = (uint32_t)B;
|
||||||
|
ctx->buffer[2] = (uint32_t)C;
|
||||||
|
ctx->buffer[3] = (uint32_t)D;
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Add some amount of input to the context
|
||||||
|
*
|
||||||
|
* If the input fills out a block of 512 bits, apply the algorithm (md5Step)
|
||||||
|
* and save the result in the buffer. Also updates the overall size.
|
||||||
|
*/
|
||||||
|
void md5Update(MD5Context *ctx, uint8_t *input_buffer, size_t input_len){
|
||||||
|
uint32_t input[16];
|
||||||
|
unsigned int offset = ctx->size % 64;
|
||||||
|
ctx->size += (uint64_t)input_len;
|
||||||
|
|
||||||
|
// Copy each byte in input_buffer into the next space in our context input
|
||||||
|
for(unsigned int i = 0; i < input_len; ++i){
|
||||||
|
ctx->input[offset++] = (uint8_t)*(input_buffer + i);
|
||||||
|
|
||||||
|
// If we've filled our context input, copy it into our local array input
|
||||||
|
// then reset the offset to 0 and fill in a new buffer.
|
||||||
|
// Every time we fill out a chunk, we run it through the algorithm
|
||||||
|
// to enable some back and forth between cpu and i/o
|
||||||
|
if(offset % 64 == 0){
|
||||||
|
for(unsigned int j = 0; j < 16; ++j){
|
||||||
|
// Convert to little-endian
|
||||||
|
// The local variable `input` our 512-bit chunk separated into 32-bit words
|
||||||
|
// we can use in calculations
|
||||||
|
input[j] = (uint32_t)(ctx->input[(j * 4) + 3]) << 24 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4) + 2]) << 16 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4) + 1]) << 8 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4)]);
|
||||||
|
}
|
||||||
|
md5Step(ctx->buffer, input);
|
||||||
|
offset = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Pad the current input to get to 448 bytes, append the size in bits to the very end,
|
||||||
|
* and save the result of the final iteration into digest.
|
||||||
|
*/
|
||||||
|
void md5Finalize(MD5Context *ctx){
|
||||||
|
uint32_t input[16];
|
||||||
|
unsigned int offset = ctx->size % 64;
|
||||||
|
unsigned int padding_length = offset < 56 ? 56 - offset : (56 + 64) - offset;
|
||||||
|
|
||||||
|
// Fill in the padding and undo the changes to size that resulted from the update
|
||||||
|
md5Update(ctx, PADDING, padding_length);
|
||||||
|
ctx->size -= (uint64_t)padding_length;
|
||||||
|
|
||||||
|
// Do a final update (internal to this function)
|
||||||
|
// Last two 32-bit words are the two halves of the size (converted from bytes to bits)
|
||||||
|
for(unsigned int j = 0; j < 14; ++j){
|
||||||
|
input[j] = (uint32_t)(ctx->input[(j * 4) + 3]) << 24 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4) + 2]) << 16 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4) + 1]) << 8 |
|
||||||
|
(uint32_t)(ctx->input[(j * 4)]);
|
||||||
|
}
|
||||||
|
input[14] = (uint32_t)(ctx->size * 8);
|
||||||
|
input[15] = (uint32_t)((ctx->size * 8) >> 32);
|
||||||
|
|
||||||
|
md5Step(ctx->buffer, input);
|
||||||
|
|
||||||
|
// Move the result into digest (convert from little-endian)
|
||||||
|
for(unsigned int i = 0; i < 4; ++i){
|
||||||
|
ctx->digest[(i * 4) + 0] = (uint8_t)((ctx->buffer[i] & 0x000000FF));
|
||||||
|
ctx->digest[(i * 4) + 1] = (uint8_t)((ctx->buffer[i] & 0x0000FF00) >> 8);
|
||||||
|
ctx->digest[(i * 4) + 2] = (uint8_t)((ctx->buffer[i] & 0x00FF0000) >> 16);
|
||||||
|
ctx->digest[(i * 4) + 3] = (uint8_t)((ctx->buffer[i] & 0xFF000000) >> 24);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Step on 512 bits of input with the main MD5 algorithm.
|
||||||
|
*/
|
||||||
|
void md5Step(uint32_t *buffer, uint32_t *input){
|
||||||
|
uint32_t AA = buffer[0];
|
||||||
|
uint32_t BB = buffer[1];
|
||||||
|
uint32_t CC = buffer[2];
|
||||||
|
uint32_t DD = buffer[3];
|
||||||
|
|
||||||
|
uint32_t E;
|
||||||
|
|
||||||
|
unsigned int j;
|
||||||
|
|
||||||
|
for(unsigned int i = 0; i < 64; ++i){
|
||||||
|
switch(i / 16){
|
||||||
|
case 0:
|
||||||
|
E = F(BB, CC, DD);
|
||||||
|
j = i;
|
||||||
|
break;
|
||||||
|
case 1:
|
||||||
|
E = G(BB, CC, DD);
|
||||||
|
j = ((i * 5) + 1) % 16;
|
||||||
|
break;
|
||||||
|
case 2:
|
||||||
|
E = H(BB, CC, DD);
|
||||||
|
j = ((i * 3) + 5) % 16;
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
E = I(BB, CC, DD);
|
||||||
|
j = (i * 7) % 16;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
uint32_t temp = DD;
|
||||||
|
DD = CC;
|
||||||
|
CC = BB;
|
||||||
|
BB = BB + rotateLeft(AA + E + K[i] + input[j], S[i]);
|
||||||
|
AA = temp;
|
||||||
|
}
|
||||||
|
|
||||||
|
buffer[0] += AA;
|
||||||
|
buffer[1] += BB;
|
||||||
|
buffer[2] += CC;
|
||||||
|
buffer[3] += DD;
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Functions that run the algorithm on the provided input and put the digest into result.
|
||||||
|
* result should be able to store 16 bytes.
|
||||||
|
*/
|
||||||
|
void md5String(char *input, uint8_t *result){
|
||||||
|
MD5Context ctx;
|
||||||
|
md5Init(&ctx);
|
||||||
|
md5Update(&ctx, (uint8_t *)input, strlen(input));
|
||||||
|
md5Finalize(&ctx);
|
||||||
|
|
||||||
|
memcpy(result, ctx.digest, 16);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
void md5File(FILE *file, uint8_t *result){
|
||||||
|
void *input_buffer = malloc(1024);
|
||||||
|
size_t input_size = 0;
|
||||||
|
|
||||||
|
MD5Context ctx;
|
||||||
|
md5Init(&ctx);
|
||||||
|
|
||||||
|
while((input_size = fread(input_buffer, 1, 1024, file)) > 0){
|
||||||
|
md5Update(&ctx, (uint8_t *)input_buffer, input_size);
|
||||||
|
}
|
||||||
|
|
||||||
|
md5Finalize(&ctx);
|
||||||
|
|
||||||
|
free(input_buffer);
|
||||||
|
|
||||||
|
memcpy(result, ctx.digest, 16);
|
||||||
|
}
|
||||||
28
code/components/jomjol_fileserver_ota/md5.h
Normal file
28
code/components/jomjol_fileserver_ota/md5.h
Normal file
@@ -0,0 +1,28 @@
|
|||||||
|
/* Src: https://github.com/Zunawe/md5-c, commit: f3529b6
|
||||||
|
* License: Unlicense */
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#ifndef MD5_H
|
||||||
|
#define MD5_H
|
||||||
|
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
|
||||||
|
typedef struct{
|
||||||
|
uint64_t size; // Size of input in bytes
|
||||||
|
uint32_t buffer[4]; // Current accumulation of hash
|
||||||
|
uint8_t input[64]; // Input to be used in the next step
|
||||||
|
uint8_t digest[16]; // Result of algorithm
|
||||||
|
}MD5Context;
|
||||||
|
|
||||||
|
void md5Init(MD5Context *ctx);
|
||||||
|
void md5Update(MD5Context *ctx, uint8_t *input, size_t input_len);
|
||||||
|
void md5Finalize(MD5Context *ctx);
|
||||||
|
void md5Step(uint32_t *buffer, uint32_t *input);
|
||||||
|
|
||||||
|
void md5String(char *input, uint8_t *result);
|
||||||
|
void md5File(FILE *file, uint8_t *result);
|
||||||
|
|
||||||
|
#endif // MD5_H
|
||||||
@@ -36,6 +36,7 @@ extern "C" {
|
|||||||
#include "MainFlowControl.h"
|
#include "MainFlowControl.h"
|
||||||
|
|
||||||
#include "server_help.h"
|
#include "server_help.h"
|
||||||
|
#include "md5.h"
|
||||||
#ifdef ENABLE_MQTT
|
#ifdef ENABLE_MQTT
|
||||||
#include "interface_mqtt.h"
|
#include "interface_mqtt.h"
|
||||||
#endif //ENABLE_MQTT
|
#endif //ENABLE_MQTT
|
||||||
@@ -610,6 +611,8 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|||||||
FILE *fd = NULL;
|
FILE *fd = NULL;
|
||||||
struct stat file_stat;
|
struct stat file_stat;
|
||||||
|
|
||||||
|
ESP_LOGI(TAG, "uri: %s", req->uri);
|
||||||
|
|
||||||
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
/* Skip leading "/upload" from URI to get filename */
|
/* Skip leading "/upload" from URI to get filename */
|
||||||
@@ -711,43 +714,76 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|||||||
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "File saved: " + string(filename));
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "File saved: " + string(filename));
|
||||||
ESP_LOGI(TAG, "File reception completed");
|
ESP_LOGI(TAG, "File reception completed");
|
||||||
|
|
||||||
std::string directory = std::string(filepath);
|
string s = req->uri;
|
||||||
size_t zw = directory.find("/");
|
if (isInString(s, "?md5")) {
|
||||||
size_t found = zw;
|
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Calculate and return MD5 sum...");
|
||||||
while (zw != std::string::npos)
|
|
||||||
{
|
|
||||||
zw = directory.find("/", found+1);
|
|
||||||
if (zw != std::string::npos)
|
|
||||||
found = zw;
|
|
||||||
}
|
|
||||||
|
|
||||||
int start_fn = strlen(((struct file_server_data *)req->user_ctx)->base_path);
|
fd = fopen(filepath, "r");
|
||||||
ESP_LOGD(TAG, "Directory: %s, start_fn: %d, found: %d", directory.c_str(), start_fn, found);
|
if (!fd) {
|
||||||
directory = directory.substr(start_fn, found - start_fn + 1);
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to open file for reading: " + string(filepath));
|
||||||
directory = "/fileserver" + directory;
|
/* Respond with 500 Internal Server Error */
|
||||||
// ESP_LOGD(TAG, "Directory danach 2: %s", directory.c_str());
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to open file for reading");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
/* Redirect onto root to see the updated file list */
|
uint8_t result[16];
|
||||||
if (strcmp(filename, "/config/config.ini") == 0 ||
|
string md5hex = "";
|
||||||
strcmp(filename, "/config/ref0.jpg") == 0 ||
|
string response = "{\"md5\":";
|
||||||
strcmp(filename, "/config/ref0_org.jpg") == 0 ||
|
char hex[3];
|
||||||
strcmp(filename, "/config/ref1.jpg") == 0 ||
|
|
||||||
strcmp(filename, "/config/ref1_org.jpg") == 0 ||
|
md5File(fd, result);
|
||||||
strcmp(filename, "/config/reference.jpg") == 0 ||
|
fclose(fd);
|
||||||
strcmp(filename, "/img_tmp/ref0.jpg") == 0 ||
|
|
||||||
strcmp(filename, "/img_tmp/ref0_org.jpg") == 0 ||
|
for (int i = 0; i < sizeof(result); i++) {
|
||||||
strcmp(filename, "/img_tmp/ref1.jpg") == 0 ||
|
snprintf(hex, sizeof(hex), "%02x", result[i]);
|
||||||
strcmp(filename, "/img_tmp/ref1_org.jpg") == 0 ||
|
md5hex.append(hex);
|
||||||
strcmp(filename, "/img_tmp/reference.jpg") == 0 )
|
}
|
||||||
{
|
|
||||||
httpd_resp_set_status(req, HTTPD_200); // Avoid reloading of folder content
|
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "MD5 of " + string(filepath) + ": " + md5hex);
|
||||||
}
|
response.append("\"" + md5hex + "\"");
|
||||||
else {
|
response.append("}");
|
||||||
httpd_resp_set_status(req, "303 See Other"); // Reload folder content after upload
|
|
||||||
|
httpd_resp_sendstr(req, response.c_str());
|
||||||
}
|
}
|
||||||
|
else { // Return file server page
|
||||||
|
std::string directory = std::string(filepath);
|
||||||
|
size_t zw = directory.find("/");
|
||||||
|
size_t found = zw;
|
||||||
|
while (zw != std::string::npos)
|
||||||
|
{
|
||||||
|
zw = directory.find("/", found+1);
|
||||||
|
if (zw != std::string::npos)
|
||||||
|
found = zw;
|
||||||
|
}
|
||||||
|
|
||||||
httpd_resp_set_hdr(req, "Location", directory.c_str());
|
int start_fn = strlen(((struct file_server_data *)req->user_ctx)->base_path);
|
||||||
httpd_resp_sendstr(req, "File uploaded successfully");
|
ESP_LOGD(TAG, "Directory: %s, start_fn: %d, found: %d", directory.c_str(), start_fn, found);
|
||||||
|
directory = directory.substr(start_fn, found - start_fn + 1);
|
||||||
|
directory = "/fileserver" + directory;
|
||||||
|
// ESP_LOGD(TAG, "Directory danach 2: %s", directory.c_str());
|
||||||
|
|
||||||
|
/* Redirect onto root to see the updated file list */
|
||||||
|
if (strcmp(filename, "/config/config.ini") == 0 ||
|
||||||
|
strcmp(filename, "/config/ref0.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/config/ref0_org.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/config/ref1.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/config/ref1_org.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/config/reference.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/img_tmp/ref0.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/img_tmp/ref0_org.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/img_tmp/ref1.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/img_tmp/ref1_org.jpg") == 0 ||
|
||||||
|
strcmp(filename, "/img_tmp/reference.jpg") == 0 )
|
||||||
|
{
|
||||||
|
httpd_resp_set_status(req, HTTPD_200); // Avoid reloading of folder content
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
httpd_resp_set_status(req, "303 See Other"); // Reload folder content after upload
|
||||||
|
}
|
||||||
|
|
||||||
|
httpd_resp_set_hdr(req, "Location", directory.c_str());
|
||||||
|
httpd_resp_sendstr(req, "File uploaded successfully");
|
||||||
|
}
|
||||||
|
|
||||||
return ESP_OK;
|
return ESP_OK;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -31,7 +31,6 @@ enum t_RateType {
|
|||||||
RateChange // time difference is considered and a normalized rate is used for comparison with NumberPost.maxRate
|
RateChange // time difference is considered and a normalized rate is used for comparison with NumberPost.maxRate
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Holds all properties and settings of a sequence. A sequence is a set of digit and/or analog ROIs that are combined to
|
* Holds all properties and settings of a sequence. A sequence is a set of digit and/or analog ROIs that are combined to
|
||||||
* provide one meter reading (value).
|
* provide one meter reading (value).
|
||||||
@@ -45,6 +44,7 @@ struct NumberPost {
|
|||||||
int ChangeRateThreshold; // threshold parameter for negative rate detection
|
int ChangeRateThreshold; // threshold parameter for negative rate detection
|
||||||
bool PreValueOkay; // previousValueValid; indicates that the reading of the previous round has no errors
|
bool PreValueOkay; // previousValueValid; indicates that the reading of the previous round has no errors
|
||||||
bool AllowNegativeRates; // allowNegativeRate; defines if the consistency checks allow negative rates between consecutive meter readings.
|
bool AllowNegativeRates; // allowNegativeRate; defines if the consistency checks allow negative rates between consecutive meter readings.
|
||||||
|
bool IgnoreLeadingNaN;
|
||||||
bool checkDigitIncreaseConsistency; // extendedConsistencyCheck; performs an additional consistency check to avoid wrong readings
|
bool checkDigitIncreaseConsistency; // extendedConsistencyCheck; performs an additional consistency check to avoid wrong readings
|
||||||
time_t timeStampLastValue; // Timestamp for the last read value; is used for the log
|
time_t timeStampLastValue; // Timestamp for the last read value; is used for the log
|
||||||
time_t timeStampLastPreValue; // Timestamp for the last PreValue set; is used for useMaxRateValue
|
time_t timeStampLastPreValue; // Timestamp for the last PreValue set; is used for useMaxRateValue
|
||||||
@@ -66,7 +66,7 @@ struct NumberPost {
|
|||||||
float AnalogToDigitTransitionStart; // AnalogToDigitTransitionStartValue; FIXME: need a better description; When is the digit > x.1, i.e. when does it start to tilt?
|
float AnalogToDigitTransitionStart; // AnalogToDigitTransitionStartValue; FIXME: need a better description; When is the digit > x.1, i.e. when does it start to tilt?
|
||||||
int Nachkomma; // decimalPlaces; usually defined by the number of analog ROIs; affected by DecimalShift
|
int Nachkomma; // decimalPlaces; usually defined by the number of analog ROIs; affected by DecimalShift
|
||||||
|
|
||||||
string DomoticzIdx; // Domoticz counter Idx
|
string DomoticzIdx; // Domoticz counter Idx
|
||||||
|
|
||||||
string FieldV1; // influxdbFieldName_v1; Name of the Field in InfluxDBv1
|
string FieldV1; // influxdbFieldName_v1; Name of the Field in InfluxDBv1
|
||||||
string MeasurementV1; // influxdbMeasurementName_v1; Name of the Measurement in InfluxDBv1
|
string MeasurementV1; // influxdbMeasurementName_v1; Name of the Measurement in InfluxDBv1
|
||||||
@@ -83,4 +83,3 @@ struct NumberPost {
|
|||||||
};
|
};
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
|||||||
@@ -156,7 +156,7 @@ bool ClassFlowMQTT::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|||||||
mqttServer_setMeterType("water", "L", "h", "L/h");
|
mqttServer_setMeterType("water", "L", "h", "L/h");
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "WATER_FT3") {
|
else if (toUpper(splitted[1]) == "WATER_FT3") {
|
||||||
mqttServer_setMeterType("water", "ft³", "m", "ft³/m"); // m = Minutes
|
mqttServer_setMeterType("water", "ft³", "min", "ft³/min"); // min = Minutes
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "WATER_GAL") {
|
else if (toUpper(splitted[1]) == "WATER_GAL") {
|
||||||
mqttServer_setMeterType("water", "gal", "h", "gal/h");
|
mqttServer_setMeterType("water", "gal", "h", "gal/h");
|
||||||
@@ -165,7 +165,7 @@ bool ClassFlowMQTT::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|||||||
mqttServer_setMeterType("gas", "m³", "h", "m³/h");
|
mqttServer_setMeterType("gas", "m³", "h", "m³/h");
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "GAS_FT3") {
|
else if (toUpper(splitted[1]) == "GAS_FT3") {
|
||||||
mqttServer_setMeterType("gas", "ft³", "m", "ft³/m"); // m = Minutes
|
mqttServer_setMeterType("gas", "ft³", "min", "ft³/min"); // min = Minutes
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "ENERGY_WH") {
|
else if (toUpper(splitted[1]) == "ENERGY_WH") {
|
||||||
mqttServer_setMeterType("energy", "Wh", "h", "W");
|
mqttServer_setMeterType("energy", "Wh", "h", "W");
|
||||||
@@ -180,13 +180,13 @@ bool ClassFlowMQTT::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|||||||
mqttServer_setMeterType("energy", "GJ", "h", "GJ/h");
|
mqttServer_setMeterType("energy", "GJ", "h", "GJ/h");
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "TEMPERATURE_C") {
|
else if (toUpper(splitted[1]) == "TEMPERATURE_C") {
|
||||||
mqttServer_setMeterType("temperature", "°C", "m", "°C/m"); // m = Minutes
|
mqttServer_setMeterType("temperature", "°C", "min", "°C/min"); // min = Minutes
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "TEMPERATURE_F") {
|
else if (toUpper(splitted[1]) == "TEMPERATURE_F") {
|
||||||
mqttServer_setMeterType("temperature", "°F", "m", "°F/m"); // m = Minutes
|
mqttServer_setMeterType("temperature", "°F", "min", "°F/min"); // min = Minutes
|
||||||
}
|
}
|
||||||
else if (toUpper(splitted[1]) == "TEMPERATURE_K") {
|
else if (toUpper(splitted[1]) == "TEMPERATURE_K") {
|
||||||
mqttServer_setMeterType("temperature", "K", "m", "K/m"); // m = Minutes
|
mqttServer_setMeterType("temperature", "K", "min", "K/m"); // min = Minutes
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -320,7 +320,6 @@ ClassFlowPostProcessing::ClassFlowPostProcessing(std::vector<ClassFlow*>* lfc, C
|
|||||||
ListFlowControll = lfc;
|
ListFlowControll = lfc;
|
||||||
flowTakeImage = NULL;
|
flowTakeImage = NULL;
|
||||||
UpdatePreValueINI = false;
|
UpdatePreValueINI = false;
|
||||||
IgnoreLeadingNaN = false;
|
|
||||||
flowAnalog = _analog;
|
flowAnalog = _analog;
|
||||||
flowDigit = _digit;
|
flowDigit = _digit;
|
||||||
|
|
||||||
@@ -431,6 +430,27 @@ void ClassFlowPostProcessing::handleAllowNegativeRate(string _decsep, string _va
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void ClassFlowPostProcessing::handleIgnoreLeadingNaN(string _decsep, string _value) {
|
||||||
|
string _digit, _decpos;
|
||||||
|
int _pospunkt = _decsep.find_first_of(".");
|
||||||
|
|
||||||
|
if (_pospunkt > -1) {
|
||||||
|
_digit = _decsep.substr(0, _pospunkt);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
_digit = "default";
|
||||||
|
}
|
||||||
|
|
||||||
|
for (int j = 0; j < NUMBERS.size(); ++j) {
|
||||||
|
bool _zwdc = alphanumericToBoolean(_value);
|
||||||
|
|
||||||
|
// Set to default first (if nothing else is set)
|
||||||
|
if ((_digit == "default") || (NUMBERS[j]->name == _digit)) {
|
||||||
|
NUMBERS[j]->IgnoreLeadingNaN = _zwdc;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void ClassFlowPostProcessing::handleMaxRateType(string _decsep, string _value) {
|
void ClassFlowPostProcessing::handleMaxRateType(string _decsep, string _value) {
|
||||||
string _digit, _decpos;
|
string _digit, _decpos;
|
||||||
int _pospunkt = _decsep.find_first_of(".");
|
int _pospunkt = _decsep.find_first_of(".");
|
||||||
@@ -509,7 +529,7 @@ void ClassFlowPostProcessing::handleChangeRateThreshold(string _decsep, string _
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
/*
|
|
||||||
void ClassFlowPostProcessing::handlecheckDigitIncreaseConsistency(std::string _decsep, std::string _value)
|
void ClassFlowPostProcessing::handlecheckDigitIncreaseConsistency(std::string _decsep, std::string _value)
|
||||||
{
|
{
|
||||||
std::string _digit;
|
std::string _digit;
|
||||||
@@ -532,7 +552,7 @@ void ClassFlowPostProcessing::handlecheckDigitIncreaseConsistency(std::string _d
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
*/
|
|
||||||
bool ClassFlowPostProcessing::ReadParameter(FILE* pfile, string& aktparamgraph) {
|
bool ClassFlowPostProcessing::ReadParameter(FILE* pfile, string& aktparamgraph) {
|
||||||
std::vector<string> splitted;
|
std::vector<string> splitted;
|
||||||
int _n;
|
int _n;
|
||||||
@@ -585,12 +605,7 @@ bool ClassFlowPostProcessing::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if ((toUpper(_param) == "CHECKDIGITINCREASECONSISTENCY") && (splitted.size() > 1)) {
|
if ((toUpper(_param) == "CHECKDIGITINCREASECONSISTENCY") && (splitted.size() > 1)) {
|
||||||
// handlecheckDigitIncreaseConsistency(splitted[0], splitted[1]);
|
handlecheckDigitIncreaseConsistency(splitted[0], splitted[1]);
|
||||||
if (alphanumericToBoolean(splitted[1])) {
|
|
||||||
for (_n = 0; _n < NUMBERS.size(); ++_n) {
|
|
||||||
NUMBERS[_n]->checkDigitIncreaseConsistency = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((toUpper(_param) == "ALLOWNEGATIVERATES") && (splitted.size() > 1)) {
|
if ((toUpper(_param) == "ALLOWNEGATIVERATES") && (splitted.size() > 1)) {
|
||||||
@@ -602,7 +617,7 @@ bool ClassFlowPostProcessing::ReadParameter(FILE* pfile, string& aktparamgraph)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if ((toUpper(_param) == "IGNORELEADINGNAN") && (splitted.size() > 1)) {
|
if ((toUpper(_param) == "IGNORELEADINGNAN") && (splitted.size() > 1)) {
|
||||||
IgnoreLeadingNaN = alphanumericToBoolean(splitted[1]);
|
handleIgnoreLeadingNaN(splitted[0], splitted[1]);
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((toUpper(_param) == "PREVALUEAGESTARTUP") && (splitted.size() > 1)) {
|
if ((toUpper(_param) == "PREVALUEAGESTARTUP") && (splitted.size() > 1)) {
|
||||||
@@ -670,6 +685,7 @@ void ClassFlowPostProcessing::InitNUMBERS() {
|
|||||||
_number->FlowRateAct = 0; // m3 / min
|
_number->FlowRateAct = 0; // m3 / min
|
||||||
_number->PreValueOkay = false;
|
_number->PreValueOkay = false;
|
||||||
_number->AllowNegativeRates = false;
|
_number->AllowNegativeRates = false;
|
||||||
|
_number->IgnoreLeadingNaN = false;
|
||||||
_number->MaxRateValue = 0.1;
|
_number->MaxRateValue = 0.1;
|
||||||
_number->MaxRateType = AbsoluteChange;
|
_number->MaxRateType = AbsoluteChange;
|
||||||
_number->useMaxRateValue = false;
|
_number->useMaxRateValue = false;
|
||||||
@@ -821,7 +837,7 @@ bool ClassFlowPostProcessing::doFlow(string zwtime) {
|
|||||||
ESP_LOGD(TAG, "After ShiftDecimal: ReturnRaw %s", NUMBERS[j]->ReturnRawValue.c_str());
|
ESP_LOGD(TAG, "After ShiftDecimal: ReturnRaw %s", NUMBERS[j]->ReturnRawValue.c_str());
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
if (IgnoreLeadingNaN) {
|
if (NUMBERS[j]->IgnoreLeadingNaN) {
|
||||||
while ((NUMBERS[j]->ReturnRawValue.length() > 1) && (NUMBERS[j]->ReturnRawValue[0] == 'N')) {
|
while ((NUMBERS[j]->ReturnRawValue.length() > 1) && (NUMBERS[j]->ReturnRawValue[0] == 'N')) {
|
||||||
NUMBERS[j]->ReturnRawValue.erase(0, 1);
|
NUMBERS[j]->ReturnRawValue.erase(0, 1);
|
||||||
}
|
}
|
||||||
@@ -868,12 +884,7 @@ bool ClassFlowPostProcessing::doFlow(string zwtime) {
|
|||||||
|
|
||||||
if (NUMBERS[j]->checkDigitIncreaseConsistency) {
|
if (NUMBERS[j]->checkDigitIncreaseConsistency) {
|
||||||
if (flowDigit) {
|
if (flowDigit) {
|
||||||
if (flowDigit->getCNNType() != Digit) {
|
NUMBERS[j]->Value = checkDigitConsistency(NUMBERS[j]->Value, NUMBERS[j]->DecimalShift, NUMBERS[j]->analog_roi != NULL, NUMBERS[j]->PreValue);
|
||||||
ESP_LOGD(TAG, "checkDigitIncreaseConsistency = true - ignored due to wrong CNN-Type (not Digit Classification)");
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
NUMBERS[j]->Value = checkDigitConsistency(NUMBERS[j]->Value, NUMBERS[j]->DecimalShift, NUMBERS[j]->analog_roi != NULL, NUMBERS[j]->PreValue);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
#ifdef SERIAL_DEBUG
|
#ifdef SERIAL_DEBUG
|
||||||
@@ -887,7 +898,7 @@ bool ClassFlowPostProcessing::doFlow(string zwtime) {
|
|||||||
#endif
|
#endif
|
||||||
|
|
||||||
if (PreValueUse && NUMBERS[j]->PreValueOkay) {
|
if (PreValueUse && NUMBERS[j]->PreValueOkay) {
|
||||||
if (NUMBERS[j]->Nachkomma > 0) {
|
if ((NUMBERS[j]->Nachkomma > 0) && (NUMBERS[j]->ChangeRateThreshold > 0)) {
|
||||||
double _difference1 = (NUMBERS[j]->PreValue - (NUMBERS[j]->ChangeRateThreshold / pow(10, NUMBERS[j]->Nachkomma)));
|
double _difference1 = (NUMBERS[j]->PreValue - (NUMBERS[j]->ChangeRateThreshold / pow(10, NUMBERS[j]->Nachkomma)));
|
||||||
double _difference2 = (NUMBERS[j]->PreValue + (NUMBERS[j]->ChangeRateThreshold / pow(10, NUMBERS[j]->Nachkomma)));
|
double _difference2 = (NUMBERS[j]->PreValue + (NUMBERS[j]->ChangeRateThreshold / pow(10, NUMBERS[j]->Nachkomma)));
|
||||||
|
|
||||||
|
|||||||
@@ -10,7 +10,6 @@
|
|||||||
|
|
||||||
#include <string>
|
#include <string>
|
||||||
|
|
||||||
|
|
||||||
class ClassFlowPostProcessing :
|
class ClassFlowPostProcessing :
|
||||||
public ClassFlow
|
public ClassFlow
|
||||||
{
|
{
|
||||||
@@ -19,7 +18,6 @@ protected:
|
|||||||
|
|
||||||
int PreValueAgeStartup;
|
int PreValueAgeStartup;
|
||||||
bool ErrorMessage;
|
bool ErrorMessage;
|
||||||
bool IgnoreLeadingNaN; // SPECIAL CASE for User Gustl ???
|
|
||||||
|
|
||||||
ClassFlowCNNGeneral* flowAnalog;
|
ClassFlowCNNGeneral* flowAnalog;
|
||||||
ClassFlowCNNGeneral* flowDigit;
|
ClassFlowCNNGeneral* flowDigit;
|
||||||
@@ -35,15 +33,16 @@ protected:
|
|||||||
float checkDigitConsistency(double input, int _decilamshift, bool _isanalog, double _preValue);
|
float checkDigitConsistency(double input, int _decilamshift, bool _isanalog, double _preValue);
|
||||||
|
|
||||||
void InitNUMBERS();
|
void InitNUMBERS();
|
||||||
|
|
||||||
void handleDecimalSeparator(string _decsep, string _value);
|
void handleDecimalSeparator(string _decsep, string _value);
|
||||||
void handleMaxRateValue(string _decsep, string _value);
|
void handleMaxRateValue(string _decsep, string _value);
|
||||||
void handleDecimalExtendedResolution(string _decsep, string _value);
|
void handleDecimalExtendedResolution(string _decsep, string _value);
|
||||||
void handleMaxRateType(string _decsep, string _value);
|
void handleMaxRateType(string _decsep, string _value);
|
||||||
void handleAnalogToDigitTransitionStart(string _decsep, string _value);
|
void handleAnalogToDigitTransitionStart(string _decsep, string _value);
|
||||||
void handleAllowNegativeRate(string _decsep, string _value);
|
void handleAllowNegativeRate(string _decsep, string _value);
|
||||||
|
void handleIgnoreLeadingNaN(string _decsep, string _value);
|
||||||
void handleChangeRateThreshold(string _decsep, string _value);
|
void handleChangeRateThreshold(string _decsep, string _value);
|
||||||
|
void handlecheckDigitIncreaseConsistency(std::string _decsep, std::string _value);
|
||||||
std::string GetStringReadouts(general);
|
|
||||||
|
|
||||||
void WriteDataLog(int _index);
|
void WriteDataLog(int _index);
|
||||||
|
|
||||||
@@ -75,5 +74,4 @@ public:
|
|||||||
string name(){return "ClassFlowPostProcessing";};
|
string name(){return "ClassFlowPostProcessing";};
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
#endif //CLASSFFLOWPOSTPROCESSING_H
|
#endif //CLASSFFLOWPOSTPROCESSING_H
|
||||||
|
|||||||
@@ -85,7 +85,7 @@ bool MQTTPublish(std::string _key, std::string _content, int qos, bool retained_
|
|||||||
_content.append("..");
|
_content.append("..");
|
||||||
}
|
}
|
||||||
|
|
||||||
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Published topic: " + _key + ", content: " + _content + " (msg_id=" + std::to_string(msg_id) + ")");
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Published topic: " + _key + ", content: " + _content);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
@@ -465,7 +465,7 @@ void MQTTconnected(){
|
|||||||
if (subscribeFunktionMap != NULL) {
|
if (subscribeFunktionMap != NULL) {
|
||||||
for(std::map<std::string, std::function<bool(std::string, char*, int)>>::iterator it = subscribeFunktionMap->begin(); it != subscribeFunktionMap->end(); ++it) {
|
for(std::map<std::string, std::function<bool(std::string, char*, int)>>::iterator it = subscribeFunktionMap->begin(); it != subscribeFunktionMap->end(); ++it) {
|
||||||
int msg_id = esp_mqtt_client_subscribe(client, it->first.c_str(), 0);
|
int msg_id = esp_mqtt_client_subscribe(client, it->first.c_str(), 0);
|
||||||
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "topic " + it->first + " subscribe successful, msg_id=" + std::to_string(msg_id));
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "topic " + it->first + " subscribe successful");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -174,14 +174,14 @@ bool MQTThomeassistantDiscovery(int qos) {
|
|||||||
int aFreeInternalHeapSizeBefore = heap_caps_get_free_size(MALLOC_CAP_8BIT | MALLOC_CAP_INTERNAL);
|
int aFreeInternalHeapSizeBefore = heap_caps_get_free_size(MALLOC_CAP_8BIT | MALLOC_CAP_INTERNAL);
|
||||||
|
|
||||||
// Group | Field | User Friendly Name | Icon | Unit | Device Class | State Class | Entity Category
|
// Group | Field | User Friendly Name | Icon | Unit | Device Class | State Class | Entity Category
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "uptime", "Uptime", "clock-time-eight-outline", "s", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "uptime", "Uptime", "progress-clock", "s", "duration", "measurement", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "MAC", "MAC Address", "network-outline", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "MAC", "MAC Address", "network-outline", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "fwVersion", "Firmware Version", "application-outline", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "fwVersion", "Firmware Version", "application-outline", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "hostname", "Hostname", "network-outline", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "hostname", "Hostname", "network-outline", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "freeMem", "Free Memory", "memory", "B", "", "measurement", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "freeMem", "Free Memory", "memory", "B", "", "measurement", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "wifiRSSI", "Wi-Fi RSSI", "wifi", "dBm", "signal_strength", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "wifiRSSI", "Wi-Fi RSSI", "wifi", "dBm", "signal_strength", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "CPUtemp", "CPU Temperature", "thermometer", "°C", "temperature", "measurement", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "CPUtemp", "CPU Temperature", "thermometer", "°C", "temperature", "measurement", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "interval", "Interval", "clock-time-eight-outline", "min", "" , "measurement", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "interval", "Interval", "clock-time-eight-outline", "min", "", "measurement", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "IP", "IP", "network-outline", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "IP", "IP", "network-outline", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "status", "Status", "list-status", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "status", "Status", "list-status", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "flowstart", "Manual Flow Start", "timer-play-outline", "", "", "", "", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic("", "flowstart", "Manual Flow Start", "timer-play-outline", "", "", "", "", qos);
|
||||||
@@ -195,9 +195,12 @@ bool MQTThomeassistantDiscovery(int qos) {
|
|||||||
|
|
||||||
/* If "Allow neg. rate" is true, use "measurement" instead of "total_increasing" for the State Class, see https://github.com/jomjol/AI-on-the-edge-device/issues/3331 */
|
/* If "Allow neg. rate" is true, use "measurement" instead of "total_increasing" for the State Class, see https://github.com/jomjol/AI-on-the-edge-device/issues/3331 */
|
||||||
std::string value_state_class = "total_increasing";
|
std::string value_state_class = "total_increasing";
|
||||||
if ((*NUMBERS)[i]->AllowNegativeRates) {
|
if (meterType == "temperature") {
|
||||||
value_state_class = "measurement";
|
value_state_class = "measurement";
|
||||||
}
|
}
|
||||||
|
else if ((*NUMBERS)[i]->AllowNegativeRates) {
|
||||||
|
value_state_class = "total";
|
||||||
|
}
|
||||||
|
|
||||||
/* Energy meters need a different Device Class, see https://github.com/jomjol/AI-on-the-edge-device/issues/3333 */
|
/* Energy meters need a different Device Class, see https://github.com/jomjol/AI-on-the-edge-device/issues/3333 */
|
||||||
std::string rate_device_class = "volume_flow_rate";
|
std::string rate_device_class = "volume_flow_rate";
|
||||||
@@ -205,17 +208,17 @@ bool MQTThomeassistantDiscovery(int qos) {
|
|||||||
rate_device_class = "power";
|
rate_device_class = "power";
|
||||||
}
|
}
|
||||||
|
|
||||||
// Group | Field | User Friendly Name | Icon | Unit | Device Class | State Class | Entity Category
|
// Group | Field | User Friendly Name | Icon | Unit | Device Class | State Class | Entity Category | QoS
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "value", "Value", "gauge", valueUnit, meterType, value_state_class, "", qos); // State Class = "total_increasing" if <NUMBERS>.AllowNegativeRates = false, else use "measurement"
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "value", "Value", "gauge", valueUnit, meterType, value_state_class, "", qos); // State Class = "total_increasing" if <NUMBERS>.AllowNegativeRates = false, "measurement" in case of a thermometer, else use "total".
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "raw", "Raw Value", "raw", valueUnit, meterType, "measurement", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "raw", "Raw Value", "raw", valueUnit, meterType, value_state_class, "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "error", "Error", "alert-circle-outline", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "error", "Error", "alert-circle-outline", "", "", "", "diagnostic", qos);
|
||||||
/* Not announcing "rate" as it is better to use rate_per_time_unit resp. rate_per_digitization_round */
|
/* Not announcing "rate" as it is better to use rate_per_time_unit resp. rate_per_digitization_round */
|
||||||
// allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate", "Rate (Unit/Minute)", "swap-vertical", "", "", "", ""); // Legacy, always Unit per Minute
|
// allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate", "Rate (Unit/Minute)", "swap-vertical", "", "", "", "", qos); // Legacy, always Unit per Minute
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate_per_time_unit", "Rate (" + rateUnit + ")", "swap-vertical", rateUnit, rate_device_class, "measurement", "", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate_per_time_unit", "Rate (" + rateUnit + ")", "swap-vertical", rateUnit, rate_device_class, "measurement", "", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate_per_digitization_round", "Change since last Digitization round", "arrow-expand-vertical", valueUnit, "", "measurement", "", qos); // correctly the Unit is Unit/Interval!
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "rate_per_digitization_round","Change since last Digitization round", "arrow-expand-vertical", valueUnit, "", "measurement", "", qos); // correctly the Unit is Unit/Interval!
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "timestamp", "Timestamp", "clock-time-eight-outline", "", "timestamp", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "timestamp", "Timestamp", "clock-time-eight-outline", "", "timestamp", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "json", "JSON", "code-json", "", "", "", "diagnostic", qos);
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "json", "JSON", "code-json", "", "", "", "diagnostic", qos);
|
||||||
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "problem", "Problem", "alert-outline", "", "problem", "", "", qos); // Special binary sensor which is based on error topic
|
allSendsSuccessed |= sendHomeAssistantDiscoveryTopic(group, "problem", "Problem", "alert-outline", "", "problem", "", "", qos); // Special binary sensor which is based on error topic
|
||||||
}
|
}
|
||||||
|
|
||||||
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Successfully published all Homeassistant Discovery MQTT topics");
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Successfully published all Homeassistant Discovery MQTT topics");
|
||||||
|
|||||||
@@ -31,7 +31,6 @@ AlignmentAlgo
|
|||||||
CNNGoodThreshold
|
CNNGoodThreshold
|
||||||
PreValueAgeStartup
|
PreValueAgeStartup
|
||||||
ErrorMessage
|
ErrorMessage
|
||||||
CheckDigitIncreaseConsistency
|
|
||||||
IO0
|
IO0
|
||||||
IO1
|
IO1
|
||||||
IO3
|
IO3
|
||||||
|
|||||||
@@ -4,4 +4,4 @@ Default Value: `undefined`
|
|||||||
Dedicated definition of the field for InfluxDB use for saving in the Influx database (e.g.: "watermeter/value").
|
Dedicated definition of the field for InfluxDB use for saving in the Influx database (e.g.: "watermeter/value").
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.Field`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.Field`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -4,4 +4,4 @@ Default Value: `undefined`
|
|||||||
Field for InfluxDB v2 to use for saving.
|
Field for InfluxDB v2 to use for saving.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.Field`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.Field`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -3,9 +3,26 @@ Default Value: `other`
|
|||||||
|
|
||||||
Select the Meter Type so the sensors have the right units in Homeassistant.
|
Select the Meter Type so the sensors have the right units in Homeassistant.
|
||||||
|
|
||||||
!!! Note
|
|
||||||
For `Watermeter` you need to have Homeassistant 2022.11 or newer!
|
|
||||||
|
|
||||||
Please also make sure that the selected Meter Type matches the dimension of the value provided by the meter!
|
Please also make sure that the selected Meter Type matches the dimension of the value provided by the meter!
|
||||||
Eg. if your meter provides `m³`, you need to also set it to `m³`.
|
Eg. if your meter provides `m³`, you need to also set it to `m³`.
|
||||||
Alternatively you can set the parameter `DecimalShift` to `3` so the value is converted to `liters`!
|
Alternatively you can set the parameter `DecimalShift` to `3` so the value is converted to `liters`!
|
||||||
|
|
||||||
|
List of supported options:
|
||||||
|
|
||||||
|
- `other`
|
||||||
|
- `water_m3` (uses `m^3/h` as rate)
|
||||||
|
- `water_l` (uses `l/h` as rate, not officially supported by Homeassistant!)
|
||||||
|
- `water_gal` (uses `gal/h` as rate, not officially supported by Homeassistant!)
|
||||||
|
- `water_ft3` (uses `ft^3/min` as rate)
|
||||||
|
- `gas_m3` (uses `m^3/h` as rate)
|
||||||
|
- `gas_ft3` (uses `ft^3/min` as rate)
|
||||||
|
- `energy_wh` (uses `W` as rate)
|
||||||
|
- `energy_kwh` (uses `KW` as rate)
|
||||||
|
- `energy_mwh` (uses `MW` as rate)
|
||||||
|
- `energy_gj` (uses `GJ/h` as rate, not officially supported by Homeassistant!)
|
||||||
|
- `temperature_c` (uses `+C/min` as rate)
|
||||||
|
- `temperature_f` (uses `°F/min` as rate)
|
||||||
|
- `temperature_k` (uses `K/min` as rate)
|
||||||
|
|
||||||
|
!!! Note
|
||||||
|
Not all options are supported by Homeassistant, see `SensorDeviceClass.VOLUME_FLOW_RATE` in [https://developers.home-assistant.io/docs/core/entity/sensor/#available-device-classes](https://developers.home-assistant.io/docs/core/entity/sensor/#available-device-classes)!
|
||||||
|
|||||||
@@ -4,4 +4,4 @@ Default Value: `0`
|
|||||||
The Idx number for the counter device. Can be obtained from the devices setup page on the Domoticz system.
|
The Idx number for the counter device. Can be obtained from the devices setup page on the Domoticz system.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.DomoticzIDX`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.DomoticzIDX`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -1,8 +0,0 @@
|
|||||||
# Parameter `CheckDigitIncreaseConsistency`
|
|
||||||
Default Value: `false`
|
|
||||||
|
|
||||||
!!! Warning
|
|
||||||
This is an **Expert Parameter**! Only change it if you understand what it does!
|
|
||||||
|
|
||||||
An additional consistency check.
|
|
||||||
It especially improves the zero crossing check between digits.
|
|
||||||
@@ -7,4 +7,4 @@ Allow a meter to count backwards (decreasing values).
|
|||||||
This is unusual (it means there is a negative rate) and not wanted in most cases!
|
This is unusual (it means there is a negative rate) and not wanted in most cases!
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.AllowNegativeRates`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.AllowNegativeRates`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -9,4 +9,4 @@ See [here](../Watermeter-specific-analog---digit-transition) for details.
|
|||||||
Range: `6.0` .. `9.9`.
|
Range: `6.0` .. `9.9`.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.AnalogToDigitTransitionStart`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.AnalogToDigitTransitionStart`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
# Parameter `ChangeRateThreshold`
|
# Parameter `ChangeRateThreshold`
|
||||||
Default Value: `2`
|
Default Value: `2`
|
||||||
|
|
||||||
Range: `1` .. `9`.
|
Range: `0` .. `9`.
|
||||||
|
|
||||||
Threshold parameter for change rate detection.<br>
|
Threshold parameter for change rate detection.<br>
|
||||||
This parameter is intended to compensate for small reading fluctuations that occur when the meter does not change its value for a long time (e.g. at night) or slightly turns backwards. This can eg. happen on watermeters.
|
This parameter is intended to compensate for small reading fluctuations that occur when the meter does not change its value for a long time (e.g. at night) or slightly turns backwards. This can eg. happen on watermeters.
|
||||||
@@ -10,18 +10,18 @@ It is only applied to the last digit of the read value (See example below).
|
|||||||
If the read value is within PreValue +/- Threshold, no further calculation is carried out and the Value/Prevalue remains at the old value.
|
If the read value is within PreValue +/- Threshold, no further calculation is carried out and the Value/Prevalue remains at the old value.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.ChangeRateThreshold`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.ChangeRateThreshold`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|
||||||
## Example
|
## Example
|
||||||
|
|
||||||
- Smallest ROI provides value for `0.000'x` (Eg. a water meter with 4 pointers behind the decimal point)
|
- Smallest ROI provides value for `0.000'x` (Eg. a water meter with 4 pointers behind the decimal point)
|
||||||
- ChangeRateThreshold = 2
|
- ChangeRateThreshold = 2
|
||||||
|
|
||||||
#### With `Extended Resolution` **disabled**
|
#### With `ExtendedResolution` **disabled**
|
||||||
PreValue: `123.456'7` -> Threshold = `+/-0.000'2`.<br>
|
PreValue: `123.456'7` -> Threshold = `+/-0.000'2`.<br>
|
||||||
All changes between `123.456'5` and `123.456'9` get ignored
|
All changes between `123.456'5` and `123.456'9` get ignored
|
||||||
|
|
||||||
#### With `Extended Resolution` **enabled**
|
#### With `ExtendedResolution` **enabled**
|
||||||
PreValue: `123.456'78` -> Threshold = `+/-0.000'02`.<br>
|
PreValue: `123.456'78` -> Threshold = `+/-0.000'02`.<br>
|
||||||
All changes between `123.456'76` and `123.456'80` get ignored.
|
All changes between `123.456'76` and `123.456'80` get ignored.
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,11 @@
|
|||||||
|
# Parameter `CheckDigitIncreaseConsistency`
|
||||||
|
Default Value: `false`
|
||||||
|
|
||||||
|
!!! Warning
|
||||||
|
This is an **Expert Parameter**! Only change it if you understand what it does!
|
||||||
|
|
||||||
|
An additional consistency check.
|
||||||
|
It especially improves the zero crossing check between digits.
|
||||||
|
|
||||||
|
!!! Note
|
||||||
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.CheckDigitIncreaseConsistency`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
@@ -5,4 +5,4 @@ Shift the decimal separator (positiv or negativ).
|
|||||||
Eg. to move from `m³` to `liter` (`1 m³` equals `1000 liters`), you need to set it to `+3`.
|
Eg. to move from `m³` to `liter` (`1 m³` equals `1000 liters`), you need to set it to `+3`.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.DecimalShift`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.DecimalShift`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -7,4 +7,4 @@ Use the decimal place of the last analog counter for increased accuracy.
|
|||||||
This parameter is only supported on the `*-class*` and `*-const` models! See [Choosing-the-Model](../Choosing-the-Model) for details.
|
This parameter is only supported on the `*-class*` and `*-const` models! See [Choosing-the-Model](../Choosing-the-Model) for details.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.ExtendedResolution`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.ExtendedResolution`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -6,4 +6,4 @@ This is only relevant for models which use `N`!
|
|||||||
See [here](../Choosing-the-Model) for details.
|
See [here](../Choosing-the-Model) for details.
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.IgnoreLeadingNaN`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.IgnoreLeadingNaN`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -5,4 +5,4 @@ Defines if the **Change Rate** is calculated as the difference between the last
|
|||||||
as the difference normalized to the interval (`RateChange` = difference per minute).
|
as the difference normalized to the interval (`RateChange` = difference per minute).
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.MaxRateType`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.MaxRateType`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
@@ -6,4 +6,4 @@ Maximum allowed change between two readings, if exceeded the last reading will b
|
|||||||
If negative rate is disallowed and no maximum rate value is set, one false high reading will lead to a period of missing measurements until the measurement reaches the previous false high reading. E.g. if the counter is at `600,00` and it's read incorrectly as` 610,00`, all measurements will be skipped until the counter reaches `610,00`. Setting the MaxRateValue to `0,05` leads to a rejection of all readings with a difference `> 0,05`, in this case `610,00`. The rejection also applies to correct readings with a difference `> 0,05`!
|
If negative rate is disallowed and no maximum rate value is set, one false high reading will lead to a period of missing measurements until the measurement reaches the previous false high reading. E.g. if the counter is at `600,00` and it's read incorrectly as` 610,00`, all measurements will be skipped until the counter reaches `610,00`. Setting the MaxRateValue to `0,05` leads to a rejection of all readings with a difference `> 0,05`, in this case `610,00`. The rejection also applies to correct readings with a difference `> 0,05`!
|
||||||
|
|
||||||
!!! Note
|
!!! Note
|
||||||
This parameter must be prefixed with `<NUMBER>` followed by a dot (eg. `main.MaxRateValue`). `<NUMBER>` is the name of the number sequence defined in the ROI's.
|
If you edit the config file manually, you must prefix this parameter with `<NUMBER>` followed by a dot (eg. `main.MaxRateValue`). The reason is that this parameter is specific for each `<NUMBER>` (`<NUMBER>` is the name of the number sequence defined in the ROI's).
|
||||||
|
|||||||
5
sd-card/Readme.md
Normal file
5
sd-card/Readme.md
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
# SD Card content
|
||||||
|
This folder contains the files which are required to setup the SD card.
|
||||||
|
|
||||||
|
❗ Do not directly copy this folder onto your SD card, **it will not work!** Instead, you can use any of the artifacts generaded in any of the Pipeline runs of the [Build-Pipeline](https://github.com/jomjol/AI-on-the-edge-device/actions/workflows/build.yaml).
|
||||||
|
The files in the `html` folder here only serve as templates. The real `html` folder get generated using the Github actions.
|
||||||
BIN
sd-card/config/ana-cont_1500_s2_q.tflite
Normal file
BIN
sd-card/config/ana-cont_1500_s2_q.tflite
Normal file
Binary file not shown.
@@ -43,7 +43,7 @@ AlignmentAlgo = default
|
|||||||
/config/ref1.jpg 442 142
|
/config/ref1.jpg 442 142
|
||||||
|
|
||||||
[Digits]
|
[Digits]
|
||||||
Model = /config/dig-cont_0712_s3_q.tflite
|
Model = /config/dig-cont_0900_s3_q.tflite
|
||||||
CNNGoodThreshold = 0.5
|
CNNGoodThreshold = 0.5
|
||||||
;ROIImagesLocation = /log/digit
|
;ROIImagesLocation = /log/digit
|
||||||
;ROIImagesRetention = 3
|
;ROIImagesRetention = 3
|
||||||
@@ -52,7 +52,7 @@ main.dig2 343 126 30 54 false
|
|||||||
main.dig3 391 126 30 54 false
|
main.dig3 391 126 30 54 false
|
||||||
|
|
||||||
[Analog]
|
[Analog]
|
||||||
Model = /config/ana-cont_1300_s2.tflite
|
Model = /config/ana-cont_1500_s2_q.tflite
|
||||||
CNNGoodThreshold = 0.5
|
CNNGoodThreshold = 0.5
|
||||||
;ROIImagesLocation = /log/analog
|
;ROIImagesLocation = /log/analog
|
||||||
;ROIImagesRetention = 3
|
;ROIImagesRetention = 3
|
||||||
@@ -73,7 +73,7 @@ main.MaxRateValue = 0.05
|
|||||||
main.ExtendedResolution = false
|
main.ExtendedResolution = false
|
||||||
main.IgnoreLeadingNaN = false
|
main.IgnoreLeadingNaN = false
|
||||||
ErrorMessage = true
|
ErrorMessage = true
|
||||||
CheckDigitIncreaseConsistency = false
|
main.CheckDigitIncreaseConsistency = false
|
||||||
|
|
||||||
;[MQTT]
|
;[MQTT]
|
||||||
;Uri = mqtt://IP-ADRESS:1883
|
;Uri = mqtt://IP-ADRESS:1883
|
||||||
|
|||||||
BIN
sd-card/config/dig-class100-0180-s2-q.tflite
Normal file
BIN
sd-card/config/dig-class100-0180-s2-q.tflite
Normal file
Binary file not shown.
BIN
sd-card/config/dig-cont_0900_s3_q.tflite
Normal file
BIN
sd-card/config/dig-cont_0900_s3_q.tflite
Normal file
Binary file not shown.
@@ -43,14 +43,14 @@ AlignmentAlgo = default
|
|||||||
/config/ref1.jpg 536 113
|
/config/ref1.jpg 536 113
|
||||||
|
|
||||||
[Digits]
|
[Digits]
|
||||||
Model = /config/dig-cont_0710_s3_q.tflite
|
Model = /config/dig-cont_0810_s3_q.tflite
|
||||||
CNNGoodThreshold = 0.5
|
CNNGoodThreshold = 0.5
|
||||||
;ROIImagesLocation = /log/digit
|
;ROIImagesLocation = /log/digit
|
||||||
;ROIImagesRetention = 3
|
;ROIImagesRetention = 3
|
||||||
main.dig1 438 62 49 71 false
|
main.dig1 438 62 49 71 false
|
||||||
|
|
||||||
[Analog]
|
[Analog]
|
||||||
Model = /config/ana-cont_1300_s2.tflite
|
Model = /config/ana-cont_1400_s2_q.tflite
|
||||||
;ROIImagesLocation = /log/analog
|
;ROIImagesLocation = /log/analog
|
||||||
;ROIImagesRetention = 3
|
;ROIImagesRetention = 3
|
||||||
main.ana1 452 199 120 120 false
|
main.ana1 452 199 120 120 false
|
||||||
@@ -67,7 +67,7 @@ main.AllowNegativeRates = true
|
|||||||
main.ExtendedResolution = true
|
main.ExtendedResolution = true
|
||||||
main.IgnoreLeadingNaN = false
|
main.IgnoreLeadingNaN = false
|
||||||
ErrorMessage = true
|
ErrorMessage = true
|
||||||
CheckDigitIncreaseConsistency = false
|
main.CheckDigitIncreaseConsistency = false
|
||||||
|
|
||||||
;[MQTT]
|
;[MQTT]
|
||||||
;Uri = mqtt://IP-ADRESS:1883
|
;Uri = mqtt://IP-ADRESS:1883
|
||||||
@@ -76,11 +76,14 @@ CheckDigitIncreaseConsistency = false
|
|||||||
;user = USERNAME
|
;user = USERNAME
|
||||||
;password = PASSWORD
|
;password = PASSWORD
|
||||||
RetainMessages = false
|
RetainMessages = false
|
||||||
|
;DomoticzTopicIn = undefined
|
||||||
|
;main.DomoticzIDX = undefined
|
||||||
HomeassistantDiscovery = false
|
HomeassistantDiscovery = false
|
||||||
;MeterType = other
|
;MeterType = other
|
||||||
;CACert = /config/certs/RootCA.pem
|
;CACert = /config/certs/RootCA.pem
|
||||||
;ClientCert = /config/certs/client.pem.crt
|
;ClientCert = /config/certs/client.pem.crt
|
||||||
;ClientKey = /config/certs/client.pem.key
|
;ClientKey = /config/certs/client.pem.key
|
||||||
|
;ValidateServerCert = true
|
||||||
|
|
||||||
;[InfluxDB]
|
;[InfluxDB]
|
||||||
;Uri = undefined
|
;Uri = undefined
|
||||||
@@ -133,4 +136,3 @@ TimeZone = CET-1CEST,M3.5.0,M10.5.0/3
|
|||||||
RSSIThreshold = -75
|
RSSIThreshold = -75
|
||||||
CPUFrequency = 160
|
CPUFrequency = 160
|
||||||
SetupMode = false
|
SetupMode = false
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
|
|
||||||
/* The UI can also be run locally, but you have to set the IP of your devide accordingly.
|
/* The UI can also be run locally, but you have to set the IP of your device accordingly.
|
||||||
* And you also might have to disable CORS in your webbrowser!
|
* And you also might have to disable CORS in your webbrowser!
|
||||||
|
* Eg using https://chromewebstore.google.com/detail/allow-cors-access-control/lhobafahddgcelffkeicbaginigeejlf?utm_source=ext_app_menu on chrome
|
||||||
* Keep empty to disable using it. Enabling it will break access through a forwared port, see
|
* Keep empty to disable using it. Enabling it will break access through a forwared port, see
|
||||||
* https://github.com/jomjol/AI-on-the-edge-device/issues/2681 */
|
* https://github.com/jomjol/AI-on-the-edge-device/issues/2681 */
|
||||||
var domainname_for_testing = "";
|
var domainname_for_testing = "";
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
17
sd-card/html/md5.min.js
vendored
Normal file
17
sd-card/html/md5.min.js
vendored
Normal file
File diff suppressed because one or more lines are too long
@@ -25,6 +25,7 @@
|
|||||||
</style>
|
</style>
|
||||||
|
|
||||||
<link href="firework.css?v=$COMMIT_HASH" rel="stylesheet">
|
<link href="firework.css?v=$COMMIT_HASH" rel="stylesheet">
|
||||||
|
<script src="md5.min.js?v=$COMMIT_HASH"></script>
|
||||||
<script type="text/javascript" src="jquery-3.6.0.min.js?v=$COMMIT_HASH"></script>
|
<script type="text/javascript" src="jquery-3.6.0.min.js?v=$COMMIT_HASH"></script>
|
||||||
<script type="text/javascript" src="common.js?v=$COMMIT_HASH"></script>
|
<script type="text/javascript" src="common.js?v=$COMMIT_HASH"></script>
|
||||||
<script type="text/javascript" src="firework.js?v=$COMMIT_HASH"></script>
|
<script type="text/javascript" src="firework.js?v=$COMMIT_HASH"></script>
|
||||||
@@ -142,7 +143,7 @@
|
|||||||
|
|
||||||
function doRebootAfterUpdate() {
|
function doRebootAfterUpdate() {
|
||||||
var xhttp = new XMLHttpRequest();
|
var xhttp = new XMLHttpRequest();
|
||||||
xhttp.open("GET", "/reboot", true);
|
xhttp.open("GET", domainname + "/reboot", true);
|
||||||
xhttp.send();
|
xhttp.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -169,15 +170,35 @@
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
var _toDo = domainname + "/ota?task=emptyfirmwaredir";
|
var url = domainname + "/ota?task=emptyfirmwaredir";
|
||||||
xhttp.open("GET", _toDo, true);
|
xhttp.open("GET", url, true);
|
||||||
xhttp.send();
|
xhttp.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function extract() {
|
function validateMd5(md5_on_device, callback) {
|
||||||
document.getElementById("status").innerText = "Status: Processing on device...";
|
const reader = new FileReader();
|
||||||
|
|
||||||
|
reader.onload = (event) => {
|
||||||
|
const fileContent = event.target.result;
|
||||||
|
md5_on_webbrowser = md5(fileContent);
|
||||||
|
console.log("MD5 on device: " + md5_on_device + ", MD5 on web browser: " + md5_on_webbrowser);
|
||||||
|
if (md5_on_device == md5_on_webbrowser) {
|
||||||
|
console.log("MD5 values are equal");
|
||||||
|
callback(true);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
console.log("MD5 values are NOT equal!");
|
||||||
|
callback(false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var fileInput = document.getElementById("file_selector").files;
|
||||||
|
reader.readAsArrayBuffer(fileInput[0]);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
function extract() {
|
||||||
var xhttp = new XMLHttpRequest();
|
var xhttp = new XMLHttpRequest();
|
||||||
/* first delete the old firmware */
|
/* first delete the old firmware */
|
||||||
xhttp.onreadystatechange = function() {
|
xhttp.onreadystatechange = function() {
|
||||||
@@ -186,9 +207,9 @@
|
|||||||
document.cookie = "page=overview.html?v=$COMMIT_HASH" + "; path=/"; // Make sure after the reboot we go to the overview page
|
document.cookie = "page=overview.html?v=$COMMIT_HASH" + "; path=/"; // Make sure after the reboot we go to the overview page
|
||||||
|
|
||||||
if (xhttp.responseText.startsWith("reboot")) { // Reboot required
|
if (xhttp.responseText.startsWith("reboot")) { // Reboot required
|
||||||
console.log("Upload completed, the device will now restart and install the update!");
|
console.log("The device will now reboot and install the update!");
|
||||||
document.getElementById("status").innerText = "Status: Installing...";
|
document.getElementById("status").innerText = "Status: Installing...";
|
||||||
firework.launch('Upload completed, the device will now restart and install the update', 'success', 5000);
|
firework.launch('Upload completed and validated. The device will now reboot and install the update', 'success', 5000);
|
||||||
|
|
||||||
/* Tell it to reboot */
|
/* Tell it to reboot */
|
||||||
doRebootAfterUpdate();
|
doRebootAfterUpdate();
|
||||||
@@ -228,8 +249,8 @@
|
|||||||
|
|
||||||
var file_name = document.getElementById("file_selector").value;
|
var file_name = document.getElementById("file_selector").value;
|
||||||
filePath = file_name.split(/[\\\/]/).pop();
|
filePath = file_name.split(/[\\\/]/).pop();
|
||||||
var _toDo = domainname + "/ota?task=update&file=" + filePath;
|
var url = domainname + "/ota?task=update&file=" + filePath;
|
||||||
xhttp.open("GET", _toDo, true);
|
xhttp.open("GET", url, true);
|
||||||
xhttp.send();
|
xhttp.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -242,7 +263,7 @@
|
|||||||
function upload() {
|
function upload() {
|
||||||
document.getElementById("status").innerText = "Status: Uploading...";
|
document.getElementById("status").innerText = "Status: Uploading...";
|
||||||
|
|
||||||
var upload_path = "/upload/firmware/" + filePath;
|
var url = domainname + "/upload/firmware/" + filePath + "?md5";
|
||||||
|
|
||||||
var file = _("file_selector").files[0];
|
var file = _("file_selector").files[0];
|
||||||
var formdata = new FormData();
|
var formdata = new FormData();
|
||||||
@@ -253,7 +274,7 @@
|
|||||||
ajax.addEventListener("error", errorHandler, false);
|
ajax.addEventListener("error", errorHandler, false);
|
||||||
ajax.addEventListener("abort", abortHandler, false);
|
ajax.addEventListener("abort", abortHandler, false);
|
||||||
|
|
||||||
ajax.open("POST", upload_path);
|
ajax.open("POST", url);
|
||||||
ajax.send(file);
|
ajax.send(file);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -263,16 +284,43 @@
|
|||||||
" MB of " + (event.total / 1024/ 1024).toFixed(2) + " MB";
|
" MB of " + (event.total / 1024/ 1024).toFixed(2) + " MB";
|
||||||
var percent = (event.loaded / event.total) * 100;
|
var percent = (event.loaded / event.total) * 100;
|
||||||
_("progressBar").value = Math.round(percent);
|
_("progressBar").value = Math.round(percent);
|
||||||
_("status").innerHTML = "Status: " + Math.round(percent) + "% uploaded. Please wait...";
|
|
||||||
|
if (Math.round(percent) == 100) {
|
||||||
|
_("progressBar").value = 0; //will clear progress bar after successful upload
|
||||||
|
_("loaded_n_total").innerHTML = "";
|
||||||
|
_("status").innerHTML = "Status: Upload completed. Validating file...";
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
_("status").innerHTML = "Status: " + Math.round(percent) + "% uploaded...";
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function completeHandler(event) {
|
function completeHandler(event) {
|
||||||
_("status").innerHTML = "Status: " + event.target.responseText;
|
console.log("Upload completed");
|
||||||
_("progressBar").value = 0; //will clear progress bar after successful upload
|
console.log("Response: " + event.target.responseText);
|
||||||
_("loaded_n_total").innerHTML = "";
|
|
||||||
|
|
||||||
extract();
|
try {
|
||||||
|
md5_on_device = JSON.parse(event.target.responseText).md5;
|
||||||
|
validateMd5(md5_on_device, (result) => {
|
||||||
|
if (result == true) {
|
||||||
|
_("status").innerHTML = "Status: The uploaded file is valid, installing it...";
|
||||||
|
extract();
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
_("status").innerHTML = "Status: The file got corrupted! Please upload it again!";
|
||||||
|
firework.launch('Upload failed, the file got corrupted! Please upload it again!', 'danger', 30000);
|
||||||
|
document.getElementById("start_OTA_button").disabled = false;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
catch (e) {
|
||||||
|
// If the firmware is to old, it will return the file sever page instead of the JSON object with the MD5 sum.
|
||||||
|
// In juch case just proceed to keep legacy support.
|
||||||
|
console.log("It seems to be a legacy firmware, installing the update without validation!");
|
||||||
|
_("status").innerHTML = "Status: It seems to be a legacy firmware, installing the update without validation...";
|
||||||
|
extract();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ var ref = new Array(2);
|
|||||||
var NUMBERS = new Array(0);
|
var NUMBERS = new Array(0);
|
||||||
var REFERENCES = new Array(0);
|
var REFERENCES = new Array(0);
|
||||||
|
|
||||||
|
|
||||||
function getNUMBERSList() {
|
function getNUMBERSList() {
|
||||||
_domainname = getDomainname();
|
_domainname = getDomainname();
|
||||||
var namenumberslist = "";
|
var namenumberslist = "";
|
||||||
@@ -33,7 +32,6 @@ function getNUMBERSList() {
|
|||||||
return namenumberslist;
|
return namenumberslist;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getDATAList() {
|
function getDATAList() {
|
||||||
_domainname = getDomainname();
|
_domainname = getDomainname();
|
||||||
datalist = "";
|
datalist = "";
|
||||||
@@ -62,7 +60,6 @@ function getDATAList() {
|
|||||||
return datalist;
|
return datalist;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getTFLITEList() {
|
function getTFLITEList() {
|
||||||
_domainname = getDomainname();
|
_domainname = getDomainname();
|
||||||
tflitelist = "";
|
tflitelist = "";
|
||||||
@@ -90,7 +87,6 @@ function getTFLITEList() {
|
|||||||
return tflitelist;
|
return tflitelist;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function ParseConfig() {
|
function ParseConfig() {
|
||||||
config_split = config_gesamt.split("\n");
|
config_split = config_gesamt.split("\n");
|
||||||
var aktline = 0;
|
var aktline = 0;
|
||||||
@@ -172,7 +168,7 @@ function ParseConfig() {
|
|||||||
category[catname]["enabled"] = false;
|
category[catname]["enabled"] = false;
|
||||||
category[catname]["found"] = false;
|
category[catname]["found"] = false;
|
||||||
param[catname] = new Object();
|
param[catname] = new Object();
|
||||||
ParamAddValue(param, catname, "DecimalShift", 1, true);
|
ParamAddValue(param, catname, "DecimalShift", 1, true, "0");
|
||||||
ParamAddValue(param, catname, "AnalogToDigitTransitionStart", 1, true, "9.2");
|
ParamAddValue(param, catname, "AnalogToDigitTransitionStart", 1, true, "9.2");
|
||||||
ParamAddValue(param, catname, "ChangeRateThreshold", 1, true, "2");
|
ParamAddValue(param, catname, "ChangeRateThreshold", 1, true, "2");
|
||||||
// ParamAddValue(param, catname, "PreValueUse", 1, true, "true");
|
// ParamAddValue(param, catname, "PreValueUse", 1, true, "true");
|
||||||
@@ -185,7 +181,7 @@ function ParseConfig() {
|
|||||||
ParamAddValue(param, catname, "IgnoreLeadingNaN", 1, true, "false");
|
ParamAddValue(param, catname, "IgnoreLeadingNaN", 1, true, "false");
|
||||||
// ParamAddValue(param, catname, "IgnoreAllNaN", 1, true, "false");
|
// ParamAddValue(param, catname, "IgnoreAllNaN", 1, true, "false");
|
||||||
ParamAddValue(param, catname, "ErrorMessage");
|
ParamAddValue(param, catname, "ErrorMessage");
|
||||||
ParamAddValue(param, catname, "CheckDigitIncreaseConsistency");
|
ParamAddValue(param, catname, "CheckDigitIncreaseConsistency", 1, true, "false");
|
||||||
|
|
||||||
var catname = "MQTT";
|
var catname = "MQTT";
|
||||||
category[catname] = new Object();
|
category[catname] = new Object();
|
||||||
@@ -359,7 +355,6 @@ function ParseConfig() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function ParamAddValue(param, _cat, _param, _anzParam = 1, _isNUMBER = false, _defaultValue = "", _checkRegExList = null) {
|
function ParamAddValue(param, _cat, _param, _anzParam = 1, _isNUMBER = false, _defaultValue = "", _checkRegExList = null) {
|
||||||
param[_cat][_param] = new Object();
|
param[_cat][_param] = new Object();
|
||||||
param[_cat][_param]["found"] = false;
|
param[_cat][_param]["found"] = false;
|
||||||
@@ -371,7 +366,6 @@ function ParamAddValue(param, _cat, _param, _anzParam = 1, _isNUMBER = false, _d
|
|||||||
param[_cat][_param].checkRegExList = _checkRegExList;
|
param[_cat][_param].checkRegExList = _checkRegExList;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
function ParseConfigParamAll(_aktline, _catname) {
|
function ParseConfigParamAll(_aktline, _catname) {
|
||||||
++_aktline;
|
++_aktline;
|
||||||
|
|
||||||
@@ -403,7 +397,6 @@ function ParseConfigParamAll(_aktline, _catname) {
|
|||||||
return _aktline;
|
return _aktline;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function ParamExtractValue(_param, _linesplit, _catname, _paramname, _aktline, _iscom, _anzvalue = 1) {
|
function ParamExtractValue(_param, _linesplit, _catname, _paramname, _aktline, _iscom, _anzvalue = 1) {
|
||||||
if ((_linesplit[0].toUpperCase() == _paramname.toUpperCase()) && (_linesplit.length > _anzvalue)) {
|
if ((_linesplit[0].toUpperCase() == _paramname.toUpperCase()) && (_linesplit.length > _anzvalue)) {
|
||||||
_param[_catname][_paramname]["found"] = true;
|
_param[_catname][_paramname]["found"] = true;
|
||||||
@@ -417,7 +410,6 @@ function ParamExtractValue(_param, _linesplit, _catname, _paramname, _aktline, _
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function ParamExtractValueAll(_param, _linesplit, _catname, _aktline, _iscom) {
|
function ParamExtractValueAll(_param, _linesplit, _catname, _aktline, _iscom) {
|
||||||
for (var paramname in _param[_catname]) {
|
for (var paramname in _param[_catname]) {
|
||||||
_AktROI = "default";
|
_AktROI = "default";
|
||||||
@@ -475,7 +467,6 @@ function ParamExtractValueAll(_param, _linesplit, _catname, _aktline, _iscom) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getCamConfig() {
|
function getCamConfig() {
|
||||||
ParseConfig();
|
ParseConfig();
|
||||||
|
|
||||||
@@ -653,12 +644,10 @@ function getCamConfig() {
|
|||||||
return param;
|
return param;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getConfigParameters() {
|
function getConfigParameters() {
|
||||||
return param;
|
return param;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function WriteConfigININew() {
|
function WriteConfigININew() {
|
||||||
// Cleanup empty NUMBERS
|
// Cleanup empty NUMBERS
|
||||||
for (var j = 0; j < NUMBERS.length; ++j) {
|
for (var j = 0; j < NUMBERS.length; ++j) {
|
||||||
@@ -760,7 +749,6 @@ function WriteConfigININew() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function isCommented(input) {
|
function isCommented(input) {
|
||||||
let isComment = false;
|
let isComment = false;
|
||||||
|
|
||||||
@@ -772,7 +760,6 @@ function isCommented(input) {
|
|||||||
return [isComment, input];
|
return [isComment, input];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function SaveConfigToServer(_domainname){
|
function SaveConfigToServer(_domainname){
|
||||||
// leere Zeilen am Ende löschen
|
// leere Zeilen am Ende löschen
|
||||||
var zw = config_split.length - 1;
|
var zw = config_split.length - 1;
|
||||||
@@ -792,17 +779,14 @@ function SaveConfigToServer(_domainname){
|
|||||||
FileSendContent(config_gesamt, "/config/config.ini", _domainname);
|
FileSendContent(config_gesamt, "/config/config.ini", _domainname);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getConfig() {
|
function getConfig() {
|
||||||
return config_gesamt;
|
return config_gesamt;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getConfigCategory() {
|
function getConfigCategory() {
|
||||||
return category;
|
return category;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function ExtractROIs(_aktline, _type){
|
function ExtractROIs(_aktline, _type){
|
||||||
var linesplit = ZerlegeZeile(_aktline);
|
var linesplit = ZerlegeZeile(_aktline);
|
||||||
abc = getNUMBERS(linesplit[0], _type);
|
abc = getNUMBERS(linesplit[0], _type);
|
||||||
@@ -819,7 +803,6 @@ function ExtractROIs(_aktline, _type){
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getNUMBERS(_name, _type, _create = true) {
|
function getNUMBERS(_name, _type, _create = true) {
|
||||||
_pospunkt = _name.indexOf (".");
|
_pospunkt = _name.indexOf (".");
|
||||||
|
|
||||||
@@ -879,7 +862,6 @@ function getNUMBERS(_name, _type, _create = true) {
|
|||||||
return neuroi;
|
return neuroi;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function CopyReferenceToImgTmp(_domainname) {
|
function CopyReferenceToImgTmp(_domainname) {
|
||||||
for (index = 0; index < 2; ++index) {
|
for (index = 0; index < 2; ++index) {
|
||||||
_filenamevon = REFERENCES[index]["name"];
|
_filenamevon = REFERENCES[index]["name"];
|
||||||
@@ -894,12 +876,10 @@ function CopyReferenceToImgTmp(_domainname) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function GetReferencesInfo(){
|
function GetReferencesInfo(){
|
||||||
return REFERENCES;
|
return REFERENCES;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function UpdateConfigReferences(_domainname){
|
function UpdateConfigReferences(_domainname){
|
||||||
for (var index = 0; index < 2; ++index) {
|
for (var index = 0; index < 2; ++index) {
|
||||||
_filenamenach = REFERENCES[index]["name"];
|
_filenamenach = REFERENCES[index]["name"];
|
||||||
@@ -914,7 +894,6 @@ function UpdateConfigReferences(_domainname){
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function UpdateConfigReference(_anzneueref, _domainname){
|
function UpdateConfigReference(_anzneueref, _domainname){
|
||||||
var index = 0;
|
var index = 0;
|
||||||
|
|
||||||
@@ -939,12 +918,10 @@ function UpdateConfigReference(_anzneueref, _domainname){
|
|||||||
FileCopyOnServer(_filenamevon, _filenamenach, _domainname);
|
FileCopyOnServer(_filenamevon, _filenamenach, _domainname);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getNUMBERInfo(){
|
function getNUMBERInfo(){
|
||||||
return NUMBERS;
|
return NUMBERS;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function RenameNUMBER(_alt, _neu){
|
function RenameNUMBER(_alt, _neu){
|
||||||
if ((_neu.indexOf(".") >= 0) || (_neu.indexOf(",") >= 0) || (_neu.indexOf(" ") >= 0) || (_neu.indexOf("\"") >= 0)) {
|
if ((_neu.indexOf(".") >= 0) || (_neu.indexOf(",") >= 0) || (_neu.indexOf(" ") >= 0) || (_neu.indexOf("\"") >= 0)) {
|
||||||
return "Number sequence name must not contain , . \" or a space";
|
return "Number sequence name must not contain , . \" or a space";
|
||||||
@@ -972,7 +949,6 @@ function RenameNUMBER(_alt, _neu){
|
|||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function DeleteNUMBER(_delete){
|
function DeleteNUMBER(_delete){
|
||||||
if (NUMBERS.length == 1) {
|
if (NUMBERS.length == 1) {
|
||||||
return "One number sequence is mandatory. Therefore this cannot be deleted"
|
return "One number sequence is mandatory. Therefore this cannot be deleted"
|
||||||
@@ -993,7 +969,6 @@ function DeleteNUMBER(_delete){
|
|||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function CreateNUMBER(_numbernew){
|
function CreateNUMBER(_numbernew){
|
||||||
found = false;
|
found = false;
|
||||||
|
|
||||||
@@ -1041,7 +1016,6 @@ function CreateNUMBER(_numbernew){
|
|||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function getROIInfo(_typeROI, _number){
|
function getROIInfo(_typeROI, _number){
|
||||||
index = -1;
|
index = -1;
|
||||||
|
|
||||||
@@ -1059,7 +1033,6 @@ function getROIInfo(_typeROI, _number){
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function RenameROI(_number, _type, _alt, _neu){
|
function RenameROI(_number, _type, _alt, _neu){
|
||||||
if ((_neu.includes("=")) || (_neu.includes(".")) || (_neu.includes(":")) || (_neu.includes(",")) || (_neu.includes(";")) || (_neu.includes(" ")) || (_neu.includes("\""))) {
|
if ((_neu.includes("=")) || (_neu.includes(".")) || (_neu.includes(":")) || (_neu.includes(",")) || (_neu.includes(";")) || (_neu.includes(" ")) || (_neu.includes("\""))) {
|
||||||
return "ROI name must not contain . : , ; = \" or space";
|
return "ROI name must not contain . : , ; = \" or space";
|
||||||
@@ -1098,7 +1071,6 @@ function RenameROI(_number, _type, _alt, _neu){
|
|||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function DeleteNUMBER(_delte) {
|
function DeleteNUMBER(_delte) {
|
||||||
if (NUMBERS.length == 1) {
|
if (NUMBERS.length == 1) {
|
||||||
return "The last number cannot be deleted"
|
return "The last number cannot be deleted"
|
||||||
@@ -1119,7 +1091,6 @@ function DeleteNUMBER(_delte) {
|
|||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function CreateROI(_number, _type, _pos, _roinew, _x, _y, _dx, _dy, _CCW){
|
function CreateROI(_number, _type, _pos, _roinew, _x, _y, _dx, _dy, _CCW){
|
||||||
_indexnumber = -1;
|
_indexnumber = -1;
|
||||||
|
|
||||||
|
|||||||
3
webinstaller/Readme.md
Normal file
3
webinstaller/Readme.md
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
# Webinstaller
|
||||||
|
This folder is used to provide the required files to generate the [Web-Installer](https://jomjol.github.io/AI-on-the-edge-device/).
|
||||||
|
The Webinstaller gets automatically updated on a release using the Github actions.
|
||||||
2
webinstaller/binary/Readme.md
Normal file
2
webinstaller/binary/Readme.md
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
# Binary folder of the webinstaller
|
||||||
|
The firmware itself (`firmware.bin`) gets copied to this folder through the Github action.
|
||||||
@@ -67,21 +67,19 @@
|
|||||||
|
|
||||||
<div class="footer">
|
<div class="footer">
|
||||||
<div class="footer-section">
|
<div class="footer-section">
|
||||||
<span>Support & Contact Us</span>
|
<span>Support & Contact</span>
|
||||||
<a href="https://github.com/jomjol/AI-on-the-edge-device" target="_blank" title="GitHub">
|
<a href="https://github.com/jomjol/AI-on-the-edge-device" target="_blank" title="GitHub">
|
||||||
<img src="https://github.com/jomjol/AI-on-the-edge-device/images/github-logo.png" alt="GitHub">
|
<img src="https://raw.githubusercontent.com/jomjol/AI-on-the-edge-device/refs/heads/main/images/github-logo.png" alt="GitHub">
|
||||||
</a>
|
|
||||||
<img src="https://github.com/jomjol/AI-on-the-edge-device/images/gmail-logo.png" alt="Email">
|
|
||||||
</a>
|
</a>
|
||||||
<a href="https://github.com/jomjol/AI-on-the-edge-device/discussions" target="_blank" title="GitHub">
|
<a href="https://github.com/jomjol/AI-on-the-edge-device/discussions" target="_blank" title="GitHub">
|
||||||
<img src="https://github.com/jomjol/AI-on-the-edge-device/images/discussion-logo" alt="GitHub">
|
<img src="https://raw.githubusercontent.com/jomjol/AI-on-the-edge-device/refs/heads/main/images/discussion-logo.png" alt="GitHub">
|
||||||
</a>
|
</a>
|
||||||
|
|
||||||
</div>
|
</div>
|
||||||
<div class="footer-section">
|
<div class="footer-section">
|
||||||
<span>Donations</span>
|
<span>Donations</span>
|
||||||
<a href="https://www.paypal.com/donate?hosted_button_id=8TRSVYNYKDSWL" target="_blank" title="Donate via PayPal">
|
<a href="https://www.paypal.com/donate?hosted_button_id=8TRSVYNYKDSWL" target="_blank" title="Donate via PayPal">
|
||||||
<img src="https://github.com/jomjol/AI-on-the-edge-device/images/paypal.png" alt="PayPal" style="width: 60px; height: auto;">
|
<img src="https://raw.githubusercontent.com/jomjol/AI-on-the-edge-device/refs/heads/main/images/paypal.png" alt="PayPal" style="width: 60px; height: auto;">
|
||||||
</a>
|
</a>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
Reference in New Issue
Block a user