mirror of
https://github.com/IBM/fp-go.git
synced 2025-08-10 22:31:32 +02:00
80 lines
2.3 KiB
Go
80 lines
2.3 KiB
Go
// Copyright (c) 2023 IBM Corp.
|
|
// All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package di
|
|
|
|
import (
|
|
A "github.com/IBM/fp-go/array"
|
|
DIE "github.com/IBM/fp-go/di/erasure"
|
|
E "github.com/IBM/fp-go/either"
|
|
"github.com/IBM/fp-go/errors"
|
|
F "github.com/IBM/fp-go/function"
|
|
IOE "github.com/IBM/fp-go/ioeither"
|
|
)
|
|
|
|
func lookupAt[T any](idx int, token Dependency[T]) func(params []any) E.Either[error, T] {
|
|
return F.Flow3(
|
|
A.Lookup[any](idx),
|
|
E.FromOption[any](errors.OnNone("No parameter at position %d", idx)),
|
|
E.Chain(token.Unerase),
|
|
)
|
|
}
|
|
|
|
func eraseTuple[A, R any](f func(A) IOE.IOEither[error, R]) func(E.Either[error, A]) IOE.IOEither[error, any] {
|
|
return F.Flow3(
|
|
IOE.FromEither[error, A],
|
|
IOE.Chain(f),
|
|
IOE.Map[error](F.ToAny[R]),
|
|
)
|
|
}
|
|
|
|
func eraseProviderFactory0[R any](f IOE.IOEither[error, R]) func(params ...any) IOE.IOEither[error, any] {
|
|
return func(_ ...any) IOE.IOEither[error, any] {
|
|
return F.Pipe1(
|
|
f,
|
|
IOE.Map[error](F.ToAny[R]),
|
|
)
|
|
}
|
|
}
|
|
|
|
func MakeProviderFactory0[R any](
|
|
fct IOE.IOEither[error, R],
|
|
) DIE.ProviderFactory {
|
|
return DIE.MakeProviderFactory(
|
|
A.Empty[DIE.Dependency](),
|
|
eraseProviderFactory0(fct),
|
|
)
|
|
}
|
|
|
|
// MakeTokenWithDefault0 creates a unique [InjectionToken] for a specific type with an attached default [DIE.Provider]
|
|
func MakeTokenWithDefault0[R any](name string, fct IOE.IOEither[error, R]) InjectionToken[R] {
|
|
return MakeTokenWithDefault[R](name, MakeProviderFactory0(fct))
|
|
}
|
|
|
|
func MakeProvider0[R any](
|
|
token InjectionToken[R],
|
|
fct IOE.IOEither[error, R],
|
|
) DIE.Provider {
|
|
return DIE.MakeProvider(
|
|
token,
|
|
MakeProviderFactory0(fct),
|
|
)
|
|
}
|
|
|
|
// ConstProvider simple implementation for a provider with a constant value
|
|
func ConstProvider[R any](token InjectionToken[R], value R) DIE.Provider {
|
|
return MakeProvider0[R](token, IOE.Of[error](value))
|
|
}
|