Method UpdateEntityPool

database/sql/pools.go:405–433

(ctx context.Context, entity params.ForgeEntity, poolID string, param params.UpdatePoolParams)

}

func (s *sqlDatabase) UpdateEntityPool(ctx context.Context, entity params.ForgeEntity, poolID string, param params.UpdatePoolParams) (updatedPool params.Pool, err error) {
	var rowsAffected int64
	defer func() {
		if err == nil && rowsAffected > 0 {
			s.sendNotify(common.PoolEntityType, common.UpdateOperation, updatedPool)
		}
	}()
	err = s.conn.Transaction(func(tx *gorm.DB) error {
		pool, err := s.getEntityPool(tx, entity.EntityType, entity.ID, poolID, "Tags", "Instances")
		if err != nil {
			return fmt.Errorf("error fetching pool: %w", err)
		}

		updatedPool, rowsAffected, err = s.updatePool(tx, pool, param)
		if err != nil {
			return fmt.Errorf("error updating pool: %w", err)
		}
		return nil
	})
	if err != nil {
		return params.Pool{}, err
	}

	updatedPool, err = s.GetPoolByID(ctx, poolID)
	if err != nil {
		return params.Pool{}, err
	}
	return updatedPool, nil
}

func (s *sqlDatabase) ListEntityPools(_ context.Context, entity params.ForgeEntity) ([]params.Pool, error) {
	pools, err := s.listEntityPools(s.conn, entity.EntityType, entity.ID, "Tags")