Skip to content

Commit

Permalink
Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
@akrambek
akrambek committed Feb 29, 2024
1 parent 7b36c26 commit 23d84db
Show file tree
Hide file tree
Showing 17 changed files with 31 additions and 34 deletions.
2 changes: 1 addition & 1 deletion ...ipts/io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/http/create.pet/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ connect "zilla://streams/asyncapi0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3833148448)
.apiId(1969035042)
.operationId("createPet")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand Down
2 changes: 1 addition & 1 deletion ...ipts/io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/http/create.pet/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3833148448)
.apiId(1969035042)
.operationId("createPet")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand Down
6 changes: 3 additions & 3 deletions ...ivity/zilla/specs/binding/asyncapi/streams/asyncapi/mqtt/publish.and.subscribe/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ connect "zilla://streams/asyncapi0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.session()
Expand Down Expand Up @@ -50,7 +50,7 @@ connect "zilla://streams/asyncapi0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.publish()
Expand Down Expand Up @@ -83,7 +83,7 @@ connect "zilla://streams/asyncapi0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.subscribe()
Expand Down
6 changes: 3 additions & 3 deletions ...ivity/zilla/specs/binding/asyncapi/streams/asyncapi/mqtt/publish.and.subscribe/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.session()
Expand Down Expand Up @@ -51,7 +51,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.publish()
Expand Down Expand Up @@ -81,7 +81,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.subscribe()
Expand Down
2 changes: 1 addition & 1 deletion .../io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/proxy.kafka.publish/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ connect "zilla://streams/asyncapi_kafka0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(1321622121)
.apiId(246623678)
.extension(kafka:beginEx()
.typeId(zilla:id("kafka"))
.merged()
Expand Down
2 changes: 1 addition & 1 deletion .../io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/proxy.kafka.publish/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(1321622121)
.apiId(246623678)
.extension(kafka:beginEx()
.typeId(zilla:id("kafka"))
.merged()
Expand Down
2 changes: 1 addition & 1 deletion ...s/io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/proxy.mqtt.publish/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ connect "zilla://streams/asyncapi_proxy0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.publish()
Expand Down
2 changes: 1 addition & 1 deletion ...s/io/aklivity/zilla/specs/binding/asyncapi/streams/asyncapi/proxy.mqtt.publish/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(3724230511)
.apiId(819642305)
.extension(mqtt:beginEx()
.typeId(zilla:id("mqtt"))
.publish()
Expand Down
4 changes: 2 additions & 2 deletions ...aklivity/zilla/runtime/binding/asyncapi/internal/config/AsyncapiOptionsConfigAdapter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -252,11 +252,11 @@ private List<AsyncapiConfig> asListAsyncapis(
private AsyncapiConfig asAsyncapi(
Map.Entry<String, JsonValue> entry)
{
final String apiLabel = entry.getKey();
final String location = ((JsonString) entry.getValue()).getString();
final String specText = readURL.apply(location);
final String apiLabel = entry.getKey();
crc.reset();
crc.update(specText.getBytes(StandardCharsets.UTF_8));
crc.update(apiLabel.getBytes(StandardCharsets.UTF_8));
final long apiId = crc.getValue();
Asyncapi asyncapi = parser.parse(specText);

Expand Down
2 changes: 1 addition & 1 deletion ...s/io/aklivity/zilla/specs/binding/openapi/asyncapi/streams/asyncapi/create.pet/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ connect "zilla://streams/asyncapi_client0"

write zilla:begin.ext ${asyncapi:beginEx()
.typeId(zilla:id("asyncapi"))
.apiId(1823889317)
.apiId(3259359871)
.extension(kafka:beginEx()
.typeId(zilla:id("kafka"))
.merged()
Expand Down
2 changes: 1 addition & 1 deletion ...s/io/aklivity/zilla/specs/binding/openapi/asyncapi/streams/asyncapi/create.pet/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ accepted

read zilla:begin.ext ${asyncapi:matchBeginEx()
.typeId(zilla:id("asyncapi"))
.apiId(1823889317)
.apiId(3259359871)
.extension(kafka:beginEx()
.typeId(zilla:id("kafka"))
.merged()
Expand Down
4 changes: 2 additions & 2 deletions ...ts/io/aklivity/zilla/specs/binding/openapi/asyncapi/streams/openapi/create.pet/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ connect "zilla://streams/composite0"

write zilla:begin.ext ${openapi:beginEx()
.typeId(zilla:id("openapi"))
.apiId(3223647503)
.apiId(1783189785)
.operationId("createPets")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand All @@ -39,7 +39,7 @@ write close

read zilla:begin.ext ${openapi:matchBeginEx()
.typeId(zilla:id("openapi"))
.apiId(3223647503)
.apiId(1783189785)
.operationId("createPets")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand Down
4 changes: 2 additions & 2 deletions ...ts/io/aklivity/zilla/specs/binding/openapi/asyncapi/streams/openapi/create.pet/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ accepted

read zilla:begin.ext ${openapi:beginEx()
.typeId(zilla:id("openapi"))
.apiId(3223647503)
.apiId(1783189785)
.operationId("createPets")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand All @@ -41,7 +41,7 @@ read closed

write zilla:begin.ext ${openapi:beginEx()
.typeId(zilla:id("openapi"))
.apiId(3223647503)
.apiId(1783189785)
.operationId("createPets")
.extension(http:beginEx()
.typeId(zilla:id("http"))
Expand Down
1 change: 0 additions & 1 deletion ...runtime/binding/openapi/asyncapi/internal/config/OpenapiAsyncCompositeBindingAdapter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import io.aklivity.zilla.runtime.binding.openapi.asyncapi.config.OpenapiAsyncapiOptionsConfig;
import io.aklivity.zilla.runtime.binding.openapi.asyncapi.config.OpenapiAsyncapiSpecConfig;
import io.aklivity.zilla.runtime.binding.openapi.asyncapi.internal.OpenapiAsyncapiBinding;
import io.aklivity.zilla.runtime.binding.openapi.internal.model.OpenApiOperation;
import io.aklivity.zilla.runtime.binding.openapi.internal.model.Openapi;
import io.aklivity.zilla.runtime.binding.openapi.internal.view.OpenApiPathView;
import io.aklivity.zilla.runtime.engine.config.BindingConfig;
Expand Down
4 changes: 2 additions & 2 deletions ...runtime/binding/openapi/asyncapi/internal/config/OpenapiAsyncapiOptionsConfigAdapter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ public OptionsConfig adaptFromJson(
final String specText = readURL.apply(location);
final String apiLabel = n;
crc.reset();
crc.update(specText.getBytes(UTF_8));
crc.update(apiLabel.getBytes(UTF_8));
final long apiId = crc.getValue();
openapis.add(new OpenapiConfig(apiLabel, apiId, location, openapiParser.parse(specText)));
});
Expand All @@ -118,7 +118,7 @@ public OptionsConfig adaptFromJson(
final String specText = readURL.apply(location);
final String apiLabel = n;
crc.reset();
crc.update(specText.getBytes(UTF_8));
crc.update(apiLabel.getBytes(UTF_8));
final long apiId = crc.getValue();
asyncapis.add(new AsyncapiConfig(apiLabel, apiId, location, asyncapiParser.parse(specText)));
});
Expand Down
2 changes: 1 addition & 1 deletion .../zilla/runtime/binding/openapi/asyncapi/internal/streams/OpenapiAsyncapiProxyFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1224,7 +1224,7 @@ private AsyncapiStream(
this.originId = originId;
this.routedId = routedId;
this.initialId = supplyInitialId.applyAsLong(routedId);
this.operationId = String;
this.operationId = operationId;
this.replyId = supplyReplyId.applyAsLong(initialId);
this.authorization = authorization;
this.apiId = apiId;
Expand Down
18 changes: 8 additions & 10 deletions incubator/binding-openapi.spec/NOTICE
View file
Original file line number Diff line number Diff line change
@@ -1,15 +1,13 @@
Licensed under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at:
Licensed under the Aklivity Community License (the "License"); you may not use
this file except in compliance with the License. You may obtain a copy of the
License at

http://www.apache.org/licenses/LICENSE-2.0
https://www.aklivity.io/aklivity-community-license/

Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on
an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OF ANY KIND, either express or implied. See the License for the
specific language governing permissions and limitations under the License.

This project includes:
agrona under The Apache License, Version 2.0
Expand Down

0 comments on commit 23d84db

Please sign in to comment.