eth-indexer/internal/handler/handler.go

package handler

import (
	"context"
	"encoding/json"

	"github.com/grassrootseconomics/celo-indexer/internal/store"
	"github.com/grassrootseconomics/celo-tracker/pkg/event"
)

type (
	HandlerOpts struct {
		Store store.Store
		// Cache *cache.Cache
	}

	Handler struct {
		store store.Store
		// cache *cache.Cache
	}
)

func NewHandler(o HandlerOpts) *Handler {
	return &Handler{
		store: o.Store,
		// cache: o.Cache,
	}
}

func (h *Handler) Handle(ctx context.Context, msgSubject string, msgData []byte) error {
	var chainEvent event.Event

	if err := json.Unmarshal(msgData, &chainEvent); err != nil {
		return err
	}

	switch msgSubject {
	case "TRACKER.TOKEN_TRANSFER":
		// from := chainEvent.Payload["from"].(string)
		// to := chainEvent.Payload["to"].(string)

		// if h.cache.Exists(from) || h.cache.Exists(to) {
		// 	return h.store.InsertTokenTransfer(ctx, chainEvent)
		// }
		return h.store.InsertTokenTransfer(ctx, chainEvent)
	case "TRACKER.POOL_SWAP":
		return h.store.InsertPoolSwap(ctx, chainEvent)
	case "TRACKER.FAUCET_GIVE":
		return h.store.InsertFaucetGive(ctx, chainEvent)
	case "TRACKER.POOL_DEPOSIT":
		return h.store.InsertPoolDeposit(ctx, chainEvent)
	case "TRACKER.TOKEN_MINT":
		return h.store.InsertTokenMint(ctx, chainEvent)
	case "TRACKER.TOKEN_BURN":
		return h.store.InsertTokenBurn(ctx, chainEvent)
	case "TRACKER.QUOTER_PRICE_INDEX_UPDATED":
		return h.store.InsertPriceQuoteUpdate(ctx, chainEvent)
	}

	return nil
}