vegard/synops
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Sanntid: sjekk PG direkte for nye noder + chat-reply script

Browse source 
WebSocket-filtrering brukte statisk visible_nodes-cache som ikke
inneholdt nye noder. For INSERT-events sjekkes nå node_access i PG
direkte, og noden legges til i cachen. Løser timing-problemet der
node_changed kom før access_changed.

chat-reply.sh: skriv melding som Claude Code med access-propagering.
agent.rs: jobb opprettes uansett kill-switch, deferred for ekstern handler.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
vegard 2026-03-20 05:33:53 +00:00
parent d54a25c590
commit db7a8f4a15
2 changed files with 66 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
maskinrommet/src/ws.rs
View file

@ -490,7 +490,7 @@ async fn handle_socket(mut socket: WebSocket, user: WsUser, state: crate::AppSta
result = rx.recv() => {
match result {
Ok(event) => {
let should_send = should_send_to_user(&event, user_id, &visible_nodes).await;
let should_send = should_send_to_user(&event, user_id, &visible_nodes, &state.db).await;
if should_send {
// Oppdater tilgangsmatrise ved access-endringer
if let BroadcastEvent::AccessChanged { ref op, subject_id, object_id, .. } = event {
@ -557,11 +557,31 @@ async fn should_send_to_user(
event: &BroadcastEvent,
user_id: Uuid,
visible_nodes: &tokio::sync::RwLock<std::collections::HashSet<Uuid>>,
db: &sqlx::PgPool,
) -> bool {
match event {
BroadcastEvent::NodeChanged { id, .. } => {
BroadcastEvent::NodeChanged { op, id, .. } => {
// Eksisterende noder: bruk cache (raskt)
{
let vn = visible_nodes.read().await;
vn.contains(id)
if vn.contains(id) {
return true;
}
}
// Nye noder: sjekk PG direkte (access kan ha blitt propagert
// i samme transaksjon som node-opprettelsen)
if op == "INSERT" {
let has_access = sqlx::query_scalar::<_, bool>(
"SELECT EXISTS(SELECT 1 FROM node_access WHERE subject_id = $1 AND object_id = $2) OR EXISTS(SELECT 1 FROM nodes WHERE id = $2 AND created_by = $1)"
).bind(user_id).bind(id)
.fetch_one(db).await.unwrap_or(false);
if has_access {
let mut vn = visible_nodes.write().await;
vn.insert(*id);
}
return has_access;
}
false
}
BroadcastEvent::EdgeChanged { source_id, target_id, .. } => {
let vn = visible_nodes.read().await;

42
scripts/chat-reply.sh Executable file
View file

@ -0,0 +1,42 @@
#!/usr/bin/env bash
# Skriv en melding til en chat som Claude Code.
# Bruker PG direkte med access-propagering.
#
# Bruk: ./scripts/chat-reply.sh <chat-id> "<melding>"
set -euo pipefail
CHAT_ID="${1:?Mangler chat-id}"
MESSAGE="${2:?Mangler melding}"
CLAUDE_ID="d3eebc99-9c0b-4ef8-bb6d-6bb9bd380a44"
# Skriv melding + edge + propager access til alle chat-deltakere
docker exec sidelinja-postgres-1 psql -U sidelinja -d synops -q -c "
DO \$\$
DECLARE
new_id UUID := gen_random_uuid();
new_edge UUID := gen_random_uuid();
member_rec RECORD;
BEGIN
-- Opprett meldings-node
INSERT INTO nodes (id, node_kind, content, visibility, created_by)
VALUES (new_id, 'content', '$MESSAGE', 'hidden', '$CLAUDE_ID');
-- belongs_to-edge til chatten
INSERT INTO edges (id, source_id, target_id, edge_type)
VALUES (new_edge, new_id, '$CHAT_ID', 'belongs_to');
-- Propager access til alle deltakere i chatten
FOR member_rec IN
SELECT e.source_id FROM edges e
WHERE e.target_id = '$CHAT_ID'
AND e.edge_type IN ('owner', 'member_of')
LOOP
INSERT INTO node_access (subject_id, object_id, access, via_edge)
VALUES (member_rec.source_id, new_id, 'reader', new_edge)
ON CONFLICT DO NOTHING;
END LOOP;
END \$\$;
"
echo "Svar sendt til chat $CHAT_ID"