quests.go

package main

import (
	"bytes"
	"fmt"
	"net/http"
	"strconv"
	"strings"
	"time"

	"github.com/anonutopia/gowaves"
)

type QuestsService struct {
}

func (qs *QuestsService) start() {
	for {
		qs.checkQuests()
		time.Sleep(time.Second * 5)
	}
}

func (qs *QuestsService) isFbLinkValid(link string) bool {
	if !strings.Contains(link, "https://www.facebook.com/") &&
		!strings.Contains(link, "https://m.facebook.com/") &&
		!strings.Contains(link, "https://free.facebook.com/") &&
		!strings.Contains(link, "https://l.facebook.com/") &&
		!strings.Contains(link, "https://lm.facebook.com/") &&
		!strings.Contains(link, "https://mobile.facebook.com/") &&
		!strings.Contains(link, "https://facebook.com/") &&
		!strings.Contains(link, "https://web.facebook.com/") {

		if strings.Contains(link, "facebook") {
			logTelegram(fmt.Sprintf("[quests.go - 34] link: %s", link))
		}

		return false
	}

	if r, err := http.Get(link); err != nil {
		logTelegram("[quests.go - 29]" + err.Error())
		return false
	} else {
		buf := new(bytes.Buffer)
		buf.ReadFrom(r.Body)
		body := buf.String()
		if (!strings.Contains(body, "Anote") && !strings.Contains(body, "Anotu")) ||
			!strings.Contains(body, "anonutopia.com") ||
			(!strings.Contains(body, "Follow") && !strings.Contains(body, "preuzeti")) {

			return false
		}
	}

	return true
}

func (qs *QuestsService) isTwLinkValid(link string) bool {
	parts := strings.Split(link, "/")

	if !strings.HasPrefix(link, "https://www.twitter.com/") &&
		!strings.HasPrefix(link, "https://mobile.twitter.com/") &&
		!strings.HasPrefix(link, "https://twitter.com/") {

		if strings.Contains(link, "twitter") {
			logTelegram(fmt.Sprintf("[quests.go - 64] link: %s", link))
		}

		return false
	}

	if len(parts) != 6 {
		return false
	}

	if id, err := strconv.Atoi(parts[len(parts)-1]); err != nil {
		return id > 0
	}

	return true
}

func (qs *QuestsService) createQuest(u *User, link string) {
	u.FbPostLink = link
	now := time.Now()
	u.LastFbQuest = &now
	if !u.SentAint {
		u.MinedAnotes += 10 * int(satInBtc)
		messageTelegram(tr(u.TelegramID, "fbQuestAnotesAdded"), int64(u.TelegramID))
		u.SentFbAnotes = true
	} else {
		u.SentFbAnotes = false
	}
	db.Save(u)
}

func (qs *QuestsService) createQuestTw(u *User, link string) {
	u.TwPostLink = link
	now := time.Now()
	u.LastTwQuest = &now
	if !u.SentAint {
		u.MinedAnotes += 10 * int(satInBtc)
		messageTelegram(tr(u.TelegramID, "twQuestAnotesAdded"), int64(u.TelegramID))
		u.SentTwAnotes = true
	} else {
		u.SentTwAnotes = false
	}
	db.Save(u)
}

func (qs *QuestsService) isQuestAvailable(u *User) bool {
	if u.LastFbQuest != nil &&
		time.Since(*u.LastFbQuest) < time.Duration(time.Hour*24*7) {
		return false
	}

	return true
}

func (qs *QuestsService) isQuestAvailableTw(u *User) bool {
	if u.LastTwQuest != nil &&
		time.Since(*u.LastTwQuest) < time.Duration(time.Hour*24*7) {
		return false
	}

	return true
}

func (qs *QuestsService) checkQuests() {
	var users []*User

	first := time.Now().Add(time.Hour * -15)
	second := time.Now().Add(time.Hour * -12)

	db.Where("sent_aint = false AND last_fb_quest BETWEEN ? AND ?", first, second).Find(&users)

	for _, u := range users {
		if !u.SentAint {
			qs.sendAint(u)
			u.SentAint = true
			db.Save(u)
			messageTelegram(tr(u.TelegramID, "fbQuestAintSent"), int64(u.TelegramID))
		}
	}

	db.Where("sent_fb_anotes = false AND last_fb_quest BETWEEN ? AND ?", first, second).Find(&users)

	for _, u := range users {
		if u.SentAint {
			u.MinedAnotes += 10 * int(satInBtc)
			u.SentFbAnotes = true
			db.Save(u)
			messageTelegram(tr(u.TelegramID, "fbQuestAnotesAdded2"), int64(u.TelegramID))
		}
	}

	db.Where("sent_aint = false AND last_tw_quest BETWEEN ? AND ?", first, second).Find(&users)

	for _, u := range users {
		if !u.SentAint {
			qs.sendAint(u)
			u.SentAint = true
			db.Save(u)
			messageTelegram(tr(u.TelegramID, "twQuestAintSent"), int64(u.TelegramID))
		}
	}

	db.Where("sent_tw_anotes = false AND last_tw_quest BETWEEN ? AND ?", first, second).Find(&users)

	for _, u := range users {
		if u.SentAint {
			u.MinedAnotes += 10 * int(satInBtc)
			u.SentTwAnotes = true
			db.Save(u)
			messageTelegram(tr(u.TelegramID, "twQuestAnotesAdded2"), int64(u.TelegramID))
		}
	}
}

func (qs *QuestsService) sendAint(u *User) {
	atr := &gowaves.AssetsTransferRequest{
		Amount:    1,
		AssetID:   conf.AintID,
		Fee:       100000,
		Recipient: u.Address,
		Sender:    conf.NodeAddress,
	}

	if _, err := wnc.AssetsTransfer(atr); err != nil {
		logTelegram("[quests.go - 107]" + err.Error())
	}
}

func initQuestsService() *QuestsService {
	qs := &QuestsService{}
	go qs.start()
	return qs
}