import.go

package main

import (
	"bufio"
	"context"
	"errors"
	"os"

	"github.com/filecoin-project/go-f3/certstore"
	"github.com/filecoin-project/go-f3/gpbft"
	"github.com/filecoin-project/go-f3/manifest"
	"github.com/filecoin-project/go-jsonrpc"
	"github.com/ipfs/go-datastore/namespace"
)

func importSnap(ctx context.Context, rpcEndpoint string, f3Root string, snapshotPath string) (err error) {
	logger.Infof("importing F3 snapshot at %s", snapshotPath)

	f3api := F3Api{}
	closer, err := jsonrpc.NewClient(ctx, rpcEndpoint, "F3", &f3api, nil)
	if err != nil {
		return err
	}
	defer closer()
	rawNetworkName := waitRawNetworkName(ctx, &f3api)
	networkName := gpbft.NetworkName(rawNetworkName)
	m := RawNetwork2PredefinedManifestMappings[networkName]
	if m == nil {
		m2 := manifest.LocalDevnetManifest()
		m = &m2
		m.NetworkName = networkName
	}

	ds, err := getDatastore(f3Root)
	if err != nil {
		return err
	}
	dsWrapper := namespace.Wrap(ds, m.DatastorePrefix())
	defer func() {
		if closeErr := dsWrapper.Close(); closeErr != nil {
			err = errors.Join(err, closeErr)
		}
	}()

	f, err := os.Open(snapshotPath)
	if err != nil {
		return err
	}
	defer func() {
		if closeErr := f.Close(); closeErr != nil {
			err = errors.Join(err, closeErr)
		}
	}()
	return certstore.ImportSnapshotToDatastore(ctx, bufio.NewReader(f), dsWrapper, m)
}