Skip to Content.
Sympa Menu

notify-dpml - r1049 - in trunk/main/planet/web/war: etc etc/web src/main/org/acme

notify-dpml AT lists.ibiblio.org

Subject: DPML Notify

List archive

Chronological Thread  
  • From: mcconnell at BerliOS <mcconnell AT mail.berlios.de>
  • To: notify-dpml AT lists.ibiblio.org
  • Subject: r1049 - in trunk/main/planet/web/war: etc etc/web src/main/org/acme
  • Date: Mon, 6 Feb 2006 21:06:26 +0100

Author: mcconnell
Date: 2006-02-06 21:06:18 +0100 (Mon, 06 Feb 2006)
New Revision: 1049

Removed:
trunk/main/planet/web/war/etc/web/chat/
trunk/main/planet/web/war/etc/web/js/
trunk/main/planet/web/war/src/main/org/acme/ChatFilter.java
Modified:
trunk/main/planet/web/war/etc/web.xml
Log:
remove cruft

Modified: trunk/main/planet/web/war/etc/web.xml
===================================================================
--- trunk/main/planet/web/war/etc/web.xml 2006-02-06 19:58:50 UTC (rev
1048)
+++ trunk/main/planet/web/war/etc/web.xml 2006-02-06 20:06:18 UTC (rev
1049)
@@ -23,15 +23,6 @@
<servlet-name>*</servlet-name>
</filter-mapping>

- <filter>
- <filter-name>Chat</filter-name>
- <filter-class>org.acme.ChatFilter</filter-class>
- </filter>
- <filter-mapping>
- <filter-name>Chat</filter-name>
- <url-pattern>/chat/*</url-pattern>
- </filter-mapping>
-
<servlet>
<servlet-name>Hello</servlet-name>
<servlet-class>org.acme.HelloWorld</servlet-class>

Deleted: trunk/main/planet/web/war/src/main/org/acme/ChatFilter.java
===================================================================
--- trunk/main/planet/web/war/src/main/org/acme/ChatFilter.java 2006-02-06
19:58:50 UTC (rev 1048)
+++ trunk/main/planet/web/war/src/main/org/acme/ChatFilter.java 2006-02-06
20:06:18 UTC (rev 1049)
@@ -1,387 +0,0 @@
-/*
- * Copyright 2004-2005 Mort Bay Consulting Pty. Ltd.
- * Copyright 2006 Stephen McConnell.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.acme;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-
-import javax.servlet.FilterConfig;
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpSession;
-
-import org.mortbay.util.ajax.AjaxFilter;
-import org.mortbay.util.ajax.Continuation;
-import org.mortbay.util.ajax.ContinuationSupport;
-
-public class ChatFilter extends AjaxFilter
-{
- private final String mutex="mutex";
- private Map chatroom;
-
- /**
- * @param filterConfig the filter configuration
- * @exception ServletException if a servlet exception occurs
- * @see org.mortbay.ajax.AjaxFilter#init(javax.servlet.FilterConfig)
- */
- public void init( FilterConfig filterConfig ) throws ServletException
- {
- super.init(filterConfig);
- chatroom=new HashMap();
- }
-
- /**
- * Destroy the instance.
- * @see org.mortbay.ajax.AjaxFilter#destroy()
- */
- public void destroy()
- {
- super.destroy();
- chatroom=null;
- }
-
- /**
- * Handle a request.
- * @param method the method name
- * @param request the request
- * @param response the response
- * @see org.mortbay.ajax.AjaxFilter#handle(java.lang.String,
javax.servlet.http.HttpServletRequest,
org.mortbay.ajax.AjaxFilter.AjaxResponse)
- */
- public void handle( String method, HttpServletRequest request,
AjaxResponse response )
- {
- if( "join".equals( method ) )
- {
- doJoinChat( request, response );
- }
- else if( "chat".equals( method ) )
- {
- doChat( request, response );
- }
- else if( "getEvents".equals( method ) )
- {
- doGetEvents(request,response);
- }
- else if( "leave".equals( method ) )
- {
- doLeaveChat(request,response);
- }
- else
- {
- super.handle(method, request, response);
- }
- }
-
- private void doJoinChat( HttpServletRequest request, AjaxResponse
response )
- {
- HttpSession session = request.getSession( true );
- String id = session.getId();
- String name = request.getParameter( "name" );
- if( name == null || name.length() == 0 )
- {
- name = "Newbie";
- }
-
- Member member = null;
-
- synchronized( mutex )
- {
- if( chatroom.containsKey( id ) )
- {
- // exists already, so just update name
- member = (Member) chatroom.get( id );
- if( !name.equals( member.getName() ) )
- {
- member.rename( name );
- }
- }
- else
- {
- member = new Member( session, name );
- chatroom.put( session.getId(), member );
- sendEvent( member, "has joined the chat", true );
- }
-
- sendMembers( response );
- response.objectResponse( "joined", "<ok/>" );
- }
- }
-
- private void doLeaveChat( HttpServletRequest request, AjaxResponse
response )
- {
- HttpSession session = request.getSession(true);
- String id = session.getId();
-
- Member member=null;
- synchronized( mutex )
- {
- member = (Member) chatroom.get( id );
- if( member==null )
- {
- return;
- }
- if( "Elvis".equals( member.getName() ) )
- {
- sendEvent( member, "has left the building", true );
- }
- else
- {
- sendEvent( member, "has left the chat", true );
- }
- chatroom.remove(id);
- }
- sendMembers( response );
- response.objectResponse( "left", "<ok/>" );
- }
-
- private void doChat( HttpServletRequest request, AjaxResponse response )
- {
- HttpSession session = request.getSession( true );
- String id = session.getId();
- String text = request.getParameter( "text" );
-
- Member member = null;
- synchronized( mutex )
- {
- member = (Member) chatroom.get( id );
- }
-
- if( member == null )
- {
- return;
- }
- sendEvent( member, text, false );
- }
-
-
- private void doGetEvents( HttpServletRequest request, AjaxResponse
response )
- {
- HttpSession session = request.getSession( true );
- String id = session.getId();
- long timeoutMS = 10000L;
-
- Member member=null;
- synchronized( mutex )
- {
- member = (Member) chatroom.get( id );
- }
-
- boolean alerts = false;
- if( member != null )
- {
- // Get an existing Continuation or create a new one if there are
no events.
- if( !member.hasEvents() )
- {
- Continuation continuation =
ContinuationSupport.getContinuation( request, mutex );
- member.setContinuation( continuation );
- continuation.suspend( timeoutMS );
- }
-
- member.setContinuation( null );
- alerts = member.sendEvents( response );
-
- if( alerts )
- {
- sendMembers( response );
- }
- // Signal for a new poll
- response.objectResponse( "poll", "<ok/>" );
- }
- }
-
- private void sendEvent( Member member, String text, boolean alert )
- {
- Event event = new Event( member.getName(), text, alert );
-
- ArrayList invalids = null;
- synchronized( mutex )
- {
- Iterator iter = chatroom.values().iterator();
- while( iter.hasNext() )
- {
- Member m = (Member) iter.next();
-
- try
- {
- m.getSession().getAttribute( "anything" );
- m.addEvent( event );
- }
- catch( IllegalStateException e )
- {
- if( invalids==null )
- {
- invalids=new ArrayList();
- }
- invalids.add( m );
- iter.remove();
- }
- }
- }
-
- for( int i=0; invalids != null && i< invalids.size(); i++ )
- {
- Member m = (Member) invalids.get( i );
- sendEvent( m, "has timed out of the chat", true );
- }
- }
-
- private void sendMembers( AjaxResponse response )
- {
- StringBuffer buf = new StringBuffer();
- buf.append("<ul>\n");
- synchronized( mutex )
- {
- Iterator iter = chatroom.values().iterator();
- while( iter.hasNext() )
- {
- Member m = (Member) iter.next();
- buf.append( "<li>" );
- buf.append( encodeText( m.getName() ) );
- buf.append( "</li>\n" );
- }
- }
- buf.append( "</ul>\n" );
- response.elementResponse( "members", buf.toString() );
- }
-
- private static class Event
- {
- private String _from;
- private String _text;
- private boolean _alert;
-
- Event( String from, String text, boolean alert )
- {
- _from = from;
- _text = text;
- _alert = alert;
- }
-
- boolean isAlert()
- {
- return _alert;
- }
-
- public String toString()
- {
- return "<event from=\""
- +_from
- + "\" alert=\""
- + _alert
- + "\">"
- + encodeText( _text )
- + "</event>";
- }
- }
-
- private class Member
- {
- private HttpSession _session;
- private String _name;
- private List _events = new ArrayList();
- private Continuation _continuation;
-
- Member( HttpSession session, String name )
- {
- _session=session;
- _name=name;
- }
-
- /**
- * @return Returns the name.
- */
- public String getName()
- {
- return _name;
- }
-
- /**
- * @param name The name to set.
- */
- public void setName( String name )
- {
- _name = name;
- }
-
- /**
- * @return Returns the session.
- */
- public HttpSession getSession()
- {
- return _session;
- }
-
- /**
- * @return Returns the continuation.
- */
- public Continuation getContinuation()
- {
- return _continuation;
- }
-
- /**
- * @param continuation The continuation to set.
- */
- public void setContinuation( Continuation continuation )
- {
- _continuation = continuation;
- }
-
- public void addEvent( Event event )
- {
- synchronized( this )
- {
- _events.add( event );
- if( _continuation!=null )
- {
- _continuation.resume();
- }
- }
- }
-
- public boolean hasEvents()
- {
- return _events != null && _events.size() > 0;
- }
-
- public void rename( String name )
- {
- String oldName = getName();
- setName( name );
- ChatFilter.this.sendEvent( this, oldName + " has been renamed to
" + name, true );
- }
-
- public boolean sendEvents( AjaxResponse response )
- {
- synchronized( this )
- {
- boolean alerts=false;
- for( int i=0; i< _events.size(); i++ )
- {
- Event event = (Event) _events.get( i );
- response.objectResponse( "event", event.toString() );
- alerts |= event.isAlert();
- }
- _events.clear();
- return alerts;
- }
- }
- }
-}




  • r1049 - in trunk/main/planet/web/war: etc etc/web src/main/org/acme, mcconnell at BerliOS, 02/06/2006

Archive powered by MHonArc 2.6.24.

Top of Page