judo-runtimeaccess-api-overview

name: judo-runtime:access-api-overview description: Comprehensive guide to JUDO Access Manager API interfaces. Use when you need to understand operation authorization, implement custom authentication interceptors, work with signed identifiers, or integrate access control into your application. metadata: author: BlackBelt Technology version: "${project.version}"

JUDO Access Manager API Overview

Complete guide to the Access Manager API interfaces in JUDO Runtime Core.

Overview

The Access Manager API module (judo-runtime-core-accessmanager-api) defines the core contracts for:

• Operation Authorization - Controlling access to operations based on actor/principal
• Authentication Interception - Hooking into the authentication/authorization lifecycle
• Signed Identifiers - Tracking entity instances in bound operations

This is a pure API module with no dependencies on implementation details, making it suitable for use across different runtime configurations.

Architecture

graph TB
    subgraph "Client Request"
        A[HTTP Request with JWT]
    end
    
    subgraph "Security Layer"
        B[Authentication]
        C[Principal Extraction]
    end
    
    subgraph "Access Manager API"
        D[AccessManager]
        E[AuthenticationInterceptor]
        F[AuthenticationInterceptorProvider]
        G[SignedIdentifier]
    end
    
    subgraph "Dispatcher"
        H[Operation Execution]
    end
    
    A --> B
    B --> C
    C --> D
    D --> E
    F -.->|provides| E
    D -->|uses| G
    D -->|authorize| H
    
    style D fill:#f9f,stroke:#333,stroke-width:2px
    style E fill:#bbf,stroke:#333,stroke-width:2px
    style G fill:#bfb,stroke:#333,stroke-width:2px

Core Interfaces

AccessManager

The primary interface for authorizing operation calls. Implementations decide whether a given operation is allowed based on the principal, operation metadata, and signed identifier.

package hu.blackbelt.judo.runtime.core.accessmanager.api;

/**
 * Access manager is used to check if a given operation call is allowed.
 */
public interface AccessManager {

    /**
     * Authorize an operation call.
     *
     * @param operation operation to call (EMF EOperation)
     * @param signedIdentifier signed identifier of bound operation
     * @param exchange exchange map containing request context
     */
    void authorizeOperation(EOperation operation, 
                           SignedIdentifier signedIdentifier, 
                           Map<String, Object> exchange);
}

Key Points:

• Throws AccessDeniedException if authorization fails
• Throws AuthenticationRequiredException if authentication is needed
• The exchange map contains Dispatcher.PRINCIPAL_KEY with the JudoPrincipal

SignedIdentifier

Represents the identity of an entity instance used in bound operations. Contains metadata about how the instance was produced and its type information.

package hu.blackbelt.judo.runtime.core.accessmanager.api;

@Getter
@Builder
public class SignedIdentifier {

    @NonNull
    private final String identifier;      // The unique identifier value

    private final ETypedElement producedBy;  // The operation/reference that produced this

    private final String entityType;      // Fully qualified entity type name

    private final Integer version;        // Optimistic locking version

    private final Boolean immutable;      // Whether the entity is read-only
}

Usage Example:

SignedIdentifier signedId = SignedIdentifier.builder()
    .identifier("550e8400-e29b-41d4-a716-446655440000")
    .entityType("Model.Customer")
    .producedBy(getCustomerOperation)
    .version(1)
    .immutable(false)
    .build();

AuthenticationInterceptor

Allows hooking into the authentication/authorization lifecycle at key points. Useful for custom logging, audit trails, or additional security checks.

package hu.blackbelt.judo.runtime.core.accessmanager.api;

/**
 * Interceptor for authentication/authorization calls.
 */
public interface AuthenticationInterceptor {
    
    /**
     * Get the interceptor name for identification.
     */
    String getName();

    /**
     * Determine if this interceptor should handle the given operation.
     * Default: handles all operations.
     */
    default boolean isSuitableForOperation(EOperation operation, 
                                           String claim,
                                           String realm, 
                                           String client, 
                                           Map<String, Object> attributes) {
        return true;
    }

    /**
     * Called after principal extraction but BEFORE mapped principal load.
     * CAUTION: Actor-based expressions cannot be used here.
     */
    default void authenticate(String operationFullyQualifiedName,
                             Map<String, Object> exchange,
                             String claim,
                             String realm,
                             String client,
                             Map<String, Object> attributes) {}

    /**
     * Called after successful authorization, BEFORE operation execution.
     */
    default void success(EOperation operation,
                        SignedIdentifier signedIdentifier,
                        Map<String, Object> exchange,
                        String claim,
                        String realm,
                        String client,
                        Map<String, Object> attributes) {}
}

AuthenticationInterceptorProvider

Factory interface for providing authentication interceptors. Allows dynamic registration of interceptors.

package hu.blackbelt.judo.runtime.core.accessmanager.api;

public interface AuthenticationInterceptorProvider {
    
    default Collection<AuthenticationInterceptor> getAuthenticationInterceptors() {
        return new ArrayList<>();
    }
}

Authorization Flow

sequenceDiagram
    participant Client
    participant Dispatcher
    participant AccessManager
    participant InterceptorProvider as AuthenticationInterceptorProvider
    participant Interceptor as AuthenticationInterceptor
    
    Client->>Dispatcher: Operation call with exchange
    Dispatcher->>AccessManager: authorizeOperation(op, signedId, exchange)
    
    AccessManager->>AccessManager: Extract JudoPrincipal from exchange
    AccessManager->>AccessManager: Check operation exposure
    
    alt Not Exposed to Actor
        AccessManager-->>Dispatcher: throw AccessDeniedException
        Dispatcher-->>Client: 403 Forbidden
    end
    
    alt No Principal & Not Public
        AccessManager-->>Dispatcher: throw AuthenticationRequiredException
        Dispatcher-->>Client: 401 Unauthorized
    end
    
    AccessManager->>InterceptorProvider: getAuthenticationInterceptors()
    InterceptorProvider-->>AccessManager: List<AuthenticationInterceptor>
    
    loop Each Interceptor
        AccessManager->>Interceptor: isSuitableForOperation(...)
        alt Suitable
            AccessManager->>Interceptor: success(op, signedId, exchange, ...)
        end
    end
    
    AccessManager->>AccessManager: Run behaviour authorizers
    AccessManager-->>Dispatcher: Authorization passed
    Dispatcher->>Dispatcher: Execute operation
    Dispatcher-->>Client: Response

Implementation: DefaultAccessManager

The judo-runtime-core-accessmanager module provides DefaultAccessManager, which:

1. Checks operation exposure - Operations must be exposed to the actor via @exposedBy annotation
2. Validates bound operations - SignedIdentifier's producedBy must be accessible to the actor
3. Runs behaviour authorizers - CRUD operations validated by specialized authorizers
4. Invokes interceptors - Calls registered AuthenticationInterceptor instances

Behaviour Authorizers

The default implementation includes authorizers for standard operations:

Implementing Custom Interceptors

Example: Audit Logging Interceptor

public class AuditLoggingInterceptor implements AuthenticationInterceptor {
    
    private final AuditService auditService;
    
    public AuditLoggingInterceptor(AuditService auditService) {
        this.auditService = auditService;
    }
    
    @Override
    public String getName() {
        return "audit-logging";
    }
    
    @Override
    public boolean isSuitableForOperation(EOperation operation, 
                                          String claim,
                                          String realm, 
                                          String client, 
                                          Map<String, Object> attributes) {
        // Only audit write operations
        Optional<AsmUtils.OperationBehaviour> behaviour = AsmUtils.getBehaviour(operation);
        return behaviour.isPresent() && 
               (behaviour.get() == AsmUtils.OperationBehaviour.CREATE_INSTANCE ||
                behaviour.get() == AsmUtils.OperationBehaviour.UPDATE_INSTANCE ||
                behaviour.get() == AsmUtils.OperationBehaviour.DELETE_INSTANCE);
    }
    
    @Override
    public void success(EOperation operation,
                       SignedIdentifier signedIdentifier,
                       Map<String, Object> exchange,
                       String claim,
                       String realm,
                       String client,
                       Map<String, Object> attributes) {
        auditService.log(AuditEvent.builder()
            .user(claim)
            .realm(realm)
            .operation(AsmUtils.getOperationFQName(operation))
            .entityId(signedIdentifier != null ? signedIdentifier.getIdentifier() : null)
            .timestamp(Instant.now())
            .build());
    }
}

Example: Rate Limiting Interceptor

public class RateLimitingInterceptor implements AuthenticationInterceptor {
    
    private final RateLimiter rateLimiter;
    
    @Override
    public String getName() {
        return "rate-limiter";
    }
    
    @Override
    public void authenticate(String operationFQN,
                            Map<String, Object> exchange,
                            String claim,
                            String realm,
                            String client,
                            Map<String, Object> attributes) {
        String key = claim + ":" + client;
        if (!rateLimiter.tryAcquire(key)) {
            throw new AccessDeniedException(ValidationResult.builder()
                .code("RATE_LIMIT_EXCEEDED")
                .level(ValidationResult.Level.ERROR)
                .build());
        }
    }
}

Registering Interceptors with Guice

public class CustomSecurityModule extends AbstractModule {
    
    @Override
    protected void configure() {
        bind(AuthenticationInterceptorProvider.class)
            .to(CustomInterceptorProvider.class);
    }
}

public class CustomInterceptorProvider implements AuthenticationInterceptorProvider {
    
    @Inject
    private AuditService auditService;
    
    @Override
    public Collection<AuthenticationInterceptor> getAuthenticationInterceptors() {
        return Arrays.asList(
            new AuditLoggingInterceptor(auditService),
            new RateLimitingInterceptor()
        );
    }
}

Integration Points

graph LR
    subgraph "judo-runtime-core-accessmanager-api"
        A[AccessManager]
        B[AuthenticationInterceptor]
        C[SignedIdentifier]
    end
    
    subgraph "judo-runtime-core-accessmanager"
        D[DefaultAccessManager]
        E[BehaviourAuthorizers]
    end
    
    subgraph "judo-runtime-core-dispatcher"
        F[DefaultDispatcher]
    end
    
    subgraph "judo-runtime-core-security"
        G[JudoPrincipal]
    end
    
    subgraph "judo-runtime-core-guice"
        H[Guice Bindings]
    end
    
    D -->|implements| A
    D -->|uses| B
    D -->|uses| C
    D -->|contains| E
    F -->|calls| A
    F -->|creates| C
    D -->|reads| G
    H -->|binds| A
    H -->|binds| D

Error Handling

Error Codes

Package Structure

hu.blackbelt.judo.runtime.core.accessmanager.api/
├── AccessManager.java               # Core authorization interface
├── AuthenticationInterceptor.java   # Lifecycle hook interface
├── AuthenticationInterceptorProvider.java  # Interceptor factory
└── SignedIdentifier.java           # Bound operation identifier

See Also

• judo-runtime-core-accessmanager - Default AccessManager implementation
• judo-runtime-core-security - Authentication and JudoPrincipal
• judo-runtime-core-dispatcher - Operation dispatching
• judo-runtime-core-guice - Dependency injection bindings