File Coverage

blib/lib/PLS/Server/Request/TextDocument/DidChange.pm

Criterion	Covered	Total	%
statement	27	44	61.3
branch	0	4	0.0
condition			n/a
subroutine	9	11	81.8
pod	0	1	0.0
total	36	60	60.0

package PLS::Server::Request::TextDocument::DidChange;

use strict;
use warnings;

use parent 'PLS::Server::Request';

use feature 'state';

use IO::Async::Loop;
use IO::Async::Timer::Countdown;

use PLS::Parser::Document;
use PLS::Parser::Index;
use PLS::Server::Request::TextDocument::PublishDiagnostics;

=head1 NAME

PLS::Server::Request::TextDocument::DidChange

=head1 DESCRIPTION

This is a notification from the client to the server that
a text document was changed.

=cut

sub service
{
    my ($self, $server) = @_;

    return unless (ref $self->{params}{contentChanges} eq 'ARRAY');
    PLS::Parser::Document->update_file(
                                       uri     => $self->{params}{textDocument}{uri},
                                       changes => $self->{params}{contentChanges},
                                       version => $self->{params}{textDocument}{version}
                                      );

    state %timers;

    my $uri = $self->{params}{textDocument}{uri};

    if (ref $timers{$uri} eq 'IO::Async::Timer::Countdown')
    {
        # If we get another change before the timer goes off, reset the timer.
        # This will allow us to limit the diagnostics to a time one second after the user stopped typing.
        $timers{$uri}->reset();
    } ## end if (ref $timers{$uri} ...)
    else
    {
        $timers{$uri} = IO::Async::Timer::Countdown->new(
            delay     => 2,
            on_expire => sub {
                my $index = PLS::Parser::Index->new();
                $index->index_files($uri)->then(sub { Future->wait_all(@_) })->retain();

                $server->send_server_request(PLS::Server::Request::TextDocument::PublishDiagnostics->new(uri => $uri));
                delete $timers{$uri};
            },
            remove_on_expire => 1
        );

        my $loop = IO::Async::Loop->new();
        $loop->add($timers{$uri});
        $timers{$uri}->start();
    } ## end else [ if (ref $timers{$uri} ...)]

    return;
} ## end sub service

1;