Mark/deployment script fixes

CHANGELOG.md

@@ -5,7 +5,40 @@ layout: page
 ---
 
 ## Unreleased
-<!-- last-processed: 4f8345a (2026-04-29) -->
+<!-- last-processed: 14a735a -->
+
+<!-- os-dev: 14a735a (2026-06-30) -->
+
+* **Ori Shadmon** (2026-06-30)
+  * General: run schedule -> schedule
+  * Southbound / Monitoring: run schedule -> schedule; missing comma
+
+<!-- os-dev: 1eac7db (2026-06-29) -->
+
+* **Ori Shadmon** (2026-06-29)
+  * Node deployment / Policies: cluster name
+
+<!-- os-dev: 60c299c (2026-06-29) -->
+
+* **Ori Shadmon** (2026-06-29)
+  * General: water plant was missing variables integrated into it
+
+<!-- os-dev: bf794d5 (2026-06-23) -->
+
+### [bf794d5] · 2026-06-23 (latest)
+
+| Date | Commit | Author | Summary |
+|------|--------|--------|---------|
+| 2026-06-22 | — | Ori Shadmon | Removed customer- and Ori-specific files (Archive, Customers, Test) |
+| 2026-06-22 | — | Ori Shadmon | Smart city data generator reorg — improved MQTT logic, notifications, node monitoring + param configs |
+| 2026-06-22 | — | Ori Shadmon | Node deployment — zero-touch support, node/cluster naming rework, monitoring policy integration |
+| 2026-06-22 | — | Ori Shadmon | Node deployment / Database — operator helpers, monitoring DB creation, PSQL support |
+| 2026-06-22 | — | Ori Shadmon | Node deployment / Policies — cluster numbering and naming fixes, monitoring policy simplification |
+| 2026-06-22 | — | Ori Shadmon | Southbound / Industrial — Modbus mapping logic |
+| 2026-06-22 | — | Ori Shadmon | Southbound / Monitoring — node monitoring, zero-touch support, syslog and Docker monitoring |
+| 2026-06-22 | — | Ori Shadmon | Docker — working docker builder |
+| 2026-06-22 | — | Ori Shadmon | General — file naming, image builder command, versioning, changelog cleanup |
+| 2026-06-19 | — | pintomax | Sample scripts — fixed waste plan notifications |
 
 <!-- Developers: add bullets below as changes land in your branch -->
 

Dockerfile

@@ -0,0 +1,5 @@
+FROM busybox
+
+COPY . deployment-scripts/
+
+CMD ["sh", "-c", "mkdir -p /target && cp -a /deployment-scripts/. /target/ && echo 'deployment-scripts copied to volume'"]

archive/aggregation.al

@@ -0,0 +1,81 @@
+#------------------------------------------------------------------------------------------------#
+# The following provides a simple set of commands to run aggregation against the data            #
+# In addition, there's an option save a summary of the data every X time frame, as opposed to    #
+# as opposed to all the data as it comes in...                                                   #
+#                                                                                                #
+# This (sample) code is used with OPC-UA and the default MQTT example, if enabled. The code can  #
+# also be used with user-defined data sources if desired. A more comprehensive, python-based     #
+# option can be found in deployment-scripts/aggregations                                         #
+# URL: https://github.com/AnyLog-co/documentation/blob/master/aggregations.md                    #
+#                                                                                                #
+# Note: if !enable_aggregations isn't enabled script will not run                                #
+#------------------------------------------------------------------------------------------------#
+# process !local_scripts/sample-scripts/aggregations.al
+
+on error ignore
+if !aggregation_policy then config from policy where id = !aggregation_policy
+else if not !enable_aggregation then goto end-script
+
+:enable-aggregations:
+#-----------------------------------------------------------------------------#
+# Aggregation functions summarize streaming data over defined time intervals. #
+#-----------------------------------------------------------------------------#
+on error goto enable-aggregations-error
+<set aggregation where
+    dbms=!aggregations_dbms and
+    table=!aggregations_table and
+    intervals=!aggregations_intervals and
+    time=!aggregations_time  and
+    time_column=!aggregation_time_column and
+    value_column=!aggregation_value_column>
+
+
+:config-ingestion:
+#-----------------------------------------------------------------------------#
+#  modify the ingestion frequency of aggregation tables in the local database.#
+#-----------------------------------------------------------------------------#
+on error call config-ingestion-error
+if !enable_ingest_aggregations == true then
+<do set aggregation ingest where
+    dbms=!aggregations_table and
+    table=!aggregations_table and
+    source = !ingest_raw_data and
+    derived = !ingest_aggregations>
+# do get aggregation ingest
+
+
+#:configure-encoding:
+#-----------------------------------------------------------------------------#
+#  Apply encoding on the values assigned to each time interval                #
+#-----------------------------------------------------------------------------#
+on error call configure-encoding-error
+if !enable_encoding and !encoding_tolerance then
+do set aggregation encoding where
+    dbms=!aggregations_dbms and
+    table=!aggregations_table and
+    value_column=!aggregation_value_column and
+    encoding = !encoding_type and
+    tolerance = !encoding_tolerance>
+else if !enable_encoding then
+<do set aggregation encoding where
+    dbms=!aggregations_dbms and
+    table=!aggregations_table and
+    value_column=!aggregation_value_column and
+    encoding = !encoding_type>
+
+
+
+:end-script:
+end script
+
+:enable-aggregations-error:
+echo "Failed to initiate aggregations for default logical database"
+goto end-script
+
+:config-ingestion-error:
+echo "Failed to configure ingestion"
+return
+
+:configure-encoding-error:
+echo "Failed to configure encoding"
+return

archive/config_threshold.al

@@ -0,0 +1,37 @@
+#----------------------------------------------------------------------------------------------------------------------#
+# Set buffer threshold
+#----------------------------------------------------------------------------------------------------------------------#
+# process !local_scripts/policies/config_threshold.al
+
+if !debug_mode == true then 
+
+:set-params:
+if !debug_mode == true then print "Set buffer threshold"
+threshold_dbms = ""
+threshold_table = ""
+
+on error goto threshold-error
+if !threshold_dbms and !threshold_table then
+<do set buffer threshold where
+    dbms=!threshold_dbms and table=!threshold_table and
+    time=!threshold_time and
+    volume=!threshold_volume and
+    write_immediate=!write_immediate>
+if !threshold_dbms and not !threshold_table then
+<do set buffer threshold where
+    dbms=!threshold_dbms and
+    time=!threshold_time and
+    volume=!threshold_volume and
+    write_immediate=!write_immediate>
+if not !threshold_dbms and not !threshold_table then
+<do set buffer threshold where
+    time=!threshold_time and
+    volume=!threshold_volume and
+    write_immediate=!write_immediate>
+
+:end-script:
+end script
+
+:threshold-error:
+echo "Failed to set threshold"
+goto end-script

archive/connect_networking.al

@@ -0,0 +1,92 @@
+# Connect to TCP, REST and Broker (if configured) using default params
+#----------------------------------------------------------------------------------------------------------------------#
+# process !local_scripts/connect_networking.al
+
+on error ignore
+set debug off
+if !debug_mode == true then 
+
+if !overlay_ip then goto overlay-tcp-networking
+
+:tcp-networking:
+if !debug_mode == true then print "Start TCP communication service"
+
+on error goto tcp-networking-error
+<run tcp server where
+    external_ip=!external_ip and external_port=!anylog_server_port and
+    internal_ip=!ip and internal_port=!anylog_server_port and
+    bind=!tcp_bind and threads=!tcp_threads>
+
+:rest-networking:
+if !debug_mode == true then print "Start REST communication service"
+
+on error goto rest-networking-error
+<run rest server where
+    external_ip=!external_ip and external_port=!anylog_rest_port and
+    internal_ip=!ip and internal_port=!anylog_rest_port and
+    bind=!rest_bind and threads=!rest_threads and timeout=!rest_timeout>
+
+if not !anylog_broker_port then goto end-script
+
+:broker-networking:
+if !debug_mode == true then print "Start Message Broker service"
+
+on error goto broker-networking-error
+<run message broker where
+    external_ip=!external_ip and external_port=!anylog_broker_port and
+    internal_ip=!ip and internal_port=!anylog_broker_port and
+    bind=!broker_bind and threads=!broker_threads>
+ goto end-script
+
+
+:overlay-tcp-networking:
+if !debug_mode == true then print "Start TCP communication service"
+
+on error goto tcp-networking-error
+<run tcp server where
+    external_ip=!ip and external_port=!anylog_server_port and
+    internal_ip=!overlay_ip and internal_port=!anylog_server_port and
+    bind=!tcp_bind and threads=!tcp_threads>
+
+:overlay-rest-networking:
+if !debug_mode == true then print "Start REST communication service"
+
+on error goto rest-networking-error
+<run rest server where
+    external_ip=!ip and external_port=!anylog_rest_port and
+    internal_ip=!overlay_ip and internal_port=!anylog_rest_port and
+    bind=!rest_bind and threads=!rest_threads and timeout=!rest_timeout>
+
+if not !anylog_broker_port then goto end-script
+
+:overlay-broker-networking:
+if !debug_mode == true then print "Start Message Broker service"
+
+on error goto broker-networking-error
+<run message broker where
+    external_ip=!ip and external_port=!anylog_broker_port and
+    internal_ip=!!overlay_ip and internal_port=!anylog_broker_port and
+    bind=!broker_bind and threads=!broker_threads>
+ goto end-script
+
+:end-script:
+end script
+
+:terminate-scripts:
+exit scripts
+
+:tcp-networking-error:
+print "Error: Failed to connect to TCP with IP address - unable to continue deployment process"
+goto terminate-scripts
+
+:rest-networking-error:
+print "Error: Failed to connect to REST with IP address - unable to continue deployment process"
+goto terminate-scripts
+
+:broker-networking-error:
+print "Error: Failed to connect to Message Broker with IP address - will continue deployment without Message Broker"
+do goto end-script
+
+
+
+