package revaconfig

import (
	"github.com/opencloud-eu/opencloud/services/storage-users/pkg/config"
)

// EOS is the config mapping for the EOS storage driver
func EOS(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"namespace":              cfg.Drivers.EOS.Root,
		"shadow_namespace":       cfg.Drivers.EOS.ShadowNamespace,
		"uploads_namespace":      cfg.Drivers.EOS.UploadsNamespace,
		"share_folder":           cfg.Drivers.EOS.ShareFolder,
		"eos_binary":             cfg.Drivers.EOS.EosBinary,
		"xrdcopy_binary":         cfg.Drivers.EOS.XrdcopyBinary,
		"master_url":             cfg.Drivers.EOS.MasterURL,
		"slave_url":              cfg.Drivers.EOS.SlaveURL,
		"cache_directory":        cfg.Drivers.EOS.CacheDirectory,
		"sec_protocol":           cfg.Drivers.EOS.SecProtocol,
		"keytab":                 cfg.Drivers.EOS.Keytab,
		"single_username":        cfg.Drivers.EOS.SingleUsername,
		"enable_logging":         cfg.Drivers.EOS.EnableLogging,
		"show_hidden_sys_files":  cfg.Drivers.EOS.ShowHiddenSysFiles,
		"force_single_user_mode": cfg.Drivers.EOS.ForceSingleUserMode,
		"use_keytab":             cfg.Drivers.EOS.UseKeytab,
		"gatewaysvc":             cfg.Drivers.EOS.GatewaySVC,
	}
}

// EOSHome is the config mapping for the EOSHome storage driver
func EOSHome(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"namespace":              cfg.Drivers.EOS.Root,
		"shadow_namespace":       cfg.Drivers.EOS.ShadowNamespace,
		"uploads_namespace":      cfg.Drivers.EOS.UploadsNamespace,
		"share_folder":           cfg.Drivers.EOS.ShareFolder,
		"eos_binary":             cfg.Drivers.EOS.EosBinary,
		"xrdcopy_binary":         cfg.Drivers.EOS.XrdcopyBinary,
		"master_url":             cfg.Drivers.EOS.MasterURL,
		"slave_url":              cfg.Drivers.EOS.SlaveURL,
		"cache_directory":        cfg.Drivers.EOS.CacheDirectory,
		"sec_protocol":           cfg.Drivers.EOS.SecProtocol,
		"keytab":                 cfg.Drivers.EOS.Keytab,
		"single_username":        cfg.Drivers.EOS.SingleUsername,
		"user_layout":            cfg.Drivers.EOS.UserLayout,
		"enable_logging":         cfg.Drivers.EOS.EnableLogging,
		"show_hidden_sys_files":  cfg.Drivers.EOS.ShowHiddenSysFiles,
		"force_single_user_mode": cfg.Drivers.EOS.ForceSingleUserMode,
		"use_keytab":             cfg.Drivers.EOS.UseKeytab,
		"gatewaysvc":             cfg.Drivers.EOS.GatewaySVC,
	}
}

// EOSGRPC is the config mapping for the EOSGRPC storage driver
func EOSGRPC(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"namespace":              cfg.Drivers.EOS.Root,
		"shadow_namespace":       cfg.Drivers.EOS.ShadowNamespace,
		"share_folder":           cfg.Drivers.EOS.ShareFolder,
		"eos_binary":             cfg.Drivers.EOS.EosBinary,
		"xrdcopy_binary":         cfg.Drivers.EOS.XrdcopyBinary,
		"master_url":             cfg.Drivers.EOS.MasterURL,
		"master_grpc_uri":        cfg.Drivers.EOS.GRPCURI,
		"slave_url":              cfg.Drivers.EOS.SlaveURL,
		"cache_directory":        cfg.Drivers.EOS.CacheDirectory,
		"sec_protocol":           cfg.Drivers.EOS.SecProtocol,
		"keytab":                 cfg.Drivers.EOS.Keytab,
		"single_username":        cfg.Drivers.EOS.SingleUsername,
		"user_layout":            cfg.Drivers.EOS.UserLayout,
		"enable_logging":         cfg.Drivers.EOS.EnableLogging,
		"show_hidden_sys_files":  cfg.Drivers.EOS.ShowHiddenSysFiles,
		"force_single_user_mode": cfg.Drivers.EOS.ForceSingleUserMode,
		"use_keytab":             cfg.Drivers.EOS.UseKeytab,
		"enable_home":            false,
		"gatewaysvc":             cfg.Drivers.EOS.GatewaySVC,
	}
}

// Local is the config mapping for the Local storage driver
func Local(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"root":         cfg.Drivers.Local.Root,
		"share_folder": cfg.Drivers.Local.ShareFolder,
	}
}

// Posix is the config mapping for the Posix storage driver
func Posix(cfg *config.Config, enableFSScan, enableFSWatch bool) map[string]interface{} {
	return map[string]interface{}{
		"root":                        cfg.Drivers.Posix.Root,
		"personalspacepath_template":  cfg.Drivers.Posix.PersonalSpacePathTemplate,
		"personalspacealias_template": cfg.Drivers.Posix.PersonalSpaceAliasTemplate,
		"generalspacepath_template":   cfg.Drivers.Posix.GeneralSpacePathTemplate,
		"generalspacealias_template":  cfg.Drivers.Posix.GeneralSpaceAliasTemplate,
		"permissionssvc":              cfg.Drivers.Posix.PermissionsEndpoint,
		"permissionssvc_tls_mode":     cfg.Commons.GRPCClientTLS.Mode,
		"treetime_accounting":         true,
		"treesize_accounting":         true,
		"asyncfileuploads":            cfg.Drivers.Posix.AsyncUploads,
		"scan_debounce_delay":         cfg.Drivers.Posix.ScanDebounceDelay,
		"max_quota":                   cfg.Drivers.Posix.MaxQuota,
		"disable_versioning":          cfg.Drivers.Posix.DisableVersioning,
		"propagator":                  cfg.Drivers.Posix.Propagator,
		"async_propagator_options": map[string]interface{}{
			"propagation_delay": cfg.Drivers.Posix.AsyncPropagatorOptions.PropagationDelay,
		},
		"max_acquire_lock_cycles":    cfg.Drivers.Posix.MaxAcquireLockCycles,
		"lock_cycle_duration_factor": cfg.Drivers.Posix.LockCycleDurationFactor,
		"max_concurrency":            cfg.Drivers.Posix.MaxConcurrency,
		"idcache": map[string]interface{}{
			"cache_store":               cfg.IDCache.Store,
			"cache_nodes":               cfg.IDCache.Nodes,
			"cache_database":            cfg.IDCache.Database,
			"cache_ttl":                 cfg.IDCache.TTL,
			"cache_disable_persistence": cfg.IDCache.DisablePersistence,
			"cache_auth_username":       cfg.IDCache.AuthUsername,
			"cache_auth_password":       cfg.IDCache.AuthPassword,
		},
		"filemetadatacache": map[string]interface{}{
			"cache_store":               cfg.FilemetadataCache.Store,
			"cache_nodes":               cfg.FilemetadataCache.Nodes,
			"cache_database":            cfg.FilemetadataCache.Database,
			"cache_ttl":                 cfg.FilemetadataCache.TTL,
			"cache_disable_persistence": cfg.FilemetadataCache.DisablePersistence,
			"cache_auth_username":       cfg.FilemetadataCache.AuthUsername,
			"cache_auth_password":       cfg.FilemetadataCache.AuthPassword,
		},
		"events": map[string]interface{}{
			"numconsumers": cfg.Events.NumConsumers,
		},
		"tokens": map[string]interface{}{
			"transfer_shared_secret": cfg.Commons.TransferSecret,
			"transfer_expires":       cfg.TransferExpires,
			"download_endpoint":      cfg.DataServerURL,
			"datagateway_endpoint":   cfg.DataGatewayURL,
		},
		"use_space_groups":           cfg.Drivers.Posix.UseSpaceGroups,
		"enable_fs_revisions":        cfg.Drivers.Posix.EnableFSRevisions,
		"scan_fs":                    enableFSScan,
		"watch_fs":                   enableFSWatch,
		"watch_type":                 cfg.Drivers.Posix.WatchType,
		"watch_path":                 cfg.Drivers.Posix.WatchPath,
		"watch_notification_brokers": cfg.Drivers.Posix.WatchNotificationBrokers,
		"watch_root":                 cfg.Drivers.Posix.WatchRoot,
		"inotify_stats_frequency":    cfg.Drivers.Posix.InotifyStatsFrequency,
	}
}

// LocalHome is the config mapping for the LocalHome storage driver
func LocalHome(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"root":         cfg.Drivers.Local.Root,
		"share_folder": cfg.Drivers.Local.ShareFolder,
		"user_layout":  cfg.Drivers.Local.UserLayout,
	}
}

// OwnCloudSQL is the config mapping for the OwnCloudSQL storage driver
func OwnCloudSQL(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"datadirectory":   cfg.Drivers.OwnCloudSQL.Root,
		"upload_info_dir": cfg.Drivers.OwnCloudSQL.UploadInfoDir,
		"share_folder":    cfg.Drivers.OwnCloudSQL.ShareFolder,
		"user_layout":     cfg.Drivers.OwnCloudSQL.UserLayout,
		"enable_home":     false,
		"dbusername":      cfg.Drivers.OwnCloudSQL.DBUsername,
		"dbpassword":      cfg.Drivers.OwnCloudSQL.DBPassword,
		"dbhost":          cfg.Drivers.OwnCloudSQL.DBHost,
		"dbport":          cfg.Drivers.OwnCloudSQL.DBPort,
		"dbname":          cfg.Drivers.OwnCloudSQL.DBName,
		"userprovidersvc": cfg.Drivers.OwnCloudSQL.UsersProviderEndpoint,
		"tokens": map[string]interface{}{
			"download_endpoint":      cfg.DataServerURL,
			"datagateway_endpoint":   cfg.DataGatewayURL,
			"transfer_shared_secret": cfg.Commons.TransferSecret,
			"transfer_expires":       cfg.TransferExpires,
		},
	}
}

// Decomposed is the config mapping for the Decomposed storage driver
func Decomposed(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"metadata_backend": "messagepack",
		"propagator":       cfg.Drivers.Decomposed.Propagator,
		"async_propagator_options": map[string]interface{}{
			"propagation_delay": cfg.Drivers.Decomposed.AsyncPropagatorOptions.PropagationDelay,
		},
		"root":                        cfg.Drivers.Decomposed.Root,
		"user_layout":                 cfg.Drivers.Decomposed.UserLayout,
		"share_folder":                cfg.Drivers.Decomposed.ShareFolder,
		"personalspacealias_template": cfg.Drivers.Decomposed.PersonalSpaceAliasTemplate,
		"personalspacepath_template":  cfg.Drivers.Decomposed.PersonalSpacePathTemplate,
		"generalspacealias_template":  cfg.Drivers.Decomposed.GeneralSpaceAliasTemplate,
		"generalspacepath_template":   cfg.Drivers.Decomposed.GeneralSpacePathTemplate,
		"treetime_accounting":         true,
		"treesize_accounting":         true,
		"permissionssvc":              cfg.Drivers.Decomposed.PermissionsEndpoint,
		"permissionssvc_tls_mode":     cfg.Commons.GRPCClientTLS.Mode,
		"max_acquire_lock_cycles":     cfg.Drivers.Decomposed.MaxAcquireLockCycles,
		"lock_cycle_duration_factor":  cfg.Drivers.Decomposed.LockCycleDurationFactor,
		"max_concurrency":             cfg.Drivers.Decomposed.MaxConcurrency,
		"asyncfileuploads":            cfg.Drivers.Decomposed.AsyncUploads,
		"max_quota":                   cfg.Drivers.Decomposed.MaxQuota,
		"disable_versioning":          cfg.Drivers.Decomposed.DisableVersioning,
		"filemetadatacache": map[string]interface{}{
			"cache_store":               cfg.FilemetadataCache.Store,
			"cache_nodes":               cfg.FilemetadataCache.Nodes,
			"cache_database":            cfg.FilemetadataCache.Database,
			"cache_ttl":                 cfg.FilemetadataCache.TTL,
			"cache_disable_persistence": cfg.FilemetadataCache.DisablePersistence,
			"cache_auth_username":       cfg.FilemetadataCache.AuthUsername,
			"cache_auth_password":       cfg.FilemetadataCache.AuthPassword,
		},
		"idcache": map[string]interface{}{
			"cache_store":               cfg.IDCache.Store,
			"cache_nodes":               cfg.IDCache.Nodes,
			"cache_database":            cfg.IDCache.Database,
			"cache_ttl":                 cfg.IDCache.TTL,
			"cache_disable_persistence": cfg.IDCache.DisablePersistence,
			"cache_auth_username":       cfg.IDCache.AuthUsername,
			"cache_auth_password":       cfg.IDCache.AuthPassword,
		},
		"events": map[string]interface{}{
			"numconsumers": cfg.Events.NumConsumers,
		},
		"tokens": map[string]interface{}{
			"transfer_shared_secret": cfg.Commons.TransferSecret,
			"transfer_expires":       cfg.TransferExpires,
			"download_endpoint":      cfg.DataServerURL,
			"datagateway_endpoint":   cfg.DataGatewayURL,
		},
	}
}

// DecomposedsNoEvents is the config mapping for the Decomposed storage driver emitting no events
func DecomposedNoEvents(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"metadata_backend": "messagepack",
		"propagator":       cfg.Drivers.Decomposed.Propagator,
		"async_propagator_options": map[string]interface{}{
			"propagation_delay": cfg.Drivers.Decomposed.AsyncPropagatorOptions.PropagationDelay,
		},
		"root":                        cfg.Drivers.Decomposed.Root,
		"user_layout":                 cfg.Drivers.Decomposed.UserLayout,
		"share_folder":                cfg.Drivers.Decomposed.ShareFolder,
		"personalspacealias_template": cfg.Drivers.Decomposed.PersonalSpaceAliasTemplate,
		"personalspacepath_template":  cfg.Drivers.Decomposed.PersonalSpacePathTemplate,
		"generalspacealias_template":  cfg.Drivers.Decomposed.GeneralSpaceAliasTemplate,
		"generalspacepath_template":   cfg.Drivers.Decomposed.GeneralSpacePathTemplate,
		"treetime_accounting":         true,
		"treesize_accounting":         true,
		"permissionssvc":              cfg.Drivers.Decomposed.PermissionsEndpoint,
		"permissionssvc_tls_mode":     cfg.Commons.GRPCClientTLS.Mode,
		"max_acquire_lock_cycles":     cfg.Drivers.Decomposed.MaxAcquireLockCycles,
		"lock_cycle_duration_factor":  cfg.Drivers.Decomposed.LockCycleDurationFactor,
		"max_concurrency":             cfg.Drivers.Decomposed.MaxConcurrency,
		"max_quota":                   cfg.Drivers.Decomposed.MaxQuota,
		"disable_versioning":          cfg.Drivers.Decomposed.DisableVersioning,
		"filemetadatacache": map[string]interface{}{
			"cache_store":               cfg.FilemetadataCache.Store,
			"cache_nodes":               cfg.FilemetadataCache.Nodes,
			"cache_database":            cfg.FilemetadataCache.Database,
			"cache_ttl":                 cfg.FilemetadataCache.TTL,
			"cache_disable_persistence": cfg.FilemetadataCache.DisablePersistence,
			"cache_auth_username":       cfg.FilemetadataCache.AuthUsername,
			"cache_auth_password":       cfg.FilemetadataCache.AuthPassword,
		},
		"idcache": map[string]interface{}{
			"cache_store":               cfg.IDCache.Store,
			"cache_nodes":               cfg.IDCache.Nodes,
			"cache_database":            cfg.IDCache.Database,
			"cache_ttl":                 cfg.IDCache.TTL,
			"cache_disable_persistence": cfg.IDCache.DisablePersistence,
			"cache_auth_username":       cfg.IDCache.AuthUsername,
			"cache_auth_password":       cfg.IDCache.AuthPassword,
		},
	}
}

// S3 is the config mapping for the s3 storage driver
func S3(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"enable_home": false,
		"region":      cfg.Drivers.S3.Region,
		"access_key":  cfg.Drivers.S3.AccessKey,
		"secret_key":  cfg.Drivers.S3.SecretKey,
		"endpoint":    cfg.Drivers.S3.Endpoint,
		"bucket":      cfg.Drivers.S3.Bucket,
		"prefix":      cfg.Drivers.S3.Root,
	}
}

// DecomposedS3 is the config mapping for the decomposeds3 storage driver
func DecomposedS3(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"metadata_backend": "messagepack",
		"propagator":       cfg.Drivers.DecomposedS3.Propagator,
		"async_propagator_options": map[string]interface{}{
			"propagation_delay": cfg.Drivers.DecomposedS3.AsyncPropagatorOptions.PropagationDelay,
		},
		"root":                        cfg.Drivers.DecomposedS3.Root,
		"user_layout":                 cfg.Drivers.DecomposedS3.UserLayout,
		"share_folder":                cfg.Drivers.DecomposedS3.ShareFolder,
		"personalspacealias_template": cfg.Drivers.DecomposedS3.PersonalSpaceAliasTemplate,
		"personalspacepath_template":  cfg.Drivers.DecomposedS3.PersonalSpacePathTemplate,
		"generalspacealias_template":  cfg.Drivers.DecomposedS3.GeneralSpaceAliasTemplate,
		"generalspacepath_template":   cfg.Drivers.DecomposedS3.GeneralSpacePathTemplate,
		"treetime_accounting":         true,
		"treesize_accounting":         true,
		"permissionssvc":              cfg.Drivers.DecomposedS3.PermissionsEndpoint,
		"permissionssvc_tls_mode":     cfg.Commons.GRPCClientTLS.Mode,
		"s3.region":                   cfg.Drivers.DecomposedS3.Region,
		"s3.access_key":               cfg.Drivers.DecomposedS3.AccessKey,
		"s3.secret_key":               cfg.Drivers.DecomposedS3.SecretKey,
		"s3.endpoint":                 cfg.Drivers.DecomposedS3.Endpoint,
		"s3.bucket":                   cfg.Drivers.DecomposedS3.Bucket,
		"s3.disable_content_sha254":   cfg.Drivers.DecomposedS3.DisableContentSha256,
		"s3.disable_multipart":        cfg.Drivers.DecomposedS3.DisableMultipart,
		"s3.send_content_md5":         cfg.Drivers.DecomposedS3.SendContentMd5,
		"s3.concurrent_stream_parts":  cfg.Drivers.DecomposedS3.ConcurrentStreamParts,
		"s3.num_threads":              cfg.Drivers.DecomposedS3.NumThreads,
		"s3.part_size":                cfg.Drivers.DecomposedS3.PartSize,
		"max_acquire_lock_cycles":     cfg.Drivers.DecomposedS3.MaxAcquireLockCycles,
		"lock_cycle_duration_factor":  cfg.Drivers.DecomposedS3.LockCycleDurationFactor,
		"max_concurrency":             cfg.Drivers.DecomposedS3.MaxConcurrency,
		"disable_versioning":          cfg.Drivers.DecomposedS3.DisableVersioning,
		"asyncfileuploads":            cfg.Drivers.DecomposedS3.AsyncUploads,
		"filemetadatacache": map[string]interface{}{
			"cache_store":               cfg.FilemetadataCache.Store,
			"cache_nodes":               cfg.FilemetadataCache.Nodes,
			"cache_database":            cfg.FilemetadataCache.Database,
			"cache_ttl":                 cfg.FilemetadataCache.TTL,
			"cache_disable_persistence": cfg.FilemetadataCache.DisablePersistence,
			"cache_auth_username":       cfg.FilemetadataCache.AuthUsername,
			"cache_auth_password":       cfg.FilemetadataCache.AuthPassword,
		},
		"idcache": map[string]interface{}{
			"cache_store":               cfg.IDCache.Store,
			"cache_nodes":               cfg.IDCache.Nodes,
			"cache_database":            cfg.IDCache.Database,
			"cache_ttl":                 cfg.IDCache.TTL,
			"cache_disable_persistence": cfg.IDCache.DisablePersistence,
			"cache_auth_username":       cfg.IDCache.AuthUsername,
			"cache_auth_password":       cfg.IDCache.AuthPassword,
		},
		"events": map[string]interface{}{
			"numconsumers": cfg.Events.NumConsumers,
		},
		"tokens": map[string]interface{}{
			"transfer_shared_secret": cfg.Commons.TransferSecret,
			"transfer_expires":       cfg.TransferExpires,
			"download_endpoint":      cfg.DataServerURL,
			"datagateway_endpoint":   cfg.DataGatewayURL,
		},
	}
}

// DecomposedS3NoEvents is the config mapping for the decomposeds3 storage driver emitting no events
func DecomposedS3NoEvents(cfg *config.Config) map[string]interface{} {
	return map[string]interface{}{
		"metadata_backend": "messagepack",
		"propagator":       cfg.Drivers.DecomposedS3.Propagator,
		"async_propagator_options": map[string]interface{}{
			"propagation_delay": cfg.Drivers.DecomposedS3.AsyncPropagatorOptions.PropagationDelay,
		},
		"root":                        cfg.Drivers.DecomposedS3.Root,
		"user_layout":                 cfg.Drivers.DecomposedS3.UserLayout,
		"share_folder":                cfg.Drivers.DecomposedS3.ShareFolder,
		"personalspacealias_template": cfg.Drivers.Decomposed.PersonalSpaceAliasTemplate,
		"personalspacepath_template":  cfg.Drivers.Decomposed.PersonalSpacePathTemplate,
		"generalspacealias_template":  cfg.Drivers.Decomposed.GeneralSpaceAliasTemplate,
		"generalspacepath_template":   cfg.Drivers.Decomposed.GeneralSpacePathTemplate,
		"treetime_accounting":         true,
		"treesize_accounting":         true,
		"permissionssvc":              cfg.Drivers.DecomposedS3.PermissionsEndpoint,
		"permissionssvc_tls_mode":     cfg.Commons.GRPCClientTLS.Mode,
		"s3.region":                   cfg.Drivers.DecomposedS3.Region,
		"s3.access_key":               cfg.Drivers.DecomposedS3.AccessKey,
		"s3.secret_key":               cfg.Drivers.DecomposedS3.SecretKey,
		"s3.endpoint":                 cfg.Drivers.DecomposedS3.Endpoint,
		"s3.bucket":                   cfg.Drivers.DecomposedS3.Bucket,
		"max_acquire_lock_cycles":     cfg.Drivers.DecomposedS3.MaxAcquireLockCycles,
		"max_concurrency":             cfg.Drivers.DecomposedS3.MaxConcurrency,
		"disable_versioning":          cfg.Drivers.DecomposedS3.DisableVersioning,
		"lock_cycle_duration_factor":  cfg.Drivers.DecomposedS3.LockCycleDurationFactor,
		"filemetadatacache": map[string]interface{}{
			"cache_store":               cfg.FilemetadataCache.Store,
			"cache_nodes":               cfg.FilemetadataCache.Nodes,
			"cache_database":            cfg.FilemetadataCache.Database,
			"cache_ttl":                 cfg.FilemetadataCache.TTL,
			"cache_disable_persistence": cfg.FilemetadataCache.DisablePersistence,
			"cache_auth_username":       cfg.FilemetadataCache.AuthUsername,
			"cache_auth_password":       cfg.FilemetadataCache.AuthPassword,
		},
		"idcache": map[string]interface{}{
			"cache_store":               cfg.IDCache.Store,
			"cache_nodes":               cfg.IDCache.Nodes,
			"cache_database":            cfg.IDCache.Database,
			"cache_ttl":                 cfg.IDCache.TTL,
			"cache_disable_persistence": cfg.IDCache.DisablePersistence,
			"cache_auth_username":       cfg.IDCache.AuthUsername,
			"cache_auth_password":       cfg.IDCache.AuthPassword,
		},
	}
}