Adding CLI and SDK for push delta files

Author: SeqLaz

qfieldcloud_sdk/cli.py

@@ -459,6 +459,27 @@ def job_status(ctx: Context, job_id):
     else:
         log(f'Job status for {job_id}: {status["status"]}')
 
+@cli.command(short_help="Push a delta file to a project.")
+@click.argument("project_id")
+@click.argument("delta_filename", type=click.Path(exists=True))
+@click.pass_context
+def delta_push(ctx: Context, project_id: str, delta_filename: str) -> None:
+    """Push a delta file to a project with PROJECT_ID."""
+    log(f'Pushing delta file "{delta_filename}" to project "{project_id}"…')
+
+    try:
+        response = ctx.obj["client"].push_delta(project_id, delta_filename)
+
+        if ctx.obj["format_json"]:
+            print_json(response)
+        else:
+            log(f'Delta file "{delta_filename}" pushed to project "{project_id}".')
+    except Exception as e:
+        log(f"Error pushing delta file: {e}")
+        if ctx.obj["format_json"]:
+            print_json({"error": str(e)})
+        else:
+            click.echo(f"Error: {e}", err=True)
 
 @cli.command()
 @click.argument("project_id")

qfieldcloud_sdk/sdk.py

@@ -617,6 +617,33 @@ def job_status(self, job_id: str) -> Dict[str, Any]:
 
         return resp.json()
 
+    def push_delta(self, project_id: str, delta_filename: str) -> Dict[str, Any]:
+        """Push a delta file to a project.
+
+        Args:
+            project_id: Project ID.
+            delta_filename: Path to the delta JSON file.
+
+        Returns:
+            A dictionary containing the response from the server.
+        """
+        try:
+            with open(delta_filename, 'r') as delta_file:
+                files = {'file': delta_file}
+                resp = self._request(
+                    "POST",
+                    f"deltas/{project_id}/",
+                    files=files,
+                )
+            print(f"Response status code: {resp.status_code}")
+
+            if resp.content:
+                return resp.json()
+            else:
+                return {"message": "Delta pushed successfully"}
+        except Exception as e:
+            raise RuntimeError(f"Failed to push delta: {e}")
+
     def delete_files(
         self,
         project_id: str,