sendMethods.go

package main

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"sort"
	"strconv"
	"strings"
	"time"

	"github.com/Liza-Developer/mcapi2"
)

var (
	sends       []time.Time
	recvs       []time.Time
	statuscodes []string
	email       []string
)

func sendAuto(option string, delay float64) {
	leng := 0
	delays, _ := strconv.Atoi(config[`Config`].([]interface{})[0].(string))
	for _, name := range names {

		if useAuto {
			delay = AutoOffset(false)
		}

		if bearers.Bearers == nil || len(bearers.Bearers) == 0 {
			fmt.Println("Attempting to reauth accounts..")
			authAccs()
		}

		dropTime := mcapi2.DropTime(name)

		fmt.Printf("    Name: %v\n   Delay: %v\nDroptime: %v\n\n", name, delay, dropTime)

		mcapi2.PreSleep(dropTime)

		payload := bearers.CreatePayloads(name)

		mcapi2.Sleep(dropTime, delay)

		fmt.Println()

		for f, accType := range bearers.AccountType {
			switch accType {
			case "Giftcard":
				leng = 6
			case "Microsoft":
				leng = 2
			}

			for i := 0; i < leng; {
				go func() {
					send, recv, status := payload.SocketSending(int64(f))
					sends = append(sends, send)
					recvs = append(recvs, recv)
					statuscodes = append(statuscodes, status)
				}()
				i++
				time.Sleep(time.Duration(delays) * time.Microsecond)
			}
			email = append(email, strings.Split(AccountsVer[f], ":")[0])
		}

		time.Sleep(500 * time.Millisecond)

		sort.Slice(sends, func(i, j int) bool {
			return sends[i].Before(sends[j])
		})

		for i, accountType := range payload.AccountType {

			switch accountType {
			case "Giftcard":
				leng = 6
			case "Microsoft":
				leng = 2
			}

			for f := 0; f < leng; {
				if statuscodes[f] != "200" {
					content += fmt.Sprintf("- [%v] Sent @ %v | Recv @ %v\n", statuscodes[f], formatTime(sends[f]), formatTime(recvs[f]))
					fmt.Printf("[%v] Sent @ %v | Recv @ %v\n", statuscodes[f], formatTime(sends[f]), formatTime(recvs[f]))
				} else {
					time.Sleep(500 * time.Millisecond)

					bearerGot, emailGot, got := check(statuscodes[f], name, fmt.Sprintf("%v", dropTime))

					content += fmt.Sprintf("+ [%v] Succesfully sniped %v | %v\n", statuscodes[f], name, emailGot)
					fmt.Printf("[%v] Recv @ %v | %v\n", statuscodes[f], formatTime(recvs[f]), strings.Split(emailGot, ":")[0])

					if got {
						fmt.Println("[204] Sent Webhook")
					} else {
						fmt.Println("[FAILED] Couldnt send webhook.")
					}

					req, err := sendInfo.ChangeSkin(jsonValue(skinUrls{Url: sendInfo.SkinUrl, Varient: "slim"}), bearerGot)
					if err != nil {
						log.Println(err)
					} else {
						if req.StatusCode == 200 {
							fmt.Println("[200] Changed Skin")
						} else if req.StatusCode == 400 {
							fmt.Println("[400] Used wrong bearer during Skin Change. (acc is giftcard :skull:)")
						} else {
							fmt.Println("[401] Unauthorized")
						}
					}

					bearers.Bearers = remove(bearers.Bearers, bearers.Bearers[i])
					bearers.AccountType = remove(bearers.AccountType, bearers.AccountType[i])
					payload.Payload = remove(payload.Payload, payload.Payload[i])
				}
				f++
			}
		}

		content = `
+    __  ______________ _   __
-   /  |/  / ____/ ___// | / /
+  / /|_/ / /    \__ \/  |/ / 
- / /  / / /___ ___/ / /|  /  
+/_/  /_/\____//____/_/ |_/

`

	}
}

func singlesniper(name string, delay float64) {
	var leng int
	delays, _ := strconv.Atoi(config[`Config`].([]interface{})[0].(string))
	dropTime = mcapi2.DropTime(name)

	fmt.Printf(`    Name: %v
   Delay: %v
Droptime: %v

`, name, delay, formatTime(time.Unix(dropTime, 0)))

	mcapi2.PreSleep(dropTime)

	payload := bearers.CreatePayloads(name)

	mcapi2.Sleep(dropTime, delay)

	fmt.Println()

	for f, accType := range bearers.AccountType {
		switch accType {
		case "Giftcard":
			leng = 6
		case "Microsoft":
			leng = 2
		}

		for i := 0; i < leng; {
			go func() {
				send, recv, status := payload.SocketSending(int64(f))
				sends = append(sends, send)
				recvs = append(recvs, recv)
				statuscodes = append(statuscodes, status)
			}()
			i++
			time.Sleep(time.Duration(delays) * time.Microsecond)
		}
		email = append(email, strings.Split(AccountsVer[f], ":")[0])
	}

	time.Sleep(500 * time.Millisecond)

	sort.Slice(sends, func(i, j int) bool {
		return sends[i].Before(sends[j])
	})

	var num int

	for _, accountType := range payload.AccountType {

		switch accountType {
		case "Giftcard":
			leng = 6
		case "Microsoft":
			leng = 2
		}

		for f := 0; f < leng; {
			if statuscodes[f] != "200" {
				content += fmt.Sprintf("- [%v] Sent @ %v | Recv @ %v\n", statuscodes[num], formatTime(sends[num]), formatTime(recvs[num]))
				fmt.Printf("[%v] Sent @ %v | Recv @ %v\n", statuscodes[num], formatTime(sends[num]), formatTime(recvs[num]))
				num++
			} else {
				time.Sleep(500 * time.Millisecond)

				bearerGot, emailGot, got := check(statuscodes[f], name, fmt.Sprintf("%v", dropTime))

				content += fmt.Sprintf("+ [%v] Succesfully sniped %v | %v\n", statuscodes[num], name, strings.Split(emailGot, ":")[0])
				fmt.Printf("[%v] Recv @ %v | %v\n", statuscodes[num], formatTime(recvs[num]), strings.Split(emailGot, ":")[0])

				if got {
					fmt.Println("[204] Sent Webhook")
				} else {
					fmt.Println("[FAILED] Couldnt send webhook.")
				}

				req, err := sendInfo.ChangeSkin(jsonValue(skinUrls{Url: sendInfo.SkinUrl, Varient: "slim"}), bearerGot)
				if err != nil {
					log.Println(err)
				} else {
					if req.StatusCode == 200 {
						fmt.Println("[200] Changed Skin")
					} else if req.StatusCode == 400 {
						fmt.Println("[400] Used wrong bearer during Skin Change. (acc is giftcard :skull:)")
					} else {
						fmt.Println("[401] Unauthorized")
					}
				}

				break
			}
			f++
		}
	}

	time.Sleep(time.Second * 3)
}

func searches(name string) float64 {
	var searches float64
	req, _ := http.NewRequest("GET", "https://droptime.site/api/v2/searches/"+name, nil)

	resp, _ := http.DefaultClient.Do(req)

	if resp.StatusCode != 200 {
		searches = 0
	} else {
		body, _ := ioutil.ReadAll(resp.Body)

		var config map[string]interface{}

		json.Unmarshal(body, &config)

		searches = config["searches"].(float64)
	}

	return searches
}