Method Publish

module/strategy/iml.go:315–350

(ctx context.Context, driver string, scope string, target string)

}

func (i *imlStrategyModule) Publish(ctx context.Context, driver string, scope string, target string) error {
	d, has := strategy_driver.GetDriver(driver)
	if !has {
		return fmt.Errorf("driver not found: %s", driver)
	}
	list, err := i.strategyService.AllByDriver(ctx, driver, strategy_dto.ToScope(scope).Int(), target)
	if err != nil {
		return err
	}

	return i.transaction.Transaction(ctx, func(txCtx context.Context) error {
		publishStrategies := make([]*eosc.Base[gateway.StrategyRelease], 0, len(list))
		for _, l := range list {
			if l.IsDelete {
				err = i.strategyService.Delete(ctx, l.Id)
				if err != nil {
					return err
				}
			}
			publishStrategies = append(publishStrategies, d.ToRelease(strategy_dto.ToStrategy(l), nil, 5000))

			err = i.strategyService.CommitStrategy(txCtx, scope, target, l.Id, l)
			if err != nil {
				return err
			}
		}
		client, err := i.clusterService.GatewayClient(ctx, cluster.DefaultClusterID)
		if err != nil {
			return err
		}
		defer func() {
			_ = client.Close(ctx)
		}()
		return client.Strategy().Online(ctx, publishStrategies...)
	})
}

func (i *imlStrategyModule) Delete(ctx context.Context, id string) error {
	_, err := i.strategyService.LatestStrategyCommit(ctx, strategy_dto.ScopeGlobal, "", id)