@@ -79,7 +79,7 @@ public static function getSubscribedEvents()
79
79
public function onSolariumNodeWorkflowComplete (Event $ event ): void
80
80
{
81
81
$ node = $ event ->getSubject ();
82
- if ($ node instanceof Node) {
82
+ if ($ node instanceof Node && null !== $ node -> getId () ) {
83
83
$ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Node::class, $ node ->getId ())));
84
84
}
85
85
}
@@ -93,7 +93,10 @@ public function onSolariumNodeWorkflowComplete(Event $event): void
93
93
*/
94
94
public function onSolariumSingleUpdate (NodesSourcesUpdatedEvent $ event )
95
95
{
96
- $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (NodesSources::class, $ event ->getNodeSource ()->getId ())));
96
+ $ id = $ event ->getNodeSource ()->getId ();
97
+ if (null !== $ id ) {
98
+ $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (NodesSources::class, $ id )));
99
+ }
97
100
}
98
101
99
102
/**
@@ -103,7 +106,10 @@ public function onSolariumSingleUpdate(NodesSourcesUpdatedEvent $event)
103
106
*/
104
107
public function onSolariumSingleDelete (NodesSourcesDeletedEvent $ event )
105
108
{
106
- $ this ->messageBus ->dispatch (new Envelope (new SolrDeleteMessage (NodesSources::class, $ event ->getNodeSource ()->getId ())));
109
+ $ id = $ event ->getNodeSource ()->getId ();
110
+ if (null !== $ id ) {
111
+ $ this ->messageBus ->dispatch (new Envelope (new SolrDeleteMessage (NodesSources::class, $ id )));
112
+ }
107
113
}
108
114
109
115
/**
@@ -113,7 +119,10 @@ public function onSolariumSingleDelete(NodesSourcesDeletedEvent $event)
113
119
*/
114
120
public function onSolariumNodeDelete (NodeDeletedEvent $ event )
115
121
{
116
- $ this ->messageBus ->dispatch (new Envelope (new SolrDeleteMessage (Node::class, $ event ->getNode ()->getId ())));
122
+ $ id = $ event ->getNode ()->getId ();
123
+ if (null !== $ id ) {
124
+ $ this ->messageBus ->dispatch (new Envelope (new SolrDeleteMessage (Node::class, $ id )));
125
+ }
117
126
}
118
127
119
128
/**
@@ -125,7 +134,10 @@ public function onSolariumNodeDelete(NodeDeletedEvent $event)
125
134
*/
126
135
public function onSolariumNodeUpdate (FilterNodeEvent $ event )
127
136
{
128
- $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Node::class, $ event ->getNode ()->getId ())));
137
+ $ id = $ event ->getNode ()->getId ();
138
+ if (null !== $ id ) {
139
+ $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Node::class, $ id )));
140
+ }
129
141
}
130
142
131
143
@@ -137,7 +149,7 @@ public function onSolariumNodeUpdate(FilterNodeEvent $event)
137
149
public function onSolariumDocumentDelete (FilterDocumentEvent $ event )
138
150
{
139
151
$ document = $ event ->getDocument ();
140
- if ($ document instanceof Document) {
152
+ if ($ document instanceof Document && null !== $ document -> getId () ) {
141
153
$ this ->messageBus ->dispatch (new Envelope (new SolrDeleteMessage (Document::class, $ document ->getId ())));
142
154
}
143
155
}
@@ -152,7 +164,7 @@ public function onSolariumDocumentDelete(FilterDocumentEvent $event)
152
164
public function onSolariumDocumentUpdate (FilterDocumentEvent $ event )
153
165
{
154
166
$ document = $ event ->getDocument ();
155
- if ($ document instanceof Document) {
167
+ if ($ document instanceof Document && null !== $ document -> getId () ) {
156
168
$ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Document::class, $ document ->getId ())));
157
169
}
158
170
}
@@ -167,7 +179,10 @@ public function onSolariumDocumentUpdate(FilterDocumentEvent $event)
167
179
*/
168
180
public function onSolariumTagUpdate (TagUpdatedEvent $ event )
169
181
{
170
- $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Tag::class, $ event ->getTag ()->getId ())));
182
+ $ id = $ event ->getTag ()->getId ();
183
+ if (null !== $ id ) {
184
+ $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Tag::class, $ id )));
185
+ }
171
186
}
172
187
173
188
/**
@@ -180,6 +195,9 @@ public function onSolariumTagUpdate(TagUpdatedEvent $event)
180
195
*/
181
196
public function onSolariumFolderUpdate (FolderUpdatedEvent $ event )
182
197
{
183
- $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Folder::class, $ event ->getFolder ()->getId ())));
198
+ $ id = $ event ->getFolder ()->getId ();
199
+ if (null !== $ id ) {
200
+ $ this ->messageBus ->dispatch (new Envelope (new SolrReindexMessage (Folder::class, $ id )));
201
+ }
184
202
}
185
203
}
0 commit comments