Function feedAll

services/session-ingest/src/queue-consumer.test.ts:56–59

(extractor: ReturnType<typeof createItemExtractor>, json: string)

import { getWorkerDb } from '@kilocode/db/client';
import { getSessionIngestDO } from './dos/SessionIngestDO';
import { getUserConnectionDO } from './dos/UserConnectionDO';
import { getSessionAccessCacheDO } from './dos/SessionAccessCacheDO';
import { notifyUserSessionEvent } from './session-events';
import { QUEUE_RETRY_DELAY_SECONDS, createItemExtractor, queue } from './queue-consumer';
import { computeSessionMetadataUpdates } from './ingest/metadata';

const encoder = new TextEncoder();