Changeset 1101

Timestamp:

11/04/07 18:38:35 (6 years ago)

Author:

tokuhirom

Message:

lang/perl/mobirc: now you can post message to twitter/wassr/frepa, or more target.

Location:

lang/perl/mobirc/trunk/mobirc/lib/Mobirc

Files:

• Channel.pm (modified) (1 diff)
• HTTPD.pm (modified) (1 diff)
• HTTPD/Controller.pm (modified) (1 diff)
• Plugin/Component/IRCClient.pm (modified) (1 diff)
• Plugin/Component/Twitter.pm (modified) (4 diffs)

lang/perl/mobirc/trunk/mobirc/lib/Mobirc/Channel.pm

@@ -71 +71 @@
 }
 
+sub post_command {
+    my ($self, $command) = @_;
+
+    for my $code (@{$self->{global_context}->get_hook_codes('process_command')}) {
+        my $ret = $code->($self->{global_context}, $command, $self);
+        last if $ret;
+    }
+}
+
 sub name {
     my ($self, $name) = @_;

lang/perl/mobirc/trunk/mobirc/lib/Mobirc/HTTPD.pm

@@ -69 +69 @@
     my $c = {
         config     => $config,
-        poe        => $poe,
         req        => $request,
         user_agent => $user_agent,
         mobile_agent => HTTP::MobileAgent->new($user_agent),
         irc_nick     => $poe->kernel->alias_resolve('irc_session')->get_heap->{irc}->nick_name,
-        irc_incode   => $poe->kernel->alias_resolve('irc_session')->get_heap->{config}->{incode},
         global_context => Mobirc->context,
     };

lang/perl/mobirc/trunk/mobirc/lib/Mobirc/HTTPD/Controller.pm

@@ -131 +131 @@
     DEBUG "POST MESSAGE $message";
 
+    $c->{global_context}->get_channel($channel)->post_command($message);
+
     my $irc_incode = $c->{irc_incode};
-    if ($message) {
-        if ($message =~ m{^/}) {
-            DEBUG "SENDING COMMAND";
-            $message =~ s!^/!!g;
-
-            my @args =
-              map { encode( $irc_incode, $_ ) } split /\s+/,
-              $message;
-
-            $c->{poe}->kernel->post('mobirc_irc', @args);
-        } else {
-            DEBUG "NORMAL PRIVMSG";
-
-            $c->{poe}->kernel->post( 'mobirc_irc',
-                privmsg => encode( $irc_incode, $channel ) =>
-                encode( $irc_incode, $message ) );
-
-            DEBUG "Sending message $message";
-            if ($c->{config}->{httpd}->{echo} eq true) {
-                $c->{global_context}->get_channel($channel)->add_message(
-                    Mobirc::Message->new(
-                        who => decode(
-                            $irc_incode,
-                            $c->{irc_nick}
-                        ),
-                        body  => $message,
-                        class => 'publicfromhttpd',
-                    )
-                );
-            }
-        }
-    }
 
     my $response = HTTP::Response->new(302);

lang/perl/mobirc/trunk/mobirc/lib/Mobirc/Plugin/Component/IRCClient.pm

@@ -18 +18 @@
     DEBUG "register ircclient component";
     $global_context->register_hook(
-        'run_component' => sub { _init($conf, $global_context) },
-    );
+        'run_component' => sub { _init($conf, shift) },
+    );
+    $global_context->register_hook(
+        'process_command' => sub { my ($global_context, $command, $channel) = @_;  _process_command($conf, $global_context, $command, $channel) },
+    );
+}
+
+sub _process_command {
+    my ($conf, $global_context, $command, $channel) = @_;
+
+    my $irc_incode = $conf->{incode};
+    if ($command && $channel->name =~ /^[#*%]/) {
+        if ($command =~ m{^/}) {
+            DEBUG "SENDING COMMAND";
+            $command =~ s!^/!!g;
+
+            my @args =
+              map { encode( $irc_incode, $_ ) } split /\s+/,
+              $command;
+
+            $poe_kernel->post('mobirc_irc', @args);
+        } else {
+            DEBUG "NORMAL PRIVMSG";
+
+            $poe_kernel->post( 'mobirc_irc',
+                privmsg => encode( $irc_incode, $channel->name ) =>
+                encode( $irc_incode, $command ) );
+
+            DEBUG "Sending command $command";
+            # FIXME: httpd $B4X78$J$$7o(B
+            if ($global_context->config->{httpd}->{echo} eq true) {
+                $channel->add_message(
+                    Mobirc::Message->new(
+                        who => decode(
+                            $irc_incode,
+                            $conf->{irc_nick}
+                        ),
+                        body  => $command,
+                        class => 'public',
+                    )
+                );
+            }
+        }
+        return true;
+    }
+    return false;
 }
 

lang/perl/mobirc/trunk/mobirc/lib/Mobirc/Plugin/Component/Twitter.pm

@@ -7 +7 @@
 use POE;
 use POE::Sugar::Args;
+use Encode;
 
 sub register {
@@ -15 +16 @@
         'run_component' => sub { _init($conf, shift) },
     );
+    $global_context->register_hook(
+        'process_command' => sub { my ($global_context, $command, $channel) = @_;  _process_command($conf, $global_context, $command, $channel) },
+    );
 
     $conf->{channel} ||= U '#twitter';
@@ -20 +24 @@
     $conf->{screenname} ||= $conf->{username};
     $conf->{friend_timeline_interval} ||= 60;
+}
+
+sub _process_command {
+    my ($conf, $global_context, $command, $channel) = @_;
+
+    if ($conf->{channel} eq $channel->name) {
+        $poe_kernel->post( $conf->{alias}, 'update', encode('utf-8', $command) );
+        $channel->add_message(
+            Mobirc::Message->new(
+                who => $conf->{screenname},
+                body  => $command,
+                class => 'twitter',
+            )
+        );
+        return true;
+    }
+    return false;
 }
 
@@ -86 +107 @@
       channel: #mytwitter
 
-=head1 LIMITATION
-
-read only. you cannot post to twitter ;-(
-