Method ListInstances

backend/store/instance.go:84–174

ListInstances lists all instance.

(ctx context.Context, find *FindInstanceMessage)

// ListInstances lists all instance.
func (s *Store) ListInstances(ctx context.Context, find *FindInstanceMessage) ([]*InstanceMessage, error) {
	where := qb.Q().Space("instance.workspace = ?", find.Workspace)
	if filterQ := find.FilterQ; filterQ != nil {
		where.And("?", filterQ)
	}

	if v := find.ResourceID; v != nil {
		where.And("instance.resource_id = ?", *v)
	}
	if v := find.ResourceIDs; v != nil {
		where.And("instance.resource_id = ANY(?)", *v)
	}
	if !find.ShowDeleted {
		where.And("instance.deleted = ?", false)
	}

	q := qb.Q().Space(`
		SELECT
			instance.resource_id,
			instance.workspace,
			instance.environment,
			instance.deleted,
			instance.metadata
		FROM instance
		WHERE ?
	`, where)

	if len(find.OrderByKeys) > 0 {
		orderBy := []string{}
		for _, v := range find.OrderByKeys {
			orderBy = append(orderBy, fmt.Sprintf("%s %s", v.Key, v.SortOrder.String()))
		}
		q.Space(fmt.Sprintf("ORDER BY %s", strings.Join(orderBy, ", ")))
	} else {
		q.Space("ORDER BY resource_id ASC")
	}

	if v := find.Limit; v != nil {
		q.Space("LIMIT ?", *v)
	}
	if v := find.Offset; v != nil {
		q.Space("OFFSET ?", *v)
	}

	query, queryArgs, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	var instanceMessages []*InstanceMessage
	rows, err := s.GetDB().QueryContext(ctx, query, queryArgs...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	for rows.Next() {
		var instanceMessage InstanceMessage
		var environment sql.NullString