Method handleSendNotificationRequest

internal/server/grpc_session.go:507–533

(ctx context.Context, rep repo.RepositoryWriter, authz auth.AuthorizationInfo, req *grpcapi.SendNotificationRequest)

}

func (s *Server) handleSendNotificationRequest(ctx context.Context, rep repo.RepositoryWriter, authz auth.AuthorizationInfo, req *grpcapi.SendNotificationRequest) *grpcapi.SessionResponse {
	ctx, span := tracer.Start(ctx, "GRPCSession.SendNotification")
	defer span.End()

	if authz.ContentAccessLevel() < auth.AccessLevelAppend {
		return accessDeniedResponse()
	}

	eventArgs, err := notifydata.UnmarshalEventArgs(req.GetEventArgs(), req.GetEventArgsType())
	if err != nil {
		return errorResponse(err)
	}

	if err := notification.SendInternal(ctx, rep,
		req.GetTemplateName(),
		eventArgs,
		notification.Severity(req.GetSeverity()),
		s.options.NotifyTemplateOptions); err != nil {
		return errorResponse(err)
	}

	return &grpcapi.SessionResponse{
		Response: &grpcapi.SessionResponse_SendNotification{
			SendNotification: &grpcapi.SendNotificationResponse{},
		},
	}
}

func accessDeniedResponse() *grpcapi.SessionResponse {
	return &grpcapi.SessionResponse{