moviestar - BuzzerStar - svn - BuzzerProxy - SOURCE CODE

/*
 * 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;
import java.util.List;

/**
 *
 * @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;

... [truncated, 256 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;

import java.security.SecureRandom;
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[] key = null;

    /**
     * @param key
     */
    public Crypto(byte[] key) {
        if ( key == null )
            throw new NullPointerException( "key == null !!!" );

        this.key = key;
    }

    /**
     * @return
     */
    public static byte[] generateSessionID(int dep) {
        SecureRandom randomr = new SecureRandom();
        randomr.setSeed(System.currentTimeMillis());
        return randomr.generateSeed( dep );
    }

    /**
     * @param key
     * @param plainText
     * @return
     */
    public String performEncrypt(String plainText) {

... [truncated, 64 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] ...

/*
 * 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;

/**
 * @author M. Friedeboldt
 */
public class ResultContainer {

    // TODO Inhalt der URL's
}

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] ...

package googleproxy;

/*
 * 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();


... [truncated, 71 more lines] ...