compatible with new version of telegramAPI
This commit is contained in:
parent
5519ab072d
commit
1874c2bec4
|
@ -16,6 +16,7 @@ import de.mrbesen.telegram.event.EventHandler;
|
|||
import de.mrbesen.telegram.event.EventListener;
|
||||
import de.mrbesen.telegram.event.events.UserSendMessageEvent;
|
||||
import de.mrbesen.telegram.log.Log4JLog;
|
||||
import de.mrbesen.telegram.objects.TMessage;
|
||||
import de.mrbesen.telegram.objects.TUser;
|
||||
|
||||
public class Main implements JSONCommandHandler, EventListener{
|
||||
|
@ -158,26 +159,13 @@ public class Main implements JSONCommandHandler, EventListener{
|
|||
}
|
||||
|
||||
@Override
|
||||
public boolean onCommand(TUser sender, String cmd, String[] args) {
|
||||
//unused
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean onCommand(TUser sender, String cmd, String[] args, JSONObject j) {
|
||||
public boolean onCommand(TUser sender, String cmd, String[] args, TMessage json) {
|
||||
if(cmd.startsWith("random")) {
|
||||
String ytid = cra.getDB().getRandom();
|
||||
int chatid = 0;
|
||||
try {
|
||||
//log.debug(j.toString());
|
||||
chatid = j.getJSONObject("chat").getInt("id");
|
||||
} catch(Throwable t) { t.printStackTrace(); }
|
||||
//log.info("chatid: " + chatid);
|
||||
if(chatid != 0) {
|
||||
tapi.sendMessage(new MessageBuilder().setText("https://youtube.com/watch?v=" + ytid).setReciver(chatid).build());
|
||||
} else {
|
||||
sender.sendMessage("https://youtube.com/watch?v=" + ytid);
|
||||
}
|
||||
int chatid = json.getChatID();
|
||||
|
||||
tapi.sendMessage(new MessageBuilder().setAsync().setText("https://youtube.com/watch?v=" + ytid).setReciver(chatid).build());
|
||||
|
||||
return true;
|
||||
} else if(cmd.equals("admin")) {
|
||||
if(admins.contains(sender.getName())) {
|
||||
|
@ -250,4 +238,6 @@ public class Main implements JSONCommandHandler, EventListener{
|
|||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
|
@ -20,7 +20,7 @@ public class Server implements Runnable {
|
|||
public Server(DB d) {
|
||||
db = d;
|
||||
}
|
||||
|
||||
|
||||
void start() {
|
||||
run = true;
|
||||
t = new Thread(this, "Server");
|
||||
|
@ -35,21 +35,21 @@ public class Server implements Runnable {
|
|||
public void run() {
|
||||
try {
|
||||
final int port = 2419;
|
||||
ssoc = new ServerSocket(port, -1, InetAddress.getByName("::1"));
|
||||
ssoc = new ServerSocket(port, -1);
|
||||
//ssoc.bind(new InetSocketAddress(, port));
|
||||
ssoc.setSoTimeout(5);
|
||||
log.info("opened Server at port " + port);
|
||||
while(run) {
|
||||
try {
|
||||
Socket client = ssoc.accept();
|
||||
if(client.getInetAddress().isLoopbackAddress()) {
|
||||
PrintWriter out = new PrintWriter(client.getOutputStream());
|
||||
out.println(db.getRandom());
|
||||
out.flush();
|
||||
out.close();
|
||||
} else {
|
||||
//if(client.getInetAddress().isLoopbackAddress()) {
|
||||
PrintWriter out = new PrintWriter(client.getOutputStream());
|
||||
out.println(db.getRandom());
|
||||
out.flush();
|
||||
out.close();
|
||||
/*} else {
|
||||
log.info("client connected: " + client.getInetAddress().toString());
|
||||
}
|
||||
}*/
|
||||
client.close();
|
||||
} catch(SocketTimeoutException ignored) {}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue