rdev/internal/adapter/templates/provider.go
jordan 39df51defd feat: Add multi-provider code agent interface with Claude Code and OpenCode adapters
Implements weeks 1-4 of the multi-provider architecture:

Week 1 - Foundation:
- Add domain models (AgentProvider, AgentRequest, AgentEvent, AgentResult)
- Define CodeAgent port interface with Execute, Cancel, Capabilities
- Create thread-safe provider registry with first-registered default

Week 2 - Claude Code Adapter:
- Extract kubectl exec logic into CodeAgent implementation
- Parse stream-json output format (init, message, tool_use, result)
- Support session continuation via --resume flag

Week 3 - OpenCode Adapter:
- HTTP/SSE client for opencode serve API
- Session management (create, send message, abort)
- Event streaming with documented buffer rationale

Week 4 - Quality & Polish:
- Fix race condition in OpenCode Cancel method
- Add AgentRequest.Validate() with ErrPromptRequired, ErrInvalidTimeout
- Document DefaultAvailabilityTimeout constants
- Add HTTP error context for debugging

Also includes:
- Work queue system with PostgreSQL adapter
- Credential store for infrastructure secrets
- Project templates with Woodpecker CI integration
- Comprehensive test coverage

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-27 09:25:51 -07:00

231 lines
6.1 KiB
Go

// Package templates provides embedded project templates for seeding new repos.
//
// Templates are embedded at compile time from the templates/ subdirectory.
// Each template contains starter files with {{VAR}} placeholders that get
// interpolated when seeding a repository.
package templates
import (
"context"
"embed"
"encoding/base64"
"fmt"
"io/fs"
"log/slog"
"path/filepath"
"regexp"
"strings"
"code.gitea.io/sdk/gitea"
"github.com/orchard9/rdev/internal/domain"
"github.com/orchard9/rdev/internal/port"
)
//go:embed all:templates
var templatesFS embed.FS
// availableTemplates lists all supported project templates.
var availableTemplates = []port.TemplateInfo{
{Name: "default", Description: "Basic project with Dockerfile", Stack: "generic"},
{Name: "astro-landing", Description: "Astro landing page with Tailwind", Stack: "astro"},
{Name: "go-api", Description: "Go REST API with chi router", Stack: "go"},
}
// templateNameRegex validates template names (alphanumeric, dash only).
var templateNameRegex = regexp.MustCompile(`^[a-z][a-z0-9-]*$`)
// Provider implements port.TemplateProvider using embedded templates
// and the Gitea API to seed repositories.
type Provider struct {
giteaClient *gitea.Client
logger *slog.Logger
}
// Ensure Provider implements TemplateProvider.
var _ port.TemplateProvider = (*Provider)(nil)
// NewProvider creates a new template provider.
// giteaClient is used to create files in repositories.
// logger is optional; if nil, slog.Default() is used.
func NewProvider(giteaClient *gitea.Client, logger *slog.Logger) *Provider {
if logger == nil {
logger = slog.Default()
}
return &Provider{
giteaClient: giteaClient,
logger: logger,
}
}
// SeedRepo populates a repository with template files.
func (p *Provider) SeedRepo(ctx context.Context, owner, repo, templateName string, vars map[string]string) error {
// Check for context cancellation
select {
case <-ctx.Done():
return ctx.Err()
default:
}
// Validate template name (prevent path traversal, enforce naming convention)
if !isValidTemplateName(templateName) {
return fmt.Errorf("invalid template name: %s (must be lowercase alphanumeric with dashes)", templateName)
}
// Validate template exists
templateDir := "templates/" + templateName
if _, err := templatesFS.ReadDir(templateDir); err != nil {
return fmt.Errorf("template not found: %s", templateName)
}
p.logger.Info("seeding repo from template",
"owner", owner,
"repo", repo,
"template", templateName,
)
// Walk template directory and create files
var filesCreated int
err := fs.WalkDir(templatesFS, templateDir, func(path string, d fs.DirEntry, err error) error {
if err != nil {
return err
}
if d.IsDir() {
return nil
}
// Read file content
content, err := templatesFS.ReadFile(path)
if err != nil {
return fmt.Errorf("failed to read template file %s: %w", path, err)
}
// Interpolate variables
interpolated := interpolateVars(string(content), vars)
// Calculate relative path from template root
relPath, err := filepath.Rel(templateDir, path)
if err != nil {
return fmt.Errorf("failed to get relative path: %w", err)
}
// Strip .tmpl extension (allows embedding go.mod as go.mod.tmpl)
relPath = strings.TrimSuffix(relPath, ".tmpl")
// Create file in repo via Gitea API
// Gitea expects base64-encoded content
encodedContent := base64.StdEncoding.EncodeToString([]byte(interpolated))
_, _, err = p.giteaClient.CreateFile(owner, repo, relPath, gitea.CreateFileOptions{
Content: encodedContent,
FileOptions: gitea.FileOptions{
Message: "Add " + relPath + " from template",
BranchName: "main",
},
})
if err != nil {
return fmt.Errorf("failed to create file %s: %w", relPath, err)
}
filesCreated++
return nil
})
if err != nil {
return fmt.Errorf("failed to seed repo from template %s: %w", templateName, err)
}
p.logger.Info("repo seeded successfully",
"owner", owner,
"repo", repo,
"template", templateName,
"files_created", filesCreated,
)
return nil
}
// isValidTemplateName validates that a template name is safe.
func isValidTemplateName(name string) bool {
if name == "" || len(name) > 64 {
return false
}
return templateNameRegex.MatchString(name)
}
// ListTemplates returns available templates.
func (p *Provider) ListTemplates(ctx context.Context) ([]port.TemplateInfo, error) {
// Check for context cancellation
select {
case <-ctx.Done():
return nil, ctx.Err()
default:
}
result := make([]port.TemplateInfo, len(availableTemplates))
for i, t := range availableTemplates {
result[i] = t
// Populate files list
files, err := listTemplateFiles(t.Name)
if err == nil {
result[i].Files = files
}
}
return result, nil
}
// GetTemplate returns info about a specific template.
func (p *Provider) GetTemplate(ctx context.Context, name string) (*port.TemplateInfo, error) {
// Check for context cancellation
select {
case <-ctx.Done():
return nil, ctx.Err()
default:
}
for _, t := range availableTemplates {
if t.Name == name {
result := t
files, err := listTemplateFiles(name)
if err == nil {
result.Files = files
}
return &result, nil
}
}
return nil, fmt.Errorf("%w: %s", domain.ErrTemplateNotFound, name)
}
// interpolateVars replaces {{VAR_NAME}} placeholders with values.
func interpolateVars(content string, vars map[string]string) string {
result := content
for key, value := range vars {
placeholder := "{{" + key + "}}"
result = strings.ReplaceAll(result, placeholder, value)
}
return result
}
// listTemplateFiles returns the list of files in a template.
func listTemplateFiles(templateName string) ([]string, error) {
templateDir := "templates/" + templateName
var files []string
err := fs.WalkDir(templatesFS, templateDir, func(path string, d fs.DirEntry, err error) error {
if err != nil {
return err
}
if d.IsDir() {
return nil
}
relPath, err := filepath.Rel(templateDir, path)
if err != nil {
return err
}
// Strip .tmpl extension for display
relPath = strings.TrimSuffix(relPath, ".tmpl")
files = append(files, relPath)
return nil
})
return files, err
}