1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
package main
import (
"encoding/json"
"fmt"
"log"
"net/http"
"os"
"os/signal"
"syscall"
"github.com/ketsuna-org/bot-creator-api/internal"
)
func init() {
// Initialize the application
}
func main() {
mux := http.NewServeMux()
// Start the application
mux.HandleFunc("GET /", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte("Hello, World!"))
})
botId := "xxxxx"
botToken := "xxxxx"
bot := &internal.Bot{
BotID: botId,
BotToken: botToken,
}
conn, err := internal.Start(bot)
if err != nil {
log.Fatalf("Error starting bot: %v", err)
}
defer conn.Close()
// Handle the bot connection
data, err := json.Marshal(map[string]interface{}{
"command": "update",
"data": map[string]interface{}{
"ping": map[string]string{
"response": "pong ((userName))",
},
},
})
if err != nil {
log.Fatalf("Error marshaling JSON: %v", err)
}
conn.Write(data)
// Handle if signal is received
signals := make(chan os.Signal, 1)
signal.Notify(signals, os.Interrupt)
signal.Notify(signals, syscall.SIGTERM)
go func() {
sig := <-signals
log.Printf("Received signal: %s", sig)
// let's kill the bot
if bot.Cmd != nil {
if err := bot.Cmd.Process.Kill(); err != nil {
log.Printf("Error killing bot process: %v", err)
} else {
log.Printf("Bot process killed successfully")
}
}
// let's remove the socket
socketPath := fmt.Sprintf("/tmp/%s.sock", bot.BotID)
if err := os.RemoveAll(socketPath); err != nil {
log.Printf("Error removing socket: %v", err)
} else {
log.Printf("Socket removed successfully")
}
os.Exit(0)
}()
panic(http.ListenAndServe(":2030", mux))
}
|
