package sql

import (
	"donat-widget/internal/model"
	"fmt"
)

var CreateWidget = `
INSERT INTO widgets (streamer_id, template_id, image, audio, duration, min_amount, max_amount name)
VALUES (@streamer_id, @template_id, @image, @audio, @duration, @min_amount, @max_amount, @name)
RETURNING id;
`

var GetWidgetByStreamerID = `
SELECT * FROM widgets
WHERE streamer_id = (@streamer_id);
`
var GetWidgetByID = `
SELECT * FROM widgets
WHERE id = (@id);
`

func UpdateMediaUrl(mediaType model.MediaType) string {
	query := fmt.Sprintf(`
		UPDATE widgets 
		SET %s = (@%s)
		WHERE id = (@id)
	`, mediaType, mediaType)
	return query
}

var GetAllWidget = `
SELECT * FROM widgets
WHERE streamer_id = (@streamer_id);
`

func GetMediaUrl(mediaType model.MediaType) string {
	query := fmt.Sprintf(`
		SELECT %s
		FROM widgets
		WHERE id = (@id)
	`, mediaType)
	return query
}

var CreateDonat = `
INSERT INTO donats (streamer_id, widget_id, text, amount, donat_user, order_id, target_id)
VALUES (@streamer_id, @widget_id, @text, @amount, @donat_user, @order_id, @target_id)
RETURNING id;
`
var MarkDonatView = `
UPDATE donats
SET view = (@view)
WHERE id = (@id);
`
var MarkDonatPaid = `
UPDATE donats
SET paid = (@paid)
WHERE order_id = (@order_id);
`
var GetDonatByStreamerID = `
SELECT * FROM donats
WHERE streamer_id = (@streamer_id) AND paid = (@paid) AND view = (@view);
`
var GetDonatByOrderID = `
SELECT * FROM donats
WHERE order_id = (@order_id);
`

var CreateTarget = `
INSERT INTO targets (streamer_id, text, amount)
VALUES (@streamer_id, @text, @amount)
RETURNING id;
`

var GetAllTarget = `
SELECT * FROM targets
WHERE streamer_id = (@streamer_id);
`
var AddAmountToTarget = `
UPDATE targets
SET collected = collected + (@amount)
WHERE id = (@target_id);
`

var GetDonationPage = `
SELECT * FROM donate_pages WHERE streamer_id = (@streamer_id);
`

var GetDonationPageByLogin = `
SELECT * FROM donate_pages WHERE streamer_login = (@streamer_login);
`

var GetWidgetsByStreamerID = `
SELECT 
	w.id, 
	w.streamer_id, 
	w.template_id, 
	img.id AS image_id,
	img.file_name AS image_file_name,
	img.file_type AS image_type,
    audio.id AS audio_id,
	audio.file_name AS audio_file_name,
	audio.file_type AS audio_type,
	w.duration, 
	w.min_amount, 
	w.created_at, 
	w.updated_at
FROM widgets w
LEFT JOIN files img ON w.image = img.id
LEFT JOIN files audio ON w.audio = audio.id
WHERE w.streamer_id = (@streamer_id);
`

var AddNewFile = `
INSERT INTO files (streamer_id, file_name, file_type, extension) 
VALUES 
(@streamer_id, @file_name, @file_type, @extension)
RETURNING id;
`

var GetWidgetByName = `SELECT id FROM widgets WHERE (
    streamer_id = @streamer_id AND 
    name = @name);
`

var FileById = `SELECT file_name, streamer_id, file_type FROM files WHERE id = (@id);`

var AudioFilesWidgets = `
SELECT f.* 
FROM files AS f
JOIN widgets AS w ON w.audio = f.id
WHERE f.streamer_id = (@streamer_id);
`

var ImageFilesWidgets = `
SELECT f.* 
FROM files AS f
JOIN widgets AS w ON w.image = f.id
WHERE f.streamer_id = (@streamer_id);
`

var UpdateWidget = `
UPDATE widgets
SET
    duration = COALESCE(@duration, duration),
    min_amount = COALESCE(@min_amount, min_amount),
    max_amount = COALESCE(@max_amount, max_amount),
    is_active = COALESCE(@is_active, is_active),
    image = COALESCE(@image, image),
    audio = COALESCE(@audio, audio),
    name = COALESCE(@name, name)
WHERE id = @id;
`

var GetWidgetById = `
SELECT id FROM widgets WHERE id = (@widget_id) AND streamer_id = (@streamer_id);
`