package db

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

	"tangled.org/core/appview/models"
	"tangled.org/core/orm"
)

func AddCollaborator(e Execer, c models.Collaborator) error {
	var repoDid *string
	if c.RepoDid != "" {
		repoDid = &c.RepoDid
	}

	_, err := e.Exec(
		`insert into collaborators (did, rkey, subject_did, repo_at, repo_did) values (?, ?, ?, ?, ?);`,
		c.Did, c.Rkey, c.SubjectDid, c.RepoAt, repoDid,
	)
	return err
}

func DeleteCollaborator(e Execer, filters ...orm.Filter) error {
	var conditions []string
	var args []any
	for _, filter := range filters {
		conditions = append(conditions, filter.Condition())
		args = append(args, filter.Arg()...)
	}

	whereClause := ""
	if conditions != nil {
		whereClause = " where " + strings.Join(conditions, " and ")
	}

	query := fmt.Sprintf(`delete from collaborators %s`, whereClause)

	_, err := e.Exec(query, args...)
	return err
}

func CollaboratingIn(e Execer, collaborator string) ([]models.Repo, error) {
	rows, err := e.Query(`select repo_at from collaborators where subject_did = ?`, collaborator)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var repoAts []string
	for rows.Next() {
		var aturi string
		err := rows.Scan(&aturi)
		if err != nil {
			return nil, err
		}
		repoAts = append(repoAts, aturi)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	if repoAts == nil {
		return nil, nil
	}

	return GetRepos(e, 0, orm.FilterIn("at_uri", repoAts))
}

func GetCollaborators(e Execer, filters ...orm.Filter) ([]models.Collaborator, error) {
	var collaborators []models.Collaborator
	var conditions []string
	var args []any
	for _, filter := range filters {
		conditions = append(conditions, filter.Condition())
		args = append(args, filter.Arg()...)
	}
	whereClause := ""
	if conditions != nil {
		whereClause = " where " + strings.Join(conditions, " and ")
	}
	query := fmt.Sprintf(`select
			id,
			did,
			rkey,
			subject_did,
			repo_at,
			created,
			repo_did
		from collaborators %s`,
		whereClause,
	)
	rows, err := e.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	for rows.Next() {
		var collaborator models.Collaborator
		var createdAt string
		var collabRepoDid sql.NullString
		if err := rows.Scan(
			&collaborator.Id,
			&collaborator.Did,
			&collaborator.Rkey,
			&collaborator.SubjectDid,
			&collaborator.RepoAt,
			&createdAt,
			&collabRepoDid,
		); err != nil {
			return nil, err
		}
		collaborator.Created, err = time.Parse(time.RFC3339, createdAt)
		if err != nil {
			collaborator.Created = time.Now()
		}
		if collabRepoDid.Valid {
			collaborator.RepoDid = collabRepoDid.String
		}
		collaborators = append(collaborators, collaborator)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return collaborators, nil
}