Skip to content

Commit

Permalink
build: prepare to 0.7.2 (#238)
Browse files Browse the repository at this point in the history
* build: prepare to 0.7.2

* dependencies
  • Loading branch information
ndr-brt authored Aug 14, 2024
1 parent e1b1677 commit 2b2377a
Show file tree
Hide file tree
Showing 10 changed files with 128 additions and 128 deletions.
234 changes: 119 additions & 115 deletions DEPENDENCIES

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public void initialize(ServiceExtensionContext context) {
.buildEventGridEventPublisherAsyncClient();


var publisher = new AzureEventGridPublisher(context.getComponentId(), monitor, publisherClient);
var publisher = new AzureEventGridPublisher(context.getConnectorId(), monitor, publisherClient);

var processObservable = context.getService(TransferProcessObservable.class, true);
if (processObservable != null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public BlobMetadata.Builder decorate(DataFlowStartMessage request, DataSource.Pa
builder.put(ORIGINAL_NAME, part.name())
.put(REQUEST_ID, request.getId())
.put(PROCESS_ID, request.getProcessId())
.put(CONNECTOR_ID, context.getComponentId())
.put(CONNECTOR_ID, context.getConnectorId())
.put(PARTICIPANT_ID, context.getParticipantId());

var dataAddress = request.getDestinationDataAddress();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ public BlobAdapter getBlobAdapter(String accountName, String containerName, Stri

var metadataProvider = new BlobMetadataProviderImpl(monitor);
metadataProvider.registerDecorator(new CommonBlobMetadataDecorator(typeManager, context));
when(context.getComponentId()).thenReturn("connector-id");
when(context.getConnectorId()).thenReturn("connector-id");
when(context.getParticipantId()).thenReturn("participant-id");
var dataSinkFactory = new AzureStorageDataSinkFactory(account2ApiPatched, executor, partitionSize, monitor, vault, typeManager, metadataProvider);
var dataSink = dataSinkFactory.createSink(request);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public InputStream openStream() {
}
};

when(context.getComponentId()).thenReturn(TEST_CONNECTOR_ID);
when(context.getConnectorId()).thenReturn(TEST_CONNECTOR_ID);
when(context.getParticipantId()).thenReturn(TEST_PARTICIPANT_ID);

var decorator = new CommonBlobMetadataDecorator(typeManager, context);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ void transfer_success() {
sharedAccessSignatureMatcher(sinkSharedAccessSignature)
)).thenReturn(fakeCompletionMarker);

when(context.getComponentId()).thenReturn("connectorId");
when(context.getConnectorId()).thenReturn("connectorId");
when(context.getParticipantId()).thenReturn("participantId");

var metadataProvider = new BlobMetadataProviderImpl(monitor);
Expand Down Expand Up @@ -170,7 +170,7 @@ void transfer_WhenSourceFails_fails() throws Exception {
sharedAccessSignatureMatcher(sinkSharedAccessSignature)
)).thenReturn(fakeSink);

when(context.getComponentId()).thenReturn("connectorId");
when(context.getConnectorId()).thenReturn("connectorId");
when(context.getParticipantId()).thenReturn("participantId");

var metadataProvider = new BlobMetadataProviderImpl(monitor);
Expand Down Expand Up @@ -226,7 +226,7 @@ void transfer_whenSinkFails_fails() throws Exception {
when(blobApi.getBlobAdapter(anyString(), anyString(), anyString(), anyString()))
.thenReturn(blobAdapter);

when(context.getComponentId()).thenReturn("connectorId");
when(context.getConnectorId()).thenReturn("connectorId");
when(context.getParticipantId()).thenReturn("participantId");

var metadataProvider = new BlobMetadataProviderImpl(monitor);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ void setUp() {
sharedAccessSignatureMatcher(sharedAccessSignature)))
.thenReturn(completionMarker);

when(context.getComponentId()).thenReturn("connectorId");
when(context.getConnectorId()).thenReturn("connectorId");
when(context.getParticipantId()).thenReturn("participantId");
when(destinationBlobName.resolve(blobName, 1)).thenReturn(blobName);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,8 @@ dependencies {
testImplementation(libs.edc.ih.spi.store)

testImplementation(testFixtures(project(":extensions:common:azure:azure-test")))
testImplementation(project(":extensions:common:azure:azure-test"))
testImplementation(libs.edc.sql.core)
testImplementation(libs.edc.sql.identityhub.store)
testImplementation(testFixtures(libs.edc.ih.spi.store))
testImplementation(testFixtures(libs.edc.ext.azure.test))

}
Original file line number Diff line number Diff line change
Expand Up @@ -18,12 +18,10 @@ plugins {

dependencies {
testRuntimeOnly(libs.edc.rs.spi.store)
testImplementation(project(":extensions:common:azure:azure-test"))
testImplementation(testFixtures(project(":extensions:common:azure:azure-test")))
testImplementation(libs.edc.sql.core)
testImplementation(libs.edc.sql.participant.store)
testImplementation(testFixtures(libs.edc.rs.spi.store))
testImplementation(testFixtures(libs.edc.ext.azure.test))

}

2 changes: 1 addition & 1 deletion gradle/libs.versions.toml
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
format.version = "1.1"

[versions]
edc = "0.7.1"
edc = "0.7.2"
# we need to pin the version of IH, because this is the last version to contain the DWN implementation
# current snapshot builds of IH don't have feature parity yet.
# todo: remove this once IH supports credential presentation and issuance
Expand Down

0 comments on commit 2b2377a

Please sign in to comment.