infrastructure

Documentation

Index

• Variables
• func FindRepoRootFrom(cwd ports.CWD) (string, error)
• func IdentitiesStore(ctx context.Context, sources ...identityStoreSource) (ports.IdentitiesStore, error)
• func NewGitRepositoryFromPath(from ports.CWD) (*GitRepository, *ReadWriteDirFS, error)
• type AgentIdentitiesStore
  • func (a AgentIdentitiesStore) Generate(ctx context.Context, cmd dto.GenerateIdentityCommand) (publicKey string, err error)
  • func (a AgentIdentitiesStore) Identities(ctx context.Context, query dto.IdentitiesQuery) ([]age.Identity, error)
• type AgentIdentitiesStoreSource
  • func NewAgentIdentitiesStoreSource() *AgentIdentitiesStoreSource
  • func (a *AgentIdentitiesStoreSource) GetStore() (ports.IdentitiesStore, error)
  • func (a *AgentIdentitiesStoreSource) IsValid(ctx context.Context) (bool, error)
• type FileIdentityStore
  • func (f *FileIdentityStore) Generate(_ context.Context, cmd dto.GenerateIdentityCommand) (publicKey string, err error)
  • func (f *FileIdentityStore) Identities(context.Context, dto.IdentitiesQuery) ([]age.Identity, error)
• type FileIdentityStoreSource
  • func NewFileIdentityStoreSource(url *url.URL) *FileIdentityStoreSource
  • func (f *FileIdentityStoreSource) GetStore() (ports.IdentitiesStore, error)
  • func (f *FileIdentityStoreSource) IsValid(context.Context) (bool, error)
• type GitRepository
  • func NewGitRepository(repoFS fs.FS, repository *git.Repository) (*GitRepository, error)
  • func (g GitRepository) Commit(message string) error
  • func (g GitRepository) IsStagingDirty() (bool, error)
  • func (g GitRepository) OpenObjectAtHead(filePath string) (*object.File, error)
  • func (g GitRepository) Remotes() ([]string, error)
  • func (g GitRepository) StageFile(path string) error
  • func (g GitRepository) WalkAgeFiles(onMatch fs.WalkDirFunc) error
• type ReadWriteDirFS
  • func NewReadWriteDirFS(rootPath string) *ReadWriteDirFS
  • func (f ReadWriteDirFS) Create(filePath string, opts ...ports.OpenRWOptions) (ports.ReadWriteFile, error)
  • func (f ReadWriteDirFS) Mkdir(dir string, all bool, mode os.FileMode) error
  • func (f ReadWriteDirFS) Open(name string) (fs.File, error)
  • func (f ReadWriteDirFS) ReadDir(name string) ([]fs.DirEntry, error)
  • func (f ReadWriteDirFS) Remove(filePath string) error
  • func (f ReadWriteDirFS) Rename(oldPath, newPath string) error
  • func (f ReadWriteDirFS) TempFile(dir, pattern string) (ports.ReadWriteFile, error)
• type RecipientsFile
  • func NewRecipientsFile(fs ports.ReadWriteFS) *RecipientsFile
  • func (r RecipientsFile) All() ([]age.Recipient, error)
  • func (r RecipientsFile) Append(pubKey string, comment string) (recipients []age.Recipient, err error)

Variables

var ErrRepoNotFound = errors.New("could not find git repository")

Functions

func FindRepoRootFrom

func FindRepoRootFrom(cwd ports.CWD) (string, error)

func IdentitiesStore

func IdentitiesStore(ctx context.Context, sources ...identityStoreSource) (ports.IdentitiesStore, error)

func NewGitRepositoryFromPath

func NewGitRepositoryFromPath(from ports.CWD) (*GitRepository, *ReadWriteDirFS, error)

Types

type AgentIdentitiesStore

type AgentIdentitiesStore struct {
	IdentitiesClient agentv1connect.IdentitiesStoreServiceClient
}

func (AgentIdentitiesStore) Generate

func (a AgentIdentitiesStore) Generate(
	ctx context.Context,
	cmd dto.GenerateIdentityCommand,
) (publicKey string, err error)

func (AgentIdentitiesStore) Identities

func (a AgentIdentitiesStore) Identities(ctx context.Context, query dto.IdentitiesQuery) ([]age.Identity, error)

type AgentIdentitiesStoreSource

type AgentIdentitiesStoreSource struct {
	BaseUrl string
	Client  connect.HTTPClient
}

func NewAgentIdentitiesStoreSource

func NewAgentIdentitiesStoreSource() *AgentIdentitiesStoreSource

func (*AgentIdentitiesStoreSource) GetStore

func (a *AgentIdentitiesStoreSource) GetStore() (ports.IdentitiesStore, error)

func (*AgentIdentitiesStoreSource) IsValid

func (a *AgentIdentitiesStoreSource) IsValid(ctx context.Context) (bool, error)

type FileIdentityStore

type FileIdentityStore url.URL

func (*FileIdentityStore) Generate

func (f *FileIdentityStore) Generate(_ context.Context, cmd dto.GenerateIdentityCommand) (publicKey string, err error)

func (*FileIdentityStore) Identities

func (f *FileIdentityStore) Identities(context.Context, dto.IdentitiesQuery) ([]age.Identity, error)

type FileIdentityStoreSource

type FileIdentityStoreSource url.URL

func NewFileIdentityStoreSource

func NewFileIdentityStoreSource(url *url.URL) *FileIdentityStoreSource

func (*FileIdentityStoreSource) GetStore

func (f *FileIdentityStoreSource) GetStore() (ports.IdentitiesStore, error)

func (*FileIdentityStoreSource) IsValid

func (f *FileIdentityStoreSource) IsValid(context.Context) (bool, error)

type GitRepository

type GitRepository struct {
	RepoFS     fs.FS
	Repository *git.Repository
	Worktree   *git.Worktree
}

func NewGitRepository

func NewGitRepository(repoFS fs.FS, repository *git.Repository) (*GitRepository, error)

func (GitRepository) Commit

func (g GitRepository) Commit(message string) error

func (GitRepository) IsStagingDirty

func (g GitRepository) IsStagingDirty() (bool, error)

func (GitRepository) OpenObjectAtHead

func (g GitRepository) OpenObjectAtHead(filePath string) (*object.File, error)

func (GitRepository) Remotes

func (g GitRepository) Remotes() ([]string, error)

func (GitRepository) StageFile

func (g GitRepository) StageFile(path string) error

func (GitRepository) WalkAgeFiles

func (g GitRepository) WalkAgeFiles(onMatch fs.WalkDirFunc) error

type ReadWriteDirFS

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

func NewReadWriteDirFS

func NewReadWriteDirFS(rootPath string) *ReadWriteDirFS

func (ReadWriteDirFS) Create

func (f ReadWriteDirFS) Create(filePath string, opts ...ports.OpenRWOptions) (ports.ReadWriteFile, error)

func (ReadWriteDirFS) Mkdir

func (f ReadWriteDirFS) Mkdir(dir string, all bool, mode os.FileMode) error

func (ReadWriteDirFS) Open

func (f ReadWriteDirFS) Open(name string) (fs.File, error)

func (ReadWriteDirFS) ReadDir

func (f ReadWriteDirFS) ReadDir(name string) ([]fs.DirEntry, error)

func (ReadWriteDirFS) Remove

func (f ReadWriteDirFS) Remove(filePath string) error

func (ReadWriteDirFS) Rename

func (f ReadWriteDirFS) Rename(oldPath, newPath string) error

func (ReadWriteDirFS) TempFile

func (f ReadWriteDirFS) TempFile(dir, pattern string) (ports.ReadWriteFile, error)

type RecipientsFile

type RecipientsFile struct {
	FS ports.ReadWriteFS
}

func NewRecipientsFile

func NewRecipientsFile(fs ports.ReadWriteFS) *RecipientsFile

func (RecipientsFile) All

func (r RecipientsFile) All() ([]age.Recipient, error)

func (RecipientsFile) Append

func (r RecipientsFile) Append(pubKey string, comment string) (recipients []age.Recipient, err error)