Compare commits

...

16 Commits

2 changed files with 383 additions and 26 deletions

View File

@ -3,6 +3,7 @@ token = ""
appid = "" appid = ""
guildid = "" guildid = ""
category_id = "" category_id = ""
admin_roles = [""]
[database] [database]
host = "" host = ""
@ -11,4 +12,4 @@ name = ""
username = "" username = ""
password = "" password = ""
admin_roles = [""]

402
main.go
View File

@ -1,19 +1,36 @@
package main package main
import ( import (
"bytes"
"database/sql" "database/sql"
"encoding/json"
"fmt" "fmt"
"log" "log"
"mime/multipart"
"net/http"
"os" "os"
"os/signal" "os/signal"
"strconv"
"strings" "strings"
"syscall" "syscall"
"time"
"github.com/BurntSushi/toml" "github.com/BurntSushi/toml"
"github.com/bwmarrin/discordgo" "github.com/bwmarrin/discordgo"
_ "github.com/lib/pq" "github.com/lib/pq"
) )
type UserResponse struct {
ID string `json:"id"`
Username string `json:"username"`
Subscription bool `json:"subscription"`
Group string `json:"group"`
Expiration string `json:"expiration"`
Versions []string `json:"versions"`
PFP string `json:"pfp"`
Message int `json:"message"`
}
var ( var (
config Config config Config
client *discordgo.Session client *discordgo.Session
@ -21,16 +38,16 @@ var (
) )
type Config struct { type Config struct {
Discord Discord `toml:"discord"` Discord Discord `toml:"discord"`
Database Database `toml:"database"` Database Database `toml:"database"`
AdminRoles []string `toml:"admin_roles"`
} }
type Discord struct { type Discord struct {
Token string `toml:"token"` Token string `toml:"token"`
AppID string `toml:"appid"` AppID string `toml:"appid"`
GuildID string `toml:"guildid"` GuildID string `toml:"guildid"`
CategoryID string `toml:"category_id"` CategoryID string `toml:"category_id"`
AdminRoles []string `toml:"admin_roles"`
} }
type Database struct { type Database struct {
@ -105,15 +122,14 @@ func getUsernameFromMember(member *discordgo.Member) string {
var userName string var userName string
if member.Nick != "" { if member.Nick != "" {
userName = member.Nick userName = member.Nick
} else if member.User != nil && member.User.Username != "" { } else if member.User.GlobalName != "" {
userName = member.User.Username userName = member.User.GlobalName
} else { } else {
userName = "UnknownUser" userName = member.User.Username
} }
return userName return userName
} }
var ( var (
commands = []discordgo.ApplicationCommand{ commands = []discordgo.ApplicationCommand{
{ {
@ -128,9 +144,66 @@ var (
}, },
}, },
}, },
{
Name: "resetvanity",
Description: "Reset a user's HWID for Vanity by username or UID",
Options: []*discordgo.ApplicationCommandOption{
{
Type: discordgo.ApplicationCommandOptionString,
Name: "identifier",
Description: "Usernames or UIDs, separated by commas",
Required: true,
},
},
},
{
Name: "resetmesa",
Description: "Reset a user's HWID for Mesa by username or UID",
Options: []*discordgo.ApplicationCommandOption{
{
Type: discordgo.ApplicationCommandOptionString,
Name: "identifier",
Description: "Usernames or UIDs, separated by commas",
Required: true,
},
},
},
} }
commandsHandlers = map[string]func(client *discordgo.Session, i *discordgo.InteractionCreate){ commandsHandlers = map[string]func(client *discordgo.Session, i *discordgo.InteractionCreate){
"setup": func(client *discordgo.Session, i *discordgo.InteractionCreate) { "setup": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
hasAdminPermission := false
for _, roleID := range config.Discord.AdminRoles {
member, err := client.GuildMember(i.GuildID, i.Member.User.ID)
if err != nil {
log.Println("Error fetching member info:", err)
return
}
for _, role := range member.Roles {
if role == roleID {
hasAdminPermission = true
break
}
}
if hasAdminPermission {
break
}
}
if !hasAdminPermission {
err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource,
Data: &discordgo.InteractionResponseData{
Content: "You do not have permission to run this command.",
Flags: discordgo.MessageFlagsEphemeral,
},
})
if err != nil {
log.Println("Error sending interaction response:", err)
}
return
}
channelOption := i.ApplicationCommandData().Options[0].ChannelValue(client) channelOption := i.ApplicationCommandData().Options[0].ChannelValue(client)
_, err := client.ChannelMessageSendComplex(channelOption.ID, &discordgo.MessageSend{ _, err := client.ChannelMessageSendComplex(channelOption.ID, &discordgo.MessageSend{
Content: "Click the button below to request a HWID reset:", Content: "Click the button below to request a HWID reset:",
@ -160,7 +233,14 @@ var (
log.Println("Error sending interaction response:", err) log.Println("Error sending interaction response:", err)
} }
}, },
"resetvanity": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
resetCommandHandler(client, i, "vanity")
},
"resetmesa": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
resetCommandHandler(client, i, "mesa")
},
} }
componentsHandlers = map[string]func(client *discordgo.Session, i *discordgo.InteractionCreate){ componentsHandlers = map[string]func(client *discordgo.Session, i *discordgo.InteractionCreate){
"create_ticket": func(client *discordgo.Session, i *discordgo.InteractionCreate) { "create_ticket": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{ err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
@ -224,15 +304,31 @@ var (
return return
} }
_, baseUrl := getTableNameAndBaseURL(selectedOption)
userUID, _ := fetchUserID(userName, baseUrl)
if userUID == 0 {
err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource,
Data: &discordgo.InteractionResponseData{
Content: fmt.Sprintf("Account not found for %s", softwareType),
Flags: discordgo.MessageFlagsEphemeral,
},
})
if err != nil {
log.Println("Error sending interaction response:", err)
}
return
}
channel, err := client.GuildChannelCreateComplex(guildID, discordgo.GuildChannelCreateData{ channel, err := client.GuildChannelCreateComplex(guildID, discordgo.GuildChannelCreateData{
Name: fmt.Sprintf("reset-%s-%s", softwareType, userName), Name: fmt.Sprintf("reset-%s-%s", softwareType, userName),
Type: discordgo.ChannelTypeGuildText, Type: discordgo.ChannelTypeGuildText,
ParentID: categoryID, ParentID: categoryID,
PermissionOverwrites: []*discordgo.PermissionOverwrite{ PermissionOverwrites: []*discordgo.PermissionOverwrite{
{ {
ID: guildID, ID: guildID,
Type: discordgo.PermissionOverwriteTypeRole, Type: discordgo.PermissionOverwriteTypeRole,
Deny: discordgo.PermissionViewChannel, Deny: discordgo.PermissionViewChannel,
}, },
}, },
}) })
@ -241,8 +337,14 @@ var (
return return
} }
for _, roleID := range config.AdminRoles { for _, roleID := range config.Discord.AdminRoles {
client.ChannelPermissionSet(channel.ID, roleID, discordgo.PermissionOverwriteTypeRole, discordgo.PermissionViewChannel, 0) if roleID != "" {
err := client.ChannelPermissionSet(channel.ID, roleID, discordgo.PermissionOverwriteTypeRole, discordgo.PermissionViewChannel|discordgo.PermissionSendMessages, 0)
if err != nil {
log.Printf("Error setting permissions for role %s: %v", roleID, err)
}
}
} }
err = client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{ err = client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
@ -258,19 +360,19 @@ var (
} }
_, err = client.ChannelMessageSendComplex(channel.ID, &discordgo.MessageSend{ _, err = client.ChannelMessageSendComplex(channel.ID, &discordgo.MessageSend{
Content: fmt.Sprintf("Reset request by %s for %s", userName, softwareType), Content: fmt.Sprintf("Reset request by <@%s> for %s", userID, softwareType),
Components: []discordgo.MessageComponent{ Components: []discordgo.MessageComponent{
discordgo.ActionsRow{ discordgo.ActionsRow{
Components: []discordgo.MessageComponent{ Components: []discordgo.MessageComponent{
discordgo.Button{ discordgo.Button{
Label: "Accept", Label: "Accept",
Style: discordgo.PrimaryButton, Style: discordgo.PrimaryButton,
CustomID: fmt.Sprintf("accept_%s_%s", userID, softwareType), CustomID: fmt.Sprintf("accept_%s_%s_%d", userID, softwareType, userUID),
}, },
discordgo.Button{ discordgo.Button{
Label: "Decline", Label: "Decline",
Style: discordgo.DangerButton, Style: discordgo.DangerButton,
CustomID: fmt.Sprintf("decline_%s_%s", userID, softwareType), CustomID: fmt.Sprintf("decline_%s_%s_%d", userID, softwareType, userUID),
}, },
}, },
}, },
@ -284,12 +386,13 @@ var (
"accept": func(client *discordgo.Session, i *discordgo.InteractionCreate) { "accept": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
data := i.MessageComponentData().CustomID data := i.MessageComponentData().CustomID
parts := strings.Split(data, "_") parts := strings.Split(data, "_")
if len(parts) != 3 { if len(parts) != 4 {
log.Println("Invalid accept button custom ID") log.Println("Invalid accept button custom ID")
return return
} }
userID := parts[1] userID := parts[1]
softwareType := parts[2] softwareType := parts[2]
userUID, _ := strconv.Atoi(parts[3])
member, err := client.GuildMember(i.GuildID, userID) member, err := client.GuildMember(i.GuildID, userID)
if err != nil { if err != nil {
@ -299,6 +402,23 @@ var (
userName := getUsernameFromMember(member) userName := getUsernameFromMember(member)
reset(userName, softwareType) reset(userName, softwareType)
tableName, _ := getTableNameAndBaseURL(strings.ToLower(softwareType))
successes, errors := resetAndVerify(tableName, []int{userUID})
if len(errors) > 0 {
for _, err := range errors {
log.Println("Error resetting hwid:", err)
}
} else {
for _, success := range successes {
if success {
log.Printf("Reset successful for UID %d", userUID)
} else {
log.Printf("Reset unsuccessful for UID %d", userUID)
}
}
}
log.Printf("Reset the HWID of user %s with UID %d for %s", userName, userUID, softwareType)
err = client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{ err = client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource, Type: discordgo.InteractionResponseChannelMessageWithSource,
@ -331,7 +451,7 @@ var (
"decline": func(client *discordgo.Session, i *discordgo.InteractionCreate) { "decline": func(client *discordgo.Session, i *discordgo.InteractionCreate) {
data := i.MessageComponentData().CustomID data := i.MessageComponentData().CustomID
parts := strings.Split(data, "_") parts := strings.Split(data, "_")
if len(parts) != 3 { if len(parts) != 4 {
log.Println("Invalid decline button custom ID") log.Println("Invalid decline button custom ID")
return return
} }
@ -367,6 +487,122 @@ var (
} }
) )
func resetCommandHandler(client *discordgo.Session, i *discordgo.InteractionCreate, softwareType string) {
hasAdminPermission := false
var err error
var tableName string
for _, roleID := range config.Discord.AdminRoles {
member, err := client.GuildMember(i.GuildID, i.Member.User.ID)
if err != nil {
log.Println("Error fetching member info:", err)
return
}
for _, role := range member.Roles {
if role == roleID {
hasAdminPermission = true
break
}
}
if hasAdminPermission {
break
}
}
if !hasAdminPermission {
err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource,
Data: &discordgo.InteractionResponseData{
Content: "You do not have permission to run this command.",
Flags: discordgo.MessageFlagsEphemeral,
},
})
if err != nil {
log.Println("Error sending interaction response:", err)
}
return
}
identifier := i.ApplicationCommandData().Options[0].StringValue()
identifierList := strings.Split(identifier, ",")
var userUIDs []int
for _, identifier := range identifierList {
identifier = strings.TrimSpace(identifier)
var userName string
var userUID int
var err error
if uid, err := strconv.Atoi(identifier); err == nil {
userUID = uid
} else {
userName = identifier
}
if userName != "" {
_, baseURL := getTableNameAndBaseURL(softwareType)
userUID, err = fetchUserID(userName, baseURL)
if err != nil {
log.Println("Error fetching user ID:", err)
continue
}
}
if userUID != 0 {
userUIDs = append(userUIDs, userUID)
}
}
if len(userUIDs) == 0 {
err := client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource,
Data: &discordgo.InteractionResponseData{
Content: "No valid users found to reset.",
Flags: discordgo.MessageFlagsEphemeral,
},
})
if err != nil {
log.Println("Error sending interaction response:", err)
}
return
}
tableName, _ = getTableNameAndBaseURL(softwareType)
successes, errors := resetAndVerify(tableName, userUIDs)
if len(errors) > 0 {
for _, err := range errors {
log.Println("Error:", err)
}
} else {
for i, success := range successes {
if success {
log.Printf("Reset successful for UID %d", userUIDs[i])
} else {
log.Printf("Reset unsuccessful for UID %d", userUIDs[i])
}
}
}
for _, uid := range userUIDs {
log.Printf("Reset the HWID of user with UID %d for %s", uid, softwareType)
}
err = client.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
Type: discordgo.InteractionResponseChannelMessageWithSource,
Data: &discordgo.InteractionResponseData{
Content: fmt.Sprintf("Successfully reset HWID for %d users.", len(userUIDs)),
Flags: discordgo.MessageFlagsEphemeral,
},
})
if err != nil {
log.Println("Error sending interaction response:", err)
}
}
func canCreateTicket(userName, softwareType string) bool { func canCreateTicket(userName, softwareType string) bool {
guildChannels, err := client.GuildChannels(config.Discord.GuildID) guildChannels, err := client.GuildChannels(config.Discord.GuildID)
if err != nil { if err != nil {
@ -386,6 +622,127 @@ func canCreateTicket(userName, softwareType string) bool {
return true return true
} }
func getTableNameAndBaseURL(choice string) (string, string) {
var tableName, baseURL string
switch choice {
case "vanity":
tableName = "AuthUserData"
baseURL = "http://vanitycheats.xyz/UserAuthentication.php"
case "mesa":
tableName = "AuthUserData-Mesachanger.com"
baseURL = "http://mesachanger.com/UserAuthentication.php"
default:
fmt.Println("Invalid choice. Please choose 'vanity' or 'mesa'.")
}
return tableName, baseURL
}
func fetchUserID(username string, baseURL string) (int, error) {
requestBody := &bytes.Buffer{}
multiPartWriter := multipart.NewWriter(requestBody)
err := multiPartWriter.WriteField("username", username)
if err != nil {
return 0, fmt.Errorf("error adding username field: %w", err)
}
multiPartWriter.Close()
request, err := http.NewRequest("POST", baseURL, requestBody)
if err != nil {
return 0, fmt.Errorf("error creating request: %w", err)
}
request.Header.Set("Content-Type", multiPartWriter.FormDataContentType())
client := &http.Client{
Timeout: 10 * time.Second,
}
resp, err := client.Do(request)
if err != nil {
return 0, fmt.Errorf("error sending request: %w", err)
}
defer resp.Body.Close()
var userResp UserResponse
err = json.NewDecoder(resp.Body).Decode(&userResp)
if err != nil {
return 0, fmt.Errorf("error decoding JSON: %w", err)
}
uid, err := strconv.Atoi(userResp.ID)
if err != nil {
return 0, fmt.Errorf("error converting user ID: %w", err)
}
return uid, nil
}
func resetHWID(tableName string, uids []int) {
query := fmt.Sprintf(`UPDATE public.%q
SET "StorageIdentifier" = NULL, "BootIdentifier" = NULL
WHERE "UID" = ANY($1)`, tableName)
_, err := db.Exec(query, pq.Array(uids))
if err != nil {
log.Printf("Error resetting HWID: %v", err)
return
}
}
func resetAndVerify(tableName string, uids []int) ([]bool, []error) {
var successes []bool
var errorsSlice []error
rows, err := db.Query(fmt.Sprintf(`SELECT "UID", MD5(CONCAT("StorageIdentifier", "BootIdentifier")) FROM public.%q WHERE "UID" = ANY($1)`, tableName), pq.Array(uids))
if err != nil {
log.Printf("Error querying database for before hashes: %v", err)
return nil, []error{err}
}
defer rows.Close()
beforeHashesMap := make(map[int]string)
for rows.Next() {
var uid int
var beforeHash string
err := rows.Scan(&uid, &beforeHash)
if err != nil {
log.Printf("Error scanning rows: %v", err)
errorsSlice = append(errorsSlice, err)
continue
}
beforeHashesMap[uid] = beforeHash
}
resetHWID(tableName, uids)
rows, err = db.Query(fmt.Sprintf(`SELECT "UID", MD5(CONCAT("StorageIdentifier", "BootIdentifier")) FROM public.%q WHERE "UID" = ANY($1)`, tableName), pq.Array(uids))
if err != nil {
log.Printf("Error querying database for after hashes: %v", err)
return nil, []error{err}
}
defer rows.Close()
afterHashesMap := make(map[int]string)
for rows.Next() {
var uid int
var afterHash string
err := rows.Scan(&uid, &afterHash)
if err != nil {
log.Printf("Error scanning rows: %v", err)
errorsSlice = append(errorsSlice, err)
continue
}
afterHashesMap[uid] = afterHash
}
for _, uid := range uids {
afterHash, ok := afterHashesMap[uid]
if !ok {
errorsSlice = append(errorsSlice, fmt.Errorf("no rows found for UID %d after reset", uid))
successes = append(successes, false)
continue
}
successes = append(successes, beforeHashesMap[uid] != afterHash || afterHash == "d41d8cd98f00b204e9800998ecf8427e")
}
return successes, errorsSlice
}
func main() { func main() {
if client == nil { if client == nil {
log.Println("Bot client is not initialized") log.Println("Bot client is not initialized")
@ -441,4 +798,3 @@ func main() {
db.Close() db.Close()
} }
} }