Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d2b3d4f6ea | |||
| f3d327f28f | |||
| 2b05d8c952 |
+96
-9
@@ -67,12 +67,69 @@ PY
|
||||
fi
|
||||
}
|
||||
|
||||
if [ -z "$1" ]; then
|
||||
update_runtime_ports() {
|
||||
local new_port="$1"
|
||||
local env_file="$PWD/.docker-build.env"
|
||||
local current_ports=""
|
||||
local port_list=()
|
||||
local unique_ports=()
|
||||
local first_port=""
|
||||
if [ -n "$new_port" ]; then
|
||||
if [ -f "$env_file" ]; then
|
||||
current_ports="$(awk -F= '/^INVENTAR_HTTP_PORTS=/{print $2; exit}' "$env_file" | tr -d ' ' || true)"
|
||||
if [ -z "$current_ports" ]; then
|
||||
current_ports="$(awk -F= '/^INVENTAR_HTTP_PORT=/{print $2; exit}' "$env_file" | tr -d ' ' || true)"
|
||||
fi
|
||||
fi
|
||||
|
||||
if [ -n "$current_ports" ]; then
|
||||
IFS=',' read -r -a port_list <<<"${current_ports// /,}"
|
||||
fi
|
||||
port_list+=("$new_port")
|
||||
|
||||
for port in "${port_list[@]}"; do
|
||||
if [ -n "$port" ] && ! printf '%s\n' "${unique_ports[@]}" | grep -qx "$port"; then
|
||||
unique_ports+=("$port")
|
||||
fi
|
||||
done
|
||||
|
||||
if [ ${#unique_ports[@]} -eq 0 ]; then
|
||||
unique_ports=("$new_port")
|
||||
fi
|
||||
|
||||
first_port="${unique_ports[0]}"
|
||||
local ports_csv
|
||||
ports_csv="$(IFS=,; echo "${unique_ports[*]}")"
|
||||
|
||||
if [ ! -f "$env_file" ]; then
|
||||
cat > "$env_file" <<EOF
|
||||
NUITKA_BUILD=0
|
||||
INVENTAR_HTTP_PORT=$first_port
|
||||
INVENTAR_HTTP_PORTS=$ports_csv
|
||||
EOF
|
||||
else
|
||||
if grep -q '^INVENTAR_HTTP_PORTS=' "$env_file" 2>/dev/null; then
|
||||
sed -i "s|^INVENTAR_HTTP_PORTS=.*|INVENTAR_HTTP_PORTS=$ports_csv|" "$env_file"
|
||||
else
|
||||
printf '\nINVENTAR_HTTP_PORTS=%s\n' "$ports_csv" >> "$env_file"
|
||||
fi
|
||||
if grep -q '^INVENTAR_HTTP_PORT=' "$env_file" 2>/dev/null; then
|
||||
sed -i "s|^INVENTAR_HTTP_PORT=.*|INVENTAR_HTTP_PORT=$first_port|" "$env_file"
|
||||
else
|
||||
printf '\nINVENTAR_HTTP_PORT=%s\n' "$first_port" >> "$env_file"
|
||||
fi
|
||||
fi
|
||||
|
||||
echo "Updated runtime env ports: $ports_csv"
|
||||
fi
|
||||
}
|
||||
|
||||
if [ -z "${1:-}" ]; then
|
||||
show_help
|
||||
fi
|
||||
|
||||
COMMAND=$1
|
||||
TENANT_ID=$2
|
||||
COMMAND="$1"
|
||||
TENANT_ID="${2:-}"
|
||||
|
||||
case "$COMMAND" in
|
||||
-h|--help)
|
||||
@@ -91,6 +148,7 @@ case "$COMMAND" in
|
||||
exit 1
|
||||
fi
|
||||
register_tenant_port "$TENANT_ID" "$PORT_ARG"
|
||||
update_runtime_ports "$PORT_ARG"
|
||||
fi
|
||||
|
||||
echo "Adding new tenant '$TENANT_ID'..."
|
||||
@@ -169,17 +227,46 @@ print(f'Tenant {sys.argv[1]} session cache cleared. Tenant restarted.')
|
||||
;;
|
||||
|
||||
list)
|
||||
echo "Listing active tenants (Databases):"
|
||||
echo "Listing configured tenants (config.json):"
|
||||
if [ -f "$CONFIG_FILE" ]; then
|
||||
python3 - "$CONFIG_FILE" <<'PY'
|
||||
import json, sys
|
||||
path = sys.argv[1]
|
||||
with open(path, 'r', encoding='utf-8') as f:
|
||||
cfg = json.load(f)
|
||||
tenants = cfg.get('tenants', {})
|
||||
if isinstance(tenants, dict) and tenants:
|
||||
for tid, conf in tenants.items():
|
||||
port = conf.get('port') if isinstance(conf, dict) else None
|
||||
if port is not None:
|
||||
print(f'- {tid} (port {port})')
|
||||
else:
|
||||
print(f'- {tid}')
|
||||
else:
|
||||
print(' (no tenants configured)')
|
||||
PY
|
||||
else
|
||||
echo " (config.json not found)"
|
||||
fi
|
||||
|
||||
echo ""
|
||||
echo "Listing active tenant databases (MongoDB):"
|
||||
APP_CONTAINER=$(docker ps -qf "name=app" | head -n 1)
|
||||
if [ -n "$APP_CONTAINER" ]; then
|
||||
docker exec $APP_CONTAINER python3 -c "
|
||||
import sys; sys.path.insert(0, '/app/Web'); import settings; from pymongo import MongoClient
|
||||
docker exec -i "$APP_CONTAINER" python3 - <<'PY'
|
||||
import sys
|
||||
sys.path.insert(0, '/app/Web')
|
||||
import settings
|
||||
from pymongo import MongoClient
|
||||
client = MongoClient(settings.MONGODB_HOST, int(settings.MONGODB_PORT))
|
||||
prefix = f'{settings.MONGODB_DB}_'
|
||||
dbs = [d for d in client.list_database_names() if d.startswith(prefix)]
|
||||
for db in dbs:
|
||||
print(f'- {db.replace(prefix, \"\")}')
|
||||
"
|
||||
if dbs:
|
||||
for db in dbs:
|
||||
print(f'- {db.replace(prefix, "")}')
|
||||
else:
|
||||
print(' (no tenant databases found)')
|
||||
PY
|
||||
else
|
||||
echo "Error: Application container not running."
|
||||
fi
|
||||
|
||||
@@ -419,6 +419,7 @@ configure_host_ports() {
|
||||
local requested_http
|
||||
local requested_ports
|
||||
local ports=()
|
||||
local occupied_ports=()
|
||||
|
||||
requested_http=""
|
||||
requested_ports=""
|
||||
@@ -442,15 +443,33 @@ configure_host_ports() {
|
||||
if [ ${#ports[@]} -gt 0 ]; then
|
||||
HTTP_PORTS_VALUE="${ports[*]}"
|
||||
HTTP_PORT_VALUE="${ports[0]}"
|
||||
|
||||
for port in "${ports[@]}"; do
|
||||
if port_in_use "$port"; then
|
||||
occupied_ports+=("$port")
|
||||
fi
|
||||
done
|
||||
|
||||
if [ ${#occupied_ports[@]} -gt 0 ]; then
|
||||
if [ ${#ports[@]} -eq 1 ]; then
|
||||
HTTP_PORT_VALUE="$(find_free_port "$DEFAULT_TENANT_PORT_START")"
|
||||
echo "Host port ${ports[0]} is already occupied. Assigned new tenant port: $HTTP_PORT_VALUE"
|
||||
HTTP_PORTS_VALUE="$HTTP_PORT_VALUE"
|
||||
else
|
||||
echo "Error: requested host port(s) already in use: ${occupied_ports[*]}"
|
||||
echo "Remove the occupied port(s) from INVENTAR_HTTP_PORTS or stop the conflicting service."
|
||||
exit 1
|
||||
fi
|
||||
fi
|
||||
else
|
||||
HTTP_PORT_VALUE="$DEFAULT_TENANT_PORT_START"
|
||||
HTTP_PORTS_VALUE="$HTTP_PORT_VALUE"
|
||||
fi
|
||||
|
||||
if port_in_use "$HTTP_PORT_VALUE"; then
|
||||
HTTP_PORT_VALUE="$(find_free_port "$DEFAULT_TENANT_PORT_START")"
|
||||
echo "Host port ${ports[0]:-$DEFAULT_TENANT_PORT_START} is already occupied. Assigned new tenant port: $HTTP_PORT_VALUE"
|
||||
HTTP_PORTS_VALUE="$HTTP_PORT_VALUE"
|
||||
if port_in_use "$HTTP_PORT_VALUE"; then
|
||||
HTTP_PORT_VALUE="$(find_free_port "$DEFAULT_TENANT_PORT_START")"
|
||||
echo "Host port $DEFAULT_TENANT_PORT_START is already occupied. Assigned new tenant port: $HTTP_PORT_VALUE"
|
||||
HTTP_PORTS_VALUE="$HTTP_PORT_VALUE"
|
||||
fi
|
||||
fi
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user