style(rust): better format some test code

Author: etorreborre

implementations/rust/ockam/ockam_api/src/cli_state/storage/journeys_repository_sql.rs

@@ -241,61 +241,61 @@ mod test {
     #[tokio::test]
     async fn test_several_host_journeys() -> Result<()> {
         with_application_dbs(|db| async move {
-        let repository: Arc<dyn JourneysRepository> =
-        Arc::new(JourneysSqlxDatabase::new(db));
-
-        // create and store a the first host journey
-        let opentelemetry_context1 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-01\",\"tracestate\":\"\"}").unwrap();
-        let start1 = Utc::now();
-        let host_journey1 = Journey::new(opentelemetry_context1.clone(), None, start1);
-        repository.store_host_journey(host_journey1.clone()).await?;
-
-        // retrieve the journey based on the time
-        //   before the journey 1 start -> None
-        //   equal or after the journey 1 start -> Some(journey1)
-        let actual = repository
-            .get_host_journey(start1.sub(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, None);
-
-        let actual = repository.get_host_journey(start1).await?;
-        assert_eq!(actual, Some(host_journey1.clone()));
-
-        let actual = repository
-            .get_host_journey(start1.add(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(host_journey1.clone()));
-
-        // Create the next journey
-        let opentelemetry_context2 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-02\",\"tracestate\":\"\"}").unwrap();
-        let start2 = start1.add(Duration::from_secs(1000));
-        let host_journey2 = Journey::new(
-            opentelemetry_context2.clone(),
-            Some(opentelemetry_context1),
-            start2,
-        );
-        repository.store_host_journey(host_journey2.clone()).await?;
-        // retrieve the journey based on the time
-        //   right before the journey 2 start -> Some(journey1)
-        //   equal or after the journey 2 start -> Some(journey2)
-        let actual = repository
-            .get_host_journey(start2.sub(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(host_journey1.clone()));
-
-        let actual = repository.get_host_journey(start2).await?;
-        assert_eq!(actual, Some(host_journey2.clone()));
-        assert_eq!(
-            host_journey2.previous_opentelemetry_context(),
-            Some(host_journey1.opentelemetry_context())
-        );
+            let repository: Arc<dyn JourneysRepository> =
+            Arc::new(JourneysSqlxDatabase::new(db));
+
+            // create and store a the first host journey
+            let opentelemetry_context1 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-01\",\"tracestate\":\"\"}").unwrap();
+            let start1 = Utc::now();
+            let host_journey1 = Journey::new(opentelemetry_context1.clone(), None, start1);
+            repository.store_host_journey(host_journey1.clone()).await?;
+
+            // retrieve the journey based on the time
+            //   before the journey 1 start -> None
+            //   equal or after the journey 1 start -> Some(journey1)
+            let actual = repository
+                .get_host_journey(start1.sub(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, None);
+
+            let actual = repository.get_host_journey(start1).await?;
+            assert_eq!(actual, Some(host_journey1.clone()));
+
+            let actual = repository
+                .get_host_journey(start1.add(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(host_journey1.clone()));
+
+            // Create the next journey
+            let opentelemetry_context2 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-02\",\"tracestate\":\"\"}").unwrap();
+            let start2 = start1.add(Duration::from_secs(1000));
+            let host_journey2 = Journey::new(
+                opentelemetry_context2.clone(),
+                Some(opentelemetry_context1),
+                start2,
+            );
+            repository.store_host_journey(host_journey2.clone()).await?;
+            // retrieve the journey based on the time
+            //   right before the journey 2 start -> Some(journey1)
+            //   equal or after the journey 2 start -> Some(journey2)
+            let actual = repository
+                .get_host_journey(start2.sub(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(host_journey1.clone()));
+
+            let actual = repository.get_host_journey(start2).await?;
+            assert_eq!(actual, Some(host_journey2.clone()));
+            assert_eq!(
+                host_journey2.previous_opentelemetry_context(),
+                Some(host_journey1.opentelemetry_context())
+            );
 
-        let actual = repository
-            .get_host_journey(start2.add(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(host_journey2));
+            let actual = repository
+                .get_host_journey(start2.add(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(host_journey2));
 
-        Ok(())
+            Ok(())
         }).await
     }
 
@@ -307,63 +307,64 @@ mod test {
                 Arc::new(JourneysSqlxDatabase::new(db));
 
             // create and store a the first host journey
-        let opentelemetry_context1 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-01\",\"tracestate\":\"\"}").unwrap();
-        let start1 = Utc::now();
-        let project_journey1 =
-            ProjectJourney::new("project_id", opentelemetry_context1.clone(), None, start1);
-        repository
-            .store_project_journey(project_journey1.clone())
-            .await?;
-
-        // retrieve the journey based on the time
-        //   before the journey 1 start -> None
-        //   equal or after the journey 1 start -> Some(journey1)
-        let actual = repository
-            .get_project_journey("project_id", start1.sub(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, None);
-
-        let actual = repository.get_project_journey("project_id", start1).await?;
-        assert_eq!(actual, Some(project_journey1.clone()));
-
-        let actual = repository
-            .get_project_journey("project_id", start1.add(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(project_journey1.clone()));
-
-        // Create the next journey
-        let opentelemetry_context2 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-02\",\"tracestate\":\"\"}").unwrap();
-        let start2 = start1.add(Duration::from_secs(1000));
-        let project_journey2 = ProjectJourney::new(
-            "project_id",
-            opentelemetry_context2.clone(),
-            Some(opentelemetry_context1),
-            start2,
-        );
-        repository
-            .store_project_journey(project_journey2.clone())
-            .await?;
-
-        // retrieve the journey based on the time
-        //   right before the journey 2 start -> Some(journey1)
-        //   equal or after the journey 2 start -> Some(journey2)
-        let actual = repository
-            .get_project_journey("project_id", start2.sub(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(project_journey1.clone()));
-
-        let actual = repository.get_project_journey("project_id", start2).await?;
-        assert_eq!(actual, Some(project_journey2.clone()));
-        assert_eq!(
-            project_journey2.previous_opentelemetry_context(),
-            Some(project_journey1.opentelemetry_context())
-        );
+            let opentelemetry_context1 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-01\",\"tracestate\":\"\"}").unwrap();
+            let start1 = Utc::now();
+            let project_journey1 =
+                ProjectJourney::new("project_id", opentelemetry_context1.clone(), None, start1);
+            repository
+                .store_project_journey(project_journey1.clone())
+                .await?;
+
+            // retrieve the journey based on the time
+            //   before the journey 1 start -> None
+            //   equal or after the journey 1 start -> Some(journey1)
+            let actual = repository
+                .get_project_journey("project_id", start1.sub(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, None);
+
+            let actual = repository.get_project_journey("project_id", start1).await?;
+            assert_eq!(actual, Some(project_journey1.clone()));
+
+            let actual = repository
+                .get_project_journey("project_id", start1.add(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(project_journey1.clone()));
+
+            // Create the next journey
+            let opentelemetry_context2 = OpenTelemetryContext::from_str("{\"traceparent\":\"00-b9ce70eaad5a86ef6b9fa4db00589e86-8e2d99c5e5ed66e4-02\",\"tracestate\":\"\"}").unwrap();
+            let start2 = start1.add(Duration::from_secs(1000));
+            let project_journey2 = ProjectJourney::new(
+                "project_id",
+                opentelemetry_context2.clone(),
+                Some(opentelemetry_context1),
+                start2,
+            );
+            repository
+                .store_project_journey(project_journey2.clone())
+                .await?;
+
+            // retrieve the journey based on the time
+            //   right before the journey 2 start -> Some(journey1)
+            //   equal or after the journey 2 start -> Some(journey2)
+            let actual = repository
+                .get_project_journey("project_id", start2.sub(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(project_journey1.clone()));
 
-        let actual = repository
-            .get_project_journey("project_id", start2.add(Duration::from_secs(3)))
-            .await?;
-        assert_eq!(actual, Some(project_journey2));
+            let actual = repository.get_project_journey("project_id", start2).await?;
+            assert_eq!(actual, Some(project_journey2.clone()));
+            assert_eq!(
+                project_journey2.previous_opentelemetry_context(),
+                Some(project_journey1.opentelemetry_context())
+            );
 
-        Ok(()) }).await
+            let actual = repository
+                .get_project_journey("project_id", start2.add(Duration::from_secs(3)))
+                .await?;
+            assert_eq!(actual, Some(project_journey2));
+
+            Ok(())
+        }).await
     }
 }