diff --git a/.github/workflows/dotnet.yml b/.github/workflows/dotnet.yml
index 71634218..39604b70 100644
--- a/.github/workflows/dotnet.yml
+++ b/.github/workflows/dotnet.yml
@@ -1,28 +1,39 @@
-# This workflow will build a .NET project
+# This workflow will build and test a .NET project
# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-net
-name: .NET
+name: .NET CI
on:
push:
- branches: [ "*" ]
+ branches: [ main, develop ]
pull_request:
- branches: [ "*" ]
+ branches: [ main, develop ]
jobs:
build:
-
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
+
- name: Setup .NET
uses: actions/setup-dotnet@v4
with:
dotnet-version: 10.0.x
+
+ - name: Cache NuGet packages
+ uses: actions/cache@v4
+ with:
+ path: ~/.nuget/packages
+ key: ${{ runner.os }}-nuget-${{ hashFiles('**/*.csproj') }}
+ restore-keys: |
+ ${{ runner.os }}-nuget-
+
- name: Restore dependencies
run: dotnet restore
+
- name: Build
- run: dotnet build --no-restore
+ run: dotnet build --no-restore --configuration Release
+
- name: Test
- run: dotnet test --no-build --verbosity normal
+ run: dotnet test --no-build --configuration Release --verbosity normal
diff --git a/.github/workflows/nuget-publish.yml b/.github/workflows/nuget-publish.yml
new file mode 100644
index 00000000..30a482f0
--- /dev/null
+++ b/.github/workflows/nuget-publish.yml
@@ -0,0 +1,282 @@
+name: NuGet Publish
+
+on:
+ push:
+ branches: [ master, develop ]
+ tags: [ '*' ]
+ workflow_dispatch:
+ inputs:
+ version:
+ description: 'Override version (optional)'
+ required: false
+ type: string
+ environment:
+ description: 'Publish environment'
+ required: false
+ default: 'auto'
+ type: choice
+ options:
+ - auto
+ - staging
+ - production
+ create_release:
+ description: 'Create GitHub release (production only)'
+ required: false
+ type: boolean
+ default: false
+ release_notes:
+ description: 'Release notes'
+ required: false
+ type: string
+
+env:
+ DOTNET_VERSION: 10.0.x
+ NUGET_SOURCE: https://api.nuget.org/v3/index.json
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ outputs:
+ version: ${{ steps.setup.outputs.version }}
+ is-nightly: ${{ steps.setup.outputs.is-nightly }}
+ is-release: ${{ steps.setup.outputs.is-release }}
+ should-publish: ${{ steps.setup.outputs.should-publish }}
+ environment: ${{ steps.setup.outputs.environment }}
+ create-release: ${{ steps.setup.outputs.create-release }}
+
+ steps:
+ - uses: actions/checkout@v4
+ with:
+ fetch-depth: 0
+
+ - name: Setup .NET
+ uses: actions/setup-dotnet@v4
+ with:
+ dotnet-version: ${{ env.DOTNET_VERSION }}
+
+ - name: Cache NuGet packages
+ uses: actions/cache@v4
+ with:
+ path: ~/.nuget/packages
+ key: ${{ runner.os }}-nuget-${{ hashFiles('**/*.csproj') }}
+ restore-keys: |
+ ${{ runner.os }}-nuget-
+
+ - name: Restore dependencies
+ run: dotnet restore
+
+ - name: Build
+ run: dotnet build --no-restore --configuration Release
+
+ - name: Test
+ run: dotnet test --no-build --configuration Release --verbosity normal
+
+ - name: Setup version and publishing strategy
+ id: setup
+ uses: actions/github-script@v7
+ with:
+ script: |
+ const core = require('@actions/core');
+
+ // Get current context
+ const ref = context.ref;
+ const eventName = context.eventName;
+ const inputs = context.payload.inputs || {};
+
+ // Initialize variables
+ let version = '';
+ let isNightly = false;
+ let isRelease = false;
+ let shouldPublish = false;
+ let environment = 'auto';
+ let createRelease = false;
+
+ // Handle manual override
+ if (inputs.version) {
+ version = inputs.version;
+ environment = inputs.environment || 'auto';
+ isNightly = version.includes('nightly');
+ isRelease = !isNightly && !version.includes('preview');
+ shouldPublish = true;
+ createRelease = inputs.create_release === true && isRelease;
+ } else {
+ // Automatic version detection
+ if (ref === 'refs/heads/develop') {
+ // Nightly builds for develop branch
+ const timestamp = new Date().toISOString().replace(/[:.]/g, '-').slice(0, 19);
+ const commitSha = context.sha.substring(0, 7);
+ version = `1.0.0-nightly-${timestamp}-${commitSha}`;
+ isNightly = true;
+ shouldPublish = true;
+ environment = 'nightly';
+ } else if (ref.startsWith('refs/tags/')) {
+ // Release from git tag
+ version = ref.replace('refs/tags/v', '');
+ version = ref.replace('refs/tags/', '');
+ isRelease = true;
+ shouldPublish = true;
+ environment = 'production';
+ // Create GitHub release for all tags
+ createRelease = true;
+ } else if (eventName === 'release') {
+ // Release from GitHub release
+ version = context.payload.release.tag_name;
+ isRelease = true;
+ shouldPublish = true;
+ environment = 'production';
+ } else if (ref === 'refs/heads/main') {
+ // Main branch builds (preview versions)
+ version = `1.0.0-preview-${context.runNumber}`;
+ environment = 'staging';
+ shouldPublish = false; // Don't auto-publish from main
+ }
+ }
+
+ // Resolve auto environment
+ if (environment === 'auto') {
+ environment = isNightly ? 'nightly' : isRelease ? 'production' : 'staging';
+ }
+
+ // Validate version format (basic check)
+ if (!version.match(/^\d+\.\d+\.\d+(-[\w\.\-]+)?$/)) {
+ core.setFailed(`Invalid version format: ${version}`);
+ return;
+ }
+
+ // Set outputs
+ core.setOutput('version', version);
+ core.setOutput('is-nightly', isNightly);
+ core.setOutput('is-release', isRelease);
+ core.setOutput('should-publish', shouldPublish);
+ core.setOutput('environment', environment);
+ core.setOutput('create-release', createRelease && ref.startsWith('refs/tags/'));
+
+ // Log information
+ console.log(`Version: ${version}`);
+ console.log(`Is Nightly: ${isNightly}`);
+ console.log(`Is Release: ${isRelease}`);
+ console.log(`Should Publish: ${shouldPublish}`);
+ console.log(`Environment: ${environment}`);
+ console.log(`Create Release: ${createRelease}`);
+
+ - name: Pack
+ run: |
+ dotnet pack Netorrent/Netorrent.csproj \
+ --configuration Release \
+ --output ./artifacts \
+ -p:PackageVersion=${{ steps.setup.outputs.version }} \
+ -p:ContinuousIntegrationBuild=true \
+ -p:IncludeSymbols=true
+
+ - name: Validate packages
+ run: |
+ dotnet nuget verify ./artifacts/*.nupkg --all
+ dotnet nuget verify ./artifacts/*.snupkg --all
+
+ - name: List packages
+ if: steps.setup.outputs.should-publish == 'true'
+ run: |
+ echo "Generated packages:"
+ ls -la ./artifacts/ || echo "No artifacts found"
+
+ - name: Upload artifacts
+ uses: actions/upload-artifact@v4
+ if: steps.setup.outputs.should-publish == 'true'
+ with:
+ name: nuget-packages-${{ steps.setup.outputs.version }}
+ path: ./artifacts/*.nupkg
+ retention-days: ${{ steps.setup.outputs.is-nightly == 'true' && '30' || '90' }}
+
+ publish:
+ needs: build
+ runs-on: ubuntu-latest
+ if: needs.build.outputs.should-publish == 'true'
+ environment: ${{ needs.build.outputs.environment }}
+
+ steps:
+ - name: Download artifacts
+ uses: actions/download-artifact@v4
+ with:
+ name: nuget-packages-${{ needs.build.outputs.version }}
+ path: ./artifacts
+
+ - name: Setup .NET
+ uses: actions/setup-dotnet@v4
+ with:
+ dotnet-version: ${{ env.DOTNET_VERSION }}
+
+ - name: Publish to NuGet
+ run: |
+ dotnet nuget push ./artifacts/*.nupkg \
+ --source ${{ env.NUGET_SOURCE }} \
+ --api-key ${{ secrets.NUGET_API_KEY }} \
+ --skip-duplicate
+ env:
+ NUGET_API_KEY: ${{ secrets.NUGET_API_KEY }}
+
+ - name: Publish symbols
+ run: |
+ dotnet nuget push ./artifacts/*.snupkg \
+ --source ${{ env.NUGET_SOURCE }} \
+ --api-key ${{ secrets.NUGET_API_KEY }} \
+ --skip-duplicate
+ env:
+ NUGET_API_KEY: ${{ secrets.NUGET_API_KEY }}
+
+ - name: Create GitHub Release
+ if: needs.build.outputs.create-release == 'true'
+ uses: actions/create-release@v1
+ env:
+ GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+ with:
+ tag_name: ${{ needs.build.outputs.version }}
+ release_name: Release ${{ needs.build.outputs.version }}
+ body: |
+ ## 📦 Package Information
+ - **Version**: `${{ needs.build.outputs.version }}`
+ - **NuGet**: [Netorrent.${{ needs.build.outputs.version }}](https://www.nuget.org/packages/Netorrent/${{ needs.build.outputs.version }})
+ - **Installation**: `dotnet add package Netorrent --version ${{ needs.build.outputs.version }}`
+
+ ${{ github.event.inputs.release_notes || '' }}
+
+ ---
+
+ 🤖 *This release was automatically generated. Check [Actions](https://github.com/${{ github.repository }}/actions) for build details.*
+ draft: false
+ prerelease: ${{ contains(needs.build.outputs.version, 'nightly') || contains(needs.build.outputs.version, 'preview') || contains(needs.build.outputs.version, 'rc') }}
+
+ - name: Upload release assets
+ if: needs.build.outputs.create-release == 'true'
+ uses: actions/github-script@v7
+ with:
+ script: |
+ const fs = require('fs');
+ const path = require('path');
+
+ const version = '${{ needs.build.outputs.version }}';
+ const artifactsDir = './artifacts';
+
+ // Get release ID
+ const { data: release } = await github.rest.repos.getReleaseByTag({
+ owner: context.repo.owner,
+ repo: context.repo.repo,
+ tag: version
+ });
+
+ // Upload all .nupkg and .snupkg files
+ const files = fs.readdirSync(artifactsDir)
+ .filter(file => file.endsWith('.nupkg') || file.endsWith('.snupkg'));
+
+ for (const file of files) {
+ const filePath = path.join(artifactsDir, file);
+ const fileData = fs.readFileSync(filePath);
+
+ await github.rest.repos.uploadReleaseAsset({
+ owner: context.repo.owner,
+ repo: context.repo.repo,
+ release_id: release.id,
+ name: file,
+ data: fileData
+ });
+ }
+
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 00000000..f288702d
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,674 @@
+ GNU GENERAL PUBLIC LICENSE
+ Version 3, 29 June 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc.
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+ Preamble
+
+ The GNU General Public License is a free, copyleft license for
+software and other kinds of works.
+
+ The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works. By contrast,
+the GNU General Public License is intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users. We, the Free Software Foundation, use the
+GNU General Public License for most of our software; it applies also to
+any other work released this way by its authors. You can apply it to
+your programs, too.
+
+ When we speak of free software, we are referring to freedom, not
+price. Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+ To protect your rights, we need to prevent others from denying you
+these rights or asking you to surrender the rights. Therefore, you have
+certain responsibilities if you distribute copies of the software, or if
+you modify it: responsibilities to respect the freedom of others.
+
+ For example, if you distribute copies of such a program, whether
+gratis or for a fee, you must pass on to the recipients the same
+freedoms that you received. You must make sure that they, too, receive
+or can get the source code. And you must show them these terms so they
+know their rights.
+
+ Developers that use the GNU GPL protect your rights with two steps:
+(1) assert copyright on the software, and (2) offer you this License
+giving you legal permission to copy, distribute and/or modify it.
+
+ For the developers' and authors' protection, the GPL clearly explains
+that there is no warranty for this free software. For both users' and
+authors' sake, the GPL requires that modified versions be marked as
+changed, so that their problems will not be attributed erroneously to
+authors of previous versions.
+
+ Some devices are designed to deny users access to install or run
+modified versions of the software inside them, although the manufacturer
+can do so. This is fundamentally incompatible with the aim of
+protecting users' freedom to change the software. The systematic
+pattern of such abuse occurs in the area of products for individuals to
+use, which is precisely where it is most unacceptable. Therefore, we
+have designed this version of the GPL to prohibit the practice for those
+products. If such problems arise substantially in other domains, we
+stand ready to extend this provision to those domains in future versions
+of the GPL, as needed to protect the freedom of users.
+
+ Finally, every program is threatened constantly by software patents.
+States should not allow patents to restrict development and use of
+software on general-purpose computers, but in those that do, we wish to
+avoid the special danger that patents applied to a free program could
+make it effectively proprietary. To prevent this, the GPL assures that
+patents cannot be used to render the program non-free.
+
+ The precise terms and conditions for copying, distribution and
+modification follow.
+
+ TERMS AND CONDITIONS
+
+ 0. Definitions.
+
+ "This License" refers to version 3 of the GNU General Public License.
+
+ "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+ "The Program" refers to any copyrightable work licensed under this
+License. Each licensee is addressed as "you". "Licensees" and
+"recipients" may be individuals or organizations.
+
+ To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy. The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+ A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+ To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy. Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+ To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies. Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+ An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License. If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+ 1. Source Code.
+
+ The "source code" for a work means the preferred form of the work
+for making modifications to it. "Object code" means any non-source
+form of a work.
+
+ A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+ The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form. A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+ The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities. However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work. For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+ The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+ The Corresponding Source for a work in source code form is that
+same work.
+
+ 2. Basic Permissions.
+
+ All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met. This License explicitly affirms your unlimited
+permission to run the unmodified Program. The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work. This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+ You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force. You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright. Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+ Conveying under any other circumstances is permitted solely under
+the conditions stated below. Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+ 3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+ No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+ When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+ 4. Conveying Verbatim Copies.
+
+ You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+ You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+ 5. Conveying Modified Source Versions.
+
+ You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+ a) The work must carry prominent notices stating that you modified
+ it, and giving a relevant date.
+
+ b) The work must carry prominent notices stating that it is
+ released under this License and any conditions added under section
+ 7. This requirement modifies the requirement in section 4 to
+ "keep intact all notices".
+
+ c) You must license the entire work, as a whole, under this
+ License to anyone who comes into possession of a copy. This
+ License will therefore apply, along with any applicable section 7
+ additional terms, to the whole of the work, and all its parts,
+ regardless of how they are packaged. This License gives no
+ permission to license the work in any other way, but it does not
+ invalidate such permission if you have separately received it.
+
+ d) If the work has interactive user interfaces, each must display
+ Appropriate Legal Notices; however, if the Program has interactive
+ interfaces that do not display Appropriate Legal Notices, your
+ work need not make them do so.
+
+ A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit. Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+ 6. Conveying Non-Source Forms.
+
+ You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+ a) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by the
+ Corresponding Source fixed on a durable physical medium
+ customarily used for software interchange.
+
+ b) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by a
+ written offer, valid for at least three years and valid for as
+ long as you offer spare parts or customer support for that product
+ model, to give anyone who possesses the object code either (1) a
+ copy of the Corresponding Source for all the software in the
+ product that is covered by this License, on a durable physical
+ medium customarily used for software interchange, for a price no
+ more than your reasonable cost of physically performing this
+ conveying of source, or (2) access to copy the
+ Corresponding Source from a network server at no charge.
+
+ c) Convey individual copies of the object code with a copy of the
+ written offer to provide the Corresponding Source. This
+ alternative is allowed only occasionally and noncommercially, and
+ only if you received the object code with such an offer, in accord
+ with subsection 6b.
+
+ d) Convey the object code by offering access from a designated
+ place (gratis or for a charge), and offer equivalent access to the
+ Corresponding Source in the same way through the same place at no
+ further charge. You need not require recipients to copy the
+ Corresponding Source along with the object code. If the place to
+ copy the object code is a network server, the Corresponding Source
+ may be on a different server (operated by you or a third party)
+ that supports equivalent copying facilities, provided you maintain
+ clear directions next to the object code saying where to find the
+ Corresponding Source. Regardless of what server hosts the
+ Corresponding Source, you remain obligated to ensure that it is
+ available for as long as needed to satisfy these requirements.
+
+ e) Convey the object code using peer-to-peer transmission, provided
+ you inform other peers where the object code and Corresponding
+ Source of the work are being offered to the general public at no
+ charge under subsection 6d.
+
+ A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+ A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling. In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage. For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product. A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+ "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source. The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+ If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information. But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+ The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed. Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+ Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+ 7. Additional Terms.
+
+ "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law. If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+ When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it. (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.) You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+ Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+ a) Disclaiming warranty or limiting liability differently from the
+ terms of sections 15 and 16 of this License; or
+
+ b) Requiring preservation of specified reasonable legal notices or
+ author attributions in that material or in the Appropriate Legal
+ Notices displayed by works containing it; or
+
+ c) Prohibiting misrepresentation of the origin of that material, or
+ requiring that modified versions of such material be marked in
+ reasonable ways as different from the original version; or
+
+ d) Limiting the use for publicity purposes of names of licensors or
+ authors of the material; or
+
+ e) Declining to grant rights under trademark law for use of some
+ trade names, trademarks, or service marks; or
+
+ f) Requiring indemnification of licensors and authors of that
+ material by anyone who conveys the material (or modified versions of
+ it) with contractual assumptions of liability to the recipient, for
+ any liability that these contractual assumptions directly impose on
+ those licensors and authors.
+
+ All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10. If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term. If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+ If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+ Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+ 8. Termination.
+
+ You may not propagate or modify a covered work except as expressly
+provided under this License. Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+ However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+ Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+ Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License. If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+ 9. Acceptance Not Required for Having Copies.
+
+ You are not required to accept this License in order to receive or
+run a copy of the Program. Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance. However,
+nothing other than this License grants you permission to propagate or
+modify any covered work. These actions infringe copyright if you do
+not accept this License. Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+ 10. Automatic Licensing of Downstream Recipients.
+
+ Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License. You are not responsible
+for enforcing compliance by third parties with this License.
+
+ An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations. If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+ You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License. For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+ 11. Patents.
+
+ A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based. The
+work thus licensed is called the contributor's "contributor version".
+
+ A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version. For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+ Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+ In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement). To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+ If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients. "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+ If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+ A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License. You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+ Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+ 12. No Surrender of Others' Freedom.
+
+ If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License. If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all. For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+ 13. Use with the GNU Affero General Public License.
+
+ Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU Affero General Public License into a single
+combined work, and to convey the resulting work. The terms of this
+License will continue to apply to the part which is the covered work,
+but the special requirements of the GNU Affero General Public License,
+section 13, concerning interaction through a network will apply to the
+combination as such.
+
+ 14. Revised Versions of this License.
+
+ The Free Software Foundation may publish revised and/or new versions of
+the GNU General Public License from time to time. Such new versions will
+be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+ Each version is given a distinguishing version number. If the
+Program specifies that a certain numbered version of the GNU General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation. If the Program does not specify a version number of the
+GNU General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+ If the Program specifies that a proxy can decide which future
+versions of the GNU General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+ Later license versions may give you additional or different
+permissions. However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+ 15. Disclaimer of Warranty.
+
+ THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW. EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE. THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+ 16. Limitation of Liability.
+
+ IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+ 17. Interpretation of Sections 15 and 16.
+
+ If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+ END OF TERMS AND CONDITIONS
+
+ How to Apply These Terms to Your New Programs
+
+ If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+ To do so, attach the following notices to the program. It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+
+ Copyright (C)
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program. If not, see .
+
+Also add information on how to contact you by electronic and paper mail.
+
+ If the program does terminal interaction, make it output a short
+notice like this when it starts in an interactive mode:
+
+ Copyright (C)
+ This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
+ This is free software, and you are welcome to redistribute it
+ under certain conditions; type `show c' for details.
+
+The hypothetical commands `show w' and `show c' should show the appropriate
+parts of the General Public License. Of course, your program's commands
+might be different; for a GUI interface, you would use an "about box".
+
+ You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU GPL, see
+.
+
+ The GNU General Public License does not permit incorporating your program
+into proprietary programs. If your program is a subroutine library, you
+may consider it more useful to permit linking proprietary applications with
+the library. If this is what you want to do, use the GNU Lesser General
+Public License instead of this License. But first, please read
+.
diff --git a/Netorrent.Example/Netorrent.Example.csproj b/Netorrent.Example/Netorrent.Example.csproj
index f1a43186..7eec74b7 100644
--- a/Netorrent.Example/Netorrent.Example.csproj
+++ b/Netorrent.Example/Netorrent.Example.csproj
@@ -9,6 +9,7 @@
+
diff --git a/Netorrent.Example/Program.cs b/Netorrent.Example/Program.cs
index 320bca7a..0e7a1756 100644
--- a/Netorrent.Example/Program.cs
+++ b/Netorrent.Example/Program.cs
@@ -1,31 +1,265 @@
-// See https://aka.ms/new-console-template for more information
-using Microsoft.Extensions.Logging;
-using Netorrent.TorrentFile;
+using Netorrent.TorrentFile;
+using Spectre.Console;
-ILogger logger = LoggerFactory.Create(builder => builder.AddConsole()).CreateLogger("TorrentCLI");
+using var cts = new CancellationTokenSource();
-var torrentClient = new TorrentClient(o => o with { Logger = logger });
-await using var torrent = await torrentClient.ImportTorrentAsync(
- "C:\\Users\\elrob\\Downloads\\debian-13.2.0-amd64-netinst.iso.torrent",
- "D:\\output"
-);
+Console.CancelKeyPress += (s, e) =>
+{
+ e.Cancel = true;
+ cts.Cancel();
+};
+try
+{
+ var torrentPath = await BrowseForTorrent(cts.Token);
+ var outputPath = await BrowseForOutputDir(cts.Token);
+
+ await using var client = new TorrentClient();
+ await using var torrent = await client.LoadTorrentAsync(
+ torrentPath,
+ outputPath,
+ cancellationToken: cts.Token
+ );
+ cts.Token.Register(torrent.Stop);
+ var statusTask = RunStatusUI(torrent, cts.Token);
+
+ await torrent.CheckAsync(cts.Token);
+ await torrent.StartAsync();
+
+ await Task.WhenAll(Task.Delay(-1, cts.Token), torrent.Completion.AsTask());
-var task = Task.Run(async () =>
+ AnsiConsole.MarkupLine("[green]Download complete.[/]");
+}
+catch (OperationCanceledException oce) when (oce.CancellationToken == cts.Token)
{
+ AnsiConsole.MarkupLine("[yellow]Canceled by user.[/]");
+}
+catch (Exception ex)
+{
+ AnsiConsole.MarkupLine($"[yellow]Error {ex.Message.EscapeMarkup()}[/]");
+ AnsiConsole.MarkupLine($"[yellow]Stacktrace {ex.StackTrace.EscapeMarkup()}[/]");
+}
+
+static async ValueTask BrowseForOutputDir(CancellationToken cancellationToken)
+{
+ var current = Directory.GetCurrentDirectory();
+
while (true)
{
- logger.LogInformation(
- "Downloaded {downloaded}/{total} at {speed}, from {active}/{total} active peers",
- torrent.DownloadInfo.DownloadedBytes,
- torrent.DownloadInfo.TotalBytes,
- torrent.DownloadInfo.DownloadSpeed,
- torrent.DownloadInfo.ActivePeers,
- torrent.DownloadInfo.TotalPeers
+ string[] dirs;
+ try
+ {
+ dirs = Directory.GetDirectories(current);
+ }
+ catch (Exception ex) when (ex is UnauthorizedAccessException || ex is IOException)
+ {
+ AnsiConsole.MarkupLine(
+ $"[red]Cannot enumerate directory: {ex.Message.EscapeMarkup()}[/]"
+ );
+ var parent = Directory.GetParent(current);
+ if (parent == null)
+ {
+ // If we cannot read the start folder and there's no parent, fall back to current directory.
+ current = Directory.GetCurrentDirectory();
+ }
+ else
+ {
+ current = parent.FullName;
+ }
+ continue;
+ }
+
+ List items =
+ [
+ ".. (up)",
+ .. dirs.Select(d =>
+ {
+ var name = Path.GetFileName(d);
+ if (string.IsNullOrEmpty(name)) // root drive (e.g. "C:\")
+ name = d;
+ return $"(dir) {name}";
+ }),
+ "(select) Use this directory",
+ "(new) Create new directory here",
+ ];
+
+ var choice = await AnsiConsole.PromptAsync(
+ new SelectionPrompt()
+ .Title($"Browsing output directories: [green]{current.EscapeMarkup()}[/]")
+ .PageSize(20)
+ .AddChoices(items.Select(StringExtensions.EscapeMarkup)),
+ cancellationToken
);
- await Task.Delay(1000);
+
+ if (choice == ".. (up)")
+ {
+ var parent = Directory.GetParent(current);
+ if (parent == null)
+ {
+ // already at root, ignore
+ continue;
+ }
+ current = parent.FullName;
+ continue;
+ }
+
+ if (choice.StartsWith("(dir) "))
+ {
+ var name = choice.RemoveMarkup().Substring("(dir) ".Length);
+ // If name is a full path (happens for root), prefer that
+ string candidate =
+ dirs.FirstOrDefault(d =>
+ Path.GetFileName(d).Equals(name, StringComparison.OrdinalIgnoreCase)
+ || string.Equals(d, name, StringComparison.OrdinalIgnoreCase)
+ ) ?? Path.Combine(current, name);
+ current = Path.GetFullPath(candidate);
+ continue;
+ }
+
+ if (choice == "(select) Use this directory")
+ {
+ return current;
+ }
+
+ if (choice == "(new) Create new directory here")
+ {
+ var newName = await AnsiConsole.PromptAsync(
+ new TextPrompt("Enter new directory name:").Validate(n =>
+ {
+ if (string.IsNullOrWhiteSpace(n))
+ return ValidationResult.Error("[red]Name cannot be empty[/]");
+ if (n.IndexOfAny(Path.GetInvalidFileNameChars()) >= 0)
+ return ValidationResult.Error("[red]Name contains invalid characters[/]");
+ return ValidationResult.Success();
+ }),
+ cancellationToken
+ );
+
+ var newPath = Path.Combine(current, newName);
+
+ try
+ {
+ Directory.CreateDirectory(newPath);
+ current = Path.GetFullPath(newPath);
+ }
+ catch (Exception ex)
+ when (ex is UnauthorizedAccessException
+ || ex is IOException
+ || ex is ArgumentException
+ )
+ {
+ AnsiConsole.MarkupLine(
+ $"[red]Could not create directory: {ex.Message.EscapeMarkup()}[/]"
+ );
+ }
+
+ continue;
+ }
}
-});
-await torrent.StartAsync();
+}
+
+static async ValueTask BrowseForTorrent(CancellationToken cancellationToken)
+{
+ var current = Directory.GetCurrentDirectory();
+
+ while (true)
+ {
+ var dirs = Directory
+ .GetDirectories(current)
+ .Select(d => ("D", Path.GetFileName(d), d))
+ .ToList();
+
+ var files = Directory
+ .GetFiles(current, "*.torrent")
+ .Select(f => ("F", Path.GetFileName(f), f))
+ .ToList();
+
+ List items =
+ [
+ ".. (up)",
+ .. dirs.Select(t => $"(dir) {t.Item2}"),
+ .. files.Select(t => $"(file) {t.Item2}"),
+ ];
+
+ var choice = await AnsiConsole.PromptAsync(
+ new SelectionPrompt()
+ .Title($"Browsing: [green]{current.EscapeMarkup()}[/]")
+ .PageSize(20)
+ .AddChoices(items.Select(StringExtensions.EscapeMarkup)),
+ cancellationToken
+ );
+
+ if (choice == ".. (up)")
+ {
+ var parent = Directory.GetParent(current);
+ if (parent == null)
+ continue;
+ current = parent.FullName;
+ continue;
+ }
+
+ if (choice.StartsWith("(dir) "))
+ {
+ var name = choice.RemoveMarkup().Substring("(dir) ".Length);
+ current = Path.Combine(current, name);
+ continue;
+ }
+
+ if (choice.StartsWith("(file) "))
+ {
+ var name = choice.RemoveMarkup().Substring("(file) ".Length);
+ return Path.Combine(current, name);
+ }
+ }
+}
+
+static async Task RunStatusUI(Torrent torrent, CancellationToken token) =>
+ await AnsiConsole
+ .Progress()
+ .AutoClear(false)
+ .Columns(
+ new TaskDescriptionColumn(),
+ new ProgressBarColumn
+ {
+ CompletedStyle = new Style(Color.Green),
+ FinishedStyle = new Style(Color.Lime),
+ RemainingStyle = new Style(Color.Grey),
+ },
+ new PercentageColumn(),
+ new RemainingTimeColumn(),
+ new SpinnerColumn()
+ )
+ .StartAsync(async ctx =>
+ {
+ var checkTask = ctx.AddTask("Checking", autoStart: true);
+ var progressTask = ctx.AddTask("Downloading", autoStart: true);
+ var uploadTask = ctx.AddTask("Uploading", autoStart: true);
+
+ // Initialize
+ checkTask.MaxValue(torrent.Statistics.Check.TotalPiecesCount);
+ progressTask.MaxValue(torrent.Statistics.Data.Total.Bytes);
+ uploadTask.IsIndeterminate(true);
+ progressTask.IsIndeterminate(true);
+
+ while (!token.IsCancellationRequested)
+ {
+ if (checkTask.IsFinished)
+ {
+ progressTask.IsIndeterminate(false);
+ }
+
+ checkTask.Value(torrent.Statistics.Check.CheckedPiecesCount);
+ progressTask.Value(torrent.Statistics.Data.Verified.Bytes);
+ uploadTask.Value(torrent.Statistics.Data.Uploaded.Bytes);
+ var desc = progressTask.Description = (
+ torrent.MetaInfo.Title ?? torrent.MetaInfo.Info.Name
+ ).EscapeMarkup();
+
+ checkTask.Description = $@"Checking {desc}";
+ progressTask.Description = $@"Downloading {desc}";
+ uploadTask.Description = $@"Uploading {desc}";
+
+ await Task.Delay(1000, token);
+ }
-var taskFinished = await Task.WhenAny(torrent.DownloadInfo.DownloadTask, task);
-await taskFinished;
+ progressTask.StopTask();
+ });
diff --git a/Netorrent.Tests.Integration/Data/debian-13.3.0-amd64-netinst.iso.torrent b/Netorrent.Tests.Integration/Data/debian-13.3.0-amd64-netinst.iso.torrent
new file mode 100644
index 00000000..c13b2021
Binary files /dev/null and b/Netorrent.Tests.Integration/Data/debian-13.3.0-amd64-netinst.iso.torrent differ
diff --git a/Netorrent.Tests/Fixtures/OpenTrackerFixture.cs b/Netorrent.Tests.Integration/Fixtures/OpenTrackerFixture.cs
similarity index 96%
rename from Netorrent.Tests/Fixtures/OpenTrackerFixture.cs
rename to Netorrent.Tests.Integration/Fixtures/OpenTrackerFixture.cs
index 606a55d8..4985b450 100644
--- a/Netorrent.Tests/Fixtures/OpenTrackerFixture.cs
+++ b/Netorrent.Tests.Integration/Fixtures/OpenTrackerFixture.cs
@@ -2,7 +2,7 @@
using TUnit.Core.Interfaces;
using IContainer = DotNet.Testcontainers.Containers.IContainer;
-namespace Netorrent.Tests.Fixtures;
+namespace Netorrent.Tests.Integration.Fixtures;
public class OpenTrackerFixture : IAsyncInitializer, IAsyncDisposable
{
diff --git a/Netorrent.Tests.Integration/Netorrent.Tests.Integration.csproj b/Netorrent.Tests.Integration/Netorrent.Tests.Integration.csproj
new file mode 100644
index 00000000..e182a278
--- /dev/null
+++ b/Netorrent.Tests.Integration/Netorrent.Tests.Integration.csproj
@@ -0,0 +1,21 @@
+
+
+ net10.0
+ enable
+ enable
+ false
+ true
+
+
+
+
+
+
+
+
+
+
+ PreserveNewest
+
+
+
diff --git a/Netorrent.Tests/TUnitLogger.cs b/Netorrent.Tests.Integration/TUnitLogger.cs
similarity index 98%
rename from Netorrent.Tests/TUnitLogger.cs
rename to Netorrent.Tests.Integration/TUnitLogger.cs
index dfd8c345..b4b672fc 100644
--- a/Netorrent.Tests/TUnitLogger.cs
+++ b/Netorrent.Tests.Integration/TUnitLogger.cs
@@ -1,6 +1,6 @@
using TUnit.Core.Logging;
-namespace Netorrent.Tests;
+namespace Netorrent.Tests.Integration;
internal class TUnitLogger(DefaultLogger logger) : Microsoft.Extensions.Logging.ILogger
{
diff --git a/Netorrent.Tests/Torrents/Hooks.cs b/Netorrent.Tests.Integration/Torrents/Hooks.cs
similarity index 91%
rename from Netorrent.Tests/Torrents/Hooks.cs
rename to Netorrent.Tests.Integration/Torrents/Hooks.cs
index e95e94fa..a4fc447c 100644
--- a/Netorrent.Tests/Torrents/Hooks.cs
+++ b/Netorrent.Tests.Integration/Torrents/Hooks.cs
@@ -1,4 +1,4 @@
-namespace Netorrent.Tests.Torrents;
+namespace Netorrent.Tests.Integration.Torrents;
public static class Hooks
{
diff --git a/Netorrent.Tests.Integration/Torrents/RealTorrentTests.cs b/Netorrent.Tests.Integration/Torrents/RealTorrentTests.cs
new file mode 100644
index 00000000..d3961a56
--- /dev/null
+++ b/Netorrent.Tests.Integration/Torrents/RealTorrentTests.cs
@@ -0,0 +1,24 @@
+using Microsoft.Extensions.Logging;
+using Netorrent.TorrentFile;
+
+namespace Netorrent.Tests.Integration.Torrents;
+
+[Timeout(5 * 60_000)]
+public class RealTorrentTests
+{
+ private static ILogger Logger => new TUnitLogger(TestContext.Current!.GetDefaultLogger());
+
+ [Test]
+ public async Task Should_Download_Real_Torrent(CancellationToken cancellationToken)
+ {
+ await using var torrentClient = new TorrentClient(o => o with { Logger = Logger });
+ await using var torrent = await torrentClient.LoadTorrentAsync(
+ "Data/debian-13.3.0-amd64-netinst.iso.torrent",
+ "Output",
+ cancellationToken: cancellationToken
+ );
+ cancellationToken.Register(torrent.Stop);
+ await torrent.StartAsync();
+ await torrent.Completion;
+ }
+}
diff --git a/Netorrent.Tests.Integration/Torrents/TorrentTests.cs b/Netorrent.Tests.Integration/Torrents/TorrentTests.cs
new file mode 100644
index 00000000..39150fdf
--- /dev/null
+++ b/Netorrent.Tests.Integration/Torrents/TorrentTests.cs
@@ -0,0 +1,515 @@
+using System.Net;
+using System.Net.Sockets;
+using Microsoft.Extensions.Logging;
+using Netorrent.Extensions;
+using Netorrent.Tests.Integration.Fixtures;
+using Netorrent.TorrentFile;
+using Netorrent.TorrentFile.FileStructure;
+using Shouldly;
+
+namespace Netorrent.Tests.Integration.Torrents;
+
+[ClassDataSource(Shared = SharedType.PerClass)]
+[Timeout(5 * 60_000)]
+public class TorrentTests(OpenTrackerFixture fixture)
+{
+ private readonly OpenTrackerFixture _fixture = fixture;
+ private static ILogger Logger => new TUnitLogger(TestContext.Current!.GetDefaultLogger());
+
+ private static async Task ReadAllBytesAsync(
+ string path,
+ CancellationToken cancellationToken = default
+ )
+ {
+ await using var stream = new FileStream(
+ path,
+ FileMode.Open,
+ FileAccess.Read,
+ FileShare.ReadWrite,
+ bufferSize: 4096,
+ options: FileOptions.Asynchronous | FileOptions.SequentialScan
+ );
+
+ var buffer = new byte[stream.Length];
+ int totalRead = 0;
+
+ while (totalRead < buffer.Length)
+ {
+ int read = await stream.ReadAsync(buffer.AsMemory(totalRead), cancellationToken);
+
+ if (read == 0)
+ break;
+
+ totalRead += read;
+ }
+
+ return buffer;
+ }
+
+ private static async ValueTask CreateRandomFileAsync(string folder)
+ {
+ var guid = Guid.NewGuid().ToString();
+ var path = Path.Combine(folder, $"Test_{guid}");
+ if (!Directory.Exists(folder))
+ Directory.CreateDirectory(folder);
+ await using var stream = new FileStream(
+ path,
+ FileMode.Create,
+ FileAccess.Write,
+ FileShare.None,
+ bufferSize: 81920,
+ options: FileOptions.SequentialScan
+ );
+
+ long size = 10L * 1024 * 1024; // 10 MB
+ for (long i = 0; i < size; i++)
+ {
+ stream.WriteByte((byte)Random.Shared.Next(0, 255));
+ }
+ return path;
+ }
+
+ [Test]
+ [MatrixDataSource]
+ public async Task Should_Stop_Torrent(
+ [Matrix(3)] int seedersCount,
+ [Matrix(12)] int leechersCount,
+ CancellationToken cancellationToken
+ )
+ {
+ var path = await CreateRandomFileAsync("Input");
+
+ var seeders = await GetSeedersAsync(seedersCount, path, Logger, warmupTime: 0.Seconds)
+ .ToListAsync(cancellationToken: cancellationToken);
+ var seedersTorrents = seeders.Select(i => i.Torrent).ToList();
+
+ var leechers = await GetLeechersAsync(
+ leechersCount,
+ seedersTorrents[0].MetaInfo,
+ Logger,
+ warmupTime: 0.Seconds
+ )
+ .ToListAsync(cancellationToken: cancellationToken);
+ var leechersTorrents = leechers.Select(i => i.Torrent).ToList();
+
+ try
+ {
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ cancellationToken.Register(seederTorrent.Stop);
+ await seederTorrent.StartAsync();
+ }
+
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ cancellationToken.Register(leecherTorrent.Stop);
+ await leecherTorrent.StartAsync();
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.StopAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.StopAsync();
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.Completion.AsTask().ShouldNotThrowAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.Completion.AsTask().ShouldThrowAsync();
+ }
+ }
+ finally
+ {
+ foreach (var (_, client) in seeders)
+ {
+ await client.DisposeAsync();
+ }
+
+ foreach (var (_, client) in leechers)
+ {
+ await client.DisposeAsync();
+ }
+ }
+ }
+
+ [Test]
+ [MatrixDataSource]
+ public async Task Should_Start_Stop_Start_Torrent(
+ [Matrix(3)] int seedersCount,
+ [Matrix(12)] int leechersCount,
+ CancellationToken cancellationToken
+ )
+ {
+ var path = await CreateRandomFileAsync("Input");
+
+ var seeders = await GetSeedersAsync(seedersCount, path, Logger, warmupTime: 0.Seconds)
+ .ToListAsync(cancellationToken: cancellationToken);
+ var seedersTorrents = seeders.Select(i => i.Torrent).ToList();
+
+ var leechers = await GetLeechersAsync(
+ leechersCount,
+ seedersTorrents[0].MetaInfo,
+ Logger,
+ warmupTime: 0.Seconds
+ )
+ .ToListAsync(cancellationToken: cancellationToken);
+ var leechersTorrents = leechers.Select(i => i.Torrent).ToList();
+
+ try
+ {
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ cancellationToken.Register(seederTorrent.Stop);
+ await seederTorrent.StartAsync();
+ }
+
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ cancellationToken.Register(leecherTorrent.Stop);
+ await leecherTorrent.StartAsync();
+ }
+
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.StopAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.StopAsync();
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.StartAsync();
+ }
+
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.StartAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.Completion.AsTask().ShouldNotThrowAsync();
+ }
+ }
+ finally
+ {
+ foreach (var (_, client) in seeders)
+ {
+ await client.DisposeAsync();
+ }
+
+ foreach (var (_, client) in leechers)
+ {
+ await client.DisposeAsync();
+ }
+ }
+ }
+
+ [Test]
+ [MatrixDataSource]
+ public async Task Should_Throw_In_Torrent(
+ [Matrix(3)] int seedersCount,
+ [Matrix(12)] int leechersCount,
+ CancellationToken cancellationToken
+ )
+ {
+ var path = await CreateRandomFileAsync("Input");
+
+ var seeders = await GetSeedersAsync(seedersCount, path, Logger, warmupTime: 0.Seconds)
+ .ToListAsync(cancellationToken: cancellationToken);
+ var seedersTorrents = seeders.Select(i => i.Torrent).ToList();
+
+ var leechers = await GetLeechersAsync(
+ leechersCount,
+ seedersTorrents[0].MetaInfo,
+ Logger,
+ warmupTime: 0.Seconds
+ )
+ .ToListAsync(cancellationToken: cancellationToken);
+ var leechersTorrents = leechers.Select(i => i.Torrent).ToList();
+
+ try
+ {
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ cancellationToken.Register(seederTorrent.Stop);
+ await seederTorrent.StartAsync();
+ }
+
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ cancellationToken.Register(leecherTorrent.Stop);
+ await leecherTorrent.StartAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ leecherTorrent.Completion.TrySetException(new InvalidOperationException());
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.StopAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.StopAsync();
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.Completion.AsTask().ShouldNotThrowAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent
+ .Completion.AsTask()
+ .ShouldThrowAsync();
+ }
+ }
+ finally
+ {
+ foreach (var (_, client) in seeders)
+ {
+ await client.DisposeAsync();
+ }
+
+ foreach (var (_, client) in leechers)
+ {
+ await client.DisposeAsync();
+ }
+ }
+ }
+
+ [Test]
+ [MatrixDataSource]
+ public async Task Should_Download_Torrent_With_Different_Ips_And_Trackers(
+ [Matrix(UsedTrackers.Http, UsedTrackers.Udp, UsedTrackers.Http | UsedTrackers.Udp)]
+ UsedTrackers usedTrackers,
+ [Matrix(
+ UsedAddressProtocol.Ipv4,
+ UsedAddressProtocol.Ipv6,
+ UsedAddressProtocol.Ipv4 | UsedAddressProtocol.Ipv6
+ )]
+ UsedAddressProtocol usedAdressProtocol,
+ [Matrix(3)] int seedersCount,
+ [Matrix(12)] int leechersCount,
+ CancellationToken cancellationToken
+ ) =>
+ await TestDownloadAsync(
+ usedTrackers,
+ usedAdressProtocol,
+ seedersCount,
+ leechersCount,
+ cancellationToken
+ );
+
+ [Test]
+ public async Task Should_Download_Torrent(CancellationToken cancellationToken) =>
+ await TestDownloadAsync(
+ UsedTrackers.Http | UsedTrackers.Udp,
+ UsedAddressProtocol.Ipv4 | UsedAddressProtocol.Ipv6,
+ 4,
+ 50,
+ cancellationToken
+ );
+
+ private async Task TestDownloadAsync(
+ UsedTrackers usedTrackers,
+ UsedAddressProtocol usedAdressProtocol,
+ int seedersCount,
+ int leechersCount,
+ CancellationToken cancellationToken
+ )
+ {
+ if (!Socket.OSSupportsIPv6 && usedAdressProtocol.HasFlag(UsedAddressProtocol.Ipv6))
+ {
+ Skip.Test("Ipv6 is not supported");
+ }
+
+ if (!Socket.OSSupportsIPv4 && usedAdressProtocol.HasFlag(UsedAddressProtocol.Ipv4))
+ {
+ Skip.Test("Ipv4 is not supported");
+ }
+
+ var path = await CreateRandomFileAsync("Input");
+
+ var seeders = await GetSeedersAsync(
+ seedersCount,
+ path,
+ Logger,
+ usedTrackers,
+ usedAdressProtocol,
+ 0.Seconds
+ )
+ .ToListAsync(cancellationToken: cancellationToken);
+ var seedersTorrents = seeders.Select(i => i.Torrent).ToList();
+
+ var leechers = await GetLeechersAsync(
+ leechersCount,
+ seedersTorrents[0].MetaInfo,
+ Logger,
+ usedTrackers,
+ usedAdressProtocol,
+ 0.Seconds
+ )
+ .ToListAsync(cancellationToken: cancellationToken);
+ var leechersTorrents = leechers.Select(i => i.Torrent).ToList();
+
+ try
+ {
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ cancellationToken.Register(seederTorrent.Stop);
+ await seederTorrent.StartAsync();
+ }
+
+ //This is needed because if seeder and leecher announce at the same time they don't see each other
+ await Task.Delay(5000, cancellationToken);
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ cancellationToken.Register(leecherTorrent.Stop);
+ await leecherTorrent.StartAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.Completion.AsTask().ShouldNotThrowAsync();
+ }
+
+ foreach (var seederTorrent in seedersTorrents)
+ {
+ await seederTorrent.StopAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ await leecherTorrent.StopAsync();
+ }
+
+ foreach (var leecherTorrent in leechersTorrents)
+ {
+ var originalFile = await ReadAllBytesAsync(path, cancellationToken);
+ var downloadedFile = await ReadAllBytesAsync(
+ $"{leecherTorrent.OutputDirectory}/{leecherTorrent.MetaInfo.Info.Name}",
+ cancellationToken
+ );
+ originalFile.SequenceEqual(downloadedFile).ShouldBeTrue();
+ leecherTorrent.Statistics.Data.Verified.ShouldBe(downloadedFile.Length);
+ }
+ }
+ finally
+ {
+ foreach (var (_, client) in seeders)
+ {
+ await client.DisposeAsync();
+ }
+ foreach (var (_, client) in leechers)
+ {
+ await client.DisposeAsync();
+ }
+ }
+ }
+
+ private async IAsyncEnumerable<(Torrent Torrent, TorrentClient Client)> GetSeedersAsync(
+ int number,
+ string path,
+ ILogger logger,
+ UsedTrackers usedTrackers = UsedTrackers.Http | UsedTrackers.Udp,
+ UsedAddressProtocol usedAdressProtocol =
+ UsedAddressProtocol.Ipv4 | UsedAddressProtocol.Ipv6,
+ TimeSpan? warmupTime = null
+ )
+ {
+ for (int i = 0; i < number; i++)
+ {
+ var seeder = new TorrentClient(o =>
+ GetOptions(logger, usedTrackers, usedAdressProtocol, warmupTime, o)
+ );
+
+ var seederTorrent = await seeder.CreateTorrentAsync(
+ path,
+ _fixture.AnnounceUrl,
+ [.. _fixture.AnnounceUrls]
+ );
+
+ yield return (seederTorrent, seeder);
+ }
+ }
+
+ private static async IAsyncEnumerable<(Torrent Torrent, TorrentClient Client)> GetLeechersAsync(
+ int number,
+ MetaInfo metaInfo,
+ ILogger logger,
+ UsedTrackers usedTrackers = UsedTrackers.Http | UsedTrackers.Udp,
+ UsedAddressProtocol usedAdressProtocol =
+ UsedAddressProtocol.Ipv4 | UsedAddressProtocol.Ipv6,
+ TimeSpan? warmupTime = null
+ )
+ {
+ for (int i = 0; i <