-
Notifications
You must be signed in to change notification settings - Fork 5
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fixed Broken Airplay from Previous Commit.
- Loading branch information
1 parent
f0ca743
commit 9c5a8a8
Showing
32 changed files
with
943 additions
and
146 deletions.
There are no files selected for viewing
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,84 @@ | ||
package com.laer.easycast; | ||
|
||
/** | ||
* Created by Parth on 09-11-2014. | ||
*/ | ||
|
||
import java.math.BigInteger; | ||
import java.net.InetAddress; | ||
import java.security.MessageDigest; | ||
import java.util.logging.Level; | ||
import java.util.logging.Logger; | ||
|
||
/** | ||
* Copyright (c) 2011 Carson McDonald | ||
* <p/> | ||
* Permission is hereby granted, free of charge, to any person obtaining a copy | ||
* of this software and associated documentation files (the "Software"), to deal | ||
* in the Software without restriction, including without limitation the rights | ||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
* copies of the Software, and to permit persons to whom the Software is | ||
* furnished to do so, subject to the following conditions: | ||
* <p/> | ||
* The above copyright notice and this permission notice shall be included in | ||
* all copies or substantial portions of the Software. | ||
* <p/> | ||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
* THE SOFTWARE. | ||
*/ | ||
|
||
public class Device { | ||
private static Logger logger = Logger.getLogger(Device.class.getName()); | ||
|
||
private String id; | ||
private String name; | ||
private InetAddress inetAddress; | ||
private int port; | ||
|
||
public Device(String name, InetAddress inetAddress, int port) { | ||
this.name = name; | ||
this.inetAddress = inetAddress; | ||
this.port = port; | ||
|
||
try { | ||
MessageDigest messageDigest = MessageDigest.getInstance("MD5"); | ||
messageDigest.update(inetAddress.getAddress()); | ||
messageDigest.update(String.valueOf(port).getBytes("UTF-8")); | ||
id = String.format("%032X", new BigInteger(1, messageDigest.digest())); | ||
} catch (Exception e) { | ||
logger.log(Level.SEVERE, e.getMessage(), e); | ||
throw new RuntimeException(e.getMessage(), e); | ||
} | ||
} | ||
|
||
public String getName() { | ||
return name; | ||
} | ||
|
||
public InetAddress getInetAddress() { | ||
return inetAddress; | ||
} | ||
|
||
public int getPort() { | ||
return port; | ||
} | ||
|
||
public String getId() { | ||
return id; | ||
} | ||
|
||
@Override | ||
public String toString() { | ||
return "Device{" + | ||
"id='" + getId() + '\'' + | ||
", name='" + name + '\'' + | ||
", inetAddress='" + inetAddress + '\'' + | ||
", port=" + port + | ||
'}'; | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,67 @@ | ||
package com.laer.easycast; | ||
|
||
/** | ||
* Created by Parth on 09-11-2014. | ||
*/ | ||
|
||
import java.io.UnsupportedEncodingException; | ||
import java.net.URLEncoder; | ||
import java.util.HashMap; | ||
import java.util.Map; | ||
import java.util.logging.Level; | ||
import java.util.logging.Logger; | ||
|
||
/** | ||
* Copyright (c) 2011 Carson McDonald | ||
* <p/> | ||
* Permission is hereby granted, free of charge, to any person obtaining a copy | ||
* of this software and associated documentation files (the "Software"), to deal | ||
* in the Software without restriction, including without limitation the rights | ||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
* copies of the Software, and to permit persons to whom the Software is | ||
* furnished to do so, subject to the following conditions: | ||
* <p/> | ||
* The above copyright notice and this permission notice shall be included in | ||
* all copies or substantial portions of the Software. | ||
* <p/> | ||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
* THE SOFTWARE. | ||
*/ | ||
|
||
public abstract class DeviceCommand { | ||
private static Logger logger = Logger.getLogger(DeviceCommand.class.getName()); | ||
protected String requestType = "POST"; | ||
private Map<String, String> parameterMap = new HashMap<String, String>(); | ||
|
||
protected void addParameter(String name, Object value) { | ||
parameterMap.put(name, value.toString()); | ||
} | ||
|
||
protected String constructCommand(String commandName, String content) { | ||
String parameterValue = parameterMap.keySet().size() == 0 ? "" : "?"; | ||
for (String key : parameterMap.keySet()) { | ||
try { | ||
parameterValue += key + "=" + URLEncoder.encode(parameterMap.get(key), "utf-8"); | ||
} catch (UnsupportedEncodingException e) { | ||
logger.log(Level.SEVERE, e.getMessage(), e); | ||
throw new RuntimeException(e.getMessage(), e); | ||
} | ||
} | ||
|
||
String headerPart = String.format("%s /%s%s HTTP/1.1\n" + | ||
"Content-Length: %d\n" + | ||
"User-Agent: MediaControl/1.0\n", requestType, commandName, parameterValue, content == null ? 0 : content.length()); | ||
if (content == null || content.length() == 0) { | ||
return headerPart; | ||
} else { | ||
return headerPart + "\n" + content; | ||
} | ||
} | ||
|
||
public abstract String getCommandString(); | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,110 @@ | ||
package com.laer.easycast; | ||
|
||
/** | ||
* Created by Parth on 09-11-2014. | ||
*/ | ||
|
||
import java.io.BufferedReader; | ||
import java.io.BufferedWriter; | ||
import java.io.IOException; | ||
import java.io.InputStreamReader; | ||
import java.io.OutputStreamWriter; | ||
import java.net.Socket; | ||
import java.util.logging.Level; | ||
import java.util.logging.Logger; | ||
|
||
/** | ||
* Copyright (c) 2011 Carson McDonald | ||
* <p/> | ||
* Permission is hereby granted, free of charge, to any person obtaining a copy | ||
* of this software and associated documentation files (the "Software"), to deal | ||
* in the Software without restriction, including without limitation the rights | ||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
* copies of the Software, and to permit persons to whom the Software is | ||
* furnished to do so, subject to the following conditions: | ||
* <p/> | ||
* The above copyright notice and this permission notice shall be included in | ||
* all copies or substantial portions of the Software. | ||
* <p/> | ||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
* THE SOFTWARE. | ||
* <p/> | ||
* This class manages the connection to an AirPlay device. | ||
*/ | ||
public class DeviceConnection { | ||
private static Logger logger = Logger.getLogger(DeviceConnection.class.getName()); | ||
|
||
private Device device; | ||
private Socket socket; | ||
|
||
public DeviceConnection(Device device) { | ||
this.device = device; | ||
} | ||
|
||
public void close() { | ||
if (socket != null) { | ||
try { | ||
socket.close(); | ||
} catch (IOException e) { | ||
// ignore anything here | ||
} | ||
} | ||
} | ||
|
||
public DeviceResponse sendCommand(DeviceCommand command) { | ||
if (socket == null || socket.isClosed()) { | ||
try { | ||
socket = new Socket(device.getInetAddress(), device.getPort()); | ||
} catch (IOException e) { | ||
logger.log(Level.SEVERE, e.getMessage(), e); | ||
throw new RuntimeException(e.getMessage(), e); | ||
} | ||
} | ||
|
||
try { | ||
BufferedReader deviceInput = new BufferedReader(new InputStreamReader(socket.getInputStream())); | ||
BufferedWriter deviceOutput = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); | ||
|
||
String commandString = command.getCommandString(); | ||
deviceOutput.write(commandString + "\n"); | ||
deviceOutput.flush(); | ||
|
||
StringBuffer fullResponse = new StringBuffer(); | ||
String partialResponse; | ||
while (!(partialResponse = deviceInput.readLine().trim()).equals("")) { | ||
fullResponse.append(partialResponse); | ||
fullResponse.append("\n"); | ||
} | ||
|
||
int contentLength = 0; | ||
if (fullResponse.indexOf("Content-Length:") != -1) { | ||
String cls = "Content-Length:"; | ||
int si = fullResponse.indexOf(cls); | ||
int ei = fullResponse.indexOf("\n", si + cls.length()); | ||
contentLength = Integer.parseInt(fullResponse.substring(si + cls.length(), ei).trim()); | ||
} | ||
|
||
StringBuffer content = null; | ||
if (contentLength > 0) { | ||
content = new StringBuffer(contentLength); | ||
char buffer[] = new char[1024]; | ||
int read, totalRead = 0; | ||
do { | ||
read = deviceInput.read(buffer); | ||
totalRead += read; | ||
content.append(buffer, 0, read); | ||
} while (read != -1 && totalRead < contentLength); | ||
} | ||
|
||
return new DeviceResponse(fullResponse.toString(), content == null ? null : content.toString()); | ||
} catch (IOException e) { | ||
logger.log(Level.SEVERE, e.getMessage(), e); | ||
throw new RuntimeException(e.getMessage(), e); | ||
} | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,41 @@ | ||
package com.laer.easycast; | ||
|
||
/** | ||
* Created by Parth on 09-11-2014. | ||
*/ | ||
|
||
import java.util.HashMap; | ||
import java.util.Map; | ||
|
||
/** | ||
* Copyright (c) 2011 Carson McDonald | ||
* <p/> | ||
* Permission is hereby granted, free of charge, to any person obtaining a copy | ||
* of this software and associated documentation files (the "Software"), to deal | ||
* in the Software without restriction, including without limitation the rights | ||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
* copies of the Software, and to permit persons to whom the Software is | ||
* furnished to do so, subject to the following conditions: | ||
* <p/> | ||
* The above copyright notice and this permission notice shall be included in | ||
* all copies or substantial portions of the Software. | ||
* <p/> | ||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
* THE SOFTWARE. | ||
*/ | ||
|
||
public class DeviceConnectionService { | ||
private static Map<String, DeviceConnection> deviceConnectionMap = new HashMap<String, DeviceConnection>(); | ||
|
||
public static DeviceConnection getConnection(Device device) { | ||
if (!deviceConnectionMap.containsKey(device.getId())) { | ||
deviceConnectionMap.put(device.getId(), new DeviceConnection(device)); | ||
} | ||
return deviceConnectionMap.get(device.getId()); | ||
} | ||
} |
Oops, something went wrong.