print errors

cmd/sst/progress.go

@@ -15,9 +15,10 @@ import (
 var urnRegex = regexp.MustCompile(`\/[^:]+`)
 
 type Progress struct {
-	Color color.Attribute
-	Label string
-	URN   string
+	Color   color.Attribute
+	Label   string
+	URN     string
+	Message string
 	time.Duration
 }
 
@@ -38,11 +39,15 @@ func progress(events project.StackEventStream) {
 		if progress.Duration != 0 {
 			color.New(color.FgHiBlack).Printf(" (%s)", progress.Duration)
 		}
+		if progress.Message != "" {
+			color.New(color.FgHiBlack).Print(" ", progress.Message)
+		}
 		fmt.Println()
 		spin.Enable()
 	}
 
 	timing := make(map[string]time.Time)
+	errors := make(map[string]string)
 	outputs := make(map[string]interface{})
 
 	for evt := range events {
@@ -52,11 +57,13 @@ func progress(events project.StackEventStream) {
 			spin.Enable()
 			continue
 		}
+
 		if evt.ResourcePreEvent != nil {
 			timing[evt.ResourcePreEvent.Metadata.URN] = time.Now()
 			if evt.ResourcePreEvent.Metadata.Type == "pulumi:pulumi:Stack" {
 				continue
 			}
+
 			if evt.ResourcePreEvent.Metadata.Op == apitype.OpSame {
 				printProgress(Progress{
 					Color: color.FgHiBlack,
@@ -85,6 +92,16 @@ func progress(events project.StackEventStream) {
 				continue
 			}
 
+			if evt.ResourcePreEvent.Metadata.Op == apitype.OpReplace {
+				printProgress(Progress{
+					Color: color.FgYellow,
+					Label: "Updating",
+					URN:   evt.ResourcePreEvent.Metadata.URN,
+				})
+
+				continue
+			}
+
 			if evt.ResourcePreEvent.Metadata.Op == apitype.OpDelete {
 				printProgress(Progress{
 					Color: color.FgYellow,
@@ -129,16 +146,46 @@ func progress(events project.StackEventStream) {
 				})
 			}
 		}
+
+		if evt.ResOpFailedEvent != nil {
+		}
+
+		if evt.DiagnosticEvent != nil {
+			if strings.HasPrefix(evt.DiagnosticEvent.Prefix, "error") && evt.DiagnosticEvent.URN != "" {
+				splits := strings.Split(evt.DiagnosticEvent.Message, "\n")
+				splits = strings.Split(splits[1], ":")
+				error := strings.TrimSpace(splits[len(splits)-1])
+				errors[evt.DiagnosticEvent.URN] = error
+				printProgress(Progress{
+					URN:     evt.DiagnosticEvent.URN,
+					Color:   color.FgRed,
+					Label:   "Error   ",
+					Message: error,
+				})
+			}
+		}
 	}
 
 	spin.Stop()
-	color.New(color.FgGreen, color.Bold).Print("\n✔")
-	color.New(color.FgWhite, color.Bold).Println("  Deployed:")
 
-	for k, v := range outputs {
-		color.New(color.FgHiBlack).Print("   ")
-		color.New(color.FgHiBlack, color.Bold).Print(k + ": ")
-		color.New(color.FgWhite).Println(v)
+	if len(errors) == 0 {
+		color.New(color.FgGreen, color.Bold).Print("\n✔")
+		color.New(color.FgWhite, color.Bold).Println("  Deployed:")
+
+		for k, v := range outputs {
+			color.New(color.FgHiBlack).Print("   ")
+			color.New(color.FgHiBlack, color.Bold).Print(k + ": ")
+			color.New(color.FgWhite).Println(v)
+		}
+	} else {
+		color.New(color.FgRed, color.Bold).Print("\n❌")
+		color.New(color.FgWhite, color.Bold).Println(" Failed:")
+
+		for k, v := range errors {
+			color.New(color.FgHiBlack).Print("   ")
+			color.New(color.FgRed, color.Bold).Print(formatURN(k) + ": ")
+			color.New(color.FgWhite).Println(v)
+		}
 	}
 
 }

examples/test-old/sst.config.ts

@@ -11,7 +11,9 @@ export default {
   },
   stacks(app) {
     app.stack(function Default(ctx) {
-      // const b = new CfnBucket(ctx.stack, "MyBucket");
+      const b = new CfnBucket(ctx.stack, "MyBucket", {
+        bucketName: "sst",
+      });
       ctx.stack.addOutputs({
         // url: b.attrDomainName,
       });

examples/test/sst.config.ts

@@ -9,7 +9,9 @@ export default {
     };
   },
   async run() {
-    const bucket = new aws.s3.Bucket("my-bucket");
+    const bucket = new aws.s3.Bucket("my-bucket", {
+      bucket: "sst",
+    });
     return {
       url: util.interpolate`https://${bucket.bucketDomainName}`,
     };

internal/components/src/runtime/index.ts

@@ -0,0 +1,3 @@
+import { LocalWorkspace } from "@pulumi/pulumi/automation";
+
+const stack = await LocalWorkspace.createStack({});

pkg/js/js.go

@@ -137,7 +137,7 @@ type EvalMessage struct {
 func (p *Process) Eval(input EvalOptions) error {
 	outfile := filepath.Join(input.Dir,
 		"eval",
-		fmt.Sprintf("eval-%x.mjs", time.Now().Unix()),
+		fmt.Sprintf("eval-%x.mjs", time.Now().UnixMilli()),
 	)
 	slog.Info("esbuild building")
 	result := esbuild.Build(esbuild.BuildOptions{

pkg/project/stack.go

@@ -77,6 +77,7 @@ func (s *stack) runtime() (string, error) {
         },
         envVars: {
           PULUMI_CONFIG_PASSPHRASE: "",
+          PULUMI_SKIP_UPDATE_CHECK: "true",
           PULUMI_EXPERIMENTAL: "1",
           PULUMI_SKIP_CHECKPOINTS: "true",
           NODE_PATH: app.paths.temp + "/node_modules",
@@ -108,13 +109,16 @@ func (s *stack) run(cmd string) (StackEventStream, error) {
 		Dir: s.project.PathTemp(),
 		Code: fmt.Sprintf(`
       %v
-      await stack.%v({
-        // onOutput: (line) => console.log(new Date().toISOString(), line),
-        onEvent: (evt) => {
-          console.log("~e" + JSON.stringify(evt))
-          // console.log(JSON.stringify(evt, null, 4))
-        },
-      })
+      try {
+        const result = await stack.%v({
+          // onOutput: (line) => console.log(new Date().toISOString(), line),
+          logVerbosity: 0,
+          onEvent: (evt) => {
+            console.log("~e" + JSON.stringify(evt))
+          },
+        })
+      } catch (e) {
+      }
     `, stack, cmd),
 	})
 	if err != nil {