diff --git a/README.md b/README.md deleted file mode 100644 index c3c1a08..0000000 --- a/README.md +++ /dev/null @@ -1,163 +0,0 @@ -# πŸ“¦ Packets – Custom Package Manager for Linux - -> A fast and minimal package manager written in Go with Lua hooks, local network discovery, and SQLite-based indexing. - ---- - -## πŸ“˜ Overview - -**Packets** is a lightweight package manager for Linux, written in Go. It supports: - -- Installation and removal of packages -- Dependency resolution and upgrading -- `.tar.zst` compressed packages with `manifest.toml` metadata -- Lua-based install/remove hooks -- Local cache with SHA-256 validation -- Peer-to-peer discovery over LAN -- Remote package syncing via HTTP -- SQLite-based local database - ---- - -## πŸ“ Directory Structure - -| Path | Description | -|-----------------------|----------------------------------| -| `/etc/packets/` | Configuration files | -| `/opt/packets/` | Installed package data | -| `/var/cache/packets/` | Cached `.tar.zst` package files | - -(This can be changed in `/etc/packets/config.toml`) - ---- - -# Available Commands - -| Command | Description | -|---------------------------|----------------------------------------------------------------------------| -|`packets install ` | Install a package (resolves dependencies, executes Lua install hook) | -|`packets remove ` | Remove a package (executes Lua remove hook) | -|`packets upgrade ` | Upgrade a package by checking family and serial in the manifest | -|`packets sync [url]` | Synchronize index.db from remote HTTP source | -|`packets serve init/stop` | Starts and stop the LAN service daemon | -|`packets list` | List all installed packages | -|`packets info` | Get technical package information | -|`packets search` | List all packages in index.db | - -# πŸ“¦ Package Format - -Packages must be compressed as .tar.zst and include: - - -- β”œβ”€β”€ manifest.toml # Package metadata -- β”œβ”€β”€ data/ # Files to install -- β”œβ”€β”€ install.lua # Lua install hook -- └── remove.lua # Lua remove hook - - -## Example manifest.toml - [Info] - name = "packets" - version = "1.0.0" - description = "offline and online packetmanager" - dependencies = [] - author = "robo" - family = "1f84ca15-5077-4f1d-a370-0ec860766eb2" - serial = 0 - - [Hooks] - install = "install.lua" - remove = "remove.lua" - --- -# πŸ”„ Installation Process - -- Check if package is already cached and validated via SHA-256. - -- If not, search the package: - - Via LAN: Sends UDP broadcast (Q:filename) to peers. - - Via HTTP: Downloads from configured mirrors. - - Decompress .tar.zst, install files. - - Execute Lua install hook. - -# 🧩 Core Features -βœ… Dependency Resolution - -Installs required dependencies listed in the manifest. -## 🌐 LAN Discovery - -Broadcasts package request to devices in the same network via UDP. -## πŸ“‘ Remote Download - -Downloads package via HTTP if not found on LAN. -## πŸ”’ Security - - SHA-256 checksum validation - - Path validation to avoid exploits (..) - - Safe, sandboxed Lua runtime with limited API - - -# 🌍 Global Variables Available in Lua Scripts - -During the execution of install.lua and remove.lua hooks, some global variables are automatically provided to the Lua environment. These help simplify file path handling and access to package-specific directories. -## Available variables: - -|Name |Type | Description -|--------------------|--------|--------------------------------------------------------------------------| -|packets_package_dir | string| Absolute path to the package's data directory (e.g., /opt/packets/...) | -| packets_bin_dir | string| Path where executables should be installed (e.g., /usr/bin) | -|script | string| Path to the currently executing script (e.g., "install.lua") | -|data_dir | string| Path to the /data folder of the current package | -### Example usage in Lua: - - print("Installing into: " .. packets_bin_dir) - print("Package data in: " .. data_dir) - - -- Copy a binary to /usr/bin - os.copy(path_join(data_dir, "htop"), path_join(packets_bin_dir, "htop")) - -These variables are preloaded in the Lua environmentβ€”no need to manually declare or initialize them. - - -## πŸ› οΈ Allowed Lua API (install/remove hooks) - -To ensure security, only a limited set of safe functions are exposed in Lua hooks: - - os.remove(path) - os.rename(old, new) - os.copy(source, target) - os.symlink(source, target) - io.open(path, mode) - os.mkdir(path, filemode) - path_join(...) - -### Note: Dangerous functions like os.execute, os.getenv, etc. are removed. -## πŸ—ƒοΈ Databases - - index.db: Available packages (after sync) - - installed.db: Packages currently installed - -# ⚠️ Restrictions & Notes - - Linux only (//go:build linux) - - Root permissions required for most commands - - Changing dataDir triggers prompt to migrate installed packages - - Binaries in binDir are not automatically moved if path changes - - Do not manually edit lastDataDir - - -# TODO - -- Auto-compile packages -- An web page to upload packages diff --git a/cmd/http/httpsocket.go b/cmd/http/httpsocket.go deleted file mode 100644 index fa88314..0000000 --- a/cmd/http/httpsocket.go +++ /dev/null @@ -1,37 +0,0 @@ -package main - -import ( - "fmt" - "log" - "net/http" - "os" - "path/filepath" - - "packets/internal" - - "github.com/BurntSushi/toml" -) - -type ConfigTOML struct { - Config struct { - DefaultHttpPort int `toml:"httpPort"` - DefaultCacheDir string `toml:"cacheDir"` - } `toml:"Config"` -} - -func main() { - - internal.PacketsPackageDir() - var cfg ConfigTOML - toml.Decode(filepath.Join(internal.PacketsPackageDir(), "config.toml"), &cfg) - - pid := os.Getpid() - if err := os.WriteFile(filepath.Join(internal.PacketsPackageDir(), "http.pid"), []byte(fmt.Sprint(pid)), 0644); err != nil { - fmt.Println("error saving subprocess pid", err) - } - - fs := http.FileServer(http.Dir(cfg.Config.DefaultCacheDir)) - http.Handle("/", fs) - - log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", cfg.Config.DefaultHttpPort), nil)) -} diff --git a/cmd/packets/main.go b/cmd/packets/main.go deleted file mode 100644 index dfe3c3f..0000000 --- a/cmd/packets/main.go +++ /dev/null @@ -1,1872 +0,0 @@ -//go:build linux - -package main - -import ( - "archive/tar" - "bufio" - "crypto/sha256" - "database/sql" - "encoding/hex" - "errors" - "fmt" - "io" - "io/fs" - "log" - "net" - "net/http" - "net/url" - "os" - "os/exec" - "packets/internal" - "path" - "path/filepath" - "runtime" - "strconv" - "strings" - "syscall" - "time" - - "github.com/BurntSushi/toml" - "github.com/klauspost/compress/zstd" - "github.com/schollz/progressbar/v3" - "github.com/spf13/cobra" - lua "github.com/yuin/gopher-lua" - "golang.org/x/net/ipv4" - _ "modernc.org/sqlite" -) - -type UpgradeHelpAuto struct { - OgRealname string - NeoRealname string -} - -type ConfigTOML struct { - Config struct { - HttpPort int `toml:"httpPort"` - CacheDir string `toml:"cacheDir"` - AutoDeleteCacheDir bool `toml:"dayToDeleteCacheDir"` - DaysToDelete int `toml:"daysToDelete"` - DataDir string `toml:"dataDir"` - BinDir string `toml:"binDir"` - LastDataDir string `toml:"lastDataDir"` - } `toml:"Config"` -} - -type CountingReader struct { - R io.Reader - Total int64 -} - -func (c *CountingReader) Read(p []byte) (int, error) { - n, err := c.R.Read(p) - c.Total += int64(n) - return n, err -} - -type Installed struct { - Realname string - Version string - Dependencies []string - Family string - Serial uint -} - -type Peer struct { - IP net.IP - Port int -} - -type Quer1 struct { - Realname string - Version string - Description string -} - -type Manifest struct { - Info struct { - Name string `toml:"name"` - Version string `toml:"version"` - Description string `toml:"description"` - Dependencies []string `toml:"dependencies"` - Author string `toml:"author"` - Family string `toml:"family"` - Serial uint `toml:"serial"` - } `toml:"Info"` - Hooks struct { - Install string `toml:"install"` - Remove string `toml:"remove"` - } `toml:"Hooks"` -} - -const LANDeadLine = 2 * time.Second - -// errors - -var ErrNotInstalled = errors.New("this package isn't installed") - -var serialPass uint -var cfg ConfigTOML -var PacketsDir string - -var isUpgrade bool -var upgradeHelper string - -var Unsafe bool - -var rootCmd = &cobra.Command{Use: "packets"} - -var installCmd = &cobra.Command{ - Use: "install {package} [packages...]", - Short: "Install a package", - Args: cobra.MinimumNArgs(1), - Run: func(cmd *cobra.Command, args []string) { - if os.Getuid() != 0 { - fmt.Println("please, run as root") - return - } - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return - } - defer db.Close() - - nameToQuery := args[0] - var exist bool - db.QueryRow("SELECT EXISTS(SELECT 1 FROM packages WHERE realname = ? LIMIT 1)", nameToQuery).Scan(&exist) - if exist { - QueryInstall(nameToQuery) - return - } - - rows, err := db.Query("SELECT realname, version, description FROM packages WHERE name = ?", nameToQuery) - if err != nil { - if strings.Contains(err.Error(), "file is not a database (26)") { - fmt.Println("index.db corrupted") - return - } - log.Panic(err) - return - } - - defer rows.Close() - - var pkgs []Quer1 - for rows.Next() { - var q Quer1 - if err := rows.Scan(&q.Realname, &q.Version, &q.Description); err != nil { - log.Fatal(err) - } - pkgs = append(pkgs, q) - } - switch len(pkgs) { - case 0: - fmt.Printf("can't find any results for %s\n", nameToQuery) - return - case 1: - fmt.Printf(":: Founded 1 package for %s \n", nameToQuery) - - fmt.Printf("Downloading %s \n", pkgs[0].Realname) - QueryInstall(pkgs[0].Realname) - return - - default: - fmt.Printf(":: Founded %d versions for (%s)\n Select 1 to install\n", len(pkgs), nameToQuery) - for i, q := range pkgs { - fmt.Printf("[%d] %s : %s\n %s\n", i, q.Realname, q.Version, q.Description) - } - var choice int - - fmt.Print(">> ") - fmt.Fscan(bufio.NewReader(os.Stdin), &choice) - if choice > len(pkgs) || choice < 0 { - fmt.Println("invalid option") - return - } - - QueryInstall(pkgs[choice].Realname) - return - } - }, -} - -var serve = &cobra.Command{ - Use: "serve", - Short: "Start or stops the packets daemon", -} - -var serveInit = &cobra.Command{ - Use: "init", - Short: "Starts the packets daemon", - Run: func(cmd *cobra.Command, args []string) { - var sockets [2]string - sockets[0] = filepath.Join(PacketsDir, "udpsocket") - sockets[1] = filepath.Join(PacketsDir, "httpsocket") - - for _, v := range sockets { - abs, _ := filepath.Abs(v) - cmd := exec.Command(abs) - cmd.Stdout, cmd.Stderr = os.Stdout, os.Stderr - if err := cmd.Start(); err != nil { - log.Fatalf("failed to start %s: %v", v, err) - } - - } - }, -} -var serveStop = &cobra.Command{ - Use: "stop", - Short: "Stops the packets daemon", - Run: func(cmd *cobra.Command, args []string) { - var pidfiles [2]string - pidfiles[0] = filepath.Join(PacketsDir, "http.pid") - pidfiles[1] = filepath.Join(PacketsDir, "udp.pid") - - for _, v := range pidfiles { - data, err := os.ReadFile(v) - if err != nil { - fmt.Println("cant read PID:", err) - return - } - pid, _ := strconv.Atoi(string(data)) - syscall.Kill(pid, syscall.SIGTERM) - } - }, -} - -var syncCmd = &cobra.Command{ - Use: "sync [url]", - Short: "Syncronizes with an remote index.db, and check if the data dir is changed", - Run: func(cmd *cobra.Command, args []string) { - if os.Getuid() != 0 { - fmt.Println("please, run as root") - return - } - - if len(args) == 0 { - fmt.Println("Starting to sync with https://servidordomal.fun/index.db") - if err := Sync("https://servidordomal.fun/index.db"); err != nil { - fmt.Println("failed to sync with https://servidordomal.fun/index.db : ", err) - return - } - fmt.Println("Sucessifully sync!") - return - } - - syncurl := args[0] - - fmt.Printf("Starting to sync with %s\n", syncurl) - if err := Sync(syncurl); err != nil { - fmt.Printf("failed to sync with %s : %e ", syncurl, err) - return - } - fmt.Println("Sucessifully sync!") - }, -} - -var removeCmd = &cobra.Command{ - Use: "remove {package} [packages...]", - Short: "Remove packages by the package realname", - Run: func(cmd *cobra.Command, args []string) { - if os.Getuid() != 0 { - fmt.Println("please, run as root") - return - } - for _, realname := range args { - - err := Unninstall(realname) - if err != nil { - if err == ErrNotInstalled { - fmt.Println(err.Error()) - } else { - log.Fatal(err) - } - return - } - } - }, -} -var listCmd = &cobra.Command{ - Use: "list", - Short: "List all installed packages", - Run: func(cmd *cobra.Command, args []string) { - if err := ListPackets(); err != nil { - return - } - }, -} - -var searchCmd = &cobra.Command{ - Use: "search [query name]", - Short: "List all packages in index.db", - Args: cobra.MaximumNArgs(1), - Run: func(cmd *cobra.Command, args []string) { - if err := Search(cmd, args); err != nil { - log.Fatal(err) - } - }, -} - -var upgradeCmd = &cobra.Command{ - Use: "upgrade [packages...]", - Short: "Upgrade package", - Run: func(cmd *cobra.Command, args []string) { - - isUpgrade = true - if len(args) == 0 { - if err := AutoUpgrade(); err != nil { - log.Fatal(err) - } - return - } - - for _, og_realname := range args { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return - } - defer db.Close() - - idb, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return - } - defer idb.Close() - - var family string - if err := idb.QueryRow("SELECT family FROM packages WHERE realname = ?", og_realname).Scan(&family); err != nil { - if err == sql.ErrNoRows { - fmt.Printf("error: cant find %s\n", og_realname) - os.Exit(1) - } else { - log.Fatal(err) - } - } - - var neo_realname string - - if err := db.QueryRow("SELECT realname FROM packages WHERE family = ? ORDER BY serial DESC LIMIT 1", family).Scan(&neo_realname); err != nil { - if err == sql.ErrNoRows { - fmt.Printf("error: cant find %s\n", og_realname) - os.Exit(1) - } else { - log.Fatal(err) - } - } - - if neo_realname == og_realname { - fmt.Printf("%s is up to date!\n", og_realname) - return - } - - if err := db.QueryRow("SELECT serial FROM packages WHERE family = ? ORDER BY serial DESC LIMIT 1", family).Scan(&serialPass); err != nil { - log.Fatal("line 255", err) - return - } - - fmt.Println("founded an upgrade") - upgradeHelper = og_realname - QueryInstall(neo_realname) - } - }, -} - -var infoCmd = &cobra.Command{ - Use: "info {name}", - Short: "Get technical package information", - Args: cobra.MinimumNArgs(1), - Run: func(cmd *cobra.Command, args []string) { - - _, err := os.Stat(filepath.Join(PacketsDir, "index.db")) - if err != nil { - if os.IsNotExist(err) { - fmt.Println("cant find index.db, please use sync first") - } - } - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal("cant find index.db, please use sync first") - } - defer db.Close() - - var name, version, hash, description, mirrorsRaw, family string - var dependenciesRaw *string - var dependencies, mirrors []string - var serial int - - if err := db.QueryRow("SELECT name, version, hash, description, dependencies, mirrors, family, serial FROM packages WHERE realname = ?", args[0]).Scan(&name, &version, &hash, &description, &dependenciesRaw, &mirrorsRaw, &family, &serial); err != nil { - if err == sql.ErrNoRows { - fmt.Printf("cant find any result for %s\n", args[0]) - os.Exit(1) - } else { - log.Fatal(err) - } - - } - - if dependenciesRaw != nil { - dependencies = strings.Fields(*dependenciesRaw) - } else { - dependencies = []string{} - } - mirrors = strings.Fields(mirrorsRaw) - - fmt.Printf(":: Package %s : %s\n:: (%s)\n %s\n Dependencies: %v\n Mirrors: %v\n ---------------------------------\n Family: %s\n Serial: %d\n SHA256sum: %s\n", args[0], version, name, description, dependencies, mirrors, family, serial, hash) - }, -} - -func main() { - - if runtime.GOOS == "linux" { - if os.Geteuid() != 0 { - fmt.Println("Please run packets as root\nThis can change in future versions but currently it is required.") - return - } - } - - // ABOUT CONFIG.TOML - PacketsDir = internal.PacketsPackageDir() - _, err := os.Stat(filepath.Join(PacketsDir, "config.toml")) - if err != nil { - if os.IsNotExist(err) { - fmt.Println("can't find config.toml, generating a default one") - - os.MkdirAll(PacketsDir, 0644) - file, err := os.Create(filepath.Join(PacketsDir, "config.toml")) - if err != nil { - log.Fatal(err) - } - defer file.Close() - - cfg := internal.DefaultConfigTOML() - - encoder := toml.NewEncoder(file) - - if err := encoder.Encode(cfg); err != nil { - log.Fatal(err) - } - file.WriteString("\n\n# BE CAREFULL CHANGING BIN_DIR, BECAUSE THE BINARIES DON'T MOVE AUTOMATICALLY\n# NEVER CHANGE lastDataDir") - fmt.Println("Operation Sucess!") - } - } - - _, err = toml.DecodeFile(filepath.Join(PacketsDir, "config.toml"), &cfg) - if err != nil { - log.Fatal(err) - } - - // COMMANDS - rootCmd.AddCommand(serve) - - serve.AddCommand(serveInit) - serve.AddCommand(serveStop) - - rootCmd.AddCommand(installCmd) - installCmd.Flags().BoolVar(&Unsafe, "unsafe", false, "Execute lua script without sandbox") - - rootCmd.AddCommand(syncCmd) - rootCmd.AddCommand(removeCmd) - removeCmd.Flags().BoolVar(&Unsafe, "unsafe", false, "Execute lua script without sandbox") - - rootCmd.AddCommand(upgradeCmd) - upgradeCmd.Flags().BoolVar(&Unsafe, "unsafe", false, "Execute lua script without sandbox") - - rootCmd.AddCommand(listCmd) - rootCmd.AddCommand(searchCmd) - - rootCmd.AddCommand(infoCmd) - - rootCmd.Execute() - -} - -// Install function extracts and execute postinstall scripts, following the manifest.toml -func Install(packagepath string, serial uint) error { - - manifest, err := internal.ManifestReadXZ(packagepath) - if err != nil { - log.Panic(err) - } - - name := manifest.Info.Name - - var destDir = filepath.Join(cfg.Config.DataDir, name) - - if cfg.Config.LastDataDir != cfg.Config.DataDir { - fmt.Printf("Ooops... Data directory has been changed from (%s), to (%s), do you want to cancel the installation and Sync first? [Y/n]\n", cfg.Config.LastDataDir, cfg.Config.DataDir) - - var answer string - - fmt.Print(">> ") - fmt.Scan(&answer) - - if answer == "y" || answer == "Y" { - if err := os.MkdirAll(cfg.Config.DataDir, 0755); err != nil { - return err - } - - bar := progressbar.NewOptions64(-1, - progressbar.OptionSetDescription("Moving ..."), - ) - - err := filepath.WalkDir(cfg.Config.LastDataDir, func(last string, d fs.DirEntry, walkErr error) error { - if walkErr != nil { - return walkErr - } - - if last == cfg.Config.LastDataDir { - return nil - } - - rel, err := filepath.Rel(cfg.Config.LastDataDir, last) - if err != nil { - return err - } - dest := filepath.Join(cfg.Config.DataDir, rel) - - if d.IsDir() { - return os.MkdirAll(dest, 0755) - } - - return os.Rename(last, dest) - - }) - if err != nil { - return err - } - - f, err := os.OpenFile(filepath.Join(PacketsDir, "config.toml"), os.O_WRONLY, 0644) - if err != nil { - return err - } - - cfg.Config.LastDataDir = cfg.Config.DataDir - - encoder := toml.NewEncoder(f) - - err = encoder.Encode(cfg) - - if err != nil { - bar.Finish() - return err - } - - f.WriteString("\n\n# BE CAREFULL CHANGING BIN_DIR, BECAUSE THE BINARIES DON'T MOVE AUTOMATICALLY\n# NEVER CHANGE lastDataDir") - os.Remove(cfg.Config.LastDataDir) - bar.Finish() - } - } - - f, err := os.Open(packagepath) - if err != nil { - return err - } - defer f.Close() - - zs, err := zstd.NewReader(f) - if err != nil { - return err - } - defer zs.Close() - - tr := tar.NewReader(zs) - - bar := progressbar.NewOptions64( - -1, - progressbar.OptionSetDescription("[2/2] Unpacking ..."), - progressbar.OptionSetWriter(os.Stdout), - progressbar.OptionClearOnFinish(), - ) - for { - hdr, err := tr.Next() - if err == io.EOF { - break - } - if err != nil { - return err - } - - rel := filepath.Clean(hdr.Name) - - if rel == ".." || strings.HasPrefix(rel, ".."+string(os.PathSeparator)) { - continue - } - - if err := os.MkdirAll(destDir, 0755); err != nil { - return err - } - - absPath := filepath.Join(destDir, rel) - - switch hdr.Typeflag { - - case tar.TypeDir: - err = os.MkdirAll(absPath, os.FileMode(hdr.Mode)) - - if err != nil { - return err - } - - case tar.TypeReg: - err = os.MkdirAll(filepath.Dir(absPath), 0755) - if err != nil { - return err - } - - out, err := os.Create(absPath) - if err != nil { - return err - } - - n, err := io.Copy(out, tr) - out.Close() - if err != nil { - return err - } - bar.Add64(n) - - err = os.Chmod(absPath, os.FileMode(hdr.Mode)) - if err != nil { - return err - } - default: - - } - } - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - var familyUuid string - - if err := db.QueryRow("SELECT family FROM packages WHERE realname = ?", name).Scan(&familyUuid); err != nil { - return err - } - - manifest.Info.Family = familyUuid - manifest.Info.Serial = serialPass - - file, err := os.OpenFile(filepath.Join(cfg.Config.DataDir, name, "manifest.toml"), os.O_WRONLY|os.O_TRUNC, 0644) - if err != nil { - return err - } - defer file.Close() - - encoder := toml.NewEncoder(file) - - encoder.Encode(&manifest) - - L := lua.NewState() - defer L.Close() - - if !Unsafe { - internal.SandboxDir = filepath.Join(cfg.Config.DataDir, name) - osObject := L.GetGlobal("os").(*lua.LTable) - ioObject := L.GetGlobal("io").(*lua.LTable) - - L.SetGlobal("package", lua.LNil) - L.SetGlobal("require", lua.LNil) - L.SetGlobal("runningUnsafe", lua.LFalse) - - L.SetGlobal("packets_package_dir", lua.LString(cfg.Config.DataDir)) - L.SetGlobal("packets_bin_dir", lua.LString(cfg.Config.BinDir)) - L.SetGlobal("script", lua.LString(manifest.Hooks.Install)) - L.SetGlobal("data_dir", lua.LString(filepath.Join(cfg.Config.DataDir, name, "data"))) - - L.SetGlobal("path_join", L.NewFunction(internal.Ljoin)) - - // Packets build functions - build := L.NewTable() - - L.SetField(build, "requirements", L.NewFunction(internal.CompileRequirements)) - L.SetField(build, "compile", L.NewFunction(internal.LuaCompile)) - - L.SetGlobal("build", build) - - osObject.RawSetString("execute", lua.LNil) - osObject.RawSetString("exit", lua.LNil) - osObject.RawSetString("getenv", lua.LNil) - - osObject.RawSetString("remove", L.NewFunction(internal.SafeRemove)) - osObject.RawSetString("rename", L.NewFunction(internal.SafeRename)) - osObject.RawSetString("copy", L.NewFunction(internal.SafeCopy)) - osObject.RawSetString("symlink", L.NewFunction(internal.SymbolicLua)) - osObject.RawSetString("mkdir", L.NewFunction(internal.LMkdir)) - - ioObject.RawSetString("input", lua.LNil) - ioObject.RawSetString("output", lua.LNil) - ioObject.RawSetString("popen", lua.LNil) - ioObject.RawSetString("tmpfile", lua.LNil) - ioObject.RawSetString("stdout", lua.LNil) - ioObject.RawSetString("stdeer", lua.LNil) - ioObject.RawSetString("stdin", lua.LNil) - ioObject.RawSetString("lines", lua.LNil) - ioObject.RawSetString("open", L.NewFunction(internal.SafeOpen)) - } else { - L.SetGlobal("runningUnsafe", lua.LTrue) - } - - if err := L.DoFile(filepath.Join(cfg.Config.DataDir, name, manifest.Hooks.Install)); err != nil { - log.Panic(err) - } - - bar.Finish() - fmt.Printf(":: Package %s fully installed\n", name) - - var insert = Installed{ - Realname: manifest.Info.Name, - Version: manifest.Info.Version, - Dependencies: manifest.Info.Dependencies, - Family: manifest.Info.Family, - Serial: manifest.Info.Serial, - } - - if err := AddToInstalledDB(insert); err != nil { - log.Fatal(err) - return err - } - return nil -} - -// GetPackageByMirror download a pacakge from a httpserver -func GetPackageByMirror(mirror string, realname string) error { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - var serial uint - - if err := db.QueryRow("SELECT serial FROM packages WHERE realname = ?", realname).Scan(&serial); err != nil { - log.Fatal(err) - } - - u, _ := url.Parse(mirror) - filename := path.Base(u.Path) - - resp, err := http.Get(mirror) - if err != nil { - log.Panic("error doing get request, do you really have an internet connection?") - return err - } - - var domain = mirror - var link bool - - if cont := strings.Contains(mirror, "https"); cont { - link = true - domain = strings.Replace(mirror, "https", "", 1) - } else { - link = true - domain = strings.Replace(mirror, "http", "", 1) - } - if link { - - domain = strings.Replace(domain, "://", "", 1) - slice := strings.SplitN(domain, "/", 2) - - domain = slice[0] - } - - bar := progressbar.NewOptions64(resp.ContentLength, - progressbar.OptionSetDescription(fmt.Sprintf("[1/2] Downloading from %s ...", domain)), - progressbar.OptionShowBytes(true), - progressbar.OptionSetPredictTime(true), - progressbar.OptionShowCount(), - progressbar.OptionClearOnFinish(), - ) - - defer resp.Body.Close() - - if resp.StatusCode != 200 { - if err := os.Remove(filepath.Join(cfg.Config.CacheDir, filename)); err != nil { - if os.IsNotExist(err) { - return fmt.Errorf("failed to download, status code not 200OK") - } else { - return err - } - } - return fmt.Errorf("failed to download, status code not 200OK") - } - - if err := os.MkdirAll(cfg.Config.CacheDir, 0755); err != nil { - log.Fatal("error creating file for package ", err) - return err - } - - out, err := os.Create(filepath.Join(cfg.Config.CacheDir, filename)) - if err != nil { - log.Fatal("error creating package ", err) - return err - } - defer out.Close() - - _, err = io.Copy(io.MultiWriter(out, bar), resp.Body) - if err != nil { - err := os.Remove(filepath.Join(cfg.Config.CacheDir, filename)) - if err != nil { - return err - } - return err - } - bar.Finish() - - err = Validate(filename, realname) - if err != nil { - return err - } - - if isUpgrade { - if err := Upgrade(filepath.Join(cfg.Config.CacheDir, filename), upgradeHelper, serialPass); err != nil { - return err - } - return nil - } - err = Install(filepath.Join(cfg.Config.CacheDir, filename), serial) - if err != nil { - return err - } - return nil - -} -func ResolvDependencies(realname string) { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - } - defer db.Close() - - var dependencies *string - - err = db.QueryRow("SELECT dependencies FROM packages WHERE realname = ?", realname).Scan(&dependencies) - if err != nil { - log.Panic(err) - return - } - - if dependencies == nil { - return - } - - dependencie := strings.Fields(*dependencies) - - for _, v := range dependencie { - err := AlredySatisfied(v) - if err != nil { - fmt.Printf("error installing %v : %s", v, err.Error()) - continue - } - QueryInstall(v) - } -} - -func QueryInstall(realname string) { - - _, err := os.Stat(filepath.Join(PacketsDir, "index.db")) - if err != nil { - if os.IsNotExist(err) { - fmt.Println("cant find index.db, please use sync first") - } - } - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal("cant find index.db, please use sync first") - } - defer db.Close() - - simplecheck, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - - log.Fatal(err) - - } - var exist bool - simplecheck.QueryRow("SELECT EXISTS(SELECT 1 FROM packages WHERE realname = ? LIMIT 1)", realname).Scan(&exist) - if exist { - fmt.Println("Alredy installed!") - simplecheck.Close() - return - } - defer simplecheck.Close() - - var mirrors string - var serial uint - var family string - - ResolvDependencies(realname) - - err = db.QueryRow("SELECT mirrors, serial, family FROM packages WHERE realname = ?", realname).Scan(&mirrors, &serial, &family) - if err != nil { - log.Fatal(err) - } - - if !isUpgrade { - - var recognize string - - err = simplecheck.QueryRow("SELECT realname FROM packages WHERE family = ?", family).Scan(&recognize) - if err != nil { - if err == sql.ErrNoRows { - } - } - if err == nil { - fmt.Println(":: Older package found, upgrading.") - isUpgrade = true - upgradeHelper = recognize - } - } - - if !strings.Contains(mirrors, " ") { - u, _ := url.Parse(mirrors) - filename := path.Base(u.Path) - - fmt.Println("Checking in cache dir") - if CheckDownloaded(filename) { - err := Validate(filename, realname) - if err != nil { - return - } - if isUpgrade { - if err := Upgrade(filepath.Join(cfg.Config.CacheDir, filename), upgradeHelper, serialPass); err != nil { - log.Fatal(err) - return - } - return - } - Install(filepath.Join(cfg.Config.CacheDir, filename), serial) - return - - } - fmt.Println(":: Asking in LAN for the package") - peers := AskLAN(filename) - answers := len(peers) - if answers != 0 { - for _, p := range peers { - fmt.Printf("Downloading from %s\n", p.IP) - if err := GetPackageByMirror(fmt.Sprintf("http://%s:%d/%s", p.IP, p.Port, filename), realname); err != nil { - log.Println(err) - break - } - fmt.Printf("Download failed!\n") - } - } - if err := GetPackageByMirror(mirrors, realname); err != nil { - log.Println(err) - return - } - - } else { - - fmt.Println(":: A mirror list was found") - mirrorlist := strings.Fields(mirrors) - - for _, v := range mirrorlist { - u, _ := url.Parse(v) - filename := path.Base(u.Path) - - fmt.Printf("Checking for %s\n", filename) - if CheckDownloaded(filename) { - err := Validate(filename, realname) - if err != nil { - continue - } else { - if isUpgrade { - if err := Upgrade(filepath.Join(cfg.Config.CacheDir, filename), upgradeHelper, serialPass); err != nil { - log.Fatal(err) - return - } - break - } - Install(filepath.Join(cfg.Config.CacheDir, filename), serial) - break - } - } - fmt.Println(":: Checking for package in LAN") - peers := AskLAN(filename) - answers := len(peers) - if answers != 0 { - for _, p := range peers { - fmt.Printf("Downloading from %s\n", v) - if err := GetPackageByMirror(fmt.Sprintf("http://%s:%d/%s", p.IP, p.Port, filename), realname); err == nil { - break - } - fmt.Printf("Failed!\n") - } - } - fmt.Printf("Downloading from %s\n", v) - if err := GetPackageByMirror(v, realname); err != nil { - log.Println(err) - break - } - - } - } - -} - -func CheckDownloaded(filename string) bool { - - _, err := os.Stat(filepath.Join(cfg.Config.CacheDir, filename)) - if err != nil { - if os.IsNotExist(err) { - return false - } else { - return true - } - } - return true -} - -func Validate(filename string, realname string) error { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - downloaded, err := os.Open(filepath.Join(cfg.Config.CacheDir, filename)) - if err != nil { - log.Fatal("error reading new file") - return err - } - defer downloaded.Close() - - h := sha256.New() - if _, err := io.Copy(h, downloaded); err != nil { - fmt.Println("error doing sha256sum") - return err - } - - sum := h.Sum(nil) - hashString := hex.EncodeToString(sum) - - var hashStringDB string - - err = db.QueryRow("SELECT hash FROM packages WHERE realname = ?", realname).Scan(&hashStringDB) - if err != nil { - log.Panic(err) - return err - } - - if hashString != hashStringDB { - fmt.Println("tampered package, removing it...") - - err := os.Remove(filepath.Join(cfg.Config.CacheDir, filename)) - if err != nil { - return err - } - QueryInstall(realname) - return nil - } - return nil -} - -func AskLAN(filename string) []Peer { - var peers []Peer - query := []byte("Q:" + filename) - - pc, err := net.ListenPacket("udp", ":0") - if err != nil { - log.Panic("error starting udp socket:", err) - } - defer pc.Close() - - if pconn := ipv4.NewPacketConn(pc); pconn != nil { - _ = pconn.SetTTL(1) - } - - ifaces, _ := net.Interfaces() - for _, ifc := range ifaces { - if ifc.Flags&net.FlagUp == 0 || ifc.Flags&net.FlagLoopback != 0 { - continue - } - - addrs, _ := ifc.Addrs() - for _, a := range addrs { - ipnet, ok := a.(*net.IPNet) - if !ok || ipnet.IP.To4() == nil { - continue - } - - bcast := broadcastAddr(ipnet.IP.To4(), ipnet.Mask) - dst := &net.UDPAddr{IP: bcast, Port: 1333} - - _, err = pc.WriteTo(query, dst) - if err != nil { - log.Printf("[%s] can't send to %s: %v", ifc.Name, bcast, err) - } - } - } - _ = pc.SetDeadline(time.Now().Add(LANDeadLine)) - buf := make([]byte, 1500) - - for { - n, addr, err := pc.ReadFrom(buf) - if err != nil { - break - } - msg := string(buf[:n]) - - if strings.HasPrefix(msg, "H:"+filename) { - parts := strings.Split(msg, ":") - port, _ := strconv.Atoi(parts[2]) - fmt.Printf("%s have the package\n", addr) - peers = append(peers, Peer{IP: addr.(*net.UDPAddr).IP, Port: port}) - } - } - return peers -} - -func broadcastAddr(ip net.IP, mask net.IPMask) net.IP { - b := make(net.IP, len(ip)) - for i := range ip { - b[i] = ip[i] | ^mask[i] - } - return b -} - -func Sync(url string) error { - resp, err := http.Get(url) - if err != nil { - return err - } - defer resp.Body.Close() - _, err = os.Stat(filepath.Join(PacketsDir, "index.db")) - - if err != nil { - if os.IsNotExist(err) { - os.MkdirAll(PacketsDir, 0755) - } - } - f, err := os.Create(filepath.Join(PacketsDir, "index.db")) - if err != nil { - return err - } - - if _, err = io.Copy(f, resp.Body); err != nil { - return err - } - - if cfg.Config.LastDataDir != cfg.Config.DataDir { - fmt.Printf("Ooops... Data directory has been changed on %s do you want to move the packages from (%s), to (%s)\n", filepath.Join(PacketsDir, "config.toml"), cfg.Config.LastDataDir, cfg.Config.DataDir) - fmt.Println(":: What you want to do?") - fmt.Println("[y] Yes [n] No, [x] Ignore it and stop to show this message (not recommended)") - - var answer string - fmt.Print(">> ") - fmt.Scan(&answer) - - switch answer { - case "n": - fmt.Println("Just ignoring...") - - case "x": - f, err := os.OpenFile(filepath.Join(PacketsDir, "config.toml"), os.O_WRONLY, 0644) - if err != nil { - return err - } - - cfg.Config.LastDataDir = cfg.Config.DataDir - - encoder := toml.NewEncoder(f) - - err = encoder.Encode(cfg) - if err != nil { - return err - } - f.WriteString("\n\n# BE CAREFULL CHANGING BIN_DIR, BECAUSE THE BINARIES DON'T MOVE AUTOMATICALLY\n# NEVER CHANGE lastDataDir") - - return nil - - case "y": - if err := os.MkdirAll(cfg.Config.DataDir, 0755); err != nil { - return err - } - - bar := progressbar.NewOptions64(-1, - progressbar.OptionSetDescription("Moving ..."), - ) - - err := filepath.WalkDir(cfg.Config.LastDataDir, func(last string, d fs.DirEntry, walkErr error) error { - if walkErr != nil { - return walkErr - } - - if last == cfg.Config.LastDataDir { - return nil - } - - rel, err := filepath.Rel(cfg.Config.LastDataDir, last) - if err != nil { - return err - } - dest := filepath.Join(cfg.Config.DataDir, rel) - - if d.IsDir() { - return os.MkdirAll(dest, 0755) - } - - return os.Rename(last, dest) - - }) - if err != nil { - return err - } - - f, err := os.OpenFile(filepath.Join(PacketsDir, "config.toml"), os.O_WRONLY, 0644) - if err != nil { - return err - } - - cfg.Config.LastDataDir = cfg.Config.DataDir - - encoder := toml.NewEncoder(f) - - err = encoder.Encode(cfg) - if err != nil { - bar.Finish() - return err - } - f.WriteString("\n\n# BE CAREFULL CHANGING BIN_DIR, BECAUSE THE BINARIES DON'T MOVE AUTOMATICALLY\n# NEVER CHANGE lastDataDir") - os.Remove(cfg.Config.LastDataDir) - bar.Finish() - - return nil - default: - if err := os.MkdirAll(cfg.Config.DataDir, 0755); err != nil { - return err - } - - bar := progressbar.NewOptions64(-1, - progressbar.OptionSetDescription("Moving ..."), - ) - - err := filepath.WalkDir(cfg.Config.LastDataDir, func(last string, d fs.DirEntry, walkErr error) error { - if walkErr != nil { - return walkErr - } - - if last == cfg.Config.LastDataDir { - return nil - } - - rel, err := filepath.Rel(cfg.Config.LastDataDir, last) - if err != nil { - return err - } - dest := filepath.Join(cfg.Config.DataDir, rel) - - if d.IsDir() { - return os.MkdirAll(dest, 0755) - } - - return os.Rename(last, dest) - - }) - if err != nil { - return err - } - bar.Finish() - return nil - } - } - - return nil -} - -func AddToInstalledDB(insert Installed) error { - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - _, err = db.Exec("CREATE TABLE IF NOT EXISTS packages (realname TEXT NOT NULL UNIQUE PRIMARY KEY, version TEXT NOT NULL, dependencies TEXT, name TEXT, family TEXT NOT NULL, serial INTEGER)") - if err != nil { - return err - } - - if len(insert.Dependencies) == 0 { - _, err = db.Exec("INSERT INTO packages (realname, version, family, serial) VALUES (?, ?, ?, ?)", insert.Realname, insert.Version, insert.Family, insert.Serial) - if err != nil { - return err - } - return nil - } - var query string - for _, v := range insert.Dependencies { - - query = query + v + " " - } - - query = query[:len(query)-1] - - _, err = db.Exec("INSERT INTO packages (realname, version, dependencies, family, serial) VALUES (?, ?, ?, ?, ?)", insert.Realname, insert.Version, query, insert.Family, insert.Serial) - if err != nil { - return err - } - - return nil -} - -func Unninstall(realname string) error { - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - var exist bool - - err = db.QueryRow("SELECT EXISTS(SELECT 1 FROM packages WHERE realname = ? LIMIT 1)", realname).Scan(&exist) - if err != nil { - return err - } - - if !exist { - return ErrNotInstalled - } - fmt.Printf(":: Sure you will remove %s ? [Y/n] ", realname) - var answer string - fmt.Print(">> ") - fmt.Scan(&answer) - - if answer != "y" && answer != "Y" { - return fmt.Errorf("operation cancelled") - } - - var manifest Manifest - - toml.DecodeFile(filepath.Join(cfg.Config.DataDir, realname, "manifest.toml"), &manifest) - - L := lua.NewState() - defer L.Close() - - if !Unsafe { - internal.SandboxDir = filepath.Join(cfg.Config.DataDir, realname) - osObject := L.GetGlobal("os").(*lua.LTable) - ioObject := L.GetGlobal("io").(*lua.LTable) - - L.SetGlobal("package", lua.LNil) - L.SetGlobal("require", lua.LNil) - L.SetGlobal("runningUnsafe", lua.LFalse) - - L.SetGlobal("packets_package_dir", lua.LString(cfg.Config.DataDir)) - L.SetGlobal("packets_bin_dir", lua.LString(cfg.Config.BinDir)) - L.SetGlobal("script", lua.LString(path.Join(cfg.Config.DataDir, realname, manifest.Hooks.Remove))) - L.SetGlobal("data_dir", lua.LString(filepath.Join(cfg.Config.DataDir, realname, "data"))) - - L.SetGlobal("path_join", L.NewFunction(internal.Ljoin)) - - // Packets build functions - build := L.NewTable() - - L.SetField(build, "requirements", L.NewFunction(internal.CompileRequirements)) - L.SetField(build, "compile", L.NewFunction(internal.LuaCompile)) - - L.SetGlobal("build", build) - - osObject.RawSetString("execute", lua.LNil) - osObject.RawSetString("exit", lua.LNil) - osObject.RawSetString("getenv", lua.LNil) - - osObject.RawSetString("remove", L.NewFunction(internal.SafeRemove)) - osObject.RawSetString("rename", L.NewFunction(internal.SafeRename)) - osObject.RawSetString("copy", L.NewFunction(internal.SafeCopy)) - osObject.RawSetString("symlink", L.NewFunction(internal.SymbolicLua)) - osObject.RawSetString("mkdir", L.NewFunction(internal.LMkdir)) - - ioObject.RawSetString("input", lua.LNil) - ioObject.RawSetString("output", lua.LNil) - ioObject.RawSetString("popen", lua.LNil) - ioObject.RawSetString("tmpfile", lua.LNil) - ioObject.RawSetString("stdout", lua.LNil) - ioObject.RawSetString("stderr", lua.LNil) - ioObject.RawSetString("stdin", lua.LNil) - ioObject.RawSetString("lines", lua.LNil) - ioObject.RawSetString("open", L.NewFunction(internal.SafeOpen)) - - } else { - L.SetGlobal("runningUnsafe", lua.LTrue) - } - - if err := L.DoFile(filepath.Join(cfg.Config.DataDir, realname, manifest.Hooks.Remove)); err != nil { - log.Panic(err) - } - - if err := os.RemoveAll(filepath.Join(cfg.Config.DataDir, realname)); err != nil { - return err - } - - _, err = db.Exec("DELETE FROM packages WHERE realname = ?", realname) - if err != nil { - return err - } - - fmt.Println("Sucessifully removed") - return nil -} - -func AlredySatisfied(realname string) error { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - var exist bool - - _, err = db.Exec("CREATE TABLE IF NOT EXISTS packages (realname TEXT NOT NULL UNIQUE PRIMARY KEY, version TEXT NOT NULL, dependencies TEXT, name TEXT, family TEXT NOT NULL, serial INTEGER)") - if err != nil { - return err - } - - err = db.QueryRow("SELECT EXISTS(SELECT 1 FROM packages WHERE realname = ? LIMIT 1)", realname).Scan(&exist) - if err != nil { - return err - } - - if !exist { - return nil - } - return fmt.Errorf("conflict") -} - -func ListPackets() error { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - rows, err := db.Query("SELECT realname, version FROM packages") - if err != nil { - return err - } - - var realname string - var version string - defer rows.Close() - - fmt.Println("Installed packages:") - for rows.Next() { - rows.Scan(&realname, &version) - fmt.Printf("%s %s\n", realname, version) - } - return nil -} - -func Upgrade(packagepath string, og_realname string, serial uint) error { - - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - log.Fatal(err) - return err - } - defer db.Close() - - var exist bool - - err = db.QueryRow("SELECT EXISTS(SELECT 1 FROM packages WHERE realname = ? LIMIT 1)", og_realname).Scan(&exist) - if err != nil { - return err - } - - if !exist { - return ErrNotInstalled - } - - if cfg.Config.LastDataDir != cfg.Config.DataDir { - fmt.Printf("Ooops... Data directory has been changed from (%s), to (%s), do you want to cancel the installation and Sync first? [Y/n]\n", cfg.Config.LastDataDir, cfg.Config.DataDir) - - var answer string - fmt.Print(">> ") - fmt.Scan(&answer) - - if answer == "y" || answer == "Y" { - if err := os.MkdirAll(cfg.Config.DataDir, 0755); err != nil { - return err - } - - bar := progressbar.NewOptions64(-1, - progressbar.OptionSetDescription("Moving ..."), - ) - - err := filepath.WalkDir(cfg.Config.LastDataDir, func(last string, d fs.DirEntry, walkErr error) error { - if walkErr != nil { - return walkErr - } - - if last == cfg.Config.LastDataDir { - return nil - } - - rel, err := filepath.Rel(cfg.Config.LastDataDir, last) - if err != nil { - return err - } - dest := filepath.Join(cfg.Config.DataDir, rel) - - if d.IsDir() { - return os.MkdirAll(dest, 0755) - } - - return os.Rename(last, dest) - - }) - - if err != nil { - return err - } - - f, err := os.OpenFile(filepath.Join(PacketsDir, "config.toml"), os.O_WRONLY, 0644) - if err != nil { - return err - } - - cfg.Config.LastDataDir = cfg.Config.DataDir - - encoder := toml.NewEncoder(f) - - err = encoder.Encode(cfg) - - if err != nil { - bar.Finish() - return err - } - - f.WriteString("\n\n# BE CAREFULL CHANGING BIN_DIR, BECAUSE THE BINARIES DON'T MOVE AUTOMATICALLY\n#NEVER CHANGE lastDataDir") - os.Remove(cfg.Config.LastDataDir) - bar.Finish() - } - } - - manifest, err := internal.ManifestReadXZ(packagepath) - if err != nil { - log.Panic(err) - } - - name := manifest.Info.Name - - fmt.Printf("Unpacking (%s) above (%s)\n", name, og_realname) - - var destDir = filepath.Join(cfg.Config.DataDir, og_realname) - - f, err := os.Open(packagepath) - if err != nil { - return err - } - stats, _ := f.Stat() - totalSize := stats.Size() - defer f.Close() - - counter := &CountingReader{R: f} - - zs, err := zstd.NewReader(f) - if err != nil { - return err - } - - tr := tar.NewReader(zs) - - bar := progressbar.NewOptions64( - totalSize, - progressbar.OptionSetDescription("[2/2] Upgrading ..."), - progressbar.OptionSetWriter(os.Stdout), - progressbar.OptionClearOnFinish(), - ) - - for { - hdr, err := tr.Next() - if err == io.EOF { - break - } - if err != nil { - return err - } - - rel := filepath.Clean(hdr.Name) - - if rel == ".." || strings.HasPrefix(rel, ".."+string(os.PathSeparator)) { - continue - } - - if err := os.MkdirAll(destDir, 0755); err != nil { - return err - } - - absPath := filepath.Join(destDir, rel) - - switch hdr.Typeflag { - - case tar.TypeDir: - err = os.MkdirAll(absPath, os.FileMode(hdr.Mode)) - - if err != nil { - return err - } - - case tar.TypeReg: - err = os.MkdirAll(filepath.Dir(absPath), 0755) - if err != nil { - return err - } - - out, err := os.Create(absPath) - if err != nil { - return err - } - _, err = io.Copy(out, tr) - out.Close() - if err != nil { - return err - } - - bar.Set(int(counter.Total)) - - err = os.Chmod(absPath, os.FileMode(hdr.Mode)) - if err != nil { - return err - } - default: - - } - - } - bar.Finish() - - os.Rename(destDir, filepath.Join(cfg.Config.DataDir, name)) - - dbx, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - log.Fatal(err) - return err - } - defer dbx.Close() - - var familyUuid string - - if err := dbx.QueryRow("SELECT family FROM packages WHERE realname = ?", name).Scan(&familyUuid); err != nil { - return err - } - - manifest.Info.Family = familyUuid - manifest.Info.Serial = serialPass - - file, err := os.OpenFile(filepath.Join(cfg.Config.DataDir, name, "manifest.toml"), os.O_WRONLY|os.O_TRUNC, 0644) - if err != nil { - return err - } - defer file.Close() - - encoder := toml.NewEncoder(file) - - encoder.Encode(&manifest) - - L := lua.NewState() - defer L.Close() - - if !Unsafe { - internal.SandboxDir = filepath.Join(cfg.Config.DataDir, name) - osObject := L.GetGlobal("os").(*lua.LTable) - ioObject := L.GetGlobal("io").(*lua.LTable) - - L.SetGlobal("package", lua.LNil) - L.SetGlobal("require", lua.LNil) - L.SetGlobal("runningUnsafe", lua.LFalse) - - L.SetGlobal("packets_package_dir", lua.LString(cfg.Config.DataDir)) - L.SetGlobal("packets_bin_dir", lua.LString(cfg.Config.BinDir)) - L.SetGlobal("script", lua.LString(manifest.Hooks.Install)) - L.SetGlobal("data_dir", lua.LString(filepath.Join(cfg.Config.DataDir, name, "data"))) - - L.SetGlobal("path_join", L.NewFunction(internal.Ljoin)) - - // Packets build functions - build := L.NewTable() - - L.SetField(build, "requirements", L.NewFunction(internal.CompileRequirements)) - L.SetField(build, "compile", L.NewFunction(internal.LuaCompile)) - - L.SetGlobal("build", build) - - // end of build functions - - osObject.RawSetString("execute", lua.LNil) - osObject.RawSetString("exit", lua.LNil) - osObject.RawSetString("getenv", lua.LNil) - - osObject.RawSetString("remove", L.NewFunction(internal.SafeRemove)) - osObject.RawSetString("rename", L.NewFunction(internal.SafeRename)) - osObject.RawSetString("copy", L.NewFunction(internal.SafeCopy)) - osObject.RawSetString("symlink", L.NewFunction(internal.SymbolicLua)) - osObject.RawSetString("mkdir", L.NewFunction(internal.LMkdir)) - - ioObject.RawSetString("input", lua.LNil) - ioObject.RawSetString("output", lua.LNil) - ioObject.RawSetString("popen", lua.LNil) - ioObject.RawSetString("tmpfile", lua.LNil) - ioObject.RawSetString("stdout", lua.LNil) - ioObject.RawSetString("stderr", lua.LNil) - ioObject.RawSetString("stdin", lua.LNil) - ioObject.RawSetString("lines", lua.LNil) - ioObject.RawSetString("open", L.NewFunction(internal.SafeOpen)) - } else { - L.SetGlobal("runningUnsafe", lua.LTrue) - } - - if err := L.DoFile(filepath.Join(cfg.Config.DataDir, name, manifest.Hooks.Install)); err != nil { - log.Panic(err) - } - - fmt.Printf("\nPackage %s fully installed\n", name) - - var insert = Installed{ - Realname: manifest.Info.Name, - Version: manifest.Info.Version, - Dependencies: manifest.Info.Dependencies, - Family: manifest.Info.Family, - Serial: manifest.Info.Serial, - } - - _, err = db.Exec("DELETE FROM packages WHERE realname = ?", og_realname) - if err != nil { - return err - } - - if err := AddToInstalledDB(insert); err != nil { - return err - } - return nil -} - -func AutoUpgrade() error { - - index, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - return err - } - defer index.Close() - - installed, err := sql.Open("sqlite", filepath.Join(PacketsDir, "installed.db")) - if err != nil { - return err - } - defer installed.Close() - - rows, err := installed.Query("SELECT family, serial, realname FROM packages") - if err != nil { - return err - } - defer rows.Close() - - var family, realname, ogRealname string - var serial, maxserial int - - var list []UpgradeHelpAuto - - for rows.Next() { - rows.Scan(&family, &serial, &ogRealname) - if err := index.QueryRow("SELECT serial, realname FROM packages WHERE serial = (SELECT MAX(serial) FROM packages WHERE family = ?) AND family = ?", family, family).Scan(&maxserial, &realname); err != nil { - return err - } - - if maxserial > serial { - brinco := &UpgradeHelpAuto{ - OgRealname: ogRealname, - NeoRealname: realname, - } - list = append(list, *brinco) - } - } - - for _, v := range list { - upgradeHelper = v.OgRealname - QueryInstall(v.NeoRealname) - } - - return nil -} - -func Search(cmd *cobra.Command, args []string) error { - db, err := sql.Open("sqlite", filepath.Join(PacketsDir, "index.db")) - if err != nil { - return err - } - defer db.Close() - - var name, realname, version, description string - var dependenciesRaw *string - var arrayDepedencies []string - - if len(args) == 0 { - - rows, err := db.Query("SELECT name, realname, version, description, dependencies FROM packages") - if err != nil { - return err - } - defer rows.Close() - - for rows.Next() { - if err := rows.Scan(&name, &realname, &version, &description, &dependenciesRaw); err != nil { - return err - } - - if dependenciesRaw != nil { - arrayDepedencies = strings.Fields(*dependenciesRaw) - } else { - arrayDepedencies = []string{} - } - fmt.Printf(":: Package %s : %s\n:: (%s)\n %s\n Dependencies: %v\n\n", realname, version, name, description, arrayDepedencies) - } - } else { - rows, err := db.Query("SELECT name, realname, version, description, dependencies FROM packages WHERE name = ?", args[0]) - if err != nil { - return err - } - defer rows.Close() - - for rows.Next() { - if err := rows.Scan(&name, &realname, &version, &description, &dependenciesRaw); err != nil { - return err - } - - if dependenciesRaw != nil { - arrayDepedencies = strings.Fields(*dependenciesRaw) - } else { - arrayDepedencies = []string{} - } - fmt.Printf(":: Package %s : %s\n:: (%s)\n %s\n Dependencies: %v\n\n", realname, version, name, description, arrayDepedencies) - } - - } - return nil -} - -/* -TODO: - asyncronous install with goroutines - packets search -*/ diff --git a/cmd/udp/udpsocket.go b/cmd/udp/udpsocket.go deleted file mode 100644 index 901baa6..0000000 --- a/cmd/udp/udpsocket.go +++ /dev/null @@ -1,65 +0,0 @@ -package main - -import ( - "fmt" - "log" - "net" - "os" - "packets/internal" - "path/filepath" - "strings" - - "github.com/BurntSushi/toml" -) - -type ConfigTOML struct { - Config struct { - HttpPort int `toml:"httpPort"` - CacheDir string `toml:"cacheDir"` - } `toml:"Config"` -} - -var cfg ConfigTOML - -func CheckDownloaded(filename string) bool { - - _, err := os.Stat(filepath.Join(cfg.Config.CacheDir)) - if os.IsNotExist(err) { - return false - } else { - return true - } - -} - -func main() { - pid := os.Getpid() - if err := os.WriteFile(filepath.Join(internal.PacketsPackageDir(), "udp.pid"), []byte(fmt.Sprint(pid)), 0644); err != nil { - fmt.Println("error saving subprocess pid", err) - } - toml.Decode(filepath.Join(internal.PacketsPackageDir(), "config.toml"), &cfg) - - addr := net.UDPAddr{IP: net.IPv4zero, Port: 1333} - conn, err := net.ListenUDP("udp", &addr) - if err != nil { - log.Fatal(err) - } - defer conn.Close() - buf := make([]byte, 1500) - - for { - n, remote, err := conn.ReadFromUDP(buf) - if err != nil { - log.Println("error creating udp socket", err) - } - msg := string(buf[:n]) - if !strings.HasPrefix(msg, "Q:") { - continue - } - filename := strings.TrimPrefix(msg, "Q:") - if CheckDownloaded(filename) { - reply := fmt.Sprintf("H:%s:%d", filename, cfg.Config.HttpPort) - conn.WriteToUDP([]byte(reply), remote) - } - } -} diff --git a/docs/examples/package.lua b/docs/examples/package.lua deleted file mode 100644 index cf22520..0000000 --- a/docs/examples/package.lua +++ /dev/null @@ -1 +0,0 @@ --- PACKETS SCRIPTS EXAMPLES \ No newline at end of file diff --git a/go.mod b/go.mod deleted file mode 100644 index 0142e22..0000000 --- a/go.mod +++ /dev/null @@ -1,31 +0,0 @@ -module packets - -go 1.24.4 - -require ( - github.com/BurntSushi/toml v1.5.0 - github.com/klauspost/compress v1.18.0 - github.com/schollz/progressbar/v3 v3.18.0 - github.com/spf13/cobra v1.9.1 - github.com/yuin/gopher-lua v1.1.1 - golang.org/x/net v0.41.0 - modernc.org/sqlite v1.38.0 -) - -require ( - github.com/dustin/go-humanize v1.0.1 // indirect - github.com/google/uuid v1.6.0 // indirect - github.com/inconshreveable/mousetrap v1.1.0 // indirect - github.com/mattn/go-isatty v0.0.20 // indirect - github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db // indirect - github.com/ncruces/go-strftime v0.1.9 // indirect - github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect - github.com/rivo/uniseg v0.4.7 // indirect - github.com/spf13/pflag v1.0.7 // indirect - golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 // indirect - golang.org/x/sys v0.33.0 // indirect - golang.org/x/term v0.32.0 // indirect - modernc.org/libc v1.65.10 // indirect - modernc.org/mathutil v1.7.1 // indirect - modernc.org/memory v1.11.0 // indirect -) diff --git a/go.sum b/go.sum deleted file mode 100644 index 784f096..0000000 --- a/go.sum +++ /dev/null @@ -1,85 +0,0 @@ -github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg= -github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho= -github.com/chengxilo/virtualterm v1.0.4 h1:Z6IpERbRVlfB8WkOmtbHiDbBANU7cimRIof7mk9/PwM= -github.com/chengxilo/virtualterm v1.0.4/go.mod h1:DyxxBZz/x1iqJjFxTFcr6/x+jSpqN0iwWCOK1q10rlY= -github.com/cpuguy83/go-md2man/v2 v2.0.6/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g= -github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= -github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY= -github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto= -github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e h1:ijClszYn+mADRFY17kjQEVQ1XRhq2/JR1M3sGqeJoxs= -github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e/go.mod h1:boTsfXsheKC2y+lKOCMpSfarhxDeIzfZG1jqGcPl3cA= -github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= -github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= -github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8= -github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw= -github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo= -github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ= -github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= -github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= -github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc= -github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= -github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db h1:62I3jR2EmQ4l5rM/4FEfDWcRD+abF5XlKShorW5LRoQ= -github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db/go.mod h1:l0dey0ia/Uv7NcFFVbCLtqEBQbrT4OCwCSKTEv6enCw= -github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4= -github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls= -github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= -github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE= -github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo= -github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ= -github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88= -github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM= -github.com/schollz/progressbar/v3 v3.18.0 h1:uXdoHABRFmNIjUfte/Ex7WtuyVslrw2wVPQmCN62HpA= -github.com/schollz/progressbar/v3 v3.18.0/go.mod h1:IsO3lpbaGuzh8zIMzgY3+J8l4C8GjO0Y9S69eFvNsec= -github.com/spf13/cobra v1.9.1 h1:CXSaggrXdbHK9CF+8ywj8Amf7PBRmPCOJugH954Nnlo= -github.com/spf13/cobra v1.9.1/go.mod h1:nDyEzZ8ogv936Cinf6g1RU9MRY64Ir93oCnqb9wxYW0= -github.com/spf13/pflag v1.0.6/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= -github.com/spf13/pflag v1.0.7 h1:vN6T9TfwStFPFM5XzjsvmzZkLuaLX+HS+0SeFLRgU6M= -github.com/spf13/pflag v1.0.7/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= -github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= -github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= -github.com/yuin/gopher-lua v1.1.1 h1:kYKnWBjvbNP4XLT3+bPEwAXJx262OhaHDWDVOPjL46M= -github.com/yuin/gopher-lua v1.1.1/go.mod h1:GBR0iDaNXjAgGg9zfCvksxSRnQx76gclCIb7kdAd1Pw= -golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 h1:R84qjqJb5nVJMxqWYb3np9L5ZsaDtB+a39EqjV0JSUM= -golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0/go.mod h1:S9Xr4PYopiDyqSyp5NjCrhFrqg6A5zA2E/iPHPhqnS8= -golang.org/x/mod v0.24.0 h1:ZfthKaKaT4NrhGVZHO1/WDTwGES4De8KtWO0SIbNJMU= -golang.org/x/mod v0.24.0/go.mod h1:IXM97Txy2VM4PJ3gI61r1YEk/gAj6zAHN3AdZt6S9Ww= -golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw= -golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA= -golang.org/x/sync v0.14.0 h1:woo0S4Yywslg6hp4eUFjTVOyKt0RookbpAHG4c1HmhQ= -golang.org/x/sync v0.14.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA= -golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw= -golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= -golang.org/x/term v0.32.0 h1:DR4lr0TjUs3epypdhTOkMmuF5CDFJ/8pOnbzMZPQ7bg= -golang.org/x/term v0.32.0/go.mod h1:uZG1FhGx848Sqfsq4/DlJr3xGGsYMu/L5GW4abiaEPQ= -golang.org/x/tools v0.33.0 h1:4qz2S3zmRxbGIhDIAgjxvFutSvH5EfnsYrRBj0UI0bc= -golang.org/x/tools v0.33.0/go.mod h1:CIJMaWEY88juyUfo7UbgPqbC8rU2OqfAV1h2Qp0oMYI= -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= -modernc.org/cc/v4 v4.26.1 h1:+X5NtzVBn0KgsBCBe+xkDC7twLb/jNVj9FPgiwSQO3s= -modernc.org/cc/v4 v4.26.1/go.mod h1:uVtb5OGqUKpoLWhqwNQo/8LwvoiEBLvZXIQ/SmO6mL0= -modernc.org/ccgo/v4 v4.28.0 h1:rjznn6WWehKq7dG4JtLRKxb52Ecv8OUGah8+Z/SfpNU= -modernc.org/ccgo/v4 v4.28.0/go.mod h1:JygV3+9AV6SmPhDasu4JgquwU81XAKLd3OKTUDNOiKE= -modernc.org/fileutil v1.3.3 h1:3qaU+7f7xxTUmvU1pJTZiDLAIoJVdUSSauJNHg9yXoA= -modernc.org/fileutil v1.3.3/go.mod h1:HxmghZSZVAz/LXcMNwZPA/DRrQZEVP9VX0V4LQGQFOc= -modernc.org/gc/v2 v2.6.5 h1:nyqdV8q46KvTpZlsw66kWqwXRHdjIlJOhG6kxiV/9xI= -modernc.org/gc/v2 v2.6.5/go.mod h1:YgIahr1ypgfe7chRuJi2gD7DBQiKSLMPgBQe9oIiito= -modernc.org/libc v1.65.10 h1:ZwEk8+jhW7qBjHIT+wd0d9VjitRyQef9BnzlzGwMODc= -modernc.org/libc v1.65.10/go.mod h1:StFvYpx7i/mXtBAfVOjaU0PWZOvIRoZSgXhrwXzr8Po= -modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU= -modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg= -modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI= -modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw= -modernc.org/opt v0.1.4 h1:2kNGMRiUjrp4LcaPuLY2PzUfqM/w9N23quVwhKt5Qm8= -modernc.org/opt v0.1.4/go.mod h1:03fq9lsNfvkYSfxrfUhZCWPk1lm4cq4N+Bh//bEtgns= -modernc.org/sortutil v1.2.1 h1:+xyoGf15mM3NMlPDnFqrteY07klSFxLElE2PVuWIJ7w= -modernc.org/sortutil v1.2.1/go.mod h1:7ZI3a3REbai7gzCLcotuw9AC4VZVpYMjDzETGsSMqJE= -modernc.org/sqlite v1.38.0 h1:+4OrfPQ8pxHKuWG4md1JpR/EYAh3Md7TdejuuzE7EUI= -modernc.org/sqlite v1.38.0/go.mod h1:1Bj+yES4SVvBZ4cBOpVZ6QgesMCKpJZDq0nxYzOpmNE= -modernc.org/strutil v1.2.1 h1:UneZBkQA+DX2Rp35KcM69cSsNES9ly8mQWD71HKlOA0= -modernc.org/strutil v1.2.1/go.mod h1:EHkiggD70koQxjVdSBM3JKM7k6L0FbGE5eymy9i3B9A= -modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y= -modernc.org/token v1.1.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM= diff --git a/internal/internal.go b/internal/internal.go deleted file mode 100644 index d6d4757..0000000 --- a/internal/internal.go +++ /dev/null @@ -1,557 +0,0 @@ -package internal - -import ( - "archive/tar" - "fmt" - "io" - "io/fs" - "log" - "os" - "os/exec" - "path/filepath" - "strings" - - "github.com/BurntSushi/toml" - "github.com/klauspost/compress/zstd" - lua "github.com/yuin/gopher-lua" -) - -var AllowedCmds = map[string]string{ - "go": "go", // "Go code compiler" - "gcc": "gcc", // "C" - "g++": "g++", // "C++" - "rustc": "rustc", // "Rust" - "javac": "javac", // "Java" - "luac": "luac", // "Lua" - "pyinstaller": "pyinstaller", // "Python" - "kotlinc": "kotlinc", // "Kotlin" - "mcs": "mcs", // "C# compiler" - "swiftc": "swiftc", // "Swift compiler" - "ts": "tsc", // "TypeScript compiler" - "ruby": "rubyc", // "Ruby compiler" -} - -type ConfigTOML struct { - Config struct { - HttpPort int `toml:"httpPort"` - CacheDir string `toml:"cacheDir"` - AutoDeleteCacheDir bool `toml:"dayToDeleteCacheDir"` - DaysToDelete int `toml:"daysToDelete"` - DataDir string `toml:"dataDir"` - BinDir string `toml:"binDir"` - LastDataDir string `toml:"lastDataDir"` - } `toml:"Config"` -} - -type Manifest struct { - Info struct { - Name string `toml:"name"` - Version string `toml:"version"` - Description string `toml:"description"` - Dependencies []string `toml:"dependencies"` - Author string `toml:"author"` - Family string `toml:"family"` - Serial uint `toml:"serial"` - } `toml:"Info"` - Hooks struct { - Install string `toml:"install"` - Remove string `toml:"remove"` - } `toml:"Hooks"` -} - -var SandboxDir string - -func PacketsPackageDir() string { - - out, _ := exec.Command("uname", "-s").Output() - - if uname := strings.TrimSpace(string(out)); uname == "J2ME" { - - _, err := os.Stat("packets.help") - if os.IsNotExist(err) { - err = nil - - var thedirectory string - err := filepath.WalkDir("/mnt", func(path string, d fs.DirEntry, err error) error { - if d.IsDir() { - - thedirectory = filepath.Join(path, "packets") - if err := os.Mkdir(thedirectory, 0644); err != nil { - return err - } - if err := os.WriteFile("packets.help", []byte(thedirectory), 0644); err != nil { - return err - } - if err := os.Mkdir(filepath.Join(filepath.Join(thedirectory, "cache")), 0644); err != nil { - return err - } - if err := os.Mkdir(filepath.Join(filepath.Join(thedirectory, "packages")), 0644); err != nil { - return err - } - if err := os.Mkdir(filepath.Join(filepath.Join(thedirectory, "bin")), 0644); err != nil { - return err - } - return nil - } - return nil - }) - if err != nil { - log.Fatal(err) - } - return thedirectory - } - - byt, err := os.ReadFile("packets.help") - if err != nil { - log.Fatal(err) - } - - return string(byt) - - } else { - return "/etc/packets" - } -} - -func ManifestReadXZ(path string) (*Manifest, error) { - f, err := os.Open(path) - if err != nil { - return nil, err - } - defer f.Close() - - zr, err := zstd.NewReader(f) - if err != nil { - return nil, err - } - defer zr.Close() - - tarReader := tar.NewReader(zr) - - for { - header, err := tarReader.Next() - if err == io.EOF { - break - } - if err != nil { - return nil, err - } - - if filepath.Base(header.Name) == "manifest.toml" { - decoder := toml.NewDecoder(tarReader) - - var manifest Manifest - - if _, err := decoder.Decode(&manifest); err != nil { - log.Fatal(err) - } - - return &manifest, nil - } - - } - return nil, fmt.Errorf("can't find manifest.toml") -} - -func DefaultConfigTOML() *ConfigTOML { - - var cfg ConfigTOML - out, _ := exec.Command("uname", "-s").Output() - - if uname := strings.TrimSpace(string(out)); uname == "J2ME" { - cfg.Config.HttpPort = 9123 - cfg.Config.AutoDeleteCacheDir = false - cfg.Config.CacheDir = filepath.Join(PacketsPackageDir(), "cache") - cfg.Config.DataDir = filepath.Join(PacketsPackageDir(), "data") - cfg.Config.DaysToDelete = -1 - cfg.Config.BinDir = filepath.Join(PacketsPackageDir(), "bin") - cfg.Config.LastDataDir = filepath.Join(PacketsPackageDir(), "data") - return &cfg - } else { - - cfg.Config.HttpPort = 9123 - cfg.Config.AutoDeleteCacheDir = false - cfg.Config.CacheDir = "/var/cache/packets" - cfg.Config.DataDir = "/opt/packets" - cfg.Config.DaysToDelete = -1 - cfg.Config.BinDir = "/usr/bin" - cfg.Config.LastDataDir = "/opt/packets" - - return &cfg - } - -} - -func IsSafe(str string) bool { - s, err := filepath.EvalSymlinks(filepath.Clean(str)) - if err != nil { - s = filepath.Clean(str) - } - - var cfg ConfigTOML - toml.DecodeFile(filepath.Join(PacketsPackageDir(), "config.toml"), &cfg) - - if strings.HasPrefix(s, cfg.Config.DataDir) || strings.HasPrefix(s, cfg.Config.BinDir) { - return true - - } else if strings.Contains(s, ".ssh") { - return false - - } else if strings.HasPrefix(s, "/etc") { - return false - - } else if strings.HasPrefix(s, "/usr") || strings.HasPrefix(s, "/bin") { - fmt.Println(s, "estΓ‘ dentro de usr") - return strings.HasPrefix(s, "/usr/share") - - } else if strings.HasPrefix(s, "/var/mail") { - return false - - } else if strings.HasPrefix(s, "/proc") { - return false - - } else if strings.HasPrefix(s, "/sys") { - return false - - } else if strings.HasPrefix(s, "/var/run") || strings.HasPrefix(s, "/run") { - return false - - } else if strings.HasPrefix(s, "/tmp") { - return false - - } else if strings.HasPrefix(s, "/dev") { - return false - - } else if strings.HasPrefix(s, "/boot") { - return false - - } else if strings.HasPrefix(s, "/home") { - if strings.Contains(s, "/Pictures") || strings.Contains(s, "/Videos") || strings.Contains(s, "/Documents") || strings.Contains(s, "/Downloads") { - return false - } - - } else if strings.HasPrefix(s, "/lib") || strings.HasPrefix(s, "/lib64") || strings.HasPrefix(s, "/var/lib64") || strings.HasPrefix(s, "/lib") { - return false - - } else if strings.HasPrefix(s, "/sbin") { - return false - - } else if strings.HasPrefix(s, "/srv") { - return false - - } else if strings.HasPrefix(s, "/mnt") { - return false - - } else if strings.HasPrefix(s, "/media") { - return false - } else if strings.HasPrefix(s, "/snap") { - return false - } - - return true -} - -func SafeRemove(L *lua.LState) int { - filename := L.CheckString(1) - if !IsSafe(filename) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - err := os.RemoveAll(filename) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] remove failed\n" + err.Error())) - return 2 - } - L.Push(lua.LTrue) - L.Push(lua.LNil) - return 2 -} - -func SafeRename(L *lua.LState) int { - oldname := L.CheckString(1) - newname := L.CheckString(2) - - if !IsSafe(oldname) || !IsSafe(newname) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - - if err := os.Rename(oldname, newname); err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] rename failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - return 1 -} -func SafeCopy(L *lua.LState) int { - oldname := L.CheckString(1) - newname := L.CheckString(2) - - if !IsSafe(oldname) || !IsSafe(newname) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - - src, err := os.Open(oldname) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - - } - defer src.Close() - - status, err := src.Stat() - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - - err = os.MkdirAll(filepath.Dir(newname), 0755) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - - dst, err := os.Create(newname) - if err != nil { - if !os.IsExist(err) { - dst, err = os.Open(newname) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - } else { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - } - - defer dst.Close() - if err := dst.Chmod(status.Mode()); err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - - _, err = io.Copy(dst, src) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] copy failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - L.Push(lua.LNil) - return 2 -} - -func SymbolicLua(L *lua.LState) int { - fileName := L.CheckString(1) - destination := L.CheckString(2) - - if !IsSafe(fileName) || !IsSafe(destination) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - - _ = os.RemoveAll(destination) - if err := os.Symlink(fileName, destination); err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] symlink failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - L.Push(lua.LNil) - return 2 -} - -func modeFlags(mode string) int { - switch mode { - case "r", "rb": - return os.O_RDONLY - case "w", "wb": - return os.O_CREATE | os.O_WRONLY | os.O_TRUNC - case "a", "ab": - return os.O_CREATE | os.O_WRONLY | os.O_APPEND - case "r+", "r+b", "rb+", "br+": - return os.O_RDWR - case "w+", "w+b", "wb+", "bw+": - return os.O_CREATE | os.O_RDWR | os.O_TRUNC - case "a+", "a+b", "ab+", "ba+": - return os.O_CREATE | os.O_RDWR | os.O_APPEND - default: - return os.O_RDONLY - } -} - -func SafeOpen(L *lua.LState) int { - path := L.CheckString(1) - mode := L.OptString(2, "r") - - if !IsSafe(path) { - L.Push(lua.LNil) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - file, err := os.OpenFile(path, modeFlags(mode), 0644) - if err != nil { - L.Push(lua.LNil) - L.Push(lua.LString("[packets] open failed\n" + err.Error())) - return 2 - } - - ud := L.NewUserData() - ud.Value = file - L.SetMetatable(ud, L.GetTypeMetatable("file")) - L.Push(ud) - L.Push(lua.LNil) - return 2 -} - -func Ljoin(L *lua.LState) int { - - n := L.GetTop() - parts := make([]string, 0, n) - - for i := 1; i <= n; i++ { - val := L.Get(i) - parts = append(parts, val.String()) - } - - result := filepath.Join(parts...) - L.Push(lua.LString(result)) - return 1 -} - -func LMkdir(L *lua.LState) int { - path := L.CheckString(1) - perm := L.CheckInt(2) - - if !IsSafe(path) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath\n")) - return 2 - } - - if err := os.MkdirAll(path, os.FileMode(perm)); err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] mkdir failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - L.Push(lua.LNil) - return 2 -} - -func LuaCompile(L *lua.LState) int { - lang := L.CheckString(1) - args := []string{} - for i := 2; i <= L.GetTop(); i++ { - - if strings.Contains(L.CheckString(i), "/") { - - tryintoacess, err := filepath.Abs(filepath.Clean(filepath.Join(SandboxDir, L.CheckString(i)))) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] invalid filepath\n" + err.Error())) - return 2 - } - - fmt.Printf("sandboxdir: (%s) acessto: (%s)\n", SandboxDir, tryintoacess) - rel, err := filepath.Rel(SandboxDir, tryintoacess) - if err != nil || strings.HasPrefix(rel, "..") { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - } - - args = append(args, L.CheckString(i)) - } - - bin, suc := AllowedCmds[lang] - if !suc { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsupported language")) - return 2 - } - - cmd := exec.Command(bin, args...) - cmd.Dir = SandboxDir - out, err := cmd.CombinedOutput() - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] compile failed\n" + err.Error() + "\n" + string(out))) - return 2 - } - if err := cmd.Run(); err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] compile failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - L.Push(lua.LString(string(out))) - return 2 -} - -func CompileRequirements(L *lua.LState) int { - - cmdLang := L.CheckString(1) - - if strings.Contains(L.CheckString(2), "/") { - - tryintoacess, err := filepath.Abs(filepath.Clean(L.CheckString(2))) - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] invalid filepath\n" + err.Error())) - return 2 - } - if !strings.HasPrefix(tryintoacess, SandboxDir) { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] unsafe filepath")) - return 2 - } - } - - var err error - - switch cmdLang { - case "python": - cmd := exec.Command("pip", "install", "--target", filepath.Join(SandboxDir, "tmp/build"), "-r", L.CheckString(2)) - cmd.Dir = filepath.Join(SandboxDir, "data") - err = cmd.Run() - case "java": - cmd := exec.Command("mvn", "dependency:copy-dependencies", "-DoutputDirectory="+filepath.Join(SandboxDir, "tmp/build")) - cmd.Dir = L.CheckString(2) - err = cmd.Run() - case "ruby": - cmd := exec.Command("bundle", "install", "--path", filepath.Join(SandboxDir, "tmp/build")) - cmd.Dir = L.CheckString(2) - err = cmd.Run() - } - - if err != nil { - L.Push(lua.LFalse) - L.Push(lua.LString("[packets] requirements install failed\n" + err.Error())) - return 2 - } - - L.Push(lua.LTrue) - L.Push(lua.LNil) - return 2 -}