moonlight-stream/Internet-Hosting-Tool
1
0
Fork 0
mirror of https://github.com/moonlight-stream/Internet-Hosting-Tool.git synced 2025-07-02 07:45:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Untabify source

Browse Source
This commit is contained in:
Cameron Gutman 2019-07-28 13:25:51 -07:00
parent b1a1352bbf
commit 6f3898e4b4
3 changed files with 161 additions and 161 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
GS-IPv6-Forwarder

@ -1 +1 @@
Subproject commit 1c4e9a1701a218c16c3e6f0cccd17e1948975c22 Subproject commit 7b395a9f2f091b61bf072b2fe3f74fdc6e7eba7b

24
miss/miss.cpp
View File

@ -97,7 +97,7 @@ bool UPnPMapPort(struct UPNPUrls* urls, struct IGDdatas* data, int proto, const
printf("NOT FOUND" NL); printf("NOT FOUND" NL);
} }
else if (err == UPNPCOMMAND_SUCCESS) { else if (err == UPNPCOMMAND_SUCCESS) {
// Some routers change the description, so we can't check that here // Some routers change the description, so we can't check that here
if (!strcmp(intClient, myAddr)) { if (!strcmp(intClient, myAddr)) {
if (atoi(leaseDuration) == 0) { if (atoi(leaseDuration) == 0) {
printf("OK (Permanent)" NL); printf("OK (Permanent)" NL);
@ -747,18 +747,18 @@ void ResetLogFile()
{ {
char oldLogFilePath[MAX_PATH + 1]; char oldLogFilePath[MAX_PATH + 1];
char currentLogFilePath[MAX_PATH + 1]; char currentLogFilePath[MAX_PATH + 1];
char timeString[MAX_PATH + 1] = {}; char timeString[MAX_PATH + 1] = {};
SYSTEMTIME time; SYSTEMTIME time;
ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-old.log", oldLogFilePath, sizeof(oldLogFilePath)); ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-old.log", oldLogFilePath, sizeof(oldLogFilePath));
ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-current.log", currentLogFilePath, sizeof(currentLogFilePath)); ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-current.log", currentLogFilePath, sizeof(currentLogFilePath));
// Close the existing stdout handle. This is important because otherwise // Close the existing stdout handle. This is important because otherwise
// it may still be open as stdout when we try to MoveFileEx below. // it may still be open as stdout when we try to MoveFileEx below.
fclose(stdout); fclose(stdout);
// Rotate the current to the old log file // Rotate the current to the old log file
MoveFileExA(currentLogFilePath, oldLogFilePath, MOVEFILE_REPLACE_EXISTING); MoveFileExA(currentLogFilePath, oldLogFilePath, MOVEFILE_REPLACE_EXISTING);
// Redirect stdout to this new file // Redirect stdout to this new file
freopen(currentLogFilePath, "w", stdout); freopen(currentLogFilePath, "w", stdout);
@ -766,10 +766,10 @@ void ResetLogFile()
// Print a log header // Print a log header
printf("Moonlight Internet Streaming Service v" VER_VERSION_STR NL); printf("Moonlight Internet Streaming Service v" VER_VERSION_STR NL);
// Print the current time // Print the current time
GetSystemTime(&time); GetSystemTime(&time);
GetTimeFormatA(LOCALE_SYSTEM_DEFAULT, 0, &time, "hh':'mm':'ss tt", timeString, ARRAYSIZE(timeString)); GetTimeFormatA(LOCALE_SYSTEM_DEFAULT, 0, &time, "hh':'mm':'ss tt", timeString, ARRAYSIZE(timeString));
printf("The current UTC time is: %s" NL, timeString); printf("The current UTC time is: %s" NL, timeString);
} }
DWORD WINAPI GameStreamStateChangeThread(PVOID Context) DWORD WINAPI GameStreamStateChangeThread(PVOID Context)

296
mist/mist.cpp
View File

@ -34,8 +34,8 @@ static struct port_entry {
{IPPROTO_UDP, 48000, true}, {IPPROTO_UDP, 48000, true},
#if 0 #if 0
// These are not currently used, so let's // These are not currently used, so let's
// avoid testing them for now. // avoid testing them for now.
{IPPROTO_UDP, 48002, true}, {IPPROTO_UDP, 48002, true},
{IPPROTO_UDP, 48010, true} {IPPROTO_UDP, 48010, true}
#endif #endif
@ -67,8 +67,8 @@ void DisplayMessage(const char* message, const char* helpUrl = nullptr, MessageP
fprintf(LOG_OUT, "%s\n", message); fprintf(LOG_OUT, "%s\n", message);
if (terminal) { if (terminal) {
char logPath[MAX_PATH + 1]; char logPath[MAX_PATH + 1];
FILE* f; FILE* f;
fprintf(LOG_OUT, "--------------- CURRENT MISS LOG -------------------\n"); fprintf(LOG_OUT, "--------------- CURRENT MISS LOG -------------------\n");
@ -86,53 +86,53 @@ void DisplayMessage(const char* message, const char* helpUrl = nullptr, MessageP
fprintf(LOG_OUT, "Failed to find current MISS log\n"); fprintf(LOG_OUT, "Failed to find current MISS log\n");
} }
fprintf(LOG_OUT, "\n----------------- OLD MISS LOG ---------------------\n"); fprintf(LOG_OUT, "\n----------------- OLD MISS LOG ---------------------\n");
ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-old.log", logPath, sizeof(logPath)); ExpandEnvironmentStringsA("%ProgramData%\\MISS\\miss-old.log", logPath, sizeof(logPath));
f = fopen(logPath, "r"); f = fopen(logPath, "r");
if (f != nullptr) { if (f != nullptr) {
char buffer[1024]; char buffer[1024];
while (!feof(f)) { while (!feof(f)) {
int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f); int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f);
fwrite(buffer, 1, bytesRead, LOG_OUT); fwrite(buffer, 1, bytesRead, LOG_OUT);
} }
fclose(f); fclose(f);
} }
else { else {
fprintf(LOG_OUT, "Failed to find old MISS log\n"); fprintf(LOG_OUT, "Failed to find old MISS log\n");
} }
fprintf(LOG_OUT, "--------------- CURRENT GSV6FWD LOG -------------------\n"); fprintf(LOG_OUT, "--------------- CURRENT GSV6FWD LOG -------------------\n");
ExpandEnvironmentStringsA("%ProgramData%\\MISS\\GSv6Fwd-current.log", logPath, sizeof(logPath)); ExpandEnvironmentStringsA("%ProgramData%\\MISS\\GSv6Fwd-current.log", logPath, sizeof(logPath));
f = fopen(logPath, "r"); f = fopen(logPath, "r");
if (f != nullptr) { if (f != nullptr) {
char buffer[1024]; char buffer[1024];
while (!feof(f)) { while (!feof(f)) {
int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f); int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f);
fwrite(buffer, 1, bytesRead, LOG_OUT); fwrite(buffer, 1, bytesRead, LOG_OUT);
} }
fclose(f); fclose(f);
} }
else { else {
fprintf(LOG_OUT, "Failed to find current GSv6Fwd log\n"); fprintf(LOG_OUT, "Failed to find current GSv6Fwd log\n");
} }
fprintf(LOG_OUT, "\n----------------- OLD GSV6FWD LOG ---------------------\n"); fprintf(LOG_OUT, "\n----------------- OLD GSV6FWD LOG ---------------------\n");
ExpandEnvironmentStringsA("%ProgramData%\\MISS\\GSv6Fwd-old.log", logPath, sizeof(logPath)); ExpandEnvironmentStringsA("%ProgramData%\\MISS\\GSv6Fwd-old.log", logPath, sizeof(logPath));
f = fopen(logPath, "r"); f = fopen(logPath, "r");
if (f != nullptr) { if (f != nullptr) {
char buffer[1024]; char buffer[1024];
while (!feof(f)) { while (!feof(f)) {
int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f); int bytesRead = fread(buffer, 1, ARRAYSIZE(buffer), f);
fwrite(buffer, 1, bytesRead, LOG_OUT); fwrite(buffer, 1, bytesRead, LOG_OUT);
} }
fclose(f); fclose(f);
} }
else { else {
fprintf(LOG_OUT, "Failed to find old GSv6Fwd log\n"); fprintf(LOG_OUT, "Failed to find old GSv6Fwd log\n");
} }
fflush(LOG_OUT); fflush(LOG_OUT);
} }
@ -302,20 +302,20 @@ PortTestStatus TestPort(PSOCKADDR_STORAGE addr, int proto, int port, bool withSe
FD_ZERO(&fds); FD_ZERO(&fds);
if (serverSock != INVALID_SOCKET) { if (serverSock != INVALID_SOCKET) {
FD_SET(serverSock, &fds); FD_SET(serverSock, &fds);
} }
else { else {
FD_SET(clientSock, &fds); FD_SET(clientSock, &fds);
} }
// If we have a server socket, listen for the accept() instead of the // If we have a server socket, listen for the accept() instead of the
// connect() so we can be compatible with the loopback relay. // connect() so we can be compatible with the loopback relay.
timeout.tv_sec = 3; timeout.tv_sec = 3;
err = select(0, err = select(0,
serverSock != INVALID_SOCKET ? &fds : nullptr, serverSock != INVALID_SOCKET ? &fds : nullptr,
serverSock == INVALID_SOCKET ? &fds : nullptr, serverSock == INVALID_SOCKET ? &fds : nullptr,
nullptr, &timeout); nullptr, &timeout);
if (err == 1) { if (err == 1) {
// Our FD was signalled for connect() or accept() completion // Our FD was signalled for connect() or accept() completion
fprintf(LOG_OUT, "Success\n"); fprintf(LOG_OUT, "Success\n");
@ -339,18 +339,18 @@ PortTestStatus TestPort(PSOCKADDR_STORAGE addr, int proto, int port, bool withSe
else { else {
const char testMsg[] = "moonlight-test"; const char testMsg[] = "moonlight-test";
// Send several test packets to ensure a random lost packet doesn't make the test fail // Send several test packets to ensure a random lost packet doesn't make the test fail
for (int i = 0; i < 5; i++) { for (int i = 0; i < 5; i++) {
err = sendto(clientSock, testMsg, sizeof(testMsg), 0, (struct sockaddr*)&sin6, addrLen); err = sendto(clientSock, testMsg, sizeof(testMsg), 0, (struct sockaddr*)&sin6, addrLen);
if (err == SOCKET_ERROR) { if (err == SOCKET_ERROR) {
fprintf(LOG_OUT, "sendto() failed: %d\n", WSAGetLastError()); fprintf(LOG_OUT, "sendto() failed: %d\n", WSAGetLastError());
closesocket(clientSock); closesocket(clientSock);
closesocket(serverSock); closesocket(serverSock);
return PortTestError; return PortTestError;
} }
Sleep(200); Sleep(200);
} }
struct timeval timeout = {}; struct timeval timeout = {};
fd_set fds; fd_set fds;
@ -381,54 +381,54 @@ PortTestStatus TestPort(PSOCKADDR_STORAGE addr, int proto, int port, bool withSe
PortTestStatus TestHttpPort(PSOCKADDR_STORAGE addr, int port) PortTestStatus TestHttpPort(PSOCKADDR_STORAGE addr, int port)
{ {
HINTERNET hInternet; HINTERNET hInternet;
HINTERNET hRequest; HINTERNET hRequest;
char url[1024]; char url[1024];
hInternet = InternetOpenA("MIST", 0, nullptr, nullptr, 0); hInternet = InternetOpenA("MIST", 0, nullptr, nullptr, 0);
if (hInternet == nullptr) { if (hInternet == nullptr) {
fprintf(LOG_OUT, "InternetOpen() failed: %d\n", GetLastError()); fprintf(LOG_OUT, "InternetOpen() failed: %d\n", GetLastError());
return PortTestError; return PortTestError;
} }
char addrStr[64]; char addrStr[64];
inet_ntop(AF_INET, &((struct sockaddr_in*)addr)->sin_addr, addrStr, sizeof(addrStr)); inet_ntop(AF_INET, &((struct sockaddr_in*)addr)->sin_addr, addrStr, sizeof(addrStr));
sprintf(url, "%s://%s:%d/", sprintf(url, "%s://%s:%d/",
port == 47989 ? "http" : "https", port == 47989 ? "http" : "https",
addrStr, addrStr,
port); port);
hRequest = InternetOpenUrlA(hInternet, url, nullptr, 0, hRequest = InternetOpenUrlA(hInternet, url, nullptr, 0,
INTERNET_FLAG_IGNORE_CERT_DATE_INVALID | INTERNET_FLAG_NO_UI | INTERNET_FLAG_NO_AUTH | INTERNET_FLAG_NO_COOKIES | INTERNET_FLAG_RELOAD, INTERNET_FLAG_IGNORE_CERT_DATE_INVALID | INTERNET_FLAG_NO_UI | INTERNET_FLAG_NO_AUTH | INTERNET_FLAG_NO_COOKIES | INTERNET_FLAG_RELOAD,
NULL); NULL);
if (hRequest == nullptr) { if (hRequest == nullptr) {
if (GetLastError() == ERROR_INTERNET_CLIENT_AUTH_CERT_NEEDED) { if (GetLastError() == ERROR_INTERNET_CLIENT_AUTH_CERT_NEEDED) {
// This is expected for our HTTPS connection // This is expected for our HTTPS connection
fprintf(LOG_OUT, "Success\n"); fprintf(LOG_OUT, "Success\n");
} }
else { else {
// CANNOT_CONNECT is the "expected" error // CANNOT_CONNECT is the "expected" error
if (GetLastError() == ERROR_INTERNET_CANNOT_CONNECT) { if (GetLastError() == ERROR_INTERNET_CANNOT_CONNECT) {
fprintf(LOG_OUT, "Failed\n"); fprintf(LOG_OUT, "Failed\n");
} }
else { else {
fprintf(LOG_OUT, "Failed: %d\n", GetLastError()); fprintf(LOG_OUT, "Failed: %d\n", GetLastError());
} }
InternetCloseHandle(hInternet); InternetCloseHandle(hInternet);
return PortTestError; return PortTestError;
} }
} }
else { else {
fprintf(LOG_OUT, "Success\n"); fprintf(LOG_OUT, "Success\n");
InternetCloseHandle(hRequest); InternetCloseHandle(hRequest);
} }
InternetCloseHandle(hInternet); InternetCloseHandle(hInternet);
return PortTestOk; return PortTestOk;
} }
bool TestAllPorts(PSOCKADDR_STORAGE addr, char* portMsg, int portMsgLen, bool consolePrint) bool TestAllPorts(PSOCKADDR_STORAGE addr, char* portMsg, int portMsgLen, bool consolePrint)
@ -440,22 +440,22 @@ bool TestAllPorts(PSOCKADDR_STORAGE addr, char* portMsg, int portMsgLen, bool co
k_Ports[i].proto == IPPROTO_TCP ? "TCP" : "UDP", k_Ports[i].proto == IPPROTO_TCP ? "TCP" : "UDP",
k_Ports[i].port); k_Ports[i].port);
if (consolePrint) { if (consolePrint) {
fprintf(CONSOLE_OUT, "\tTesting %s %d...\n", fprintf(CONSOLE_OUT, "\tTesting %s %d...\n",
k_Ports[i].proto == IPPROTO_TCP ? "TCP" : "UDP", k_Ports[i].proto == IPPROTO_TCP ? "TCP" : "UDP",
k_Ports[i].port); k_Ports[i].port);
} }
PortTestStatus status = TestPort(addr, k_Ports[i].proto, k_Ports[i].port, k_Ports[i].withServer); PortTestStatus status = TestPort(addr, k_Ports[i].proto, k_Ports[i].port, k_Ports[i].withServer);
if (status != PortTestError && !k_Ports[i].withServer) { if (status != PortTestError && !k_Ports[i].withServer) {
// Test using a real HTTP client if the port wasn't totally dead. // Test using a real HTTP client if the port wasn't totally dead.
// This is required to confirm functionality with the loopback relay. // This is required to confirm functionality with the loopback relay.
// TestHttpPort() can take significantly longer to timeout than TestPort(), // TestHttpPort() can take significantly longer to timeout than TestPort(),
// so we only do this test if we believe we're likely to get a response. // so we only do this test if we believe we're likely to get a response.
fprintf(LOG_OUT, "Testing TCP %d with HTTP traffic...", k_Ports[i].port); fprintf(LOG_OUT, "Testing TCP %d with HTTP traffic...", k_Ports[i].port);
status = TestHttpPort(addr, k_Ports[i].port); status = TestHttpPort(addr, k_Ports[i].port);
} }
if (status != PortTestOk) { if (status != PortTestOk) {
// If we got an unknown result, assume it matches with whatever // If we got an unknown result, assume it matches with whatever
@ -750,8 +750,8 @@ bool IsDoubleNAT(PSOCKADDR_IN wanAddr)
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
WSADATA wsaData; WSADATA wsaData;
SYSTEMTIME time; SYSTEMTIME time;
char timeString[MAX_PATH + 1] = {}; char timeString[MAX_PATH + 1] = {};
char tempPath[MAX_PATH + 1]; char tempPath[MAX_PATH + 1];
GetTempPathA(sizeof(tempPath), tempPath); GetTempPathA(sizeof(tempPath), tempPath);
@ -762,10 +762,10 @@ int main(int argc, char* argv[])
// Print a log header // Print a log header
fprintf(LOG_OUT, "Moonlight Internet Streaming Tester v" VER_VERSION_STR "\n"); fprintf(LOG_OUT, "Moonlight Internet Streaming Tester v" VER_VERSION_STR "\n");
// Print the current time // Print the current time
GetSystemTime(&time); GetSystemTime(&time);
GetTimeFormatA(LOCALE_SYSTEM_DEFAULT, 0, &time, "hh':'mm':'ss tt", timeString, ARRAYSIZE(timeString)); GetTimeFormatA(LOCALE_SYSTEM_DEFAULT, 0, &time, "hh':'mm':'ss tt", timeString, ARRAYSIZE(timeString));
fprintf(LOG_OUT, "The current UTC time is: %s\n", timeString); fprintf(LOG_OUT, "The current UTC time is: %s\n", timeString);
// Print a console header // Print a console header
fprintf(CONSOLE_OUT, "Moonlight Internet Streaming Tester v" VER_VERSION_STR "\n\n"); fprintf(CONSOLE_OUT, "Moonlight Internet Streaming Tester v" VER_VERSION_STR "\n\n");
@ -829,7 +829,7 @@ int main(int argc, char* argv[])
return -1; return -1;
} }
fprintf(CONSOLE_OUT, "Testing GameStream connectivity over the Internet...\n"); fprintf(CONSOLE_OUT, "Testing GameStream connectivity over the Internet...\n");
// Detect a double NAT by detecting STUN and and UPnP mismatches // Detect a double NAT by detecting STUN and and UPnP mismatches
if (sin.sin_addr.S_un.S_addr != locallyReportedWanAddr.sin_addr.S_un.S_addr) { if (sin.sin_addr.S_un.S_addr != locallyReportedWanAddr.sin_addr.S_un.S_addr) {
@ -858,27 +858,27 @@ int main(int argc, char* argv[])
snprintf(msgBuf, sizeof(msgBuf), "Your ISP is running a Carrier-Grade NAT that is preventing you from hosting services like Moonlight on the Internet. Click the Help button for guidance on fixing this issue."); snprintf(msgBuf, sizeof(msgBuf), "Your ISP is running a Carrier-Grade NAT that is preventing you from hosting services like Moonlight on the Internet. Click the Help button for guidance on fixing this issue.");
DisplayMessage(msgBuf, "https://github.com/moonlight-stream/moonlight-docs/wiki/Internet-Streaming-Errors#carrier-grade-nat-error"); DisplayMessage(msgBuf, "https://github.com/moonlight-stream/moonlight-docs/wiki/Internet-Streaming-Errors#carrier-grade-nat-error");
} }
else { else {
struct hostent* host; struct hostent* host;
// We can get here if the router doesn't support NAT reflection. // We can get here if the router doesn't support NAT reflection.
// We'll need to call out to our loopback server to get a second opinion. // We'll need to call out to our loopback server to get a second opinion.
fprintf(CONSOLE_OUT, "Testing GameStream connectivity over the Internet using a relay server...\n"); fprintf(CONSOLE_OUT, "Testing GameStream connectivity over the Internet using a relay server...\n");
fprintf(LOG_OUT, "Testing GameStream ports via loopback server\n"); fprintf(LOG_OUT, "Testing GameStream ports via loopback server\n");
host = gethostbyname("loopback.moonlight-stream.org"); host = gethostbyname("loopback.moonlight-stream.org");
if (host != nullptr) { if (host != nullptr) {
sin.sin_addr = *(struct in_addr*)host->h_addr; sin.sin_addr = *(struct in_addr*)host->h_addr;
if (TestAllPorts((PSOCKADDR_STORAGE)&sin, portMsgBuf, sizeof(portMsgBuf), true)) { if (TestAllPorts((PSOCKADDR_STORAGE)&sin, portMsgBuf, sizeof(portMsgBuf), true)) {
goto AllTestsPassed; goto AllTestsPassed;
} }
} }
else { else {
fprintf(LOG_OUT, "gethostbyname() failed: %d\n", WSAGetLastError()); fprintf(LOG_OUT, "gethostbyname() failed: %d\n", WSAGetLastError());
} }
} }
snprintf(msgBuf, sizeof(msgBuf), "Internet GameStream connectivity check failed. Click the Help button for guidance on fixing this issue.\n\nThe following ports were not forwarded properly:\n%s", portMsgBuf); snprintf(msgBuf, sizeof(msgBuf), "Internet GameStream connectivity check failed. Click the Help button for guidance on fixing this issue.\n\nThe following ports were not forwarded properly:\n%s", portMsgBuf);
DisplayMessage(msgBuf, "https://github.com/moonlight-stream/moonlight-docs/wiki/Internet-Streaming-Errors#internet-gamestream-connectivity-check-error"); DisplayMessage(msgBuf, "https://github.com/moonlight-stream/moonlight-docs/wiki/Internet-Streaming-Errors#internet-gamestream-connectivity-check-error");
@ -887,8 +887,8 @@ int main(int argc, char* argv[])
AllTestsPassed: AllTestsPassed:
snprintf(msgBuf, sizeof(msgBuf), "This PC is ready to stream over the Internet!\n\n" snprintf(msgBuf, sizeof(msgBuf), "This PC is ready to stream over the Internet!\n\n"
"For the easiest setup, you should pair Moonlight to your PC from your home network before trying to stream over the Internet.\n\n" "For the easiest setup, you should pair Moonlight to your PC from your home network before trying to stream over the Internet.\n\n"
"If you can't, you can type the following address into Moonlight's Add PC dialog: %s", wanAddrStr); "If you can't, you can type the following address into Moonlight's Add PC dialog: %s", wanAddrStr);
DisplayMessage(msgBuf, nullptr, MpInfo); DisplayMessage(msgBuf, nullptr, MpInfo);
return 0; return 0;