feat: Add the ability to manage channels and send broadcasts

README.md

@@ -195,7 +195,7 @@ This will result in the following notification payload being sent to the device.
 ```
 
 ## Manage Channels
-Live Activities can be used to broadcast push notifications over channels. To do so, you will need your apps' `bundleId`. 
+Starting in iOS 18 and iPadOS 18 Live Activities can be used to broadcast push notifications over channels. To do so, you will need your apps' `bundleId`. 
 
 ```javascript
 let bundleId = "com.node.apn";
@@ -252,7 +252,7 @@ After the promise is fulfilled, `result` will look like the following:
 Further information about managing channels can be found in [Apple's documentation](https://developer.apple.com/documentation/usernotifications/sending-channel-management-requests-to-apns).
 
 ## Sending A Broadcast Notification
-After a channel is created using `manageChannels`, broadcast push notifications can be sent to any device subscribed to the respective `channelId` created for a `bundleId`. A broadcast notification looks similar to a standard Live Activity notification mentioned above but requires `note.channelId` to be populated. An example is below:
+Starting in iOS 18 and iPadOS 18, after a channel is created using `manageChannels`, broadcast push notifications can be sent to any device subscribed to the respective `channelId` created for a `bundleId`. A broadcast notification looks similar to a standard Live Activity notification mentioned above but requires `note.channelId` to be populated. An example is below:
 
 ```javascript
 let note = new apn.Notification();

lib/client.js

@@ -60,7 +60,7 @@
       ) {
         this.manageChannelsSession.ping((error, duration) => {
           if (error && this.errorLogger.enabled) {
             this.errorLogger(
               'ManageChannelsSession No Ping response after ' +
                 duration +
                 ' ms with error:' +
@@ -215,7 +215,7 @@
               httpMethod,
               retryCount
             );
             return { ...subDirectoryInformation, ...resentRequest };
           } catch (error) {
             if (error.status == 500) {
               await this.closeAndDestroySession(this.manageChannelsSession);
@@ -272,7 +272,7 @@
               httpMethod,
               retryCount
             );
             return { ...subDirectoryInformation, ...resentRequest };
           } catch (error) {
             if (error.status == 500) {
               await this.closeAndDestroySession(this.session);
@@ -323,7 +323,7 @@
         httpMethod,
         retryCount
       );
       return sentRequest;
     } catch (error) {
       // Recursivelly call self until retryCount is exhausted
       // or error is thrown.
@@ -336,7 +336,7 @@
         httpMethod,
         retryCount
       );
       return sentRequest;
     }
   };
 
@@ -384,13 +384,6 @@
         this.destroySession(session);
       });
 
-      this.session.on('socketError', error => {
-        if (this.errorLogger.enabled) {
-          this.errorLogger(`Socket error: ${error}`);
-        }
-        this.closeAndDestroySession(session);
-      });
-
       this.session.on('error', error => {
         if (this.errorLogger.enabled) {
           this.errorLogger(`Session error: ${error}`);
@@ -471,10 +464,10 @@
       });
 
       this.manageChannelsSession.on('socketError', error => {
         if (this.errorLogger.enabled) {
           this.errorLogger(`ManageChannelsSession Socket error: ${error}`);
         }
         this.closeAndDestroySession(session);
       });
 
       this.manageChannelsSession.on('error', error => {
@@ -603,12 +596,12 @@
 
             if (status === 403 && response.reason === 'ExpiredProviderToken') {
               this.config.token.regenerate(tokenGeneration);
               const error = {
                 status,
                 retryAfter,
                 error: new VError(response.reason),
               };
               reject({ ...headerObject, ...error });
               return;
             } else if (status === 500 && response.reason === 'InternalServerError') {
               const error = {
@@ -655,8 +648,8 @@
 
         status = ABORTED_STATUS;
 
         const error = { error: new VError('apn write aborted') };
         reject(error);
       });
 
       request.on('error', error => {
@@ -676,12 +669,12 @@
       });
 
       request.on('frameError', (frameType, errorCode, streamId) => {
         const errorMessage = `Request frame error: (frameType: ${frameType}, errorCode ${errorCode}, streamId: ${streamId})`;
         if (this.errorLogger.enabled) {
           this.errorLogger(errorMessage);
         }
         const error = new VError(errorMessage);
         reject({ error });
       });
 
       request.end();