/[meteor]/googlecode.com/svn/trunk/Meteor/Channel.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /googlecode.com/svn/trunk/Meteor/Channel.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 47 by knops.gerd, Mon Feb 4 21:06:42 2008 UTC revision 62 by andrew.betts, Thu Nov 27 00:33:21 2008 UTC
# Line 4  Line 4 
4  #   An HTTP server for the 2.0 web  #   An HTTP server for the 2.0 web
5  #   Copyright (c) 2006 contributing authors  #   Copyright (c) 2006 contributing authors
6  #  #
7  #   Subscriber.pm  #   Channel.pm
8  #  #
9  #       Description:  #       Description:
10  #       A Meteor Channel  #       A Meteor Channel
# Line 77  sub listChannels { Line 77  sub listChannels {
77          $list;          $list;
78  }  }
79    
 sub listChannelsUsingTemplate {  
         my $class=shift;  
         my $template=shift;  
           
         return '' unless(defined($template) && $template ne '');  
           
         my $list='';  
         foreach my $channelName (sort keys %Channels)  
         {  
                 my $channel=$Channels{$channelName};  
                   
                 $list.=$channel->descriptionWithTemplate($template);  
         }  
           
         $list;  
 }  
   
80  sub deleteChannel {  sub deleteChannel {
81          my $class=shift;          my $class=shift;
82          my $channelName=shift;          my $channelName=shift;
# Line 173  sub addSubscriber { Line 156  sub addSubscriber {
156          my $userAgent=shift || '';          my $userAgent=shift || '';
157                    
158          # Note: negative $startId means go back that many messages          # Note: negative $startId means go back that many messages
159            my $startIndex=$self->indexForMessageID($startId);
160            my $logStartIndex = $startIndex || $self->lastMsgID() || 0;
161                    
162          push(@{$self->{'subscribers'}},$subscriber) if($persist);          push(@{$self->{'subscribers'}},$subscriber) if($persist);
163                    
164          &::syslog('info','',          &::syslog('info','',
165                  'joinchannel',                  'joinchannel',
166                  $subscriber->{'subscriberID'},                  $subscriber->{'socketFN'},
167                  $self->{'name'},                  $self->{'name'},
168                  $mode,                  $logStartIndex
                 $startId,  
                 $userAgent  
169          );          );
170                    
         my $startIndex=$self->indexForMessageID($startId);  
171          return unless(defined($startIndex));          return unless(defined($startIndex));
172                    
173          my $msgCount=scalar(@{$self->{'messages'}});          my $msgCount=scalar(@{$self->{'messages'}});
# Line 193  sub addSubscriber { Line 175  sub addSubscriber {
175                    
176          $startIndex=0 if($startIndex<0);          $startIndex=0 if($startIndex<0);
177                    
178          if($startIndex<$msgCount)          if($startIndex<$msgCount) {
179          {                  $subscriber->sendMessages(@{$self->{'messages'}}[$startIndex..$msgCount-1]);
                 $subscriber->sendMessages(@{$self->{'messages'}}[$startIndex,$msgCount-1]);  
180          }          }
181  }  }
182    
# Line 205  sub removeSubscriber { Line 186  sub removeSubscriber {
186          my $reason=shift ||'unknown';          my $reason=shift ||'unknown';
187                    
188          my $idx=undef;          my $idx=undef;
189          for(my $i=0;$i<scalar(@{$self->{'subscribers'}});$i++)          my $numsubs = scalar(@{$self->{'subscribers'}});
190          {  
191                  if($self->{'subscribers'}->[$i]==$subscriber)          for (my $i=0; $i<$numsubs; $i++) {
192                  {                  if($self->{'subscribers'}->[$i]==$subscriber) {
193                          $idx=$i;                          $idx=$i;
194                          last;                          last;
195                  }                  }
# Line 218  sub removeSubscriber { Line 199  sub removeSubscriber {
199          {          {
200                  splice(@{$self->{'subscribers'}},$idx,1);                  splice(@{$self->{'subscribers'}},$idx,1);
201                                    
202                    my $timeConnected = time - $subscriber->{'connectionStart'};
203                  &::syslog('info','',                  &::syslog('info','',
204                          'leavechannel',                          'leavechannel',
205                            $subscriber->{'ip'},
206                          $subscriber->{'subscriberID'},                          $subscriber->{'subscriberID'},
207                          $self->{'name'},                          $self->{'name'},
208                          $subscriber->{'ConnectionStart'},                          $timeConnected,
209                          $subscriber->{'MessageCount'},                          $subscriber->{'messageCount'},
210                          $subscriber->{'bytesWritten'},                          $subscriber->{'bytesWritten'},
211                          $reason                          $reason
212                  );                  );
# Line 246  sub addMessage { Line 229  sub addMessage {
229          $message->setText($messageText);          $message->setText($messageText);
230          $message->setChannelName($self->{'name'});          $message->setChannelName($self->{'name'});
231          push(@{$self->{'messages'}},$message);          push(@{$self->{'messages'}},$message);
232            &::syslog('debug',"New message ".$message->{"id"}." on channel ".$self->{'name'});
233                    
234          $self->trimMessageStoreBySize();          $self->trimMessageStoreBySize();
235                    
# Line 353  sub indexForMessageID { Line 337  sub indexForMessageID {
337    
338  sub lastMsgID {  sub lastMsgID {
339          my $self=shift;          my $self=shift;
           
340          my $numMessages=scalar(@{$self->{'messages'}});          my $numMessages=scalar(@{$self->{'messages'}});
341                    return undef unless($numMessages>0);
         return 'undefined' unless($numMessages>0);  
           
342          @{$self->{'messages'}}[-1]->id();          @{$self->{'messages'}}[-1]->id();
343  }  }
344    
# Line 365  sub descriptionWithTemplate { Line 346  sub descriptionWithTemplate {
346          my $self=shift;          my $self=shift;
347          my $template=shift;          my $template=shift;
348                    
349            return '' unless(defined($template) && $template ne '');
350            
351          $template=~s/~([a-zA-Z0-9_]*)~/          $template=~s/~([a-zA-Z0-9_]*)~/
352                  if(!defined($1) || $1 eq '')                  if(!defined($1) || $1 eq '') {
                 {  
353                          '~';                          '~';
354                  }                  } elsif($1 eq 'messageCount') {
                 elsif($1 eq 'messageCount')  
                 {  
355                          $self->messageCount();                          $self->messageCount();
356                  }                  } elsif($1 eq 'subscriberCount') {
                 elsif($1 eq 'subscriberCount')  
                 {  
357                          $self->subscriberCount();                          $self->subscriberCount();
358                  }                  } elsif($1 eq 'lastMsgID') {
359                  elsif($1 eq 'lastMsgID')                          $self->lastMsgID() || 1;
360                  {                  } elsif($1 eq 'name') {
361                          $self->lastMsgID();                          $self->{'name'};
362                  }                  } else {
                   
                 elsif(exists($self->{$1}))  
                 {  
                         $self->{$1};  
                 }  
                 else  
                 {  
363                          '';                          '';
364                  }                  }
365          /gex;          /gex;
Legend:
Removed from v.47  
changed lines
  Added in v.62
  ViewVC Help
Powered by ViewVC 1.1.26