package sqlite

import (
	"context"
	"database/sql"

	"git.aiterp.net/lucifer/lucifer/models"
)

type lightRepository struct{}

// LightRepository is a sqlite datbase repository for the Light model.
var LightRepository models.LightRepository = &lightRepository{}

func (r *lightRepository) FindByID(ctx context.Context, id int) (models.Light, error) {
	light := models.Light{}
	err := db.GetContext(ctx, &light, "SELECT * FROM light WHERE id=?", id)

	return light, err
}

func (r *lightRepository) FindByInternalID(ctx context.Context, internalID string) (models.Light, error) {
	light := models.Light{}
	err := db.GetContext(ctx, &light, "SELECT * FROM light WHERE internal_id=?", internalID)

	return light, err
}

func (r *lightRepository) List(ctx context.Context) ([]models.Light, error) {
	lights := make([]models.Light, 0, 64)
	err := db.SelectContext(ctx, &lights, "SELECT * FROM light")

	return lights, err
}

func (r *lightRepository) ListByBridge(ctx context.Context, bridge models.Bridge) ([]models.Light, error) {
	lights := make([]models.Light, 0, 64)
	err := db.SelectContext(ctx, &lights, "SELECT * FROM light WHERE bridge_id=?", bridge.ID)

	return lights, err
}

func (r *lightRepository) ListByGroup(ctx context.Context, group models.Group) ([]models.Light, error) {
	lights := make([]models.Light, 0, 64)
	err := db.SelectContext(ctx, &lights, "SELECT * FROM light WHERE group_id=?", group.ID)

	if err == sql.ErrNoRows {
		err = nil
	}

	return lights, err
}

func (r *lightRepository) Insert(ctx context.Context, light models.Light) (models.Light, error) {
	res, err := db.NamedExecContext(ctx, "INSERT INTO light (bridge_id, internal_id, group_id, name, enabled, color, brightness) VALUES(:bridge_id, :internal_id, :group_id, :name, :enabled, :color, :brightness)", light)
	if err != nil {
		return models.Light{}, err
	}

	id, err := res.LastInsertId()
	if err != nil {
		return models.Light{}, err
	}

	light.ID = int(id)
	return light, nil
}

func (r *lightRepository) Update(ctx context.Context, light models.Light) error {
	_, err := db.NamedExecContext(ctx, "UPDATE light SET group_id=:group_id, name=:name, enabled=:enabled, color=:color, brightness=:brightness WHERE id=:id", light)
	return err
}

func (r *lightRepository) Remove(ctx context.Context, light models.Light) error {
	_, err := db.NamedExecContext(ctx, "DELETE FROM light WHERE id=:id", light)
	return err
}