Skip to content

Commit f27c278

Browse files
authored
[WIP] Awakeable IDs following the new ID scheme (#204)
1 parent e6c3980 commit f27c278

File tree

3 files changed

+5
-2
lines changed

3 files changed

+5
-2
lines changed

sdk-core/src/main/java/dev/restate/sdk/core/Entries.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import java.util.function.Function;
2020

2121
final class Entries {
22+
static final String AWAKEABLE_IDENTIFIER_PREFIX = "prom_1";
2223

2324
private Entries() {}
2425

sdk-core/src/main/java/dev/restate/sdk/core/SyscallsImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,8 @@ public void awakeable(SyscallCallback<Map.Entry<String, DeferredResult<ByteStrin
265265
.rewind()));
266266

267267
return new AbstractMap.SimpleImmutableEntry<>(
268-
Base64.getUrlEncoder().encodeToString(awakeableId.toByteArray()),
268+
Entries.AWAKEABLE_IDENTIFIER_PREFIX
269+
+ Base64.getUrlEncoder().encodeToString(awakeableId.toByteArray()),
269270
deferredResult);
270271
},
271272
callback));

sdk-core/src/test/java/dev/restate/sdk/core/AwakeableIdTestSuite.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,8 @@ public Stream<TestDefinition> definitions() {
4242
expectedAwakeableId.putInt(1);
4343
expectedAwakeableId.rewind();
4444
String base64ExpectedAwakeableId =
45-
Base64.getUrlEncoder().encodeToString(expectedAwakeableId.array());
45+
Entries.AWAKEABLE_IDENTIFIER_PREFIX
46+
+ Base64.getUrlEncoder().encodeToString(expectedAwakeableId.array());
4647

4748
return Stream.of(
4849
testInvocation(this::returnAwakeableId, GreeterGrpc.getGreetMethod())

0 commit comments

Comments
 (0)