@@ -213,14 +213,15 @@ async function deliverQueuedSessionDelivery(params: {
213213entry: QueuedSessionDelivery;
214214}) {
215215const { cfg, storePath, canonicalKey } = loadSessionEntry(params.entry.sessionKey);
216+const queuedDeliveryContext = resolveQueuedSessionDeliveryContext(params.entry);
216217217218if (params.entry.kind === "systemEvent") {
218219enqueueSystemEvent(params.entry.text, {
219220sessionKey: canonicalKey,
220- ...(resolveQueuedSessionDeliveryContext(params.entry)
221+ ...(queuedDeliveryContext
221222 ? {
222223deliveryContext: {
223- ...resolveQueuedSessionDeliveryContext(params.entry),
224+ ...queuedDeliveryContext,
224225},
225226}
226227 : {}),
@@ -232,10 +233,10 @@ async function deliverQueuedSessionDelivery(params: {
232233if (!params.entry.route) {
233234enqueueSystemEvent(params.entry.message, {
234235sessionKey: canonicalKey,
235- ...(resolveQueuedSessionDeliveryContext(params.entry)
236+ ...(queuedDeliveryContext
236237 ? {
237238deliveryContext: {
238- ...resolveQueuedSessionDeliveryContext(params.entry),
239+ ...queuedDeliveryContext,
239240},
240241}
241242 : {}),
@@ -383,10 +384,12 @@ async function drainRestartContinuationQueue(params: {
383384export async function recoverPendingRestartContinuationDeliveries(params: {
384385deps: CliDeps;
385386log?: SessionDeliveryRecoveryLogger;
387+maxEnqueuedAt?: number;
386388}) {
387389await recoverPendingSessionDeliveries({
388390deliver: (entry) => deliverQueuedSessionDelivery({ deps: params.deps, entry }),
389391log: params.log ?? log,
392+maxEnqueuedAt: params.maxEnqueuedAt,
390393});
391394}
392395此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。