Function RegisterModules

maddy.go:530–615

(c *container.C, globals map[string]interface{}, nodes []config.Node)

}

func RegisterModules(c *container.C, globals map[string]interface{}, nodes []config.Node) (err error) {
	var endpoints []struct {
		Endpoint container.LifetimeModule
		Cfg      *config.Map
	}

	for _, block := range nodes {
		var instName string
		var modAliases []string
		if len(block.Args) == 0 {
			instName = block.Name
		} else {
			instName = block.Args[0]
			modAliases = block.Args[1:]
		}

		modName := block.Name

		endpFactory := modules.GetEndpoint(modName)
		if endpFactory != nil {
			inst, err := endpFactory(c, modName, block.Args)
			if err != nil {
				return err
			}

			endpoints = append(endpoints, struct {
				Endpoint container.LifetimeModule
				Cfg      *config.Map
			}{Endpoint: inst, Cfg: config.NewMap(globals, block)})
			continue
		}

		factory := modules.Get(modName)
		if factory == nil {
			return config.NodeErr(block, "unknown module or global directive: %s", modName)
		}

		inst, err := factory(c, modName, instName)
		if err != nil {
			return err
		}

		err = c.Modules.Register(inst, func() error {
			err := inst.Configure(nil, config.NewMap(globals, block))
			if err != nil {
				return err
			}

			if lt, ok := inst.(container.LifetimeModule); ok {
				c.Lifetime.Add(lt)
			}
			return nil
		})
		if err != nil {
			if errors.Is(err, container.ErrInstanceNameDuplicate) {
				return config.NodeErr(block, "config block named %s already exists", inst.InstanceName())
			}
			return err