wip

Author: isabella

packages/cli/tests/push/process_completeness.nu

@@ -0,0 +1,56 @@
+use ../../test.nu *
+use std assert
+
+# Create a remote server.
+let remote_server = spawn -n remote
+
+# Create a local server.
+let local_server = spawn -n local
+
+# Add the remote.
+let output = tg remote put local $remote_server.url | complete
+success $output
+
+# Use the pre-generated test directory with a deep process tree (100 processes deep).
+const path = path self "../../../../test_process_completeness"
+
+# Build the module.
+let output = run tg -u $local_server.url build -d $path | from json
+
+# Parse the process ID.
+let process_id = $output.process
+
+# Wait for the process to complete.
+tg wait $process_id
+
+# First push.
+let first_push = tg -u $local_server.url push -r local --recursive $process_id | complete
+success $first_push
+
+# Parse the number of objects from the first push.
+# The output format is "pushed {} processes, {} objects, {} bytes".
+let first_match = ($first_push.stderr | parse -r 'pushed (\d+) processes, (\d+) objects, (\d+) bytes')
+assert (($first_match | length) > 0) "expected to find push output in first push"
+let first_processes = $first_match.0.capture0 | into int
+let first_objects = $first_match.0.capture1 | into int
+let first_bytes = $first_match.0.capture2 | into int
+print -e $first_push.stderr
+
+# Index.
+run tg -u $local_server.url index
+run tg -u $remote_server.url index
+
+let second_push = tg -u $local_server.url push -r local --recursive --commands $process_id | complete
+success $second_push
+
+# Parse the number of objects from the second push.
+print -e $second_push.stderr
+let second_match = ($second_push.stderr | parse -r 'pushed (\d+) processes, (\d+) objects, (\d+) bytes')
+assert (($second_match | length) > 0) "expected to find push output in second push"
+let second_processes = $second_match.0.capture0 | into int
+let second_objects = $second_match.0.capture1 | into int
+let second_bytes = $second_match.0.capture2 | into int
+
+exit 1
+
+assert ($second_objects < $first_objects) $"expected second push to have fewer objects \(($second_objects)\) than first push \(($first_objects)\)"