Function closeExecutionStorePersistence

packages/storage/src/execution-stores.ts:624–672

(
  sessionStore: { close?(): Promise<void> },
  runtimePersistence: { close(): void },
  extras: {
    agentRunStore?: Pick<DurableAgentRunStore, 'close'>;
    conversationOperationalStateStore?: Pick<ConversationOperationalStateStore, 'close'>;
    messageReceiptStore?: { close(): void };
    interactionStore?:
      | InteractiveInteractionStoreReaderFacade
      | InteractiveInteractionStoreWriterFacade;
  } = {},
)

}

async function closeExecutionStorePersistence(
  sessionStore: { close?(): Promise<void> },
  runtimePersistence: { close(): void },
  extras: {
    agentRunStore?: Pick<DurableAgentRunStore, 'close'>;
    conversationOperationalStateStore?: Pick<ConversationOperationalStateStore, 'close'>;
    messageReceiptStore?: { close(): void };
    interactionStore?:
      | InteractiveInteractionStoreReaderFacade
      | InteractiveInteractionStoreWriterFacade;
  } = {},
): Promise<void> {
  const errors: unknown[] = [];
  try {
    runtimePersistence.close();
  } catch (error) {
    errors.push(error);
  }
  try {
    await sessionStore.close?.();
  } catch (error) {
    errors.push(error);
  }
  try {
    extras.agentRunStore?.close?.();
  } catch (error) {
    errors.push(error);
  }
  try {
    extras.conversationOperationalStateStore?.close();
  } catch (error) {
    errors.push(error);
  }
  try {
    extras.messageReceiptStore?.close();
  } catch (error) {
    errors.push(error);
  }
  try {
    if (extras.interactionStore) {
      closeSqliteInteractionStoreFacade(extras.interactionStore);
    }
  } catch (error) {
    errors.push(error);
  }
  if (errors.length > 0) {
    throw new AggregateError(errors, 'Unable to close execution store persistence');
  }
}

function invalidExecutionStores(
  kind: StorageRootKind,