mirror of
https://github.com/1Password/onepassword-operator.git
synced 2025-10-22 07:28:06 +00:00
13abcb9c8f
# Conflicts: # USAGEGUIDE.md # cmd/main.go # pkg/onepassword/client/client.go # pkg/onepassword/items.go
57 lines
1.9 KiB
Go
57 lines
1.9 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"os"
|
|
|
|
"github.com/go-logr/logr"
|
|
|
|
"github.com/1Password/onepassword-operator/pkg/onepassword/client/connect"
|
|
"github.com/1Password/onepassword-operator/pkg/onepassword/client/sdk"
|
|
"github.com/1Password/onepassword-operator/pkg/onepassword/model"
|
|
)
|
|
|
|
// Client is an interface for interacting with 1Password items and vaults.
|
|
type Client interface {
|
|
GetItemByID(ctx context.Context, vaultID, itemID string) (*model.Item, error)
|
|
GetItemsByTitle(ctx context.Context, vaultID, itemTitle string) ([]model.Item, error)
|
|
GetFileContent(ctx context.Context, vaultID, itemID, fileID string) ([]byte, error)
|
|
GetVaultsByTitle(ctx context.Context, title string) ([]model.Vault, error)
|
|
}
|
|
|
|
type Config struct {
|
|
Logger logr.Logger
|
|
Version string
|
|
}
|
|
|
|
// NewFromEnvironment creates a new 1Password client based on the provided configuration.
|
|
func NewFromEnvironment(ctx context.Context, cfg Config) (Client, error) {
|
|
connectHost, _ := os.LookupEnv("OP_CONNECT_HOST")
|
|
connectToken, _ := os.LookupEnv("OP_CONNECT_TOKEN")
|
|
serviceAccountToken, _ := os.LookupEnv("OP_SERVICE_ACCOUNT_TOKEN")
|
|
|
|
if connectHost != "" && connectToken != "" && serviceAccountToken != "" {
|
|
return nil, errors.New("invalid configuration. Either Connect or Service Account credentials should be set, not both")
|
|
}
|
|
|
|
if serviceAccountToken != "" {
|
|
cfg.Logger.Info("Using Service Account Token")
|
|
return sdk.NewClient(ctx, sdk.Config{
|
|
ServiceAccountToken: serviceAccountToken,
|
|
IntegrationName: "1password-operator",
|
|
IntegrationVersion: cfg.Version,
|
|
})
|
|
}
|
|
|
|
if connectHost != "" && connectToken != "" {
|
|
cfg.Logger.Info("Using 1Password Connect")
|
|
return connect.NewClient(connect.Config{
|
|
ConnectHost: connectHost,
|
|
ConnectToken: connectToken,
|
|
}), nil
|
|
}
|
|
|
|
return nil, errors.New("invalid configuration. Connect or Service Account credentials should be set")
|
|
}
|