Method handleGlobalRequest

internal/sshserver/serverImpl.go:660–714

nolint:dupl

(authenticatedMetadata metadata.ConnectionAuthenticatedMetadata, requestID uint64, connection SSHConnectionHandler, req *ssh.Request, logger log.Logger)

//nolint:dupl
func (s *serverImpl) handleGlobalRequest(authenticatedMetadata metadata.ConnectionAuthenticatedMetadata, requestID uint64, connection SSHConnectionHandler, req *ssh.Request, logger log.Logger) {
	reply := s.createReply(req, logger)
	payload, err := s.unmarshalGlobalRequestPayload(req)
	if payload == nil {
		connection.OnUnsupportedGlobalRequest(requestID, req.Type, req.Payload)
		reply(false, fmt.Sprintf("unsupported global request type: %s", req.Type), nil)
		return
	}
	if err != nil {
		logger.Debug(
			messageCodes.Wrap(
				err,
				messageCodes.ESSHDecodeFailed,
				"failed to unmarshal %s request payload",
				req.Type,
			),
		)
		connection.OnFailedDecodeGlobalRequest(requestID, req.Type, req.Payload, err)
		reply(false, "failed to unmarshal payload", nil)
		return
	}

	logger.Debug(
		messageCodes.NewMessage(
			messageCodes.MSSHGlobalRequest,
			"%s global request from client",
			req.Type,
		).Label("RequestType", req.Type),
	)
	if err := s.handleDecodedGlobalRequest(
		authenticatedMetadata,
		requestID,
		ssh2.RequestType(req.Type),
		payload,
		connection,
	); err != nil {
		logger.Debug(
			messageCodes.NewMessage(
				messageCodes.MSSHGlobalRequestFailed,
				"%s global request from client failed",
				req.Type,
			).Label("RequestType", req.Type),
		)
		reply(false, err.Error(), err)
		return
	}
	logger.Debug(
		messageCodes.NewMessage(
			messageCodes.MSSHGlobalRequestSuccessful,
			"%s global request from client successful",
			req.Type,
		).Label("RequestType", req.Type),
	)
	reply(true, "", nil)
}

func (s *serverImpl) handleDecodedGlobalRequest(
	authenticatedMetadata metadata.ConnectionAuthenticatedMetadata,