moviestar - BuzzerProxy - src - buzzerproxy - SOURCE CODE

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 
package buzzerproxy;


import java.net.*;
import java.io.*;

import org.bouncycastle.util.encoders.Hex;
import org.bouncycastle.crypto.BufferedBlockCipher;
import org.bouncycastle.crypto.paddings.PaddedBufferedBlockCipher;
import org.bouncycastle.crypto.modes.CBCBlockCipher;
import org.bouncycastle.crypto.engines.AESEngine;
import org.bouncycastle.crypto.params.KeyParameter;
import org.bouncycastle.crypto.CryptoException;

*/

/*
public final class AES
{

    public static final String decryptAES(String key, String message) throws Exception
    {

        // Get the KeyGenerator
        KeyGenerator kgen = KeyGenerator.getInstance("AES");
        kgen.init(128); // 192 and 256 bits may not be available

        // Generate the secret key specs.
        SecretKey skey = kgen.generateKey();
        byte[] raw = skey.getEncoded();

        SecretKeySpec skeySpec = new SecretKeySpec(raw, "AES");

        // Instantiate the cipher
        Cipher cipher = Cipher.getInstance("AES");
//////        cipher.init(Cipher.ENCRYPT_MODE, skeySpec);
//////
//////        byte[] encrypted =
//////                cipher.doFinal((args.length == 0
//////                ? "This is just an example" : args[0]).getBytes());
//////        System.out.println("encrypted string: " + asHex(encrypted));

        byte[] theByteArray = message.getBytes();

        cipher.init(Cipher.DECRYPT_MODE, skeySpec);
        byte[] original = cipher.doFinal(theByteArray);

... [truncated, 69 more lines] ...

/*
 * todo: 
 * - results so abholen, dass gleich die einzenlen dateien verlinkt werden können und aufs handy gepusht werden
 * - in eine datei die aktuellen ergebnisse zwischenspeichern serilized, bei jedem start einlesen ( key=SESSIONID, VALUE=XMLRESULTSTRING )
 * - polling beim server einbauen
 * - im fehlerfall thread stoppen und neuen thread starten oder externe anwendung startet im fehlerfall neu
 * - lockfile support, run only one instance
 * http://download.oracle.com/javase/tutorial/essential/concurrency/simple.html
 */
package buzzerproxy;

import buzzerproxy.CommunicationProtocol;
import buzzerproxy.Crypto;
import buzzerproxy.Google;
import buzzerproxy.GoogleResultParser;
import buzzerproxy.Gzip;
import buzzerproxy.IO;
import buzzerproxy.Logging;
import buzzerproxy.XMLParser;
import buzzerproxy.bprot.ByteProtServer;
import buzzerproxy.handler.ExceptionHandler;
import buzzerproxy.handler.QuestionInterface;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.io.*;
import java.util.ArrayList;
import java.util.HashMap;

/**
 *
 * @author thecerial
 */
public class BuzzerProxy implements ExceptionHandler, QuestionInterface {

    private ServerSocket serverSocket = null;
    private Socket socket = null;
    private final String secredCryptoKey = "7953e8d5dc9fed4b6d37569410fe2f85";
    private int ServerPort = 3381;
    private int backlogQueue = 10;
    private int timeout = 7000;                                                 // 7 Sekunden darf jeder Request die Server Ressourcen verbraten
    private String BuzzerProxyVersion = "1.1.a - 12.8.2011";
    private String SECRET_AUTH_KEY = "2429545b007ffc86a98df6f3cab76fc4";
    private String Version = "www.buzzerstar.com" + " / BuzzerProxyJar Version -" + BuzzerProxyVersion
            + " running on localhost on Port " + ServerPort;
    private Socket client;
    private ServerSocket server;
    private String xmlContent = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>" + "<search>"

... [truncated, 255 more lines] ...

package buzzerproxy;

import java.util.ArrayList;
import java.util.HashMap;

/**
 * CacheDeleter - beinhaltet alle Funktione zum Cachen eines Suchbegriffs und
 * seiner Results
 * 
 * @author Sebastian Enger
 * @see Serialization
 * @since 1.1
 * @version 1.1 / 2011-08-21
 * @typ Class
 * 
 */
public class CacheDeleter extends Thread {

	HashMap<String, ArrayList<ResultContainer>> cache = new HashMap<String, ArrayList<ResultContainer>>();

	public CacheDeleter(HashMap<String, ArrayList<ResultContainer>> cache) {
		this.cache = cache;
	}

	public synchronized void cleanCache() {

		ArrayList<ResultContainer> value = new ArrayList<ResultContainer>();
		long epoch = System.currentTimeMillis() / 1000;
		int count = 0;

		for (String key : cache.keySet()) {
			value = cache.get(key);
			ResultContainer it = value.get(count);
			long storetime = it.getLastChecked();
			if (storetime + Constant.CACHE_VALID_THROUGH > epoch) { 
				value.remove(count);
			}  			 
			count++;
		} 

	}  

	@Override
	public void run() {
		cleanCache();
	}
} // static class CacheDeleter extends Thread {

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map.Entry;
import java.util.Set;
import java.util.TreeSet;

/**
 * CacheManager.java - beinhaltet alle Funktione zum Cachen eines Suchbegriffs
 * und seiner Results
 * 
 * @author Sebastian Enger
 * @see Serialization
 * @since 1.1
 * @version 1.1 / 2011-08-21
 * @typ Class
 * 
 */
public class CacheManager implements Serializable {

    /**
     * 
     */
    private static final long                           serialVersionUID = 1L;

    /** Cache */
    private HashMap<String, ArrayList<ResultContainer>> cache;

    /** Cache Deleter */
    private CacheDeleter                                cacheDeleter;

    /** Cache Writer/Reader*/
    private Serialization                               ser;

    /**
     * Konstruktor
     * @throws Exception 
     */
    public CacheManager() throws Exception {
        cache = new HashMap<String, ArrayList<ResultContainer>>();

        ser = new Serialization( Constant.CACHEFILE );
    }

... [truncated, 150 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import org.apache.http.Header;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;

/**
 *
 * @author Enger
 */
public class CheckStatus {

    private String contentLenght = "";
    
    public boolean isAlive(String urlToGet) throws ClientProtocolException, IOException {

        boolean isAlive = false;
        String urlGetMe = null;
        setContentLenght("-1");

        try {
            URL url = new URL(urlToGet);
            URI uri = new URI(url.getProtocol(), url.getHost(), url.getPath(), url.getQuery(), null);
            //   System.out.println("URI " + uri.toString() + " is OK");
            urlGetMe = uri.toString();
        } catch (MalformedURLException e) {
            System.out.println("URL " + urlToGet + " is a malformed URL");
        } catch (URISyntaxException e) {
            System.out.println("URI " + urlToGet + " is a malformed URL");
        }

        HttpClient client = new DefaultHttpClient();
        HttpGet method = new HttpGet(urlGetMe);
        HttpResponse httpResponse = null;
        try {
            httpResponse = client.execute(method);
            int statusCode = httpResponse.getStatusLine().getStatusCode();

... [truncated, 36 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Enger
 */
public class CommunicationProtocol {

    CommunicationProtocol() {
    }

    public final String internalServerErrorXML() {

        StringBuilder sb = new StringBuilder();
        sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>");
        sb.append("<servicetyp>InternalServerError</servicetyp>");
        sb.append("<content>");
        sb.append("<item></item>");
        sb.append("</content>");
        sb.append("</xml>");

        return sb.toString();

    } //  public final String internalServerErrorXML(){

    public final String timeoutXML() {

        StringBuilder sb = new StringBuilder();
        sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>");
        sb.append("<servicetyp>Timeout</servicetyp>");
        sb.append("<content>");
        sb.append("<item></item>");
        sb.append("</content>");
        sb.append("</xml>");

        return sb.toString();

    } //  public final String timeoutXML(){

    public final String wrongProtocolXML() {

        StringBuilder sb = new StringBuilder();
        sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>");

... [truncated, 25 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

/**
 * 
 * @author Enger
 */
public class Constant {

	public static final String CACHEFILE = "buzzerstar.cache.ser.db";
	public static final int SERVER_PORT = 3381;
	public static final String SERVER_HOST = "46.38.232.54";
	public static final int HTTP_TIMEOUT = 5000; // in ms
	public static final long CACHE_VALID_THROUGH = 60 * 60 * 24 * 7; // 7 Tage
																		// Cache
	public static final String HTTP_USER_AGENT = "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:6.0) Gecko/20100101 Firefox/6.0";
	public static final String HTTP_REFERER = "http://www.google.de/search?q=really+cool+site&ie=utf-8&oe=utf-8&aq=t&rls=org.mozilla:de:official&client=firefox-a&hl=en&gl=US";
	public static final String XML_PATH = "/srv/server/resources/xml/Users.xml"; // linux:
																																// /server/protocol/Users.xml
	public static final String XML_VERSION = "xmlversion";
	public static final String XML_CURRENT_VERSION = "1000";
	public static final String SECRET_AUTH_KEY = "2429545b007ffc86a98df6f3cab76fc4";
	
	public static final String LOCKFILE = "buzzerstar.lock";
	
	// Update File, das ausgeliefert werden soll
	public static final String UPDATE_ANDROID = "/srv/server/update/BuzzerStar_V1_0_0.pkm";
	
	
	
	// xml related
	public static final String CLIENT_ID = "clientid";
	public static final String CLIENT_VERSION = "clientversion";
	public static final String SEARCH_SERVICE = "searchservice";
	public static final String FILE_TYP = "filetyp";
	public static final String RESULT_PAGE = "page";
	public static final String SEARCH_QUERY = "searchquery";
	
	public static final String TOP_SEARCH_KEYWORDS = "/srv/server/resources/top/top.txt";
	
	
	// DB related
	public static final String DB_HIBERNATE_CONFIGURATION_XML = "/srv/server/resources/xml/hibernate.cfg.xml"; 
	public static final String DB_ALTERNATIVE_LOG_FILE = "buzzerstar.query.log.txt";
	public static final String DB_CRYPTO_KEY = "rouTer!9923@On1ine!3381=";
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

//import java.math.BigInteger;
import java.security.SecureRandom;
//import java.util.UUID;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.bouncycastle.util.encoders.Hex;
import org.bouncycastle.crypto.BufferedBlockCipher;
import org.bouncycastle.crypto.paddings.PaddedBufferedBlockCipher;
import org.bouncycastle.crypto.modes.CBCBlockCipher;
import org.bouncycastle.crypto.engines.AESEngine;
import org.bouncycastle.crypto.params.KeyParameter;
import org.bouncycastle.crypto.CryptoException;

/**
 *
 * @author Enger
 */
public class Crypto {

    private byte[] cipherText = null;
    public SecureRandom random = new SecureRandom();
    private int len = 256;
    private long sessionIDLenght = 32;

    public final long generateSessionID() {
     
        //   return UUID.randomUUID().toString()+new BigInteger(130, random).toString(len);
        //  return new BigInteger(130, random).longValue();
        SecureRandom randomr = new SecureRandom();
        return randomr.nextLong();

    } // public final String generateSessionID(){

    public final String performEncrypt(byte[] key, String plainText) {

        if (plainText == null || !(plainText instanceof String) || key == null || !(key instanceof byte[])) {
            Exception e = new Exception();
            Logger.getLogger(Crypto.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( str == null || !(str instanceof String)){

        byte[] ptBytes = plainText.getBytes();

        BufferedBlockCipher cipher = new PaddedBufferedBlockCipher(new CBCBlockCipher(new AESEngine()));

... [truncated, 40 more lines] ...

package buzzerproxy;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

import buzzerproxy.Mediatype;

/**
 * @author Master
 */
public enum Filetype implements Serializable {

    //*********
    // Musik
    //*********
    MP3(Mediatype.MUSIK, "mp3"),
    FLAC(Mediatype.MUSIK, "flac"), WMA(Mediatype.MUSIK, "wma"),
    MIDI(Mediatype.MUSIK, "midi"), MP2(Mediatype.MUSIK, "mp2"),
    WAV(Mediatype.MUSIK, "wav"), AAC(Mediatype.MUSIK, "aac"),
    SMAF(Mediatype.MUSIK, "smaf"), MLD(Mediatype.MUSIK, "mld"), 
    OGG(Mediatype.MUSIK, "ogg"), MMF(Mediatype.MUSIK, "mmf"),
    AIFF(Mediatype.MUSIK, "aiff"), RMA(Mediatype.MUSIK, "rma"), 
    MPC(Mediatype.MUSIK, "mpc"), APE(Mediatype.MUSIK,"ape"), // musik
            

    //*********
    // Bilder
    //*********

    JPG(Mediatype.BILDER, "jpg"), JPEG(Mediatype.BILDER, "jpeg"),
    PNG(Mediatype.BILDER, "png"), GIF(Mediatype.BILDER, "gif"),
    BMP(Mediatype.BILDER, "bmp"), TIFF(Mediatype.BILDER, "tiff"), 
    SVG(Mediatype.BILDER, "svg"), JPA(Mediatype.BILDER, "jpa"),
    TIF(Mediatype.BILDER, "tif"), THM(Mediatype.BILDER, "thm"), // bilder
            
    //*********
    // Video
    //*********      
            
    PG3(Mediatype.VIDEO, "3gp"), MPG(Mediatype.VIDEO, "mpg"), 
    AVI(Mediatype.VIDEO, "avi"), WMV(Mediatype.VIDEO, "wmv"), 
    MP4(Mediatype.VIDEO, "mp4"), MPE(Mediatype.VIDEO, "mpe"),
    RM(Mediatype.VIDEO, "rm"), MPEG(Mediatype.VIDEO, "mpeg"), 
    MOV(Mediatype.VIDEO,"mov"), WMM(Mediatype.VIDEO, "wmm"), 
    WMF(Mediatype.VIDEO, "wmf"), RAM(Mediatype.VIDEO, "ram"), 
    OGM(Mediatype.VIDEO, "ogm"), ASX(Mediatype.VIDEO, "asx"), 
    FLV(Mediatype.VIDEO, "flv"), FLA(Mediatype.VIDEO, "fla"), 
    SWF(Mediatype.VIDEO, "swf"), F4V(Mediatype.VIDEO, "f4v"), 
    DIV(Mediatype.VIDEO, "div"), DIVX(Mediatype.VIDEO, "divx"), 

... [truncated, 107 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.http.client.ClientProtocolException;

public class Google {

    private String GOOGLE_SEARCH_BASE = "https://ajax.googleapis.com/ajax/services/search/web?v=1.0&" + "q=intitle:'index+of'%20+'last+modified'%20+'parent+directory'%20+description%20+size+FILETYP+SEARCHQUERY&key=AIzaSyAcvn-vGugDlvBilWabtpfGeC619KQxo_w";

    public String getGoogleContent(String searchQuery, String fileType) {

        if (searchQuery == null || !(searchQuery instanceof String) || fileType == null || !(fileType instanceof String)) {
            Exception e = new Exception();
            Logger.getLogger(Google.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( str == null || !(str instanceof String)){

        Http h = new Http();
        String returnContent = "";
        searchQuery = searchQuery.replace(" ", "%20");
        fileType = fileType.replace(" ", "%20");
        String searchUrl = GOOGLE_SEARCH_BASE.replace("SEARCHQUERY", searchQuery).replace("FILETYP", fileType);
       
        try {
            returnContent = h.get(searchUrl);
        } catch (ClientProtocolException ex) {
            Logger.getLogger(Google.class.getName()).log(Level.SEVERE, null, ex);
        }

         return returnContent;
         
    } // public String getGoogleContent(String searchQuery, String fileType){
} // public class Google {

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import buzzerproxy.Http;
import java.util.ArrayList;
import org.apache.http.client.ClientProtocolException;

/**
 *
 * @author Enger
 */
public class GoogleResultParser {

    public ArrayList<String> parseResults(String rawResults, String filetyp) {

        if (rawResults == null || !(rawResults instanceof String)) {
            Exception e = new Exception();
            Logger.getLogger(GoogleResultParser.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( str == null || !(str instanceof String)){


        Http h = new Http();
        StringBuilder sb = new StringBuilder();
        String[] arr = rawResults.split("\"");

//        sb.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\" ?>");
//        sb.append("<content>");
//        sb.append("<servicetyp>Results</servicetyp>");
        try {
            for (int i = 0; i < arr.length; i++) {
                int pos = i + 2;

                if (arr[i].equalsIgnoreCase("unescapedUrl")) {
                    String url = arr[pos];
                    boolean isAlive = false;
                    try {
                        isAlive = h.isAlive(url);
                    } catch (ClientProtocolException ex) {
                        Logger.getLogger(GoogleResultParser.class.getName()).log(Level.SEVERE, null, ex);
                    } catch (IOException ex) {
                        Logger.getLogger(GoogleResultParser.class.getName()).log(Level.SEVERE, null, ex);
                    }
                    System.out.println("URL: " + url + " Status: " + isAlive);

... [truncated, 50 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.math.BigInteger;
import java.security.SecureRandom;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.zip.*;

/**
 * Quelle: http://download.oracle.com/javase/6/docs/api/java/util/zip/Inflater.html 
 * Quelle: http://www.coderanch.com/t/374637/java/java/Compressing-Decompressing-strings-Java
 * @author IBB-Teilnehmer
 */
public final class Gzip {

    public SecureRandom random = new SecureRandom();
    public final int FileNameLenght = 512;

    public final String gzip(String str) {
        
        if ( str == null || !(str instanceof String)){
            Exception e = new Exception();
            Logger.getLogger(Gzip.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( str == null || !(str instanceof String)){
        
        Writer writer = null;
        
        try {
            String longFilename = new BigInteger(130, random).toString(FileNameLenght);
            FileOutputStream output = null;
            try {
                output = new FileOutputStream(longFilename + ".gz");

... [truncated, 409 more lines] ...

/**
 * 
 */
package buzzerproxy;
import java.util.ArrayList;

import buzzerproxy.Http;
/**
 * @author Enger
 *
 */
public class HTTPTest {
	private static String startUrl = "http://bobgentile.com/Music/";
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Http h = new Http();
		ArrayList<String> r = h.getRecursively(startUrl);
		System.out.println("UrlArraySize: " + r.size());
	}

}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

/**
 *
 * @author Enger
 * @see: http://www.rgagnon.com/javadetails/java-0639.html
 */
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import java.net.URLDecoder;
import java.util.List;
import java.util.ArrayList;

import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.ResponseHandler;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.BasicResponseHandler;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
import org.apache.http.protocol.BasicHttpContext;
import org.apache.http.protocol.HttpContext;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;

/**
@see http://hc.apache.org/httpcomponents-client-ga/examples.html
 */
public class Http {

    private ArrayList<String> validResultEntrys = new ArrayList<String>();

    public Http() {

... [truncated, 269 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.DataOutputStream;
import java.util.HashMap;

/**
 *
 * @author Enger
 */
public class IO {

    IO() {
    }

    public boolean isValidFileTyp(String uri, String filetyp){
        
        boolean is = false;
       
        filetyp = filetyp.replaceAll("\\(", "");
        filetyp = filetyp.replaceAll("\\)", "");
        String[] content = filetyp.split("|.");
        
        for ( int i=0;i<content.length;i++){
            if ( uri.endsWith(content[i])){
                is = true;
            } // if ( uri.endsWith(content[i])){
        } //  for ( int i=0;i<content.length;i++){
        return is;
        
    } //  public boolean isValidFileTyp(String uri, String filetyp){
    
    public boolean isSet(DataOutputStream str) {

        boolean status = false;
        try {
            if (str == null || !(str instanceof DataOutputStream) || str.size() <= 0) {
                status = false;
            } else {
                status = true;
            } // if ( str == null || !(str instanceof String)){
        } catch (NullPointerException e) {
            status = false;
        } catch (Exception e) {
            status = false;
        }
        return status;

... [truncated, 40 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Enger
 */
public class Logging {

    public final String SAVE_FILE = "/home/java/BuzzerProxyLogging.txt";

    public void appendFile(String str) {

        if (str == null || !(str instanceof String)){
            Exception e = new Exception();
            Logger.getLogger(Logging.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( rawResults == null || !(rawResults instanceof String)){
        
        FileWriter out = null;
        try {
            out = new FileWriter(SAVE_FILE, true);
        } catch (IOException ex) {
            Logger.getLogger(Logging.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        BufferedWriter writer = new BufferedWriter(out);
        
        try {
            writer.write(str);
        } catch (IOException ex) {
            Logger.getLogger(Logging.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        try {
            writer.close();
        } catch (IOException ex) {
            Logger.getLogger(Logging.class.getName()).log(Level.SEVERE, null, ex);
        }
        
    } // public void appendFile(String str) {

... [truncated, 3 more lines] ...

package buzzerproxy;

import java.io.Serializable;

/**
 * @author Master
 */
public enum Mediatype implements Serializable {

    MUSIK(""), VIDEO(""), BILDER(""), APPS(""), COMPRESSED(""), TEXT(""), OFFICE(""), PREMIUM("");

    private String caption;

    private Mediatype(String caption) {
        this.caption = caption;
    }

    /**
     * @return
     */
    public String getCaption() {
        return caption;
    }
}

package buzzerproxy;

import java.io.Serializable;

/**
 * @author M. Friedeboldt / Sebastian Enger
 */
public class ResultContainer implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    private long              lastChecked;
    private String            resultUrl        = "";
    private String            sizeOfUrlContent = "";
    private String            fileTyp          = "";

    /**
     * @return the lastChecked
     */
    public long getLastChecked() {
        return lastChecked;
    }

    /**
     * @param lastChecked
     *            the lastChecked to set
     */
    public void setLastChecked(long lastChecked) {
        this.lastChecked = lastChecked;
    }

    /**
     * @return the resultUrl
     */
    public String getResultUrl() {
        return resultUrl;
    }

    /**
     * @param resultUrl
     *            the resultUrl to set
     */
    public void setResultUrl(String resultUrl) {
        this.resultUrl = resultUrl;
    }

    /**

... [truncated, 31 more lines] ...

package buzzerproxy;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.concurrent.Semaphore;

public class Serialization {

	private File cacheFile;

	private Semaphore semaphore = new Semaphore(1);

	/**
	 * @param filename
	 * @throws IOException
	 */
	public Serialization(String filename) throws IOException {
		if (filename == null)
			filename = "cache.ser.db";

		cacheFile = new File(filename);
		if (!cacheFile.exists()) {
			cacheFile.createNewFile();
		}
	}

	/**
	 * @param filename
	 * @param r
	 */
	public synchronized void writeCache(
			HashMap<String, ArrayList<ResultContainer>> c) {

		try {
			// Block
			semaphore.acquire();

			try {

... [truncated, 66 more lines] ...

package buzzerproxy;

import buzzerproxy.CommunicationProtocol;
import buzzerproxy.Crypto;
import buzzerproxy.Google;
import buzzerproxy.GoogleResultParser;
import buzzerproxy.Gzip;
import buzzerproxy.IO;
import buzzerproxy.Logging;
import buzzerproxy.XMLParser;
import buzzerproxy.bprot.ByteProtServer;
import buzzerproxy.handler.ExceptionHandler;
import buzzerproxy.handler.QuestionInterface;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.io.*;
import java.util.ArrayList;
import java.util.HashMap;

/**
 *
 * @author Enger
 */
public class TestClass {

    public static void main(String[] args) {
        // TODO code application logic here
        //  BuzzerProxy proxy = new BuzzerProxy();
        Google g = new Google();
        GoogleResultParser gr = new GoogleResultParser();
        String searchquery = "Madonna";
        String filetyp = "(.mp3|.wav|.flac)";
        String googleResultString = g.getGoogleContent(searchquery, filetyp);
        System.out.println("googleResultString:" + googleResultString);
        ArrayList<String> ResultXMLString = gr.parseResults(googleResultString, filetyp);

        for (String uri : ResultXMLString) {
            System.out.println(uri);
        }


    } // public static void main(String[] args) {
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.io.IOException;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

/** 
 * The Timer class allows a graceful exit when an application
 * is stalled due to a networking timeout. Once the timer is
 * set, it must be cleared via the reset() method, or the
 * timeout() method is called.
 * <p>
 * The timeout length is customizable, by changing the 'length'
 * property, or through the constructor. The length represents
 * the length of the timer in milliseconds.
 *
 * @version     1.0
 * @author	David Reilly
 * @see         http://www.javacoffeebreak.com/articles/network_timeouts/
 */
public class Timer extends Thread {

    /** Rate at which timer is checked */
    protected int m_rate = 100;
    /** Length of timeout */
    private int m_length;
    /** Time elapsed */
    private int m_elapsed;
    private Socket client;
    public boolean isTimeout = false;
    
    /**
     * Creates a timer of a specified length
     * @param	length	Length of time before timeout occurs
     */
    public Timer(int length, Socket client) {
        if (client == null || !(client instanceof Socket)) {
            System.err.println("Client is null");
            System.exit(1);
        }

        // Assign to member variable
        m_length = length;

        // Set time elapsed

... [truncated, 56 more lines] ...

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package buzzerproxy;

import java.util.HashMap;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Enger
 */
public class XMLParser {

    public final String CLIENT_ID = "clientid";
    public final String CLIENT_VERSION = "clientversion";
    public final String SEARCH_SERVICE = "searchservice";
    public final String FILE_TYP = "filetyp";
    public final String RESULT_PAGE = "page";
    public final String SEARCH_QUERY = "searchquery";

    public final HashMap<String, String> parseResults(String rawResults) {

        if ( rawResults == null || !(rawResults instanceof String)|| rawResults.isEmpty() ){
            Exception e = new Exception();
            Logger.getLogger(XMLParser.class.getName()).log(Level.SEVERE, null, e);
            System.exit(1);
        } // if ( rawResults == null || !(rawResults instanceof String)){
            
        HashMap<String, String> results = new HashMap<String, String>();
        String[] arr = rawResults.split("<");
        String key = null;
        String value = null;
                
        for (int i = 0; i < arr.length; i++) {
            //System.out.println("array"+i+"  :"+arr[i]);
            try {
                String[] splitter = arr[i].split(">");
                key = splitter[0];
                value = splitter[1];
                if ((key != null && !key.isEmpty()) && ( value != null && !value.isEmpty() ) ){
                    
                    splitter[0].trim();
                    splitter[1].trim();
                    splitter[0] = splitter[0].replaceAll("\\s+", "");	 // Achtung, hier wird der Whitespace entfernt	   
                    splitter[1] = splitter[1].replaceAll("\\s+", "");
                    
                    results.put(key, value);

... [truncated, 32 more lines] ...