exec method

ExecSession exec({ required String containerId, required String command, bool tty = false, String? name, })

Implementation

ExecSession exec({required String containerId, required String command, bool tty = false, String? name}) {
  final requestId = const Uuid().v4();
  final session = ExecSession._(requestId: requestId, command: command, containerId: containerId, tty: tty);

  room
      .invoke(toolkit: 'containers', tool: 'exec', input: ToolStreamInput(session.inputStream()))
      .then((output) async {
        if (output is! ToolStreamOutput) {
          throw _unexpectedResponseError(operation: 'exec');
        }

        await for (final chunk in output.stream) {
          if (chunk is ErrorContent) {
            throw RoomServerException(chunk.text, code: chunk.code);
          }
          if (chunk is ControlContent) {
            if (chunk.method == 'close') {
              break;
            }
            throw _unexpectedResponseError(operation: 'exec');
          }
          if (chunk is! BinaryContent) {
            throw _unexpectedResponseError(operation: 'exec');
          }

          final rawChannel = chunk.headers['channel'];
          if (rawChannel is! int) {
            throw RoomServerException('containers.exec returned a chunk without a valid channel');
          }

          if (rawChannel == 1) {
            session._stdoutController.add(chunk.data);
            continue;
          }
          if (rawChannel == 2) {
            session._stderrController.add(chunk.data);
            continue;
          }
          if (rawChannel == 3) {
            session._close(_decodeContainerStatusPayload(chunk.data, operation: 'exec'));
            return;
          }
        }

        throw RoomServerException('containers.exec stream closed before a status was returned');
      })
      .catchError((Object error) {
        session._closeError(error);
      });

  return session;
}