Method CreateInstance

backend/store/instance.go:177–219

CreateInstance creates an instance.

(ctx context.Context, instanceCreate *InstanceMessage)

// CreateInstance creates an instance.
func (s *Store) CreateInstance(ctx context.Context, instanceCreate *InstanceMessage) (*InstanceMessage, error) {
	if err := validateInstanceDataSources(instanceCreate.Metadata); err != nil {
		return nil, err
	}

	redacted, err := s.obfuscateInstance(ctx, instanceCreate.Metadata)
	if err != nil {
		return nil, err
	}
	metadataBytes, err := protojson.Marshal(redacted)
	if err != nil {
		return nil, err
	}
	var environment *string
	if instanceCreate.EnvironmentID != nil && *instanceCreate.EnvironmentID != "" {
		environment = instanceCreate.EnvironmentID
	}

	q := qb.Q().Space(`
			INSERT INTO instance (
				resource_id,
				workspace,
				environment,
				metadata
			) VALUES (?, ?, ?, ?)
		`, instanceCreate.ResourceID, instanceCreate.Workspace, environment, metadataBytes)
	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}
	if _, err := s.GetDB().ExecContext(ctx, query, args...); err != nil {
		return nil, err
	}

	instance := &InstanceMessage{
		EnvironmentID: instanceCreate.EnvironmentID,
		ResourceID:    instanceCreate.ResourceID,
		Workspace:     instanceCreate.Workspace,
		Metadata:      instanceCreate.Metadata,
	}
	s.instanceCache.Add(getInstanceCacheKey(instance.ResourceID), instance)
	return instance, nil
}

// UpdateInstance updates an instance.
func (s *Store) UpdateInstance(ctx context.Context, patch *UpdateInstanceMessage) (*InstanceMessage, error) {