001         package com.croftsoft.apps.chat.model.seri;
002    
003         import java.io.*;
004         import java.util.*;
005    
006         import com.croftsoft.core.animation.clock.SystemClock;
007         import com.croftsoft.core.animation.clock.Timekeeper;
008         import com.croftsoft.core.animation.model.Model;
009         import com.croftsoft.core.animation.model.ModelId;
010         import com.croftsoft.core.lang.NullArgumentException;
011    import com.croftsoft.core.util.consumer.Consumer;
012         import com.croftsoft.core.util.queue.Queue;
013    
014         import com.croftsoft.apps.chat.ChatConstants;
015         import com.croftsoft.apps.chat.model.ChatGame;
016         import com.croftsoft.apps.chat.model.ChatWorld;
017         import com.croftsoft.apps.chat.model.ChatWorldAccessor;
018         import com.croftsoft.apps.chat.model.seri.SeriChatWorld;
019         import com.croftsoft.apps.chat.request.CreateModelRequest;
020         import com.croftsoft.apps.chat.request.KillRequest;
021         import com.croftsoft.apps.chat.request.MoveRequest;
022         import com.croftsoft.apps.chat.request.Request;
023         import com.croftsoft.apps.chat.request.TalkRequest;
024         import com.croftsoft.apps.chat.request.ViewRequest;
025         import com.croftsoft.apps.chat.response.UnknownRequestResponse;
026         import com.croftsoft.apps.chat.server.CreateModelServer;
027         import com.croftsoft.apps.chat.server.KillServer;
028         import com.croftsoft.apps.chat.server.MoveServer;
029         import com.croftsoft.apps.chat.server.TalkServer;
030         import com.croftsoft.apps.chat.server.RequestServer;
031         import com.croftsoft.apps.chat.server.ViewServer;
032         import com.croftsoft.apps.chat.user.User;
033         import com.croftsoft.apps.chat.user.UserId;
034         import com.croftsoft.apps.chat.user.UserStore;
035    import com.croftsoft.apps.chat.user.seri.SeriUserStore;
036    
037         /*********************************************************************
038         * A Serializable ChatGame implementation.
039         *
040         * @version
041         *   2003-09-10
042         * @since
043         *   2003-06-06
044         * @author
045         *   <a href="http://www.CroftSoft.com/">David Wallace Croft</a>
046         *********************************************************************/
047    
048         public final class  SeriChatGame
049           implements Serializable, ChatGame
050         //////////////////////////////////////////////////////////////////////
051         //////////////////////////////////////////////////////////////////////
052         {
053    
054         private static final long  serialVersionUID = 0L;
055    
056         //
057    
058         private static final double  TIME_DELTA_MAX = 0.2;
059    
060         private static final double  TIME_FACTOR    = 1.0;
061    
062         //
063    
064         private final UserStore   userStore;
065    
066         private final ChatWorld   chatWorld;
067    
068         private final Timekeeper  timekeeper;
069    
070         private final Map         classToRequestServerMap;
071    
072         //////////////////////////////////////////////////////////////////////
073         // static methods
074         //////////////////////////////////////////////////////////////////////
075    
076    /*
077         public static void  main ( String [ ]  args )
078         //////////////////////////////////////////////////////////////////////
079         {
080           Queue  requestQueue = new ListQueue ( );
081    
082           ChatGame  chatGame = new SeriChatGame (
083             requestQueue,
084             new Consumer ( )
085             {
086               public void  consume ( Object  o )
087               {
088                 System.out.println ( o );
089               }
090             } );
091    
092           final String  USERNAME = "Test User";
093    
094           requestQueue.append ( new CreateRequest ( USERNAME ) );
095    
096           int  x = 0;
097    
098           int  y = 0;
099    
100           while ( true )
101           {
102             chatGame.update ( );
103    
104             requestQueue.append ( new MoveRequest ( USERNAME, x, y ) );
105    
106             x++;
107    
108             y++;
109           }
110         }
111    */
112    
113         //////////////////////////////////////////////////////////////////////
114         // constructor methods
115         //////////////////////////////////////////////////////////////////////
116    
117         public  SeriChatGame ( UserStore  userStore )
118         //////////////////////////////////////////////////////////////////////
119         {
120           NullArgumentException.check ( this.userStore = userStore );
121    
122           Consumer  eventConsumer = 
123             new Consumer ( )
124             {
125               public void  consume ( Object  o )
126               {
127                 broadcast ( o );
128               }
129             };
130    
131           chatWorld = new SeriChatWorld ( eventConsumer );
132    
133           timekeeper = new Timekeeper ( SystemClock.INSTANCE, TIME_FACTOR );
134    
135           classToRequestServerMap = new HashMap ( );
136    
137    /*
138           classToRequestServerMap.put (
139             KillRequest.class,
140             new KillServer ( chatWorld ) );
141    */
142    
143           classToRequestServerMap.put (
144             CreateModelRequest.class,
145             new CreateModelServer ( chatWorld ) );
146    
147           classToRequestServerMap.put (
148             MoveRequest.class,
149             new MoveServer ( chatWorld ) );
150    
151           classToRequestServerMap.put (
152             TalkRequest.class,
153             new TalkServer ( eventConsumer ) );
154    
155           classToRequestServerMap.put (
156             ViewRequest.class,
157             new ViewServer ( ( SeriChatWorld ) chatWorld ) );
158         }
159    
160         public  SeriChatGame ( )
161         //////////////////////////////////////////////////////////////////////
162         {
163           this ( new SeriUserStore ( ) );
164         }
165    
166         //////////////////////////////////////////////////////////////////////
167         //////////////////////////////////////////////////////////////////////
168    
169         public ChatWorldAccessor  getChatWorldAccessor ( )
170         //////////////////////////////////////////////////////////////////////
171         {
172           return chatWorld;
173         }
174    
175         public ChatWorld  getChatWorld ( )
176         //////////////////////////////////////////////////////////////////////
177         {
178           return chatWorld;
179         }
180    
181         //////////////////////////////////////////////////////////////////////
182         //////////////////////////////////////////////////////////////////////
183    
184         public void  update ( )
185         //////////////////////////////////////////////////////////////////////
186         {
187           chatWorld.prepare ( );
188    
189           Model [ ]  models = chatWorld.getModels ( );
190    
191           for ( int  i = 0; i < models.length; i++ )
192           {
193             Model  model = models [ i ];
194    
195             if ( !model.isActive ( ) )
196             {
197               chatWorld.removeModel ( model.getModelId ( ) );
198             }
199           }
200    
201           UserId [ ]  userIds = userStore.getUserIds ( );
202    
203           for ( int  i = 0; i < userIds.length; i++ )
204           {
205             User  user = userStore.getUser ( userIds [ i ] );
206    
207             if ( user == null )
208             {
209               continue;
210             }
211    
212             if ( System.currentTimeMillis ( )
213               >= user.getLastRequestTime ( ) + ChatConstants.USER_TIMEOUT )
214             {
215               removeUser ( user );
216    
217               continue;
218             }
219    
220             Queue  requestQueue = user.getRequestQueue ( );
221    
222             Request  request = ( Request ) requestQueue.poll ( );
223    
224             if ( request == null )
225             {
226               continue;
227             }
228    
229             RequestServer  requestServer = ( RequestServer )
230               classToRequestServerMap.get ( request.getClass ( ) );
231    
232             if ( requestServer == null )
233             {
234               queue ( user, new UnknownRequestResponse ( request ) );
235             }
236    
237             Object  response = requestServer.serve ( user, request );
238    
239             if ( response != null )
240             {
241               queue ( user, response );
242             }
243           }
244    
245           timekeeper.update ( );
246    
247           double  timeDelta = timekeeper.getTimeDelta ( );
248    
249           if ( timeDelta > TIME_DELTA_MAX )
250           {
251             timeDelta = TIME_DELTA_MAX;
252           }
253    
254           chatWorld.update ( timeDelta );
255         }
256    
257         //////////////////////////////////////////////////////////////////////
258         // private methods
259         //////////////////////////////////////////////////////////////////////
260    
261         private void  queue (
262           User    user,
263           Object  message )
264         //////////////////////////////////////////////////////////////////////
265         {
266           Queue  messageQueue = user.getMessageQueue ( );
267    
268           try
269           {
270             messageQueue.replace ( message );
271           }
272           catch ( IndexOutOfBoundsException  ex )
273           {
274             removeUser ( user );
275           }
276         }
277    
278         private void  broadcast ( Object  o )
279         //////////////////////////////////////////////////////////////////////
280         {
281           UserId [ ]  userIds = userStore.getUserIds ( );
282    
283           for ( int  i = 0; i < userIds.length; i++ )
284           {
285             User  user = userStore.getUser ( userIds [ i ] );
286    
287             if ( user == null )
288             {
289               continue;
290             }
291    
292             queue ( user, o );
293           }
294         }
295    
296         private void  removeUser ( User  user )
297         //////////////////////////////////////////////////////////////////////
298         {
299           userStore.removeUser ( user.getUserId ( ) );
300    
301           ModelId  modelId = user.getModelId ( );
302    
303           if ( modelId != null )
304           {
305             chatWorld.removeModel ( modelId );
306           }
307         }
308    
309         //////////////////////////////////////////////////////////////////////
310         //////////////////////////////////////////////////////////////////////
311         }