57 lines
2.0 KiB
Java
57 lines
2.0 KiB
Java
package de.mrbesen.telegram;
|
|
|
|
import com.sun.net.httpserver.HttpExchange;
|
|
import com.sun.net.httpserver.HttpHandler;
|
|
import com.sun.net.httpserver.HttpServer;
|
|
import org.json.JSONObject;
|
|
|
|
import java.io.IOException;
|
|
import java.net.InetSocketAddress;
|
|
import java.nio.charset.Charset;
|
|
import java.util.Random;
|
|
|
|
//for https server: https://stackoverflow.com/questions/2308479/simple-java-https-server
|
|
//for jks store: https://stackoverflow.com/questions/2138940/import-pem-into-java-key-store
|
|
public class WebhookTelegramAPI extends TelegramAPI implements HttpHandler {
|
|
|
|
private int port = 8000;
|
|
private String pw = "supersecret";
|
|
|
|
public void main() throws Exception {
|
|
try {
|
|
HttpServer server = HttpServer.create(new InetSocketAddress(8000), 0);
|
|
server.createContext("/" + pw , this);
|
|
server.setExecutor(null); // creates a default executor
|
|
server.start();
|
|
start = System.currentTimeMillis();
|
|
} catch (Exception exception) {
|
|
System.out.println("Failed to create HTTPS server on port " + port + " of localhost");
|
|
exception.printStackTrace();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void handle(HttpExchange req) throws IOException {
|
|
req.sendResponseHeaders(200,0);
|
|
String data = readfromIS(req.getRequestBody());
|
|
TelegramAPIUpdate upd = new TelegramAPIUpdate(new JSONObject(data), this);
|
|
++fetchedUpdates;
|
|
}
|
|
|
|
public WebhookTelegramAPI(String apikey, String externaladdr, String allowedupd) throws IOException {
|
|
super(apikey);
|
|
byte[] array = new byte[16]; // length is bounded by 7
|
|
new Random().nextBytes(array);
|
|
pw = new String(array, Charset.forName("UTF-8"));
|
|
if(externaladdr.endsWith("/"))
|
|
externaladdr = externaladdr.substring(0, externaladdr.length()-1);
|
|
|
|
request("setWebhook", "url=" + externaladdr + "/" + pw + "&allowed_updates=" + allowedupd, 0);
|
|
}
|
|
|
|
public WebhookTelegramAPI(String apikey, String externaladdr) throws IOException {
|
|
this(apikey, externaladdr, "[\"message\",\"edited_message\",\"channel_post\",\"edited_channel_post\",\"inline_query\",\"chosen_inline_result\",\"callback_query\",\"shipping_query\",\"pre_checkout_query\"]");
|
|
}
|
|
|
|
}
|