example.go

package main

import (
	"context"

	"github.com/tinkershack/wabot/config"
	"github.com/tinkershack/wabot/datastore"
	"github.com/tinkershack/wabot/logger"
	"github.com/tinkershack/wabot/wabot"
	"github.com/tinkershack/wabot/webhooks"

	"log/slog"

	"github.com/spf13/viper"
)

func main() {
	// Must satisfy config.Config fields
	viper.SetEnvPrefix("wabot") // will be uppercased automatically, e.g. WABOT_BASEURL
	viper.AutomaticEnv()

	viper.SetConfigName("wabot")
	viper.SetConfigType("yaml")
	viper.AddConfigPath(".")

	if err := viper.ReadInConfig(); err != nil {
		slog.Error("Error reading config file", "error", err)
		panic(err)
	}

	cfg := config.New()

	// Unmarshal the values into the config.Config struct
	if err := viper.Unmarshal(&cfg); err != nil {
		slog.Error("Error parsing config file", "error", err)
		panic(err)
	}
	logger := logger.NewTag(cfg.LogLevel, "main")

	w, err := wabot.New(cfg)
	if err != nil {
		logger.Error("failed to create wabot", "error", err)
		panic(err)
	}

	wl := w.Logger

	handoffFn := webhooks.HandoffFunc(func(ctx context.Context, store *datastore.Store, rawData *[]byte) {
		// logger.Debug("handoff", "raw_data", string(rawData))
	})

	respondFn := webhooks.RespondFunc(func(ctx context.Context, store *datastore.Store, payload webhooks.Payload) {
		messages := payload.GetMessages()
		if len(messages) == 0 {
			wl.Warn("No messages found in payload")
			return
		}

		// Process the messages
		for _, message := range messages {
			mtype := message.GetMessageType()
			switch mtype {
			case "location", "text", "flows", "interactive", "payment":
				wl.Debug("message type", "type", mtype, "message", message)
			default:
				wl.Warn("unsupported message type", "type", mtype)
			}
		}
		logger.Debug("respond", "payload", payload)
	})

	w.SetHandoffFn(handoffFn)
	w.SetRespondFn(respondFn)

	if err := w.Serve(); err != nil {
		logger.Error("wabot failed", "error", err)
	}
}