//go:generate mockgen -destination mock_settingsdocument/mock_settingsdocument.go github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/settingsdocument DeletedIdsProvider
package settingsdocument

import (
	"github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/spacesyncproto"
	"github.com/anytypeio/go-anytype-infrastructure-experiments/common/pkg/acl/tree"
	"github.com/gogo/protobuf/proto"
)

type DeletedIdsProvider interface {
	ProvideIds(tr tree.ObjectTree, startId string) (ids []string, lastId string, err error)
}

type provider struct{}

func (p *provider) convert(decrypted []byte) (res any, err error) {
	deleteChange := &spacesyncproto.SettingsData{}
	err = proto.Unmarshal(decrypted, deleteChange)
	if err != nil {
		return nil, err
	}
	return deleteChange, nil
}

func (p *provider) ProvideIds(tr tree.ObjectTree, startId string) (ids []string, lastId string, err error) {
	processChange := func(change *tree.Change) bool {
		// ignoring root change which has empty model or startId change
		lastId = change.Id
		if change.Model == nil || (change.Id == startId && startId != "") {
			return true
		}

		deleteChange := change.Model.(*spacesyncproto.SettingsData)
		// getting data from snapshot if we start from it
		if change.Id == tr.Root().Id {
			ids = deleteChange.Snapshot.DeletedIds
			return true
		}

		// otherwise getting data from content
		for _, cnt := range deleteChange.Content {
			if cnt.GetObjectDelete() != nil {
				ids = append(ids, cnt.GetObjectDelete().GetId())
			}
		}
		return true
	}
	if startId == "" {
		err = tr.IterateFrom(tr.ID(), p.convert, processChange)
	} else {
		err = tr.IterateFrom(startId, p.convert, processChange)
	}
	return
}