response-service-impl.ts

import { inject, injectable } from 'inversify';
import { Emitter } from '@theia/core/lib/common/event';
import { OutputContribution } from '@theia/output/lib/browser/output-contribution';
import { OutputChannelManager } from '@theia/output/lib/common/output-channel';
import { ResponseService, OutputMessage, ProgressMessage } from '../common/protocol/response-service';

@injectable()
export class ResponseServiceImpl implements ResponseService {

    @inject(OutputContribution)
    protected outputContribution: OutputContribution;

    @inject(OutputChannelManager)
    protected outputChannelManager: OutputChannelManager;

    protected readonly progressDidChangeEmitter = new Emitter<ProgressMessage>();
    readonly onProgressDidChange = this.progressDidChangeEmitter.event;

    appendToOutput(message: OutputMessage): void {
        const { chunk } = message;
        const channel = this.outputChannelManager.getChannel('Arduino');
        channel.show({ preserveFocus: true });
        channel.append(chunk);
    }

    clearArduinoChannel(): void {
        this.outputChannelManager.getChannel('Arduino').clear();
    }

    reportProgress(progress: ProgressMessage): void {
        this.progressDidChangeEmitter.fire(progress);
    }

}