From 7568aa49938c4c8c45d020a6a3f4aabb5aed7f67 Mon Sep 17 00:00:00 2001 From: Vladislav Khorev Date: Sun, 6 Aug 2017 00:47:23 +0300 Subject: [PATCH] First commit --- .gitignore | 365 ++++++++++++++++++++++++++ main.cpp | 521 ++++++++++++++++++++++++++++++++++++++ proxyTest.sln | 28 ++ proxyTest.vcxproj | 132 ++++++++++ proxyTest.vcxproj.filters | 22 ++ 5 files changed, 1068 insertions(+) create mode 100755 .gitignore create mode 100755 main.cpp create mode 100755 proxyTest.sln create mode 100755 proxyTest.vcxproj create mode 100755 proxyTest.vcxproj.filters diff --git a/.gitignore b/.gitignore new file mode 100755 index 0000000..a4f7bbd --- /dev/null +++ b/.gitignore @@ -0,0 +1,365 @@ +# Xcode +# +# gitignore contributors: remember to update Global/Xcode.gitignore, Objective-C.gitignore & Swift.gitignore + +.DS_Store + +## Build generated +build/ +DerivedData/ + +## Various settings +*.pbxuser +!default.pbxuser +*.mode1v3 +!default.mode1v3 +*.mode2v3 +!default.mode2v3 +*.perspectivev3 +!default.perspectivev3 +xcuserdata/ +xcshareddata/ +xcworkspace/ +## Other +*.moved-aside +*.xcuserstate + +## Obj-C/Swift specific +*.hmap +*.ipa +*.dSYM.zip +*.dSYM + +# CocoaPods +# +# We recommend against adding the Pods directory to your .gitignore. However +# you should judge for yourself, the pros and cons are mentioned at: +# https://guides.cocoapods.org/using/using-cocoapods.html#should-i-check-the-pods-directory-into-source-control +# +# Pods/ + +# Carthage +# +# Add this line if you want to avoid checking in source code from Carthage dependencies. +# Carthage/Checkouts + +Carthage/Build + +# fastlane +# +# It is recommended to not store the screenshots in the git repo. Instead, use fastlane to re-generate the +# screenshots whenever they are needed. +# For more information about the recommended setup visit: +# https://github.com/fastlane/fastlane/blob/master/fastlane/docs/Gitignore.md + +fastlane/report.xml +fastlane/screenshots + +# Code Injection +# +# After new code Injection tools there's a generated folder /iOSInjectionProject +# https://github.com/johnno1962/injectionforxcode + +iOSInjectionProject/ +/proj.ios_mac/.idea + +########################### Visual Studio ################ + + +## Ignore Visual Studio temporary files, build results, and +## files generated by popular Visual Studio add-ons. +## +## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore + +# User-specific files +*.suo +*.user +*.userosscache +*.sln.docstates + +# User-specific files (MonoDevelop/Xamarin Studio) +*.userprefs + +# Build results +[Dd]ebug/ +[Dd]ebugPublic/ +[Rr]elease/ +[Rr]eleases/ +x64/ +x86/ +bld/ +[Bb]in/ +[Oo]bj/ +[Ll]og/ + +# Visual Studio 2015 cache/options directory +.vs/ +# Uncomment if you have tasks that create the project's static files in wwwroot +#wwwroot/ + +# MSTest test Results +[Tt]est[Rr]esult*/ +[Bb]uild[Ll]og.* + +# NUNIT +*.VisualState.xml +TestResult.xml + +# Build Results of an ATL Project +[Dd]ebugPS/ +[Rr]eleasePS/ +dlldata.c + +# .NET Core +project.lock.json +project.fragment.lock.json +artifacts/ +**/Properties/launchSettings.json + +*_i.c +*_p.c +*_i.h +*.ilk +*.meta +*.obj +*.pch +*.pdb +*.pgc +*.pgd +*.rsp +*.sbr +*.tlb +*.tli +*.tlh +*.tmp +*.tmp_proj +*.log +*.vspscc +*.vssscc +.builds +*.pidb +*.svclog +*.scc + +# Chutzpah Test files +_Chutzpah* + +# Visual C++ cache files +ipch/ +*.aps +*.ncb +*.opendb +*.opensdf +*.sdf +*.cachefile +*.VC.db +*.VC.VC.opendb + +# Visual Studio profiler +*.psess +*.vsp +*.vspx +*.sap + +# TFS 2012 Local Workspace +$tf/ + +# Guidance Automation Toolkit +*.gpState + +# ReSharper is a .NET coding add-in +_ReSharper*/ +*.[Rr]e[Ss]harper +*.DotSettings.user + +# JustCode is a .NET coding add-in +.JustCode + +# TeamCity is a build add-in +_TeamCity* + +# DotCover is a Code Coverage Tool +*.dotCover + +# Visual Studio code coverage results +*.coverage +*.coveragexml + +# NCrunch +_NCrunch_* +.*crunch*.local.xml +nCrunchTemp_* + +# MightyMoose +*.mm.* +AutoTest.Net/ + +# Web workbench (sass) +.sass-cache/ + +# Installshield output folder +[Ee]xpress/ + +# DocProject is a documentation generator add-in +DocProject/buildhelp/ +DocProject/Help/*.HxT +DocProject/Help/*.HxC +DocProject/Help/*.hhc +DocProject/Help/*.hhk +DocProject/Help/*.hhp +DocProject/Help/Html2 +DocProject/Help/html + +# Click-Once directory +publish/ + +# Publish Web Output +*.[Pp]ublish.xml +*.azurePubxml +# TODO: Comment the next line if you want to checkin your web deploy settings +# but database connection strings (with potential passwords) will be unencrypted +*.pubxml +*.publishproj + +# Microsoft Azure Web App publish settings. Comment the next line if you want to +# checkin your Azure Web App publish settings, but sensitive information contained +# in these scripts will be unencrypted +PublishScripts/ + +# NuGet Packages +*.nupkg +# The packages folder can be ignored because of Package Restore +**/packages/* +# except build/, which is used as an MSBuild target. +!**/packages/build/ +# Uncomment if necessary however generally it will be regenerated when needed +#!**/packages/repositories.config +# NuGet v3's project.json files produces more ignorable files +*.nuget.props +*.nuget.targets + +# Microsoft Azure Build Output +csx/ +*.build.csdef + +# Microsoft Azure Emulator +ecf/ +rcf/ + +# Windows Store app package directories and files +AppPackages/ +BundleArtifacts/ +Package.StoreAssociation.xml +_pkginfo.txt + +# Visual Studio cache files +# files ending in .cache can be ignored +*.[Cc]ache +# but keep track of directories ending in .cache +!*.[Cc]ache/ + +# Others +ClientBin/ +~$* +*~ +*.dbmdl +*.dbproj.schemaview +*.jfm +*.pfx +*.publishsettings +orleans.codegen.cs + +# Since there are multiple workflows, uncomment next line to ignore bower_components +# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622) +#bower_components/ + +# RIA/Silverlight projects +Generated_Code/ + +# Backup & report files from converting an old project file +# to a newer Visual Studio version. Backup files are not needed, +# because we have git ;-) +_UpgradeReport_Files/ +Backup*/ +UpgradeLog*.XML +UpgradeLog*.htm + +# SQL Server files +*.mdf +*.ldf +*.ndf + +# Business Intelligence projects +*.rdl.data +*.bim.layout +*.bim_*.settings + +# Microsoft Fakes +FakesAssemblies/ + +# GhostDoc plugin setting file +*.GhostDoc.xml + +# Node.js Tools for Visual Studio +.ntvs_analysis.dat +node_modules/ + +# Typescript v1 declaration files +typings/ + +# Visual Studio 6 build log +*.plg + +# Visual Studio 6 workspace options file +*.opt + +# Visual Studio 6 auto-generated workspace file (contains which files were open etc.) +*.vbw + +# Visual Studio LightSwitch build output +**/*.HTMLClient/GeneratedArtifacts +**/*.DesktopClient/GeneratedArtifacts +**/*.DesktopClient/ModelManifest.xml +**/*.Server/GeneratedArtifacts +**/*.Server/ModelManifest.xml +_Pvt_Extensions + +# Paket dependency manager +.paket/paket.exe +paket-files/ + +# FAKE - F# Make +.fake/ + +# JetBrains Rider +.idea/ +*.sln.iml + +# CodeRush +.cr/ + +# Python Tools for Visual Studio (PTVS) +__pycache__/ +*.pyc + +# Cake - Uncomment if you are using it +# tools/** +# !tools/packages.config + +# Telerik's JustMock configuration file +*.jmconfig + +# BizTalk build output +*.btp.cs +*.btm.cs +*.odx.cs +*.xsd.cs + +#other +log.txt + +desktop.ini + +xcuserdata +*/*.xcodeproj/project.xcworkspace + diff --git a/main.cpp b/main.cpp new file mode 100755 index 0000000..0741f00 --- /dev/null +++ b/main.cpp @@ -0,0 +1,521 @@ +#include +#include +#include +#include +#include +#include + +enum AddressType +{ + AT_IPV4 = 0, + AT_HOST = 3, + AT_IPV6 = 4 +}; + +class ConnectResponseRecord +{ +public: + std::vector rawData; + + enum ConnectResponseType + { + CRT_SUCCESS = 0, + CRT_GENERAL_SOCKS_SERVER_FAILURE = 1, + CRT_CONNECTION_NOT_ALLOWED_BY_RULESET = 2, + CRT_NETWORK_UNREACHABLE = 3, + CRT_HOST_UNREACHABLE = 4, + CRT_CONNECTION_REFUSED = 5, + CRT_TTL_EXPIRED = 6, + CRT_COMMAND_NOT_SUPPORTED = 7, + CRT_ADDRESS_TYPE_NOT_SUPPORTED = 8, + CRT_TO_FF_UNASSIGNED = 9 + }; + + ConnectResponseType connectResponseType; + + AddressType addressType; + + std::string address; + + uint16_t port; +}; + +class ConnectRequestRecord +{ +public: + std::string address; + uint16_t port; + + std::string getRequestData(); +}; + +std::string ConnectRequestRecord::getRequestData() +{ + std::string data = ""; + data += 0x05; + data += 0x01; + data += char(0x00); + data += 0x03; + data += static_cast(address.size()); + data += address; + data += port / 256; + data += port % 256; + return data; +} + +class proxyClient +{ +public: + proxyClient(boost::asio::io_service& ioServiceIn, boost::asio::ip::tcp::resolver::iterator endpointIn) + : ioService(ioServiceIn) + , socket(ioServiceIn) + { + do_connect(endpointIn); + } + /* + void write(const chat_message& msg) + { + io_service_.post( + [this, msg]() + { + bool write_in_progress = !write_msgs_.empty(); + write_msgs_.push_back(msg); + if (!write_in_progress) + { + do_write(); + } + }); + } + */ + void close() + { + ioService.post([this]() { socket.close(); }); + } + +private: + void do_connect(boost::asio::ip::tcp::resolver::iterator endpointIterator) + { + boost::asio::async_connect(socket, endpointIterator, + [this](boost::system::error_code ec, boost::asio::ip::tcp::resolver::iterator) + { + if (!ec) + { + sendVersion(); + } + }); + } + + + void sendVersion() + { + std::array version = {0x05, 0x01, 0x02}; + + boost::asio::async_write(socket, + boost::asio::buffer(version.data(), + version.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + doReadServerVersion(); + } + else + { + socket.close(); + } + }); + } + + std::array serverVersionMethod; + std::array serverAuthStatus; + + std::vector connectRequestArr; + + void doReadServerVersion() + { + boost::asio::async_read(socket, + boost::asio::buffer(serverVersionMethod.data(), serverVersionMethod.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + if (serverVersionMethod[0] == 5 && serverVersionMethod[1] == 2) + { + doWriteLoginPassword(); + } + else + { + //Others not supported + socket.close(); + } + } + else + { + socket.close(); + } + }); + } + + void doWriteLoginPassword() + { + std::string login = "telegram-proxy-user"; + std::string password = "telegram-telegram-999112"; + std::string data = ""; + data += 0x01; + data += static_cast(login.size()); + data += login; + data += static_cast(password.size()); + data += password; + + boost::asio::async_write(socket, + boost::asio::buffer(data.data(), + data.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + doReadAuthStatus(); + } + else + { + socket.close(); + } + }); + } + + + void connectToWebAddress(std::string address) + { + ConnectRequestRecord record = { address, 80 }; + + connectRequestArr.push_back(record); + + auto data = record.getRequestData(); + + boost::asio::async_write(socket, + boost::asio::buffer(data.data(), + data.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + doReadConnectToWebAddressResponse(); + } + else + { + socket.close(); + } + }); + + } + + + + + void doWriteSomething() + { + //std::array something = { 0x05, 0x01, 0x00, 0x03 }; + + + std::string data = "GET / HTTP/1.1\r\nHost: www.google.com\r\nConnection: close\r\n\r\n"; + + boost::asio::async_write(socket, + boost::asio::buffer(data.data(), + data.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + doReadSomethingText(); + } + else + { + socket.close(); + } + }); + } + + void doReadAuthStatus() + { + boost::asio::async_read(socket, + boost::asio::buffer(serverAuthStatus.data(), serverAuthStatus.size()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + if (serverAuthStatus[0] == 1 && serverAuthStatus[1] == 0) + { + //doWriteSomething(); + + connectToWebAddress("www.google.com"); + } + else + { + //Authorization is not succeed + socket.close(); + } + } + else + { + socket.close(); + } + }); + } + + + void doReadConnectToWebAddressResponse() + { + std::shared_ptr> firstPartPtr = std::make_shared>(); + + boost::asio::async_read(socket, + boost::asio::buffer(firstPartPtr->data(), firstPartPtr->size()), + [this, firstPartPtr](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + doReadConnectToWebAddressResponsePart2(firstPartPtr); + + } + else + { + socket.close(); + } + }); + } + + + void doReadConnectToWebAddressResponsePart2(std::shared_ptr> firstPartPtr) + { + unsigned int size = 3; + if ((*firstPartPtr)[3] == AddressType::AT_IPV4) { + size = 3; + } + if ((*firstPartPtr)[3] == AddressType::AT_HOST) { + size = (*firstPartPtr)[4]; + } + if ((*firstPartPtr)[3] == AddressType::AT_IPV6) { + size = 15; + } + + size += 2; //add port + + std::shared_ptr> secondPartPtr = std::make_shared>(); + + secondPartPtr->resize(size); + + boost::asio::async_read(socket, + boost::asio::buffer(secondPartPtr->data(), secondPartPtr->size()), + [this, firstPartPtr, secondPartPtr](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + ConnectResponseRecord connectResponseRecord; + + connectResponseRecord.rawData.clear(); + + for (unsigned char c : *firstPartPtr) + { + connectResponseRecord.rawData.push_back(c); + } + + for (unsigned char c : *secondPartPtr) + { + connectResponseRecord.rawData.push_back(c); + } + + connectResponseRecord.connectResponseType = static_cast(connectResponseRecord.rawData[1]); + connectResponseRecord.addressType = static_cast(connectResponseRecord.rawData[2]); + + size_t portOffset = 8; + + if (connectResponseRecord.addressType == AddressType::AT_IPV4) + { + connectResponseRecord.address = boost::lexical_cast(static_cast(connectResponseRecord.rawData[4])) + + "." + boost::lexical_cast(static_cast(connectResponseRecord.rawData[5])) + + "." + boost::lexical_cast(static_cast(connectResponseRecord.rawData[6])) + + "." + boost::lexical_cast(static_cast(connectResponseRecord.rawData[7])); + + portOffset = 8; + } + + if (connectResponseRecord.addressType == AddressType::AT_HOST) + { + size_t count = connectResponseRecord.rawData[4]; + + for (size_t i = 0; i < count; i++) + { + connectResponseRecord.address.push_back(connectResponseRecord.rawData[5 + i]); + } + + portOffset = 5 + count; + } + + if (connectResponseRecord.addressType == AddressType::AT_IPV6) + { + + std::stringstream stream; + stream << std::hex << connectResponseRecord.rawData[4]; + stream << std::hex << connectResponseRecord.rawData[5]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[6]; + stream << std::hex << connectResponseRecord.rawData[7]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[8]; + stream << std::hex << connectResponseRecord.rawData[9]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[10]; + stream << std::hex << connectResponseRecord.rawData[11]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[12]; + stream << std::hex << connectResponseRecord.rawData[13]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[14]; + stream << std::hex << connectResponseRecord.rawData[15]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[16]; + stream << std::hex << connectResponseRecord.rawData[17]; + stream << ":"; + stream << std::hex << connectResponseRecord.rawData[18]; + stream << std::hex << connectResponseRecord.rawData[19]; + + connectResponseRecord.address = stream.str(); + + portOffset = 20; + } + + connectResponseRecord.port = connectResponseRecord.rawData[portOffset] * 256 + connectResponseRecord.rawData[portOffset + 1]; + + doWriteSomething(); + } + else + { + socket.close(); + } + }); + } + + unsigned char item; + std::string result; + + void doReadSomething() + { + boost::asio::async_read(socket, + boost::asio::buffer(&item, 1), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + result += boost::lexical_cast(static_cast(item)) + " "; + std::cout << boost::lexical_cast(static_cast(item)) + " "; + doReadSomething(); + } + else + { + socket.close(); + } + }); + } + + void doReadSomethingText() + { + boost::asio::async_read(socket, + boost::asio::buffer(&item, 1), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + result += (item); + std::cout << item; + doReadSomethingText(); + } + else + { + socket.close(); + } + }); + } + + /* + void do_read_header() + { + boost::asio::async_read(socket_, + boost::asio::buffer(read_msg_.data(), chat_message::header_length), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec && read_msg_.decode_header()) + { + do_read_body(); + } + else + { + socket_.close(); + } + }); + } + + void do_read_body() + { + boost::asio::async_read(socket_, + boost::asio::buffer(read_msg_.body(), read_msg_.body_length()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + std::cout.write(read_msg_.body(), read_msg_.body_length()); + std::cout << "\n"; + do_read_header(); + } + else + { + socket_.close(); + } + }); + } + + void do_write() + { + boost::asio::async_write(socket_, + boost::asio::buffer(write_msgs_.front().data(), + write_msgs_.front().length()), + [this](boost::system::error_code ec, std::size_t length) + { + if (!ec) + { + write_msgs_.pop_front(); + if (!write_msgs_.empty()) + { + do_write(); + } + } + else + { + socket_.close(); + } + }); + } + */ +private: + boost::asio::io_service& ioService; + boost::asio::ip::tcp::socket socket; +}; + + +int main() +{ + std::cout << "Hello" << std::endl; + + boost::asio::io_service ioService; + + boost::asio::ip::tcp::resolver resolver(ioService); + auto endpointIterator = resolver.resolve({ "telegram-proxy.fishrungames.com", "8043" }); + + + proxyClient c(ioService, endpointIterator); + + std::thread t([&ioService]() { ioService.run(); }); + + + t.join(); + + return 0; +} \ No newline at end of file diff --git a/proxyTest.sln b/proxyTest.sln new file mode 100755 index 0000000..0a8ee4b --- /dev/null +++ b/proxyTest.sln @@ -0,0 +1,28 @@ + +Microsoft Visual Studio Solution File, Format Version 12.00 +# Visual Studio 14 +VisualStudioVersion = 14.0.25420.1 +MinimumVisualStudioVersion = 10.0.40219.1 +Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "proxyTest", "proxyTest.vcxproj", "{F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}" +EndProject +Global + GlobalSection(SolutionConfigurationPlatforms) = preSolution + Debug|x64 = Debug|x64 + Debug|x86 = Debug|x86 + Release|x64 = Release|x64 + Release|x86 = Release|x86 + EndGlobalSection + GlobalSection(ProjectConfigurationPlatforms) = postSolution + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Debug|x64.ActiveCfg = Debug|x64 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Debug|x64.Build.0 = Debug|x64 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Debug|x86.ActiveCfg = Debug|Win32 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Debug|x86.Build.0 = Debug|Win32 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Release|x64.ActiveCfg = Release|x64 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Release|x64.Build.0 = Release|x64 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Release|x86.ActiveCfg = Release|Win32 + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6}.Release|x86.Build.0 = Release|Win32 + EndGlobalSection + GlobalSection(SolutionProperties) = preSolution + HideSolutionNode = FALSE + EndGlobalSection +EndGlobal diff --git a/proxyTest.vcxproj b/proxyTest.vcxproj new file mode 100755 index 0000000..8cf0acc --- /dev/null +++ b/proxyTest.vcxproj @@ -0,0 +1,132 @@ + + + + + Debug + Win32 + + + Release + Win32 + + + Debug + x64 + + + Release + x64 + + + + {F0289CBE-E968-4DD9-AF3A-0FF0B2F0D5F6} + proxyTest + 8.1 + + + + Application + true + v140 + MultiByte + + + Application + false + v140 + true + MultiByte + + + Application + true + v140 + MultiByte + + + Application + false + v140 + true + MultiByte + + + + + + + + + + + + + + + + + + + + + + + Level3 + Disabled + true + ../boost_1_63_0 + + + true + ../boost_1_63_0/stage/x86/lib/ + + + + + Level3 + Disabled + true + ../boost_1_63_0 + + + true + + + + + Level3 + MaxSpeed + true + true + true + ../boost_1_63_0 + + + true + true + true + ../boost_1_63_0/stage/x86/lib/ + + + + + Level3 + MaxSpeed + true + true + true + ../boost_1_63_0 + + + true + true + true + + + + + + + + + \ No newline at end of file diff --git a/proxyTest.vcxproj.filters b/proxyTest.vcxproj.filters new file mode 100755 index 0000000..d5fe22c --- /dev/null +++ b/proxyTest.vcxproj.filters @@ -0,0 +1,22 @@ + + + + + {4FC737F1-C7A5-4376-A066-2A32D752A2FF} + cpp;c;cc;cxx;def;odl;idl;hpj;bat;asm;asmx + + + {93995380-89BD-4b04-88EB-625FBE52EBFB} + h;hh;hpp;hxx;hm;inl;inc;xsd + + + {67DA6AB6-F800-4c08-8B7A-83BB121AAD01} + rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx;tiff;tif;png;wav;mfcribbon-ms + + + + + Source Files + + + \ No newline at end of file