repository

README

Repository Layer

This package implements the data access layer using SQLite.

Responsibilities

• Define repository interfaces for data access
• Implement SQLite repository implementations
• Manage database schema and migrations
• Handle transactions and concurrent access
• Store installation records, cache, audit logs, and tool index
• Implement query filters and pagination

Key Components

• repository.go - Repository interface definitions
• installation.go - Installation repository implementation
• cache.go - Cache repository implementation
• audit.go - Audit log repository implementation
• index.go - Tool index repository implementation
• transaction.go - Transaction manager implementation
• schema.go - Database schema definitions
• migration.go - Database migration system

Usage

import "github.com/snowdreamtech/unirtm/internal/repository"

// Open database
db, err := repository.Open("unirtm.db")
if err != nil {
    log.Fatal(err)
}
defer db.Close()

// Use repositories
installRepo := repository.NewInstallationRepository(db)
installations, err := installRepo.List(ctx)
if err != nil {
    log.Fatal(err)
}

Requirements

Implements requirements: 2.1-2.9

Documentation

Index

• Variables
• type AuditEntry
• type AuditFilter
• type AuditRepository
• type CacheEntry
• type CacheRepository
• type IndexEntry
• type IndexRepository
• type Installation
• type InstallationRepository

Variables

var (
	// ErrNotFound indicates a resource was not found
	ErrNotFound = errors.New("not found")

	// ErrAlreadyExists indicates a resource already exists
	ErrAlreadyExists = errors.New("already exists")
)

Common repository errors

Types

type AuditEntry

type AuditEntry struct {
	ID              int64     `db:"id"`
	Timestamp       time.Time `db:"timestamp"`
	Operation       string    `db:"operation"` // install, uninstall, activate, etc.
	Tool            string    `db:"tool"`
	Version         string    `db:"version"`
	Status          string    `db:"status"` // success, failure
	Error           string    `db:"error"`
	Duration        int64     `db:"duration_ms"`
	GpgVerification string    `db:"gpg_verification"`
	Metadata        string    `db:"metadata"` // JSON-encoded metadata
}

AuditEntry represents an audit log entry

type AuditFilter

type AuditFilter struct {
	// StartTime filters audit entries after this time (inclusive)
	StartTime *time.Time
	// EndTime filters audit entries before this time (inclusive)
	EndTime *time.Time
	// Operation filters by operation type (install, uninstall, activate, etc.)
	Operation string
	// Tool filters by tool name
	Tool string
	// Status filters by status (success, failure)
	Status string
	// Limit limits the number of results returned (0 = no limit)
	Limit int
	// Offset skips the first N results (for pagination)
	Offset int
}

AuditFilter defines filters for querying audit logs

type AuditRepository

type AuditRepository interface {
	// Log records an audit log entry
	Log(ctx context.Context, entry *AuditEntry) error

	// Query queries audit logs with filters
	Query(ctx context.Context, filter AuditFilter) ([]*AuditEntry, error)
}

AuditRepository manages audit log entries with query filters Validates Requirements: 2.5 (Store audit logs)

type CacheEntry

type CacheEntry struct {
	Key       string    `db:"key"`
	Value     []byte    `db:"value"`
	ExpiresAt time.Time `db:"expires_at"`
	CreatedAt time.Time `db:"created_at"`
}

CacheEntry represents a cached item

type CacheRepository

type CacheRepository interface {
	// Set stores a cache entry with the specified TTL
	Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

	// Get retrieves a cache entry
	// Returns nil if the key does not exist or has expired
	Get(ctx context.Context, key string) ([]byte, error)

	// Delete removes a cache entry
	Delete(ctx context.Context, key string) error

	// Purge removes all expired cache entries
	Purge(ctx context.Context) error
}

CacheRepository manages cache entries with TTL support Validates Requirements: 2.2 (Store installation cache data)

type IndexEntry

type IndexEntry struct {
	Tool        string    `db:"tool"`
	Description string    `db:"description"`
	Homepage    string    `db:"homepage"`
	License     string    `db:"license"`
	Backend     string    `db:"backend"`
	UpdatedAt   time.Time `db:"updated_at"`
	Metadata    string    `db:"metadata"` // JSON-encoded metadata
}

IndexEntry represents a tool in the index

type IndexRepository

type IndexRepository interface {
	// Upsert creates or updates a tool index entry
	Upsert(ctx context.Context, entry *IndexEntry) error

	// FindByTool finds a tool index entry by tool name
	FindByTool(ctx context.Context, tool string) (*IndexEntry, error)

	// List lists all tool index entries
	List(ctx context.Context) ([]*IndexEntry, error)

	// Search searches tool index by name, description, or tags
	// The query string is matched against tool name, description, and metadata
	Search(ctx context.Context, query string) ([]*IndexEntry, error)

	// Delete removes a tool index entry
	Delete(ctx context.Context, tool string) error
}

IndexRepository manages tool index entries for tool metadata Validates Requirements: 2.4 (Store tool indexes)

type Installation

type Installation struct {
	ID          int64     `db:"id"`
	Tool        string    `db:"tool"`
	Version     string    `db:"version"`
	Backend     string    `db:"backend"`
	Provider    string    `db:"provider"`
	InstallPath string    `db:"install_path"`
	Checksum    string    `db:"checksum"`
	InstalledAt time.Time `db:"installed_at"`
	Metadata    string    `db:"metadata"` // JSON-encoded metadata
}

Installation represents an installed tool

type InstallationRepository

type InstallationRepository interface {
	// Create records a new installation
	Create(ctx context.Context, installation *Installation) error

	// Upsert creates or updates an installation record
	Upsert(ctx context.Context, installation *Installation) error

	// FindByToolAndVersion finds an installation by tool and version
	FindByToolAndVersion(ctx context.Context, tool string, version string) (*Installation, error)

	// List lists all installations
	List(ctx context.Context) ([]*Installation, error)

	// Delete removes an installation record
	Delete(ctx context.Context, tool string, version string) error
}

InstallationRepository manages installation records in the database Validates Requirements: 2.2 (Store installation cache data)