thoerup/marketstats/ShowStats.java

package dk.thoerup.marketstats;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.Date;
import java.util.Locale;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import net.spy.memcached.MemcachedClient;

import com.gc.android.market.api.MarketSession;
import com.gc.android.market.api.model.Market.AppsRequest;
import com.gc.android.market.api.model.Market.CommentsRequest;


public class ShowStats extends HttpServlet {
        private static final long serialVersionUID = 1L;

        static final int MAXCOMMENTS = 50;
        static final int TIMEOUT = 30*60;
        
        static final Logger log = Logger.getLogger(ShowStats.class.getName());

        String login;
        String password;
        
        MemcachedClient memcache = null;


        @Override
        public void init() throws ServletException {
                super.init();

                login = getServletContext().getInitParameter("login");
                password = getServletContext().getInitParameter("password");
                
                try {
                        memcache = new MemcachedClient(new InetSocketAddress("localhost", 11211));
                } catch (IOException e) {
                        throw new ServletException(e);
                }
        }

        @Override
        public void destroy() {
                super.destroy();
                
                memcache.shutdown(3, TimeUnit.SECONDS);
                memcache = null;
        }

        protected String doLookup(String query) throws IOException {
                

                String key = "marketstats:" + query.replace(' ', '_');
                String response = (String) memcache.get(key);

                if (response == null) {
                        response = doLookupWorker(query);
                        memcache.set(key, TIMEOUT, response); 
                        response += "<!-- new lookup -->";
                } else {
                        response += "<!-- from memcached -->";
                }
                return response;
        }
        
        private void loadComments(String appId, MarketSession session, ArrayList<CommentBean> commentBeans) {           
                CommentCallback commentsCb = new CommentCallback();
                commentsCb.setList( commentBeans ); 

                session.setLocale( Locale.ROOT );
                
                
                int start = 0;
                do {
                        int count = 10;
                        if (start > 0)                          
                                count = Math.min(10, commentsCb.getEntryCount() );
                        
                        //log.warning("count=" + count + " start=" + start + " entryCount=" + commentsCb.getEntryCount() );
                        CommentsRequest commentsRequest = CommentsRequest.newBuilder()
                        .setAppId(appId)
                        .setStartIndex(start)
                        .setEntriesCount(count)
                        .build();
                        
                        session.append(commentsRequest, commentsCb);
                        session.flush();
                        start +=10;
                        
                        if (start >= MAXCOMMENTS)
                                break; //emergency brake
                        
                } while ( start < commentsCb.getEntryCount() );
        }


        protected String doLookupWorker(String query) {
                final StringBuilder sb = new StringBuilder();


                MarketSession session = new MarketSession();
                session.login(login,password);


                AppsRequest appsRequest = AppsRequest.newBuilder()
                .setQuery(query)
                .setStartIndex(0).setEntriesCount(10)
                .setWithExtendedInfo(true)
                .build();


                AppsCallback appsCb = new AppsCallback() ;
                appsCb.setStringBuffer(sb);

                ArrayList<CommentBean> commentBeans = new ArrayList<CommentBean>();


                session.append(appsRequest, appsCb);
                session.flush();
                
                String appId = appsCb.getAppId();
                
                if (appId != null) {

                        loadComments(appId, session, commentBeans);
        
                        sb.append("-----------------------------------------------------------------\n");
                        for (CommentBean c : commentBeans) {
                                sb.append("User: " + c.author + "\n");
                                sb.append("Rating: " + c.rating + "\n");
                                sb.append("Time: " + new Date(c.time).toString() + "\n");
                                sb.append( c.text + "\n");
                                sb.append("\n");
        
                        }
                        sb.append("Comments: " + commentBeans.size() + "\n");
                }
                sb.append("<!--Cache.Timeout=" + TIMEOUT/60 + " minutes-->\n");         


                return sb.toString();
        }

        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                String query = request.getParameter("query");

                response.setContentType("text/html");
                PrintWriter out = response.getWriter();
                out.print( "<html><body><pre>" + doLookup(query) + "</pre></body></html>" );
        }

}
1	torben	659	package dk.thoerup.marketstats;
2
3			import java.io.IOException;
4			import java.io.PrintWriter;
5			import java.net.InetSocketAddress;
6	torben	662	import java.util.ArrayList;
7	torben	659	import java.util.Date;
8			import java.util.Locale;
9	torben	762	import java.util.concurrent.TimeUnit;
10	torben	659	import java.util.logging.Logger;
11
12			import javax.servlet.ServletException;
13			import javax.servlet.http.HttpServlet;
14			import javax.servlet.http.HttpServletRequest;
15			import javax.servlet.http.HttpServletResponse;
16
17			import net.spy.memcached.MemcachedClient;
18
19			import com.gc.android.market.api.MarketSession;
20			import com.gc.android.market.api.model.Market.AppsRequest;
21			import com.gc.android.market.api.model.Market.CommentsRequest;
22
23
24	torben	664
25	torben	659	public class ShowStats extends HttpServlet {
26			private static final long serialVersionUID = 1L;
27
28	torben	949	static final int MAXCOMMENTS = 50;
29			static final int TIMEOUT = 30*60;
30
31	torben	659	static final Logger log = Logger.getLogger(ShowStats.class.getName());
32
33			String login;
34			String password;
35	torben	667
36			MemcachedClient memcache = null;
37	torben	659
38
39			@Override
40			public void init() throws ServletException {
41			super.init();
42
43			login = getServletContext().getInitParameter("login");
44			password = getServletContext().getInitParameter("password");
45	torben	667
46			try {
47			memcache = new MemcachedClient(new InetSocketAddress("localhost", 11211));
48			} catch (IOException e) {
49			throw new ServletException(e);
50			}
51	torben	659	}
52
53	torben	762	@Override
54			public void destroy() {
55			super.destroy();
56
57			memcache.shutdown(3, TimeUnit.SECONDS);
58			memcache = null;
59			}
60
61	torben	705	protected String doLookup(String query) throws IOException {
62	torben	667
63	torben	659
64	torben	759	String key = "marketstats:" + query.replace(' ', '_');
65	torben	667	String response = (String) memcache.get(key);
66	torben	659
67			if (response == null) {
68	torben	705	response = doLookupWorker(query);
69	torben	667	memcache.set(key, TIMEOUT, response);
70	torben	659	response += "<!-- new lookup -->";
71			} else {
72			response += "<!-- from memcached -->";
73			}
74			return response;
75			}
76	torben	663
77	torben	756	private void loadComments(String appId, MarketSession session, ArrayList<CommentBean> commentBeans) {
78	torben	663	CommentCallback commentsCb = new CommentCallback();
79			commentsCb.setList( commentBeans );
80	torben	659
81	torben	756	session.setLocale( Locale.ROOT );
82	torben	663
83
84	torben	756
85	torben	663	int start = 0;
86			do {
87			int count = 10;
88			if (start > 0)
89			count = Math.min(10, commentsCb.getEntryCount() );
90
91	torben	757	//log.warning("count=" + count + " start=" + start + " entryCount=" + commentsCb.getEntryCount() );
92	torben	663	CommentsRequest commentsRequest = CommentsRequest.newBuilder()
93			.setAppId(appId)
94			.setStartIndex(start)
95			.setEntriesCount(count)
96			.build();
97
98			session.append(commentsRequest, commentsCb);
99			session.flush();
100			start +=10;
101
102	torben	949	if (start >= MAXCOMMENTS)
103	torben	663	break; //emergency brake
104
105			} while ( start < commentsCb.getEntryCount() );
106			}
107	torben	659
108	torben	663
109	torben	705	protected String doLookupWorker(String query) {
110	torben	659	final StringBuilder sb = new StringBuilder();
111
112
113			MarketSession session = new MarketSession();
114			session.login(login,password);
115
116	torben	662
117	torben	659	AppsRequest appsRequest = AppsRequest.newBuilder()
118	torben	705	.setQuery(query)
119	torben	659	.setStartIndex(0).setEntriesCount(10)
120			.setWithExtendedInfo(true)
121			.build();
122
123
124	torben	663	AppsCallback appsCb = new AppsCallback() ;
125			appsCb.setStringBuffer(sb);
126	torben	659
127	torben	662	ArrayList<CommentBean> commentBeans = new ArrayList<CommentBean>();
128	torben	659
129
130
131			session.append(appsRequest, appsCb);
132			session.flush();
133	torben	705
134			String appId = appsCb.getAppId();
135
136			if (appId != null) {
137	torben	662
138	torben	756	loadComments(appId, session, commentBeans);
139	torben	705
140			sb.append("-----------------------------------------------------------------\n");
141			for (CommentBean c : commentBeans) {
142	torben	756	sb.append("User: " + c.author + "\n");
143	torben	705	sb.append("Rating: " + c.rating + "\n");
144			sb.append("Time: " + new Date(c.time).toString() + "\n");
145			sb.append( c.text + "\n");
146			sb.append("\n");
147
148			}
149			sb.append("Comments: " + commentBeans.size() + "\n");
150	torben	662	}
151	torben	761	sb.append("<!--Cache.Timeout=" + TIMEOUT/60 + " minutes-->\n");
152	torben	662
153
154	torben	659	return sb.toString();
155			}
156
157			protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
158	torben	705	String query = request.getParameter("query");
159	torben	662
160	torben	660	response.setContentType("text/html");
161	torben	659	PrintWriter out = response.getWriter();
162	torben	758	out.print( "<html><body><pre>" + doLookup(query) + "</pre></body></html>" );
163	torben	659	}
164
165			}