Method Open

driver/ipfs-log/db.go:42–110

Open initializes and opens the database

(path string, cfg *config.Config)

// Open initializes and opens the database
func (s Store) Open(path string, cfg *config.Config) (driver.IDB, error) {
	// Check if the environment variable for Dbname is set
	DbnameENV := os.Getenv("IPFS_LOG_DBNAME")
	if DbnameENV != "" {
		Dbname = DbnameENV
	}

	// Create the directory if it doesn't exist
	if err := os.MkdirAll(path, fs.ModePerm); err != nil {
		return nil, fmt.Errorf("failed to create directory: %w", err)
	}

	// Initialize the DB struct
	db := &DB{
		ctx:  context.Background(),
		path: path,
	}

	var err error
	ctx := context.Background()
	// Create the IPFS node
	node, api, err := iflog.CreateNode(ctx, db.path)
	if err != nil {
		return nil, fmt.Errorf("failed to create IPFS node: %w", err)
	}

	// Build host multiaddress
	hostAddr, err := ma.NewMultiaddr(fmt.Sprintf("/ipfs/%s", node.PeerHost.ID()))
	if err != nil {
		return nil, fmt.Errorf("failed to create multiaddress: %w", err)
	}
	for _, a := range node.PeerHost.Addrs() {
		fmt.Println(a.Encapsulate(hostAddr).String())
	}
	fmt.Println("multi node communication identifier:", Dbname)

	// Initialize the logger
	logger := zap.NewNop()

	// Create the IPFS log
	ev, err := iflog.NewIpfsLog(ctx, api, Dbname, &iflog.EventOptions{
		Directory: db.path,
		Logger:    logger,
	})
	if err != nil {
		return nil, fmt.Errorf("failed to create IPFS log: %w", err)
	}

	// Announce and connect to the IPFS network
	if err := ev.AnnounceConnect(ctx, node); err != nil {
		return nil, fmt.Errorf("failed to announce and connect: %w", err)
	}

	// Initialize the LevelKVDB
	db.db, err = levelkv.NewLevelKVDB(ctx, ev, logger)
	if err != nil {
		return nil, fmt.Errorf("failed to create LevelKVDB: %w", err)
	}