chore: Add user agent in the rest API call headers (#18)

* chore: Add user agent in the rest API call headers

* chore: Add user agent in the rest API call headers

* chore: ugprade dbapi driver version, add smoke test for sql operator

airflow_providers_wherobots/hooks/rest_api.py

@@ -2,10 +2,13 @@
 Hook for WhereRobots API
 """
 
+import platform
 from functools import cached_property
 from typing import Any, Optional
 
 import requests
+from importlib import metadata
+from airflow.version import version as airflow_version
 from airflow.hooks.base import BaseHook
 from airflow.models import Connection
 from requests import PreparedRequest, Response
@@ -61,6 +64,20 @@ def __exit__(self, exc_type, exc_val, exc_tb):
     def conn(self) -> Connection:
         return self.get_connection(self.wherobots_conn_id)
 
+    @cached_property
+    def user_agent_header(self):
+        try:
+            package_version = metadata.version("airflow-providers-wherobots")
+        except metadata.PackageNotFoundError:
+            package_version = "unknown"
+        python_version = platform.python_version()
+        system = platform.system().lower()
+        header_value = (
+            f"airflow-providers-wherobots/{package_version} os/{system}"
+            f" python/{python_version} airflow/{airflow_version}"
+        )
+        return {"User-Agent": header_value}
+
     def _api_call(
         self,
         method: str,
@@ -71,7 +88,12 @@ def _api_call(
         auth = WherobotsAuth(self.conn.password)
         url = "https://" + self.conn.host.rstrip("/") + endpoint
         resp = self.session.request(
-            url=url, method=method, json=payload, auth=auth, params=params
+            url=url,
+            method=method,
+            json=payload,
+            auth=auth,
+            params=params,
+            headers=self.user_agent_header,
         )
         try:
             resp.raise_for_status()
@@ -98,3 +120,7 @@ def get_run_logs(self, run_id: str, start: int, size: int = 500) -> LogsResponse
         params = {"cursor": start, "size": size}
         resp_json = self._api_call("GET", f"/runs/{run_id}/logs", params=params).json()
         return LogsResponse.model_validate(resp_json)
+
+
+if __name__ == "__main__":
+    metadata.version("airflow-providers-wherobots")