Method DecodePersistedObject

core/git_remote_mirror.go:135–164

(ctx context.Context, dag *dagql.Server, resultID uint64, _ *dagql.ResultCall, payload json.RawMessage)

}

func (*RemoteGitMirror) DecodePersistedObject(ctx context.Context, dag *dagql.Server, resultID uint64, _ *dagql.ResultCall, payload json.RawMessage) (dagql.Typed, error) {
	var persisted persistedRemoteGitMirrorPayload
	if err := json.Unmarshal(payload, &persisted); err != nil {
		return nil, fmt.Errorf("decode persisted remote git mirror payload: %w", err)
	}
	mirror := NewRemoteGitMirror(persisted.RemoteURL)
	if resultID == 0 {
		return mirror, nil
	}
	link, err := loadPersistedSnapshotLinkByResultID(ctx, dag, resultID, "remote git mirror", "bare_repo")
	if err != nil {
		return nil, err
	}
	query, err := persistedDecodeQuery(dag)
	if err != nil {
		return nil, err
	}
	ref, err := query.SnapshotManager().GetMutableBySnapshotID(
		ctx,
		link.RefKey,
		bkcache.NoUpdateLastUsed,
		bkcache.WithRecordType(bkclient.UsageRecordTypeGitCheckout),
		bkcache.WithDescription(fmt.Sprintf("git bare repo for %s", mirror.RemoteURL)),
	)
	if err != nil {
		return nil, fmt.Errorf("reopen persisted remote git mirror snapshot %q: %w", link.RefKey, err)
	}
	mirror.snapshot = ref
	return mirror, nil
}

func (mirror *RemoteGitMirror) EnsureCreated(ctx context.Context, query *Query) error {
	if mirror == nil {