Method handleChannelRequest

internal/sshserver/serverImpl.go:1089–1148

nolint:dupl

(
	channelMetadata metadata.ChannelMetadata,
	requestID uint64,
	request *ssh.Request,
	sessionChannel SessionChannelHandler,
	logger log.Logger,
)

//nolint:dupl
func (s *serverImpl) handleChannelRequest(
	channelMetadata metadata.ChannelMetadata,
	requestID uint64,
	request *ssh.Request,
	sessionChannel SessionChannelHandler,
	logger log.Logger,
) {
	reply := s.createReply(request, logger)
	payload, err := s.unmarshalChannelRequestPayload(request)
	if payload == nil {
		sessionChannel.OnUnsupportedChannelRequest(requestID, request.Type, request.Payload)
		reply(false, fmt.Sprintf("unsupported request type: %s", request.Type), nil)
		return
	}
	if err != nil {
		logger.Debug(
			messageCodes.Wrap(
				err,
				messageCodes.ESSHDecodeFailed,
				"failed to unmarshal %s request payload",
				request.Type,
			),
		)
		sessionChannel.OnFailedDecodeChannelRequest(requestID, request.Type, request.Payload, err)
		reply(false, "failed to unmarshal payload", nil)
		return
	}
	logger.Debug(
		messageCodes.NewMessage(
			messageCodes.MSSHChannelRequest,
			"%s channel request from client",
			request.Type,
		).Label("RequestType", request.Type),
	)
	if err := s.handleDecodedChannelRequest(
		channelMetadata,
		requestID,
		ssh2.RequestType(request.Type),
		payload,
		sessionChannel,
	); err != nil {
		logger.Debug(
			messageCodes.NewMessage(
				messageCodes.MSSHChannelRequestFailed,
				"%s channel request from client failed",
				request.Type,
			).Label("RequestType", request.Type),
		)
		reply(false, err.Error(), err)
		return
	}
	logger.Debug(
		messageCodes.NewMessage(
			messageCodes.MSSHChannelRequestSuccessful,
			"%s channel request from client successful",
			request.Type,
		).Label("RequestType", request.Type),
	)