feat: integrate additional asset types for server

cli/server.go

@@ -86,6 +86,10 @@ func runServer(ctx context.Context, cfg *Config) error {
 	logger := initLogger(cfg.LogLevel)
 	logger.Info("compass starting", "version", Version)
 
+	if err := registerAdditionalAssetTypes(cfg.Service.AdditionalAssetTypes); err != nil {
+		return fmt.Errorf("error registering additional asset types: %w", err)
+	}
+
 	nrApp, cleanUp, err := telemetry.Init(ctx, cfg.Telemetry, logger)
 	if err != nil {
 		return err
@@ -259,3 +263,12 @@ func migratePostgres(ctx context.Context, logger log.Logger, config *Config) (er
 
 	return nil
 }
+
+func registerAdditionalAssetTypes(additionalTypes []string) error {
+	transformedTypes := make([]asset.Type, len(additionalTypes))
+	for i := range additionalTypes {
+		transformedTypes[i] = asset.Type(additionalTypes[i])
+	}
+
+	return asset.RegisterSupportedTypes(transformedTypes...)
+}

internal/server/server.go

@@ -40,6 +40,8 @@ type Config struct {
 	RequestTimeout time.Duration  `mapstructure:"request_timeout" default:"10s"`
 	// GRPC Config
 	GRPC GRPCConfig `mapstructure:"grpc"`
+
+	AdditionalAssetTypes []string `mapstructure:"additional_asset_types"`
 }
 
 func (cfg Config) addr() string     { return fmt.Sprintf("%s:%d", cfg.Host, cfg.Port) }