Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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: 0 additions & 1 deletion .agents/messages/receiver-ad4e4f8f/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/receiver-bbb512c8/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/receiver-c059e24d/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/receiver-c5fe09dd/.processed

This file was deleted.

2 changes: 0 additions & 2 deletions .agents/messages/receiver_ops-37cadd82/.processed

This file was deleted.

6 changes: 0 additions & 6 deletions .agents/messages/receiver_scale-dab9c017/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/receiver_sec-371a042e/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/sender-ae6bf2b2/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-0231eb27/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-29544c66/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-3617e505/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-4313c9d0/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-714aedf8/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-78219b37/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-7db0f955/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-863045de/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-8ef1b6bc/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-94de765b/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-d6ff15cb/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-e36f5d0e/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-f99f7fd8/.processed

This file was deleted.

1 change: 0 additions & 1 deletion .agents/messages/test-b-fd4cc5d4/.processed

This file was deleted.

Empty file removed .agents/registry/.lock
Empty file.
60 changes: 0 additions & 60 deletions docs/review/REVIEW_20260104.md

This file was deleted.

13 changes: 0 additions & 13 deletions scripts/index

This file was deleted.

61 changes: 0 additions & 61 deletions scripts/lib/audit.py

This file was deleted.

55 changes: 0 additions & 55 deletions scripts/lib/concurrency.py

This file was deleted.

47 changes: 6 additions & 41 deletions scripts/lib/io.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
import tempfile
import json
import time
import gzip

def write_atomic(filepath, content, mode='w', encoding='utf-8'):
"""
Expand Down Expand Up @@ -33,62 +32,28 @@ def write_atomic(filepath, content, mode='w', encoding='utf-8'):
os.remove(tmp_path)
raise e

def write_atomic_gzip(filepath, content_str, encoding='utf-8'):
"""Atomic write for GZIP files."""
directory = os.path.dirname(os.path.abspath(filepath))
if not os.path.exists(directory):
os.makedirs(directory, exist_ok=True)

fd, tmp_path = tempfile.mkstemp(dir=directory, suffix='.gz')
os.close(fd)

try:
with gzip.open(tmp_path, 'wt', encoding=encoding) as f:
f.write(content_str)
f.flush()
# Try to fsync underlying file
if hasattr(f, 'fileobj') and f.fileobj:
f.fileobj.flush()
os.fsync(f.fileobj.fileno())

os.replace(tmp_path, filepath)
except Exception as e:
if os.path.exists(tmp_path):
os.remove(tmp_path)
raise e

def read_text(filepath, encoding='utf-8', retries=3, delay=0.1):
"""
Reads text from a file with simple retry logic for transient errors.
Supports .gz files transparently.
"""
if not os.path.exists(filepath):
raise FileNotFoundError(f"File not found: {filepath}")

is_gzip = filepath.endswith('.gz')

for attempt in range(retries):
try:
if is_gzip:
with gzip.open(filepath, 'rt', encoding=encoding) as f:
return f.read()
else:
with open(filepath, 'r', encoding=encoding) as f:
return f.read()
with open(filepath, 'r', encoding=encoding) as f:
return f.read()
except OSError:
if attempt == retries - 1:
raise
time.sleep(delay)

def write_json(filepath, data, indent=2):
"""Atomic write for JSON (supports .gz)."""
"""Atomic write for JSON."""
content = json.dumps(data, indent=indent, sort_keys=True)
if filepath.endswith('.gz'):
write_atomic_gzip(filepath, content)
else:
write_atomic(filepath, content + "\n")
write_atomic(filepath, content + "\n")

def read_json(filepath):
"""Read JSON from file (supports .gz)."""
"""Read JSON from file."""
content = read_text(filepath)
return json.loads(content)
return json.loads(content)
23 changes: 0 additions & 23 deletions templates/task.md

This file was deleted.

Loading