Skip to content

Commit bc8d85d

Browse files
authored
chore: adopt upstream ParticipantIdentityResolver (#24)
1 parent 8003262 commit bc8d85d

6 files changed

Lines changed: 5 additions & 32 deletions

File tree

core/negotiation-manager/src/main/java/org/eclipse/edc/virtualized/controlplane/contract/negotiation/ContractManagerExtension.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.ContractNegotiationPendingGuard;
1919
import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.observe.ContractNegotiationObservable;
2020
import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.store.ContractNegotiationStore;
21+
import org.eclipse.edc.participantcontext.spi.identity.ParticipantIdentityResolver;
2122
import org.eclipse.edc.runtime.metamodel.annotation.Extension;
2223
import org.eclipse.edc.runtime.metamodel.annotation.Inject;
2324
import org.eclipse.edc.runtime.metamodel.annotation.Provider;
@@ -27,7 +28,6 @@
2728
import org.eclipse.edc.spi.system.ServiceExtensionContext;
2829
import org.eclipse.edc.transaction.spi.TransactionContext;
2930
import org.eclipse.edc.virtualized.controlplane.contract.spi.negotiation.ContractNegotiationStateMachineService;
30-
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantIdentityResolver;
3131
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantWebhookResolver;
3232

3333
import java.time.Clock;

core/negotiation-manager/src/main/java/org/eclipse/edc/virtualized/controlplane/contract/negotiation/ContractNegotiationStateMachineServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@
2727
import org.eclipse.edc.connector.controlplane.contract.spi.types.negotiation.ContractOfferMessage;
2828
import org.eclipse.edc.connector.controlplane.contract.spi.types.negotiation.ContractRequestMessage;
2929
import org.eclipse.edc.connector.controlplane.contract.spi.types.protocol.ContractNegotiationAck;
30+
import org.eclipse.edc.participantcontext.spi.identity.ParticipantIdentityResolver;
3031
import org.eclipse.edc.policy.model.PolicyType;
3132
import org.eclipse.edc.spi.message.RemoteMessageDispatcherRegistry;
3233
import org.eclipse.edc.spi.monitor.Monitor;
3334
import org.eclipse.edc.spi.response.StatusResult;
3435
import org.eclipse.edc.spi.types.domain.message.ProcessRemoteMessage;
3536
import org.eclipse.edc.transaction.spi.TransactionContext;
3637
import org.eclipse.edc.virtualized.controlplane.contract.spi.negotiation.ContractNegotiationStateMachineService;
37-
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantIdentityResolver;
3838
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantWebhookResolver;
3939

4040
import java.time.Clock;

core/v-connector-core/src/main/java/org/eclipse/edc/virtualized/controlplane/VirtualCoreServicesExtension.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
package org.eclipse.edc.virtualized.controlplane;
1616

1717
import org.eclipse.edc.participantcontext.spi.config.ParticipantContextConfig;
18+
import org.eclipse.edc.participantcontext.spi.identity.ParticipantIdentityResolver;
1819
import org.eclipse.edc.protocol.spi.DataspaceProfileContextRegistry;
1920
import org.eclipse.edc.runtime.metamodel.annotation.Extension;
2021
import org.eclipse.edc.runtime.metamodel.annotation.Inject;
@@ -23,7 +24,6 @@
2324
import org.eclipse.edc.spi.system.ServiceExtension;
2425
import org.eclipse.edc.virtualized.controlplane.participantcontext.ParticipantContextIdentityResolverImpl;
2526
import org.eclipse.edc.virtualized.controlplane.participantcontext.ParticipantWebhookResolverImpl;
26-
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantIdentityResolver;
2727
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantWebhookResolver;
2828

2929
import static org.eclipse.edc.virtualized.controlplane.VirtualCoreServicesExtension.NAME;

core/v-connector-core/src/main/java/org/eclipse/edc/virtualized/controlplane/participantcontext/ParticipantContextIdentityResolverImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
package org.eclipse.edc.virtualized.controlplane.participantcontext;
1616

1717
import org.eclipse.edc.participantcontext.spi.config.ParticipantContextConfig;
18-
import org.eclipse.edc.virtualized.controlplane.participantcontext.spi.ParticipantIdentityResolver;
18+
import org.eclipse.edc.participantcontext.spi.identity.ParticipantIdentityResolver;
1919
import org.jetbrains.annotations.Nullable;
2020

2121
import static org.eclipse.edc.virtualized.controlplane.VirtualCoreServicesExtension.PARTICIPANT_ID;
@@ -28,7 +28,6 @@ public ParticipantContextIdentityResolverImpl(ParticipantContextConfig contextCo
2828
this.contextConfig = contextConfig;
2929
}
3030

31-
//TODO take into account the protocol, probably wait for upstream final changes
3231
@Override
3332
public @Nullable String getParticipantId(String participantContextId, String protocol) {
3433
return contextConfig.getString(participantContextId, PARTICIPANT_ID);

data-protocols/dsp/dsp-2025/dsp-http-api-configuration-2025/src/main/java/org/eclipse/edc/virtual/protocol/dsp/http/api/configuration/v2025/DspApiConfigurationV2025Extension.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public void initialize(ServiceExtensionContext context) {
8686
registerTransformers();
8787

8888
// dynamic webhook registration based on participant context
89-
dataspaceProfileContextRegistry.register(new DataspaceProfileContext(DATASPACE_PROTOCOL_HTTP_V_2025_1, V_2025_1, () -> dspWebhookAddress.get() + "/%s" + V_2025_1_PATH, context.getParticipantId(), participantIdExtractionFunction));
89+
dataspaceProfileContextRegistry.register(new DataspaceProfileContext(DATASPACE_PROTOCOL_HTTP_V_2025_1, V_2025_1, () -> dspWebhookAddress.get() + "/%s" + V_2025_1_PATH, participantIdExtractionFunction));
9090
}
9191

9292
private void registerNamespaces() {

spi/v-core-spi/src/main/java/org/eclipse/edc/virtualized/controlplane/participantcontext/spi/ParticipantIdentityResolver.java

Lines changed: 0 additions & 26 deletions
This file was deleted.

0 commit comments

Comments
 (0)