Method updateInstance

database/sql/instances.go:406–472

(ctx context.Context, instanceName string, param params.UpdateInstanceParams, force bool)

}

func (s *sqlDatabase) updateInstance(ctx context.Context, instanceName string, param params.UpdateInstanceParams, force bool) (params.Instance, error) {
	var rowsAffected int64
	err := s.conn.Transaction(func(tx *gorm.DB) error {
		instance, err := s.getInstance(ctx, tx, instanceName, "Pool", "ScaleSet")
		if err != nil {
			return fmt.Errorf("error updating instance: %w", err)
		}

		if !force {
			// Validate transitions
			if err := s.validateAgentID(instance.AgentID, param.AgentID); err != nil {
				return err
			}

			if err := s.validateRunnerStatusTransition(instance.RunnerStatus, param.RunnerStatus); err != nil {
				return err
			}
			if err := s.validateInstanceStatusTransition(instance.Status, param.Status); err != nil {
				return err
			}
		}

		// Apply updates
		if err := s.applyInstanceUpdates(&instance, param); err != nil {
			return err
		}

		// Save instance
		result := tx.Save(&instance)
		if result.Error != nil {
			return fmt.Errorf("error updating instance: %w", result.Error)
		}
		rowsAffected = result.RowsAffected

		// Update addresses if provided
		if len(param.Addresses) > 0 {
			addrs := make([]Address, 0, len(param.Addresses))
			for _, addr := range param.Addresses {
				addrs = append(addrs, Address{
					Address: addr.Address,
					Type:    string(addr.Type),
				})
			}
			if err := tx.Model(&instance).Association("Addresses").Replace(addrs); err != nil {
				return fmt.Errorf("error updating addresses: %w", err)
			}
		}
		return nil
	})
	if err != nil {
		return params.Instance{}, fmt.Errorf("error updating instance: %w", err)
	}

	instance, err := s.getInstance(ctx, s.conn, instanceName, "Pool", "ScaleSet")
	if err != nil {
		return params.Instance{}, fmt.Errorf("error updating instance: %w", err)
	}