78 lines
1.9 KiB
Go
78 lines
1.9 KiB
Go
|
package store
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"database/sql"
|
||
|
|
"errors"
|
||
|
|
|
||
|
|
"g.fc.run/misc/byre/internal/api"
|
||
|
|
)
|
||
|
|
|
||
|
|
const previewColumns = `task_id, name, port, created_at`
|
||
|
|
|
||
|
|
func (s *Store) SetPreview(ctx context.Context, p api.Preview, actor string) ([]int, error) {
|
||
|
|
dropped := []int{}
|
||
|
|
err := s.write(ctx, func(tx *sql.Tx, emit emitFunc) error {
|
||
|
|
projectID := ""
|
||
|
|
err := tx.QueryRowContext(ctx, `SELECT project_id FROM tasks WHERE id = ? AND status = ?`, p.TaskId, string(api.TaskStatusActive)).Scan(&projectID)
|
||
|
|
if errors.Is(err, sql.ErrNoRows) {
|
||
|
|
return ErrNotFound
|
||
|
|
}
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
rows, err := tx.QueryContext(ctx, `DELETE FROM previews WHERE task_id = ? AND (name = ? OR port = ?) RETURNING port`, p.TaskId, p.Name, p.Port)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
for rows.Next() {
|
||
|
|
port := 0
|
||
|
|
err = rows.Scan(&port)
|
||
|
|
if err != nil {
|
||
|
|
rows.Close()
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
if port != p.Port {
|
||
|
|
dropped = append(dropped, port)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
rows.Close()
|
||
|
|
err = rows.Err()
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
_, err = tx.ExecContext(ctx, `INSERT INTO previews (`+previewColumns+`) VALUES (?, ?, ?, ?)`, p.TaskId, p.Name, p.Port, formatTime(p.CreatedAt))
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
return emit(api.Event{Kind: "preview.exposed", ProjectId: &projectID, TaskId: &p.TaskId, Actor: actor, Payload: ToPayload(p)})
|
||
|
|
})
|
||
|
|
return dropped, err
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Store) ListPreviews(ctx context.Context, taskID string) ([]api.Preview, error) {
|
||
|
|
rows, err := s.db.QueryContext(ctx, `SELECT `+previewColumns+` FROM previews WHERE task_id = ? ORDER BY name`, taskID)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
defer rows.Close()
|
||
|
|
|
||
|
|
previews := []api.Preview{}
|
||
|
|
for rows.Next() {
|
||
|
|
p := api.Preview{}
|
||
|
|
createdAt := ""
|
||
|
|
err = rows.Scan(&p.TaskId, &p.Name, &p.Port, &createdAt)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
p.CreatedAt, err = parseTime(createdAt)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
previews = append(previews, p)
|
||
|
|
}
|
||
|
|
return previews, rows.Err()
|
||
|
|
}
|