Advertisement
Guest User

Untitled

a guest
Jun 25th, 2017
67
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.67 KB | None | 0 0
  1. private void readResponse() throws IOException {
  2. //Read Loop Thread//
  3. Thread readThread = new Thread(new Runnable() {
  4. @Override
  5. public void run() {
  6. try {
  7. //Innput reader and channel/
  8. DataInputStream sockInput = new DataInputStream(socket.getInputStream());
  9. ReadableByteChannel readChannel = Channels.newChannel(sockInput);
  10. while (true) {
  11. // see if any message has been received//
  12. ByteBuffer bufferA = ByteBuffer.allocate(10000000);
  13.  
  14. @SuppressWarnings("unused")
  15. int count = 0;
  16.  
  17. //empty message//
  18. String message = "";
  19.  
  20. //Read bytes//
  21. while ((count = readChannel.read(bufferA)) > 0) {
  22. // flip the byte buffer to start reading//
  23. bufferA.flip();
  24. //decode bytes and add each char-construct message//
  25. message += Charset.defaultCharset().decode(bufferA);
  26.  
  27. }
  28. //check if message had data//
  29. if (message.length() > 0 && !message.trim().isEmpty()) {
  30.  
  31. ///////////////////////////////////////
  32. //SERVER COMMANDS/////////////////////
  33.  
  34. //on login//
  35. if (message.trim().toLowerCase().startsWith("ok:")) {
  36. onConnectRcv(message);
  37. }
  38.  
  39. //on login fail//
  40. if (message.trim().toLowerCase().startsWith("denied:")) {
  41. onConnectFailRcv();
  42. }
  43.  
  44. //On init//
  45. if (message.trim().toLowerCase().contains("inited")) {
  46. onInitRcv(message);
  47. }
  48.  
  49. if (message.trim().toLowerCase().contains("bird")) {
  50. Server.passcommands("bird");
  51. }
  52.  
  53. //message//
  54. if (message.trim().toLowerCase().startsWith("b:")) {
  55. String clean = cleanMSG(message);
  56. String sender = getSender(message);
  57. // Bot.print("[Room message] "+sender+" : "+clean);
  58. test.append(sender + " : " + clean +"\n");
  59. //System.out.println("[Room message] " + sender + " : " + clean);
  60. checkCmd(clean, sender);
  61. }
  62.  
  63. //System.out.println("[Room] Room debug : "+message);
  64. //com.cavariux.twitchirc.Bot.print("[Room] Room debug : "+message);
  65.  
  66. //Reset message//
  67. message = "";
  68. if (!socket.getKeepAlive()) {
  69. socket.close();
  70. break;
  71. }
  72. }
  73. }
  74. }catch (SocketException e) {
  75. System.out.println("Fuked up socket");
  76. } catch (IOException e) {
  77. e.printStackTrace();
  78. }
  79. //System.out.println("did it");
  80. }
  81.  
  82.  
  83. });
  84. readThread.start();
  85. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement