Function init

plugins/mount/manager.go:39–125

()

)

func init() {
	registry.Register(&plugin.Registration{
		Type: plugins.MountManagerPlugin,
		ID:   "bolt",
		Requires: []plugin.Type{
			plugins.MetadataPlugin,
			plugins.MountHandlerPlugin,
		},
		InitFn: func(ic *plugin.InitContext) (any, error) {
			md, err := ic.GetSingle(plugins.MetadataPlugin)
			if err != nil {
				return nil, err
			}
			hp, err := ic.GetByType(plugins.MountHandlerPlugin)
			if err != nil && !errors.Is(err, plugin.ErrPluginNotFound) {
				return nil, err
			}
			var opts []manager.Opt
			for k, v := range hp {
				opts = append(opts, manager.WithMountHandler(k, v.(mount.Handler)))
			}

			root := ic.Properties[plugins.PropertyStateDir]

			// TODO: Allow overriding root and target directory from config

			targets := filepath.Join(root, "t")
			if merr := os.MkdirAll(targets, 0700); merr != nil {
				return nil, merr
			}

			// roots are the directories that mount handlers can operate in
			// TODO: support additional roots from config
			opts = append(opts, manager.WithAllowedRoot(filepath.Dir(ic.Properties[plugins.PropertyRootDir])))

			//if _, ok := mhandlers["mkdir"]; !ok {
			//	mkdir, err := handlers.MkdirHandler(roots...)
			//	if err != nil {
			//		return nil, fmt.Errorf("failed to create mkdir handler: %w", err)
			//	}
			//	mhandlers["mkdir"] = mkdir
			//}

			metadb := filepath.Join(root, "mounts.db")

			db, err := bolt.Open(metadb, 0600, nil)
			if err != nil {
				return nil, fmt.Errorf("failed to open database file: %w", err)
			}

			mm, err := manager.NewManager(db, targets, opts...)
			if err != nil {
				db.Close()
				return nil, fmt.Errorf("failed to create mount manager: %w", err)
			}

			//TODO: IF has sync
			if sync, ok := mm.(interface{ Sync(context.Context) error }); ok {