Function syncState

core/application/p2p.go:164–232

(ctx context.Context, n *node.Node, app *Application)

}

func syncState(ctx context.Context, n *node.Node, app *Application) error {
	xlog.Debug("[p2p-sync] Syncing state")

	whatWeHave := []string{}
	for _, model := range app.ModelConfigLoader().GetAllModelsConfigs() {
		whatWeHave = append(whatWeHave, model.Name)
	}

	ledger, _ := n.Ledger()
	currentData := ledger.CurrentData()
	xlog.Debug("[p2p-sync] Current data", "data", currentData)
	data, exists := ledger.GetKey("shared_state", "models")
	if !exists {
		ledger.AnnounceUpdate(ctx, time.Minute, "shared_state", "models", whatWeHave)
		xlog.Debug("No models found in the ledger, announced our models", "models", whatWeHave)
	}

	models := []string{}
	if err := data.Unmarshal(&models); err != nil {
		xlog.Warn("error unmarshalling models", "error", err)
		return nil
	}

	xlog.Debug("[p2p-sync] Models comparison", "ourModels", whatWeHave, "ledgerModels", models)

	// Sync with our state
	whatIsNotThere := []string{}
	for _, model := range whatWeHave {
		if !slices.Contains(models, model) {
			whatIsNotThere = append(whatIsNotThere, model)
		}
	}
	if len(whatIsNotThere) > 0 {
		xlog.Debug("[p2p-sync] Announcing our models", "models", append(models, whatIsNotThere...))
		ledger.AnnounceUpdate(
			ctx,
			1*time.Minute,
			"shared_state",
			"models",
			append(models, whatIsNotThere...),
		)
	}

	// Check if we have a model that is not in our state, otherwise install it
	for _, model := range models {
		if slices.Contains(whatWeHave, model) {
			xlog.Debug("[p2p-sync] Model is already present in this instance", "model", model)
			continue
		}

		// we install model
		xlog.Info("[p2p-sync] Installing model which is not present in this instance", "model", model)

		uuid, err := uuid.NewUUID()
		if err != nil {
			xlog.Error("error generating UUID", "error", err)
			continue
		}