Merge pull request #7 from sky-xo/gemini

feat: add Gemini agent spawn support

Author: sky-xo

go.mod

@@ -51,6 +51,7 @@ require (
 	golang.org/x/net v0.33.0 // indirect
 	golang.org/x/sys v0.39.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
 	modernc.org/libc v1.66.10 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
 	modernc.org/memory v1.11.0 // indirect

go.sum

@@ -114,6 +114,8 @@ golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
 golang.org/x/tools v0.36.0 h1:kWS0uv/zsvHEle1LbV5LE8QujrxB3wfQyxHfhOk0Qkg=
 golang.org/x/tools v0.36.0/go.mod h1:WBDiHKJK8YgLHlcQPYQzNCkUxUypCaa5ZegCVutKm+s=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 modernc.org/cc/v4 v4.26.5 h1:xM3bX7Mve6G8K8b+T11ReenJOT+BmVqQj0FY5T4+5Y4=
 modernc.org/cc/v4 v4.26.5/go.mod h1:uVtb5OGqUKpoLWhqwNQo/8LwvoiEBLvZXIQ/SmO6mL0=
 modernc.org/ccgo/v4 v4.28.1 h1:wPKYn5EC/mYTqBO373jKjvX2n+3+aK7+sICCv4Fjy1A=

internal/agent/agent.go

@@ -12,14 +12,15 @@ const (
 const (
 	SourceClaude = "claude"
 	SourceCodex  = "codex"
+	SourceGemini = "gemini"
 )
 
 // Agent represents any AI coding agent (Claude, Codex, etc.)
 type Agent struct {
 	// Identity
 	ID     string // ULID or extracted from filename
 	Name   string // Display name (user-given for Codex, extracted from transcript for Claude)
-	Source string // "claude" or "codex"
+	Source string // "claude", "codex", or "gemini"
 
 	// Channel grouping
 	RepoPath string // Git repo path

internal/cli/logs.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/sky-xo/june/internal/codex"
 	"github.com/sky-xo/june/internal/db"
+	"github.com/sky-xo/june/internal/gemini"
 	"github.com/spf13/cobra"
 )
 
@@ -47,24 +48,39 @@ func runLogs(name string) error {
 	// Find session file if not set
 	sessionFile := agent.SessionFile
 	if sessionFile == "" {
-		found, err := codex.FindSessionFile(agent.ULID)
-		if err != nil {
+		var findErr error
+		if agent.Type == "gemini" {
+			sessionFile, findErr = gemini.FindSessionFile(agent.ULID)
+		} else {
+			sessionFile, findErr = codex.FindSessionFile(agent.ULID)
+		}
+		if findErr != nil {
 			return fmt.Errorf("session file not found for agent %q", name)
 		}
-		sessionFile = found
 	}
 
-	// Read from beginning (cursor 0), don't update cursor
-	entries, _, err := codex.ReadTranscript(sessionFile, 0)
-	if err != nil {
-		return fmt.Errorf("failed to read transcript: %w", err)
+	// Read transcript based on agent type
+	var output string
+
+	if agent.Type == "gemini" {
+		entries, _, err := gemini.ReadTranscript(sessionFile, 0)
+		if err != nil {
+			return fmt.Errorf("failed to read transcript: %w", err)
+		}
+		output = gemini.FormatEntries(entries)
+	} else {
+		entries, _, err := codex.ReadTranscript(sessionFile, 0)
+		if err != nil {
+			return fmt.Errorf("failed to read transcript: %w", err)
+		}
+		output = codex.FormatEntries(entries)
 	}
 
-	if len(entries) == 0 {
+	if output == "" {
 		fmt.Println("(no output)")
 		return nil
 	}
 
-	fmt.Print(codex.FormatEntries(entries))
+	fmt.Print(output)
 	return nil
 }

internal/cli/peek.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/sky-xo/june/internal/codex"
 	"github.com/sky-xo/june/internal/db"
+	"github.com/sky-xo/june/internal/gemini"
 	"github.com/spf13/cobra"
 )
 
@@ -48,25 +49,41 @@ func runPeek(name string) error {
 	// Find session file if not set
 	sessionFile := agent.SessionFile
 	if sessionFile == "" {
-		found, err := codex.FindSessionFile(agent.ULID)
-		if err != nil {
+		var findErr error
+		if agent.Type == "gemini" {
+			sessionFile, findErr = gemini.FindSessionFile(agent.ULID)
+		} else {
+			sessionFile, findErr = codex.FindSessionFile(agent.ULID)
+		}
+		if findErr != nil {
 			return fmt.Errorf("session file not found for agent %q", name)
 		}
-		sessionFile = found
-		// Update in database
-		if err := database.UpdateSessionFile(name, found); err != nil {
-			// Log warning but continue - this is not fatal
+		if err := database.UpdateSessionFile(name, sessionFile); err != nil {
 			fmt.Fprintf(os.Stderr, "warning: failed to update session file in database: %v\n", err)
 		}
 	}
 
-	// Read from cursor
-	entries, newCursor, err := codex.ReadTranscript(sessionFile, agent.Cursor)
-	if err != nil {
-		return fmt.Errorf("failed to read transcript: %w", err)
+	// Read transcript based on agent type
+	var output string
+	var newCursor int
+
+	if agent.Type == "gemini" {
+		entries, cursor, err := gemini.ReadTranscript(sessionFile, agent.Cursor)
+		if err != nil {
+			return fmt.Errorf("failed to read transcript: %w", err)
+		}
+		newCursor = cursor
+		output = gemini.FormatEntries(entries)
+	} else {
+		entries, cursor, err := codex.ReadTranscript(sessionFile, agent.Cursor)
+		if err != nil {
+			return fmt.Errorf("failed to read transcript: %w", err)
+		}
+		newCursor = cursor
+		output = codex.FormatEntries(entries)
 	}
 
-	if len(entries) == 0 {
+	if output == "" {
 		fmt.Println("(no new output)")
 		return nil
 	}
@@ -76,7 +93,6 @@ func runPeek(name string) error {
 		return fmt.Errorf("failed to update cursor: %w", err)
 	}
 
-	// Print entries
-	fmt.Print(codex.FormatEntries(entries))
+	fmt.Print(output)
 	return nil
 }