moviestar - software - SOURCE CODE

package com.jicoma.ic;


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 com.twmacinta.util.*;
import com.ic.BuzzerStarMovie.Misc.LizenzKey;
import com.ic.BuzzerStarMovie.Misc.Constant;


public class Crypt{

 //private BufferedBlockCipher cipher      = null;
 private byte[] cipherText  = null;
	
	public Crypt(String kryptKey){
		
		//System.out.println("cipherText: " +kryptKey);
		
	this.cipherText = Hex.decode(kryptKey.getBytes());
	
		//String st = new String(Hex.encode(cipherText));
        
	}
    
public final String performEncrypt(String plainText){

        byte[] ptBytes = plainText.getBytes();

   BufferedBlockCipher cipher = new PaddedBufferedBlockCipher(new CBCBlockCipher(new AESEngine()));
        
        String name = cipher.getUnderlyingCipher().getAlgorithmName();

        cipher.init(true, new KeyParameter(cipherText));

        byte[] rv = new byte[cipher.getOutputSize(ptBytes.length)];

        int oLen = cipher.processBytes(ptBytes, 0, ptBytes.length, rv, 0);
        try
        {
            cipher.doFinal(rv, oLen);
        }
        catch (CryptoException ce)
        {

... [truncated, 17 more lines] ...

package com.ic.BuzzerStarMovie;

import android.app.Activity;
import android.os.Bundle;

import android.widget.TextView;
import android.widget.Button;
import android.widget.EditText;
import android.view.View;

import android.view.View.OnClickListener;
import android.graphics.Color;
import android.view.View.OnFocusChangeListener;

import java.io.ByteArrayOutputStream;
import android.content.res.AssetManager;

import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;
 
import org.xml.sax.InputSource;
import org.xml.sax.XMLReader;
import java.util.Locale;
import android.os.Build.VERSION;
import android.os.Build;
import java.io.Serializable;
import java.io.ObjectOutputStream;
import java.io.InputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.io.InputStream;
import java.util.zip.GZIPInputStream;


import com.jicoma.ic.Crypt;
import com.ic.BuzzerStarMovie.Misc.LizenzKey;

import java.net.Socket;
import java.net.UnknownHostException;
import java.io.IOException;




 
public class SearchScreen extends Activity implements OnClickListener{
	
private Button sendSearch;
private Button clearButton;
private EditText searchText;

... [truncated, 175 more lines] ...

package com.ic.BuzzerStarMovie;

import android.app.Activity;
import android.os.Bundle;

import android.widget.TextView;
import android.widget.Button;
import android.widget.EditText;
import android.view.View;

import android.view.View.OnClickListener;
import android.graphics.Color;
import android.view.View.OnFocusChangeListener;

import java.io.ByteArrayOutputStream;
import android.content.res.AssetManager;

import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;
 
import org.xml.sax.InputSource;
import org.xml.sax.XMLReader;
import java.util.Locale;
import android.os.Build.VERSION;
import android.os.Build;
import java.io.Serializable;
import java.io.ObjectOutputStream;
import java.io.InputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.io.InputStream;
import java.util.zip.GZIPInputStream;


import com.jicoma.ic.Crypt;
import com.ic.BuzzerStarMovie.Misc.LizenzKey;

import java.net.Socket;
import java.net.UnknownHostException;
import java.io.IOException;




 
public class SearchScreen extends Activity implements OnClickListener{
	
private Button sendSearch;
private Button clearButton;
private EditText searchText;

... [truncated, 175 more lines] ...

package com.jicoma.ic;

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

package com.jicoma.ic;


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;
import com.ic.BuzzerStarMovie.FindXmlHandler;

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;
    

... [truncated, 284 more lines] ...

package com.jicoma.ic;

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);  
	                  
	                // the following statement is used to log any messages  

... [truncated, 144 more lines] ...

package com.jicoma.ic;

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 com.jicoma.ic;

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 com.jicoma.ic;

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

package com.jicoma.ic;

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 com.jicoma.ic;

/*
 * 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 com.ic.BuzzerStarMovie;

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, 113 more lines] ...

package com.jicoma.ic;

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