Skip to content

feat(SPOE-port): allow define custom port number for internal SPOE agent #80

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
oleksandr-nc merged 2 commits into from
Jan 5, 2026
Merged

feat(SPOE-port): allow define custom port number for internal SPOE agent #80

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
5834547
feat(SPOE-port): allow define custom port number for internal SPOE agent
oleksandr-nc Jan 5, 2026
1a9492b
update README.md
oleksandr-nc Jan 5, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Dockerfile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@ USER root
ENV HP_EXAPPS_ADDRESS="0.0.0.0:8780" \
HP_EXAPPS_HTTPS_ADDRESS="0.0.0.0:8781" \
HP_FRP_ADDRESS="0.0.0.0:8782" \
HP_SPOA_ADDRESS="127.0.0.1:9600" \
HP_FRP_DISABLE_TLS="false" \
HP_TIMEOUT_CONNECT="30s" \
HP_TIMEOUT_CLIENT="30s" \
Expand Down
3 changes: 2 additions & 1 deletion haproxy.cfg.template
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
# This template is processed by envsubst in start.sh to replace variables:
# HP_EXAPPS_ADDRESS,
# HP_EXAPPS_HTTPS_ADDRESS,
# HP_SPOA_ADDRESS,
# HP_TIMEOUT_CONNECT,
# HP_TIMEOUT_CLIENT,
# HP_TIMEOUT_SERVER,
Expand Down Expand Up @@ -119,4 +120,4 @@ backend agents
timeout connect 5s
timeout server 3m
option spop-check
server agent1 127.0.0.1:9600 check
server agent1 ${HP_SPOA_ADDRESS} check
7 changes: 5 additions & 2 deletions haproxy_agent.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,9 @@
APPID_PATTERN = re.compile(r"(?:^|/)exapps/([^/]+)")
SHARED_KEY = os.environ.get("HP_SHARED_KEY")
NC_INSTANCE_URL = os.environ.get("NC_INSTANCE_URL")
SPOA_ADDRESS = os.environ.get("HP_SPOA_ADDRESS", "127.0.0.1:9600")
SPOA_HOST, SPOA_PORT = SPOA_ADDRESS.rsplit(":", 1)
SPOA_PORT = int(SPOA_PORT)
# Set up the logging configuration
LOG_LEVEL = os.environ["HP_LOG_LEVEL"].upper()
logging.basicConfig(level=LOG_LEVEL)
Expand Down Expand Up @@ -1705,10 +1708,10 @@ async def run_http_server(host="127.0.0.1", port=8200):


async def main():
spoa_task = asyncio.create_task(SPOA_AGENT._run(host="127.0.0.1", port=9600)) # noqa
spoa_task = asyncio.create_task(SPOA_AGENT._run(host=SPOA_HOST, port=SPOA_PORT)) # noqa
http_task = asyncio.create_task(run_http_server(host="127.0.0.1", port=8200))

LOGGER.info("Starting both servers: SPOA on 127.0.0.1:9600, HTTP on 127.0.0.1:8200")
LOGGER.info("Starting both servers: SPOA on %s:%d, HTTP on 127.0.0.1:8200", SPOA_HOST, SPOA_PORT)
await asyncio.gather(spoa_task, http_task)


Expand Down
11 changes: 4 additions & 7 deletions healthcheck.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
# healthcheck.sh
# - Validates HAProxy config syntax.
# - Checks if Python SPOE HTTP Control API is listening on 127.0.0.1:8200.
# - Checks if SPOE Agent is running on 127.0.0.1:9600.
# - Checks if SPOE Agent is running on HP_SPOA_ADDRESS (default 127.0.0.1:9600).
# - Checks FRP port at HP_FRP_ADDRESS.
# - Checks EXAPPS HTTP frontend, and also the EXAPPS HTTPS frontend if the /certs/cert.pem file exists.
#
Expand All @@ -26,12 +26,6 @@ if ! nc -z 127.0.0.1 8200; then
exit 1
fi

# 3) Check SPOE Agent port on 127.0.0.1:9600
if ! nc -z 127.0.0.1 9600; then
echo "ERROR: SPOE Agent not responding on 127.0.0.1:9600"
exit 1
fi

# Helper: netcat a given "host:port"
check_port () {
local fulladdr="$1"
Expand All @@ -53,6 +47,9 @@ check_port () {
fi
}

# 3) Check SPOE Agent port
check_port "${HP_SPOA_ADDRESS:-127.0.0.1:9600}"

# 4) Check FRP port
check_port "${HP_FRP_ADDRESS:-0.0.0.0:8782}"

Expand Down
13 changes: 9 additions & 4 deletions start.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ set -e
# - Reads HP_SHARED_KEY or HP_SHARED_KEY_FILE
# - Comments out HTTPS frontends if no /certs/cert.pem is found
# - Starts FRP server (frps) on HP_FRP_ADDRESS
# - Starts the Python SPOE agent on 127.0.0.1:9600
# - Starts the Python SPOE agent on HP_SPOA_ADDRESS
# - Launches Python SPOE HTTP Control API on 127.0.0.1:8200
# - Finally runs HAProxy in the foreground
#
Expand Down Expand Up @@ -108,6 +108,11 @@ fi
FRP_HOST="$(echo "$HP_FRP_ADDRESS" | cut -d':' -f1)"
FRP_PORT="$(echo "$HP_FRP_ADDRESS" | cut -d':' -f2)"

# Initialize SPOA_HOST and SPOA_PORT from HP_SPOA_ADDRESS (default 127.0.0.1:9600).
HP_SPOA_ADDRESS="${HP_SPOA_ADDRESS:-127.0.0.1:9600}"
SPOA_HOST="$(echo "$HP_SPOA_ADDRESS" | cut -d':' -f1)"
SPOA_PORT="$(echo "$HP_SPOA_ADDRESS" | cut -d':' -f2)"

# ----------------------------------------------------------------------------
# Map HP_LOG_LEVEL (our user-friendly strings) to valid HAProxy log levels
# ----------------------------------------------------------------------------
Expand Down Expand Up @@ -340,15 +345,15 @@ EOF
fi
fi

log "INFO: Starting Python HaProxy Agent on 127.0.0.1:8200 and 127.0.0.1:9600..."
log "INFO: Starting Python HaProxy Agent on 127.0.0.1:8200 and ${HP_SPOA_ADDRESS}..."
nohup python3 /usr/local/bin/haproxy_agent.py &

# Wait deterministically for the agent to be ready (HTTP) and for SPOA (TCP)
log "INFO: Waiting for HaRP Agent HTTP (GET http://127.0.0.1:8200/info) to be ready..."
wait_for_http "http://127.0.0.1:8200/info" "$HP_WAIT_AGENT_HTTP" "$HP_WAIT_INTERVAL"

log "INFO: Waiting for SPOA port 127.0.0.1:9600..."
wait_for_tcp "127.0.0.1" "9600" "$HP_WAIT_SPOA" "$HP_WAIT_INTERVAL"
log "INFO: Waiting for SPOA port ${HP_SPOA_ADDRESS}..."
wait_for_tcp "$SPOA_HOST" "$SPOA_PORT" "$HP_WAIT_SPOA" "$HP_WAIT_INTERVAL"

log "INFO: Starting FRP server on ${HP_FRP_ADDRESS}..."
frps -c /frps.toml &
Expand Down