-
Notifications
You must be signed in to change notification settings - Fork 44
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: 'kpm run' supports compile single kcl file
- Loading branch information
Showing
115 changed files
with
531 additions
and
20 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| package constants | ||
|
|
||
| const ( | ||
| KFilePathSuffix = ".k" | ||
| TarPathSuffix = ".tar" | ||
| OciScheme = "oci" | ||
| FileEntry = "file" | ||
| UrlEntry = "url" | ||
| RefEntry = "ref" | ||
| TarEntry = "tar" | ||
| KCL_MOD = "kcl.mod" | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -93,6 +93,7 @@ const ( | |
| AddItselfAsDep | ||
| PkgTagExists | ||
| DependencyNotFound | ||
| KclModNotFound | ||
| CompileFailed | ||
| ) | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,199 @@ | ||
| package runner | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "os" | ||
| "path/filepath" | ||
| "sort" | ||
|
|
||
| "github.com/golang-collections/collections/set" | ||
| "kcl-lang.io/kpm/pkg/constants" | ||
| "kcl-lang.io/kpm/pkg/errors" | ||
| "kcl-lang.io/kpm/pkg/reporter" | ||
| "kcl-lang.io/kpm/pkg/utils" | ||
| ) | ||
|
|
||
| // Entry is the entry of 'kpm run'. | ||
| type Entry struct { | ||
| // The package source of the entry, filepath, tar path, url or ref. | ||
| packageSource string | ||
| // The start files for one compilation. | ||
| entryFiles []string | ||
| // The kind of the entry, file, tar, url or ref. | ||
| kind string | ||
| // If the entry is a fake package, | ||
| // which means the entry only contains kcl files without kcl.mod. | ||
| isFakePackage bool | ||
| } | ||
|
|
||
| // SetKind will set the kind of the entry. | ||
| func (e *Entry) SetKind(kind string) { | ||
| e.kind = kind | ||
| } | ||
|
|
||
| // Kind will return the kind of the entry. | ||
| func (e *Entry) Kind() string { | ||
| return e.kind | ||
| } | ||
|
|
||
| // IsLocalFile will return true if the entry is a local file. | ||
| func (e *Entry) IsLocalFile() bool { | ||
| return e.kind == constants.FileEntry | ||
| } | ||
|
|
||
| // IsUrl will return true if the entry is a url. | ||
| func (e *Entry) IsUrl() bool { | ||
| return e.kind == constants.UrlEntry | ||
| } | ||
|
|
||
| // IsRef will return true if the entry is a ref. | ||
| func (e *Entry) IsRef() bool { | ||
| return e.kind == constants.RefEntry | ||
| } | ||
|
|
||
| // IsTar will return true if the entry is a tar. | ||
| func (e *Entry) IsTar() bool { | ||
| return e.kind == constants.TarEntry | ||
| } | ||
|
|
||
| // IsEmpty will return true if the entry is empty. | ||
| func (e *Entry) IsEmpty() bool { | ||
| return len(e.packageSource) == 0 | ||
| } | ||
|
|
||
| // PackageSource will return the package source of the entry. | ||
| func (e *Entry) PackageSource() string { | ||
| return e.packageSource | ||
| } | ||
|
|
||
| // EntryFiles will return the entry files of the entry. | ||
| func (e *Entry) EntryFiles() []string { | ||
| return e.entryFiles | ||
| } | ||
|
|
||
| // SetPackageSource will set the package source of the entry. | ||
| func (e *Entry) SetPackageSource(packageSource string) { | ||
| e.packageSource = packageSource | ||
| } | ||
|
|
||
| // SetIsFakePackage will set the 'isFakePackage' flag. | ||
| func (e *Entry) SetIsFakePackage(isFakePackage bool) { | ||
| e.isFakePackage = isFakePackage | ||
| } | ||
|
|
||
| // IsFakePackage will return the 'isFakePackage' flag. | ||
| func (e *Entry) IsFakePackage() bool { | ||
| return e.isFakePackage | ||
| } | ||
|
|
||
| // AddEntryFile will add a entry file to the entry. | ||
| func (e *Entry) AddEntryFile(entrySource string) { | ||
| e.entryFiles = append(e.entryFiles, entrySource) | ||
| } | ||
|
|
||
| // FindRunEntryFrom will find the entry of the compilation from the entry sources. | ||
| func FindRunEntryFrom(sources []string) (*Entry, *reporter.KpmEvent) { | ||
| entry := Entry{} | ||
| // modPathSet is used to check if there are multiple packages to be compiled at the same time. | ||
| // It is a set of the package source so that the same package source will only be added once. | ||
| var modPathSet = set.New() | ||
| for _, source := range sources { | ||
| // If the entry is a local file but not a tar file, | ||
| if utils.DirExists(source) && !utils.IsTar(source) { | ||
| // Find the 'kcl.mod' | ||
| modPath, err := FindModRootFrom(source) | ||
| if err != (*reporter.KpmEvent)(nil) { | ||
| // If the 'kcl.mod' is not found, | ||
| if err.Type() == reporter.KclModNotFound { | ||
| if utils.IsKfile(source) { | ||
| // If the entry is a kcl file, the parent dir of the kcl file will be package path. | ||
| modPath = filepath.Dir(source) | ||
| } else { | ||
| // If the entry is a dir, the dir will be package path. | ||
| modPath = source | ||
| } | ||
| } else { | ||
| return nil, err | ||
| } | ||
| } | ||
| entry.SetPackageSource(modPath) | ||
| entry.AddEntryFile(source) | ||
| entry.SetKind(constants.FileEntry) | ||
| entry.SetIsFakePackage(!utils.DirExists(filepath.Join(modPath, constants.KCL_MOD))) | ||
| absModPath, bugerr := filepath.Abs(modPath) | ||
| if bugerr != nil { | ||
| return nil, reporter.NewErrorEvent(reporter.Bug, bugerr, errors.InternalBug.Error()) | ||
| } | ||
| modPathSet.Insert(absModPath) | ||
| } else if utils.IsURL(source) || utils.IsRef(source) || utils.IsTar(source) { | ||
| modPathSet.Insert(source) | ||
| entry.SetPackageSource(source) | ||
| entry.SetKind(GetSourceKindFrom(source)) | ||
| } | ||
| } | ||
|
|
||
| // kpm only allows one package to be compiled at a time. | ||
| if modPathSet.Len() > 1 { | ||
| // sort the mod paths to make the error message more readable. | ||
| var modPaths []string | ||
| setModPathsMethod := func(modpath interface{}) { | ||
| p, ok := modpath.(string) | ||
| if !ok { | ||
| modPaths = append(modPaths, "") | ||
| } else { | ||
| modPaths = append(modPaths, p) | ||
| } | ||
| } | ||
| modPathSet.Do(setModPathsMethod) | ||
| sort.Strings(modPaths) | ||
| return nil, reporter.NewErrorEvent( | ||
| reporter.CompileFailed, | ||
| fmt.Errorf("cannot compile multiple packages %s at the same time", modPaths), | ||
| "only allows one package to be compiled at a time", | ||
| ) | ||
| } | ||
|
|
||
| return &entry, nil | ||
| } | ||
|
|
||
| // GetSourceKindFrom will return the kind of the source. | ||
| func GetSourceKindFrom(source string) string { | ||
| if utils.DirExists(source) && !utils.IsTar(source) { | ||
| return constants.FileEntry | ||
| } else if utils.IsTar(source) { | ||
| return constants.TarEntry | ||
| } else if utils.IsURL(source) { | ||
| return constants.UrlEntry | ||
| } else if utils.IsRef(source) { | ||
| return constants.RefEntry | ||
| } | ||
| return "" | ||
| } | ||
|
|
||
| // FindModRootFrom will find the kcl.mod path from the start path. | ||
| func FindModRootFrom(startPath string) (string, *reporter.KpmEvent) { | ||
| info, err := os.Stat(startPath) | ||
| if err != nil { | ||
| return "", reporter.NewErrorEvent(reporter.CompileFailed, fmt.Errorf("failed to access path '%s'", startPath)) | ||
| } | ||
| var start string | ||
| // If the start path is a kcl file, find from the parent dir of the kcl file. | ||
| if utils.IsKfile(startPath) { | ||
| start = filepath.Dir(startPath) | ||
| } else if info.IsDir() { | ||
| // If the start path is a dir, find from the start path. | ||
| start = startPath | ||
| } else { | ||
| return "", reporter.NewErrorEvent(reporter.CompileFailed, fmt.Errorf("invalid file path '%s'", startPath)) | ||
| } | ||
|
|
||
| if _, err := os.Stat(filepath.Join(start, constants.KCL_MOD)); err == nil { | ||
| return start, nil | ||
| } else { | ||
| parent := filepath.Dir(startPath) | ||
| if parent == startPath { | ||
| return "", reporter.NewErrorEvent(reporter.KclModNotFound, fmt.Errorf("cannot find kcl.mod in '%s'", startPath)) | ||
| } | ||
| return FindModRootFrom(filepath.Dir(startPath)) | ||
| } | ||
| } |
Oops, something went wrong.