Method createHandler

cli/src/events/manager.ts:111–143

(sdkContext: EventsContext)

    }

    private createHandler(sdkContext: EventsContext): DriveListener {
        return async (event: DriveEvent) => {
            const { promise, resolve } = Promise.withResolvers<void>();
            this.processingEvents.add(promise);

            const scopeId = event.treeEventScopeId;
            try {
                if (event.type === DriveEventType.TreeRemove) {
                    const sub = this.volumeSubscriptions[sdkContext].get(scopeId);
                    if (sub) {
                        try {
                            sub.dispose();
                        } catch (error: unknown) {
                            this.logger.warn(`Failed to dispose volume event subscription: ${error}`);
                        }
                        this.volumeSubscriptions[sdkContext].delete(scopeId);
                    }
                    await this.provider.removeScope(sdkContext, scopeId);
                    return;
                }

                const eventId = event.eventId;
                this.logger.debug(`Updating latest event ID for scope ${sdkContext}:${scopeId} to ${eventId}`);
                await this.provider.setLatestEventId(sdkContext, scopeId, eventId);
            } catch (error: unknown) {
                this.logger.error(`Failed to handle event ${event.type} for scope ${scopeId}`, error);
                throw error;
            } finally {
                this.processingEvents.delete(promise);
                resolve();
            }
        };
    }

    async clear(): Promise<void> {
        await this.dispose();