Banana-Coding.com - Java Knuddels Emulator

Quellcode

/* Banana-Chat - The first Open Source Knuddels Emulator
 * Copyright (C) 2011  Flav <http://banana-coding.com>
 *
 * Diese Datei unterliegt dem Copyright von Banana-Coding und
 * darf verändert, aber weder in andere Projekte eingefügt noch
 * reproduziert werden.
 *
 * Der Emulator dient - sofern der Client nicht aus Eigenproduktion
 * stammt - nur zu Lernzwecken, das Hosten des originalen Clients
 * ist untersagt und wird der Knuddels GmbH gemeldet.
 */
package knuddels;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import tools.IntegerUtil;
import tools.KCodeParser;
import tools.PacketCreator;
import tools.Pair;
import tools.database.ConnectionPool;
import tools.database.PoolConnection;

/**
 *
 * @author Flav
 */
public class Client {

    private final List<Channel> channels;
    private final Socket socket;
    private OutputStream out;
    private List<Pair<String, Integer>> icons;
    private String name;
    private byte gender;
    private String age;
    private String birthday;
    private String starsign;
    private String forgiven;
    private String realname;
    private String stadt;
    private String land;
    private String hobbys;
    private String job;
    private String email;
    private String motto;
    private int roses;
    private byte rank;
    private int kisses;
    private int knuddels;
    private int onlineTime;
    private long loginTimestamp;
    private String registrationDate;
    private String like;
    private String registrationTime;
    private String ipAddress;
    private int ban;
    private String appletVersion;
    private String readme;
    private boolean away;
    private int spam;
    private long lastAction;
    private float wordmixPoints;
    private float quizPoints;
    private float mafia;
    //Familymitglied
    private byte famcheck;
    private String famcheckdate;
    private String famseit;
    private Client kdice_user;
    private int kdice_id;
    private int kdice_count;
    private String kdice_dice;

    public Client(Socket socket) {
        channels = new ArrayList<Channel>();
        this.socket = socket;

        if (socket == null) {
            return;
        }

        try {
            out = socket.getOutputStream();
        } catch (IOException e) {
        }
    }

    public List<Pair<String, Integer>> getIcons() {
        return icons;
    }

    private void addIcon(String icon, int size) {
        Pair<String, Integer> pair = new Pair<String, Integer>(icon, size);
        icons.add(pair);

        for (Channel channel : getChannels()) {
            String add = PacketCreator.addIcon(channel.getName(), name, pair);

            for (Client target : channel.getClients()) {
                target.send(add);
            }
        }
    }

    private void removeIcon(String icon) {
        for (Pair<String, Integer> pair : icons) {
            if (pair.getLeft().equals(icon)) {
                icons.remove(pair);
                break;
            }
        }

        for (Channel channel : getChannels()) {
            String remove = PacketCreator.removeIcon(channel.getName(), name, icon);

            for (Client target : channel.getClients()) {
                target.send(remove);
            }
        }
    }

    public String getName() {
        return name;
    }

    public String getAppletVersion() {
        return appletVersion;
    }
    
    public String getRealName() {
        return realname;
    }

    public String getBirthday() {
        return birthday;
    }

    public String getStadt() {
        return stadt;
    }

    public String getLand() {
        return land;
    }

    public String getHobbys() {
        return hobbys;
    }

    public String getJob() {
        return job;
    }

    public String getMotto() {
        return motto;
    }

    public String getAge() {
        return age;
    }

    public String getStarsign() {
        return starsign;
    }

    public String getForgiven() {
        return forgiven;
    }
    
    public String getEmail(){
        return email;
    }

    public void setRealName(String realname) {
        this.realname = realname;
    }

    public void setBirthday(String birthday) {
        this.birthday = birthday;
    }

    public void setStadt(String stadt) {
        this.stadt = stadt;
    }

    public void setLand(String land) {
        this.land = land;
    }

    public void setHobbys(String hobbys) {
        this.hobbys = hobbys;
    }

    public void setJob(String job) {
        this.job = job;
    }

    public void setMotto(String motto) {
        this.motto = motto;
    }
    
    public void setAge(String age){
        this.age = age;
    }
    
    public void setStarsign(String starsign){
        this.starsign = starsign;
    }
    
    public void setForgiven(String forgiven){
        this.forgiven = forgiven;
    }
    
    public void setEmail(String email){
        this.email = email;
    }

    public String getReadme() {
        return readme;
    }

    public void setReadme(String text) {
        this.readme = text;
    }

    public byte getRank() {
        return rank;
    }

    public String getLike() {
        return like;
    }

    public void setLike(String like) {
        this.like = like;
    }

    public boolean isVIP() {
        return rank >= 2;
    }

    public boolean isModerator() {
        return rank >= 3;
    }

    public boolean isAdministrator() {
        return rank >= 4;
    }

    //Familymitglied
    public boolean isFam() {
        return rank >= 1;
    }

    public byte isFamcheck() {
        return famcheck;
    }

    public String getFamseit() {
        return famseit;
    }

    public String getFamcheckdate() {
        return famcheckdate;
    }

    public byte getGender() {
        return gender;
    }

    public int getKisses() {
        return kisses;
    }
    
    public void increaseMafia(float mafia){
        this.mafia += mafia;
    }
    
    public float getMafia(){
        return mafia;
    }

    public void increaseWordMixPoints(float wordmixPoints) {
        this.wordmixPoints += wordmixPoints;
    }

    public float getWordMixPoints() {
        return wordmixPoints;
    }
    
    public void increaseQuizPoints(float quizPoints){
        this.quizPoints += quizPoints;
    }
    
    public float getQuizPoints(){
        return quizPoints;
    }
    
    public void increaseRoses(int roses){
        this.roses += roses;
    }
    
    public int getRoses(){
        return roses;
    }

    public void increaseKisses() {
        kisses++;
    }

    public int getKnuddels() {
        return knuddels;
    }

    public void setKnuddels(int knuddels) {
        this.knuddels = knuddels;
    }

    public void setAppletVersion(String version) {
        this.appletVersion = version;
    }

    public int getOnlineTime() {
        return onlineTime + (int) ((System.currentTimeMillis() - loginTimestamp) / 1000);
    }

    public String getRegistrationDate() {
        return registrationDate;
    }

    public String getRegistrationTime() {
        return registrationTime;
    }

    public String getIPAddress() {
        return ipAddress;
    }

    public int getBan() {
        return ban;
    }

    public boolean isAway() {
        return away;
    }

    public void setAway(boolean away) {
        this.away = away;

        if (away) {
            addIcon("pics/away.png", 20);
        } else {
            removeIcon("pics/away.png");
        }
    }

    public int getDiceID() {
        return kdice_id;
    }

    public String getDice() {
        return kdice_dice;
    }

    public Client getDiceUser() {
        return kdice_user;
    }

    public int getDiceCount() {
        return kdice_count;
    }

    public void setDiceUser(Client user, int count, String dice) {
        kdice_user = user;
        kdice_id = IntegerUtil.rand(100000, 999999);
        kdice_count = count;
        kdice_dice = dice;
    }

    public void increaseKnuddels(int num) {
        knuddels += num;
    }

    public void decreaseKnuddels(int num) {
        knuddels -= num;
    }

    public boolean checkSpam(String channel) {
        long now = System.currentTimeMillis();

        if (lastAction > now - 2000) {
            spam++;

            if (spam == 2) {
                sendButlerMessage(channel, "Bitte _NICHT spammen_ und fluten.");
            } else if (spam == 3) {
                disconnect();
                return true;
            }
        } else {
            spam -= (now - lastAction) / 2000;

            if (spam < 0) {
                spam = 0;
            }
        }

        lastAction = now;
        return false;
    }

    public void login(String nickname) throws SQLException {
        if (name != null && !name.equals(nickname)) { // logging in using another account
            logout("Ausgeloggt");
        }

        synchronized (channels) {
            if (channels.isEmpty()) { // is logged out
                Client client = Server.get().getClient(nickname);

                if (client != null) { // someone else is logged into that account
                    client.disconnect();
                }

                loadStats(nickname);
            }
        }
    }

    public void logout(String message) {
        synchronized (channels) {
            if (!channels.isEmpty()) { // is logged in
                for (Channel channel : channels) {
                    channel.leave(this);

                    if (message != null) {
                        send(PacketCreator.kick(channel.getName(), message));
                    }
                }

                channels.clear();
                saveStats();
                Server.get().removeClient(name);
                sendHello();
            }
        }
    }

    public Channel getChannel() {
        if (name.equals(Server.get().getButler().getName())) {
            return null;
        }

        synchronized (channels) {
            return channels.get(channels.size() - 1);
        }
    }

    public List<Channel> getChannels() {
        synchronized (channels) {
            return channels;
        }
    }

    public void joinChannel(Channel channel) {
        synchronized (channels) {
            if (channels.isEmpty()) { // logged in
                Server.get().addClient(this);
            }

            channels.add(channel);
        }
    }

    public void leaveChannel(Channel channel) {
        synchronized (channels) {
            channels.remove(channel);

            if (channels.isEmpty()) { // logged out
                saveStats();
                Server.get().removeClient(name);
                sendHello();
            }
        }
    }

    public void loadStats(String name) {
        PoolConnection pcon = ConnectionPool.getConnection();
        PreparedStatement ps = null;

        try {
            Connection con = pcon.connect();
            ps = con.prepareStatement("SELECT * FROM `accounts` WHERE `name` = ?");
            ps.setString(1, name);
            ResultSet rs = ps.executeQuery();

            if (rs.next()) {
                this.name = rs.getString("name");
                age = rs.getString("age");
                birthday = rs.getString("birthday");
                starsign = rs.getString("starsign");
                forgiven = rs.getString("forgiven");
                realname = rs.getString("realname");
                stadt = rs.getString("stadt");
                land = rs.getString("land");
                hobbys = rs.getString("hobbys");
                job = rs.getString("job");
                email = rs.getString("email");
                motto = rs.getString("motto");
                rank = rs.getByte("rank");

                icons = new ArrayList<Pair<String, Integer>>();
                gender = rs.getByte("gender");

                if (gender == 1) {
                    addIcon("pics/male.png", 16);
                } else if (gender == 2) {
                    addIcon("pics/female.png", 14);
                }

                if (getRank() == 2) {
                    addIcon("pics/icon_vip.png", 22);
                }

                kisses = rs.getInt("kisses");
                roses = rs.getInt("roses");
                knuddels = rs.getInt("knuddels");
                like = rs.getString("like");
                onlineTime = rs.getInt("onlineTime");
                mafia = rs.getFloat("mafia");
                quizPoints = rs.getFloat("quizpoints");
                wordmixPoints = rs.getFloat("wordmixpoints");
                readme = rs.getString("readme");
                loginTimestamp = System.currentTimeMillis();

                String[] registration = rs.getString("registration").split(" ");
                String[] date = registration[0].split("-");
                registrationDate = String.format("%s.%s.%s", date[2], date[1], date[0]);
                registrationTime = registration[1].split("\\.")[0];

                //Familymitglied
                String famrech = rs.getString("familydate");
                String[] fdate = famrech.split("-");
                famseit = String.format("%s.%s.%s", fdate[2], fdate[1], fdate[0]);
                famcheck = rs.getByte("famcheck");
                String dfamcheck = rs.getString("famcheckdate");
                String[] fmdate = dfamcheck.split("-");
                famcheckdate = String.format("%s.%s.%s", fmdate[2], fmdate[1], fmdate[0]);

                if (isModerator()) {
                    ipAddress = "1.3.3.7";
                } else {
                    if (socket == null) {
                        ipAddress = rs.getString("ipAddress");
                    } else {
                        ipAddress = socket.getInetAddress().getHostAddress();
                    }
                }

                away = false;
                ban = rs.getInt("ban");
                spam = 0;
                lastAction = 0;
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                }
            }

            pcon.close();
        }
    }

    private void saveStats() {
        PoolConnection pcon = ConnectionPool.getConnection();
        PreparedStatement ps = null;

        try {
            Connection con = pcon.connect();
            ps = con.prepareStatement("UPDATE `accounts` SET `kisses` = ?, `knuddels` = ?, `onlineTime` = ?, `ipAddress` = ?, `readme` = ?, `age` = ?, `birthday` = ?, `starsign` = ?, `forgiven` = ?, `realname` = ?, `stadt` = ?, `land` = ?, `hobbys` = ?, `job` = ?, `email` = ?, `motto` = ?, `wordmixPoints` = ?, `mafia` = ?, `quizpoints` = ?, `like` = ?, `roses` = ? WHERE `name` = ?");
            ps.setInt(1, kisses);
            ps.setInt(2, knuddels);
            ps.setInt(3, getOnlineTime());
            ps.setString(4, ipAddress);
            ps.setString(5, readme);
            ps.setString(6, age);
            ps.setString(7, birthday);
            ps.setString(8, starsign);
            ps.setString(9, forgiven);
            ps.setString(10, realname);
            ps.setString(11, stadt);
            ps.setString(12, land);
            ps.setString(13, hobbys);
            ps.setString(14, job);
            ps.setString(15, email);
            ps.setString(16, motto);
            ps.setFloat(17, wordmixPoints);
            ps.setFloat(18, mafia);
            ps.setFloat(19, quizPoints);
            ps.setString(20, like);
            ps.setInt(21, roses);
            ps.setString(22, name);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                }
            }

            pcon.close();
        }
    }

    public void sendHello() {
        Collection<Channel> channelList = Server.get().getChannels();
        send(PacketCreator.hello(((Channel) channelList.toArray()[0]).getName()));
        send(PacketCreator.channelList(channelList));
    }

    public void sendPrivateMessage(List<Client> targets, String message, Channel channel, boolean fromGame) {
        if (!fromGame && channel.getGame() != null && !channel.getGame().parsePrivateMessage(targets, message, this)) {
            return;
        }

        message = KCodeParser.parse(message, !isModerator(), 5, 10, 20);
        message = Server.get().parseSmileys(message);

        if (message.isEmpty()) {
            return;
        }

        StringBuilder recipients = new StringBuilder();

        for (Client target : targets) {
            recipients.append(target.getName());
            recipients.append(",");
        }

        String recipient = recipients.substring(0, recipients.length() - 1);

        if (!targets.contains(this)) {
            targets.add(this);
        }

        for (Client target : targets) {
            if (channel.getClients().contains(target)) {
                target.send(PacketCreator.privateMessage(name, recipient, channel.getName(), message, " "));
            } else {
                for (Channel ch : target.getChannels()) {
                    target.send(PacketCreator.privateMessage(name, recipient, ch.getName(), message, channel.getName()));
                }
            }
        }
    }

    public void sendButlerMessage(String channel, String message) {
        send(PacketCreator.privateMessage(Server.get().getButler().getName(), name, channel, message, " "));
    }

    public void send(String message) {
        if (socket != null && socket.isConnected()) {
            try {
                out.write(Protocol.encode(message.getBytes("UTF8")));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void disconnect() {
        logout(null);

        if (socket != null && !socket.isClosed()) {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void updateReadme() {

        PoolConnection pcon = ConnectionPool.getConnection();
        PreparedStatement ps = null;

        try {
            Connection con = pcon.connect();
            ps = con.prepareStatement("UPDATE `accounts` SET `readme` = ? WHERE `name` = ?");
            ps.setString(1, readme);
            ps.setString(2, name);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                }
            }

            pcon.close();
        }
    }
}