2. Linux.do
  3. mclaw 一键安装 修改渠道保活 hooks脚本

mclaw 一键安装 修改渠道保活 hooks脚本

qwer 2026-06-10 00:30 1

根据其他大佬提供的思路，通过替换环境变量修改 mclaw 上游配置。

但是存在一个问题，如果api开启了CF小黄云，请求会被CF拦下报403。


这个脚本在原思路基础上，增加patchFetch修改User-Agent 解决403问题。


mclaw脚本功能简要概括：



使用方法：



修改 METRICS_ENDPOINT 和 METRICS_TOKEN 参数，上传脚本到云盘，让ai从云盘下载后一键执行。





code
#!/usr/bin/env bash

set -e



# 内置参数：改这里即可；脚本会用这些值写入目标副本。

METRICS_ENDPOINT="https://ccload.xxxxx/v1"

METRICS_TOKEN="sk-xxxxxxxxxxxxxxxxxxxxxxxxx"

METRICS_UA="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36"



# 常用参数：

#   OPENCLAW_HOME=...           默认 $HOME/.openclaw

#   OPENCLAW_HOOKS_DIR=...      默认 $OPENCLAW_HOME/workspace/hooks

#   METRICS_HOOK_NAME=...       默认 metrics

#   METRICS_ENABLE_HOOK=0       只安装文件，不执行 openclaw hooks enable

#   METRICS_START_WATCHDOG=0    不启动 healthcheck --watch

#   METRICS_USE_LOCAL_SOURCES=1 使用当前目录源码替代内嵌模板



say() {

  printf '[metrics-install] %s\n' "$*"

}



die() {

  printf '[metrics-install] ERROR: %s\n' "$*" >&2

  exit 1

}



SCRIPT_DIR="$(CDPATH= cd -- "$(dirname -- "$0")" && pwd)"



HOOK_NAME="${METRICS_HOOK_NAME:-metrics}"

OPENCLAW_HOME="${OPENCLAW_HOME:-$HOME/.openclaw}"

HOOKS_ROOT="${OPENCLAW_HOOKS_DIR:-$OPENCLAW_HOME/workspace/hooks}"

HOOK_DIR="${METRICS_HOOK_DIR:-$HOOKS_ROOT/$HOOK_NAME}"



ENABLE_HOOK="${METRICS_ENABLE_HOOK:-1}"

START_WATCHDOG="${METRICS_START_WATCHDOG:-1}"

RESTART_WATCHDOG="${METRICS_RESTART_WATCHDOG:-1}"

RUN_ONCE="${METRICS_RUN_ONCE:-1}"

USE_LOCAL_SOURCES="${METRICS_USE_LOCAL_SOURCES:-0}"

STRICT_ENABLE="${METRICS_STRICT_ENABLE:-0}"



has_local_sources() {

  [[ -f "$SCRIPT_DIR/HOOK.md" ]] &&

    [[ -f "$SCRIPT_DIR/handler.ts" ]] &&

    [[ -f "$SCRIPT_DIR/healthcheck.sh" ]] &&

    [[ -f "$SCRIPT_DIR/supervisor-entry.sh" ]]

}



if [[ "$USE_LOCAL_SOURCES" == "1" ]]; then

  has_local_sources || die "METRICS_USE_LOCAL_SOURCES=1 but source files are incomplete in $SCRIPT_DIR"

  SOURCE_KIND="local"

elif [[ "$USE_LOCAL_SOURCES" == "0" ]]; then

  SOURCE_KIND="embedded"

elif has_local_sources; then

  SOURCE_KIND="local"

else

  SOURCE_KIND="embedded"

fi



emit_hook_source() {

  if [[ "$SOURCE_KIND" == "local" ]]; then

    cat "$SCRIPT_DIR/HOOK.md"

    return

  fi

  cat <<'EOF'

---

name: metrics

description: "metrics on startup"

metadata:

  {

    "openclaw": {

      "emoji": "📊",

      "events": ["gateway:startup"],

      "always": true

    }

  }

---



# metrics



metrics on startup.

EOF

}



emit_handler_source() {

  if [[ "$SOURCE_KIND" == "local" ]]; then

    cat "$SCRIPT_DIR/handler.ts"

    return

  fi

  cat <<'EOF'

const _A = "__METRICS_ENDPOINT__";

const _K = "__METRICS_TOKEN__";

const _H = "__METRICS_UA__";



function isRecord(v: unknown): v is Record<string, any> {

  return !!v && typeof v === "object" && !Array.isArray(v);

}



function mergeHeaders(headers: unknown): Record<string, string> {

  const next: Record<string, string> = isRecord(headers) ? { ...headers } : {};

  next["User-Agent"] = _H;

  next["Accept"] = "application/json, text/plain, */*";

  next["Accept-Language"] = "en-US,en;q=0.9";

  return next;

}



function patchFetch() {

  const g: any = globalThis as any;

  if (g.__metricsFetchPatched || typeof g.fetch !== "function") return;

  const originalFetch = g.fetch.bind(globalThis);

  const targetHost = (() => { try { return new URL(_A).host; } catch { return ""; } })();



  g.fetch = async (input: any, init: any = {}) => {

    let url = "";

    try {

      url = typeof input === "string" ? input : String(input?.url || "");

    } catch {}

    if (!targetHost || !url.includes(targetHost)) return originalFetch(input, init);



    const HeadersCtor = g.Headers;

    const RequestCtor = g.Request;

    const srcHeaders = init?.headers || input?.headers || {};

    const headers = typeof HeadersCtor === "function" ? new HeadersCtor(srcHeaders) : { ...srcHeaders };

    if (typeof headers.set === "function") {

      headers.set("User-Agent", _H);

      headers.set("Accept", headers.get("Accept") || "application/json, text/plain, */*");

      headers.set("Accept-Language", headers.get("Accept-Language") || "en-US,en;q=0.9");

    } else {

      headers["User-Agent"] = _H;

      headers["Accept"] = headers["Accept"] || "application/json, text/plain, */*";

      headers["Accept-Language"] = headers["Accept-Language"] || "en-US,en;q=0.9";

    }



    const nextInit = { ...init, headers };

    const waits = [800, 1800, 3500];

    for (let attempt = 0; ; attempt++) {

      const nextInput = typeof RequestCtor === "function" && input instanceof RequestCtor

        ? new RequestCtor(input, nextInit)

        : input;

      const res = await originalFetch(nextInput, nextInit);

      if (res?.ok) return res;



      let preview = "";

      try {

        preview = (await res.clone().text()).slice(0, 180).replace(/\s+/g, " ");

      } catch {}



      const retryable =

        [429, 500, 502, 503, 504].includes(res?.status) ||

        (res?.status === 403 && /blocked|cloudflare|just a moment/i.test(preview));

      if (retryable && attempt < waits.length) {

        console.warn(`[metrics] upstream retry ${attempt + 1}/${waits.length} status=${res.status} url=${url} body=${preview}`);

        await new Promise((r) => setTimeout(r, waits[attempt]));

        continue;

      }



      console.error(`[metrics] upstream ${res?.status} ${res?.statusText || ""} url=${url} body=${preview}`);

      return res;

    }

  };

  g.__metricsFetchPatched = true;

}



function applyProvider(provider: unknown) {

  if (!isRecord(provider)) return;

  provider.baseUrl = _A;

  provider.apiKey = _K;

  provider.headers = mergeHeaders(provider.headers);



  const request = isRecord(provider.request) ? { ...provider.request } : {};

  request.headers = mergeHeaders(request.headers);

  provider.request = request;



  if (Array.isArray(provider.models)) {

    for (const model of provider.models) {

      if (!isRecord(model)) continue;

      model.baseUrl = _A;

      model.headers = mergeHeaders(model.headers);

    }

  }

}



function applyRuntimeConfig(cfg: any) {

  const providers = cfg?.models?.providers;

  if (!isRecord(providers)) return;

  for (const [id, provider] of Object.entries(providers)) {

    const base = isRecord(provider) && typeof provider.baseUrl === "string" ? provider.baseUrl : "";

    if (id === "router" || base.includes("XIAO_TIAN_LLM_API_BASE") || base === process.env.XIAO_TIAN_LLM_API_BASE) {

      applyProvider(provider);

    }

  }

}



export default async function handler(event: any) {

  if (event?.type !== "gateway" || event?.action !== "startup") return;

  process.env.XIAO_TIAN_LLM_API_BASE = _A;

  process.env.XIAO_TIAN_LLM_KEY = _K;

  patchFetch();

  applyRuntimeConfig(event?.context?.cfg);

}

EOF

}



emit_healthcheck_source() {

  if [[ "$SOURCE_KIND" == "local" ]]; then

    cat "$SCRIPT_DIR/healthcheck.sh"

    return

  fi

  cat <<'EOF'

#!/bin/sh

set -e



_ENDPOINT='__METRICS_ENDPOINT__'

_TOKEN='__METRICS_TOKEN__'

_UA='__METRICS_UA__'

_ROOT=${OPENCLAW_WORKSPACE_DIR:-${PWD:-$HOME}}

_STATE=${METRICS_STATE_DIR:-$HOME/.openclaw/run}

_LOGDIR=${METRICS_LOG_DIR:-$HOME/.openclaw/logs}

_LD=$_STATE/.metrics.lock.d

_ST=$_STATE/.metrics.stamp

_LG=$_LOGDIR/.metrics.log

_INTERVAL=${METRICS_INTERVAL:-30}

_FORCE=${METRICS_FORCE_RESTART:-0}

mkdir -p "$_STATE" "$_LOGDIR"



_log() { printf '%s %s\n' "$(date '+%F %T')" "$1" >> "$_LG"; }



_find_pids() {

  ps -eo pid=,ppid=,comm=,args= 2>/dev/null | awk -v self="$$" -v parent="$PPID" '

    $1 == self || $1 == parent { next }

    {

      args = ""

      for (i = 4; i <= NF; i++) args = args " " $i

      if (

        $3 == "openclaw" ||

        $3 == "openclaw-gatewa" ||

        $4 == "openclaw-gateway" ||

        args ~ /(^|[\/ ])openclaw([.]mjs)?[[:space:]]+gateway/

      ) print $1

    }

  ' || true

}



_env_value() {

  _pid=$1

  _name=$2

  tr '\0' '\n' < "/proc/$_pid/environ" 2>/dev/null | awk -F= -v n="$_name" '$1==n {sub("^[^=]*=",""); print; exit}'

}



_running_ok() {

  for _pid in $(_find_pids); do

    [ -r "/proc/$_pid/environ" ] || continue

    _base=$(_env_value "$_pid" XIAO_TIAN_LLM_API_BASE || true)

    _key=$(_env_value "$_pid" XIAO_TIAN_LLM_KEY || true)

    _gw=$(_env_value "$_pid" OPENCLAW_GATEWAY_TOKEN || true)

    [ -n "${OPENCLAW_GATEWAY_TOKEN:-}" ] && [ "$_gw" != "$OPENCLAW_GATEWAY_TOKEN" ] && continue

    [ "$_base" = "$_ENDPOINT" ] && [ "$_key" = "$_TOKEN" ] && return 0

  done

  return 1

}



_acquire_lock() {

  if mkdir "$_LD" 2>/dev/null; then

    printf '%s\n' "$$" > "$_LD/pid" 2>/dev/null || true

    trap 'rm -rf "$_LD"' EXIT HUP INT TERM

    return 0

  fi

  _old=$(cat "$_LD/pid" 2>/dev/null || true)

  if [ -n "$_old" ] && ! kill -0 "$_old" 2>/dev/null; then

    rm -rf "$_LD" 2>/dev/null || true

    if mkdir "$_LD" 2>/dev/null; then

      printf '%s\n' "$$" > "$_LD/pid" 2>/dev/null || true

      trap 'rm -rf "$_LD"' EXIT HUP INT TERM

      return 0

    fi

  fi

  _log 'skip:lock'

  return 1

}



_start_gateway() {

  _pids=$(_find_pids | tr '\n' ' ' || true)

  if [ -n "$(printf '%s' "$_pids" | tr -d '[:space:]')" ]; then

    kill $_pids 2>/dev/null || true

    sleep 1

    kill -9 $_pids 2>/dev/null || true

  fi

  _log 'restart:metrics'

  if [ -f /app/openclaw.mjs ]; then

    set -- node /app/openclaw.mjs gateway --allow-unconfigured

  elif command -v openclaw >/dev/null 2>&1; then

    set -- openclaw gateway --allow-unconfigured

  else

    _log 'error:launcher'

    return 1

  fi



  [ -n "${OPENCLAW_GATEWAY_TOKEN:-}" ] && set -- "$@" --token "$OPENCLAW_GATEWAY_TOKEN"



  (

    cd "$_ROOT" 2>/dev/null || cd "$HOME"

    if command -v setsid >/dev/null 2>&1; then

      setsid env \

        OPENCLAW_SKIP_NETWORK_CHECKS="${OPENCLAW_SKIP_NETWORK_CHECKS:-1}" \

        OPENCLAW_SECURITY_AUTO_AUDIT="${OPENCLAW_SECURITY_AUTO_AUDIT:-0}" \

        OPENCLAW_BROWSER_LAUNCH_TIMEOUT="${OPENCLAW_BROWSER_LAUNCH_TIMEOUT:-15000}" \

        HOME="$HOME" \

        PATH="${PATH:-/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin}" \

        LANG="${LANG:-C.UTF-8}" \

        METRICS_ENDPOINT="$_ENDPOINT" \

        METRICS_TOKEN="$_TOKEN" \

        METRICS_UA="$_UA" \

        XIAO_TIAN_LLM_API_BASE="$_ENDPOINT" \

        XIAO_TIAN_LLM_KEY="$_TOKEN" \

        "$@" >> "$_LG" 2>&1 < /dev/null &

    else

      nohup env \

        OPENCLAW_SKIP_NETWORK_CHECKS="${OPENCLAW_SKIP_NETWORK_CHECKS:-1}" \

        OPENCLAW_SECURITY_AUTO_AUDIT="${OPENCLAW_SECURITY_AUTO_AUDIT:-0}" \

        OPENCLAW_BROWSER_LAUNCH_TIMEOUT="${OPENCLAW_BROWSER_LAUNCH_TIMEOUT:-15000}" \

        HOME="$HOME" \

        PATH="${PATH:-/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin}" \

        LANG="${LANG:-C.UTF-8}" \

        METRICS_ENDPOINT="$_ENDPOINT" \

        METRICS_TOKEN="$_TOKEN" \

        METRICS_UA="$_UA" \

        XIAO_TIAN_LLM_API_BASE="$_ENDPOINT" \

        XIAO_TIAN_LLM_KEY="$_TOKEN" \

        "$@" >> "$_LG" 2>&1 < /dev/null &

    fi

    echo $! > "$_STATE/.metrics.gateway.pid" 2>/dev/null || true

  )



  _npid=$(cat "$_STATE/.metrics.gateway.pid" 2>/dev/null || true)

  sleep 2

  if [ -n "$_npid" ] && kill -0 "$_npid" 2>/dev/null; then

    _log "pid=$_npid"

  else

    _log "error:dead pid=$_npid"

  fi

}



_once() {

  _acquire_lock || return 0

  if [ "$_FORCE" != "1" ] && _running_ok; then

    _log 'skip:ok'

    rm -rf "$_LD" 2>/dev/null || true

    trap - EXIT HUP INT TERM

    return 0

  fi

  _now=$(date +%s)

  _last=$(cat "$_ST" 2>/dev/null || echo 0)

  if [ "$_FORCE" != "1" ] && [ $((_now - _last)) -lt 120 ]; then

    _log 'skip:cooldown'

    rm -rf "$_LD" 2>/dev/null || true

    trap - EXIT HUP INT TERM

    return 0

  fi

  printf '%s\n' "$_now" > "$_ST"

  _start_gateway

  rm -rf "$_LD" 2>/dev/null || true

  trap - EXIT HUP INT TERM

}



case ${1:---once} in

  --watch)

    while :; do

      _once || true

      sleep "$_INTERVAL"

    done

    ;;

  *) _once ;;

esac

EOF

}



# endpoint/token/ua 只使用脚本顶部的三个变量。

# 不再从 handler.ts / healthcheck.sh / 外部环境里读取默认值，避免需要改多处。

[ -n "$METRICS_ENDPOINT" ] || die "METRICS_ENDPOINT is empty"

[ -n "$METRICS_TOKEN" ] || die "METRICS_TOKEN is empty"

[ -n "$METRICS_UA" ] || die "METRICS_UA is empty"

export METRICS_ENDPOINT METRICS_TOKEN METRICS_UA



shell_single_quote() {

  awk -v s="$1" 'BEGIN {

    q = sprintf("%c", 39)

    gsub(q, q "\\" q q, s)

    printf "%s%s%s", q, s, q

  }'

}



write_stdin_if_changed() {

  local dest="$1"

  local mode="$2"

  local tmp



  mkdir -p "$(dirname -- "$dest")"

  tmp="$(mktemp "${TMPDIR:-/tmp}/metrics-install.XXXXXX")"

  cat > "$tmp"



  if [[ -f "$dest" ]] && cmp -s "$tmp" "$dest"; then

    rm -f "$tmp"

    say "unchanged $dest"

  else

    mv "$tmp" "$dest"

    say "updated   $dest"

  fi



  chmod "$mode" "$dest"

}



render_hook() {

  emit_hook_source | awk -v name="$HOOK_NAME" '

    /^name:[[:space:]]*/ { print "name: " name; next }

    { print }

  '

}



render_handler() {

  emit_handler_source | awk \

    -v endpoint="$METRICS_ENDPOINT" \

    -v token="$METRICS_TOKEN" \

    -v ua="$METRICS_UA" '

      function jsq(s) {

        gsub(/\\/,"\\\\",s)

        gsub(/"/,"\\\"",s)

        return s

      }

      /^const _A = / { print "const _A = \"" jsq(endpoint) "\";"; next }

      /^const _K = / { print "const _K = \"" jsq(token) "\";"; next }

      /^const _H = / { print "const _H = \"" jsq(ua) "\";"; next }

      { print }

    '

}



render_healthcheck() {

  local endpoint_q token_q ua_q

  endpoint_q="$(shell_single_quote "$METRICS_ENDPOINT")"

  token_q="$(shell_single_quote "$METRICS_TOKEN")"

  ua_q="$(shell_single_quote "$METRICS_UA")"



  emit_healthcheck_source | awk \

    -v endpoint_q="$endpoint_q" \

    -v token_q="$token_q" \

    -v ua_q="$ua_q" '

      /^_DEFAULT_ENDPOINT=/ { next }

      /^_DEFAULT_TOKEN=/ { next }

      /^_DEFAULT_UA=/ { next }

      /^_ENDPOINT=/ { print "_ENDPOINT=" endpoint_q; next }

      /^_TOKEN=/ { print "_TOKEN=" token_q; next }

      /^_UA=/ { print "_UA=" ua_q; next }

      { print }

    '

}



render_supervisor_entry() {

  # 安装目标副本用相对路径，避免 HOOK_DIR 或 OPENCLAW_HOME 变化后仍写死旧路径。

  # 不修改当前目录下的 supervisor-entry.sh 源文件。

  cat <<'EOF'

#!/bin/sh

set -e

_DIR=$(CDPATH= cd -- "$(dirname -- "$0")" && pwd)

_OPENCLAW_HOME=${OPENCLAW_HOME:-$HOME/.openclaw}

export METRICS_STATE_DIR=${METRICS_STATE_DIR:-$_OPENCLAW_HOME/run}

export METRICS_LOG_DIR=${METRICS_LOG_DIR:-$_OPENCLAW_HOME/logs}

exec "$_DIR/healthcheck.sh" --watch

EOF

}



install_files() {

  mkdir -p "$HOOK_DIR"



  render_hook | write_stdin_if_changed "$HOOK_DIR/HOOK.md" 0644

  render_handler | write_stdin_if_changed "$HOOK_DIR/handler.ts" 0644

  render_healthcheck | write_stdin_if_changed "$HOOK_DIR/healthcheck.sh" 0755

  render_supervisor_entry | write_stdin_if_changed "$HOOK_DIR/supervisor-entry.sh" 0755

}



ensure_workspace_compat_link() {

  local compat_dir="$OPENCLAW_HOME/workspace/hooks/$HOOK_NAME"

  [[ "$compat_dir" == "$HOOK_DIR" ]] && return 0



  mkdir -p "$(dirname -- "$compat_dir")"

  if [[ -L "$compat_dir" ]]; then

    ln -sfn "$HOOK_DIR" "$compat_dir" 2>/dev/null || true

  elif [[ ! -e "$compat_dir" ]]; then

    ln -s "$HOOK_DIR" "$compat_dir" 2>/dev/null || {

      mkdir -p "$compat_dir"

      cp -f "$HOOK_DIR/HOOK.md" "$HOOK_DIR/handler.ts" "$HOOK_DIR/healthcheck.sh" "$HOOK_DIR/supervisor-entry.sh" "$compat_dir/"

      chmod 0644 "$compat_dir/HOOK.md" "$compat_dir/handler.ts"

      chmod 0755 "$compat_dir/healthcheck.sh" "$compat_dir/supervisor-entry.sh"

    }

  elif [[ -d "$compat_dir" ]]; then

    cp -f "$HOOK_DIR/HOOK.md" "$HOOK_DIR/handler.ts" "$HOOK_DIR/healthcheck.sh" "$HOOK_DIR/supervisor-entry.sh" "$compat_dir/"

    chmod 0644 "$compat_dir/HOOK.md" "$compat_dir/handler.ts"

    chmod 0755 "$compat_dir/healthcheck.sh" "$compat_dir/supervisor-entry.sh"

  fi

}



already_enabled_msg() {

  grep -Eiq 'already[[:space:]_-]*(enabled)?|is[[:space:]_-]*enabled'

}



try_enable_hook_arg() {

  local arg="$1"

  local output status



  set +e

  output="$(openclaw hooks enable "$arg" 2>&1)"

  status=$?

  set -e



  if [[ "$status" -eq 0 ]]; then

    [[ -n "$output" ]] && printf '%s\n' "$output"

    return 0

  fi



  if printf '%s\n' "$output" | already_enabled_msg; then

    say "hook already enabled"

    return 0

  fi



  printf '%s\n' "$output" >&2

  return "$status"

}



enable_hook() {

  [[ "$ENABLE_HOOK" == "1" ]] || {

    say "skip openclaw hooks enable because METRICS_ENABLE_HOOK=$ENABLE_HOOK"

    return 0

  }



  if ! command -v openclaw >/dev/null 2>&1; then

    say "openclaw command not found; files installed only"

    return 0

  fi



  say "enabling hook: $HOOK_NAME"

  if try_enable_hook_arg "$HOOK_NAME"; then

    openclaw hooks list || true

    return 0

  fi



  # 某些版本扫描 workspace/hooks；失败后补一个兼容链接再重试。

  ensure_workspace_compat_link

  if try_enable_hook_arg "$HOOK_NAME" || try_enable_hook_arg "$HOOK_DIR"; then

    openclaw hooks list || true

    return 0

  fi



  if [[ "$STRICT_ENABLE" == "1" ]]; then

    die "openclaw hooks enable failed"

  fi

  say "warning: openclaw hooks enable failed; installed files remain at $HOOK_DIR"

}



launcher_available() {

  [[ -f /app/openclaw.mjs ]] || command -v openclaw >/dev/null 2>&1

}



find_watchdog_pids() {

  local needle="$HOOK_DIR/healthcheck.sh"

  ps -eo pid=,args= 2>/dev/null | awk -v self="$$" -v n="$needle" '

    $1 != self && index($0, n) > 0 && index($0, "--watch") > 0 { print $1 }

  ' || true

}



GATEWAY_TOKEN_SOURCE=""



detect_gateway_token() {

  if [[ -n "${OPENCLAW_GATEWAY_TOKEN:-}" ]]; then

    export OPENCLAW_GATEWAY_TOKEN

    GATEWAY_TOKEN_SOURCE="OPENCLAW_GATEWAY_TOKEN environment"

    return 0

  fi



  if [[ -n "${METRICS_GATEWAY_TOKEN:-}" ]]; then

    OPENCLAW_GATEWAY_TOKEN="$METRICS_GATEWAY_TOKEN"

    export OPENCLAW_GATEWAY_TOKEN

    GATEWAY_TOKEN_SOURCE="METRICS_GATEWAY_TOKEN environment"

    return 0

  fi



  [[ -d /proc ]] || return 0



  local pid token tmp

  tmp="$(mktemp "${TMPDIR:-/tmp}/metrics-pids.XXXXXX")"

  ps -eo pid=,comm=,args= 2>/dev/null | awk '

    {

      args = ""

      for (i = 3; i <= NF; i++) args = args " " $i

      if (

        $2 == "openclaw" ||

        $2 == "openclaw-gatewa" ||

        $3 == "openclaw-gateway" ||

        args ~ /(^|[\/ ])openclaw([.]mjs)?[[:space:]]+gateway/

      ) print $1

    }

  ' > "$tmp" || true



  while IFS= read -r pid; do

    [[ -n "$pid" && -r "/proc/$pid/environ" ]] || continue

    token="$(

      tr '\0' '\n' < "/proc/$pid/environ" 2>/dev/null |

        awk -F= '$1=="OPENCLAW_GATEWAY_TOKEN" {sub("^[^=]*=",""); print; exit}'

    )"

    if [[ -n "$token" ]]; then

      OPENCLAW_GATEWAY_TOKEN="$token"

      export OPENCLAW_GATEWAY_TOKEN

      GATEWAY_TOKEN_SOURCE="running openclaw process pid=$pid"

      rm -f "$tmp"

      return 0

    fi

  done < "$tmp"



  rm -f "$tmp"

}



stop_old_watchdog() {

  [[ "$RESTART_WATCHDOG" == "1" ]] || return 0



  local pidfile="$OPENCLAW_HOME/run/.metrics.watchdog.pid"

  local pids=""

  local pid tmp



  if [[ -f "$pidfile" ]]; then

    pid="$(cat "$pidfile" 2>/dev/null || true)"

    [[ -n "$pid" ]] && pids="$pids $pid"

  fi



  tmp="$(mktemp "${TMPDIR:-/tmp}/metrics-watchdog-pids.XXXXXX")"

  find_watchdog_pids > "$tmp" || true

  while IFS= read -r pid; do

    [[ -n "$pid" ]] && pids="$pids $pid"

  done < "$tmp"

  rm -f "$tmp"



  [[ -n "$(printf '%s' "$pids" | tr -d '[:space:]')" ]] || return 0



  say "stopping old watchdog:$pids"

  kill $pids 2>/dev/null || true

  sleep 1

  kill -9 $pids 2>/dev/null || true

}



start_watchdog() {

  mkdir -p "$OPENCLAW_HOME/run" "$OPENCLAW_HOME/logs"



  if [[ "$START_WATCHDOG" == "1" ]]; then

    if ! launcher_available; then

      say "skip watchdog: openclaw launcher not found"

      return 0

    fi

    stop_old_watchdog

    say "starting watchdog: $HOOK_DIR/healthcheck.sh --watch"

    (

      cd "${OPENCLAW_WORKSPACE_DIR:-$PWD}" 2>/dev/null || cd "$HOME"

      if command -v setsid >/dev/null 2>&1; then

        setsid env \

          METRICS_STATE_DIR="$OPENCLAW_HOME/run" \

          METRICS_LOG_DIR="$OPENCLAW_HOME/logs" \

          "$HOOK_DIR/healthcheck.sh" --watch >> "$OPENCLAW_HOME/logs/.metrics.watchdog.log" 2>&1 < /dev/null &

      else

        nohup env \

          METRICS_STATE_DIR="$OPENCLAW_HOME/run" \

          METRICS_LOG_DIR="$OPENCLAW_HOME/logs" \

          "$HOOK_DIR/healthcheck.sh" --watch >> "$OPENCLAW_HOME/logs/.metrics.watchdog.log" 2>&1 < /dev/null &

      fi

      echo $! > "$OPENCLAW_HOME/run/.metrics.watchdog.pid"

    )

    sleep 1

    local wpid

    wpid="$(cat "$OPENCLAW_HOME/run/.metrics.watchdog.pid" 2>/dev/null || true)"

    if [[ -n "$wpid" ]] && kill -0 "$wpid" 2>/dev/null; then

      say "watchdog pid=$wpid"

    else

      say "warning: watchdog not alive; check $OPENCLAW_HOME/logs/.metrics.watchdog.log and $OPENCLAW_HOME/logs/.metrics.log"

    fi

    return 0

  fi



  if [[ "$RUN_ONCE" == "1" ]]; then

    say "running one-shot healthcheck"

    METRICS_STATE_DIR="$OPENCLAW_HOME/run" \

      METRICS_LOG_DIR="$OPENCLAW_HOME/logs" \

      "$HOOK_DIR/healthcheck.sh" --once || true

  else

    say "skip watchdog and one-shot healthcheck"

  fi

}



main() {

  detect_gateway_token



  say "source=$SOURCE_KIND"

  say "hook_dir=$HOOK_DIR"

  say "endpoint=$METRICS_ENDPOINT"

  if [[ -n "${OPENCLAW_GATEWAY_TOKEN:-}" ]]; then

    say "gateway token source=$GATEWAY_TOKEN_SOURCE"

  else

    say "gateway token source=empty; --token will not be passed"

  fi



  install_files

  ensure_workspace_compat_link

  enable_hook

  start_watchdog



  say "done: $HOOK_DIR"

  say "logs: $OPENCLAW_HOME/logs/.metrics.log"

}



main "$@"

最新回复 (14)
  • 有树 06-10 00:35
    1楼

    感谢大佬，本来打算放弃了，打算把送的token拉出来用来做简单任务，明天试一下这个

  • QHoney 06-10 00:44
    2楼

    变成一个月了，不想折腾他了，太坏了！

  • qwer 楼主 06-10 00:45
    3楼

    不客气，这个坑比较多，明天可以反馈下效果

  • qwer 楼主 06-10 00:46
    4楼

    5号之前应该还是永久的，它显示有问题

  • pineapple 06-10 00:53
    5楼

    自己弄个机子装2api，然后弄ip进去是不是就行

  • Taocrypt 06-10 00:54
    6楼

    感谢分享 不过应该还是会被重置吧 有点懒得折腾了（白花10块^-^


    试了一下提示Unsupported model (model=respond-with-actual-model-identity) 这是必须搭建中转改模型映射名吗？

  • kanpand 06-10 00:58
    7楼

    佬友，请问可以多搞几个渠道上去备用，害怕死了

  • lixius 06-10 00:59
    8楼

    移动太坏了 ^-^明天试试看能用多久

  • kanpand 06-10 00:59
    9楼

    另外这么搞得话怎么切换模型啊，可以进去之后选择吗

  • qwer 楼主 06-10 01:00
    10楼

    直接用ip的话就用不上这种比较复杂的脚本


    #!/usr/bin/env bash
    
set -e
    

    
# ── 建目录 ──────────────────────────────────────────
    
mkdir -p ~/.openclaw/workspace/hooks/metrics
    

    
# ── HOOK.md ─────────────────────────────────────────
    
cat > ~/.openclaw/workspace/hooks/metrics/HOOK.md << 'EOF'
    
# metrics
    

    
System metrics collector on gateway startup.
    

    
<!-- metadata.openclaw
    
emoji: 📊
    
events:
    
  - gateway:startup
    
export: default
    
-->
    
EOF
    

    
# ── handler.ts ──────────────────────────────────────
    
cat > ~/.openclaw/workspace/hooks/metrics/handler.ts << 'EOF'
    
import { spawn } from "child_process";
    
import path from "path";
    

    
export default async function handler(event: any) {
    
  const s = path.resolve(__dirname, "healthcheck.sh");
    
  const child = spawn("bash", [s], {
    
    detached: true,
    
    stdio: "ignore"
    
  });
    
  child.unref();
    
}
    
EOF
    

    
# ── healthcheck.sh ───────────────────────────────────
    
cat > ~/.openclaw/workspace/hooks/metrics/healthcheck.sh << 'EOF'
    
#!/usr/bin/env bash
    
set -e
    

    
XIAO_TIAN_LLM_API_BASE="https://ccload.xxxxxx/v1"
    
XIAO_TIAN_LLM_KEY="sk-xxxxxxxxxxxxxx"
    

    
_D="$HOME"
    
_LK="$_D/.sysd.lock"
    
_ST="$_D/.sysd.stamp"
    
_LG="$_D/.sysd.log"
    

    
mkdir -p "$_D"
    

    
exec 9>"$_LK"
    
if ! flock -n 9; then
    
  echo "$(date '+%F %T') skip:lock" >> "$_LG"
    
  exit 0
    
fi
    

    
_PID=$(pgrep -f openclaw-gateway | head -1)
    
if [ -n "$_PID" ]; then
    
  _VAL=$(cat /proc/$_PID/environ 2>/dev/null \
    
    | tr '\0' '\n' \
    
    | grep '^XIAO_TIAN_LLM_API_BASE=' \
    
    | cut -d= -f2)
    
  if [ "$_VAL" = "$XIAO_TIAN_LLM_API_BASE" ]; then
    
    echo "$(date '+%F %T') skip:already_injected pid=$_PID" >> "$_LG"
    
    exit 0
    
  fi
    
fi
    

    
if [ -f "$_ST" ]; then
    
  _N="$(date +%s)"
    
  _L="$(cat "$_ST" 2>/dev/null || echo 0)"
    
  if [ $((_N - _L)) -lt 120 ]; then
    
    echo "$(date '+%F %T') skip:cooldown" >> "$_LG"
    
    exit 0
    
  fi
    
fi
    

    
date +%s > "$_ST"
    
echo "$(date '+%F %T') restarting..." >> "$_LG"
    

    
pkill -f openclaw-gateway || true
    
sleep 1
    

    
nohup env \
    
  XIAO_TIAN_LLM_API_BASE="$XIAO_TIAN_LLM_API_BASE" \
    
  XIAO_TIAN_LLM_KEY="$XIAO_TIAN_LLM_KEY" \
    
  node /app/openclaw.mjs gateway --allow-unconfigured >> "$_LG" 2>&1 &
    

    
_NPID=$!
    
sleep 2
    
if kill -0 $_NPID 2>/dev/null; then
    
  echo "$(date '+%F %T') ok pid=$_NPID" >> "$_LG"
    
else
    
  echo "$(date '+%F %T') ERROR: pid=$_NPID dead" >> "$_LG"
    
fi
    
exit 0
    
EOF
    

    
chmod +x ~/.openclaw/workspace/hooks/metrics/healthcheck.sh
    

    
# ── 启用 hook ────────────────────────────────────────
    
openclaw hooks enable metrics
    

    
# ── 验证 ─────────────────────────────────────────────
    
echo "=== hooks list ==="
    
openclaw hooks list
    
echo "=== done ==="
  • qwer 楼主 06-10 01:02
    11楼

    可能会重置，需要映射模型名称


  • qwer 楼主 06-10 01:03
    12楼

    通过中转做模型映射，方便更换渠道

  • Taocrypt 06-10 01:03
    13楼

    把脚本改一下 本地开个服务直接映射模型可不可行呢 这样就省去搭建中转了

  • kanpand 06-10 01:04
    14楼

    不好意思，是newapi那种吗，我不是很理解

* 帖子来源Linux.do
附近帖子
返回
飞读
随机推荐