mirror of
https://github.com/EnumeratedDev/bpm.git
synced 2026-09-16 10:36:12 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c427499fb6 | ||
|
|
108e355e94 | ||
|
|
7b491874eb | ||
|
|
82d3c8bd51 | ||
|
|
7a489af220 | ||
|
|
6d9157e878 | ||
|
|
fd6ddbfc41 | ||
|
|
368b098888 | ||
|
|
5e2fc138e9 | ||
|
|
bc489ebd23 | ||
|
|
6247c6eff7 | ||
|
|
c24b7c85e3 | ||
|
|
2fd01a3fc2 | ||
|
|
747c770499 | ||
|
|
26500d670d | ||
|
|
59df2324e6 | ||
|
|
12d5e7580e | ||
|
|
123697e1dc | ||
|
|
743918702a | ||
|
|
7d2caa542c | ||
|
|
ab75193022 | ||
|
|
7d577a8dc2 | ||
|
|
c85c9b5d1c | ||
|
|
721414679d | ||
|
|
c20e74203c | ||
|
|
23f9a13939 | ||
|
|
1d41236740 | ||
|
|
e445863dca |
@@ -0,0 +1,38 @@
|
||||
ifeq ($(PREFIX),)
|
||||
PREFIX := /usr/local
|
||||
endif
|
||||
ifeq ($(BINDIR),)
|
||||
BINDIR := $(PREFIX)/bin
|
||||
endif
|
||||
ifeq ($(SYSCONFDIR),)
|
||||
SYSCONFDIR := $(PREFIX)/etc
|
||||
endif
|
||||
ifeq ($(GO),)
|
||||
GO := $(shell type -a -P go | head -n 1)
|
||||
endif
|
||||
|
||||
build:
|
||||
mkdir -p build
|
||||
$(GO) build -ldflags "-w" -o build/bpm gitlab.com/bubble-package-manager/bpm
|
||||
|
||||
install: build/bpm config/
|
||||
mkdir -p $(DESTDIR)$(BINDIR)
|
||||
mkdir -p $(DESTDIR)$(SYSCONFDIR)
|
||||
cp build/bpm $(DESTDIR)$(BINDIR)/bpm
|
||||
cp config/bpm.conf $(DESTDIR)$(SYSCONFDIR)/bpm.conf
|
||||
|
||||
compress: build/bpm config/
|
||||
mkdir -p bpm/$(BINDIR)
|
||||
mkdir -p bpm/$(SYSCONFDIR)
|
||||
cp build/bpm bpm/$(BINDIR)/bpm
|
||||
cp config/bpm.conf bpm/$(SYSCONFDIR)/bpm.conf
|
||||
tar --owner=root --group=root -czf bpm.tar.gz bpm
|
||||
rm -r bpm
|
||||
|
||||
run: build/bpm
|
||||
build/bpm
|
||||
|
||||
clean:
|
||||
rm -r build/
|
||||
|
||||
.PHONY: build
|
||||
@@ -15,15 +15,16 @@ BPM is still in very early development. It should not be installed on any system
|
||||
|
||||
## Build from source
|
||||
|
||||
BPM requires go 1.22 or above to be built properly
|
||||
|
||||
```sh
|
||||
git clone https://gitlab.com/bubble-package-manager/bpm.git
|
||||
cd bpm
|
||||
mkdir build
|
||||
go build -o ./build/bpm capcreepergr.me/bpm
|
||||
- Download `go` from your package manager or from the go website
|
||||
- Download `make` from your package manager
|
||||
- Run the following command to compile the project
|
||||
```
|
||||
make
|
||||
```
|
||||
- Run the following command to install stormfetch into your system. You may also append a DESTDIR variable at the end of this line if you wish to install in a different location
|
||||
```
|
||||
make install PREFIX=/usr SYSCONFDIR=/etc
|
||||
```
|
||||
You are now able to copy the executable in the ./build directory in a VM or container's /usr/bin/ directory
|
||||
|
||||
## How to use
|
||||
|
||||
|
||||
@@ -1,34 +0,0 @@
|
||||
package bpm_utils
|
||||
|
||||
import (
|
||||
"gopkg.in/yaml.v3"
|
||||
"os"
|
||||
)
|
||||
|
||||
type BPMConfigStruct struct {
|
||||
CompilationEnv []string `yaml:"compilation_env"`
|
||||
SilentCompilation bool `yaml:"silent_compilation"`
|
||||
BinaryOutputDir string `yaml:"binary_output_dir"`
|
||||
CompilationDir string `yaml:"compilation_dir"`
|
||||
}
|
||||
|
||||
var BPMConfig BPMConfigStruct = BPMConfigStruct{
|
||||
CompilationEnv: make([]string, 0),
|
||||
SilentCompilation: false,
|
||||
BinaryOutputDir: "/var/lib/bpm/compiled/",
|
||||
CompilationDir: "/var/tmp/",
|
||||
}
|
||||
|
||||
func ReadConfig() {
|
||||
if _, err := os.Stat("/etc/bpm.conf"); os.IsNotExist(err) {
|
||||
return
|
||||
}
|
||||
bytes, err := os.ReadFile("/etc/bpm.conf")
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
err = yaml.Unmarshal(bytes, &BPMConfig)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,8 @@
|
||||
compilation_env: []
|
||||
silent_compilation: false
|
||||
compilation_dir: "/var/tmp/"
|
||||
binary_output_dir: "/var/lib/bpm/compiled/"
|
||||
repositories:
|
||||
- name: example-repository
|
||||
source: https://my-repo.xyz/
|
||||
disabled: true
|
||||
@@ -1,5 +1,8 @@
|
||||
module capcreepergr.me/bpm
|
||||
module gitlab.com/bubble-package-manager/bpm
|
||||
|
||||
go 1.22
|
||||
|
||||
require gopkg.in/yaml.v3 v3.0.1 // indirect
|
||||
require (
|
||||
github.com/elliotchance/orderedmap/v2 v2.4.0 // indirect
|
||||
gopkg.in/yaml.v3 v3.0.1 // indirect
|
||||
)
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
github.com/elliotchance/orderedmap/v2 v2.4.0 h1:6tUmMwD9F998FNpwFxA5E6NQvSpk2PVw7RKsVq3+2Cw=
|
||||
github.com/elliotchance/orderedmap/v2 v2.4.0/go.mod h1:85lZyVbpGaGvHvnKa7Qhx7zncAdBIBq6u56Hb1PRU5Q=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
|
||||
@@ -2,9 +2,10 @@ package main
|
||||
|
||||
import (
|
||||
"bufio"
|
||||
"capcreepergr.me/bpm/bpm_utils"
|
||||
"flag"
|
||||
"fmt"
|
||||
"github.com/elliotchance/orderedmap/v2"
|
||||
"gitlab.com/bubble-package-manager/bpm/utils"
|
||||
"log"
|
||||
"os"
|
||||
"path/filepath"
|
||||
@@ -17,23 +18,28 @@ import (
|
||||
/* A simple-to-use package manager */
|
||||
/* ---------------------------------- */
|
||||
|
||||
var bpmVer = "0.3.1"
|
||||
var bpmVer = "0.4.1"
|
||||
|
||||
var subcommand = "help"
|
||||
var subcommandArgs []string
|
||||
|
||||
// Flags
|
||||
var rootDir = "/"
|
||||
var verbose = false
|
||||
var yesAll = false
|
||||
var buildSource = false
|
||||
var skipCheck = false
|
||||
var keepTempDir = false
|
||||
var forceInstall = false
|
||||
var force = false
|
||||
var pkgListNumbers = false
|
||||
var pkgListNames = false
|
||||
var reinstall = false
|
||||
var reinstallAll = false
|
||||
var noOptional = false
|
||||
var nosync = true
|
||||
|
||||
func main() {
|
||||
bpm_utils.ReadConfig()
|
||||
utils.ReadConfig()
|
||||
resolveFlags()
|
||||
resolveCommand()
|
||||
}
|
||||
@@ -45,7 +51,10 @@ const (
|
||||
version
|
||||
info
|
||||
list
|
||||
search
|
||||
install
|
||||
update
|
||||
sync
|
||||
remove
|
||||
file
|
||||
)
|
||||
@@ -58,8 +67,14 @@ func getCommandType() commandType {
|
||||
return info
|
||||
case "list":
|
||||
return list
|
||||
case "search":
|
||||
return search
|
||||
case "install":
|
||||
return install
|
||||
case "update":
|
||||
return update
|
||||
case "sync":
|
||||
return sync
|
||||
case "remove":
|
||||
return remove
|
||||
case "file":
|
||||
@@ -81,20 +96,21 @@ func resolveCommand() {
|
||||
return
|
||||
}
|
||||
for n, pkg := range packages {
|
||||
info := bpm_utils.GetPackageInfo(pkg, rootDir, false)
|
||||
var info *utils.PackageInfo
|
||||
info = utils.GetPackageInfo(pkg, rootDir, false)
|
||||
if info == nil {
|
||||
fmt.Printf("Package (%s) could not be found\n", pkg)
|
||||
continue
|
||||
log.Fatalf("Error: package (%s) is not installed\n", pkg)
|
||||
}
|
||||
fmt.Print("----------------\n" + bpm_utils.CreateInfoFile(*info, true))
|
||||
fmt.Println("----------------")
|
||||
fmt.Println(utils.CreateReadableInfo(true, true, true, info, rootDir))
|
||||
if n == len(packages)-1 {
|
||||
fmt.Println("----------------")
|
||||
}
|
||||
}
|
||||
case list:
|
||||
packages, err := bpm_utils.GetInstalledPackages(rootDir)
|
||||
packages, err := utils.GetInstalledPackages(rootDir)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not get installed packages\nError: %s", err.Error())
|
||||
log.Fatalf("Error: could not get installed packages: %s", err.Error())
|
||||
return
|
||||
}
|
||||
if pkgListNumbers {
|
||||
@@ -109,122 +125,411 @@ func resolveCommand() {
|
||||
return
|
||||
}
|
||||
for n, pkg := range packages {
|
||||
info := bpm_utils.GetPackageInfo(pkg, rootDir, false)
|
||||
info := utils.GetPackageInfo(pkg, rootDir, false)
|
||||
if info == nil {
|
||||
fmt.Printf("Package (%s) could not be found\n", pkg)
|
||||
continue
|
||||
}
|
||||
fmt.Print("----------------\n" + bpm_utils.CreateInfoFile(*info, true))
|
||||
fmt.Println("----------------\n" + utils.CreateReadableInfo(true, true, true, info, rootDir))
|
||||
if n == len(packages)-1 {
|
||||
fmt.Println("----------------")
|
||||
}
|
||||
}
|
||||
}
|
||||
case search:
|
||||
searchTerms := subcommandArgs
|
||||
if len(searchTerms) == 0 {
|
||||
log.Fatalf("Error: no search terms given")
|
||||
}
|
||||
|
||||
for _, term := range searchTerms {
|
||||
nameResults := make([]*utils.PackageInfo, 0)
|
||||
descResults := make([]*utils.PackageInfo, 0)
|
||||
for _, repo := range utils.BPMConfig.Repositories {
|
||||
for _, entry := range repo.Entries {
|
||||
if strings.Contains(entry.Info.Name, term) {
|
||||
nameResults = append(nameResults, entry.Info)
|
||||
} else if strings.Contains(entry.Info.Description, term) {
|
||||
descResults = append(descResults, entry.Info)
|
||||
}
|
||||
}
|
||||
}
|
||||
results := append(nameResults, descResults...)
|
||||
if len(results) == 0 {
|
||||
log.Fatalf("Error: no results for term (%s) were found\n", term)
|
||||
}
|
||||
fmt.Printf("Results for term (%s)\n", term)
|
||||
for i, result := range results {
|
||||
fmt.Println("----------------")
|
||||
fmt.Printf("%d) %s: %s (%s)\n", i+1, result.Name, result.Description, result.GetFullVersion())
|
||||
}
|
||||
}
|
||||
case install:
|
||||
if os.Getuid() != 0 {
|
||||
fmt.Println("This subcommand needs to be run with superuser permissions")
|
||||
os.Exit(0)
|
||||
log.Fatalf("Error: this subcommand needs to be run with superuser permissions")
|
||||
}
|
||||
files := subcommandArgs
|
||||
if len(files) == 0 {
|
||||
fmt.Println("No files were given to install")
|
||||
pkgs := subcommandArgs
|
||||
if len(pkgs) == 0 {
|
||||
fmt.Println("No packages or files were given to install")
|
||||
return
|
||||
}
|
||||
for _, file := range files {
|
||||
pkgInfo, err := bpm_utils.ReadPackage(file)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not read package\nError: %s\n", err)
|
||||
|
||||
pkgsToInstall := orderedmap.NewOrderedMap[string, *struct {
|
||||
bpmFile string
|
||||
isDependency bool
|
||||
shouldFetch bool
|
||||
pkgInfo *utils.PackageInfo
|
||||
}]()
|
||||
unresolvedDepends := make([]string, 0)
|
||||
|
||||
// Search for packages
|
||||
for _, pkg := range pkgs {
|
||||
if stat, err := os.Stat(pkg); err == nil && !stat.IsDir() {
|
||||
pkgInfo, err := utils.ReadPackage(pkg)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not read package: %s\n", err)
|
||||
}
|
||||
if !reinstall && utils.IsPackageInstalled(pkgInfo.Name, rootDir) && utils.GetPackageInfo(pkgInfo.Name, rootDir, true).GetFullVersion() == pkgInfo.GetFullVersion() {
|
||||
continue
|
||||
}
|
||||
pkgsToInstall.Set(pkgInfo.Name, &struct {
|
||||
bpmFile string
|
||||
isDependency bool
|
||||
shouldFetch bool
|
||||
pkgInfo *utils.PackageInfo
|
||||
}{bpmFile: pkg, isDependency: false, shouldFetch: false, pkgInfo: pkgInfo})
|
||||
} else {
|
||||
entry, _, err := utils.GetRepositoryEntry(pkg)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not find package (%s) in any repository\n", pkg)
|
||||
}
|
||||
if !reinstall && utils.IsPackageInstalled(entry.Info.Name, rootDir) && utils.GetPackageInfo(entry.Info.Name, rootDir, true).GetFullVersion() == entry.Info.GetFullVersion() {
|
||||
continue
|
||||
}
|
||||
pkgsToInstall.Set(entry.Info.Name, &struct {
|
||||
bpmFile string
|
||||
isDependency bool
|
||||
shouldFetch bool
|
||||
pkgInfo *utils.PackageInfo
|
||||
}{bpmFile: "", isDependency: false, shouldFetch: true, pkgInfo: entry.Info})
|
||||
}
|
||||
fmt.Print("----------------\n" + bpm_utils.CreateInfoFile(*pkgInfo, true))
|
||||
fmt.Println("----------------")
|
||||
verb := "install"
|
||||
}
|
||||
|
||||
clone := pkgsToInstall.Copy()
|
||||
pkgsToInstall = orderedmap.NewOrderedMap[string, *struct {
|
||||
bpmFile string
|
||||
isDependency bool
|
||||
shouldFetch bool
|
||||
pkgInfo *utils.PackageInfo
|
||||
}]()
|
||||
for _, pkg := range clone.Keys() {
|
||||
value, _ := clone.Get(pkg)
|
||||
resolved, unresolved := value.pkgInfo.ResolveAll(&[]string{}, &[]string{}, value.pkgInfo.Type == "source", !noOptional, !reinstall, rootDir)
|
||||
unresolvedDepends = append(unresolvedDepends, unresolved...)
|
||||
for _, depend := range resolved {
|
||||
if _, ok := pkgsToInstall.Get(depend); !ok && depend != value.pkgInfo.Name {
|
||||
if !reinstallAll && utils.IsPackageInstalled(depend, rootDir) {
|
||||
continue
|
||||
}
|
||||
entry, _, err := utils.GetRepositoryEntry(depend)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not find package (%s) in any repository\n", pkg)
|
||||
}
|
||||
pkgsToInstall.Set(depend, &struct {
|
||||
bpmFile string
|
||||
isDependency bool
|
||||
shouldFetch bool
|
||||
pkgInfo *utils.PackageInfo
|
||||
}{bpmFile: "", isDependency: true, shouldFetch: true, pkgInfo: entry.Info})
|
||||
}
|
||||
}
|
||||
pkgsToInstall.Set(pkg, value)
|
||||
}
|
||||
|
||||
// Show summary
|
||||
if len(unresolvedDepends) != 0 {
|
||||
if !force {
|
||||
log.Fatalf("Error: the following dependencies could not be found in any repositories: %s\n", strings.Join(unresolvedDepends, ", "))
|
||||
} else {
|
||||
log.Println("Warning: The following dependencies could not be found in any repositories: " + strings.Join(unresolvedDepends, ", "))
|
||||
}
|
||||
}
|
||||
if pkgsToInstall.Len() == 0 {
|
||||
fmt.Println("All packages are up to date!")
|
||||
os.Exit(0)
|
||||
}
|
||||
|
||||
for _, pkg := range pkgsToInstall.Keys() {
|
||||
value, _ := pkgsToInstall.Get(pkg)
|
||||
pkgInfo := value.pkgInfo
|
||||
installedInfo := utils.GetPackageInfo(pkgInfo.Name, rootDir, false)
|
||||
sourceInfo := ""
|
||||
if pkgInfo.Type == "source" {
|
||||
if _, err := os.Stat("/bin/fakeroot"); os.IsNotExist(err) {
|
||||
fmt.Printf("Skipping... cannot %s package (%s) due to fakeroot not being installed")
|
||||
continue
|
||||
if rootDir != "/" && !force {
|
||||
log.Fatalf("Error: cannot compile and install source packages to a different root directory")
|
||||
}
|
||||
verb = "build"
|
||||
sourceInfo = "(From Source)"
|
||||
}
|
||||
if !forceInstall {
|
||||
if pkgInfo.Arch != "any" && pkgInfo.Arch != bpm_utils.GetArch() {
|
||||
fmt.Printf("skipping... cannot %s a package with a different architecture\n", verb)
|
||||
continue
|
||||
}
|
||||
if unresolved := bpm_utils.CheckDependencies(pkgInfo, rootDir); len(unresolved) != 0 {
|
||||
fmt.Printf("skipping... cannot %s package (%s) due to missing dependencies: %s\n", verb, pkgInfo.Name, strings.Join(unresolved, ", "))
|
||||
continue
|
||||
}
|
||||
if pkgInfo.Type == "source" {
|
||||
if unresolved := bpm_utils.CheckMakeDependencies(pkgInfo, "/"); len(unresolved) != 0 {
|
||||
fmt.Printf("skipping... cannot %s package (%s) due to missing make dependencies: %s\n", verb, pkgInfo.Name, strings.Join(unresolved, ", "))
|
||||
continue
|
||||
}
|
||||
}
|
||||
if installedInfo == nil {
|
||||
fmt.Printf("%s: %s (Install) %s\n", pkgInfo.Name, pkgInfo.GetFullVersion(), sourceInfo)
|
||||
} else if strings.Compare(pkgInfo.GetFullVersion(), installedInfo.GetFullVersion()) < 0 {
|
||||
fmt.Printf("%s: %s -> %s (Downgrade) %s\n", pkgInfo.Name, installedInfo.GetFullVersion(), pkgInfo.GetFullVersion(), sourceInfo)
|
||||
} else if strings.Compare(pkgInfo.GetFullVersion(), installedInfo.GetFullVersion()) > 0 {
|
||||
fmt.Printf("%s: %s -> %s (Upgrade) %s\n", pkgInfo.Name, installedInfo.GetFullVersion(), pkgInfo.GetFullVersion(), sourceInfo)
|
||||
} else {
|
||||
fmt.Printf("%s: %s (Reinstall) %s\n", pkgInfo.Name, pkgInfo.GetFullVersion(), sourceInfo)
|
||||
}
|
||||
if rootDir != "/" {
|
||||
fmt.Println("Warning: Operating in " + rootDir)
|
||||
}
|
||||
if rootDir != "/" {
|
||||
fmt.Println("Warning: Operating in " + rootDir)
|
||||
}
|
||||
if !yesAll {
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
if pkgsToInstall.Len() == 1 {
|
||||
fmt.Printf("Do you wish to install this package? [y\\N] ")
|
||||
} else {
|
||||
fmt.Printf("Do you wish to install these %d packages? [y\\N] ", pkgsToInstall.Len())
|
||||
}
|
||||
if !yesAll {
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
if pkgInfo.Type == "source" {
|
||||
fmt.Print("Would you like to view the source.sh file of this package? [Y\\n] ")
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "n" && strings.TrimSpace(strings.ToLower(text)) != "no" {
|
||||
script, err := bpm_utils.GetSourceScript(file)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not read source script\nError: %s\n", err)
|
||||
}
|
||||
fmt.Println(script)
|
||||
fmt.Println("-------EOF-------")
|
||||
}
|
||||
}
|
||||
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "y" && strings.TrimSpace(strings.ToLower(text)) != "yes" {
|
||||
fmt.Println("Cancelling...")
|
||||
os.Exit(1)
|
||||
}
|
||||
if bpm_utils.IsPackageInstalled(pkgInfo.Name, rootDir) {
|
||||
if !yesAll {
|
||||
installedInfo := bpm_utils.GetPackageInfo(pkgInfo.Name, rootDir, false)
|
||||
if strings.Compare(pkgInfo.Version, installedInfo.Version) > 0 {
|
||||
fmt.Println("This file contains a newer version of this package (" + installedInfo.Version + " -> " + pkgInfo.Version + ")")
|
||||
fmt.Print("Do you wish to update this package? [y\\N] ")
|
||||
} else if strings.Compare(pkgInfo.Version, installedInfo.Version) < 0 {
|
||||
fmt.Println("This file contains an older version of this package (" + installedInfo.Version + " -> " + pkgInfo.Version + ")")
|
||||
fmt.Print("Do you wish to downgrade this package? (Not recommended) [y\\N] ")
|
||||
} else if strings.Compare(pkgInfo.Version, installedInfo.Version) == 0 {
|
||||
fmt.Println("This package is already installed on the system and is up to date")
|
||||
fmt.Printf("Do you wish to re%s this package? [y\\N] ", verb)
|
||||
}
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "y" && strings.TrimSpace(strings.ToLower(text)) != "yes" {
|
||||
fmt.Printf("Skipping package (%s)...\n", pkgInfo.Name)
|
||||
continue
|
||||
}
|
||||
}
|
||||
} else if !yesAll {
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
fmt.Printf("Do you wish to %s this package? [y\\N] ", verb)
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "y" && strings.TrimSpace(strings.ToLower(text)) != "yes" {
|
||||
fmt.Printf("Skipping package (%s)...\n", pkgInfo.Name)
|
||||
continue
|
||||
}
|
||||
}
|
||||
|
||||
// Fetch packages from repositories
|
||||
fmt.Println("Fetching packages from available repositories...")
|
||||
for _, pkg := range pkgsToInstall.Keys() {
|
||||
value, _ := pkgsToInstall.Get(pkg)
|
||||
if !value.shouldFetch {
|
||||
continue
|
||||
}
|
||||
entry, repo, err := utils.GetRepositoryEntry(pkg)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not find package (%s) in any repository\n", pkg)
|
||||
}
|
||||
fetchedPackage, err := repo.FetchPackage(entry.Info.Name)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not fetch package (%s): %s\n", pkg, err)
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully fetched!\n", value.pkgInfo.Name)
|
||||
value.bpmFile = fetchedPackage
|
||||
pkgsToInstall.Set(pkg, value)
|
||||
}
|
||||
|
||||
// Install fetched packages
|
||||
for _, pkg := range pkgsToInstall.Keys() {
|
||||
value, _ := pkgsToInstall.Get(pkg)
|
||||
pkgInfo := value.pkgInfo
|
||||
var err error
|
||||
if value.isDependency {
|
||||
err = utils.InstallPackage(value.bpmFile, rootDir, verbose, true, buildSource, skipCheck, keepTempDir)
|
||||
} else {
|
||||
err = utils.InstallPackage(value.bpmFile, rootDir, verbose, force, buildSource, skipCheck, keepTempDir)
|
||||
}
|
||||
|
||||
err = bpm_utils.InstallPackage(file, rootDir, forceInstall, buildSource, skipCheck, keepTempDir)
|
||||
if err != nil {
|
||||
if pkgInfo.Type == "source" && keepTempDir {
|
||||
fmt.Println("BPM temp directory was created at /var/tmp/bpm_source-" + pkgInfo.Name)
|
||||
}
|
||||
log.Fatalf("Could not install package\nError: %s\n", err)
|
||||
log.Fatalf("Error: could not install package (%s): %s\n", pkg, err)
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully installed\n", pkgInfo.Name)
|
||||
if value.isDependency {
|
||||
err := utils.SetInstallationReason(pkgInfo.Name, utils.Dependency, rootDir)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not set installation reason for package: %s\n", err)
|
||||
}
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully installed!\n", pkgInfo.Name)
|
||||
if pkgInfo.Type == "source" && keepTempDir {
|
||||
fmt.Println("** It is recommended you delete the temporary bpm folder in /var/tmp **")
|
||||
}
|
||||
}
|
||||
case update:
|
||||
if os.Getuid() != 0 {
|
||||
log.Fatalf("Error: this subcommand needs to be run with superuser permissions")
|
||||
}
|
||||
|
||||
// Sync repositories
|
||||
if !nosync {
|
||||
for _, repo := range utils.BPMConfig.Repositories {
|
||||
fmt.Printf("Fetching package database for repository (%s)...\n", repo.Name)
|
||||
err := repo.SyncLocalDatabase()
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not sync local database for repository (%s): %s\n", repo.Name, err)
|
||||
}
|
||||
}
|
||||
fmt.Println("All package databases synced successfully!")
|
||||
}
|
||||
|
||||
utils.ReadConfig()
|
||||
|
||||
// Get installed packages and check for updates
|
||||
pkgs, err := utils.GetInstalledPackages(rootDir)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not get installed packages: %s\n", err)
|
||||
}
|
||||
toUpdate := orderedmap.NewOrderedMap[string, *struct {
|
||||
isDependency bool
|
||||
entry *utils.RepositoryEntry
|
||||
}]()
|
||||
for _, pkg := range pkgs {
|
||||
entry, _, err := utils.GetRepositoryEntry(pkg)
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
installedInfo := utils.GetPackageInfo(pkg, rootDir, true)
|
||||
if installedInfo == nil {
|
||||
log.Fatalf("Error: could not get package info for (%s)\n", pkg)
|
||||
}
|
||||
if strings.Compare(entry.Info.GetFullVersion(), installedInfo.GetFullVersion()) > 0 {
|
||||
toUpdate.Set(entry.Info.Name, &struct {
|
||||
isDependency bool
|
||||
entry *utils.RepositoryEntry
|
||||
}{isDependency: false, entry: entry})
|
||||
} else if reinstall {
|
||||
toUpdate.Set(entry.Info.Name, &struct {
|
||||
isDependency bool
|
||||
entry *utils.RepositoryEntry
|
||||
}{isDependency: false, entry: entry})
|
||||
}
|
||||
}
|
||||
if toUpdate.Len() == 0 {
|
||||
fmt.Println("All packages are up to date!")
|
||||
os.Exit(0)
|
||||
}
|
||||
|
||||
// Check for new dependencies in updated packages
|
||||
unresolved := make([]string, 0)
|
||||
clone := toUpdate.Copy()
|
||||
for _, key := range clone.Keys() {
|
||||
pkg, _ := clone.Get(key)
|
||||
r, u := pkg.entry.Info.ResolveAll(&[]string{}, &[]string{}, pkg.entry.Info.Type == "source", !noOptional, true, rootDir)
|
||||
unresolved = append(unresolved, u...)
|
||||
for _, depend := range r {
|
||||
if _, ok := toUpdate.Get(depend); !ok {
|
||||
entry, _, err := utils.GetRepositoryEntry(depend)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not find package (%s) in any repository\n", depend)
|
||||
}
|
||||
toUpdate.Set(depend, &struct {
|
||||
isDependency bool
|
||||
entry *utils.RepositoryEntry
|
||||
}{isDependency: true, entry: entry})
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if len(unresolved) != 0 {
|
||||
if !force {
|
||||
log.Fatalf("Error: the following dependencies could not be found in any repositories: %s\n", strings.Join(unresolved, ", "))
|
||||
} else {
|
||||
log.Printf("Warning: the following dependencies could not be found in any repositories: %s\n", strings.Join(unresolved, ", "))
|
||||
}
|
||||
}
|
||||
|
||||
for _, key := range toUpdate.Keys() {
|
||||
value, _ := toUpdate.Get(key)
|
||||
installedInfo := utils.GetPackageInfo(value.entry.Info.Name, rootDir, true)
|
||||
sourceInfo := ""
|
||||
if value.entry.Info.Type == "source" {
|
||||
sourceInfo = "(From Source)"
|
||||
}
|
||||
if installedInfo == nil {
|
||||
fmt.Printf("%s: %s (Install) %s\n", value.entry.Info.Name, value.entry.Info.GetFullVersion(), sourceInfo)
|
||||
continue
|
||||
}
|
||||
if strings.Compare(value.entry.Info.GetFullVersion(), installedInfo.GetFullVersion()) > 0 {
|
||||
fmt.Printf("%s: %s -> %s (Upgrade) %s\n", value.entry.Info.Name, installedInfo.GetFullVersion(), value.entry.Info.GetFullVersion(), sourceInfo)
|
||||
} else if reinstall {
|
||||
fmt.Printf("%s: %s -> %s (Reinstall) %s\n", value.entry.Info.Name, installedInfo.GetFullVersion(), value.entry.Info.GetFullVersion(), sourceInfo)
|
||||
}
|
||||
}
|
||||
|
||||
// Update confirmation prompt
|
||||
if !yesAll {
|
||||
fmt.Printf("Are you sure you wish to update all %d packages? [y\\N] ", toUpdate.Len())
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "y" && strings.TrimSpace(strings.ToLower(text)) != "yes" {
|
||||
fmt.Println("Cancelling update...")
|
||||
os.Exit(1)
|
||||
}
|
||||
}
|
||||
|
||||
// Fetch packages
|
||||
pkgsToInstall := orderedmap.NewOrderedMap[string, *struct {
|
||||
isDependency bool
|
||||
entry *utils.RepositoryEntry
|
||||
}]()
|
||||
fmt.Println("Fetching packages from available repositories...")
|
||||
for _, pkg := range toUpdate.Keys() {
|
||||
value, _ := toUpdate.Get(pkg)
|
||||
entry, repo, err := utils.GetRepositoryEntry(pkg)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not find package (%s) in any repository\n", pkg)
|
||||
}
|
||||
fetchedPackage, err := repo.FetchPackage(entry.Info.Name)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not fetch package (%s): %s\n", pkg, err)
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully fetched!\n", value.entry.Info.Name)
|
||||
pkgsToInstall.Set(fetchedPackage, value)
|
||||
}
|
||||
|
||||
// Install fetched packages
|
||||
for _, pkg := range pkgsToInstall.Keys() {
|
||||
value, _ := pkgsToInstall.Get(pkg)
|
||||
pkgInfo := value.entry.Info
|
||||
var err error
|
||||
if value.isDependency {
|
||||
err = utils.InstallPackage(pkg, rootDir, verbose, true, buildSource, skipCheck, keepTempDir)
|
||||
} else {
|
||||
err = utils.InstallPackage(pkg, rootDir, verbose, force, buildSource, skipCheck, keepTempDir)
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
if pkgInfo.Type == "source" && keepTempDir {
|
||||
fmt.Println("BPM temp directory was created at /var/tmp/bpm_source-" + pkgInfo.Name)
|
||||
}
|
||||
log.Fatalf("Error: could not install package (%s): %s\n", pkg, err)
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully installed!\n", pkgInfo.Name)
|
||||
if value.isDependency {
|
||||
err := utils.SetInstallationReason(pkgInfo.Name, utils.Dependency, rootDir)
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not set installation reason for package: %s\n", err)
|
||||
}
|
||||
}
|
||||
if pkgInfo.Type == "source" && keepTempDir {
|
||||
fmt.Println("** It is recommended you delete the temporary bpm folder in /var/tmp **")
|
||||
}
|
||||
}
|
||||
case sync:
|
||||
if os.Getuid() != 0 {
|
||||
log.Fatalf("Error: this subcommand needs to be run with superuser permissions")
|
||||
}
|
||||
if !yesAll {
|
||||
fmt.Printf("Are you sure you wish to sync all databases? [y\\N] ")
|
||||
reader := bufio.NewReader(os.Stdin)
|
||||
text, _ := reader.ReadString('\n')
|
||||
if strings.TrimSpace(strings.ToLower(text)) != "y" && strings.TrimSpace(strings.ToLower(text)) != "yes" {
|
||||
fmt.Println("Cancelling sync...")
|
||||
os.Exit(1)
|
||||
}
|
||||
}
|
||||
for _, repo := range utils.BPMConfig.Repositories {
|
||||
fmt.Printf("Fetching package database for repository (%s)...\n", repo.Name)
|
||||
err := repo.SyncLocalDatabase()
|
||||
if err != nil {
|
||||
log.Fatalf("Error: could not sync local database for repository (%s): %s\n", repo.Name, err)
|
||||
}
|
||||
}
|
||||
fmt.Println("All package databases synced successfully!")
|
||||
case remove:
|
||||
if os.Getuid() != 0 {
|
||||
fmt.Println("This subcommand needs to be run with superuser permissions")
|
||||
os.Exit(0)
|
||||
log.Fatalf("Error: this subcommand needs to be run with superuser permissions")
|
||||
}
|
||||
packages := subcommandArgs
|
||||
if len(packages) == 0 {
|
||||
@@ -232,12 +537,12 @@ func resolveCommand() {
|
||||
return
|
||||
}
|
||||
for _, pkg := range packages {
|
||||
pkgInfo := bpm_utils.GetPackageInfo(pkg, rootDir, false)
|
||||
pkgInfo := utils.GetPackageInfo(pkg, rootDir, false)
|
||||
if pkgInfo == nil {
|
||||
fmt.Printf("Package (%s) could not be found\n", pkg)
|
||||
continue
|
||||
}
|
||||
fmt.Print("----------------\n" + bpm_utils.CreateInfoFile(*pkgInfo, true))
|
||||
fmt.Println("----------------\n" + utils.CreateReadableInfo(false, false, false, pkgInfo, rootDir))
|
||||
fmt.Println("----------------")
|
||||
if rootDir != "/" {
|
||||
fmt.Println("Warning: Operating in " + rootDir)
|
||||
@@ -251,10 +556,10 @@ func resolveCommand() {
|
||||
continue
|
||||
}
|
||||
}
|
||||
err := bpm_utils.RemovePackage(pkg, rootDir)
|
||||
err := utils.RemovePackage(pkg, verbose, rootDir)
|
||||
|
||||
if err != nil {
|
||||
log.Fatalf("Could not remove package\nError: %s\n", err)
|
||||
log.Fatalf("Error: could not remove package: %s\n", err)
|
||||
}
|
||||
fmt.Printf("Package (%s) was successfully removed!\n", pkgInfo.Name)
|
||||
}
|
||||
@@ -267,23 +572,23 @@ func resolveCommand() {
|
||||
for _, file := range files {
|
||||
absFile, err := filepath.Abs(file)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not get absolute path of %s", file)
|
||||
log.Fatalf("Error: could not get absolute path of file (%s)\n", file)
|
||||
}
|
||||
stat, err := os.Stat(absFile)
|
||||
if os.IsNotExist(err) {
|
||||
log.Fatalf(absFile + " does not exist!")
|
||||
log.Fatalf("Error: file (%s) does not exist!\n", absFile)
|
||||
}
|
||||
pkgs, err := bpm_utils.GetInstalledPackages(rootDir)
|
||||
pkgs, err := utils.GetInstalledPackages(rootDir)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not get installed packages. Error %s", err.Error())
|
||||
log.Fatalf("Error: could not get installed packages: %s\n", err.Error())
|
||||
}
|
||||
|
||||
if !strings.HasPrefix(absFile, rootDir) {
|
||||
log.Fatalf("Could not get relative path of %s to root path", absFile)
|
||||
log.Fatalf("Error: could not get path of file (%s) relative to root path", absFile)
|
||||
}
|
||||
absFile, err = filepath.Rel(rootDir, absFile)
|
||||
if err != nil {
|
||||
log.Fatalf("Could not get relative path of %s to root path", absFile)
|
||||
log.Fatalf("Error: could not get path of file (%s) relative to root path", absFile)
|
||||
}
|
||||
absFile = strings.TrimPrefix(absFile, "/")
|
||||
if stat.IsDir() {
|
||||
@@ -292,7 +597,7 @@ func resolveCommand() {
|
||||
|
||||
var pkgList []string
|
||||
for _, pkg := range pkgs {
|
||||
if slices.Contains(bpm_utils.GetPackageFiles(pkg, rootDir), absFile) {
|
||||
if slices.Contains(utils.GetPackageFiles(pkg, rootDir), absFile) {
|
||||
pkgList = append(pkgList, pkg)
|
||||
}
|
||||
}
|
||||
@@ -316,21 +621,38 @@ func printHelp() {
|
||||
fmt.Println("-> flags will be read if passed right after the subcommand otherwise they will be read as subcommand arguments")
|
||||
fmt.Println("\033[1m---- Command List ----\033[0m")
|
||||
fmt.Println("-> bpm version | shows information on the installed version of bpm")
|
||||
fmt.Println("-> bpm info [-R] | shows information on an installed package")
|
||||
fmt.Println("-> bpm info [-R] <packages...> | shows information on an installed package")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println("-> bpm list [-R, -c, -n] | lists all installed packages")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println(" -c lists the amount of installed packages")
|
||||
fmt.Println(" -n lists only the names of installed packages")
|
||||
fmt.Println("-> bpm install [-R, -y, -f, -o, -c, -b, -k] <files...> | installs the following files")
|
||||
fmt.Println("-> bpm search <search terms...> | Searches for packages through declared repositories")
|
||||
fmt.Println("-> bpm install [-R, -v, -y, -f, -o, -c, -b, -k, --reinstall, --reinstall-all, --no-optional] <packages...> | installs the following files")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println(" -v Show additional information about what BPM is doing")
|
||||
fmt.Println(" -y skips the confirmation prompt")
|
||||
fmt.Println(" -f skips dependency and architecture checking")
|
||||
fmt.Println(" -f skips dependency, conflict and architecture checking")
|
||||
fmt.Println(" -o=<path> set the binary package output directory (defaults to /var/lib/bpm/compiled)")
|
||||
fmt.Println(" -c=<path> set the compilation directory (defaults to /var/tmp)")
|
||||
fmt.Println(" -b creates a binary package from a source package after compilation and saves it in the binary package output directory")
|
||||
fmt.Println(" -k keeps the compilation directory created by BPM after source package installation")
|
||||
fmt.Println("-> bpm remove [-R, -y] <packages...> | removes the following packages")
|
||||
fmt.Println(" --reinstall Reinstalls packages even if they do not have a newer version available")
|
||||
fmt.Println(" --reinstall-all Same as --reinstall but also reinstalls dependencies")
|
||||
fmt.Println(" --no-optional Prevents installation of optional dependencies")
|
||||
fmt.Println("-> bpm update [-R, -v, -y, -f, --reinstall, --no-sync] | updates all packages that are available in the repositories")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println(" -v Show additional information about what BPM is doing")
|
||||
fmt.Println(" -y skips the confirmation prompt")
|
||||
fmt.Println(" -f skips dependency, conflict and architecture checking")
|
||||
fmt.Println(" --reinstall Fetches and reinstalls all packages even if they do not have a newer version available")
|
||||
fmt.Println(" --no-sync Skips package database syncing")
|
||||
fmt.Println("-> bpm sync [-R, -v, -y] | Syncs package databases without updating packages")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println(" -v Show additional information about what BPM is doing")
|
||||
fmt.Println(" -y skips the confirmation prompt")
|
||||
fmt.Println("-> bpm remove [-R, -v, -y] <packages...> | removes the following packages")
|
||||
fmt.Println(" -v Show additional information about what BPM is doing")
|
||||
fmt.Println(" -R=<path> lets you define the root path which will be used")
|
||||
fmt.Println(" -y skips the confirmation prompt")
|
||||
fmt.Println("-> bpm file [-R] <files...> | shows what packages the following packages are managed by")
|
||||
@@ -352,17 +674,37 @@ func resolveFlags() {
|
||||
// Install flags
|
||||
installFlagSet := flag.NewFlagSet("Install flags", flag.ExitOnError)
|
||||
installFlagSet.StringVar(&rootDir, "R", "/", "Set the destination root")
|
||||
installFlagSet.BoolVar(&verbose, "v", false, "Show additional information about what BPM is doing")
|
||||
installFlagSet.BoolVar(&yesAll, "y", false, "Skip confirmation prompts")
|
||||
installFlagSet.StringVar(&bpm_utils.BPMConfig.BinaryOutputDir, "o", bpm_utils.BPMConfig.BinaryOutputDir, "Set the binary output directory")
|
||||
installFlagSet.StringVar(&bpm_utils.BPMConfig.CompilationDir, "c", bpm_utils.BPMConfig.CompilationDir, "Set the compilation directory")
|
||||
installFlagSet.StringVar(&utils.BPMConfig.BinaryOutputDir, "o", utils.BPMConfig.BinaryOutputDir, "Set the binary output directory")
|
||||
installFlagSet.StringVar(&utils.BPMConfig.CompilationDir, "c", utils.BPMConfig.CompilationDir, "Set the compilation directory")
|
||||
installFlagSet.BoolVar(&buildSource, "b", false, "Build binary package from source package")
|
||||
installFlagSet.BoolVar(&skipCheck, "s", false, "Skip check function during source compilation")
|
||||
installFlagSet.BoolVar(&keepTempDir, "k", false, "Keep temporary directory after source compilation")
|
||||
installFlagSet.BoolVar(&forceInstall, "f", false, "Force installation by skipping architecture and dependency resolution")
|
||||
installFlagSet.BoolVar(&force, "f", false, "Force installation by skipping architecture and dependency resolution")
|
||||
installFlagSet.BoolVar(&reinstall, "reinstall", false, "Reinstalls packages even if they do not have a newer version available")
|
||||
installFlagSet.BoolVar(&reinstallAll, "reinstall-all", false, "Same as --reinstall but also reinstalls dependencies")
|
||||
installFlagSet.BoolVar(&noOptional, "no-optional", false, "Prevents installation of optional dependencies")
|
||||
installFlagSet.Usage = printHelp
|
||||
// Update flags
|
||||
updateFlagSet := flag.NewFlagSet("Update flags", flag.ExitOnError)
|
||||
updateFlagSet.StringVar(&rootDir, "R", "/", "Set the destination root")
|
||||
updateFlagSet.BoolVar(&verbose, "v", false, "Show additional information about what BPM is doing")
|
||||
updateFlagSet.BoolVar(&yesAll, "y", false, "Skip confirmation prompts")
|
||||
updateFlagSet.BoolVar(&force, "f", false, "Force update by skipping architecture and dependency resolution")
|
||||
updateFlagSet.BoolVar(&reinstall, "reinstall", false, "Fetches and reinstalls all packages even if they do not have a newer version available")
|
||||
updateFlagSet.BoolVar(&nosync, "no-sync", false, "Skips package database syncing")
|
||||
updateFlagSet.Usage = printHelp
|
||||
// Sync flags
|
||||
syncFlagSet := flag.NewFlagSet("Sync flags", flag.ExitOnError)
|
||||
syncFlagSet.StringVar(&rootDir, "R", "/", "Set the destination root")
|
||||
syncFlagSet.BoolVar(&verbose, "v", false, "Show additional information about what BPM is doing")
|
||||
syncFlagSet.BoolVar(&yesAll, "y", false, "Skip confirmation prompts")
|
||||
syncFlagSet.Usage = printHelp
|
||||
// Remove flags
|
||||
removeFlagSet := flag.NewFlagSet("Remove flags", flag.ExitOnError)
|
||||
removeFlagSet.StringVar(&rootDir, "R", "/", "Set the destination root")
|
||||
removeFlagSet.BoolVar(&verbose, "v", false, "Show additional information about what BPM is doing")
|
||||
removeFlagSet.BoolVar(&yesAll, "y", false, "Skip confirmation prompts")
|
||||
removeFlagSet.Usage = printHelp
|
||||
// File flags
|
||||
@@ -392,6 +734,18 @@ func resolveFlags() {
|
||||
return
|
||||
}
|
||||
subcommandArgs = installFlagSet.Args()
|
||||
} else if getCommandType() == update {
|
||||
err := updateFlagSet.Parse(subcommandArgs)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
subcommandArgs = updateFlagSet.Args()
|
||||
} else if getCommandType() == sync {
|
||||
err := syncFlagSet.Parse(subcommandArgs)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
subcommandArgs = syncFlagSet.Args()
|
||||
} else if getCommandType() == remove {
|
||||
err := removeFlagSet.Parse(subcommandArgs)
|
||||
if err != nil {
|
||||
@@ -405,5 +759,8 @@ func resolveFlags() {
|
||||
}
|
||||
subcommandArgs = fileFlagSet.Args()
|
||||
}
|
||||
if reinstallAll {
|
||||
reinstall = true
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,49 @@
|
||||
package utils
|
||||
|
||||
import (
|
||||
"gopkg.in/yaml.v3"
|
||||
"log"
|
||||
"os"
|
||||
)
|
||||
|
||||
type BPMConfigStruct struct {
|
||||
CompilationEnv []string `yaml:"compilation_env"`
|
||||
SilentCompilation bool `yaml:"silent_compilation"`
|
||||
BinaryOutputDir string `yaml:"binary_output_dir"`
|
||||
CompilationDir string `yaml:"compilation_dir"`
|
||||
Repositories []*Repository `yaml:"repositories"`
|
||||
}
|
||||
|
||||
var BPMConfig BPMConfigStruct
|
||||
|
||||
func ReadConfig() {
|
||||
if _, err := os.Stat("/etc/bpm.conf"); os.IsNotExist(err) {
|
||||
log.Fatal(err)
|
||||
}
|
||||
bytes, err := os.ReadFile("/etc/bpm.conf")
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
BPMConfig = BPMConfigStruct{
|
||||
CompilationEnv: make([]string, 0),
|
||||
SilentCompilation: false,
|
||||
BinaryOutputDir: "/var/lib/bpm/compiled/",
|
||||
CompilationDir: "/var/tmp/",
|
||||
}
|
||||
err = yaml.Unmarshal(bytes, &BPMConfig)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
for i := len(BPMConfig.Repositories) - 1; i >= 0; i-- {
|
||||
if BPMConfig.Repositories[i].Disabled != nil && *BPMConfig.Repositories[i].Disabled {
|
||||
BPMConfig.Repositories = append(BPMConfig.Repositories[:i], BPMConfig.Repositories[i+1:]...)
|
||||
}
|
||||
}
|
||||
for _, repo := range BPMConfig.Repositories {
|
||||
repo.Entries = make(map[string]*RepositoryEntry)
|
||||
err := repo.ReadLocalDatabase()
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
package bpm_utils
|
||||
package utils
|
||||
|
||||
import (
|
||||
"io"
|
||||
@@ -1,4 +1,4 @@
|
||||
package bpm_utils
|
||||
package utils
|
||||
|
||||
import (
|
||||
"archive/tar"
|
||||
@@ -6,6 +6,7 @@ import (
|
||||
"compress/gzip"
|
||||
"errors"
|
||||
"fmt"
|
||||
"gopkg.in/yaml.v3"
|
||||
"io"
|
||||
"io/fs"
|
||||
"os"
|
||||
@@ -19,17 +20,61 @@ import (
|
||||
)
|
||||
|
||||
type PackageInfo struct {
|
||||
Name string
|
||||
Description string
|
||||
Version string
|
||||
Url string
|
||||
License string
|
||||
Arch string
|
||||
Type string
|
||||
Keep []string
|
||||
Depends []string
|
||||
MakeDepends []string
|
||||
Provides []string
|
||||
Name string `yaml:"name,omitempty"`
|
||||
Description string `yaml:"description,omitempty"`
|
||||
Version string `yaml:"version,omitempty"`
|
||||
Revision int `yaml:"revision,omitempty"`
|
||||
Url string `yaml:"url,omitempty"`
|
||||
License string `yaml:"license,omitempty"`
|
||||
Arch string `yaml:"architecture,omitempty"`
|
||||
Type string `yaml:"type,omitempty"`
|
||||
Keep []string `yaml:"keep,omitempty"`
|
||||
Depends []string `yaml:"depends,omitempty"`
|
||||
MakeDepends []string `yaml:"make_depends,omitempty"`
|
||||
OptionalDepends []string `yaml:"optional_depends,omitempty"`
|
||||
Conflicts []string `yaml:"conflicts,omitempty"`
|
||||
Provides []string `yaml:"provides,omitempty"`
|
||||
}
|
||||
|
||||
func (pkgInfo *PackageInfo) GetFullVersion() string {
|
||||
return pkgInfo.Version + "-" + strconv.Itoa(pkgInfo.Revision)
|
||||
}
|
||||
|
||||
type InstallationReason string
|
||||
|
||||
const (
|
||||
Manual InstallationReason = "manual"
|
||||
Dependency InstallationReason = "dependency"
|
||||
Unknown InstallationReason = "unknown"
|
||||
)
|
||||
|
||||
func GetInstallationReason(pkg, rootDir string) InstallationReason {
|
||||
installedDir := path.Join(rootDir, "var/lib/bpm/installed/")
|
||||
pkgDir := path.Join(installedDir, pkg)
|
||||
if stat, err := os.Stat(path.Join(pkgDir, "installation_reason")); err != nil || stat.IsDir() {
|
||||
return Manual
|
||||
}
|
||||
bytes, err := os.ReadFile(path.Join(pkgDir, "installation_reason"))
|
||||
if err != nil {
|
||||
return Unknown
|
||||
}
|
||||
reason := string(bytes)
|
||||
if reason == "manual" {
|
||||
return Manual
|
||||
} else if reason == "dependency" {
|
||||
return Dependency
|
||||
}
|
||||
return Unknown
|
||||
}
|
||||
|
||||
func SetInstallationReason(pkg string, reason InstallationReason, rootDir string) error {
|
||||
installedDir := path.Join(rootDir, "var/lib/bpm/installed/")
|
||||
pkgDir := path.Join(installedDir, pkg)
|
||||
err := os.WriteFile(path.Join(pkgDir, "installation_reason"), []byte(reason), 0644)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func GetPackageInfoRaw(filename string) (string, error) {
|
||||
@@ -92,7 +137,7 @@ func ReadPackage(filename string) (*PackageInfo, error) {
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
pkgInfo, err := ReadPackageInfo(string(bs), false)
|
||||
pkgInfo, err := ReadPackageInfo(string(bs))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -266,114 +311,86 @@ func ExecutePackageScripts(filename, rootDir string, operation Operation, postOp
|
||||
return nil
|
||||
}
|
||||
|
||||
func ReadPackageInfo(contents string, defaultValues bool) (*PackageInfo, error) {
|
||||
func ReadPackageInfo(contents string) (*PackageInfo, error) {
|
||||
pkgInfo := PackageInfo{
|
||||
Name: "",
|
||||
Description: "",
|
||||
Version: "",
|
||||
Url: "",
|
||||
License: "",
|
||||
Arch: "",
|
||||
Type: "",
|
||||
Keep: nil,
|
||||
Depends: nil,
|
||||
MakeDepends: nil,
|
||||
Provides: nil,
|
||||
Name: "",
|
||||
Description: "",
|
||||
Version: "",
|
||||
Revision: 1,
|
||||
Url: "",
|
||||
License: "",
|
||||
Arch: "",
|
||||
Type: "",
|
||||
Keep: make([]string, 0),
|
||||
Depends: make([]string, 0),
|
||||
MakeDepends: make([]string, 0),
|
||||
OptionalDepends: make([]string, 0),
|
||||
Conflicts: make([]string, 0),
|
||||
Provides: make([]string, 0),
|
||||
}
|
||||
lines := strings.Split(contents, "\n")
|
||||
for num, line := range lines {
|
||||
if len(strings.TrimSpace(line)) == 0 {
|
||||
continue
|
||||
}
|
||||
if line[0] == '#' {
|
||||
continue
|
||||
}
|
||||
split := strings.SplitN(line, ":", 2)
|
||||
if len(split) != 2 {
|
||||
return nil, errors.New("invalid pkg.info format at line " + strconv.Itoa(num))
|
||||
}
|
||||
split[0] = strings.Trim(split[0], " ")
|
||||
split[1] = strings.Trim(split[1], " ")
|
||||
switch split[0] {
|
||||
case "name":
|
||||
if strings.Contains(split[1], " ") {
|
||||
return nil, errors.New("the " + split[0] + " field cannot contain spaces")
|
||||
}
|
||||
pkgInfo.Name = split[1]
|
||||
case "description":
|
||||
pkgInfo.Description = split[1]
|
||||
case "version":
|
||||
if strings.Contains(split[1], " ") {
|
||||
return nil, errors.New("the " + split[0] + " field cannot contain spaces")
|
||||
}
|
||||
pkgInfo.Version = split[1]
|
||||
case "url":
|
||||
pkgInfo.Url = split[1]
|
||||
case "license":
|
||||
pkgInfo.License = split[1]
|
||||
case "architecture":
|
||||
pkgInfo.Arch = split[1]
|
||||
case "type":
|
||||
pkgInfo.Type = split[1]
|
||||
case "keep":
|
||||
pkgInfo.Keep = strings.Split(strings.Replace(split[1], " ", "", -1), ",")
|
||||
pkgInfo.Keep = stringSliceRemoveEmpty(pkgInfo.Keep)
|
||||
case "depends":
|
||||
pkgInfo.Depends = strings.Split(strings.Replace(split[1], " ", "", -1), ",")
|
||||
pkgInfo.Depends = stringSliceRemoveEmpty(pkgInfo.Depends)
|
||||
case "make_depends":
|
||||
pkgInfo.MakeDepends = strings.Split(strings.Replace(split[1], " ", "", -1), ",")
|
||||
pkgInfo.MakeDepends = stringSliceRemoveEmpty(pkgInfo.MakeDepends)
|
||||
case "provides":
|
||||
pkgInfo.Provides = strings.Split(strings.Replace(split[1], " ", "", -1), ",")
|
||||
pkgInfo.Provides = stringSliceRemoveEmpty(pkgInfo.Provides)
|
||||
}
|
||||
err := yaml.Unmarshal([]byte(contents), &pkgInfo)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if !defaultValues {
|
||||
if pkgInfo.Name == "" {
|
||||
return nil, errors.New("this package contains no name")
|
||||
} else if pkgInfo.Description == "" {
|
||||
return nil, errors.New("this package contains no description")
|
||||
} else if pkgInfo.Version == "" {
|
||||
return nil, errors.New("this package contains no version")
|
||||
} else if pkgInfo.Arch == "" {
|
||||
return nil, errors.New("this package contains no architecture")
|
||||
} else if pkgInfo.Type == "" {
|
||||
return nil, errors.New("this package contains no type")
|
||||
}
|
||||
if pkgInfo.Name == "" {
|
||||
return nil, errors.New("this package contains no name")
|
||||
} else if pkgInfo.Description == "" {
|
||||
return nil, errors.New("this package contains no description")
|
||||
} else if pkgInfo.Version == "" {
|
||||
return nil, errors.New("this package contains no version")
|
||||
} else if pkgInfo.Revision <= 0 {
|
||||
return nil, errors.New("this package contains a revision number less or equal to 0")
|
||||
} else if pkgInfo.Arch == "" {
|
||||
return nil, errors.New("this package contains no architecture")
|
||||
} else if pkgInfo.Type == "" {
|
||||
return nil, errors.New("this package contains no type")
|
||||
}
|
||||
for i := 0; i < len(pkgInfo.Keep); i++ {
|
||||
pkgInfo.Keep[i] = strings.TrimPrefix(pkgInfo.Keep[i], "/")
|
||||
}
|
||||
return &pkgInfo, nil
|
||||
}
|
||||
|
||||
func CreateInfoFile(pkgInfo PackageInfo, keepSourceFields bool) string {
|
||||
ret := ""
|
||||
ret = ret + "name: " + pkgInfo.Name + "\n"
|
||||
ret = ret + "description: " + pkgInfo.Description + "\n"
|
||||
ret = ret + "version: " + pkgInfo.Version + "\n"
|
||||
if pkgInfo.Url != "" {
|
||||
ret = ret + "url: " + pkgInfo.Url + "\n"
|
||||
func CreateInfoFile(pkgInfo *PackageInfo) string {
|
||||
bytes, err := yaml.Marshal(&pkgInfo)
|
||||
if err != nil {
|
||||
return ""
|
||||
}
|
||||
if pkgInfo.License != "" {
|
||||
ret = ret + "license: " + pkgInfo.License + "\n"
|
||||
}
|
||||
ret = ret + "architecture: " + pkgInfo.Arch + "\n"
|
||||
ret = ret + "type: " + pkgInfo.Type + "\n"
|
||||
if len(pkgInfo.Keep) > 0 {
|
||||
ret = ret + "keep (" + strconv.Itoa(len(pkgInfo.Keep)) + "): " + strings.Join(pkgInfo.Keep, ",") + "\n"
|
||||
}
|
||||
if len(pkgInfo.Depends) > 0 {
|
||||
ret = ret + "depends (" + strconv.Itoa(len(pkgInfo.Depends)) + "): " + strings.Join(pkgInfo.Depends, ",") + "\n"
|
||||
}
|
||||
if len(pkgInfo.MakeDepends) > 0 && keepSourceFields {
|
||||
ret = ret + "make_depends (" + strconv.Itoa(len(pkgInfo.MakeDepends)) + "): " + strings.Join(pkgInfo.MakeDepends, ",") + "\n"
|
||||
}
|
||||
if len(pkgInfo.Provides) > 0 {
|
||||
ret = ret + "provides (" + strconv.Itoa(len(pkgInfo.Provides)) + "): " + strings.Join(pkgInfo.Provides, ",") + "\n"
|
||||
}
|
||||
return ret
|
||||
return string(bytes)
|
||||
}
|
||||
|
||||
func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []string) {
|
||||
func CreateReadableInfo(showArchitecture, showType, showPackageRelations bool, pkgInfo *PackageInfo, rootDir string) string {
|
||||
ret := make([]string, 0)
|
||||
appendArray := func(label string, array []string) {
|
||||
if len(array) == 0 {
|
||||
return
|
||||
}
|
||||
ret = append(ret, fmt.Sprintf("%s: %s", label, strings.Join(array, ", ")))
|
||||
}
|
||||
ret = append(ret, "Name: "+pkgInfo.Name)
|
||||
ret = append(ret, "Description: "+pkgInfo.Description)
|
||||
ret = append(ret, "Version: "+pkgInfo.GetFullVersion())
|
||||
ret = append(ret, "URL: "+pkgInfo.Url)
|
||||
ret = append(ret, "License: "+pkgInfo.License)
|
||||
if showArchitecture {
|
||||
ret = append(ret, "Architecture: "+pkgInfo.Arch)
|
||||
}
|
||||
if showType {
|
||||
ret = append(ret, "Type: "+pkgInfo.Type)
|
||||
}
|
||||
if showPackageRelations {
|
||||
appendArray("Dependencies", pkgInfo.Depends)
|
||||
appendArray("Make Dependencies", pkgInfo.MakeDepends)
|
||||
appendArray("Optional dependencies", pkgInfo.OptionalDepends)
|
||||
appendArray("Conflicting packages", pkgInfo.Conflicts)
|
||||
appendArray("Provided packages", pkgInfo.Provides)
|
||||
|
||||
}
|
||||
ret = append(ret, "Installation Reason: "+string(GetInstallationReason(pkgInfo.Name, rootDir)))
|
||||
return strings.Join(ret, "\n")
|
||||
}
|
||||
|
||||
func extractPackage(pkgInfo *PackageInfo, verbose bool, filename, rootDir string) (error, []string) {
|
||||
var files []string
|
||||
if !IsPackageInstalled(pkgInfo.Name, rootDir) {
|
||||
err := ExecutePackageScripts(filename, rootDir, Install, false)
|
||||
@@ -415,22 +432,46 @@ func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []st
|
||||
return err, nil
|
||||
}
|
||||
} else {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
}
|
||||
}
|
||||
case tar.TypeReg:
|
||||
skip := false
|
||||
if _, err := os.Stat(extractFilename); err == nil {
|
||||
if slices.Contains(pkgInfo.Keep, trimmedName) {
|
||||
fmt.Println("Skipping File: " + extractFilename + "(File is configured to be kept during installs/updates)")
|
||||
files = append(files, trimmedName)
|
||||
continue
|
||||
for _, k := range pkgInfo.Keep {
|
||||
if strings.HasSuffix(k, "/") {
|
||||
if strings.HasPrefix(trimmedName, k) {
|
||||
if verbose {
|
||||
fmt.Println("Skipping File: " + extractFilename + " (Containing directory is set to be kept during installs/updates)")
|
||||
}
|
||||
files = append(files, strings.TrimPrefix(header.Name, "files/"))
|
||||
skip = true
|
||||
continue
|
||||
}
|
||||
} else {
|
||||
if trimmedName == k {
|
||||
if verbose {
|
||||
fmt.Println("Skipping File: " + extractFilename + " (File is configured to be kept during installs/updates)")
|
||||
}
|
||||
files = append(files, strings.TrimPrefix(header.Name, "files/"))
|
||||
skip = true
|
||||
continue
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if skip {
|
||||
continue
|
||||
}
|
||||
err := os.Remove(extractFilename)
|
||||
if err != nil && !os.IsNotExist(err) {
|
||||
return err, nil
|
||||
}
|
||||
outFile, err := os.Create(extractFilename)
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
}
|
||||
files = append(files, strings.TrimPrefix(header.Name, "files/"))
|
||||
if err != nil {
|
||||
return err, nil
|
||||
@@ -446,7 +487,9 @@ func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []st
|
||||
return err, nil
|
||||
}
|
||||
case tar.TypeSymlink:
|
||||
fmt.Println("Creating Symlink: " + extractFilename + " -> " + header.Linkname)
|
||||
if verbose {
|
||||
fmt.Println("Creating Symlink: " + extractFilename + " -> " + header.Linkname)
|
||||
}
|
||||
files = append(files, strings.TrimPrefix(header.Name, "files/"))
|
||||
err := os.Remove(extractFilename)
|
||||
if err != nil && !os.IsNotExist(err) {
|
||||
@@ -457,7 +500,9 @@ func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []st
|
||||
return err, nil
|
||||
}
|
||||
case tar.TypeLink:
|
||||
fmt.Println("Detected Hard Link: " + extractFilename + " -> " + path.Join(rootDir, strings.TrimPrefix(header.Linkname, "files/")))
|
||||
if verbose {
|
||||
fmt.Println("Detected Hard Link: " + extractFilename + " -> " + path.Join(rootDir, strings.TrimPrefix(header.Linkname, "files/")))
|
||||
}
|
||||
files = append(files, strings.TrimPrefix(header.Name, "files/"))
|
||||
seenHardlinks[extractFilename] = path.Join(strings.TrimPrefix(header.Linkname, "files/"))
|
||||
err := os.Remove(extractFilename)
|
||||
@@ -465,12 +510,14 @@ func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []st
|
||||
return err, nil
|
||||
}
|
||||
default:
|
||||
return errors.New("ExtractTarGz: unknown type: " + strconv.Itoa(int(header.Typeflag)) + " in " + extractFilename), nil
|
||||
return errors.New("unknown type (" + strconv.Itoa(int(header.Typeflag)) + ") in " + extractFilename), nil
|
||||
}
|
||||
}
|
||||
}
|
||||
for extractFilename, destination := range seenHardlinks {
|
||||
fmt.Println("Creating Hard Link: " + extractFilename + " -> " + path.Join(rootDir, destination))
|
||||
if verbose {
|
||||
fmt.Println("Creating Hard Link: " + extractFilename + " -> " + path.Join(rootDir, destination))
|
||||
}
|
||||
err := os.Link(path.Join(rootDir, destination), extractFilename)
|
||||
if err != nil {
|
||||
return err, nil
|
||||
@@ -481,7 +528,22 @@ func extractPackage(pkgInfo *PackageInfo, filename, rootDir string) (error, []st
|
||||
return nil, files
|
||||
}
|
||||
|
||||
func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, binaryPkgFromSrc, skipCheck, keepTempDir bool) (error, []string) {
|
||||
func isSplitPackage(filename string) bool {
|
||||
pkgInfo, err := ReadPackage(filename)
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
if pkgInfo.Type != "source" {
|
||||
return false
|
||||
}
|
||||
cmd := exec.Command("/bin/bash", "-c", fmt.Sprintf("test $(tar -tf %s | grep '^pkg.info' | wc -l) -eq 1", filename))
|
||||
if err := cmd.Run(); err == nil {
|
||||
return false
|
||||
}
|
||||
return true
|
||||
}
|
||||
|
||||
func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, verbose, binaryPkgFromSrc, skipCheck, keepTempDir bool) (error, []string) {
|
||||
var files []string
|
||||
if !IsPackageInstalled(pkgInfo.Name, rootDir) {
|
||||
err := ExecutePackageScripts(filename, rootDir, Install, false)
|
||||
@@ -510,7 +572,9 @@ func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, binaryPkgFro
|
||||
if err != nil {
|
||||
return err, nil
|
||||
}
|
||||
fmt.Println("Creating temp directory at: " + temp)
|
||||
if verbose {
|
||||
fmt.Println("Creating temp directory at: " + temp)
|
||||
}
|
||||
err = os.Mkdir(temp, 0755)
|
||||
if err != nil {
|
||||
return err, nil
|
||||
@@ -537,7 +601,9 @@ func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, binaryPkgFro
|
||||
return err, nil
|
||||
}
|
||||
} else {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
}
|
||||
err = os.Chown(extractFilename, 65534, 65534)
|
||||
if err != nil {
|
||||
return err, nil
|
||||
@@ -549,7 +615,9 @@ func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, binaryPkgFro
|
||||
return err, nil
|
||||
}
|
||||
outFile, err := os.Create(extractFilename)
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
}
|
||||
if err != nil {
|
||||
return err, nil
|
||||
}
|
||||
@@ -568,11 +636,15 @@ func compilePackage(pkgInfo *PackageInfo, filename, rootDir string, binaryPkgFro
|
||||
return err, nil
|
||||
}
|
||||
case tar.TypeSymlink:
|
||||
fmt.Println("Skipping symlink (Bundling symlinks in source packages is not supported)")
|
||||
if verbose {
|
||||
fmt.Println("Skipping symlink (Bundling symlinks in source packages is not supported)")
|
||||
}
|
||||
case tar.TypeLink:
|
||||
fmt.Println("Skipping hard link (Bundling hard links in source packages is not supported)")
|
||||
if verbose {
|
||||
fmt.Println("Skipping hard link (Bundling hard links in source packages is not supported)")
|
||||
}
|
||||
default:
|
||||
return errors.New("ExtractTarGz: unknown type: " + strconv.Itoa(int(header.Typeflag)) + " in " + extractFilename), nil
|
||||
return errors.New("unknown type (" + strconv.Itoa(int(header.Typeflag)) + ") in " + extractFilename), nil
|
||||
}
|
||||
}
|
||||
if header.Name == "source.sh" {
|
||||
@@ -668,7 +740,6 @@ if [ $? -ne 0 ]; then
|
||||
echo "Failed to run package() function in source.sh"
|
||||
fi
|
||||
`
|
||||
|
||||
err = os.WriteFile(path.Join(temp, "run.sh"), []byte(runScript), 0644)
|
||||
if err != nil {
|
||||
return err, nil
|
||||
@@ -711,6 +782,7 @@ fi
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_NAME=%s", pkgInfo.Name))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_DESC=%s", pkgInfo.Description))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_VERSION=%s", pkgInfo.Version))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_REVISION=%d", pkgInfo.Revision))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_URL=%s", pkgInfo.Url))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_ARCH=%s", pkgInfo.Arch))
|
||||
depends := make([]string, len(pkgInfo.Depends))
|
||||
@@ -765,12 +837,16 @@ fi
|
||||
return err
|
||||
}
|
||||
} else {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating Directory: " + extractFilename)
|
||||
}
|
||||
}
|
||||
} else if d.Type().IsRegular() {
|
||||
if _, err := os.Stat(extractFilename); err == nil {
|
||||
if slices.Contains(pkgInfo.Keep, relFilename) {
|
||||
fmt.Println("Skipping File: " + extractFilename + "(File is configured to be kept during installs/updates)")
|
||||
if verbose {
|
||||
fmt.Println("Skipping File: " + extractFilename + "(File is configured to be kept during installs/updates)")
|
||||
}
|
||||
files = append(files, relFilename)
|
||||
return nil
|
||||
}
|
||||
@@ -780,7 +856,9 @@ fi
|
||||
return err
|
||||
}
|
||||
outFile, err := os.Create(extractFilename)
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
if verbose {
|
||||
fmt.Println("Creating File: " + extractFilename)
|
||||
}
|
||||
files = append(files, relFilename)
|
||||
if err != nil {
|
||||
return err
|
||||
@@ -816,7 +894,9 @@ fi
|
||||
if err != nil && !os.IsNotExist(err) {
|
||||
return err
|
||||
}
|
||||
fmt.Println("Creating Symlink: "+extractFilename, " -> "+link)
|
||||
if verbose {
|
||||
fmt.Println("Creating Symlink: "+extractFilename, " -> "+link)
|
||||
}
|
||||
files = append(files, relFilename)
|
||||
err = os.Symlink(link, extractFilename)
|
||||
if err != nil {
|
||||
@@ -835,7 +915,7 @@ fi
|
||||
compiledInfo = *pkgInfo
|
||||
compiledInfo.Type = "binary"
|
||||
compiledInfo.Arch = GetArch()
|
||||
err = os.WriteFile(path.Join(temp, "pkg.info"), []byte(CreateInfoFile(compiledInfo, false)), 0644)
|
||||
err = os.WriteFile(path.Join(temp, "pkg.info"), []byte(CreateInfoFile(&compiledInfo)), 0644)
|
||||
if err != nil {
|
||||
return err, nil
|
||||
}
|
||||
@@ -855,7 +935,7 @@ fi
|
||||
}
|
||||
}
|
||||
sed := fmt.Sprintf("s/output/files/")
|
||||
fileName := compiledInfo.Name + "-" + compiledInfo.Version + "-" + compiledInfo.Arch + ".bpm"
|
||||
fileName := compiledInfo.Name + "-" + compiledInfo.GetFullVersion() + "-" + compiledInfo.Arch + ".bpm"
|
||||
cmd := exec.Command("/usr/bin/fakeroot", "-i fakeroot_file", "tar", "-czvpf", fileName, "pkg.info", "output/", "--transform", sed)
|
||||
if !BPMConfig.SilentCompilation {
|
||||
cmd.Stdin = os.Stdin
|
||||
@@ -895,7 +975,7 @@ fi
|
||||
return nil, files
|
||||
}
|
||||
|
||||
func InstallPackage(filename, rootDir string, force, binaryPkgFromSrc, skipCheck, keepTempDir bool) error {
|
||||
func InstallPackage(filename, rootDir string, verbose, force, binaryPkgFromSrc, skipCheck, keepTempDir bool) error {
|
||||
if _, err := os.Stat(filename); os.IsNotExist(err) {
|
||||
return err
|
||||
}
|
||||
@@ -913,24 +993,27 @@ func InstallPackage(filename, rootDir string, force, binaryPkgFromSrc, skipCheck
|
||||
if pkgInfo.Arch != "any" && pkgInfo.Arch != GetArch() {
|
||||
return errors.New("cannot install a package with a different architecture")
|
||||
}
|
||||
if unresolved := CheckDependencies(pkgInfo, rootDir); len(unresolved) != 0 {
|
||||
return errors.New("Could not resolve all dependencies. Missing " + strings.Join(unresolved, ", "))
|
||||
if unresolved := pkgInfo.CheckDependencies(pkgInfo.Type == "source", true, rootDir); len(unresolved) != 0 {
|
||||
return errors.New("the following dependencies are not installed: " + strings.Join(unresolved, ", "))
|
||||
}
|
||||
}
|
||||
if pkgInfo.Type == "binary" {
|
||||
err, i := extractPackage(pkgInfo, filename, rootDir)
|
||||
err, i := extractPackage(pkgInfo, verbose, filename, rootDir)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
files = i
|
||||
} else if pkgInfo.Type == "source" {
|
||||
err, i := compilePackage(pkgInfo, filename, rootDir, binaryPkgFromSrc, skipCheck, keepTempDir)
|
||||
if isSplitPackage(filename) {
|
||||
return errors.New("BPM is unable to install split source packages")
|
||||
}
|
||||
err, i := compilePackage(pkgInfo, filename, rootDir, verbose, binaryPkgFromSrc, skipCheck, keepTempDir)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
files = i
|
||||
} else {
|
||||
return errors.New("Unknown package type: " + pkgInfo.Type)
|
||||
return errors.New("unknown package type: " + pkgInfo.Type)
|
||||
}
|
||||
slices.Sort(files)
|
||||
slices.Reverse(files)
|
||||
@@ -1006,7 +1089,7 @@ func InstallPackage(filename, rootDir string, force, binaryPkgFromSrc, skipCheck
|
||||
}
|
||||
|
||||
if len(filesDiff) != 0 {
|
||||
fmt.Println("Removing obsolete files")
|
||||
fmt.Println("Removing obsolete files...")
|
||||
var symlinks []string
|
||||
for _, f := range filesDiff {
|
||||
f = path.Join(rootDir, f)
|
||||
@@ -1032,14 +1115,18 @@ func InstallPackage(filename, rootDir string, force, binaryPkgFromSrc, skipCheck
|
||||
return err
|
||||
}
|
||||
if len(dir) == 0 {
|
||||
fmt.Println("Removing: " + f)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + f)
|
||||
}
|
||||
err := os.Remove(f)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
} else {
|
||||
fmt.Println("Removing: " + f)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + f)
|
||||
}
|
||||
err := os.Remove(f)
|
||||
if err != nil {
|
||||
return err
|
||||
@@ -1065,7 +1152,9 @@ func InstallPackage(filename, rootDir string, force, binaryPkgFromSrc, skipCheck
|
||||
return err
|
||||
}
|
||||
removals++
|
||||
fmt.Println("Removing: " + f)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + f)
|
||||
}
|
||||
} else if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -1127,24 +1216,75 @@ func GetSourceScript(filename string) (string, error) {
|
||||
return "", errors.New("package does not contain a source.sh file")
|
||||
}
|
||||
|
||||
func CheckDependencies(pkgInfo *PackageInfo, rootDir string) []string {
|
||||
var unresolved []string
|
||||
for _, dependency := range pkgInfo.Depends {
|
||||
if !IsPackageInstalled(dependency, rootDir) {
|
||||
unresolved = append(unresolved, dependency)
|
||||
}
|
||||
func (pkgInfo *PackageInfo) GetAllDependencies(checkMake, checkOptional bool) []string {
|
||||
allDepends := make([]string, 0)
|
||||
allDepends = append(allDepends, pkgInfo.Depends...)
|
||||
if checkMake {
|
||||
allDepends = append(allDepends, pkgInfo.MakeDepends...)
|
||||
}
|
||||
return unresolved
|
||||
if checkOptional {
|
||||
allDepends = append(allDepends, pkgInfo.OptionalDepends...)
|
||||
}
|
||||
return allDepends
|
||||
}
|
||||
|
||||
func CheckMakeDependencies(pkgInfo *PackageInfo, rootDir string) []string {
|
||||
var unresolved []string
|
||||
for _, dependency := range pkgInfo.MakeDepends {
|
||||
if !IsPackageInstalled(dependency, "/") {
|
||||
unresolved = append(unresolved, dependency)
|
||||
func (pkgInfo *PackageInfo) CheckDependencies(checkMake, checkOptional bool, rootDir string) []string {
|
||||
var ret []string
|
||||
for _, dependency := range pkgInfo.Depends {
|
||||
if !IsPackageProvided(dependency, rootDir) {
|
||||
ret = append(ret, dependency)
|
||||
}
|
||||
}
|
||||
return unresolved
|
||||
if checkMake {
|
||||
for _, dependency := range pkgInfo.MakeDepends {
|
||||
if !IsPackageProvided(dependency, rootDir) {
|
||||
ret = append(ret, dependency)
|
||||
}
|
||||
}
|
||||
}
|
||||
if checkOptional {
|
||||
for _, dependency := range pkgInfo.OptionalDepends {
|
||||
if !IsPackageProvided(dependency, rootDir) {
|
||||
ret = append(ret, dependency)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return ret
|
||||
}
|
||||
|
||||
func (pkgInfo *PackageInfo) CheckConflicts(rootDir string) []string {
|
||||
var ret []string
|
||||
for _, conflict := range pkgInfo.Conflicts {
|
||||
if IsPackageInstalled(conflict, rootDir) {
|
||||
ret = append(ret, conflict)
|
||||
}
|
||||
}
|
||||
return ret
|
||||
}
|
||||
|
||||
func (pkgInfo *PackageInfo) ResolveAll(resolved, unresolved *[]string, checkMake, checkOptional, ignoreInstalled bool, rootDir string) ([]string, []string) {
|
||||
*unresolved = append(*unresolved, pkgInfo.Name)
|
||||
for _, depend := range pkgInfo.GetAllDependencies(checkMake, checkOptional) {
|
||||
if !slices.Contains(*resolved, depend) {
|
||||
if slices.Contains(*unresolved, depend) || (ignoreInstalled && IsPackageInstalled(depend, rootDir)) {
|
||||
continue
|
||||
}
|
||||
entry, _, err := GetRepositoryEntry(depend)
|
||||
if err != nil {
|
||||
if !slices.Contains(*unresolved, depend) {
|
||||
*unresolved = append(*unresolved, depend)
|
||||
}
|
||||
continue
|
||||
}
|
||||
entry.Info.ResolveAll(resolved, unresolved, checkMake, checkOptional, ignoreInstalled, rootDir)
|
||||
}
|
||||
}
|
||||
if !slices.Contains(*resolved, pkgInfo.Name) {
|
||||
*resolved = append(*resolved, pkgInfo.Name)
|
||||
}
|
||||
*unresolved = stringSliceRemove(*unresolved, pkgInfo.Name)
|
||||
return *resolved, *unresolved
|
||||
}
|
||||
|
||||
func IsPackageInstalled(pkg, rootDir string) bool {
|
||||
@@ -1156,6 +1296,26 @@ func IsPackageInstalled(pkg, rootDir string) bool {
|
||||
return true
|
||||
}
|
||||
|
||||
func IsPackageProvided(pkg, rootDir string) bool {
|
||||
pkgs, err := GetInstalledPackages(rootDir)
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
for _, p := range pkgs {
|
||||
if p == pkg {
|
||||
return true
|
||||
}
|
||||
i := GetPackageInfo(p, rootDir, true)
|
||||
if i == nil {
|
||||
continue
|
||||
}
|
||||
if slices.Contains(i.Provides, pkg) {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
func GetInstalledPackages(rootDir string) ([]string, error) {
|
||||
installedDir := path.Join(rootDir, "var/lib/bpm/installed/")
|
||||
items, err := os.ReadDir(installedDir)
|
||||
@@ -1212,14 +1372,14 @@ func GetPackageInfo(pkg, rootDir string, defaultValues bool) *PackageInfo {
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
info, err := ReadPackageInfo(string(bs), defaultValues)
|
||||
info, err := ReadPackageInfo(string(bs))
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
return info
|
||||
}
|
||||
|
||||
func RemovePackage(pkg, rootDir string) error {
|
||||
func RemovePackage(pkg string, verbose bool, rootDir string) error {
|
||||
installedDir := path.Join(rootDir, "var/lib/bpm/installed/")
|
||||
pkgDir := path.Join(installedDir, pkg)
|
||||
pkgInfo := GetPackageInfo(pkg, rootDir, false)
|
||||
@@ -1254,14 +1414,18 @@ func RemovePackage(pkg, rootDir string) error {
|
||||
return err
|
||||
}
|
||||
if len(dir) == 0 {
|
||||
fmt.Println("Removing: " + file)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + file)
|
||||
}
|
||||
err := os.Remove(file)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
} else {
|
||||
fmt.Println("Removing: " + file)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + file)
|
||||
}
|
||||
err := os.Remove(file)
|
||||
if err != nil {
|
||||
return err
|
||||
@@ -1287,7 +1451,9 @@ func RemovePackage(pkg, rootDir string) error {
|
||||
return err
|
||||
}
|
||||
removals++
|
||||
fmt.Println("Removing: " + file)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + file)
|
||||
}
|
||||
} else if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -1306,6 +1472,7 @@ func RemovePackage(pkg, rootDir string) error {
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_NAME=%s", pkgInfo.Name))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_DESC=%s", pkgInfo.Description))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_VERSION=%s", pkgInfo.Version))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_REVISION=%d", pkgInfo.Revision))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_URL=%s", pkgInfo.Url))
|
||||
cmd.Env = append(cmd.Env, fmt.Sprintf("BPM_PKG_ARCH=%s", pkgInfo.Arch))
|
||||
depends := make([]string, len(pkgInfo.Depends))
|
||||
@@ -1330,6 +1497,8 @@ func RemovePackage(pkg, rootDir string) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
fmt.Println("Removing: " + pkgDir)
|
||||
if verbose {
|
||||
fmt.Println("Removing: " + pkgDir)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@@ -0,0 +1,166 @@
|
||||
package utils
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"gopkg.in/yaml.v3"
|
||||
"io"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"os"
|
||||
"path"
|
||||
"strings"
|
||||
)
|
||||
|
||||
type Repository struct {
|
||||
Name string `yaml:"name"`
|
||||
Source string `yaml:"source"`
|
||||
Disabled *bool `yaml:"disabled"`
|
||||
Entries map[string]*RepositoryEntry
|
||||
}
|
||||
|
||||
type RepositoryEntry struct {
|
||||
Info *PackageInfo `yaml:"info"`
|
||||
Download string `yaml:"download"`
|
||||
}
|
||||
|
||||
func (repo *Repository) ContainsPackage(pkg string) bool {
|
||||
_, ok := repo.Entries[pkg]
|
||||
return ok
|
||||
}
|
||||
|
||||
func (repo *Repository) ReadLocalDatabase() error {
|
||||
repoFile := "/var/lib/bpm/repositories/" + repo.Name + ".bpmdb"
|
||||
if _, err := os.Stat(repoFile); err != nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
bytes, err := os.ReadFile(repoFile)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
data := string(bytes)
|
||||
for _, b := range strings.Split(data, "---") {
|
||||
entry := RepositoryEntry{
|
||||
Info: &PackageInfo{
|
||||
Name: "",
|
||||
Description: "",
|
||||
Version: "",
|
||||
Revision: 1,
|
||||
Url: "",
|
||||
License: "",
|
||||
Arch: "",
|
||||
Type: "",
|
||||
Keep: make([]string, 0),
|
||||
Depends: make([]string, 0),
|
||||
MakeDepends: make([]string, 0),
|
||||
OptionalDepends: make([]string, 0),
|
||||
Conflicts: make([]string, 0),
|
||||
Provides: make([]string, 0),
|
||||
},
|
||||
Download: "",
|
||||
}
|
||||
err := yaml.Unmarshal([]byte(b), &entry)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
repo.Entries[entry.Info.Name] = &entry
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (repo *Repository) SyncLocalDatabase() error {
|
||||
repoFile := "/var/lib/bpm/repositories/" + repo.Name + ".bpmdb"
|
||||
err := os.MkdirAll(path.Dir(repoFile), 0755)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
u, err := url.JoinPath(repo.Source, "database.bpmdb")
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
resp, err := http.Get(u)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
out, err := os.Create(repoFile)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer out.Close()
|
||||
|
||||
_, err = io.Copy(out, resp.Body)
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func GetRepository(name string) *Repository {
|
||||
for _, repo := range BPMConfig.Repositories {
|
||||
if repo.Name == name {
|
||||
return repo
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func GetRepositoryEntry(str string) (*RepositoryEntry, *Repository, error) {
|
||||
split := strings.Split(str, "/")
|
||||
if len(split) == 1 {
|
||||
pkgName := strings.TrimSpace(split[0])
|
||||
if pkgName == "" {
|
||||
return nil, nil, errors.New("could not find repository entry for this package")
|
||||
}
|
||||
for _, repo := range BPMConfig.Repositories {
|
||||
if repo.ContainsPackage(pkgName) {
|
||||
return repo.Entries[pkgName], repo, nil
|
||||
}
|
||||
}
|
||||
return nil, nil, errors.New("could not find repository entry for this package")
|
||||
} else if len(split) == 2 {
|
||||
repoName := strings.TrimSpace(split[0])
|
||||
pkgName := strings.TrimSpace(split[1])
|
||||
if repoName == "" || pkgName == "" {
|
||||
return nil, nil, errors.New("could not find repository entry for this package")
|
||||
}
|
||||
repo := GetRepository(repoName)
|
||||
if repo == nil || !repo.ContainsPackage(pkgName) {
|
||||
return nil, nil, errors.New("could not find repository entry for this package")
|
||||
}
|
||||
return repo.Entries[pkgName], repo, nil
|
||||
} else {
|
||||
return nil, nil, errors.New("could not find repository entry for this package")
|
||||
}
|
||||
}
|
||||
|
||||
func (repo *Repository) FetchPackage(pkg string) (string, error) {
|
||||
if !repo.ContainsPackage(pkg) {
|
||||
return "", errors.New("could not fetch package '" + pkg + "'")
|
||||
}
|
||||
entry := repo.Entries[pkg]
|
||||
URL, err := url.JoinPath(repo.Source, entry.Download)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
resp, err := http.Get(URL)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
err = os.MkdirAll("/var/cache/bpm/packages/", 0755)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
out, err := os.Create("/var/cache/bpm/packages/" + path.Base(entry.Download))
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
defer out.Close()
|
||||
|
||||
_, err = io.Copy(out, resp.Body)
|
||||
return "/var/cache/bpm/packages/" + path.Base(entry.Download), nil
|
||||
}
|
||||
Reference in New Issue
Block a user