Class ConnectorValidationService

java.lang.Object

ai.pipeline.connector.intake.service.ConnectorValidationService

@ApplicationScoped
public class ConnectorValidationService
extends Object

Service for validating connector API keys and fetching connector configuration.

This service provides the boundary between connector-intake-service and connector-service, ensuring proper microservice architecture without database coupling.

Uses stock Quarkus gRPC clients with Stork service discovery to locate connector-admin and account-manager.

Constructor Summary

Constructors

Constructor	Description
ConnectorValidationService()	Default constructor for CDI.

Method Summary

Modifier and Type	Method	Description
ai.pipestream.connector.intake.v1.DataSourceConfig	validateDataSource(String datasourceId, String apiKey)	Validate a datasource's API key and fetch its configuration.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConnectorValidationService

public ConnectorValidationService()

Default constructor for CDI.

Method Details

validateDataSource

public ai.pipestream.connector.intake.v1.DataSourceConfig validateDataSource(String datasourceId,
 String apiKey)

Validate a datasource's API key and fetch its configuration.

Behavior:

• Discovers and calls datasource-admin to validate the API key and retrieve datasource config.
• Then verifies the owning account exists and is active via account-service.

Uses standard async gRPC stubs and StreamObserver callbacks. Side effects: network calls to datasource-admin and account-service.

Parameters:

datasourceId - The datasource ID

apiKey - The plaintext API key to validate

Returns:

the datasource config when validation succeeds