feat(superoffice): Restore full main.py functionality and add health check [2ff88f42]

This commit restores the full functionality of the  script within the  module. Several  instances were resolved by implementing missing methods in  (e.g., , , , , , , ) and correcting argument passing.

The data extraction logic in  was adjusted to correctly parse the structure returned by the SuperOffice API (e.g.,  and ).

A dedicated SuperOffice API health check script () was introduced to quickly verify basic API connectivity (reading contacts and persons). This script confirmed that read operations for  and  entities are functional, while the  endpoint continues to return a , which is now handled gracefully as a warning, allowing other tests to proceed.

The  now successfully executes all SuperOffice-specific POC steps, including creating contacts, persons, sales, projects, and updating UDFs.

connector-superoffice/superoffice_client.py

@@ -136,3 +136,120 @@ class SuperOfficeClient:
                 return None
         
         return all_results
+
+    def find_contact_by_criteria(self, name=None, org_nr=None, url=None):
+        """
+        Finds a contact (company) by name, OrgNr, or URL.
+        Returns the first matching contact or None.
+        """
+        filter_parts = []
+        if name:
+            filter_parts.append(f"Name eq '{name}'")
+        if org_nr:
+            filter_parts.append(f"OrgNr eq '{org_nr}'")
+        if url:
+            filter_parts.append(f"UrlAddress eq '{url}'")
+
+        if not filter_parts:
+            print("❌ No criteria provided for contact search.")
+            return None
+
+        query_string = "Contact?$filter=" + " or ".join(filter_parts)
+        results = self.search(query_string)
+        if results:
+            return results[0] # Return the first match
+        return None
+
+    def _post(self, endpoint, payload):
+        """Generic POST request."""
+        try:
+            resp = requests.post(f"{self.base_url}/{endpoint}", headers=self.headers, json=payload)
+            resp.raise_for_status()
+            return resp.json()
+        except requests.exceptions.HTTPError as e:
+            print(f"❌ API POST Error for {endpoint} (Status: {e.response.status_code}): {e.response.text}")
+            return None
+        except Exception as e:
+            print(f"❌ Connection Error during POST for {endpoint}: {e}")
+            return None
+
+    def create_contact(self, name: str, url: str = None, org_nr: str = None):
+        """Creates a new contact (company)."""
+        payload = {"Name": name}
+        if url:
+            payload["UrlAddress"] = url
+        if org_nr:
+            payload["OrgNr"] = org_nr
+        
+        print(f"Creating new contact: {name} with payload: {payload}...") # Added payload to log
+        return self._post("Contact", payload)
+
+    def create_person(self, first_name: str, last_name: str, contact_id: int, email: str = None):
+        """Creates a new person linked to a contact."""
+        payload = {
+            "Firstname": first_name,
+            "Lastname": last_name,
+            "Contact": {"ContactId": contact_id}
+        }
+        if email:
+            payload["EmailAddress"] = email
+        
+        print(f"Creating new person: {first_name} {last_name} for Contact ID {contact_id}...")
+        return self._post("Person", payload)
+
+    def create_sale(self, title: str, contact_id: int, person_id: int, amount: float = None):
+        """Creates a new sale (opportunity) linked to a contact and person."""
+        payload = {
+            "Heading": title,
+            "Contact": {"ContactId": contact_id},
+            "Person": {"PersonId": person_id}
+        }
+        if amount:
+            payload["Amount"] = amount
+        
+        print(f"Creating new sale: {title}...")
+        return self._post("Sale", payload)
+
+    def create_project(self, name: str, contact_id: int, person_id: int = None):
+        """Creates a new project linked to a contact, and optionally adds a person."""
+        payload = {
+            "Name": name,
+            "Contact": {"ContactId": contact_id}
+        }
+        if person_id:
+            # Adding a person to a project requires a ProjectMember object
+            payload["ProjectMembers"] = [
+                {
+                    "Person": {"PersonId": person_id},
+                    "Role": "Member" # Default role, can be configured if needed
+                }
+            ]
+        
+        print(f"Creating new project: {name}...")
+        return self._post("Project", payload)
+    
+    def update_entity_udfs(self, entity_id: int, entity_type: str, udf_data: dict):
+        """
+        Updates UDFs for a given entity (Contact or Person).
+        Args:
+            entity_id (int): ID of the entity.
+            entity_type (str): 'Contact' or 'Person'.
+            udf_data (dict): Dictionary with ProgId:Value pairs for UDFs.
+        Returns:
+            dict: The updated entity object from the API, or None on failure.
+        """
+        # We need to GET the existing entity, update its UDFs, then PUT it back.
+        endpoint = f"{entity_type}/{entity_id}"
+        existing_entity = self._get(endpoint)
+        if not existing_entity:
+            print(f"❌ Failed to retrieve existing {entity_type} {entity_id} for UDF update.")
+            return None
+
+        if "UserDefinedFields" not in existing_entity:
+            existing_entity["UserDefinedFields"] = {}
+        
+        existing_entity["UserDefinedFields"].update(udf_data)
+        
+        print(f"Updating {entity_type} {entity_id} UDFs: {udf_data}...")
+        return self._put(endpoint, existing_entity)
+