|
3 | 3 | use Dapr\Actors\ActorConfig;
|
4 | 4 | use Dapr\Actors\ActorProxy;
|
5 | 5 | use Dapr\Actors\ActorRuntime;
|
| 6 | +use Dapr\Actors\ActorState; |
| 7 | +use Dapr\Actors\Generators\CachedGenerator; |
| 8 | +use Dapr\Actors\Generators\DynamicGenerator; |
| 9 | +use Dapr\Actors\Generators\ExistingOnly; |
| 10 | +use Dapr\Actors\Generators\FileGenerator; |
6 | 11 | use Dapr\Actors\Generators\ProxyFactory;
|
| 12 | +use Dapr\App; |
7 | 13 | use Dapr\DaprClient;
|
8 | 14 | use Dapr\Deserialization\DeserializationConfig;
|
9 | 15 | use Dapr\Deserialization\Deserializer;
|
10 | 16 | use Dapr\Deserialization\IDeserializer;
|
11 | 17 | use Dapr\PubSub\Publish;
|
12 | 18 | use Dapr\PubSub\Subscriptions;
|
| 19 | +use Dapr\PubSub\Topic; |
| 20 | +use Dapr\SecretManager; |
13 | 21 | use Dapr\Serialization\ISerializer;
|
14 | 22 | use Dapr\Serialization\SerializationConfig;
|
15 | 23 | use Dapr\Serialization\Serializer;
|
16 | 24 | use Dapr\State\IManageState;
|
17 | 25 | use Dapr\State\StateManager;
|
| 26 | +use Dapr\State\TransactionalState; |
18 | 27 | use Monolog\Handler\ErrorLogHandler;
|
19 | 28 | use Monolog\Logger;
|
20 | 29 | use Monolog\Processor\PsrLogMessageProcessor;
|
|
35 | 44 | ),
|
36 | 45 | ],
|
37 | 46 | 'dapr.log.processor' => [create(PsrLogMessageProcessor::class)],
|
38 |
| - |
39 |
| - // interface to implementation |
40 |
| - LoggerInterface::class => create(Logger::class)->constructor( |
| 47 | + 'dapr.logger' => create(Logger::class)->constructor( |
41 | 48 | 'DAPR',
|
42 | 49 | get('dapr.log.handler'),
|
43 | 50 | get('dapr.log.processor')
|
44 | 51 | ),
|
45 |
| - IDeserializer::class => autowire(Deserializer::class), |
46 |
| - ISerializer::class => autowire(Serializer::class), |
47 |
| - IManageState::class => autowire(StateManager::class), |
48 |
| - ProxyFactory::class => autowire()->constructorParameter( |
49 |
| - 'mode', |
50 |
| - get('dapr.actors.proxy.generation') |
51 |
| - ), |
52 |
| - Subscriptions::class => autowire()->constructorParameter( |
53 |
| - 'subscriptions', |
54 |
| - get('dapr.subscriptions') |
| 52 | + |
| 53 | + // default logger to prevent breaking existing code |
| 54 | + LoggerInterface::class => create(Logger::class)->constructor( |
| 55 | + 'APP', |
| 56 | + get('dapr.log.handler'), |
| 57 | + get('dapr.log.processor') |
55 | 58 | ),
|
| 59 | + |
| 60 | + // SDK wiring |
56 | 61 | ActorConfig::class => autowire()
|
57 | 62 | ->constructorParameter('actor_name_to_type', get('dapr.actors'))
|
58 | 63 | ->constructorParameter('idle_timeout', get('dapr.actors.idle_timeout'))
|
59 | 64 | ->constructorParameter('scan_interval', get('dapr.actors.scan_interval'))
|
60 | 65 | ->constructorParameter('drain_timeout', get('dapr.actors.drain_timeout'))
|
61 | 66 | ->constructorParameter('drain_enabled', get('dapr.actors.drain_enabled')),
|
62 |
| - DaprClient::class => autowire()->constructorParameter('port', get('dapr.port')), |
63 |
| - SerializationConfig::class => autowire()->constructorParameter('serializers', get('dapr.serializers.custom')), |
| 67 | + ActorRuntime::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 68 | + ActorState::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 69 | + ActorProxy::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 70 | + App::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 71 | + CachedGenerator::class => autowire(), |
| 72 | + DynamicGenerator::class => autowire(), |
| 73 | + DaprClient::class => autowire() |
| 74 | + ->constructorParameter('port', get('dapr.port')) |
| 75 | + ->constructorParameter('logger', get('dapr.logger')), |
64 | 76 | DeserializationConfig::class => autowire()->constructorParameter(
|
65 | 77 | 'deserializers',
|
66 | 78 | get('dapr.deserializers.custom')
|
67 | 79 | ),
|
68 |
| - ActorProxy::class => autowire(), |
| 80 | + ExistingOnly::class => autowire(), |
| 81 | + FileGenerator::class => autowire(), |
| 82 | + IDeserializer::class => autowire(Deserializer::class)->constructorParameter('logger', get('dapr.logger')), |
| 83 | + IManageState::class => autowire(StateManager::class)->constructorParameter('logger', get('dapr.logger')), |
| 84 | + ISerializer::class => autowire(Serializer::class)->constructorParameter('logger', get('dapr.logger')), |
| 85 | + ProxyFactory::class => autowire()->constructorParameter( |
| 86 | + 'mode', |
| 87 | + get('dapr.actors.proxy.generation') |
| 88 | + ), |
69 | 89 | Publish::class => autowire()->constructorParameter('pubsub', get('dapr.pubsub.default')),
|
70 |
| - ActorRuntime::class => autowire(), |
| 90 | + SecretManager::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 91 | + SerializationConfig::class => autowire()->constructorParameter('serializers', get('dapr.serializers.custom')), |
| 92 | + Subscriptions::class => autowire()->constructorParameter( |
| 93 | + 'subscriptions', |
| 94 | + get('dapr.subscriptions') |
| 95 | + ), |
| 96 | + Topic::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
| 97 | + TransactionalState::class => autowire()->constructorParameter('logger', get('dapr.logger')), |
71 | 98 |
|
72 | 99 | // default application settings
|
73 | 100 | 'dapr.pubsub.default' => 'pubsub',
|
|
0 commit comments