Implement sess end workflow

Author: Adjanour

.gitignore

@@ -1,2 +1,5 @@
 /sess
 /sess.exe
+docs/INTRO-POST.md
+docs/LINKEDIN-POST.md
+docs/V0.2.2-UPDATE.md

README.md

@@ -239,15 +239,15 @@ sess projects
 #    Last used: 2 hours ago
 ```
 
-### 8. End Session and Create PR (Coming in Phase 3)
+### 8. End Session and Create PR
 
 ```bash
 sess end
-# Prompts for PR description
-# Rebases onto dev
+# Prompts for commit/PR details when needed
+# Rebases onto the tracked base branch
 # Pushes branch
-# Opens PR linked to issue
-# Switches back to dev
+# Reuses or creates a PR
+# Switches back to the base branch
 ```
 
 ---
@@ -261,7 +261,7 @@ sess end
 | `sess pause` | ✅ **MVP1** | Pause current session and stop time tracking |
 | `sess resume` | ✅ **MVP1** | Resume paused session and continue time tracking |
 | `sess projects` | ✅ **MVP1** | List all tracked projects across the system |
-| `sess end` | 🚧 [Phase 3 — #3](../../issues/3) | End session, commit, push, open PR |
+| `sess end` | ✅ **v0.3.0** | End session, commit, push, create or reuse PR |
 | `sess auth` | 🚧 [Phase 4 — #6](../../issues/6) | Authenticate with GitHub (currently uses `gh` auth) |
 | `sess config` | 🚧 [Phase 4 — #7](../../issues/7) | Initialize CLI in repo with custom settings |
 
@@ -314,21 +314,20 @@ sess end
   - [x] Show session status for each project
   - [x] Display last used timestamps
 
-### Phase 3: End-to-End Workflow 🚧 **NEXT**
+### Phase 3: End-to-End Workflow ✅ **DELIVERED IN v0.3.0**
 
 **Goal:** Complete the session lifecycle from start to PR
 
-- [ ] **`sess end` Command** — [Issue #3](../../issues/3)
-  - [ ] Interactive PR description input (use PR template if exists)
-  - [ ] Commit all changes with user message
-  - [ ] Rebase onto base branch (`dev`)
-  - [ ] Conflict detection and resolution guidance
-  - [ ] Push branch to remote
-  - [ ] Create GitHub PR via `gh` CLI
-  - [ ] Link PR to issue automatically
-  - [ ] Switch back to base branch
-  - [ ] Mark session as ended
-  - [ ] Show session summary (duration, commits, PR link)
+- [x] **`sess end` Command** — [Issue #3](../../issues/3)
+  - [x] Interactive commit and PR description input
+  - [x] Commit dirty work with a user-provided message
+  - [x] Rebase onto the tracked base branch
+  - [x] Push branch to remote
+  - [x] Create or reuse a GitHub PR via `gh` CLI
+  - [x] Link PR metadata to the ended session
+  - [x] Switch back to the base branch
+  - [x] Mark session as ended
+  - [x] Show session summary (duration, PR link)
 
 - [ ] **Conflict Handling** — [Issue #4](../../issues/4)
   - [ ] Detect rebase conflicts
@@ -362,7 +361,8 @@ sess end
 - [x] **Session History** ✅ (MVP1)
   - [x] Store completed sessions in SQLite database
   - [x] Track: duration, issue, branch, state
-  - [ ] Track: commits, PR link (Phase 3)
+  - [x] Track: PR link (Phase 3)
+  - [ ] Track: commits
 
 - [ ] **Analytics Commands** — [Issue #8](../../issues/8)
   - [ ] `sess history` - Show recent sessions

docs/IMPLEMENTATION-PLAN.md

@@ -209,6 +209,10 @@ The session manager supports ending a session, but the CLI does not complete the
 - The resulting PR targets the configured base branch.
 - Session state is correct even if a later step fails.
 
+**Follow-up**
+
+- Investigate PTY-specific text-input truncation seen during automated `sess end` validation. The current command flow and prompt submission behavior are working, but a harness-driven repro still dropped the literal substring `end` inside one PR summary input chunk. Treat this as a lower-priority TUI/input-path bug and verify it against real terminal usage before changing prompt behavior further.
+
 ### 9. Add conflict and interrupted-workflow recovery
 
 **Problem**

docs/NEXT-STEPS.md

@@ -8,7 +8,6 @@ This document consolidates the open GitHub issues and remaining roadmap phases s
 
 | # | Title | Phase | Priority |
 |---|-------|-------|----------|
-| [#3](../../issues/3) | Implement `sess end` workflow | Phase 3 | 🔴 High |
 | [#4](../../issues/4) | Surface and recover from rebase or push conflicts | Phase 3 | 🔴 High |
 | [#5](../../issues/5) | Align CLI output with design guide | Cross-cutting | 🟡 Medium |
 | [#6](../../issues/6) | Add GitHub auth command | Phase 4 | 🟡 Medium |
@@ -19,12 +18,11 @@ This document consolidates the open GitHub issues and remaining roadmap phases s
 
 ## Recommended Work Order
 
-### 1. Phase 3 — Complete the Session Lifecycle (Issues #3, #4)
+### 1. Phase 3 — Finish Conflict Recovery (Issue #4)
 
-This is the most impactful next milestone. `sess end` closes the loop from session start to a merged PR, making SESS a complete tool rather than a partial one.
+`sess end` is now implemented. The remaining Phase 3 gap is robust recovery from rebase, push, or PR-creation interruptions.
 
 **Start here:**
-- [#3 — Implement `sess end` workflow](../../issues/3): prompt for PR description, commit, rebase, push, open PR via `gh`, switch back to base branch, mark session ended.
 - [#4 — Conflict handling](../../issues/4): detect rebase conflicts, pause workflow gracefully, allow the user to resolve and resume.
 
 ### 2. Cross-Cutting — Output Quality (Issue #5)
@@ -73,3 +71,4 @@ These items from the roadmap do not yet have GitHub issues. Open issues as work
 - [docs/cli_design_guide.md](cli_design_guide.md)
 - [docs/technical-spec.md](technical-spec.md)
 - [docs/MVP1-SUMMARY.md](MVP1-SUMMARY.md)
+- [docs/IMPLEMENTATION-PLAN.md](IMPLEMENTATION-PLAN.md)

docs/RELEASING.md

@@ -116,7 +116,7 @@ We follow [Semantic Versioning](https://semver.org/):
 
 - **v0.1.0** - Initial release with basic session start
 - **v0.2.0** - MVP1 - Database persistence, pause/resume, projects listing
-- **v0.3.0** - (Planned) Phase 3 - `sess end` command, PR creation
+- **v0.3.0** - Phase 3 - `sess end` command, PR creation
 - **v1.0.0** - (Future) Production-ready, stable API
 
 ## Pre-release Versions
@@ -396,8 +396,8 @@ If you encounter issues with the release process:
 
 ---
 
-**Next Release:** v0.3.0 (Phase 3 - `sess end` command)
+**Next Release:** TBD
 
 **Target Date:** TBD
 
-**Features:** PR creation, rebase automation, session completion
+**Features:** conflict recovery, auth/config work, or other post-v0.3.0 priorities

internal/db/db.go

@@ -42,6 +42,8 @@ type Session struct {
 	CurrentSliceStart *time.Time // When the current active slice started
 	TotalElapsed      int64      // Duration in nanoseconds
 	BranchType        string
+	PRNumber          *int64
+	PRURL             string
 }
 
 const (
@@ -120,6 +122,8 @@ func (db *DB) init() error {
 		current_slice_start DATETIME,
 		total_elapsed INTEGER NOT NULL DEFAULT 0,
 		branch_type TEXT,
+		pr_number INTEGER,
+		pr_url TEXT,
 		FOREIGN KEY (project_id) REFERENCES projects(id) ON DELETE CASCADE
 	);
 
@@ -142,27 +146,45 @@ func (db *DB) init() error {
 
 // runMigrations applies schema changes to existing databases
 func (db *DB) runMigrations() error {
-	// Check if current_slice_start column exists
-	var count int
-	err := db.conn.QueryRow(`
-		SELECT COUNT(*) FROM pragma_table_info('sessions')
-		WHERE name = 'current_slice_start'
-	`).Scan(&count)
-
-	if err != nil {
-		return fmt.Errorf("failed to check for current_slice_start column: %w", err)
+	migrations := []struct {
+		column     string
+		definition string
+	}{
+		{column: "current_slice_start", definition: "DATETIME"},
+		{column: "pr_number", definition: "INTEGER"},
+		{column: "pr_url", definition: "TEXT"},
 	}
 
-	// Add current_slice_start column if it doesn't exist
-	if count == 0 {
-		if _, err := db.conn.Exec(`ALTER TABLE sessions ADD COLUMN current_slice_start DATETIME`); err != nil {
-			return fmt.Errorf("failed to add current_slice_start column: %w", err)
+	for _, migration := range migrations {
+		exists, err := db.hasSessionsColumn(migration.column)
+		if err != nil {
+			return fmt.Errorf("failed to check for %s column: %w", migration.column, err)
+		}
+		if exists {
+			continue
+		}
+
+		query := fmt.Sprintf("ALTER TABLE sessions ADD COLUMN %s %s", migration.column, migration.definition)
+		if _, err := db.conn.Exec(query); err != nil {
+			return fmt.Errorf("failed to add %s column: %w", migration.column, err)
 		}
 	}
 
 	return nil
 }
 
+func (db *DB) hasSessionsColumn(name string) (bool, error) {
+	var count int
+	err := db.conn.QueryRow(`
+		SELECT COUNT(*) FROM pragma_table_info('sessions')
+		WHERE name = ?
+	`, name).Scan(&count)
+	if err != nil {
+		return false, err
+	}
+	return count > 0, nil
+}
+
 // Close closes the database connection
 func (db *DB) Close() error {
 	if db.conn != nil {
@@ -289,9 +311,9 @@ func (db *DB) UpdateProject(p *Project) error {
 // CreateSession creates a new session
 func (db *DB) CreateSession(s *Session) (*Session, error) {
 	result, err := db.conn.Exec(
-		`INSERT INTO sessions (project_id, branch, issue_id, issue_title, state, start_time, current_slice_start, total_elapsed, branch_type)
-		 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,
-		s.ProjectID, s.Branch, s.IssueID, s.IssueTitle, s.State, s.StartTime, s.CurrentSliceStart, s.TotalElapsed, s.BranchType,
+		`INSERT INTO sessions (project_id, branch, issue_id, issue_title, state, start_time, current_slice_start, total_elapsed, branch_type, pr_number, pr_url)
+		 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
+		s.ProjectID, s.Branch, s.IssueID, s.IssueTitle, s.State, s.StartTime, s.CurrentSliceStart, s.TotalElapsed, s.BranchType, s.PRNumber, s.PRURL,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create session: %w", err)
@@ -310,16 +332,19 @@ func (db *DB) CreateSession(s *Session) (*Session, error) {
 func (db *DB) GetActiveSession(projectID int64) (*Session, error) {
 	var s Session
 	var pauseTime, endTime, currentSliceStart sql.NullTime
+	var prNumber sql.NullInt64
+	var prURL sql.NullString
 
 	err := db.conn.QueryRow(
 		`SELECT id, project_id, branch, COALESCE(issue_id, ''), COALESCE(issue_title, ''),
-		        state, start_time, pause_time, end_time, current_slice_start, total_elapsed, COALESCE(branch_type, '')
+		        state, start_time, pause_time, end_time, current_slice_start, total_elapsed, COALESCE(branch_type, ''),
+		        pr_number, COALESCE(pr_url, '')
 		 FROM sessions
 		 WHERE project_id = ? AND state IN ('active', 'paused')
 		 ORDER BY start_time DESC LIMIT 1`,
 		projectID,
 	).Scan(&s.ID, &s.ProjectID, &s.Branch, &s.IssueID, &s.IssueTitle, &s.State,
-		&s.StartTime, &pauseTime, &endTime, &currentSliceStart, &s.TotalElapsed, &s.BranchType)
+		&s.StartTime, &pauseTime, &endTime, &currentSliceStart, &s.TotalElapsed, &s.BranchType, &prNumber, &prURL)
 
 	if err == sql.ErrNoRows {
 		return nil, nil
@@ -337,6 +362,12 @@ func (db *DB) GetActiveSession(projectID int64) (*Session, error) {
 	if currentSliceStart.Valid {
 		s.CurrentSliceStart = &currentSliceStart.Time
 	}
+	if prNumber.Valid {
+		s.PRNumber = &prNumber.Int64
+	}
+	if prURL.Valid {
+		s.PRURL = prURL.String
+	}
 
 	return &s, nil
 }
@@ -345,9 +376,9 @@ func (db *DB) GetActiveSession(projectID int64) (*Session, error) {
 func (db *DB) UpdateSession(s *Session) error {
 	_, err := db.conn.Exec(
 		`UPDATE sessions
-		 SET state = ?, pause_time = ?, end_time = ?, current_slice_start = ?, total_elapsed = ?
+		 SET state = ?, pause_time = ?, end_time = ?, current_slice_start = ?, total_elapsed = ?, pr_number = ?, pr_url = ?
 		 WHERE id = ?`,
-		s.State, s.PauseTime, s.EndTime, s.CurrentSliceStart, s.TotalElapsed, s.ID,
+		s.State, s.PauseTime, s.EndTime, s.CurrentSliceStart, s.TotalElapsed, s.PRNumber, s.PRURL, s.ID,
 	)
 	if err != nil {
 		return fmt.Errorf("failed to update session: %w", err)
@@ -359,7 +390,8 @@ func (db *DB) UpdateSession(s *Session) error {
 func (db *DB) GetSessionHistory(projectID int64, limit int) ([]*Session, error) {
 	rows, err := db.conn.Query(
 		`SELECT id, project_id, branch, COALESCE(issue_id, ''), COALESCE(issue_title, ''),
-		        state, start_time, pause_time, end_time, current_slice_start, total_elapsed, COALESCE(branch_type, '')
+		        state, start_time, pause_time, end_time, current_slice_start, total_elapsed, COALESCE(branch_type, ''),
+		        pr_number, COALESCE(pr_url, '')
 		 FROM sessions
 		 WHERE project_id = ?
 		 ORDER BY start_time DESC LIMIT ?`,
@@ -374,9 +406,11 @@ func (db *DB) GetSessionHistory(projectID int64, limit int) ([]*Session, error)
 	for rows.Next() {
 		var s Session
 		var pauseTime, endTime, currentSliceStart sql.NullTime
+		var prNumber sql.NullInt64
+		var prURL sql.NullString
 
 		if err := rows.Scan(&s.ID, &s.ProjectID, &s.Branch, &s.IssueID, &s.IssueTitle,
-			&s.State, &s.StartTime, &pauseTime, &endTime, &currentSliceStart, &s.TotalElapsed, &s.BranchType); err != nil {
+			&s.State, &s.StartTime, &pauseTime, &endTime, &currentSliceStart, &s.TotalElapsed, &s.BranchType, &prNumber, &prURL); err != nil {
 			return nil, fmt.Errorf("failed to scan session: %w", err)
 		}
 
@@ -389,6 +423,12 @@ func (db *DB) GetSessionHistory(projectID int64, limit int) ([]*Session, error)
 		if currentSliceStart.Valid {
 			s.CurrentSliceStart = &currentSliceStart.Time
 		}
+		if prNumber.Valid {
+			s.PRNumber = &prNumber.Int64
+		}
+		if prURL.Valid {
+			s.PRURL = prURL.String
+		}
 
 		sessions = append(sessions, &s)
 	}

internal/db/db_test.go

@@ -87,15 +87,60 @@ func TestOpenMigratesCurrentSliceStartColumn(t *testing.T) {
 		}
 	}()
 
+	assertSessionsColumnCount(t, database, "current_slice_start", 1)
+	assertSessionsColumnCount(t, database, "pr_number", 1)
+	assertSessionsColumnCount(t, database, "pr_url", 1)
+}
+
+func TestSessionHistoryRoundTripsPRMetadata(t *testing.T) {
+	database := newTestDB(t)
+	project := newTestProject(t, database)
+
+	prNumber := int64(45)
+	endTime := time.Now()
+
+	if _, err := database.CreateSession(&Session{
+		ProjectID:         project.ID,
+		Branch:            "feature/with-pr",
+		State:             StateEnded,
+		StartTime:         time.Now().Add(-time.Hour),
+		EndTime:           &endTime,
+		CurrentSliceStart: nil,
+		TotalElapsed:      int64(30 * time.Minute),
+		BranchType:        "feature",
+		PRNumber:          &prNumber,
+		PRURL:             "https://github.com/example/repo/pull/45",
+	}); err != nil {
+		t.Fatalf("create session: %v", err)
+	}
+
+	history, err := database.GetSessionHistory(project.ID, 10)
+	if err != nil {
+		t.Fatalf("get session history: %v", err)
+	}
+	if len(history) != 1 {
+		t.Fatalf("history length = %d, want 1", len(history))
+	}
+	if history[0].PRNumber == nil || *history[0].PRNumber != prNumber {
+		t.Fatalf("history PR number = %v, want %d", history[0].PRNumber, prNumber)
+	}
+	if history[0].PRURL != "https://github.com/example/repo/pull/45" {
+		t.Fatalf("history PR URL = %q, want PR URL", history[0].PRURL)
+	}
+}
+
+func assertSessionsColumnCount(t *testing.T, database *DB, column string, want int) {
+	t.Helper()
+
 	var count int
 	if err := database.conn.QueryRow(`
 		SELECT COUNT(*) FROM pragma_table_info('sessions')
-		WHERE name = 'current_slice_start'
-	`).Scan(&count); err != nil {
-		t.Fatalf("query current_slice_start column: %v", err)
+		WHERE name = ?
+	`, column).Scan(&count); err != nil {
+		t.Fatalf("query %s column: %v", column, err)
 	}
-	if count != 1 {
-		t.Fatalf("current_slice_start column count = %d, want 1", count)
+	if count != want {
+		t.Fatalf("%s column count = %d, want %d", column, count, want)
 	}
 }