Compare commits
No commits in common. "main" and "ImplDiscordStuff" have entirely different histories.
main
...
ImplDiscor
@ -3,7 +3,6 @@ token = ""
|
|||||||
appid = ""
|
appid = ""
|
||||||
guildid = ""
|
guildid = ""
|
||||||
category_id = ""
|
category_id = ""
|
||||||
admin_roles = [""]
|
|
||||||
|
|
||||||
[database]
|
[database]
|
||||||
host = ""
|
host = ""
|
||||||
@ -12,4 +11,4 @@ name = ""
|
|||||||
username = ""
|
username = ""
|
||||||
password = ""
|
password = ""
|
||||||
|
|
||||||
|
admin_roles = [""]
|
||||||
|
402
main.go
402
main.go
@ -1,36 +1,19 @@
|
|||||||
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
|
||||||
@ -38,16 +21,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 {
|
||||||
@ -122,14 +105,15 @@ 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.GlobalName != "" {
|
} else if member.User != nil && member.User.Username != "" {
|
||||||
userName = member.User.GlobalName
|
|
||||||
} else {
|
|
||||||
userName = member.User.Username
|
userName = member.User.Username
|
||||||
|
} else {
|
||||||
|
userName = "UnknownUser"
|
||||||
}
|
}
|
||||||
return userName
|
return userName
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
var (
|
var (
|
||||||
commands = []discordgo.ApplicationCommand{
|
commands = []discordgo.ApplicationCommand{
|
||||||
{
|
{
|
||||||
@ -144,66 +128,9 @@ 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:",
|
||||||
@ -233,14 +160,7 @@ 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{
|
||||||
@ -304,31 +224,15 @@ 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,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
@ -337,14 +241,8 @@ var (
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, roleID := range config.Discord.AdminRoles {
|
for _, roleID := range config.AdminRoles {
|
||||||
if roleID != "" {
|
client.ChannelPermissionSet(channel.ID, roleID, discordgo.PermissionOverwriteTypeRole, discordgo.PermissionViewChannel, 0)
|
||||||
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{
|
||||||
@ -360,19 +258,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", userID, softwareType),
|
Content: fmt.Sprintf("Reset request by %s for %s", userName, 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_%d", userID, softwareType, userUID),
|
CustomID: fmt.Sprintf("accept_%s_%s", userID, softwareType),
|
||||||
},
|
},
|
||||||
discordgo.Button{
|
discordgo.Button{
|
||||||
Label: "Decline",
|
Label: "Decline",
|
||||||
Style: discordgo.DangerButton,
|
Style: discordgo.DangerButton,
|
||||||
CustomID: fmt.Sprintf("decline_%s_%s_%d", userID, softwareType, userUID),
|
CustomID: fmt.Sprintf("decline_%s_%s", userID, softwareType),
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
@ -386,13 +284,12 @@ 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) != 4 {
|
if len(parts) != 3 {
|
||||||
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 {
|
||||||
@ -402,23 +299,6 @@ 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,
|
||||||
@ -451,7 +331,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) != 4 {
|
if len(parts) != 3 {
|
||||||
log.Println("Invalid decline button custom ID")
|
log.Println("Invalid decline button custom ID")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -487,122 +367,6 @@ 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 {
|
||||||
@ -622,127 +386,6 @@ 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")
|
||||||
@ -798,3 +441,4 @@ func main() {
|
|||||||
db.Close()
|
db.Close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user