Instrument gt commands to appear in activity feed (gt-7aw1m)
Phase 1 of activity feed improvements: gt commands now log events to
~/gt/.events.jsonl. This is the raw audit log that the feed daemon
(phase 2) will curate into the user-facing feed.
Instrumented commands:
- gt sling: logs sling events with bead and target
- gt hook: logs hook events with bead
- gt handoff: logs handoff events with subject
- gt done: logs done events with bead and branch
- gt mail send: logs mail events with to and subject
Event format follows the specification:
```json
{"ts":"2025-12-30T07:36:28Z","source":"gt","type":"mail",
"actor":"gastown/crew/joe","payload":{...},"visibility":"feed"}
```
🤖 Generated with [Claude Code](https://claude.com/claude-code)
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
174
internal/events/events.go
Normal file
174
internal/events/events.go
Normal file
@@ -0,0 +1,174 @@
|
||||
// Package events provides event logging for the gt activity feed.
|
||||
//
|
||||
// Events are written to ~/gt/.events.jsonl (raw audit log) and later
|
||||
// curated by the feed daemon into ~/.feed.jsonl (user-facing).
|
||||
package events
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/steveyegge/gastown/internal/workspace"
|
||||
)
|
||||
|
||||
// Event represents an activity event in Gas Town.
|
||||
type Event struct {
|
||||
Timestamp string `json:"ts"`
|
||||
Source string `json:"source"`
|
||||
Type string `json:"type"`
|
||||
Actor string `json:"actor"`
|
||||
Payload map[string]interface{} `json:"payload,omitempty"`
|
||||
Visibility string `json:"visibility"`
|
||||
}
|
||||
|
||||
// Visibility levels for events.
|
||||
const (
|
||||
VisibilityAudit = "audit" // Only in raw events log
|
||||
VisibilityFeed = "feed" // Appears in curated feed
|
||||
VisibilityBoth = "both" // Both audit and feed
|
||||
)
|
||||
|
||||
// Common event types for gt commands.
|
||||
const (
|
||||
TypeSling = "sling"
|
||||
TypeHook = "hook"
|
||||
TypeUnhook = "unhook"
|
||||
TypeHandoff = "handoff"
|
||||
TypeDone = "done"
|
||||
TypeMail = "mail"
|
||||
TypeSpawn = "spawn"
|
||||
TypeKill = "kill"
|
||||
TypeNudge = "nudge"
|
||||
TypeBoot = "boot"
|
||||
TypeHalt = "halt"
|
||||
)
|
||||
|
||||
// EventsFile is the name of the raw events log.
|
||||
const EventsFile = ".events.jsonl"
|
||||
|
||||
// mutex protects concurrent writes to the events file.
|
||||
var mutex sync.Mutex
|
||||
|
||||
// Log writes an event to the events log.
|
||||
// The event is appended to ~/gt/.events.jsonl.
|
||||
// Returns nil if logging fails (events are best-effort).
|
||||
func Log(eventType, actor string, payload map[string]interface{}, visibility string) error {
|
||||
event := Event{
|
||||
Timestamp: time.Now().UTC().Format(time.RFC3339),
|
||||
Source: "gt",
|
||||
Type: eventType,
|
||||
Actor: actor,
|
||||
Payload: payload,
|
||||
Visibility: visibility,
|
||||
}
|
||||
return write(event)
|
||||
}
|
||||
|
||||
// LogFeed is a convenience wrapper for feed-visible events.
|
||||
func LogFeed(eventType, actor string, payload map[string]interface{}) error {
|
||||
return Log(eventType, actor, payload, VisibilityFeed)
|
||||
}
|
||||
|
||||
// LogAudit is a convenience wrapper for audit-only events.
|
||||
func LogAudit(eventType, actor string, payload map[string]interface{}) error {
|
||||
return Log(eventType, actor, payload, VisibilityAudit)
|
||||
}
|
||||
|
||||
// write appends an event to the events file.
|
||||
func write(event Event) error {
|
||||
// Find town root
|
||||
townRoot, err := workspace.FindFromCwd()
|
||||
if err != nil || townRoot == "" {
|
||||
// Silently ignore - we're not in a Gas Town workspace
|
||||
return nil
|
||||
}
|
||||
|
||||
eventsPath := filepath.Join(townRoot, EventsFile)
|
||||
|
||||
// Marshal event to JSON
|
||||
data, err := json.Marshal(event)
|
||||
if err != nil {
|
||||
return fmt.Errorf("marshaling event: %w", err)
|
||||
}
|
||||
data = append(data, '\n')
|
||||
|
||||
// Append to file with proper locking
|
||||
mutex.Lock()
|
||||
defer mutex.Unlock()
|
||||
|
||||
f, err := os.OpenFile(eventsPath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
|
||||
if err != nil {
|
||||
return fmt.Errorf("opening events file: %w", err)
|
||||
}
|
||||
defer f.Close()
|
||||
|
||||
if _, err := f.Write(data); err != nil {
|
||||
return fmt.Errorf("writing event: %w", err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// Payload helpers for common event structures.
|
||||
|
||||
// SlingPayload creates a payload for sling events.
|
||||
func SlingPayload(beadID, target string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"bead": beadID,
|
||||
"target": target,
|
||||
}
|
||||
}
|
||||
|
||||
// HookPayload creates a payload for hook events.
|
||||
func HookPayload(beadID string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"bead": beadID,
|
||||
}
|
||||
}
|
||||
|
||||
// HandoffPayload creates a payload for handoff events.
|
||||
func HandoffPayload(subject string, toSession bool) map[string]interface{} {
|
||||
p := map[string]interface{}{
|
||||
"to_session": toSession,
|
||||
}
|
||||
if subject != "" {
|
||||
p["subject"] = subject
|
||||
}
|
||||
return p
|
||||
}
|
||||
|
||||
// DonePayload creates a payload for done events.
|
||||
func DonePayload(beadID, branch string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"bead": beadID,
|
||||
"branch": branch,
|
||||
}
|
||||
}
|
||||
|
||||
// MailPayload creates a payload for mail events.
|
||||
func MailPayload(to, subject string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"to": to,
|
||||
"subject": subject,
|
||||
}
|
||||
}
|
||||
|
||||
// SpawnPayload creates a payload for spawn events.
|
||||
func SpawnPayload(rig, polecat string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"rig": rig,
|
||||
"polecat": polecat,
|
||||
}
|
||||
}
|
||||
|
||||
// BootPayload creates a payload for rig boot events.
|
||||
func BootPayload(rig string, agents []string) map[string]interface{} {
|
||||
return map[string]interface{}{
|
||||
"rig": rig,
|
||||
"agents": agents,
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user