cleanup code

Author: yulistremovsky-dot

src/main/java/org/databunker/DatabunkerproApi.java

@@ -15,7 +15,6 @@
 import org.databunker.options.LegalBasisOptions;
 
 import org.databunker.options.AgreementAcceptOptions;
-import org.databunker.options.ConnectorOptions;
 import org.databunker.options.TenantOptions;
 import org.databunker.options.ProcessingActivityOptions;
 
@@ -803,139 +802,6 @@ public Map<String, Object> unlinkProcessingActivityFromLegalBasis(String activit
         return makeRequest("ProcessingActivityUnlinkLegalBasis", data, requestMetadata);
     }
 
-    // Connector Management
-    public Map<String, Object> listSupportedConnectors(Map<String, Object> requestMetadata) throws IOException {
-        return makeRequest("ConnectorListSupportedConnectors", null, requestMetadata);
-    }
-
-    public Map<String, Object> listConnectors(Map<String, Object> requestMetadata) throws IOException {
-        return makeRequest("ConnectorListConnectors", null, requestMetadata);
-    }
-
-    /**
-     * Creates a connector with typed options
-     *
-     * @param options         Typed options for connector creation
-     * @param requestMetadata Optional request metadata
-     * @return The created connector information
-     * @throws IOException If an I/O error occurs
-     */
-    public Map<String, Object> createConnector(ConnectorOptions options, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        if (options != null) {
-            data.putAll(OptionsConverter.toMap(options));
-        }
-        return makeRequest("ConnectorCreate", data, requestMetadata);
-    }
-
-    /**
-     * Updates a connector with typed options
-     *
-     * @param connectorid     Connector ID
-     * @param options         Typed options for connector update
-     * @param requestMetadata Optional request metadata
-     * @return The updated connector information
-     * @throws IOException If an I/O error occurs
-     */
-    public Map<String, Object> updateConnector(String connectorid, ConnectorOptions options, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        data.put("connectorid", Integer.parseInt(connectorid));
-        if (options != null) {
-            data.putAll(OptionsConverter.toMap(options));
-        }
-        return makeRequest("ConnectorUpdate", data, requestMetadata);
-    }
-
-    /**
-     * Validates connector connectivity with typed options
-     *
-     * @param connectorref    Connector reference (ID or name)
-     * @param options         Typed options for connector validation (can be null)
-     * @param requestMetadata Optional request metadata
-     * @return The validation result
-     * @throws IOException If an I/O error occurs
-     */
-    public Map<String, Object> validateConnectorConnectivity(String connectorref, ConnectorOptions options, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        if (options != null) {
-            data.putAll(OptionsConverter.toMap(options));
-        }
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorValidateConnectivity", data, requestMetadata);
-    }
-
-    public Map<String, Object> deleteConnector(String connectorref, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorDelete", data, requestMetadata);
-    }
-
-    /**
-     * Gets table metadata with typed options
-     *
-     * @param connectorref    Connector reference (ID or name)
-     * @param options         Typed options for getting table metadata
-     * @param requestMetadata Optional request metadata
-     * @return The table metadata
-     * @throws IOException If an I/O error occurs
-     */
-    public Map<String, Object> getTableMetadata(String connectorref, ConnectorOptions options, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        if (options != null) {
-            data.putAll(OptionsConverter.toMap(options));
-        }
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorGetTableMetaData", data, requestMetadata);
-    }
-
-    public Map<String, Object> connectorGetUserData(String mode, String identity, String connectorref, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        data.put("mode", mode);
-        data.put("identity", identity);
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorGetUserData", data, requestMetadata);
-    }
-
-    public Map<String, Object> connectorGetUserExtraData(String mode, String identity, String connectorref, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        data.put("mode", mode);
-        data.put("identity", identity);
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorGetUserExtraData", data, requestMetadata);
-    }
-
-    public Map<String, Object> connectorDeleteUser(String mode, String identity, String connectorref, Map<String, Object> requestMetadata) throws IOException {
-        Map<String, Object> data = new HashMap<>();
-        data.put("mode", mode);
-        data.put("identity", identity);
-        if (connectorref.matches("\\d+")) {
-            data.put("connectorid", Integer.parseInt(connectorref));
-        } else {
-            data.put("connectorname", connectorref);
-        }
-        return makeRequest("ConnectorDeleteUser", data, requestMetadata);
-    }
-
     // Group Management
     /**
      * Creates a group with typed options

src/main/java/org/databunker/examples/TypedOptionsExample.java

@@ -6,7 +6,6 @@
 import org.databunker.options.SharedRecordOptions;
 import org.databunker.options.LegalBasisOptions;
 import org.databunker.options.AgreementAcceptOptions;
-import org.databunker.options.ConnectorOptions;
 import org.databunker.options.TenantOptions;
 import org.databunker.options.ProcessingActivityOptions;
 import org.databunker.options.GroupOptions;
@@ -103,25 +102,8 @@ public static void main(String[] args) {
 
             Map<String, Object> agreement = api.acceptAgreement("email", "user@example.com", "marketing-consent", agreementOptions, null);
             System.out.println("Accepted agreement: " + agreement.get("status"));
-            
-            // Example 7: Create connector with typed ConnectorOptions
-            ConnectorOptions connectorOptions = ConnectorOptions.builder()
-                .connectorname("my-connector")
-                .connectortype("mysql")
-                .apikey("api-key-123")
-                .username("dbuser")
-                .connectordesc("MySQL database connector")
-                .dbhost("localhost")
-                .dbport(3306)
-                .dbname("mydb")
-                .tablename("users")
-                .status("active")
-                .build();
-            
-            Map<String, Object> connector = api.createConnector(connectorOptions, null);
-            System.out.println("Created connector: " + connector.get("connectorid"));
-            
-            // Example 8: Create processing activity with typed ProcessingActivityOptions
+
+            // Example 7: Create processing activity with typed ProcessingActivityOptions
             ProcessingActivityOptions activityOptions = ProcessingActivityOptions.builder()
                 .activity("data-processing")
                 .title("Data Processing Activity")