Redesign gt seance: ZFC-compliant literal seance with predecessors (gt-7qvd7)

Major redesign based on design review:

1. REMOVED: Claude Code internal parsing (ZFC violation)
   - Deleted internal/claude/sessions.go (parsed ~/.claude/projects/)
   - This coupled us to Claude Code's undocumented internal format

2. ADDED: Event-based session discovery
   - gt prime now emits session_start events to ~/gt/.events.jsonl
   - Events include role, session_id, topic, cwd
   - Discovery reads our own event stream (ZFC-compliant)

3. ADDED: --talk flag for actual seances
   - gt seance --talk <session-id> spawns: claude --fork-session --resume <id>
   - --fork-session creates a new session (read-only, no grave disturbance)
   - You literally talk to your predecessor: "Where did you put X?"

4. ADDED: One-shot prompt mode
   - gt seance --talk <id> -p "Where is the config?"
   - Uses claude --print for quick questions

The name "seance" is now literal - you commune with the dead (past sessions).

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gastown/crew/joe
2025-12-31 00:27:59 -08:00
committed by Steve Yegge
parent 35586b57e5
commit 189db8a80e
5 changed files with 261 additions and 470 deletions

View File

@@ -12,6 +12,7 @@ import (
"github.com/spf13/cobra"
"github.com/steveyegge/gastown/internal/beads"
"github.com/steveyegge/gastown/internal/events"
"github.com/steveyegge/gastown/internal/lock"
"github.com/steveyegge/gastown/internal/style"
"github.com/steveyegge/gastown/internal/templates"
@@ -111,6 +112,9 @@ func runPrime(cmd *cobra.Command, args []string) error {
// Report agent state as running (ZFC: agents self-report state)
reportAgentState(ctx, "running")
// Emit session_start event for seance discovery
emitSessionEvent(ctx)
// Output context
if err := outputPrimeContext(ctx); err != nil {
return err
@@ -1392,3 +1396,35 @@ func checkPendingEscalations(ctx RoleContext) {
fmt.Println("Close resolved ones with `bd close <id> --reason \"resolution\"`")
fmt.Println()
}
// emitSessionEvent emits a session_start event for seance discovery.
// The event is written to ~/gt/.events.jsonl and can be queried via gt seance.
// Session ID comes from CLAUDE_SESSION_ID env var if available.
func emitSessionEvent(ctx RoleContext) {
if ctx.Role == RoleUnknown {
return
}
// Get agent identity for the actor field
actor := getAgentIdentity(ctx)
if actor == "" {
return
}
// Get session ID from environment (set by Claude Code hooks)
sessionID := os.Getenv("CLAUDE_SESSION_ID")
if sessionID == "" {
// Fall back to a generated identifier
sessionID = fmt.Sprintf("%s-%d", actor, os.Getpid())
}
// Determine topic from hook state or default
topic := ""
if ctx.Role == RoleWitness || ctx.Role == RoleRefinery || ctx.Role == RoleDeacon {
topic = "patrol"
}
// Emit the event
payload := events.SessionPayload(sessionID, actor, topic, ctx.WorkDir)
events.LogFeed(events.TypeSessionStart, actor, payload)
}

View File

@@ -1,170 +1,289 @@
package cmd
import (
"bufio"
"encoding/json"
"fmt"
"os"
"os/exec"
"path/filepath"
"sort"
"strings"
"time"
"github.com/spf13/cobra"
"github.com/steveyegge/gastown/internal/claude"
"github.com/steveyegge/gastown/internal/events"
"github.com/steveyegge/gastown/internal/style"
"github.com/steveyegge/gastown/internal/workspace"
)
var (
seanceAll bool
seanceRole string
seanceRig string
seanceRecent int
seanceTalk string
seancePrompt string
seanceJSON bool
)
var seanceCmd = &cobra.Command{
Use: "seance",
GroupID: GroupDiag,
Short: "Discover and browse predecessor sessions",
Long: `Find and resume predecessor Claude Code sessions.
Short: "Talk to your predecessor sessions",
Long: `Seance lets you literally talk to predecessor sessions.
Seance scans Claude Code's session history to find Gas Town sessions.
Sessions are identified by the [GAS TOWN] beacon sent during startup.
"Where did you put the stuff you left for me?" - The #1 handoff question.
Examples:
gt seance # List recent Gas Town sessions
gt seance --all # Include non-Gas Town sessions
Instead of parsing logs, seance spawns a Claude subprocess that resumes
a predecessor session with full context. You can ask questions directly:
- "Why did you make this decision?"
- "Where were you stuck?"
- "What did you try that didn't work?"
DISCOVERY:
gt seance # List recent sessions from events
gt seance --role crew # Filter by role type
gt seance --rig gastown # Filter by rig
gt seance --recent 10 # Last 10 sessions
gt seance --json # JSON output
gt seance --recent 10 # Last N sessions
Resume a session in Claude Code:
claude --resume <session-id>
THE SEANCE (talk to predecessor):
gt seance --talk <session-id> # Interactive conversation
gt seance --talk <id> -p "Where is X?" # One-shot question
The beacon format parsed:
[GAS TOWN] gastown/crew/joe • assigned:gt-xyz • 2025-12-30T15:42`,
The --talk flag spawns: claude --fork-session --resume <id>
This loads the predecessor's full context without modifying their session.
Sessions are discovered from:
1. Events emitted by SessionStart hooks (~/gt/.events.jsonl)
2. The [GAS TOWN] beacon makes sessions searchable in /resume`,
RunE: runSeance,
}
func init() {
seanceCmd.Flags().BoolVarP(&seanceAll, "all", "a", false, "Include non-Gas Town sessions")
seanceCmd.Flags().StringVar(&seanceRole, "role", "", "Filter by role (crew, polecat, witness, etc.)")
seanceCmd.Flags().StringVar(&seanceRig, "rig", "", "Filter by rig name")
seanceCmd.Flags().IntVarP(&seanceRecent, "recent", "n", 20, "Number of recent sessions to show")
seanceCmd.Flags().StringVarP(&seanceTalk, "talk", "t", "", "Session ID to commune with")
seanceCmd.Flags().StringVarP(&seancePrompt, "prompt", "p", "", "One-shot prompt (with --talk)")
seanceCmd.Flags().BoolVar(&seanceJSON, "json", false, "Output as JSON")
rootCmd.AddCommand(seanceCmd)
}
// sessionEvent represents a session_start event from our event stream.
type sessionEvent struct {
Timestamp string `json:"ts"`
Type string `json:"type"`
Actor string `json:"actor"`
Payload map[string]interface{} `json:"payload"`
}
func runSeance(cmd *cobra.Command, args []string) error {
filter := claude.SessionFilter{
GasTownOnly: !seanceAll,
Role: seanceRole,
Rig: seanceRig,
Limit: seanceRecent,
// If --talk is provided, spawn a seance
if seanceTalk != "" {
return runSeanceTalk(seanceTalk, seancePrompt)
}
sessions, err := claude.DiscoverSessions(filter)
// Otherwise, list discoverable sessions
return runSeanceList()
}
func runSeanceList() error {
townRoot, err := workspace.FindFromCwd()
if err != nil || townRoot == "" {
return fmt.Errorf("not in a Gas Town workspace")
}
// Read session events from our event stream
sessions, err := discoverSessions(townRoot)
if err != nil {
return fmt.Errorf("discovering sessions: %w", err)
}
// Apply filters
var filtered []sessionEvent
for _, s := range sessions {
if seanceRole != "" {
actor := strings.ToLower(s.Actor)
if !strings.Contains(actor, strings.ToLower(seanceRole)) {
continue
}
}
if seanceRig != "" {
actor := strings.ToLower(s.Actor)
if !strings.Contains(actor, strings.ToLower(seanceRig)) {
continue
}
}
filtered = append(filtered, s)
}
// Apply limit
if seanceRecent > 0 && len(filtered) > seanceRecent {
filtered = filtered[:seanceRecent]
}
if seanceJSON {
enc := json.NewEncoder(os.Stdout)
enc.SetIndent("", " ")
return enc.Encode(sessions)
return enc.Encode(filtered)
}
if len(sessions) == 0 {
if seanceAll {
fmt.Println("No sessions found.")
} else {
fmt.Println("No Gas Town sessions found.")
fmt.Println(style.Dim.Render("Use --all to include non-Gas Town sessions"))
}
if len(filtered) == 0 {
fmt.Println("No session events found.")
fmt.Println(style.Dim.Render("Sessions are discovered from ~/gt/.events.jsonl"))
fmt.Println(style.Dim.Render("Ensure SessionStart hooks emit session_start events"))
return nil
}
// Print header
fmt.Printf("%s\n\n", style.Bold.Render("Claude Code Sessions"))
fmt.Printf("%s\n\n", style.Bold.Render("Discoverable Sessions"))
// Calculate column widths
idWidth := 10
roleWidth := 24
// Column widths
idWidth := 12
roleWidth := 26
timeWidth := 16
topicWidth := 30
topicWidth := 28
// Header row
fmt.Printf("%-*s %-*s %-*s %-*s\n",
idWidth, "ID",
idWidth, "SESSION_ID",
roleWidth, "ROLE",
timeWidth, "STARTED",
topicWidth, "TOPIC")
fmt.Printf("%s\n", strings.Repeat("─", idWidth+roleWidth+timeWidth+topicWidth+6))
for _, s := range sessions {
id := s.ShortID()
role := s.Role
if role == "" {
// Try to infer from path
role = inferRoleFromPath(s.Path)
for _, s := range filtered {
sessionID := getPayloadString(s.Payload, "session_id")
if len(sessionID) > idWidth {
sessionID = sessionID[:idWidth-1] + "…"
}
role := s.Actor
if len(role) > roleWidth {
role = role[:roleWidth-1] + "…"
}
timeStr := s.FormatTime()
timeStr := formatEventTime(s.Timestamp)
topic := s.Topic
if topic == "" && s.Summary != "" {
// Use summary as fallback
topic = s.Summary
topic := getPayloadString(s.Payload, "topic")
if topic == "" {
topic = "-"
}
if len(topic) > topicWidth {
topic = topic[:topicWidth-1] + "…"
}
// Color based on Gas Town status
if s.IsGasTown {
fmt.Printf("%-*s %-*s %-*s %-*s\n",
idWidth, id,
roleWidth, role,
timeWidth, timeStr,
topicWidth, topic)
} else {
fmt.Printf("%s %s %s %s\n",
style.Dim.Render(fmt.Sprintf("%-*s", idWidth, id)),
style.Dim.Render(fmt.Sprintf("%-*s", roleWidth, role)),
style.Dim.Render(fmt.Sprintf("%-*s", timeWidth, timeStr)),
style.Dim.Render(fmt.Sprintf("%-*s", topicWidth, topic)))
}
fmt.Printf("%-*s %-*s %-*s %-*s\n",
idWidth, sessionID,
roleWidth, role,
timeWidth, timeStr,
topicWidth, topic)
}
fmt.Printf("\n%s\n", style.Dim.Render("Resume a session: claude --resume <full-session-id>"))
fmt.Printf("\n%s\n", style.Bold.Render("Talk to a predecessor:"))
fmt.Printf(" gt seance --talk <session-id>\n")
fmt.Printf(" gt seance --talk <session-id> -p \"Where did you put X?\"\n")
return nil
}
// inferRoleFromPath attempts to extract a role from the project path.
func inferRoleFromPath(path string) string {
// Look for patterns like /crew/joe, /polecats/furiosa, /witness, etc.
parts := strings.Split(path, "/")
for i := len(parts) - 1; i >= 0; i-- {
part := parts[i]
switch part {
case "witness", "refinery", "deacon", "mayor":
return part
case "crew", "polecats":
if i+1 < len(parts) {
// Include the agent name
return fmt.Sprintf("%s/%s", part, parts[i+1])
func runSeanceTalk(sessionID, prompt string) error {
// Expand short IDs if needed (user might provide partial)
// For now, require full ID or let claude --resume handle it
fmt.Printf("%s Summoning session %s...\n\n", style.Bold.Render("🔮"), sessionID)
// Build the command
args := []string{"--fork-session", "--resume", sessionID}
if prompt != "" {
// One-shot mode with --print
args = append(args, "--print", prompt)
cmd := exec.Command("claude", args...)
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
if err := cmd.Run(); err != nil {
return fmt.Errorf("seance failed: %w", err)
}
return nil
}
// Interactive mode - just launch claude
cmd := exec.Command("claude", args...)
cmd.Stdin = os.Stdin
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
fmt.Printf("%s\n", style.Dim.Render("You are now talking to your predecessor. Ask them anything."))
fmt.Printf("%s\n\n", style.Dim.Render("Exit with /exit or Ctrl+C"))
if err := cmd.Run(); err != nil {
// Exit errors are normal when user exits
if exitErr, ok := err.(*exec.ExitError); ok {
if exitErr.ExitCode() == 0 || exitErr.ExitCode() == 130 {
return nil // Normal exit or Ctrl+C
}
return part
}
return fmt.Errorf("seance ended: %w", err)
}
return nil
}
// discoverSessions reads session_start events from our event stream.
func discoverSessions(townRoot string) ([]sessionEvent, error) {
eventsPath := filepath.Join(townRoot, events.EventsFile)
file, err := os.Open(eventsPath)
if err != nil {
if os.IsNotExist(err) {
return nil, nil
}
return nil, err
}
defer file.Close()
var sessions []sessionEvent
scanner := bufio.NewScanner(file)
// Increase buffer for large lines
buf := make([]byte, 0, 64*1024)
scanner.Buffer(buf, 1024*1024)
for scanner.Scan() {
var event sessionEvent
if err := json.Unmarshal(scanner.Bytes(), &event); err != nil {
continue
}
if event.Type == events.TypeSessionStart {
sessions = append(sessions, event)
}
}
// Fall back to last path component
if len(parts) > 0 {
return parts[len(parts)-1]
}
return "unknown"
// Sort by timestamp descending (most recent first)
sort.Slice(sessions, func(i, j int) bool {
return sessions[i].Timestamp > sessions[j].Timestamp
})
return sessions, scanner.Err()
}
func getPayloadString(payload map[string]interface{}, key string) string {
if v, ok := payload[key]; ok {
if s, ok := v.(string); ok {
return s
}
}
return ""
}
func formatEventTime(ts string) string {
t, err := time.Parse(time.RFC3339, ts)
if err != nil {
return ts
}
return t.Local().Format("2006-01-02 15:04")
}