@@ -43,7 +43,11 @@ import Starscream
43
43
let reachability = try ? Reachability ( )
44
44
reachability? . whenReachable = { [ weak self] reachability in
45
45
guard let self = self else {
46
- print ( " Your Pusher instance has probably become deallocated. See https://github.com/pusher/pusher-websocket-swift/issues/109 for more information " )
46
+ print ( """
47
+ Your Pusher instance has probably become deallocated. \
48
+ See https://github.com/pusher/pusher-websocket-swift/issues/109 \
49
+ for more information
50
+ """ )
47
51
return
48
52
}
49
53
@@ -72,7 +76,11 @@ import Starscream
72
76
}
73
77
reachability? . whenUnreachable = { [ weak self] reachability in
74
78
guard let self = self else {
75
- print ( " Your Pusher instance has probably become deallocated. See https://github.com/pusher/pusher-websocket-swift/issues/109 for more information " )
79
+ print ( """
80
+ Your Pusher instance has probably become deallocated. \
81
+ See https://github.com/pusher/pusher-websocket-swift/issues/109 \
82
+ for more information
83
+ """ )
76
84
return
77
85
}
78
86
@@ -487,7 +495,8 @@ import Starscream
487
495
488
496
if PusherChannelType . isPresenceChannel ( name: channelName) {
489
497
if let presChan = self . channels. find ( name: channelName) as? PusherPresenceChannel {
490
- if let dataJSON = event. dataToJSONObject ( ) as? [ String : Any ] , let presenceData = dataJSON [ " presence " ] as? [ String : AnyObject ] ,
498
+ if let dataJSON = event. dataToJSONObject ( ) as? [ String : Any ] ,
499
+ let presenceData = dataJSON [ " presence " ] as? [ String : AnyObject ] ,
491
500
let presenceHash = presenceData [ " hash " ] as? [ String : AnyObject ] {
492
501
presChan. addExistingMembers ( memberHash: presenceHash)
493
502
}
@@ -524,7 +533,8 @@ import Starscream
524
533
self . reconnectAttempts = 0
525
534
self . reconnectTimer? . invalidate ( )
526
535
527
- if options. activityTimeout == nil , let activityTimeoutFromServer = connectionData [ " activity_timeout " ] as? TimeInterval {
536
+ if options. activityTimeout == nil ,
537
+ let activityTimeoutFromServer = connectionData [ " activity_timeout " ] as? TimeInterval {
528
538
self . activityTimeoutInterval = activityTimeoutFromServer
529
539
}
530
540
@@ -550,7 +560,8 @@ import Starscream
550
560
- parameter event: The event to be processed
551
561
*/
552
562
fileprivate func handleMemberAddedEvent( event: PusherEvent ) {
553
- if let channelName = event. channelName, let chan = self . channels. find ( name: channelName) as? PusherPresenceChannel {
563
+ if let channelName = event. channelName,
564
+ let chan = self . channels. find ( name: channelName) as? PusherPresenceChannel {
554
565
if let memberJSON = event. dataToJSONObject ( ) as? [ String : Any ] {
555
566
chan. addMember ( memberJSON: memberJSON)
556
567
} else {
@@ -565,7 +576,8 @@ import Starscream
565
576
- parameter event: The event to be processed
566
577
*/
567
578
fileprivate func handleMemberRemovedEvent( event: PusherEvent ) {
568
- if let channelName = event. channelName, let chan = self . channels. find ( name: channelName) as? PusherPresenceChannel {
579
+ if let channelName = event. channelName,
580
+ let chan = self . channels. find ( name: channelName) as? PusherPresenceChannel {
569
581
if let memberJSON = event. dataToJSONObject ( ) as? [ String : Any ] {
570
582
chan. removeMember ( memberJSON: memberJSON)
571
583
} else {
@@ -607,7 +619,10 @@ import Starscream
607
619
if let message = error. message {
608
620
print ( message)
609
621
}
610
- self . delegate? . failedToSubscribeToChannel ? ( name: channelName, response: error. response, data: error. data, error: error. error)
622
+ self . delegate? . failedToSubscribeToChannel ? ( name: channelName,
623
+ response: error. response,
624
+ data: error. data,
625
+ error: error. error)
611
626
}
612
627
}
613
628
@@ -682,7 +697,8 @@ import Starscream
682
697
}
683
698
}
684
699
685
- fileprivate func requestPusherAuthFromAuthMethod( channel: PusherChannel , completionHandler: @escaping ( PusherAuth ? , PusherAuthError ? ) -> Void ) -> Bool {
700
+ fileprivate func requestPusherAuthFromAuthMethod( channel: PusherChannel ,
701
+ completionHandler: @escaping ( PusherAuth ? , PusherAuthError ? ) -> Void ) -> Bool {
686
702
guard let socketId = self . socketId else {
687
703
let message = " socketId value not found. You may not be connected. "
688
704
completionHandler ( nil , PusherAuthError ( kind: . notConnected, message: message) )
@@ -692,7 +708,9 @@ import Starscream
692
708
switch self . options. authMethod {
693
709
case . noMethod:
694
710
let errorMessage = " Authentication method required for private / presence channels but none provided. "
695
- let error = NSError ( domain: " com.pusher.PusherSwift " , code: 0 , userInfo: [ NSLocalizedFailureReasonErrorKey: errorMessage] )
711
+ let error = NSError ( domain: " com.pusher.PusherSwift " ,
712
+ code: 0 ,
713
+ userInfo: [ NSLocalizedFailureReasonErrorKey: errorMessage] )
696
714
completionHandler ( nil , PusherAuthError ( kind: . noMethod, message: errorMessage, error: error) )
697
715
return false
698
716
case . endpoint( authEndpoint: let authEndpoint) :
@@ -705,8 +723,12 @@ import Starscream
705
723
return true
706
724
} else {
707
725
let errorMessage = " Authentication request could not be built "
708
- let error = NSError ( domain: " com.pusher.PusherSwift " , code: 0 , userInfo: [ NSLocalizedFailureReasonErrorKey: errorMessage] )
709
- completionHandler ( nil , PusherAuthError ( kind: . couldNotBuildRequest, message: errorMessage, error: error) )
726
+ let error = NSError ( domain: " com.pusher.PusherSwift " ,
727
+ code: 0 ,
728
+ userInfo: [ NSLocalizedFailureReasonErrorKey: errorMessage] )
729
+ completionHandler ( nil , PusherAuthError ( kind: . couldNotBuildRequest,
730
+ message: errorMessage,
731
+ error: error) )
710
732
return false
711
733
}
712
734
case . authorizer( authorizer: let authorizer) :
@@ -807,36 +829,53 @@ import Starscream
807
829
- parameter request: The request to send
808
830
- parameter channel: The PusherChannel to authenticate subsciption for
809
831
*/
810
- fileprivate func sendAuthorisationRequest( request: URLRequest , channel: PusherChannel , completionHandler: @escaping ( PusherAuth ? , PusherAuthError ? ) -> Void ) {
832
+ fileprivate func sendAuthorisationRequest( request: URLRequest ,
833
+ channel: PusherChannel ,
834
+ completionHandler: @escaping ( PusherAuth ? , PusherAuthError ? ) -> Void ) {
811
835
let task = URLSession . dataTask ( with: request, completionHandler: { data, response, sessionError in
812
836
if let error = sessionError {
813
837
let message = " Error authorizing channel [ \( channel. name) ]: \( error) "
814
- completionHandler ( nil , PusherAuthError ( kind: . requestFailure, message: message, response: response, error: error as NSError ? ) )
838
+ completionHandler ( nil , PusherAuthError ( kind: . requestFailure,
839
+ message: message,
840
+ response: response,
841
+ error: error as NSError ? ) )
815
842
return
816
843
}
817
844
818
845
guard let data = data else {
819
846
let message = " Error authorizing channel [ \( channel. name) ] "
820
- completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse, message: message, response: response) )
847
+ completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse,
848
+ message: message,
849
+ response: response) )
821
850
return
822
851
}
823
852
824
- guard let httpResponse = response as? HTTPURLResponse , ( httpResponse. statusCode == 200 || httpResponse. statusCode == 201 ) else {
853
+ guard let httpResponse = response as? HTTPURLResponse ,
854
+ ( httpResponse. statusCode == 200 || httpResponse. statusCode == 201 ) else {
825
855
let dataString = String ( data: data, encoding: String . Encoding. utf8)
826
856
let message = " Error authorizing channel [ \( channel. name) ]: \( String ( describing: dataString) ) "
827
- completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse, message: message, response: response, data: dataString) )
857
+ completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse,
858
+ message: message,
859
+ response: response,
860
+ data: dataString) )
828
861
return
829
862
}
830
863
831
- guard let jsonObject = try ? JSONSerialization . jsonObject ( with: data, options: [ ] ) , let json = jsonObject as? [ String : AnyObject ] else {
864
+ guard let jsonObject = try ? JSONSerialization . jsonObject ( with: data,
865
+ options: [ ] ) ,
866
+ let json = jsonObject as? [ String : AnyObject ] else {
832
867
let message = " Error authorizing channel [ \( channel. name) ]: Could not parse response from auth endpoint "
833
- completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse, message: message, response: httpResponse) )
868
+ completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse,
869
+ message: message,
870
+ response: httpResponse) )
834
871
return
835
872
}
836
873
837
874
guard let auth = json [ " auth " ] as? String else {
838
875
let message = " Error authorizing channel [ \( channel. name) ]: No auth field in response "
839
- completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse, message: message, response: httpResponse) )
876
+ completionHandler ( nil , PusherAuthError ( kind: . invalidAuthResponse,
877
+ message: message,
878
+ response: httpResponse) )
840
879
return
841
880
}
842
881
@@ -919,7 +958,9 @@ extension PusherConnection: PusherEventQueueDelegate {
919
958
}
920
959
}
921
960
922
- func eventQueue( _ eventQueue: PusherEventQueue , didFailToDecryptEventWithPayload payload: PusherEventPayload , forChannelName channelName: String ) {
961
+ func eventQueue( _ eventQueue: PusherEventQueue ,
962
+ didFailToDecryptEventWithPayload payload: PusherEventPayload ,
963
+ forChannelName channelName: String ) {
923
964
DispatchQueue . main. async {
924
965
if let eventName = payload [ " event " ] as? String {
925
966
let data = payload [ " data " ] as? String
@@ -929,7 +970,9 @@ extension PusherConnection: PusherEventQueueDelegate {
929
970
}
930
971
}
931
972
932
- func eventQueue( _ eventQueue: PusherEventQueue , didReceiveEvent event: PusherEvent , forChannelName channelName: String ? ) {
973
+ func eventQueue( _ eventQueue: PusherEventQueue ,
974
+ didReceiveEvent event: PusherEvent ,
975
+ forChannelName channelName: String ? ) {
933
976
DispatchQueue . main. async {
934
977
self . handleEvent ( event: event)
935
978
}
0 commit comments