feat(xfpm): add local package installation via path command and improve logger error output

Author: oxanmerym

cmd/xfpm/main.go

@@ -74,6 +74,7 @@ func init() {
 	installCmd.Flags().BoolP("force", "f", false, "Force re-install even if already extracted")
 	installCmd.Flags().Bool("update", false, "Update mode: always fetch fresh metadata from registry")
 	installCmd.Flags().BoolP("global", "g", false, "Install packages globally")
+	installCmd.Flags().StringP("path", "P", "", "Install from a local path")
 }
 
 
@@ -84,6 +85,7 @@ var installCmd = &cobra.Command{
 	RunE: func(cmd *cobra.Command, args []string) error {
 		startTime := time.Now()
 		global, _ := cmd.Flags().GetBool("global")
+		localPath, _ := cmd.Flags().GetString("path")
 
 		var projectRoot string
 		var err error
@@ -118,6 +120,10 @@ var installCmd = &cobra.Command{
 
 		rootDeps := make(map[string]string)
 		directPkgs := make(map[string]string)
+		
+		// Map for local packages: name -> absolute path
+		localPackages := make(map[string]string)
+
 		pkgJsonPath := filepath.Join(projectRoot, "package.json")
 		var pkg *core.PackageJson
 
@@ -130,9 +136,45 @@ var installCmd = &cobra.Command{
 			}
 		}
 
+		// Handle --path flag
+		if localPath != "" {
+			absPath, err := filepath.Abs(localPath)
+			if err == nil {
+				localPkg, err := core.LoadPackageJson(filepath.Join(absPath, "package.json"))
+				if err == nil {
+					localPackages[localPkg.Name] = absPath
+					rootDeps[localPkg.Name] = localPkg.Version
+					directPkgs[localPkg.Name] = localPkg.Version
+					if resolver.ForcePackages == nil {
+						resolver.ForcePackages = make(map[string]bool)
+					}
+					resolver.ForcePackages[localPkg.Name] = true
+				}
+			}
+		}
+
 		if len(args) > 0 {
-			resolver.ForcePackages = make(map[string]bool)
+			if resolver.ForcePackages == nil {
+				resolver.ForcePackages = make(map[string]bool)
+			}
 			for _, p := range args {
+				// Check if p is a local path
+				if strings.HasPrefix(p, "./") || strings.HasPrefix(p, "../") || filepath.IsAbs(p) {
+					absPath, err := filepath.Abs(p)
+					if err == nil {
+						if fi, err := os.Stat(absPath); err == nil && fi.IsDir() {
+							localPkg, err := core.LoadPackageJson(filepath.Join(absPath, "package.json"))
+							if err == nil {
+								localPackages[localPkg.Name] = absPath
+								rootDeps[localPkg.Name] = localPkg.Version
+								directPkgs[localPkg.Name] = localPkg.Version
+								resolver.ForcePackages[localPkg.Name] = true
+								continue
+							}
+						}
+					}
+				}
+
 				name := p
 				req := ""
 
@@ -176,6 +218,8 @@ var installCmd = &cobra.Command{
 			return fmt.Errorf("no package.json found and no packages specified")
 		}
 
+		resolver.SetLocalPackages(localPackages)
+
 		s, _ := pterm.DefaultSpinner.
 			WithRemoveWhenDone(true).
 			WithText("Analysing project tree...").
@@ -216,6 +260,12 @@ var installCmd = &cobra.Command{
 			return err
 		}
 
+		for _, p := range resolved {
+			if path, ok := localPackages[p.Name]; ok {
+				p.LocalPath = path
+			}
+		}
+
 		utils.Success("Dependency tree resolved successfully (%d total).", len(resolved))
 
 		installer := core.NewInstaller(cas, registry, projectRoot)
@@ -298,7 +348,7 @@ var installCmd = &cobra.Command{
 
 func main() {
 	if err := rootCmd.Execute(); err != nil {
-		fmt.Fprintf(os.Stderr, "Error: %v\n", err)
+		utils.Error("%v", err)
 		os.Exit(1)
 	}
 }

internal/core/installer.go

@@ -207,7 +207,73 @@ func (i *Installer) batchEnsureExtracted(ctx context.Context, packages []*Resolv
 	return nil
 }
 
+func (i *Installer) extractLocal(pkg *ResolvedPackage) error {
+	pkgVStoreName := strings.ReplaceAll(pkg.Name, "/", "+") + "@" + pkg.Version
+	pkgDir := filepath.Join(i.vstoreRoot, pkgVStoreName, "node_modules", pkg.Name)
+
+	// Surgically remove only the package content directory
+	os.RemoveAll(pkgDir)
+
+	pterm.Printf("   %s %-30s %s\n", utils.GreenColor.Sprint("├─"), pkg.Name+"@"+pkg.Version, utils.DimColor.Sprint("indexing local path..."))
+
+	fileMap := make(map[string]string)
+	
+	err := filepath.Walk(pkg.LocalPath, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+		if info.IsDir() {
+			if info.Name() == "node_modules" || info.Name() == ".git" || info.Name() == ".xpm" {
+				return filepath.SkipDir
+			}
+			return nil
+		}
+
+		relPath, err := filepath.Rel(pkg.LocalPath, path)
+		if err != nil {
+			return err
+		}
+
+		file, err := os.Open(path)
+		if err != nil {
+			return err
+		}
+		defer file.Close()
+
+		isExecutable := (info.Mode() & 0111) != 0
+		hash, err := i.cas.StoreStream(file, isExecutable)
+		if err != nil {
+			return err
+		}
+
+		fileMap["package/"+relPath] = hash
+		return nil
+	})
+
+	if err != nil {
+		return err
+	}
+
+	// Store index in CAS
+	if err := i.cas.StoreIndex(pkg.Name, pkg.Version, fileMap); err != nil {
+		return err
+	}
+
+	if err := i.LinkFilesToDir(pkgDir, fileMap); err != nil {
+		return err
+	}
+
+	// Mark as changed
+	cacheKey := pkg.Name + "@" + pkg.Version
+	i.changedPackages.Store(cacheKey, true)
+	return nil
+}
+
 func (i *Installer) ensureExtracted(ctx context.Context, pkg *ResolvedPackage) error {
+	if pkg.LocalPath != "" {
+		return i.extractLocal(pkg)
+	}
+
 	pkgVStoreName := strings.ReplaceAll(pkg.Name, "/", "+") + "@" + pkg.Version
 	pkgDir := filepath.Join(i.vstoreRoot, pkgVStoreName, "node_modules", pkg.Name)
 

internal/core/resolver.go

@@ -3,6 +3,7 @@ package core
 import (
 	"context"
 	"fmt"
+	"path/filepath"
 	"runtime"
 	"strings"
 	"sync"
@@ -17,6 +18,7 @@ type ResolvedPackage struct {
 	SemverVersion        *semver.Version
 	Metadata             *VersionMetadata
 	ResolvedDependencies map[string]string
+	LocalPath            string // If set, this package is installed from a local path
 }
 
 type Platform struct {
@@ -166,6 +168,12 @@ type Resolver struct {
 	onProgress      func(string)
 	Update          bool            // Global update mode
 	ForcePackages   map[string]bool // Packages to force resolve (ignore cache)
+	LocalPackages   map[string]string // Package name -> local absolute path
+}
+
+
+func (r *Resolver) SetLocalPackages(local map[string]string) {
+	r.LocalPackages = local
 }
 
 func (r *Resolver) SetOnProgress(fn func(string)) {
@@ -326,12 +334,37 @@ func (r *Resolver) resolvePackage(ctx context.Context, name, req string, isOptio
 		utils.Log("FORCED", fmt.Sprintf("Fresh resolution for %s@%s", realName, realReq))
 	}
 
-	pkgInfo, err := r.registry.FetchPackage(ctx, realName, shouldForce)
-	if err != nil {
-		if isOptional {
-			return nil
+	var pkgInfo *RegistryPackage
+	var err error
+
+	if path, ok := r.LocalPackages[realName]; ok {
+		// Local package: load from disk
+		pkgJson, lerr := LoadPackageJson(filepath.Join(path, "package.json"))
+		if lerr != nil {
+			return fmt.Errorf("loading local package.json for %s: %w", realName, lerr)
+		}
+		pkgInfo = &RegistryPackage{
+			Name:     pkgJson.Name,
+			DistTags: map[string]string{"latest": pkgJson.Version},
+			Versions: map[string]VersionMetadata{
+				pkgJson.Version: {
+					Name:    pkgJson.Name,
+					Version: pkgJson.Version,
+					Dependencies: pkgJson.Dependencies,
+					OptionalDependencies: pkgJson.OptionalDependencies,
+					PeerDependencies: pkgJson.PeerDependencies,
+					// Bin and other fields will be handled by installer if needed
+				},
+			},
+		}
+	} else {
+		pkgInfo, err = r.registry.FetchPackage(ctx, realName, shouldForce)
+		if err != nil {
+			if isOptional {
+				return nil
+			}
+			return err
 		}
-		return err
 	}
 
 	version, err := r.bestMatch(pkgInfo, realReq)

internal/utils/lib_version.go

@@ -1,5 +1,5 @@
 package utils
 
 var (
-	BinVersion = "G0.1.48"
+	BinVersion = "G0.1.49"
 )

internal/utils/logger.go

@@ -31,7 +31,7 @@ func Info(format string, a ...any) {
 		},
 		MessageStyle: InfoColor,
 	}
-	printer.Printf(format, a...)
+	printer.Println(fmt.Sprintf(format, a...))
 }
 
 func Success(format string, a ...any) {
@@ -42,7 +42,7 @@ func Success(format string, a ...any) {
 		},
 		MessageStyle: SuccessColor,
 	}
-	printer.Printf(format, a...)
+	printer.Println(fmt.Sprintf(format, a...))
 }
 
 func Warn(format string, a ...any) {
@@ -53,7 +53,7 @@ func Warn(format string, a ...any) {
 		},
 		MessageStyle: WarnColor,
 	}
-	printer.Printf(format, a...)
+	printer.Println(fmt.Sprintf(format, a...))
 }
 
 func Error(format string, a ...any) {
@@ -64,7 +64,7 @@ func Error(format string, a ...any) {
 		},
 		MessageStyle: ErrorColor,
 	}
-	printer.Printf(format, a...)
+	printer.Println(fmt.Sprintf(format, a...))
 }
 
 func Log(prefix, msg string) {

version.json

@@ -2,7 +2,7 @@
   "name": "XFPM (XyPriss Package Manager)",
   "description": "The ultra-fast package manager for the XyPriss ecosystem.",
   "warning": "CRITICAL: Public modifications to this file are strictly forbidden. Internal Nehonix metadata ONLY.",
-  "latest": "G0.1.48",
+  "latest": "G0.1.49",
   "metadata": {
     "releaseDate": "2026-03-03",
     "channel": "stable"