Skip to content

Fix/error output stderr #410

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
namanyadav-08 wants to merge 2 commits into
base: master
Choose a base branch
from
+47 −46
Open

Fix/error output stderr #410

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
0d608c9
docs: remove duplicate Installation heading in README
namanyadav-08 May 18, 2026
4f28a45
fix: redirect error messages to stderr instead of stdout
namanyadav-08 May 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -89,9 +89,10 @@ microcks [command] [flags]
| `--microcksURL` | Microcks API URL |


## Installation


### Building from Source

To build the CLI locally:

```bash
Expand Down
18 changes: 9 additions & 9 deletions cmd/import.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command
Run: func(cmd *cobra.Command, args []string) {
// Parse subcommand args first.
if len(args) == 0 {
fmt.Println("import command require <specificationFile1[:primary],specificationFile2[:primary]> args")
fmt.Fprintln(os.Stderr, "import command require <specificationFile1[:primary],specificationFile2[:primary]> args")
cmd.HelpFunc()(cmd, args)
os.Exit(1)
}
Expand All @@ -54,7 +54,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command
// Read local config file in case we need some context info.
localConfig, err := config.ReadLocalConfig(globalClientOpts.ConfigPath)
if err != nil {
fmt.Println(err)
fmt.Fprintln(os.Stderr, err)
return
}

Expand All @@ -67,7 +67,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command

keycloakURL, err := mc.GetKeycloakURL()
if err != nil {
fmt.Printf("Got error when invoking Microcks client retrieving config: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client retrieving config: %s", err)
os.Exit(1)
}

Expand All @@ -78,7 +78,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command

oauthToken, err = kc.ConnectAndGetToken()
if err != nil {
fmt.Printf("Got error when invoking Keycloak client: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Keycloak client: %s", err)
os.Exit(1)
}
//fmt.Printf("Retrieve OAuthToken: %s", oauthToken)
Expand All @@ -100,7 +100,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command
} else {
// Create client from config file and using the current or provided context.
if localConfig == nil {
fmt.Println("Please login to perform operation...")
fmt.Fprintln(os.Stderr, "Please login to perform operation...")
return
}

Expand All @@ -110,7 +110,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command

mc, err = connectors.NewClient(*globalClientOpts)
if err != nil {
fmt.Printf("error %v", err)
fmt.Fprintf(os.Stderr, "error %v", err)
return
}
}
Expand All @@ -134,14 +134,14 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command
// Try uploading this artifact.
msg, err := mc.UploadArtifact(f, mainArtifact)
if err != nil {
fmt.Printf("Got error when invoking Microcks client importing Artifact: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client importing Artifact: %s", err)
os.Exit(1)
}
action := "discovered"
if !mainArtifact {
action = "completed"
}
fmt.Printf("Microcks has %s '%s'\n", action, msg)
fmt.Fprintf(os.Stderr, "Microcks has %s '%s'\n", action, msg)

// If watch flag is provided, update watch config.
if watch {
Expand Down Expand Up @@ -180,7 +180,7 @@ func NewImportCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command
wm, err := watcher.NewWatchManger(watchFile)
errors.CheckError(err)

fmt.Println("Watch mode enabled - microcks-watcher started...")
fmt.Fprintln(os.Stderr, "Watch mode enabled - microcks-watcher started...")
wm.Run()
}
},
Expand Down
28 changes: 14 additions & 14 deletions cmd/importDir.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -130,12 +130,12 @@ func NewImportDirCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm

localConfig, err := config.ReadLocalConfig(globalClientOpts.ConfigPath)
if err != nil {
fmt.Println(err)
fmt.Fprintln(os.Stderr, err)
return
}

if localConfig == nil {
fmt.Println("Please login to perform operation...")
fmt.Fprintln(os.Stderr, "Please login to perform operation...")
return
}

Expand All @@ -146,7 +146,7 @@ func NewImportDirCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm
// Create client
mc, err := connectors.NewClient(*globalClientOpts)
if err != nil {
fmt.Printf("error %v", err)
fmt.Fprintf(os.Stderr, "error %v", err)
return
}

Expand All @@ -162,41 +162,41 @@ func NewImportDirCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm
result, err := ImportDirectory(mc, fs, dirPath, importConfig)
if err != nil {
if validationErr, ok := err.(*ValidationError); ok {
fmt.Println(validationErr.Message)
return
fmt.Fprintln(os.Stderr, validationErr.Message)
os.Exit(1)
}
fmt.Printf("Error: %v\n", err)
fmt.Fprintf(os.Stderr, "Error: %v\n", err)
os.Exit(1)
}

// Display results
if verbose {
fmt.Printf("Found %d specification files to import...\n", result.TotalFiles)
fmt.Fprintf(os.Stderr, "Found %d specification files to import...\n", result.TotalFiles)
for i, file := range result.SuccessFiles {
fmt.Printf("[%d/%d] ✓ Imported: %s\n", i+1, result.TotalFiles, file)
fmt.Fprintf(os.Stderr, "[%d/%d] ✓ Imported: %s\n", i+1, result.TotalFiles, file)
}
for i, file := range result.FailedFiles {
errorMsg := "Unknown error"
if i < len(result.Errors) {
errorMsg = result.Errors[i]
}
fmt.Printf("✗ Failed: %s - %s\n", file, errorMsg)
fmt.Fprintf(os.Stderr, "✗ Failed: %s - %s\n", file, errorMsg)
}
} else {
fmt.Println("\nImport results:")
fmt.Fprintln(os.Stderr, "\nImport results:")
for _, file := range result.SuccessFiles {
fmt.Printf("✓ Imported: %s\n", file)
fmt.Fprintf(os.Stderr, "✓ Imported: %s\n", file)
}
for i, file := range result.FailedFiles {
errorMsg := "Unknown error"
if i < len(result.Errors) {
errorMsg = result.Errors[i]
}
fmt.Printf("✗ Failed: %s - %s\n", file, errorMsg)
fmt.Fprintf(os.Stderr, "✗ Failed: %s - %s\n", file, errorMsg)
}
}

fmt.Printf("\nImport completed: %d/%d files imported successfully\n", result.SuccessCount, result.TotalFiles)
fmt.Fprintf(os.Stderr, "\nImport completed: %d/%d files imported successfully\n", result.SuccessCount, result.TotalFiles)
},
}

Expand Down Expand Up @@ -242,7 +242,7 @@ func ImportDirectory(client MicrocksClient, fs FileSystem, dirPath string, confi
if !fileType.IsPrimary {
action = "completed"
}
fmt.Printf("Microcks has %s '%s'\n", action, msg)
fmt.Fprintf(os.Stderr, "Microcks has %s '%s'\n", action, msg)
}

result.SuccessCount++
Expand Down
6 changes: 3 additions & 3 deletions cmd/importURL.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ func NewImportURLCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm
Run: func(cmd *cobra.Command, args []string) {
// Parse subcommand args first.
if len(args) == 0 {
fmt.Println("import-url command require <specificationFile1URL[:primary],specificationFile2URL[:primary]> args")
fmt.Fprintln(os.Stderr, "import-url command require <specificationFile1URL[:primary],specificationFile2URL[:primary]> args")
os.Exit(1)
}

Expand All @@ -53,7 +53,7 @@ func NewImportURLCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm

keycloakURL, err := mc.GetKeycloakURL()
if err != nil {
fmt.Printf("Got error when invoking Microcks client retrieving config: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client retrieving config: %s", err)
os.Exit(1)
}

Expand All @@ -64,7 +64,7 @@ func NewImportURLCommand(globalClientOpts *connectors.ClientOptions) *cobra.Comm

oauthToken, err = kc.ConnectAndGetToken()
if err != nil {
fmt.Printf("Got error when invoking Keycloak client: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Keycloak client: %s", err)
os.Exit(1)
}
//fmt.Printf("Retrieve OAuthToken: %s", oauthToken)
Expand Down
38 changes: 19 additions & 19 deletions cmd/test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {
Run: func(cmd *cobra.Command, args []string) {
// Parse subcommand args first.
if len(os.Args) < 4 {
fmt.Println("test command require <apiName:apiVersion> <testEndpoint> <runner> args")
fmt.Fprintln(os.Stderr, "test command require <apiName:apiVersion> <testEndpoint> <runner> args")
os.Exit(1)
}

Expand All @@ -58,25 +58,25 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {

// Validate presence and values of args.
if len(serviceRef) == 0 || strings.HasPrefix(serviceRef, "-") {
fmt.Println("test command require <apiName:apiVersion> <testEndpoint> <runner> args")
fmt.Fprintln(os.Stderr, "test command require <apiName:apiVersion> <testEndpoint> <runner> args")
os.Exit(1)
}
if len(testEndpoint) == 0 || strings.HasPrefix(testEndpoint, "-") {
fmt.Println("test command require <apiName:apiVersion> <testEndpoint> <runner> args")
fmt.Fprintln(os.Stderr, "test command require <apiName:apiVersion> <testEndpoint> <runner> args")
os.Exit(1)
}
if len(runnerType) == 0 || strings.HasPrefix(runnerType, "-") {
fmt.Println("test command require <apiName:apiVersion> <testEndpoint> <runner> args")
fmt.Fprintln(os.Stderr, "test command require <apiName:apiVersion> <testEndpoint> <runner> args")
os.Exit(1)
}
if _, validChoice := runnerChoices[runnerType]; !validChoice {
fmt.Println("<runner> should be one of: HTTP, SOAP_HTTP, SOAP_UI, POSTMAN, OPEN_API_SCHEMA, ASYNC_API_SCHEMA, GRPC_PROTOBUF, GRAPHQL_SCHEMA")
fmt.Fprintln(os.Stderr, "<runner> should be one of: HTTP, SOAP_HTTP, SOAP_UI, POSTMAN, OPEN_API_SCHEMA, ASYNC_API_SCHEMA, GRPC_PROTOBUF, GRAPHQL_SCHEMA")
os.Exit(1)
}

// Validate presence and values of flags.
if !strings.HasSuffix(waitFor, "milli") && !strings.HasSuffix(waitFor, "sec") && !strings.HasSuffix(waitFor, "min") {
fmt.Println("--waitFor format is wrong. Accepted units are: milli, sec, min (e.g. 500milli, 30sec, 5min)")
fmt.Fprintln(os.Stderr, "--waitFor format is wrong. Accepted units are: milli, sec, min (e.g. 500milli, 30sec, 5min)")
os.Exit(1)
}

Expand All @@ -90,21 +90,21 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {
if strings.HasSuffix(waitFor, "milli") {
n, err := strconv.ParseInt(waitFor[:len(waitFor)-5], 0, 64)
if err != nil {
fmt.Printf("--waitFor value %q is not a valid number\n", waitFor)
fmt.Fprintf(os.Stderr, "--waitFor value %q is not a valid number\n", waitFor)
os.Exit(1)
}
waitForMilliseconds = n
} else if strings.HasSuffix(waitFor, "sec") {
n, err := strconv.ParseInt(waitFor[:len(waitFor)-3], 0, 64)
if err != nil {
fmt.Printf("--waitFor value %q is not a valid number\n", waitFor)
fmt.Fprintf(os.Stderr, "--waitFor value %q is not a valid number\n", waitFor)
os.Exit(1)
}
waitForMilliseconds = n * 1000
} else if strings.HasSuffix(waitFor, "min") {
n, err := strconv.ParseInt(waitFor[:len(waitFor)-3], 0, 64)
if err != nil {
fmt.Printf("--waitFor value %q is not a valid number\n", waitFor)
fmt.Fprintf(os.Stderr, "--waitFor value %q is not a valid number\n", waitFor)
os.Exit(1)
}
waitForMilliseconds = n * 60 * 1000
Expand All @@ -121,7 +121,7 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {

keycloakURL, err := mc.GetKeycloakURL()
if err != nil {
fmt.Printf("Got error when invoking Microcks client retrieving config: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client retrieving config: %s", err)
os.Exit(1)
}

Expand All @@ -132,7 +132,7 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {

oauthToken, err = kc.ConnectAndGetToken()
if err != nil {
fmt.Printf("Got error when invoking Keycloak client: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Keycloak client: %s", err)
os.Exit(1)
}
//fmt.Printf("Retrieve OAuthToken: %s", oauthToken)
Expand All @@ -144,12 +144,12 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {
} else {
localConfig, err := config.ReadLocalConfig(globalClientOpts.ConfigPath)
if err != nil {
fmt.Println(err)
fmt.Fprintln(os.Stderr, err)
return
}

if localConfig == nil {
fmt.Println("Please login to perform operation...")
fmt.Fprintln(os.Stderr, "Please login to perform operation...")
return
}

Expand All @@ -159,7 +159,7 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {

mc, err = connectors.NewClient(*globalClientOpts)
if err != nil {
fmt.Printf("error %v", err)
fmt.Fprintf(os.Stderr, "error %v", err)
return
}

Expand All @@ -172,7 +172,7 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {
var testResultID string
testResultID, err := mc.CreateTestResult(serviceRef, testEndpoint, runnerType, secretName, waitForMilliseconds, filteredOperations, operationsHeaders, oAuth2Context)
if err != nil {
fmt.Printf("Got error when invoking Microcks client creating Test: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client creating Test: %s", err)
os.Exit(1)
}
//fmt.Printf("Retrieve TestResult ID: %s", testResultID)
Expand All @@ -188,22 +188,22 @@ func NewTestCommand(globalClientOpts *connectors.ClientOptions) *cobra.Command {
for nowInMilliseconds() < future {
testResultSummary, err := mc.GetTestResult(testResultID)
if err != nil {
fmt.Printf("Got error when invoking Microcks client check TestResult: %s", err)
fmt.Fprintf(os.Stderr, "Got error when invoking Microcks client check TestResult: %s", err)
os.Exit(1)
}
success = testResultSummary.Success
inProgress := testResultSummary.InProgress
fmt.Printf("MicrocksClient got status for test \"%s\" - success: %s, inProgress: %s \n", testResultID, fmt.Sprint(success), fmt.Sprint(inProgress))
fmt.Fprintf(os.Stderr, "MicrocksClient got status for test \"%s\" - success: %s, inProgress: %s \n", testResultID, fmt.Sprint(success), fmt.Sprint(inProgress))

if !inProgress {
break
}

fmt.Println("MicrocksTester waiting for 2 seconds before checking again or exiting.")
fmt.Fprintln(os.Stderr, "MicrocksTester waiting for 2 seconds before checking again or exiting.")
time.Sleep(2 * time.Second)
}

fmt.Printf("Full TestResult details are available here: %s/#/tests/%s \n", serverAddr, testResultID)
fmt.Fprintf(os.Stderr, "Full TestResult details are available here: %s/#/tests/%s \n", serverAddr, testResultID)

if !success {
os.Exit(1)
Expand Down