package store

import (
	"github.com/jmoiron/sqlx"
	"github.com/pkg/errors"
)

type Organization struct {
	Model
	Token       string
	Description string
}

func (str *Store) CreateOrganization(org *Organization, trx *sqlx.Tx) (int, error) {
	stmt, err := trx.Prepare("insert into organizations (token, description) values ($1, $2) returning id")
	if err != nil {
		return 0, errors.Wrap(err, "error preparing organizations insert statement")
	}
	var id int
	if err := stmt.QueryRow(org.Token, org.Description).Scan(&id); err != nil {
		return 0, errors.Wrap(err, "error executing organizations insert statement")
	}
	return id, nil
}

func (str *Store) FindOrganizationByToken(token string, trx *sqlx.Tx) (*Organization, error) {
	org := &Organization{}
	if err := trx.QueryRowx("select * from organizations where token = $1 and not deleted", token).StructScan(org); err != nil {
		return nil, errors.Wrap(err, "error selecting frontend by token")
	}
	return org, nil
}

func (str *Store) DeleteOrganization(id int, trx *sqlx.Tx) error {
	stmt, err := trx.Prepare("update organizations set updated_at = current_timestamp, deleted = true where id = $1")
	if err != nil {
		return errors.Wrap(err, "error preparing organizations delete statement")
	}
	_, err = stmt.Exec(id)
	if err != nil {
		return errors.Wrap(err, "error executing organizations delete statement")
	}
	return nil
}