brut_force.go

package main

import (
	"bytes"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
	"strings"
	"time"
)

func checkResponse(res string) bool {
	var ret bool = false
	if strings.Contains(res, _response) {
		ret = true
	}
	if _not {
		return !ret
	}
	return ret
}

func brutForcePOST() {
	start := time.Now()
	queue := make(chan bool, _concurrencyLevel)
	var index int64

	scanner := getFile(_wordlistFile)
	for scanner.Scan() {
		queue <- true
		go func(value string) {
			defer func() { <-queue }()

			if err := scanner.Err(); err != nil { // check scan file
				log.Fatal(err)
			}

			if index >= _limit && _limit > -1 { // check limit
				fmt.Printf("Limit: %d\n", _limit)
				log.Printf("Took %s", time.Since(start))
				os.Exit(0)
			}

			// set payload and request
			var stringPayload string = fmt.Sprintf("{\"%s\":\"%s\"}", _payload, value)
			if _generalPayload != "" {
				stringPayload = fmt.Sprintf("{\"%s\":\"%s\", %s}", _payload, value, _generalPayload)
			}
			payload := []byte(stringPayload)
			buffer := bytes.NewBuffer(payload)
			resp, err := http.Post(_url, "application/json", buffer)
			if err != nil {
				log.Fatalf("An Error Occured %v", err)
			}
			defer resp.Body.Close()

			//Read the response body
			body, err := ioutil.ReadAll(resp.Body)
			if err != nil {
				log.Fatalln(err)
			}
			fmt.Printf("\nTest n°%d\t|\tpayload: %v\t|\tresponse: %v\n", index, string(payload), string(body))
			if checkResponse(string(body)) {
				log.Printf("Took %s", time.Since(start))
				os.Exit(0)
			}
			index++
		}(scanner.Text())
	}
	for i := 0; i < int(_concurrencyLevel); i++ {
		queue <- true
	}
	log.Printf("Took %s", time.Since(start))
}

func brutForceGET() {

}

func brutForcePUT() {

}

func brutForcePATCH() {

}

func brutForceDELETE() {

}