service

package
v0.10.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = errors.New("not found")

ErrNotFound indicates the requested resource was not found.

Functions

This section is empty.

Types

type AdminService added in v0.10.3 

type AdminService struct {
	// contains filtered or unexported fields
}

AdminService contains business logic for admin operations.

func NewAdminService added in v0.10.3 

func NewAdminService(db *gorm.DB, rbacProvider rbac.Provider) *AdminService

NewAdminService creates a new AdminService.

func (*AdminService) CreateUser added in v0.10.3 

func (s *AdminService) CreateUser(req CreateUserRequest, adminUserID uuid.UUID) (*models.User, error)

CreateUser creates a new user, optionally granting admin, and writes an audit log.

func (*AdminService) DeleteUser added in v0.10.3 

func (s *AdminService) DeleteUser(userID uuid.UUID, adminUserID uuid.UUID) error

DeleteUser deletes a user and writes an audit log. Cannot delete self.

func (*AdminService) GetDashboardStats added in v0.10.3 

func (s *AdminService) GetDashboardStats() (*DashboardStats, error)

GetDashboardStats returns admin dashboard statistics.

func (*AdminService) GetUser added in v0.10.3 

func (s *AdminService) GetUser(userID uuid.UUID) (*UserWithAdmin, error)

GetUser returns a user by ID with admin status.

func (*AdminService) GrantPermission added in v0.10.3 

func (s *AdminService) GrantPermission(userID, workspaceID uuid.UUID, roleID uint, adminUserID uuid.UUID) (*models.Permission, error)

GrantPermission creates a permission record and grants RBAC access.

func (*AdminService) ListAuditLogs added in v0.10.3 

func (s *AdminService) ListAuditLogs(userIDFilter, actionFilter string) ([]models.AuditLog, error)

ListAuditLogs returns audit logs with optional filters.

func (*AdminService) ListPermissions added in v0.10.3 

func (s *AdminService) ListPermissions() ([]models.Permission, error)

ListPermissions returns all permissions with preloaded relations.

func (*AdminService) ListRoles added in v0.10.3 

func (s *AdminService) ListRoles() ([]models.Role, error)

ListRoles returns all roles.

func (*AdminService) ListUsers added in v0.10.3 

func (s *AdminService) ListUsers() ([]UserWithAdmin, error)

ListUsers returns all users with their admin status.

func (*AdminService) RevokePermission added in v0.10.3 

func (s *AdminService) RevokePermission(permissionID string, adminUserID uuid.UUID) error

RevokePermission revokes a permission by ID and removes RBAC access.

func (*AdminService) ToggleAdmin added in v0.10.3 

func (s *AdminService) ToggleAdmin(userID uuid.UUID, adminUserID uuid.UUID) (*UserWithAdmin, error)

ToggleAdmin toggles admin status for a user and writes an audit log.

type CollaboratorResult added in v0.10.3 

type CollaboratorResult struct {
	UserID   uuid.UUID `json:"user_id"`
	Username string    `json:"username"`
	Email    string    `json:"email,omitempty"`
	Role     string    `json:"role"`
	IsOwner  bool      `json:"is_owner"`
}

CollaboratorResult is the result type for ListCollaborators.

type ConflictError 

type ConflictError struct {
	Message string
}

ConflictError represents a conflict condition (HTTP 409).

func (*ConflictError) Error 

func (e *ConflictError) Error() string

type CreateRegistryReq added in v0.10.3 

type CreateRegistryReq struct {
	Name      string
	URL       string
	Username  string
	Password  string
	APIToken  string
	IsDefault bool
	Namespace string
	CreatedBy uuid.UUID
}

CreateRegistryRequest holds parameters for creating a registry.

type CreateRequest 

type CreateRequest struct {
	Name           string
	PackageManager string
	PixiToml       string
	Source         string
	Path           string
}

CreateRequest holds parameters for creating a workspace.

type CreateUserRequest added in v0.10.3 

type CreateUserRequest struct {
	Username string
	Email    string
	Password string
	IsAdmin  bool
}

CreateUserRequest holds parameters for creating a user.

type DashboardStats added in v0.10.3 

type DashboardStats struct {
	TotalDiskUsageBytes     int64  `json:"total_disk_usage_bytes"`
	TotalDiskUsageFormatted string `json:"total_disk_usage_formatted"`
}

DashboardStats holds admin dashboard statistics.

type ForbiddenError added in v0.10.3 

type ForbiddenError struct {
	Message string
}

ForbiddenError represents a forbidden condition (HTTP 403).

func (*ForbiddenError) Error added in v0.10.3 

func (e *ForbiddenError) Error() string

type JobService added in v0.10.3 

type JobService struct {
	// contains filtered or unexported fields
}

JobService contains business logic for job operations.

func NewJobService added in v0.10.3 

func NewJobService(db *gorm.DB) *JobService

NewJobService creates a new JobService.

func (*JobService) FlushLogs added in v0.10.3 

func (s *JobService) FlushLogs(jobID uuid.UUID, logs string) error

FlushLogs persists the current log content for a job.

func (*JobService) GetJob added in v0.10.3 

func (s *JobService) GetJob(jobID string, userID uuid.UUID) (*models.Job, error)

GetJob returns a single job by ID, verifying the user owns the workspace.

func (*JobService) GetJobForStreaming added in v0.10.3 

func (s *JobService) GetJobForStreaming(jobID uuid.UUID, userID uuid.UUID) (*models.Job, error)

GetJobForStreaming returns a job by ID with ownership check, for SSE streaming. Returns the job regardless of status (caller decides what to do with completed jobs).

func (*JobService) ListJobs added in v0.10.3 

func (s *JobService) ListJobs(userID uuid.UUID) ([]models.Job, error)

ListJobs returns all jobs for workspaces owned by the given user.

func (*JobService) LoadVersion added in v0.10.3 

func (s *JobService) LoadVersion(versionID uuid.UUID) (*models.WorkspaceVersion, error)

LoadVersion loads a workspace version by ID.

func (*JobService) LoadWorkspace added in v0.10.3 

func (s *JobService) LoadWorkspace(workspaceID uuid.UUID) (*models.Workspace, error)

LoadWorkspace loads a workspace by ID.

func (*JobService) MarkCompleted added in v0.10.3 

func (s *JobService) MarkCompleted(job *models.Job, logs string)

MarkCompleted sets a job's status to completed with final logs.

func (*JobService) MarkFailed added in v0.10.3 

func (s *JobService) MarkFailed(job *models.Job, logs string, errMsg string)

MarkFailed sets a job's status to failed with error and final logs.

func (*JobService) MarkPanicked added in v0.10.3 

func (s *JobService) MarkPanicked(job *models.Job, panicMsg string)

MarkPanicked sets a job as failed after a panic recovery.

func (*JobService) MarkRunning added in v0.10.3 

func (s *JobService) MarkRunning(job *models.Job)

MarkRunning sets a job's status to running with a start timestamp.

type PublicationResult added in v0.10.3 

type PublicationResult struct {
	ID                uuid.UUID `json:"id"`
	VersionNumber     int       `json:"version_number"`
	RegistryName      string    `json:"registry_name"`
	RegistryURL       string    `json:"registry_url"`
	RegistryNamespace string    `json:"registry_namespace"`
	Repository        string    `json:"repository"`
	Tag               string    `json:"tag"`
	Digest            string    `json:"digest"`
	IsPublic          bool      `json:"is_public"`
	PublishedBy       string    `json:"published_by"`
	PublishedAt       string    `json:"published_at"`
}

PublicationResult is the denormalized publication info ready for JSON.

type PublishDefaultsResult added in v0.10.3 

type PublishDefaultsResult struct {
	RegistryID   uuid.UUID `json:"registry_id"`
	RegistryName string    `json:"registry_name"`
	Namespace    string    `json:"namespace"`
	Repository   string    `json:"repository"`
	Tag          string    `json:"tag"`
}

PublishDefaultsResult holds precomputed defaults for the publish dialog.

type PublishWorkspaceRequest added in v0.10.3 

type PublishWorkspaceRequest struct {
	RegistryID uuid.UUID
	Repository string
	Tag        string
}

PublishWorkspaceRequest holds parameters for publishing to an OCI registry.

type PushRequest 

type PushRequest struct {
	Tag      string
	PixiToml string
	PixiLock string
	Force    bool
}

PushRequest holds parameters for pushing a new version.

type PushResult 

type PushResult struct {
	VersionNumber int
	Tags          []string
	ContentHash   string
	Deduplicated  bool
	Tag           string // kept for backwards compatibility
}

PushResult is returned after a successful push.

type RegistryResult added in v0.10.3 

type RegistryResult struct {
	ID          uuid.UUID `json:"id"`
	Name        string    `json:"name"`
	URL         string    `json:"url"`
	Username    string    `json:"username"`
	HasAPIToken bool      `json:"has_api_token"`
	IsDefault   bool      `json:"is_default"`
	Namespace   string    `json:"namespace"`
	CreatedAt   string    `json:"created_at"`
}

RegistryResult is the response type for registry operations.

type RegistryService added in v0.10.3 

type RegistryService struct {
	// contains filtered or unexported fields
}

RegistryService contains business logic for OCI registry operations.

func NewRegistryService added in v0.10.3 

func NewRegistryService(db *gorm.DB, encKey []byte) *RegistryService

NewRegistryService creates a new RegistryService.

func (*RegistryService) CreateRegistry added in v0.10.3 

func (s *RegistryService) CreateRegistry(req CreateRegistryReq) (*RegistryResult, error)

CreateRegistry creates a new registry with encrypted credentials.

func (*RegistryService) DeleteRegistry added in v0.10.3 

func (s *RegistryService) DeleteRegistry(id string) error

DeleteRegistry deletes a registry by ID.

func (*RegistryService) FallbackRepositories added in v0.10.3 

func (s *RegistryService) FallbackRepositories(registryID string) []string

FallbackRepositories returns distinct repository names from publication records for a registry.

func (*RegistryService) GetRegistry added in v0.10.3 

func (s *RegistryService) GetRegistry(id string) (*RegistryResult, error)

GetRegistry returns a single registry by ID with admin-level detail.

func (*RegistryService) GetRegistryWithCredentials added in v0.10.3 

func (s *RegistryService) GetRegistryWithCredentials(id string) (*RegistryWithCredentials, error)

GetRegistryWithCredentials returns a registry with decrypted credentials for OCI operations.

func (*RegistryService) ListPublicRegistries added in v0.10.3 

func (s *RegistryService) ListPublicRegistries() ([]RegistryResult, error)

ListPublicRegistries returns registries with public-safe info (no credentials).

func (*RegistryService) ListRegistries added in v0.10.3 

func (s *RegistryService) ListRegistries() ([]RegistryResult, error)

ListRegistries returns all registries with admin-level detail (includes username, token status).

func (*RegistryService) UpdateRegistry added in v0.10.3 

func (s *RegistryService) UpdateRegistry(id string, req UpdateRegistryReq) (*RegistryResult, error)

UpdateRegistry updates an existing registry.

type RegistryWithCredentials added in v0.10.3 

type RegistryWithCredentials struct {
	Registry models.OCIRegistry
	Password string
	APIToken string
}

RegistryWithCredentials holds a registry and its decrypted credentials for OCI operations.

type UpdateRegistryReq added in v0.10.3 

type UpdateRegistryReq struct {
	Name      *string
	URL       *string
	Username  *string
	Password  *string
	APIToken  *string
	IsDefault *bool
	Namespace *string
}

UpdateRegistryReq holds parameters for updating a registry.

type UserWithAdmin added in v0.10.3 

type UserWithAdmin struct {
	models.User
	IsAdmin bool `json:"is_admin"`
}

UserWithAdmin wraps a user with their admin status.

type ValidationError 

type ValidationError struct {
	Message string
}

ValidationError represents a bad-request condition (HTTP 400).

func (*ValidationError) Error 

func (e *ValidationError) Error() string

type WorkspaceResponse added in v0.10.3 

type WorkspaceResponse struct {
	models.Workspace
	SizeFormatted string `json:"size_formatted"`
}

WorkspaceResponse wraps a workspace with computed fields.

func NewWorkspaceResponse added in v0.10.3 

func NewWorkspaceResponse(ws models.Workspace) WorkspaceResponse

NewWorkspaceResponse creates a WorkspaceResponse with formatted size.

type WorkspaceService 

type WorkspaceService struct {
	// contains filtered or unexported fields
}

WorkspaceService contains the business logic for workspace operations.

func New 

func New(db *gorm.DB, q queue.Queue, exec executor.Executor, isLocal bool, encKey []byte, rbacProvider rbac.Provider) *WorkspaceService

New creates a new WorkspaceService.

func (*WorkspaceService) Create 

func (s *WorkspaceService) Create(ctx context.Context, req CreateRequest, userID uuid.UUID) (*models.Workspace, error)

Create validates and creates a new workspace, queues the creation job, grants RBAC owner access, and writes an audit log entry.

func (*WorkspaceService) CreateVersionSnapshot added in v0.10.3 

func (s *WorkspaceService) CreateVersionSnapshot(ctx context.Context, ws *models.Workspace, jobID uuid.UUID, userID uuid.UUID, description string) error

CreateVersionSnapshot creates a version snapshot after a successful operation. Called by the worker after install, remove, create, and rollback operations.

func (*WorkspaceService) Delete 

func (s *WorkspaceService) Delete(ctx context.Context, wsID string, userID uuid.UUID) error

Delete queues a deletion job for the workspace and writes an audit log.

func (*WorkspaceService) DeleteAllPackages added in v0.10.3 

func (s *WorkspaceService) DeleteAllPackages(wsID uuid.UUID)

DeleteAllPackages removes all packages for a workspace from the DB.

func (*WorkspaceService) DeletePackagesByName added in v0.10.3 

func (s *WorkspaceService) DeletePackagesByName(wsID uuid.UUID, packages []string)

DeletePackagesByName removes specific packages from the DB.

func (*WorkspaceService) Get 

func (s *WorkspaceService) Get(id string) (*WorkspaceResponse, error)

Get returns a single workspace by ID.

func (*WorkspaceService) GetPixiToml 

func (s *WorkspaceService) GetPixiToml(wsID string) (string, error)

GetPixiToml reads the pixi.toml content from the workspace's filesystem.

func (*WorkspaceService) GetPublishDefaults added in v0.10.3 

func (s *WorkspaceService) GetPublishDefaults(wsID string) (*PublishDefaultsResult, error)

GetPublishDefaults returns default values for the publish dialog.

func (*WorkspaceService) GetVersion 

func (s *WorkspaceService) GetVersion(wsID string, versionNum string) (*models.WorkspaceVersion, error)

GetVersion returns a specific version by workspace ID and version number.

func (*WorkspaceService) GetVersionFile 

func (s *WorkspaceService) GetVersionFile(wsID string, versionNum string, field string) (string, error)

GetVersionFile returns the content of a specific file field from a version. field must be "lock" or "manifest".

func (*WorkspaceService) GetWorkspacePath added in v0.10.3 

func (s *WorkspaceService) GetWorkspacePath(ws *models.Workspace) string

GetWorkspacePath returns the filesystem path for a workspace.

func (*WorkspaceService) InstallPackages added in v0.10.3 

func (s *WorkspaceService) InstallPackages(ctx context.Context, wsID string, packages []string, userID uuid.UUID) (*models.Job, error)

InstallPackages creates and enqueues an install-packages job.

func (*WorkspaceService) List 

func (s *WorkspaceService) List(userID uuid.UUID) ([]WorkspaceResponse, error)

List returns workspaces visible to the given user. In local mode all workspaces are returned (no ownership filtering).

func (*WorkspaceService) ListCollaborators added in v0.10.3 

func (s *WorkspaceService) ListCollaborators(wsID string) ([]CollaboratorResult, error)

ListCollaborators returns all users with access to a workspace (owner + shared users).

func (*WorkspaceService) ListPackages added in v0.10.3 

func (s *WorkspaceService) ListPackages(wsID string) ([]models.Package, error)

ListPackages returns packages for a workspace, auto-syncing from disk for local workspaces with no DB records.

func (*WorkspaceService) ListPublications added in v0.10.3 

func (s *WorkspaceService) ListPublications(wsID string) ([]PublicationResult, error)

ListPublications returns all publications for a workspace.

func (*WorkspaceService) ListTags 

func (s *WorkspaceService) ListTags(wsID string) ([]models.WorkspaceTag, error)

ListTags returns tags for a workspace, ordered by creation time descending.

func (*WorkspaceService) ListVersions 

func (s *WorkspaceService) ListVersions(wsID string) ([]models.WorkspaceVersion, error)

ListVersions returns versions for a workspace (excluding large file contents).

func (*WorkspaceService) PublishWorkspace added in v0.10.3 

func (s *WorkspaceService) PublishWorkspace(ctx context.Context, wsID string, req PublishWorkspaceRequest, userID uuid.UUID) (*PublicationResult, error)

PublishWorkspace publishes a workspace's pixi.toml and pixi.lock to an OCI registry.

func (*WorkspaceService) PushVersion 

func (s *WorkspaceService) PushVersion(ctx context.Context, wsID string, req PushRequest, userID uuid.UUID) (*PushResult, error)

PushVersion creates a new workspace version (or deduplicates), writes files, handles tags (content hash, latest, optional user tag), and records audit logs.

func (*WorkspaceService) RemovePackage added in v0.10.3 

func (s *WorkspaceService) RemovePackage(ctx context.Context, wsID string, packageName string, userID uuid.UUID) (*models.Job, error)

RemovePackage creates and enqueues a remove-package job.

func (*WorkspaceService) RollbackToVersion added in v0.10.3 

func (s *WorkspaceService) RollbackToVersion(ctx context.Context, wsID string, versionNumber int, userID uuid.UUID) (*models.Job, error)

RollbackToVersion creates and enqueues a rollback job.

func (*WorkspaceService) SaveInstalledPackages added in v0.10.3 

func (s *WorkspaceService) SaveInstalledPackages(wsID uuid.UUID, packages []string)

SaveInstalledPackages records newly installed packages in the DB.

func (*WorkspaceService) SavePixiToml 

func (s *WorkspaceService) SavePixiToml(wsID string, content string) error

SavePixiToml writes pixi.toml content to the workspace's filesystem.

func (*WorkspaceService) SetWorkspacePath added in v0.10.3 

func (s *WorkspaceService) SetWorkspacePath(wsID uuid.UUID, path string) error

SetWorkspacePath updates the workspace path in the database.

func (*WorkspaceService) SetWorkspaceStatus added in v0.10.3 

func (s *WorkspaceService) SetWorkspaceStatus(wsID uuid.UUID, status models.WorkspaceStatus) error

SetWorkspaceStatus updates the workspace status in the database.

func (*WorkspaceService) ShareWorkspace added in v0.10.3 

func (s *WorkspaceService) ShareWorkspace(wsID string, ownerID uuid.UUID, targetUserID uuid.UUID, role string) (*models.Permission, error)

ShareWorkspace grants a user access to a workspace. Only the owner can share.

func (*WorkspaceService) SoftDeleteWorkspace added in v0.10.3 

func (s *WorkspaceService) SoftDeleteWorkspace(wsID uuid.UUID) error

SoftDeleteWorkspace soft-deletes a workspace.

func (*WorkspaceService) SyncPackagesFromWorkspace added in v0.10.3 

func (s *WorkspaceService) SyncPackagesFromWorkspace(ctx context.Context, ws *models.Workspace) error

SyncPackagesFromWorkspace lists packages from the workspace on disk and saves them to the DB. Called by the worker after install/remove/create/rollback operations.

func (*WorkspaceService) UnshareWorkspace added in v0.10.3 

func (s *WorkspaceService) UnshareWorkspace(wsID string, ownerID uuid.UUID, targetUserID uuid.UUID) error

UnshareWorkspace revokes a user's access to a workspace. Only the owner can unshare.

func (*WorkspaceService) UpdatePublication added in v0.10.3 

func (s *WorkspaceService) UpdatePublication(ctx context.Context, wsID string, pubID string, isPublic bool) (*PublicationResult, error)

UpdatePublication updates a publication's visibility.

func (*WorkspaceService) UpdateWorkspaceSize added in v0.10.3 

func (s *WorkspaceService) UpdateWorkspaceSize(ws *models.Workspace)

UpdateWorkspaceSize calculates and updates the workspace size in the database.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.