Post rebase

Author: slinkydeveloper

src/restate_context_impl.ts

@@ -379,7 +379,9 @@ export class RestateGrpcContextImpl implements RestateGrpcContext {
     );
 
     return {
-      id: AWAKEABLE_IDENTIFIER_PREFIX + Buffer.concat([this.id, encodedEntryIndex]).toString("base64url"),
+      id:
+        AWAKEABLE_IDENTIFIER_PREFIX +
+        Buffer.concat([this.id, encodedEntryIndex]).toString("base64url"),
       promise: this.markCombineablePromise(promise),
     };
   }

src/state_machine.ts

@@ -252,8 +252,7 @@ export class StateMachine<I, O> implements RestateStreamConsumer {
       );
     }
 
-    rlog.debugJournalMessage(
-      this.invocation.logPrefix,
+    this.console.debugJournalMessage(
       "Matched and replayed message from journal",
       COMBINATOR_ENTRY_MESSAGE,
       combinatorMessage
@@ -271,8 +270,7 @@ export class StateMachine<I, O> implements RestateStreamConsumer {
         combinatorId,
         journalEntriesOrder: order.map((pid) => pid.id),
       };
-      rlog.debugJournalMessage(
-        this.invocation.logPrefix,
+      this.console.debugJournalMessage(
         "Adding message to journal and sending to Restate",
         COMBINATOR_ENTRY_MESSAGE,
         combinatorMessage

test/protoutils.ts

@@ -503,10 +503,13 @@ export function getAwakeableId(entryIndex: number): string {
   const encodedEntryIndex = Buffer.alloc(4 /* Size of u32 */);
   encodedEntryIndex.writeUInt32BE(entryIndex);
 
-  return AWAKEABLE_IDENTIFIER_PREFIX + Buffer.concat([
-    Buffer.from("f311f1fdcb9863f0018bd3400ecd7d69b547204e776218b2", "hex"),
-    encodedEntryIndex,
-  ]).toString("base64url");
+  return (
+    AWAKEABLE_IDENTIFIER_PREFIX +
+    Buffer.concat([
+      Buffer.from("f311f1fdcb9863f0018bd3400ecd7d69b547204e776218b2", "hex"),
+      encodedEntryIndex,
+    ]).toString("base64url")
+  );
 }
 
 export function keyVal(key: string, value: any): Buffer[] {