Merge pull request #98 from InsectQY/add-air-play-support

feat - 添加 AirPlay 支持

Author: changsanjiang

Example/SJMediaCacheServer/SJViewController.m

@@ -10,6 +10,7 @@
 #import <SJMediaCacheServer/SJMediaCacheServer.h>
 #import <SJVideoPlayer/SJVideoPlayer.h>
 #import <Masonry/Masonry.h>
+#import <AVKit/AVKit.h>
 
 static NSString *const DEMO_URL = @"http://devimages.apple.com/iphone/samples/bipbop/bipbopall.m3u8";
 
@@ -34,6 +35,9 @@ - (void)viewDidLoad {
     }];
 
     SJMediaCacheServer.shared.enabledConsoleLog = YES;
+    
+    AVRoutePickerView *routePickerView = [[AVRoutePickerView alloc]initWithFrame:CGRectMake(40, 88, 40, 40)];
+    [self.view addSubview:routePickerView];
 }
 
 - (IBAction)play:(id)sender {

SJMediaCacheServer/Core/Asset/HLS/HLSAssetParser.m

@@ -7,6 +7,7 @@
 //
 
 #import "HLSAssetParser.h"
+#import "MCSNetworkUtils.h"
 #import "MCSError.h"
 #import "MCSURL.h"
 #import "NSURLRequest+MCS.h"
@@ -255,7 +256,7 @@ - (nullable NSString *)hls_findValueForAttribute:(NSString *)name startPos:(NSUI
         NSString *matchedName = obj.numberOfRanges == 3 ? [self substringWithRange:[obj rangeAtIndex:1]] : nil;
         return matchedName && [matchedName isEqualToString:name];
     }];
-    
+
     if ( result != nil ) {
         NSRange valueRange = [result rangeAtIndex:2];
         NSUInteger valuePos = valueRange.location;
@@ -286,10 +287,19 @@ - (BOOL)hls_toBOOL {
 
 - (NSString *)hls_restoreOriginalUrl:(NSURL *)resourceURL {
     if ( [self containsString:@"://"] ) {
+        // Check for localhost and device IP addresses
         NSString *localhost = @"http://localhost";
+        NSString *deviceIP = [MCSNetworkUtils getLocalIPAddress];
+
         if ( [self hasPrefix:localhost] ) {
             return [NSURL URLWithString:[self substringFromIndex:localhost.length] relativeToURL:resourceURL].absoluteString;
         }
+
+        // Also check for device IP address
+        if (deviceIP && [self hasPrefix:[NSString stringWithFormat:@"http://%@", deviceIP]]) {
+            return [NSURL URLWithString:[self substringFromIndex:(deviceIP.length + 7)] relativeToURL:resourceURL].absoluteString;
+        }
+
         return self;
     }
     return [NSURL URLWithString:self relativeToURL:resourceURL].absoluteString;
@@ -327,12 +337,12 @@ + (nullable NSString *)proxyPlaylistWithAsset:(NSString *)assetName
             MCSErrorUserInfoReasonKey : @"Empty data or unsupported format!"
         }];
     }
-    
+
     NSMutableString *_Nullable proxyPlaylist = nil;;
     if ( playlist != nil ) {
         NSMutableArray<__kindof HLSItem *> *parsingItems = NSMutableArray.array;
         proxyPlaylist = (NSMutableString *)[self parse:playlist shouldTrim:YES parsingItems:parsingItems];
-        
+
         __block NSMutableArray<id<HLSVariantStream>> *_Nullable variantStreams;
         __block NSMutableDictionary<NSString *, HLSRenditionGroup *> *_Nullable renditionGroups;
         // find variant streams and renditions
@@ -363,7 +373,7 @@ + (nullable NSString *)proxyPlaylistWithAsset:(NSString *)assetName
                 }
             }
         }];
-        
+
         // selected variant stream
         id<HLSVariantStream> _Nullable selectedVariantStream = nil;
         // selected renditions
@@ -380,7 +390,7 @@ + (nullable NSString *)proxyPlaylistWithAsset:(NSString *)assetName
 //                NSString *key = [audioGroupID stringByAppendingFormat:@"_%ld", HLSRenditionTypeAudio];
 //                HLSRenditionGroup *group = renditionGroups[key];
 //                NSParameterAssert(group != nil);
-//                selectedAudioRendition = 
+//                selectedAudioRendition =
 //                    group.renditions.count > 1 ? [self selectRenditionInGroup:group originalURL:originalURL currentURL:currentURL renditionSelectionHandler:renditionSelectionHandler] :
 //                                                 group.renditions.firstObject;
 //            }
@@ -403,7 +413,7 @@ + (nullable NSString *)proxyPlaylistWithAsset:(NSString *)assetName
                                                                                            currentURL:currentURL
                                                                             renditionSelectionHandler:renditionSelectionHandler];
         }
-        
+
         [parsingItems enumerateObjectsWithOptions:NSEnumerationReverse usingBlock:^(__kindof HLSItem * _Nonnull obj, NSUInteger idx, BOOL * _Nonnull stop) {
             BOOL shouldRemove = NO;
             switch (obj.itemType) {
@@ -427,13 +437,13 @@ + (nullable NSString *)proxyPlaylistWithAsset:(NSString *)assetName
                     break;
                 }
             }
-            
+
             // remove contents
             if ( shouldRemove ) {
                 [proxyPlaylist replaceCharactersInRange:NSMakeRange(obj.startPosition, obj.length) withString:@""];
                 return; // return;
             }
-            
+
             // replace URI with proxy url
             NSString *URI = obj.URI;
             if ( URI == nil ) return;
@@ -456,7 +466,7 @@ + (NSString *)parse:(NSString *)playlist shouldTrim:(BOOL)shouldTrim parsingItem
     __block NSUInteger offset = 0;
     [lines enumerateObjectsUsingBlock:^(NSString *line, NSUInteger idx, BOOL * _Nonnull stop) {
         if ( shouldTrim && trimmedPlaylist.length != 0 ) [trimmedPlaylist appendString:@"\n"];
-        
+
         // 去除行首尾的空白字符; 每一行要么是一个标签(以 #EXT 开头), 要么是一个 URI
         NSString *curLine = shouldTrim ? [line stringByTrimmingCharactersInSet:[NSCharacterSet whitespaceAndNewlineCharacterSet]] : line;
         // 跳过空行和注释
@@ -465,7 +475,7 @@ + (NSString *)parse:(NSString *)playlist shouldTrim:(BOOL)shouldTrim parsingItem
         BOOL isUri = !isTag && !isComments && curLine.length > 0;
         if      ( isTag ) [self handleTag:curLine offset:offset parsingItems:parsingItems context:ctx]; // 这是一个标签行
         else if ( isUri ) [self handleURI:curLine offset:offset context:ctx]; // 这是一个 URI 行
-        
+
         if ( shouldTrim && !isComments ) [trimmedPlaylist appendString:curLine];
         offset = (shouldTrim ? trimmedPlaylist.length : (offset + curLine.length)) + 1; // + @"\n"
     }];
@@ -658,7 +668,7 @@ + (NSRange)parseByteRange:(NSString *)byteRange prevEnd:(NSUInteger)previousEnd
     return NSMakeRange(location, length);
 }
 
-+ (id<HLSVariantStream>)selectVariantStreamInArray:(NSArray<id<HLSVariantStream>> *)streams 
++ (id<HLSVariantStream>)selectVariantStreamInArray:(NSArray<id<HLSVariantStream>> *)streams
                                        originalURL:(NSURL *)originalURL
                                         currentURL:(NSURL *)currentURL
                      variantStreamSelectionHandler:(nullable HLSVariantStreamSelectionHandler)variantStreamSelectionHandler {
@@ -685,7 +695,7 @@ + (NSRange)parseByteRange:(NSString *)byteRange prevEnd:(NSUInteger)previousEnd
             if ( rendition != nil ) return rendition;
         }
     }
-    
+
     return [renditions mcs_firstOrNull:^BOOL(id<HLSRendition>  _Nonnull obj) {
         return obj.isDefault; // select default rendition
     }] ?: renditions.firstObject; // or first;

SJMediaCacheServer/Core/Common/MCSNetworkUtils.h

@@ -0,0 +1,30 @@
+//
+//  MCSNetworkUtils.h
+//  SJMediaCacheServer
+//
+//  Created by changsanjiang@gmail.com on 2020/5/30.
+//  Copyright © 2020 changsanjiang@gmail.com. All rights reserved.
+//
+
+#import <Foundation/Foundation.h>
+
+NS_ASSUME_NONNULL_BEGIN
+
+@interface MCSNetworkUtils : NSObject
+
+/// Get the device's local IP address for AirPlay support
+/// This method returns the first available local IP address (preferably WiFi)
+/// @return The device's local IP address, or nil if not available
++ (nullable NSString *)getLocalIPAddress;
+
+/// Get the device's WiFi IP address specifically
+/// @return The device's WiFi IP address, or nil if WiFi is not available
++ (nullable NSString *)getWiFiIPAddress;
+
+/// Get all available local IP addresses
+/// @return Array of available local IP addresses
++ (NSArray<NSString *> *)getAllLocalIPAddresses;
+
+@end
+
+NS_ASSUME_NONNULL_END

SJMediaCacheServer/Core/Common/MCSNetworkUtils.m

@@ -0,0 +1,82 @@
+//
+//  MCSNetworkUtils.m
+//  SJMediaCacheServer
+//
+//  Created by changsanjiang@gmail.com on 2020/5/30.
+//  Copyright © 2020 changsanjiang@gmail.com. All rights reserved.
+//
+
+#import "MCSNetworkUtils.h"
+#include <ifaddrs.h>
+#include <arpa/inet.h>
+#include <net/if.h>
+
+@implementation MCSNetworkUtils
+
++ (nullable NSString *)getLocalIPAddress {
+    // First try to get WiFi IP address
+    NSString *wifiIP = [self getWiFiIPAddress];
+    if (wifiIP) {
+        return wifiIP;
+    }
+
+    // If WiFi is not available, get the first available local IP
+    NSArray<NSString *> *allIPs = [self getAllLocalIPAddresses];
+    return allIPs.firstObject;
+}
+
++ (nullable NSString *)getWiFiIPAddress {
+    NSArray<NSString *> *allIPs = [self getAllLocalIPAddresses];
+
+    // Look for WiFi interface (en0 on iOS)
+    for (NSString *ip in allIPs) {
+        if ([ip hasPrefix:@"192.168."] || [ip hasPrefix:@"10."] || [ip hasPrefix:@"172."]) {
+            return ip;
+        }
+    }
+
+    return nil;
+}
+
++ (NSArray<NSString *> *)getAllLocalIPAddresses {
+    NSMutableArray<NSString *> *ipAddresses = [NSMutableArray array];
+
+    struct ifaddrs *interfaces = NULL;
+    struct ifaddrs *temp_addr = NULL;
+
+    // Retrieve the current interfaces - returns 0 on success
+    int success = getifaddrs(&interfaces);
+    if (success == 0) {
+        // Loop through linked list of interfaces
+        temp_addr = interfaces;
+        while (temp_addr != NULL) {
+            if (temp_addr->ifa_addr->sa_family == AF_INET) {
+                // Check if interface is en0 (WiFi) or en1 (Cellular)
+                NSString *interfaceName = [NSString stringWithUTF8String:temp_addr->ifa_name];
+                if ([interfaceName isEqualToString:@"en0"] ||
+                    [interfaceName isEqualToString:@"en1"] ||
+                    [interfaceName isEqualToString:@"en2"] ||
+                    [interfaceName isEqualToString:@"en3"]) {
+
+                    // Get IP address
+                    char ip[INET_ADDRSTRLEN];
+                    inet_ntop(AF_INET, &(((struct sockaddr_in *)temp_addr->ifa_addr)->sin_addr), ip, INET_ADDRSTRLEN);
+                    NSString *ipString = [NSString stringWithUTF8String:ip];
+
+                    // Skip localhost
+                    if (![ipString isEqualToString:@"127.0.0.1"] && ![ipString isEqualToString:@"::1"]) {
+                        [ipAddresses addObject:ipString];
+                    }
+                }
+            }
+            temp_addr = temp_addr->ifa_next;
+        }
+    }
+
+    // Free memory
+    freeifaddrs(interfaces);
+
+    return [ipAddresses copy];
+}
+
+@end

SJMediaCacheServer/Core/TcpSocketServer/MCPin.m

@@ -8,6 +8,7 @@
 #import "MCPin.h"
 #import "MCHttpRequest.h"
 #import "MCSLogger.h"
+#import "MCSNetworkUtils.h"
 
 @interface MCTimer : NSObject
 - (instancetype)initWithQueue:(dispatch_queue_t)queue start:(NSTimeInterval)start interval:(NSTimeInterval)interval repeats:(BOOL)repeats block:(void (^)(MCTimer *timer))block;
@@ -18,7 +19,7 @@ - (void)resume;
 - (void)suspend;
 - (void)invalidate;
 @end
- 
+
 @implementation MCTimer {
     dispatch_semaphore_t _semaphore;
     dispatch_source_t _timer;
@@ -125,8 +126,15 @@ - (void)dealloc {
 - (void)startWithPort:(uint16_t)port {
     @synchronized (self) {
         [self _clearTimer];
-        
-        NSURL *reqURL = [NSURL URLWithString:[NSString stringWithFormat:@"http://127.0.0.1:%hu", port]];
+
+        // Get device IP address for AirPlay support
+        NSString *deviceIP = @"127.0.0.1"; // Default to localhost
+        // For AirPlay support, we need to use the device's actual IP address
+        NSString *localIP = [MCSNetworkUtils getLocalIPAddress];
+        if (localIP) {
+            deviceIP = localIP;
+        }
+        NSURL *reqURL = [NSURL URLWithString:[NSString stringWithFormat:@"http://%@:%hu", deviceIP, port]];
         __weak typeof(self) _self = self;
         mTimer = [MCTimer.alloc initWithQueue:dispatch_get_global_queue(0, 0) start:mReqInterval interval:mReqInterval repeats:YES block:^(MCTimer *timer) {
             __strong typeof(_self) self = _self;