@@ -119,7 +119,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
119119 const { subscription } = response . result ;
120120 const subscriptionModel =
121121 this . _subscriptionModelStore . _getBySubscriptionId (
122- createOperation . subscriptionId ,
122+ createOperation . _subscriptionId ,
123123 ) ;
124124
125125 const backendSubscriptionId = subscription ?. id ;
@@ -149,7 +149,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
149149 : undefined ,
150150 backendSubscriptionId
151151 ? {
152- [ createOperation . subscriptionId ] : backendSubscriptionId ,
152+ [ createOperation . _subscriptionId ] : backendSubscriptionId ,
153153 }
154154 : undefined ,
155155 ) ;
@@ -221,7 +221,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
221221
222222 const response = await updateSubscriptionById (
223223 { appId : lastOp . _appId } ,
224- lastOp . subscriptionId ,
224+ lastOp . _subscriptionId ,
225225 subscription ,
226226 ) ;
227227
@@ -241,7 +241,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
241241 case ResponseStatusType . _Missing :
242242 if (
243243 status === 404 &&
244- [ lastOp . _onesignalId , lastOp . subscriptionId ] . some ( ( id ) =>
244+ [ lastOp . _onesignalId , lastOp . _subscriptionId ] . some ( ( id ) =>
245245 this . _newRecordState . _isInMissingRetryWindow ( id ) ,
246246 )
247247 ) {
@@ -257,7 +257,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
257257 enabled : lastOp . enabled ,
258258 notification_types : lastOp . notification_types ,
259259 onesignalId : lastOp . _onesignalId ,
260- subscriptionId : lastOp . subscriptionId ,
260+ subscriptionId : lastOp . _subscriptionId ,
261261 token : lastOp . token ,
262262 type : lastOp . type ,
263263 } ) ,
@@ -272,7 +272,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
272272 ) : Promise < ExecutionResponse > {
273273 const response = await transferSubscriptionById (
274274 { appId : op . _appId } ,
275- op . subscriptionId ,
275+ op . _subscriptionId ,
276276 { onesignal_id : op . _onesignalId } ,
277277 false ,
278278 ) ;
@@ -301,12 +301,12 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
301301 ) : Promise < ExecutionResponse > {
302302 const response = await deleteSubscriptionById (
303303 { appId : op . _appId } ,
304- op . subscriptionId ,
304+ op . _subscriptionId ,
305305 ) ;
306306
307307 if ( response . ok ) {
308308 this . _subscriptionModelStore . _remove (
309- op . subscriptionId ,
309+ op . _subscriptionId ,
310310 ModelChangeTags . _Hydrate ,
311311 ) ;
312312 return new ExecutionResponse ( ExecutionResult . _Success ) ;
@@ -318,7 +318,7 @@ export class SubscriptionOperationExecutor implements IOperationExecutor {
318318 switch ( type ) {
319319 case ResponseStatusType . _Missing :
320320 if (
321- [ op . _onesignalId , op . subscriptionId ] . some ( ( id ) =>
321+ [ op . _onesignalId , op . _subscriptionId ] . some ( ( id ) =>
322322 this . _newRecordState . _isInMissingRetryWindow ( id ) ,
323323 )
324324 ) {
0 commit comments