moviestar - BuzzerProxy - src - src - 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 java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.io.*;
import java.util.HashMap;

/**
 *
 * @author thecerial
 */
public class BuzzerProxy {

    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>"
            + "<servicetyp>find</servicetyp>"
            + "<searchquery>Madonna</searchquery>"
            + "<filetyp>(.mp3|.wav|.flac)</filetyp>"
            + "<session>23232323232323232323232323</session>"
            + "<clientversion>1.0.1</clientversion>"

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

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

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.HttpURLConnection;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.text.BadLocationException;

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 getUrlContent(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)){
        
        String returnContent = "";
        searchQuery = searchQuery.replace(" ", "%20");
        fileType = fileType.replace(" ", "%20");
        String searchUrl = GOOGLE_SEARCH_BASE.replace("SEARCHQUERY", searchQuery).replace("FILETYP", fileType);
        try {
            returnContent = (openCon(new URL(searchUrl)));
        } catch (IOException ex) {
            Logger.getLogger(Google.class.getName()).log(Level.SEVERE, null, ex);
//        } catch (BadLocationException ex) {
//            Logger.getLogger(Google.class.getName()).log(Level.SEVERE, null, ex);
        }
        return returnContent;
        
    } //  public String getUrlContent(String searchQuery, String fileType) throws IOException, BadLocationException {

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

... [truncated, 65 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 GoogleResultParser {

    public String parseResults(String rawResults) {
        
         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)){
         
        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>");
        for (int i = 0; i < arr.length; i++) {
            int pos = i + 2;

//            System.out.println("array"+i+"  :"+arr[i]);
            //titleNoFormatting  unescapedUrl

            if (arr[i].equalsIgnoreCase("titleNoFormatting")) {
                sb.append("<title>");
                sb.append(arr[pos]);
                sb.append("</title>");
            }

            if (arr[i].equalsIgnoreCase("unescapedUrl")) {
                sb.append("<url>");
                sb.append(arr[pos]);
                sb.append("</url>");
//                System.out.println("REAL POSITION: '" + arr[i] + "'");
//                System.out.println("ARRAY PèOSTITION: " + arr[pos]);
            }
        } //  for (int i = 0; i < arr.length; i++) {


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

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

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

    IO() {
    }

    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;

    } //public boolean isSet(DataOutputStream str){

    public boolean isSet(HashMap str) {

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

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

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

    /**
     * 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
        m_elapsed = 0;

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