yay/pkg/db/ialpm/high_level.go

package ialpm

import (
	alpm "github.com/Jguer/go-alpm/v2"

	"github.com/Jguer/yay/v12/pkg/text"
)

// GetPackageNamesBySource returns package names with and without correspondence in SyncDBS respectively.
func (ae *AlpmExecutor) getPackageNamesBySource() {
	if ae.installedRemotePkgMap == nil {
		ae.installedRemotePkgMap = map[string]alpm.IPackage{}
	}
	for _, localpkg := range ae.LocalPackages() {
		pkgName := localpkg.Name()
		if ae.SyncPackage(pkgName) != nil {
			ae.installedSyncPkgNames = append(ae.installedSyncPkgNames, pkgName)
		} else {
			ae.installedRemotePkgNames = append(ae.installedRemotePkgNames, pkgName)
			ae.installedRemotePkgMap[pkgName] = localpkg
		}
	}

	ae.log.Debugln("populating db executor package caches.",
		"sync_len", len(ae.installedSyncPkgNames), "remote_len", len(ae.installedRemotePkgNames))
}

func (ae *AlpmExecutor) InstalledRemotePackages() map[string]alpm.IPackage {
	if ae.installedRemotePkgMap == nil {
		ae.getPackageNamesBySource()
	}

	return ae.installedRemotePkgMap
}

func (ae *AlpmExecutor) InstalledRemotePackageNames() []string {
	if ae.installedRemotePkgNames == nil {
		ae.getPackageNamesBySource()
	}

	return ae.installedRemotePkgNames
}

func (ae *AlpmExecutor) InstalledSyncPackageNames() []string {
	if ae.installedSyncPkgNames == nil {
		ae.getPackageNamesBySource()
	}

	return ae.installedSyncPkgNames
}

func (ae *AlpmExecutor) SetLogger(logger *text.Logger) {
	ae.log = logger
}