main.go

package main

import (
	"fmt"
	C "muhammedkpln/fedai/core"
	S "muhammedkpln/fedai/shared"

	_ "github.com/mattn/go-sqlite3"
	"go.mau.fi/whatsmeow/types"

	"go.mau.fi/whatsmeow/types/events"
)

func CommandCatcher(message string) (*S.Plugin, S.RegexpMatches) {
	var pl *S.Plugin
	var foundMatches S.RegexpMatches
	for _, plugin := range C.LoadedPlugins {
		var matches = plugin.CommandRegex.FindStringSubmatch(message)

		if len(matches) > 0 {
			if len(matches) <= 1 {
				pl = &plugin
				foundMatches = S.RegexpMatches{
					Match: matches[0],
				}
			} else if len(matches) > 1 && len(matches) == 3 {
				pl = &plugin
				foundMatches = S.RegexpMatches{
					Match:   matches[0],
					Action:  &matches[1],
					Payload: &matches[2],
				}
			}

		}

		// if len(matches) > 0 {
		// 	pl = &plugin
		// 	foundMatches = matches
		// 	break
		// }
	}

	if pl != nil {
		return pl, foundMatches
	}

	return pl, foundMatches
}

func handleMessageEvent(message *events.Message) {
	// set as unavailable to not see(?) the message
	go C.GetClient().SendChatPresence(message.Info.Chat, "unavailable", types.ChatPresenceMediaText)
	var m = message.Message.ExtendedTextMessage
	var textMessage = message.Message.GetConversation()

	// Catch only messages
	if message.Message.Conversation != nil || m != nil {
		var ci = m.GetContextInfo()

		var context S.PluginRunOptions = S.PluginRunOptions{
			IsQuoted:  false,
			Message:   message,
			ChatJID:   message.Info.Chat,
			SenderJID: message.Info.Sender,
			StanzaID:  message.Info.ID,
		}

		// Checks if message has context, which can mean that it has a quoted message.
		if ci != nil {
			quotedMessage := ci.QuotedMessage
			if quotedMessage != nil {
				context = S.PluginRunOptions{
					IsQuoted:      true,
					QuotedMessage: quotedMessage,
					Message:       message,
					ChatJID:       message.Info.Chat,
					SenderJID:     message.Info.Sender,
					StanzaID:      message.Info.ID,
				}
			}

		}

		textMessageWrapper := S.If(m != nil, *m.Text, textMessage)

		pl, matches := CommandCatcher(textMessageWrapper)
		if pl != nil {
			fmt.Println(context.SenderJID, C.GetClient().Store.ID)
			// fmt.Println(bool(*pl.IsPublic))

			if pl.IsPublic == nil {
				if message.Info.Sender.ToNonAD() != C.GetClient().Store.ID.ToNonAD() {
					// Plugin is not allowed to be used of other users, return
					return
				}

			}
			fmt.Println("selam")
			go pl.CommandFn(&context, matches)

		}
	}

}

func eventHandler(evt interface{}) {
	switch v := evt.(type) {
	case *events.Message:
		go handleMessageEvent(v)

	case *events.Connected:
		C.AppLog().Infof("Connection established")

	}
}

func main() {
	C.LoadDotenv()
	C.LoadDatabase()
	C.LoadModules()
	C.AppLog().Infof("Modules loaded")
	C.AppLog().Infof("Database loaded")
	C.EstablishConnection(eventHandler)
}