Add initial version of mqtt-multipub script

1 files changed, 75 insertions, 0 deletions

diff --git a/bin/mqtt-multipub b/bin/mqtt-multipub
new file mode 100755
index 0000000..4c9b2dc
--- /dev/null
+++ b/bin/mqtt-multipub
@@ -0,0 +1,75 @@
+#!/usr/bin/env perl
+
+use strict;
+use warnings;
+use 5.020;
+
+our $VERSION = '0.00';
+
+use File::Slurp qw(read_file);
+use Net::MQTT::Simple;
+
+my $mqtt = Net::MQTT::Simple->new( '172.23.225.193' );
+
+sub parse_content_string {
+	my ($raw_content) = @_;
+	if ($raw_content =~ m{ ^ / [^/] }x) {
+		my $content = read_file($raw_content);
+		chomp $content;
+		return $content;
+	}
+	return $raw_content;
+}
+
+for my $arg (@ARGV) {
+	if ($arg =~ m{ ^ (?<topic> [^=]+) = (?<msgtype> . ) = (?<content> .*) $ }x) {
+		my $content = parse_content_string($+{content});
+		if ($+{msgtype} eq 'm') {
+			$mqtt->publish( $+{topic}, $content );
+		}
+		elsif ($+{msgtype} eq 'r') {
+			$mqtt->retain( $+{topic}, $content );
+		}
+		else {
+			warn "Unsupported message type $+{msgtype} ($arg)\n";
+		}
+	}
+}
+
+__END__
+
+=head1 NAME
+
+=head1 SYNOPSIS
+
+=head1 VERSION
+
+=head1 DESCRIPTION
+
+=head1 OPTIONS
+
+=over
+
+=back
+
+=head1 EXIT STATUS
+
+=head1 CONFIGURATION
+
+None.
+
+=head1 DEPENDENCIES
+
+=over
+
+=back
+
+=head1 BUGS AND LIMITATIONS
+
+=head1 AUTHOR
+
+Copyright (C) 2017 by Daniel Friesel E<lt>derf@finalrewind.orgE<gt>
+
+=head1 LICENSE
+
+  0. You just DO WHAT THE FUCK YOU WANT TO.