From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

VVU / wubot-0.3.2-TRIAL / lib / App / Wubot / Plugin / SerialPort.pm 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
—
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

              
package App::Wubot::Plugin::SerialPort;
use Moose;
# Set up the serial port
use Capture::Tiny;
use Device::SerialPort qw( :PARAM :STAT :ALL );
our $VERSION = '0.3.2'; # VERSION
use App::Wubot::Logger;
has 'device'    => ( is      => 'rw',
                     isa     => 'Str',
                     default => '',
                 );
has 'port'      => ( is      => 'rw',
                     isa     => 'Maybe[Device::SerialPort]',
                 );
has 'logger'    => ( is      => 'ro',
                     isa     => 'Log::Log4perl::Logger',
                     lazy    => 1,
                     default => sub {
                         return Log::Log4perl::get_logger( __PACKAGE__ );
                     },
                 );
with 'App::Wubot::Plugin::Roles::Cache';
with 'App::Wubot::Plugin::Roles::Plugin';
sub init {
    my ( $self, $inputs ) = @_;
    unless ( $inputs->{config}->{device} ) {
        $self->logger->logdie( "ERROR: 'device' not defined in config!" );
    }
    unless ( -r $inputs->{config}->{device} ) {
        $self->logger->error( "ERROR: device not readable: $inputs->{config}->{device}" );
        return;
    }
    $self->device( $inputs->{config}->{device} );
    return;
}
sub _initialize_serial_port {
    my ( $self ) = @_;
    $self->port( Device::SerialPort->new( $self->device ) );
    return unless $self->port;
    # 19200, 81N on the USB ftdi driver
    $self->port->baudrate(9600);
    $self->port->databits(8);
    $self->port->parity("none");
    $self->port->stopbits(1);
    # clear contents of port on startup
    $self->port->lookclear;
}
sub check {
    my ( $self, $inputs ) = @_;
    unless ( $self->port ) {
        $self->_initialize_serial_port();
    }
    my @react;
    my $string;
  READ:
    for ( 0 .. 10 ) {
        my ( $stdout, $stderr ) = Capture::Tiny::capture {
            # Poll to see if any data is coming in
            $string = $self->port->lookfor();
        };
        if ( $stderr =~ m|^Error| ) {
            push @react, { subject => "STDERR: $stderr" };
            $self->port( undef );
        }
        last READ unless $string;
        $string =~ s|\s$||;
        push @react, { line => $string, lastupdate => time };
    }
    return { react => \@react };
}
__PACKAGE__->meta->make_immutable;
1;
__END__
=head1 NAME
App::Wubot::Plugin::SerialPort - monitor data received over a serial port
=head1 VERSION
version 0.3.2
=head1 DESCRIPTION
More to come...
=head1 SUBROUTINES/METHODS
=over 8
=item init( $inputs )
The standard monitor init() method.
=item check( $inputs )
The standard monitor check() method.
=back