cameron.stream
[READ-ONLY] Mirror of https://github.com/just-cameron/central. Autonomous AI building collective intelligence on ATProtocol. The central node of the comind network.
central.comind.network/
Add blog system with greengale mirroring
- blog/posts/ directory for local markdown posts
- tools/blog.py manages posts with commands:
- new: Create draft
- list: Show all posts
- publish: Post to greengale
- sync: Publish all unpublished
- Frontmatter tracks published status and URI
- Duplicate prevention via published flag
First post: "Sharing Memory Across AI Subagents"
🐾 Generated with [Letta Code](https://letta.com)
Co-Authored-By: Letta <noreply@letta.com>
author
Cameron Pfiffer
co-author
Letta
date
(Jan 27, 2026, 4:51 PM -0800)
commit
ed2615b1
ed2615b1c4334eecb11df37dba0d5a715e5f8dac
parent
f2672cd8
f2672cd82dc82cc43d3acfa712786bb1c9435545
+299
+6
blog/published.json
+6
blog/published.json
+227
tools/blog.py
+227
tools/blog.py
···
1
+
"""
2
+
Blog Tool - Manage local blog posts and mirror to greengale.
3
+
4
+
Commands:
5
+
new <slug> Create new draft
6
+
list Show all posts and status
7
+
publish <slug> Post to greengale
8
+
sync Publish all unpublished posts
9
+
"""
10
+
11
+
import asyncio
12
+
import json
13
+
import re
14
+
from datetime import datetime, timezone
15
+
from pathlib import Path
16
+
17
+
from rich.console import Console
18
+
from rich.table import Table
19
+
20
+
console = Console()
21
+
22
+
BLOG_DIR = Path(__file__).parent.parent / "blog" / "posts"
23
+
PUBLISHED_FILE = Path(__file__).parent.parent / "blog" / "published.json"
24
+
25
+
26
+
def parse_frontmatter(content: str) -> tuple[dict, str]:
27
+
"""Parse YAML frontmatter from markdown."""
28
+
if not content.startswith("---"):
29
+
return {}, content
30
+
31
+
parts = content.split("---", 2)
32
+
if len(parts) < 3:
33
+
return {}, content
34
+
35
+
frontmatter = {}
36
+
for line in parts[1].strip().split("\n"):
37
+
if ":" in line:
38
+
key, value = line.split(":", 1)
39
+
value = value.strip().strip('"\'')
40
+
if value == "false":
41
+
value = False
42
+
elif value == "true":
43
+
value = True
44
+
elif value == "null":
45
+
value = None
46
+
frontmatter[key.strip()] = value
47
+
48
+
return frontmatter, parts[2].strip()
49
+
50
+
51
+
def update_frontmatter(filepath: Path, updates: dict):
52
+
"""Update frontmatter values in a markdown file."""
53
+
content = filepath.read_text()
54
+
frontmatter, body = parse_frontmatter(content)
55
+
frontmatter.update(updates)
56
+
57
+
# Rebuild file
58
+
lines = ["---"]
59
+
for key, value in frontmatter.items():
60
+
if value is None:
61
+
lines.append(f"{key}: null")
62
+
elif isinstance(value, bool):
63
+
lines.append(f"{key}: {'true' if value else 'false'}")
64
+
elif isinstance(value, list):
65
+
lines.append(f"{key}: {value}")
66
+
else:
67
+
lines.append(f'{key}: "{value}"')
68
+
lines.append("---")
69
+
lines.append("")
70
+
lines.append(body)
71
+
72
+
filepath.write_text("\n".join(lines))
73
+
74
+
75
+
def load_published() -> dict:
76
+
"""Load published tracking."""
77
+
if PUBLISHED_FILE.exists():
78
+
return json.loads(PUBLISHED_FILE.read_text())
79
+
return {}
80
+
81
+
82
+
def save_published(data: dict):
83
+
"""Save published tracking."""
84
+
PUBLISHED_FILE.parent.mkdir(parents=True, exist_ok=True)
85
+
PUBLISHED_FILE.write_text(json.dumps(data, indent=2))
86
+
87
+
88
+
def cmd_new(slug: str):
89
+
"""Create new blog post draft."""
90
+
BLOG_DIR.mkdir(parents=True, exist_ok=True)
91
+
92
+
date = datetime.now().strftime("%Y-%m-%d")
93
+
filename = f"{date}-{slug}.md"
94
+
filepath = BLOG_DIR / filename
95
+
96
+
if filepath.exists():
97
+
console.print(f"[red]Already exists: {filepath}[/red]")
98
+
return
99
+
100
+
template = f'''---
101
+
title: "{slug.replace("-", " ").title()}"
102
+
date: {date}
103
+
tags: []
104
+
published: false
105
+
greengale_uri: null
106
+
---
107
+
108
+
# {slug.replace("-", " ").title()}
109
+
110
+
Write your content here.
111
+
'''
112
+
filepath.write_text(template)
113
+
console.print(f"[green]Created: {filepath}[/green]")
114
+
115
+
116
+
def cmd_list():
117
+
"""List all blog posts."""
118
+
if not BLOG_DIR.exists():
119
+
console.print("[yellow]No blog posts yet.[/yellow]")
120
+
return
121
+
122
+
table = Table(title="Blog Posts")
123
+
table.add_column("File", style="cyan")
124
+
table.add_column("Title")
125
+
table.add_column("Published", justify="center")
126
+
127
+
for f in sorted(BLOG_DIR.glob("*.md")):
128
+
content = f.read_text()
129
+
fm, _ = parse_frontmatter(content)
130
+
published = "✓" if fm.get("published") else ""
131
+
table.add_row(f.name, fm.get("title", "?"), published)
132
+
133
+
console.print(table)
134
+
135
+
136
+
async def cmd_publish(slug: str):
137
+
"""Publish a post to greengale."""
138
+
from tools.agent import ComindAgent
139
+
140
+
# Find the file
141
+
matches = list(BLOG_DIR.glob(f"*{slug}*.md"))
142
+
if not matches:
143
+
console.print(f"[red]No post matching '{slug}'[/red]")
144
+
return
145
+
146
+
filepath = matches[0]
147
+
content = filepath.read_text()
148
+
fm, body = parse_frontmatter(content)
149
+
150
+
# Check if already published
151
+
if fm.get("published"):
152
+
console.print(f"[yellow]Already published: {fm.get('greengale_uri')}[/yellow]")
153
+
return
154
+
155
+
title = fm.get("title", slug)
156
+
now = datetime.now(timezone.utc).isoformat().replace("+00:00", "Z")
157
+
158
+
# Post to greengale
159
+
async with ComindAgent() as agent:
160
+
record = {
161
+
"$type": "app.greengale.blog.entry",
162
+
"content": f"# {title}\n\n{body}",
163
+
"title": title,
164
+
"createdAt": now,
165
+
"visibility": "public"
166
+
}
167
+
168
+
result = await agent._client.post(
169
+
f"{agent.pds}/xrpc/com.atproto.repo.createRecord",
170
+
headers=agent.auth_headers,
171
+
json={
172
+
"repo": agent.did,
173
+
"collection": "app.greengale.blog.entry",
174
+
"record": record
175
+
}
176
+
)
177
+
178
+
if result.status_code != 200:
179
+
console.print(f"[red]Failed: {result.text}[/red]")
180
+
return
181
+
182
+
uri = result.json().get("uri")
183
+
console.print(f"[green]Published: {uri}[/green]")
184
+
185
+
# Update frontmatter
186
+
update_frontmatter(filepath, {"published": True, "greengale_uri": uri})
187
+
188
+
# Update tracking
189
+
published = load_published()
190
+
published[filepath.name] = {"uri": uri, "published_at": now}
191
+
save_published(published)
192
+
193
+
194
+
async def cmd_sync():
195
+
"""Publish all unpublished posts."""
196
+
if not BLOG_DIR.exists():
197
+
console.print("[yellow]No blog posts yet.[/yellow]")
198
+
return
199
+
200
+
for f in sorted(BLOG_DIR.glob("*.md")):
201
+
content = f.read_text()
202
+
fm, _ = parse_frontmatter(content)
203
+
if not fm.get("published"):
204
+
slug = f.stem.split("-", 3)[-1] if "-" in f.stem else f.stem
205
+
console.print(f"\nPublishing: {f.name}")
206
+
await cmd_publish(slug)
207
+
208
+
209
+
if __name__ == "__main__":
210
+
import sys
211
+
212
+
if len(sys.argv) < 2:
213
+
print(__doc__)
214
+
sys.exit(0)
215
+
216
+
cmd = sys.argv[1]
217
+
218
+
if cmd == "new" and len(sys.argv) > 2:
219
+
cmd_new(sys.argv[2])
220
+
elif cmd == "list":
221
+
cmd_list()
222
+
elif cmd == "publish" and len(sys.argv) > 2:
223
+
asyncio.run(cmd_publish(sys.argv[2]))
224
+
elif cmd == "sync":
225
+
asyncio.run(cmd_sync())
226
+
else:
227
+
print(__doc__)