mirror of
https://github.com/langgenius/dify.git
synced 2026-01-14 06:07:33 +08:00
72f9e77368
- Remove unused classes and imports in encryption utilities - Simplify method signatures for better readability - Enhance code quality by adding newlines for clarity - Update tests to reflect changes in import paths Co-authored-by: Claude <noreply@anthropic.com>
58 lines
2.2 KiB
Python
58 lines
2.2 KiB
Python
from typing import Union
|
|
|
|
from core.helper.provider_cache import TriggerProviderCredentialCache, TriggerProviderOAuthClientCache
|
|
from core.helper.provider_encryption import ProviderConfigCache, ProviderConfigEncrypter, create_provider_encrypter
|
|
from core.plugin.entities.plugin_daemon import CredentialType
|
|
from core.trigger.entities.api_entities import TriggerProviderCredentialApiEntity
|
|
from core.trigger.provider import PluginTriggerProviderController
|
|
from models.trigger import TriggerProvider
|
|
|
|
|
|
def create_trigger_provider_encrypter_for_credential(
|
|
tenant_id: str,
|
|
controller: PluginTriggerProviderController,
|
|
credential: Union[TriggerProvider, TriggerProviderCredentialApiEntity],
|
|
) -> tuple[ProviderConfigEncrypter, ProviderConfigCache]:
|
|
cache = TriggerProviderCredentialCache(
|
|
tenant_id=tenant_id,
|
|
provider_id=str(controller.get_provider_id()),
|
|
credential_id=credential.id,
|
|
)
|
|
encrypter, _ = create_provider_encrypter(
|
|
tenant_id=tenant_id,
|
|
config=controller.get_credential_schema_config(credential.credential_type),
|
|
cache=cache,
|
|
)
|
|
return encrypter, cache
|
|
|
|
|
|
def create_trigger_provider_encrypter(
|
|
tenant_id: str, controller: PluginTriggerProviderController, credential_id: str, credential_type: CredentialType
|
|
) -> tuple[ProviderConfigEncrypter, ProviderConfigCache]:
|
|
cache = TriggerProviderCredentialCache(
|
|
tenant_id=tenant_id,
|
|
provider_id=str(controller.get_provider_id()),
|
|
credential_id=credential_id,
|
|
)
|
|
encrypter, _ = create_provider_encrypter(
|
|
tenant_id=tenant_id,
|
|
config=controller.get_credential_schema_config(credential_type),
|
|
cache=cache,
|
|
)
|
|
return encrypter, cache
|
|
|
|
|
|
def create_trigger_provider_oauth_encrypter(
|
|
tenant_id: str, controller: PluginTriggerProviderController
|
|
) -> tuple[ProviderConfigEncrypter, ProviderConfigCache]:
|
|
cache = TriggerProviderOAuthClientCache(
|
|
tenant_id=tenant_id,
|
|
provider_id=str(controller.get_provider_id()),
|
|
)
|
|
encrypter, _ = create_provider_encrypter(
|
|
tenant_id=tenant_id,
|
|
config=[x.to_basic_provider_config() for x in controller.get_oauth_client_schema()],
|
|
cache=cache,
|
|
)
|
|
return encrypter, cache
|