moviestar - BuzzerStarProxy - src - generell - SOURCE CODE

package generell;
// Copyright 2003-2010 Christian d'Heureuse, Inventec Informatik AG, Zurich, Switzerland
// www.source-code.biz, www.inventec.ch/chdh
//
// This module is multi-licensed and may be used under the terms
// of any of the following licenses:
//
//  EPL, Eclipse Public License, V1.0 or later, http://www.eclipse.org/legal
//  LGPL, GNU Lesser General Public License, V2.1 or later, http://www.gnu.org/licenses/lgpl.html
//  GPL, GNU General Public License, V2 or later, http://www.gnu.org/licenses/gpl.html
//  AL, Apache License, V2.0 or later, http://www.apache.org/licenses
//  BSD, BSD License, http://www.opensource.org/licenses/bsd-license.php
//  MIT, MIT License, http://www.opensource.org/licenses/MIT
//
// Please contact the author if you need another license.
// This module is provided "as is", without warranties of any kind.


/**
* A Base64 encoder/decoder.
*
* <p>
* This class is used to encode and decode data in Base64 format as described in RFC 1521.
*
* <p>
* Project home page: <a href="http://www.source-code.biz/base64coder/java/">www.source-code.biz/base64coder/java</a><br>
* Author: Christian d'Heureuse, Inventec Informatik AG, Zurich, Switzerland<br>
* Multi-licensed: EPL / LGPL / GPL / AL / BSD / MIT.
*/
public class Base64Coder {

// The line separator string of the operating system.
private static final String systemLineSeparator = System.getProperty("line.separator");

// Mapping table from 6-bit nibbles to Base64 characters.
private static final char[] map1 = new char[64];
   static {
      int i=0;
      for (char c='A'; c<='Z'; c++) map1[i++] = c;
      for (char c='a'; c<='z'; c++) map1[i++] = c;
      for (char c='0'; c<='9'; c++) map1[i++] = c;
      map1[i++] = '+'; map1[i++] = '/'; }

// Mapping table from Base64 characters to 6-bit nibbles.
private static final byte[] map2 = new byte[128];
   static {
      for (int i=0; i<map2.length; i++) map2[i] = -1;
      for (int i=0; i<64; i++) map2[map1[i]] = (byte)i; }

/**

... [truncated, 177 more lines] ...

package generell;


import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.net.Socket;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Scanner;
import java.util.logging.Logger;

import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;

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

public class BuzzerProxyThread extends Thread {
    private Socket socket = null;
    private byte[] cipherText  = null;
    
    private String searchurl;
    private FindXmlHandler myXmlHandler;
	private CacheManager cache; 
	private String privatekey;
    private int maxresults;
	
    private String lauftext; 
    private String linktext;
    private String httpauthpassword;
    private String httpauthlogin;
    private TemporaryCache tCache;
    private int maxfreerequests;
    private int premiumsms;
    private String paymentscreen;
    
    private SQLFactory sqlFactory;
    
    public BuzzerProxyThread(Socket socket, int[] ports, String searchurl, String privatekey, int maxresults,String lauftext,String linktext, String httpauthpassword,String httpauthlogin, int maxfreerequests, int premiumsms, String paymentscreen, Logger searchLog) {

... [truncated, 278 more lines] ...

package generell;


import java.net.*;
import java.io.*;
import java.util.logging.FileHandler; 
import java.util.logging.Logger;
import java.util.logging.SimpleFormatter; 

public class BuzzerStarProxy {

	private static Logger searchLog;
	private static String conf 	= Constant.ConnectionConf;
    private static String logfile 	= Constant.SearchLog;
    private static int[] ports = {3381, 3382};
    private static String searchurl = "";
    private static String lauftext; 
    private static String linktext;
    private static String httpauthpassword;
    private static String httpauthlogin;
    private static int maxfreerequests;
    private static int premiumsms;
    private static String paymentscreen;
    
	public static void main(String[] args) throws IOException {
	        ServerSocket serverSocket = null;
	        Socket socket = null;
	        boolean listening = true;
	        int port = 3381;
	        String privatekey = null;
	       	int maxresults = (Integer) 50;
	       		            
	            try {
	                serverSocket = new ServerSocket(port); 
	            } catch (IOException e) {
	                System.err.println("Could not listen on port: "+port);
	                System.exit(-1);
	            }
	            searchLog = Logger.getLogger(logfile);  
	            FileHandler fh;
	            
	            try {  
	                  
	                // This block configure the logger with handler and formatter  
	                fh = new FileHandler(logfile);  
	                searchLog.addHandler(fh);  
	                //logger.setLevel(Level.ALL);  
	                SimpleFormatter formatter = new SimpleFormatter();  
	                fh.setFormatter(formatter);  
	                  

... [truncated, 145 more lines] ...

package generell;

import java.io.IOException;
import java.io.Serializable;
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 implements Serializable {

	private static final long                           serialVersionUID = 1L;
	 
	HashMap<String, ArrayList<ResultContainer>> cache = new HashMap<String, ArrayList<ResultContainer>>();

	  /** Cache Writer/Reader*/
    private Serialization                               ser;
    
	public CacheDeleter(HashMap<String, ArrayList<ResultContainer>> cache) throws IOException {
		this.cache = cache;
		ser = new Serialization( Constant.CACHEFILE );
	}

	public synchronized void cleanCache( HashMap<String, ArrayList<ResultContainer>> cache ) {

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

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


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

package generell;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;

public class CacheDeleterStart {

	  /** Cache Deleter */
    private static CacheDeleter     cacheDeleter;
    private static CacheManager		cacheManager;
    private static HashMap<String, ArrayList<ResultContainer>> cache;
    private static DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
    
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub

		cache = cacheManager.getCache();
		cacheDeleter.cleanCache(cache);
				
		//get current date time with Date()
		Date date = new Date();
		System.out.println(dateFormat.format(date) + ") Last Cache Deleter Run complete.");
		   
	}

}

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


import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import org.w3c.dom.*;

import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.DocumentBuilder;
import org.xml.sax.SAXException;
import org.xml.sax.SAXParseException;

/**
 * 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; // HashMap<Suchbegriff, ArrayList<Suchergebnisse>>

    /** 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, 136 more lines] ...

package generell;

import java.sql.*;

public class ConnectionManager // extends Object
{
    //
    // gibVerbindungFreiMethod
    //

    public static synchronized void gibVerbindungFrei(Connection inconnect)

    {
        if (dieConnection == null) {
            // keine Connection frei verfgbar, also wird die aktuelle verfgbar
            // gemacht
            try {
                dieConnection.close();
            } catch (Exception e) {
            }
            //dieConnection = inconnect;
        } else {
            // es gibt bereits eine frei verfgbare Connection, die aktuelle
            // wird echt geschlossen
            try {
                dieConnection.close();
            } catch (Exception e) {
            }
        }
    }

    //
    // holeVerbindungMethod
    //

    public static synchronized Connection holeVerbindung(String user, String password) throws Exception {
        if (dieConnection == null) {
            // keine Connection frei verfgbar
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            //Connection result = DriverManager.getConnection("jdbc:mysql://77.247.178.21:3306", user, password);
            Connection result = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306", user, password);
            result.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED );
            return result;
        } else {
            // es gibt eine freie Connection, die genommen wird
            // was passiert, wenn zwei Anwendungen gleichzeitig hier hinein
            // kommen???
            Connection erg = dieConnection;
            dieConnection = null;
            // erg = null;

... [truncated, 26 more lines] ...

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


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

	public static final String CACHEFILE = "buzzerstar.cache.ser.db";
	public static final long CACHE_VALID_TIME = 604800; // 7 * 24 * 60 * 60
	public static final int MAX_RESULTS_PER_HANDY_SEARCHSCREEN = 50; 
	public static final String SqlHost = "www.buzzerstar.com";
	public static final String SqlUser = "root";
	public static final String SqlPassword = "mysqlPasswordHere";
	public static final String ConnectionConf = "connection.conf";
	public static final String SearchLog	= "searchLog.log";
}

package generell;

import org.xml.sax.Attributes;
import org.xml.sax.SAXException;
import org.xml.sax.helpers.DefaultHandler;
import java.io.Serializable;

public class FindXmlHandler extends DefaultHandler implements Serializable {
	
	/**
	 * 
	 */
	private static final long serialVersionUID = -1058077047271686318L;
	boolean currentElement = false;
    String currentValue = "";
    
    private String servicetyp;
    private String clientversion;
	private String xmlversion;
	private String searchtext;
	private String media;
	private String key;
	private String language;
	private String android;
	private String noporn;
	private int page;
	private String imei;
	private int payment;
	
	public int getPayment(){
		return payment;
	}	
	public String getImei(){
		return imei;
	}	
	public int getPage(){
		return page;
	}
	public String getNoPorn(){
		return noporn;
	}	
	public String getServiceTyp(){
		return servicetyp;
	}
    public String getClientVersion(){
		return clientversion;
	}
	public String getXmlVersion(){
		return xmlversion;
	}

... [truncated, 105 more lines] ...

package generell;

// NOT USED ANY MORE: SEBASTIAN ENGER

import java.net.*;
import java.io.*;
import java.util.logging.FileHandler; 
import java.util.logging.Logger;
import java.util.logging.SimpleFormatter; 
 
public class JProxy {
	
	private static int sourceLimit = 15;
	private static int strikeLimit = 20;
	private static String privateKey = "380971de720bf96f51d372441d4cacf3";
	private static String token = "345Dgsdfg54534gdfghsgfhSDF8452wtHDFGHWG345tGD";
	private static String cd = "v=1009;77.247.178.21:9923:8;77.247.178.74:9923:8;";
	private static int[] ports = {3383, 3384};
	private static Logger searchLog;
	
	
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = null;
        Socket socket = null;
        boolean listening = true;
        int port =9923;
        
        
        try {
		BufferedReader in = new BufferedReader(new FileReader("conf.jpr"));
		String zeile = null;
		while ((zeile = in.readLine()) != null) {
			//System.out.println(zeile);
			if(zeile.startsWith("sourceLimit")){
				try{
				  sourceLimit=Integer.parseInt((zeile.substring(zeile.indexOf("=")+1,zeile.length())).trim());
				}catch(NumberFormatException nfe){
					System.out.println("sourceLimit set to standart value: "+ sourceLimit);
				}
				//System.out.println(sourceLimit);
			}
			if(zeile.startsWith("strikeLimit")){
				try{
				  strikeLimit=Integer.parseInt((zeile.substring(zeile.indexOf("=")+1,zeile.length())).trim());
				}catch(NumberFormatException nfe){
					System.out.println("strikeLimit set to standart value: "+ strikeLimit);
				}
				//System.out.println(strikeLimit);
			}
			if(zeile.startsWith("token")){

... [truncated, 83 more lines] ...

package generell;


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;

import java.util.Random;
import java.util.zip.GZIPOutputStream;

import java.sql.*;
import java.util.GregorianCalendar;

import java.util.logging.Logger;

import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;
 
import org.xml.sax.InputSource;
import org.xml.sax.XMLReader;

import generell.FindXmlHandler;

public class ProxyServerThread extends Thread {
    private Socket socket = null;
    private byte[] cipherText  = null;
    private String privateKey ="380971de720bf96f51d372441d4cacf3";
    private int id = 0;
    private String[] searchTerm;
    private String token ="345Dgsdfg54534gdfghsgfhSDF8452wtHDFGHWG345tGD";
    private String mediaFile;
    private String search;
    private String cd = "v=1009;77.247.178.21:9923:8;77.247.178.21:9923:8;";
    private int cdv;
    private int cdu = 0;
    private int[] ports = {3383, 3384};
    
    private int sourceLimit = 15;
    private int strikeLimit = 20;
    
    private Logger searchLog;
    private FindXmlHandler myXmlHandler; 


... [truncated, 476 more lines] ...

package generell;


import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;

public class ResultBase{

 private ArrayList<SHA1Base> resultAL;
 
    private int strikeLimit = 20;
    private int sourceLimit = 15;    
	
	public ResultBase(int sourceLimit, int strikeLimit){
		//System.out.println("ResultBase initialized");
		this.strikeLimit = strikeLimit;
		this.sourceLimit = sourceLimit;
		resultAL = new ArrayList<SHA1Base>();
	}
	
	public void setResult(String SHA1, String size, String name ,String score, String fileindex, String ipp){
		SHA1Base sha1 = getSHA1(SHA1);
		if(sha1 == null){
			//System.out.println("sha1 is null");
			//System.out.println(size);
	         long l;
			 int sl = sourceLimit;
			 try {
              l = Long.parseLong(size.trim());
              l = l /(1024L*1024L);
              if(l >= 15L){
              	if(l >= 50L){
              		sl= 49;
              		//System.out.println("< 50: "+ sl );
              	}else{
              		sl = (int)l -1;
              		//System.out.println("< 15: "+ sl );
              	}
              }
               //System.out.println("> 15: "+ sl );
               
             } catch (NumberFormatException nfe) {
                //resultAL.add(new SHA1Base(name, size ,SHA1, Integer.parseInt(score), ipp+";"+fileindex, sourceLimit));
             }
            if(SHA1.length()> 20){
			  resultAL.add(new SHA1Base(name, size ,SHA1, Integer.parseInt(score), ipp+";"+fileindex, sl));
			}else{
				System.out.println("SHA1 corrupt: "+ SHA1);
			}  			

... [truncated, 48 more lines] ...

package generell;


import java.io.Serializable;

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

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

    private String typ = "";
    private String name = "";
    private String preview = "";
    private String securepreview = "";
    private String link = "";
    private String securelink = "";
    private String size = "";
    private String category = "";
    private long installed; // currentTimeMillis()
    
    /*
     * <item>
	<typ>Zeichentrick</typ>
	<name>01   Die Star Sherrifs</name>
	<preview>http://46.38.232.54/comics/01 - Die Star Sherrifs.mp4?start=0&end=600</preview>
	<securepreview>https://46.38.232.54/comics/01 - Die Star Sherrifs.mp4?start=0&end=600</securepreview>
	<link>http://46.38.232.54/comics/01 - Die Star Sherrifs.mp4</link>
	<securelink>https://46.38.232.54/comics/01 - Die Star Sherrifs.mp4</securelink>
	<size>147662407</size>
	<category>searchresult</category>
     * */
    
    public void setTyp(String typ) {
        this.typ = typ;
    }
    public void setName(String name) {
        this.name = name;
    }
    public void setPreview(String name) {
    	 this.preview = name;
    }
    public void setSecurePreview(String name) {
    	 this.securepreview = name;
    }
    public void setLink(String name) {

... [truncated, 46 more lines] ...

package generell;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;


public class SHA1Base{
	
	private String name;
	private String SHA1;
	private String size;
	private ArrayList<SourceBase> sourceAL;
	
	private int sourceLimit = 15;  
	
	public SHA1Base(String name, String size ,String SHA1, int score, String source, int sourceLimit){
		this.name = name;
		this.SHA1 = SHA1;
		this.size = size;
		this.sourceLimit= sourceLimit;
		this.sourceAL = new ArrayList<SourceBase>();
		sourceAL.add(new SourceBase(score, source));
	}
	
	public boolean exists(String SHA1){
		if(this.SHA1.equals(SHA1)){
			return true;
		}
		return false;
	}
	public void addSource(int score, String source){
		if(!sourceExsists(source)){
			sourceAL.add(new SourceBase(score, source));
		}	
	}
	private boolean sourceExsists(String source){
		for(int i = 0; i < sourceAL.size(); i++){
			if((sourceAL.get(i).getSource()).equals(source)){
				System.out.println("source allredy exsists!!!!!!");
				return true;
			}
		}
		return false;
	} 
	public String getName(){
		return name;
	}
	public String getSHA1(){
		return SHA1;

... [truncated, 60 more lines] ...

package generell;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.sql.*;

public class SQLFactory {
	
	private String sqlHost 		= Constant.SqlHost;
	private String connection 	= "jdbc:msql://"+sqlHost+":3306/licence";
	private TemporaryCache tCache;
	private int numberOfColumns = 0;
	private String conf 		= Constant.ConnectionConf;
	private int maxpremiumrequests;
	
	public int getLicenceStatus(String imei, int maxfreerequests){
        
		tCache.setStatus(1); // auf null setzen fr scharfstellung
		
		try {
            Connection conn = DriverManager.getConnection(connection,Constant.SqlUser,Constant.SqlPassword);
            Statement stmt = conn.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY );
           
            ResultSet rs = stmt.executeQuery("SELECT requestcount AS REQUESTS FROM licence WHERE imei = "+imei+" LIMIT 1;"); // requestcount==INT | imei==VARCHAR
            String requestcount = rs.getString("REQUESTS");
            
            ResultSetMetaData rsMetaData = rs.getMetaData();
            numberOfColumns = rsMetaData.getColumnCount();
                        
            int ReqfromSql = Integer.parseInt(requestcount);
            
            if (numberOfColumns <= 0 ) {
            	tCache.setStatus(1); // kein Eintrag fr imei > zugriff erlauben
            	stmt.executeUpdate("INSERT INTO licence VALUES (1, "+imei+");");            	
            } else if ( ReqfromSql >= maxfreerequests ){
            	tCache.setStatus(0);
            } else if ( ReqfromSql < maxfreerequests ){
            	tCache.setStatus(1);
            } else {
            	tCache.setStatus(1); // auf null setzen fr scharfstellung
            }
                        
            conn.close();
        } catch (Exception e) {
            System.err.println("Got an exception! ");
            System.err.println(e.getMessage());
        }
        
        return tCache.getStatus();

... [truncated, 53 more lines] ...

package generell;


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 = Constant.CACHEFILE;

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


... [truncated, 67 more lines] ...

/**
 * 
 */
package generell;

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

	private String cache;
	private int status = 0;
	
	public void setStatus(int c) {
        this.status = c;
    }
	public int getStatus() {
	    return this.status;
	}
	
	public void setCache(String c) {
        this.cache = c;
    }
	public String getCache() {
	    return this.cache;
	}
	
}