session: move session/internal/session to internal/session (#700)

Author: hyprh

session/internal/session/summary.go renamed to internal/session/summary/summary.go

@@ -7,8 +7,8 @@
 //
 //
 
-// Package session provides internal session functionality.
-package session
+// Package summary provides internal session summary functionality.
+package summary
 
 import (
 	"context"

session/internal/session/summary_test.go renamed to internal/session/summary/summary_test.go

@@ -7,7 +7,7 @@
 //
 //
 
-package session
+package summary
 
 import (
 	"context"

session/inmemory/summary.go

@@ -15,9 +15,9 @@ import (
 	"fmt"
 	"time"
 
+	"trpc.group/trpc-go/trpc-agent-go/internal/session/summary"
 	"trpc.group/trpc-go/trpc-agent-go/log"
 	"trpc.group/trpc-go/trpc-agent-go/session"
-	isession "trpc.group/trpc-go/trpc-agent-go/session/internal/session"
 )
 
 // CreateSessionSummary generates a summary for the session and stores it on the session object.
@@ -37,7 +37,7 @@ func (s *SessionService) CreateSessionSummary(ctx context.Context, sess *session
 
 	// Run summarization based on the provided session. Persistence path will
 	// validate app/session existence under lock.
-	updated, err := isession.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
+	updated, err := summary.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
 	if err != nil {
 		return fmt.Errorf("summarize and persist failed: %w", err)
 	}

session/mysql/summary.go

@@ -17,9 +17,9 @@ import (
 	"fmt"
 	"time"
 
+	"trpc.group/trpc-go/trpc-agent-go/internal/session/summary"
 	"trpc.group/trpc-go/trpc-agent-go/log"
 	"trpc.group/trpc-go/trpc-agent-go/session"
-	isession "trpc.group/trpc-go/trpc-agent-go/session/internal/session"
 )
 
 // CreateSessionSummary is the internal implementation that returns the summary.
@@ -41,7 +41,7 @@ func (s *Service) CreateSessionSummary(
 		return fmt.Errorf("check session key failed: %w", err)
 	}
 
-	updated, err := isession.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
+	updated, err := summary.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
 	if err != nil {
 		return fmt.Errorf("summarize and persist failed: %w", err)
 	}

session/postgres/summary.go

@@ -17,9 +17,9 @@ import (
 	"fmt"
 	"time"
 
+	"trpc.group/trpc-go/trpc-agent-go/internal/session/summary"
 	"trpc.group/trpc-go/trpc-agent-go/log"
 	"trpc.group/trpc-go/trpc-agent-go/session"
-	isession "trpc.group/trpc-go/trpc-agent-go/session/internal/session"
 )
 
 // CreateSessionSummary is the internal implementation that returns the summary.
@@ -41,7 +41,7 @@ func (s *Service) CreateSessionSummary(
 		return fmt.Errorf("check session key failed: %w", err)
 	}
 
-	updated, err := isession.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
+	updated, err := summary.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
 	if err != nil {
 		return fmt.Errorf("summarize and persist failed: %w", err)
 	}

session/redis/summary.go

@@ -16,9 +16,9 @@ import (
 	"fmt"
 
 	"github.com/redis/go-redis/v9"
+	"trpc.group/trpc-go/trpc-agent-go/internal/session/summary"
 	"trpc.group/trpc-go/trpc-agent-go/log"
 	"trpc.group/trpc-go/trpc-agent-go/session"
-	isession "trpc.group/trpc-go/trpc-agent-go/session/internal/session"
 )
 
 // luaSummariesSetIfNewer atomically merges one filterKey summary into the stored
@@ -66,7 +66,7 @@ func (s *Service) CreateSessionSummary(ctx context.Context, sess *session.Sessio
 		return fmt.Errorf("check session key failed: %w", err)
 	}
 
-	updated, err := isession.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
+	updated, err := summary.SummarizeSession(ctx, s.opts.summarizer, sess, filterKey, force)
 	if err != nil {
 		return fmt.Errorf("summarize and persist failed: %w", err)
 	}