bit-vector-tensor-control-policy / scripts /render_continuity_flow.sh
J94's picture
Initial Space upload
3436bdd verified
#!/usr/bin/env bash
set -euo pipefail
ROOT="$(cd "$(dirname "$0")/.." && pwd)"
PROVIDER_SCRIPT="$ROOT/scripts/continuity_provider.sh"
VERSION_ID="${1:-hv-continuity-control-plane-v1}"
OPERATOR_CONFIG_PATH="$ROOT/build/system/continuity_operator.json"
if [ ! -x "$PROVIDER_SCRIPT" ]; then
echo "continuity provider script not available: $PROVIDER_SCRIPT" >&2
exit 1
fi
STATUS_JSON="$("$PROVIDER_SCRIPT" status)"
SURFACES_JSON="$("$PROVIDER_SCRIPT" surfaces)"
LINEAGE_JSON="$("$PROVIDER_SCRIPT" lineage "$VERSION_ID")"
if [ -f "$OPERATOR_CONFIG_PATH" ]; then
OPERATOR_JSON="$(cat "$OPERATOR_CONFIG_PATH")"
else
OPERATOR_JSON='{"active_cut":{"max_nodes":18,"preferred_surface_order":["provider_status","provider_lineage","provider_surfaces","local_fallback_pointer"]},"resume_defaults":{"preferred_active_surface":"history_navigation_surface_v1","next_packet_shape":["route","context","action","receipt"]},"invariants":[]}'
fi
jq -n \
--arg version_id "$VERSION_ID" \
--argjson status "$STATUS_JSON" \
--argjson surfaces "$SURFACES_JSON" \
--argjson lineage "$LINEAGE_JSON" \
--argjson operator "$OPERATOR_JSON" \
'{
route:{
lane:"memory",
objective:"resume and operate continuity runtime through the smallest owned surfaces first",
provider:($status.provider // "unknown"),
continuity_version_id:($lineage.version_id // $status.items[0].version_id // $status.continuity_version_id // $version_id),
active_cut:{
max_nodes:($operator.active_cut.max_nodes // 18),
preferred_surface_order:($operator.active_cut.preferred_surface_order // []),
surfaces_used:[
"provider_status",
"provider_lineage",
"provider_surfaces"
]
}
},
context:{
verified:($lineage.verified // $status.items[0].verified // false),
promoted:($lineage.promoted // $status.items[0].promoted // false),
predecessor:($lineage.predecessor // $status.items[0].predecessor // $status.predecessor_id // null),
surfaces:($surfaces.items // []),
graph_id:($lineage.graph_id // $status.items[0].graph_id // null),
active_surface:(
($surfaces.items // [])
| map(select(.activated == true))[0].surface_id
// (($surfaces.items // [])
| map(select(.surface_id == ($operator.resume_defaults.preferred_active_surface // "")))[0].surface_id)
// (($surfaces.items // [])[0].surface_id)
// null
),
resume_rule:"resume from state, not raw history replay"
},
action:{
next_step:"resume or activate one continuity surface",
recommended_surface:(
($surfaces.items // [])
| map(select(.activated == true))[0].surface_id
// (($surfaces.items // [])
| map(select(.surface_id == ($operator.resume_defaults.preferred_active_surface // "")))[0].surface_id)
// (($surfaces.items // [])[0].surface_id)
// null
),
activate_command:(
(($surfaces.items // [])
| map(select(.activated == true))[0].surface_id
// (($surfaces.items // [])[0].surface_id)
// empty) as $surface
| if $surface == "" then null
else "./bin/bvtctl continuity-activate " + $surface + " " + ($lineage.version_id // $status.items[0].version_id // $status.continuity_version_id // $version_id)
end
),
resume_packet:{
command:("./bin/bvtctl continuity-resume " + ($lineage.version_id // $status.items[0].version_id // $status.continuity_version_id // $version_id)),
shape:($operator.resume_defaults.next_packet_shape // ["route","context","action","receipt"])
}
},
receipt:{
proof_surface:"continuity provider",
lineage_verified:($lineage.verified // false),
promotion_state:(
if ($lineage.promoted // false) then "promoted"
elif ($lineage.verified // false) then "verified"
else "unverified"
end
),
evidence:[
($lineage.provider // $status.provider // "unknown"),
($lineage.graph_id // $status.items[0].graph_id // null),
(($surfaces.items // []) | length)
]
}
}'