utils

package

Go to main page

Versions in this module

v0

v0.1.5

Oct 14, 2026

Changes in this version

+ const DagDefinitionFileName

+ const IOSchemaFileName

+ const ReadmeFileName

+ var ErrGitFileAbsent = stderrs.New("file is not part of HEAD or the worktree")

+ var ErrGitPathInvalid = stderrs.New("file path must be a relative path inside the repository")

+ var ErrGitRepoHasNoCommit = stderrs.New("git repository has no commit to push")

+ var ErrGitRepoNotInitialized = stderrs.New("local directory is not a git repository")

+ func AcceptFormats(formItem map[string]interface{}) []string

+ func AcceptFormatsFromResolver(resolver map[string]interface{}) []string

+ func FetchBareRepoFromRemote(ctx context.Context, repoPath, remoteName string) error

+ func FormatIOSchemaItems(raw any) map[string]any

+ func FormatJSONIndent(raw []byte) ([]byte, error)

+ func GenerateStorePathName() (string, error)

+ func GetAnalysisURLPrefix(baseDir, outputDir string) string

+ func GetProjectDocBookDir(baseDir, projectId, reportID string) string

+ func MarshalJSONIndent(value any) ([]byte, error)

+ func PushBareRepoToRemote(ctx context.Context, repoPath, remoteName string) (branch string, pushed bool, err error)

+ func ReadScriptFileContent(baseDir, projectID, scriptType, scriptID string) ([]byte, error)

+ func ReadScriptIOSchema(baseDir, projectID, scriptID string) (map[string]any, error)

+ func ReadScriptIOSchemaFile(baseDir, projectID, scriptID string) ([]byte, error)

+ func ReadScriptReadme(baseDir, projectID, scriptID string) ([]byte, error)

+ func ReadWorkflowDagDefinition(baseDir, projectID, workflowID string) (map[string]any, error)

+ func ReadWorkflowDagDefinitionFile(baseDir, projectID, workflowID string) ([]byte, error)

+ func ReadWorkflowIOSchema(baseDir, projectID, workflowID string) (map[string]any, error)

+ func ReadWorkflowIOSchemaFile(baseDir, projectID, workflowID string) ([]byte, error)

+ func ReadWorkflowReadme(baseDir, projectID, workflowID string) ([]byte, error)

+ func RemoteURL(repo *git.Repository, remoteName string) string

+ func ResolveGitAuth(remoteURL string) (transport.AuthMethod, error)

+ func RevertWorktreeFile(dir, relPath string) error

+ func ScriptIOSchemaPath(baseDir, projectID, scriptID string) string

+ func ScriptMainFilePath(baseDir, projectID, scriptType, scriptID string) string

+ func ScriptReadmePath(baseDir, projectID, scriptID string) string

+ func WorkflowDagDefinitionPath(baseDir, projectID, workflowID string) string

+ func WorkflowIOSchemaPath(baseDir, projectID, workflowID string) string

+ func WorkflowReadmePath(baseDir, projectID, workflowID string) string

+ func WriteFileEnsureDir(path string, data []byte) error

+ func WriteJSONFile(path string, value any) error

+ func WriteScriptFileContent(baseDir, projectID, scriptType, scriptID, content string) error

+ func WriteScriptIOSchema(baseDir, projectID, scriptID, content string) error

+ func WriteScriptReadme(baseDir, projectID, scriptID, content string) error

+ func WriteWorkflowDagDefinition(baseDir, projectID, workflowID, content string) error

+ func WriteWorkflowIOSchema(baseDir, projectID, workflowID, content string) error

+ func WriteWorkflowReadme(baseDir, projectID, workflowID, content string) error

+ type GitDiffFile struct

+ Additions int

+ Binary bool

+ Deletions int

+ Diff string

+ Omitted bool

+ Path string

+ Status string

+ type GitDiffResult struct

+ HasChanges bool

+ HeadCommit string

+ Initialized bool

+ RepoDir string

+ Unpublished *GitDiffSection

+ Worktree GitDiffSection

+ func ReadGitDiff(localDir, storeDir string) GitDiffResult

+ type GitDiffSection struct

+ Additions int

+ BaseCommit string

+ Deletions int

+ FileCount int

+ Files []GitDiffFile

+ HasChanges bool

+ Patch string

+ TargetCommit string

+ Truncated bool

+ type GitRemote struct

+ Name string

+ URLs []string

+ func EnsureGitRemote(repoPath, remoteURL string) (remote GitRemote, added bool, err error)

+ func ReadGitRemotes(repoPath string) []GitRemote

type GitSyncState

+ Remotes []GitRemote

v0.1.4

Sep 19, 2026

Changes in this version

+ func CommitAll(repo *git.Repository, message string, identity GitIdentity) (bool, error)

+ func CommitDirChanges(dir, commitMessage string, identity GitIdentity) error

+ func CopyDirReplace(srcDir string, dstDir string, exclude ...string) error

+ func EnsureBareGitRepo(dir string) (*git.Repository, error)

+ func EnsureGitRepo(dir string) (*git.Repository, error)

+ func FetchBareRepoFromOrigin(ctx context.Context, repoPath string) error

+ func FindFileInGitRepo(repoPath, fileName string) (string, error)

+ func GetAnalysisNodeCacheDir(workspaceDir string) string

+ func GetAnalysisNodeEnvFile(workspaceDir string) string

+ func GetAnalysisNodeOutputDir(workspaceDir string) string

+ func GetDatasetDir(baseDir, projectId string, datasetID int64) string

+ func GetStoreDir(baseDir string) string

+ func GetWorkflowFileDir(baseDir, projectId, workflowID string) string

+ func GetWorkflowOrScriptStoreDir(baseDir, id string) string

+ func PushDirToRepo(ctx context.Context, sourceDir, targetRepoPath string) error

+ func ReadFileFromGitRepo(repoPath, relPath string) ([]byte, error)

+ func RelPath(baseDir, path string) string

+ func RelStoreDir(id string) string

+ func ResolvePath(baseDir, path string) string

+ func SyncWorktreeFromRepo(ctx context.Context, targetDir, srcRepoPath string) error

+ type AnalysisLayout struct

+ CommandLogPath string

+ CommandPath string

+ Dir string

+ ExecutorLogFile string

+ ParamsPath string

+ TraceFile string

+ WorkflowLogFile string

+ func AnalysisLayoutFor(workspaceDir string) AnalysisLayout

+ type GitIdentity struct

+ Email string

+ Name string

+ type GitSyncState struct

+ HasLocalChanges bool

+ HasStoreChanges bool

+ InSync bool

+ LocalAhead bool

+ LocalCommit string

+ LocalDir string

+ LocalDirty bool

+ LocalInitialized bool

+ StoreAhead bool

+ StoreCommit string

+ StoreDir string

+ StoreInitialized bool

+ func ReadGitSyncState(localDir, storeDir string) GitSyncState

+ type NodeLayout struct

+ CacheDir string

+ CommandPath string

+ Dir string

+ LogPath string

+ OutputDir string

+ ParamsPath string

+ func NodeLayoutFor(workspaceDir string) NodeLayout

v0.1.3

Sep 1, 2026

v0.1.2

Aug 31, 2026

Changes in this version

+ func GetProjectLiteratureDir(baseDir, projectId, literatureID string) string

+ func GetProjectReportDir(baseDir, projectId, reportID string) string

v0.1.1

Aug 27, 2026

Changes in this version

+ const EncPrefix

+ var AllowedStdioCommands = map[string]bool

+ var DangerousArgPatterns = []*regexp.Regexp

+ var DangerousEnvVarPatterns = []*regexp.Regexp

+ var ErrEncryptedDataMissingKey = errors.New("encrypted data found but SYSTEM_AES_KEY is not set or has wrong length")

+ var ErrSSRFRedirectBlocked = fmt.Errorf("redirect blocked: target URL failed SSRF validation")

+ func CleanMarkdown(input string) string

+ func CopyDir(srcDir, dstDir string) error

+ func CopyDirectory(srcDir, dstParentDir string) error

+ func CopyFile(src, dst string, perm os.FileMode) error

+ func DecryptAESGCM(encrypted string, key []byte) (string, error)

+ func DecryptStoredSecret(encrypted string) (string, error)

+ func EncryptAESGCM(plaintext string, key []byte) (string, error)

+ func EscapeHTML(input string) string

+ func GenerateID() int64

+ func GetAESKey() []byte

+ func GetAnalysisDebugDir(baseDir, analysisID, version string) string

+ func GetAnalysisDir(baseDir, projectId string, workflow int64) string

+ func GetAnalysisNodeDir(baseDir, projectId, scriptID string) string

+ func GetCurrentTime() time.Time

+ func GetProjectDir(baseDir, projectId string) string

+ func GetProjectDocDir(baseDir, projectId string) string

+ func GetScriptDir(baseDir, projectId string) string

+ func GetScriptFile(baseDir, projectID, scriptType, scriptID string) (string, string, error)

+ func GetScriptFileDir(baseDir, projectId, scriptID string) string

+ func GetWorkflowDir(baseDir, projectId string) string

+ func InitSnowflake(workerID int64) error

+ func IsPublicIP(ip net.IP) bool

+ func IsSSRFWhitelisted(hostname string) bool

+ func IsSystemProxy(host string) bool

+ func IsValidImageURL(url string) bool

+ func IsValidURL(url string) bool

+ func NewSSRFSafeHTTPClient(config SSRFSafeHTTPClientConfig) *http.Client

+ func ResolveConfiguredPath(configuredPath string, defaultRelativeToExecutable string) (string, error)

+ func ResolveExternalPath(relativePath string) (string, error)

+ func ResolveImageDir(baseDir string) string

+ func SSRFSafeDialContext(ctx context.Context, network, addr string) (net.Conn, error)

+ func SafeFileName(fileName string) (string, error)

+ func SafeObjectKey(objectKey string) error

+ func SafePathUnderBase(baseDir, filePath string) (string, error)

+ func SanitizeForDisplay(input string) string

+ func SanitizeForLog(input string) string

+ func SanitizeForLogArray(input []string) []string

+ func SanitizeHTML(input string) string

+ func ValidateInput(input string) (string, bool)

+ func ValidateStdioArgs(args []string) error

+ func ValidateStdioCommand(command string) error

+ func ValidateStdioConfig(command string, args []string, envVars map[string]string) error

+ func ValidateStdioEnvVars(envVars map[string]string) error

+ func ValidateURLForSSRF(rawURL string) error

+ type SSRFSafeHTTPClientConfig struct

+ DisableCompression bool

+ DisableKeepAlives bool

+ MaxRedirects int

+ Timeout time.Duration

+ func DefaultSSRFSafeHTTPClientConfig() SSRFSafeHTTPClientConfig

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL