eventdata_repository.go

package redshift

import (
	"context"
	"database/sql"
	"fmt"
	"strings"

	"github.com/italolelis/watchops/internal/app/provider"
)

type (
	// EventDataWriter implement writer interface.
	EventDataWriter struct {
		db     *sql.DB
		schema string
	}
)

// NewEventDataWriter creates a new instance of EventDataWriter.
func NewEventDataWriter(db *sql.DB, schema string) *EventDataWriter {
	return &EventDataWriter{db: db, schema: strings.ToLower(schema)}
}

// Add adds event data coming from webhooks.
func (w *EventDataWriter) Add(ctx context.Context, eventData provider.Event) error {
	var query = fmt.Sprintf("INSERT INTO %s.events_raw(id, event_type, metadata, time_created, signature, msg_id, source) VALUES ($1, $2, json_parse($3), $4, $5, $6, $7)", w.schema)

	if _, err := w.db.ExecContext(
		ctx,
		query,
		eventData.ID,
		eventData.EventType,
		eventData.Metadata,
		eventData.TimeCreated,
		eventData.Signature,
		eventData.MsgID,
		eventData.Source,
	); err != nil {
		return fmt.Errorf("error when executing event data query: %w", err)
	}

	return nil
}

// Closes the connection to the database.
func (w *EventDataWriter) Close() error {
	return w.db.Close()
}