fix(cli): fix for meta-cli deploy exit with code 0 on failure (#600)

fix the issue where `meta-cli deploy` command exits with code 0 on
failure.

#### Motivation and context

bug fix

#### Migration notes

No changes needed.

### Checklist

- [ ] The change come with new or modified tests
- [ ] Hard-to-understand functions have explanatory comments
- [ ] End-user documentation is updated to reflect the change

meta-cli/src/cli/deploy.rs

@@ -259,7 +259,11 @@ mod default_mode {
             };
 
             log::debug!("loader stopped, stopping pusher");
-            pusher.stop().await?;
+            let result = pusher.stop().await;
+            if let Err(e) = result {
+                System::current().stop_with_code(1);
+                return Err(e);
+            }
             ret
         }
 

meta-cli/src/deploy/actors/push_manager.rs

@@ -72,6 +72,7 @@ impl PushManagerBuilder {
                 retry_config: self.retry_config,
                 typegraph_paths: HashMap::new(),
                 one_time_push_options: HashMap::new(),
+                failed_push_exists: false,
             }
         })
     }
@@ -90,6 +91,7 @@ pub struct PushManagerActor {
     typegraph_paths: HashMap<String, PathBuf>,
     // maps: typegraph_key -> option
     one_time_push_options: HashMap<String, Vec<OneTimePushOption>>,
+    failed_push_exists: bool,
 }
 
 impl PushManagerActor {
@@ -363,6 +365,9 @@ impl Handler<PushFinished> for PushManagerActor {
                 name = name.cyan()
             ));
         }
+        if !self.failed_push_exists {
+            self.failed_push_exists = !msg.success;
+        }
 
         let res = self.remove_active(&msg.push.typegraph);
         let Some(CancelationStatus(is_cancelled)) = res else {
@@ -412,6 +417,20 @@ impl Handler<Stop> for PushManagerActor {
     }
 }
 
+#[derive(Message)]
+#[rtype(result = "()")]
+struct SendBackFailedStatus {
+    failure_tx: oneshot::Sender<bool>,
+}
+
+impl Handler<SendBackFailedStatus> for PushManagerActor {
+    type Result = ();
+
+    fn handle(&mut self, msg: SendBackFailedStatus, _ctx: &mut Self::Context) -> Self::Result {
+        msg.failure_tx.send(self.failed_push_exists).unwrap();
+    }
+}
+
 #[derive(Message)]
 #[rtype(result = "()")]
 struct CancelAllFromModule {
@@ -441,7 +460,13 @@ impl PushManager for Addr<PushManagerActor> {
         self.do_send(Stop { tx });
         rx.await?;
         log::trace!("PushManager stopped");
-        Ok(())
+        let (failure_tx, failure_rx) = oneshot::channel();
+        self.do_send(SendBackFailedStatus { failure_tx });
+        let failed = failure_rx.await.unwrap();
+        match failed {
+            false => Ok(()),
+            true => Err(anyhow::anyhow!("Pushing one or more typegraphs failed")),
+        }
     }
 
     async fn cancel_all_from(&self, path: &Path) -> Result<()> {

typegate/tests/e2e/cli/deploy_test.ts

@@ -114,6 +114,7 @@ Meta.test(
     });
 
     try {
+      await reset("e2e7895alt");
       await deploy(port);
     } catch (e) {
       assertStringIncludes(