Method GetInstanceByResourceID

backend/store/runner_queries.go:59–108

GetInstanceByResourceID gets an instance by its globally unique resource ID without workspace filter. For use by runners that resolve workspace from the loaded entity.

(ctx context.Context, resourceID string)

// GetInstanceByResourceID gets an instance by its globally unique resource ID without workspace filter.
// For use by runners that resolve workspace from the loaded entity.
func (s *Store) GetInstanceByResourceID(ctx context.Context, resourceID string) (*InstanceMessage, error) {
	if v, ok := s.instanceCache.Get(getInstanceCacheKey(resourceID)); ok && s.enableCache {
		return v, nil
	}

	q := qb.Q().Space(`
		SELECT
			instance.resource_id,
			instance.workspace,
			instance.environment,
			instance.deleted,
			instance.metadata
		FROM instance
		WHERE instance.resource_id = ?
	`, resourceID)
	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	var instance InstanceMessage
	var environment sql.NullString
	var metadata []byte
	if err := s.GetDB().QueryRowContext(ctx, query, args...).Scan(
		&instance.ResourceID,
		&instance.Workspace,
		&environment,
		&instance.Deleted,
		&metadata,
	); err != nil {
		if err == sql.ErrNoRows {
			return nil, nil
		}
		return nil, err
	}
	if environment.Valid {
		instance.EnvironmentID = &environment.String
	}
	instanceMetadata := &storepb.Instance{}
	if err := common.ProtojsonUnmarshaler.Unmarshal(metadata, instanceMetadata); err != nil {
		return nil, err
	}
	instance.Metadata = instanceMetadata

	if err := s.deobfuscateInstances(ctx, []*InstanceMessage{&instance}); err != nil {
		return nil, err
	}
	s.instanceCache.Add(getInstanceCacheKey(instance.ResourceID), &instance)
	return &instance, nil
}

// ListAllInstances lists instances across all workspaces without workspace filter.
// For use by runners (e.g., schema sync) that need to process all instances.