Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private void readResponse() throws IOException {
- //Read Loop Thread//
- Thread readThread = new Thread(new Runnable() {
- @Override
- public void run() {
- try {
- //Innput reader and channel/
- DataInputStream sockInput = new DataInputStream(socket.getInputStream());
- ReadableByteChannel readChannel = Channels.newChannel(sockInput);
- while (true) {
- // see if any message has been received//
- ByteBuffer bufferA = ByteBuffer.allocate(10000000);
- @SuppressWarnings("unused")
- int count = 0;
- //empty message//
- String message = "";
- //Read bytes//
- while ((count = readChannel.read(bufferA)) > 0) {
- // flip the byte buffer to start reading//
- bufferA.flip();
- //decode bytes and add each char-construct message//
- message += Charset.defaultCharset().decode(bufferA);
- }
- //check if message had data//
- if (message.length() > 0 && !message.trim().isEmpty()) {
- ///////////////////////////////////////
- //SERVER COMMANDS/////////////////////
- //on login//
- if (message.trim().toLowerCase().startsWith("ok:")) {
- onConnectRcv(message);
- }
- //on login fail//
- if (message.trim().toLowerCase().startsWith("denied:")) {
- onConnectFailRcv();
- }
- //On init//
- if (message.trim().toLowerCase().contains("inited")) {
- onInitRcv(message);
- }
- if (message.trim().toLowerCase().contains("bird")) {
- Server.passcommands("bird");
- }
- //message//
- if (message.trim().toLowerCase().startsWith("b:")) {
- String clean = cleanMSG(message);
- String sender = getSender(message);
- // Bot.print("[Room message] "+sender+" : "+clean);
- test.append(sender + " : " + clean +"\n");
- //System.out.println("[Room message] " + sender + " : " + clean);
- checkCmd(clean, sender);
- }
- //System.out.println("[Room] Room debug : "+message);
- //com.cavariux.twitchirc.Bot.print("[Room] Room debug : "+message);
- //Reset message//
- message = "";
- if (!socket.getKeepAlive()) {
- socket.close();
- break;
- }
- }
- }
- }catch (SocketException e) {
- System.out.println("Fuked up socket");
- } catch (IOException e) {
- e.printStackTrace();
- }
- //System.out.println("did it");
- }
- });
- readThread.start();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement