001package com.github.theholywaffle.teamspeak3; 002 003/* 004 * #%L 005 * TeamSpeak 3 Java API 006 * %% 007 * Copyright (C) 2014 Bert De Geyter 008 * %% 009 * Permission is hereby granted, free of charge, to any person obtaining a copy 010 * of this software and associated documentation files (the "Software"), to deal 011 * in the Software without restriction, including without limitation the rights 012 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 013 * copies of the Software, and to permit persons to whom the Software is 014 * furnished to do so, subject to the following conditions: 015 * 016 * The above copyright notice and this permission notice shall be included in 017 * all copies or substantial portions of the Software. 018 * 019 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 020 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 021 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE 022 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 023 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 024 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 025 * THE SOFTWARE. 026 * #L% 027 */ 028 029import com.github.theholywaffle.teamspeak3.commands.Command; 030 031import java.io.IOException; 032import java.io.PrintStream; 033 034public class SocketWriter extends Thread { 035 036 private final QueryIO io; 037 private final int floodRate; 038 private final PrintStream out; 039 private volatile long lastCommand = System.currentTimeMillis(); 040 041 public SocketWriter(QueryIO io, int floodRate) throws IOException { 042 super("[TeamSpeak-3-Java-API] SocketWriter"); 043 this.io = io; 044 if (floodRate > 50) { 045 this.floodRate = floodRate; 046 } else { 047 this.floodRate = 50; 048 } 049 050 out = new PrintStream(io.getSocket().getOutputStream(), true, "UTF-8"); 051 } 052 053 @Override 054 public void run() { 055 while (!isInterrupted()) { 056 final Command c = io.getCommandQueue().peek(); 057 if (c != null && !c.isSent()) { 058 final String msg = c.toString(); 059 TS3Query.log.info("> " + msg); 060 061 c.setSent(); 062 out.println(msg); 063 lastCommand = System.currentTimeMillis(); 064 } 065 try { 066 Thread.sleep(floodRate); 067 } catch (final InterruptedException e) { 068 interrupt(); 069 break; 070 } 071 } 072 073 out.close(); 074 075 if (!isInterrupted()) { 076 TS3Query.log.warning("SocketWriter has stopped!"); 077 } 078 } 079 080 public long getIdleTime() { 081 return System.currentTimeMillis() - lastCommand; 082 } 083}