|
|
|
@ -21,6 +21,7 @@ using NuGet.Versioning;
|
|
|
|
|
using System.Xml;
|
|
|
|
|
using System.Xml.Linq;
|
|
|
|
|
using System.Threading;
|
|
|
|
|
using NuGet.Protocol;
|
|
|
|
|
|
|
|
|
|
namespace isnd.Services
|
|
|
|
|
{
|
|
|
|
@ -228,19 +229,26 @@ namespace isnd.Services
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<Data.Catalog.Package> GetCatalogEntryAsync
|
|
|
|
|
(string pkgId, string semver = null, string pkgType = null)
|
|
|
|
|
public async Task<Data.Catalog.RegistrationLeave> GetCatalogEntryAsync
|
|
|
|
|
(string pkgId, string semver, string pkgType = null)
|
|
|
|
|
{
|
|
|
|
|
return (await dbContext.PackageVersions
|
|
|
|
|
var version = await dbContext.PackageVersions
|
|
|
|
|
.Include(v => v.Package)
|
|
|
|
|
.Include(v => v.Package.LatestCommit)
|
|
|
|
|
.Include(v => v.Package.Owner)
|
|
|
|
|
.Include(v => v.DependencyGroups)
|
|
|
|
|
.Include(v => v.LatestCommit)
|
|
|
|
|
.Where(v => v.PackageId == pkgId
|
|
|
|
|
&& v.FullString == semver
|
|
|
|
|
&& v.LatestCommit != null
|
|
|
|
|
).SingleOrDefaultAsync()).ToPackage(
|
|
|
|
|
apiBase);
|
|
|
|
|
).SingleOrDefaultAsync();
|
|
|
|
|
|
|
|
|
|
foreach (var g in version.DependencyGroups)
|
|
|
|
|
{
|
|
|
|
|
g.Dependencies = dbContext.Dependencies.Where(d => d.DependencyGroupId == g.Id).ToList();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return version.ToPackage(apiBase);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<PackageDeletionReport> UserAskForPackageDeletionAsync
|
|
|
|
@ -256,7 +264,7 @@ namespace isnd.Services
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public IEnumerable<Data.Catalog.Package> SearchCatalogEntriesById
|
|
|
|
|
public IEnumerable<Data.Catalog.RegistrationLeave> SearchCatalogEntriesById
|
|
|
|
|
(string pkgId, string semver, string pkgType, bool preRelease)
|
|
|
|
|
{
|
|
|
|
|
// PackageDependency
|
|
|
|
@ -278,6 +286,7 @@ namespace isnd.Services
|
|
|
|
|
return dbContext.PackageVersions
|
|
|
|
|
.Include(v => v.Package)
|
|
|
|
|
.Include(v => v.LatestCommit)
|
|
|
|
|
.Include(v => v.DependencyGroups.Last().Dependencies)
|
|
|
|
|
.Single(v => v.PackageId == pkgId && semver == v.FullString
|
|
|
|
|
&& (pkgType == null || pkgType == v.Type));
|
|
|
|
|
}
|
|
|
|
@ -288,18 +297,25 @@ namespace isnd.Services
|
|
|
|
|
// RegistrationPageIndexAndQuery
|
|
|
|
|
if (string.IsNullOrWhiteSpace(query.Query)) return null;
|
|
|
|
|
query.Query = query.Query.ToLower();
|
|
|
|
|
var scope = await dbContext.Packages
|
|
|
|
|
.Include(p => p.Versions)
|
|
|
|
|
.Include(p => p.Owner)
|
|
|
|
|
var scope = await dbContext.PackageVersions
|
|
|
|
|
.Include(p => p.Package)
|
|
|
|
|
.Include(p => p.Package.Owner)
|
|
|
|
|
.Include(p => p.LatestCommit)
|
|
|
|
|
.SingleOrDefaultAsync(p => p.Id.ToLower() == query.Query);
|
|
|
|
|
.Where(p => p.PackageId.ToLower() == query.Query).ToArrayAsync();
|
|
|
|
|
if (scope == null) return null;
|
|
|
|
|
if (scope.Versions.Count == 0) return null;
|
|
|
|
|
if (scope.Length == 0) return null;
|
|
|
|
|
string bid = $"{apiBase}{ApiConfig.Registration}";
|
|
|
|
|
foreach (var version in scope.Versions)
|
|
|
|
|
|
|
|
|
|
foreach (var version in scope)
|
|
|
|
|
{
|
|
|
|
|
version.DependencyGroups = dbContext.PackageDependencyGroups.Include(d => d.Dependencies)
|
|
|
|
|
.Where(d => d.PackageId == version.PackageId && d.PackageVersionFullString == version.FullString)
|
|
|
|
|
.ToList();
|
|
|
|
|
version.LatestCommit = dbContext.Commits.Single(c => c.Id == version.CommitNId);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return
|
|
|
|
|
new PackageRegistration(apiBase, scope);
|
|
|
|
|
new PackageRegistration(apiBase, query.Query, scope);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<PackageSearchResult> SearchPackageAsync(PackageRegistrationQuery query)
|
|
|
|
@ -307,19 +323,21 @@ namespace isnd.Services
|
|
|
|
|
string bid = $"{apiBase}{ApiConfig.Registration}";
|
|
|
|
|
if (string.IsNullOrWhiteSpace(query.Query))
|
|
|
|
|
query.Query = "";
|
|
|
|
|
var scope = dbContext.Packages
|
|
|
|
|
.Include(p => p.Owner)
|
|
|
|
|
.Include(p => p.Versions)
|
|
|
|
|
.Include(p => p.LatestCommit)
|
|
|
|
|
.Include(p => p.LatestCommit.Versions)
|
|
|
|
|
.Where(p => p.Id.StartsWith(query.Query)
|
|
|
|
|
&& p.LatestCommit != null
|
|
|
|
|
&& (query.Prerelease || p.Versions.Any(p => !p.IsPrerelease))
|
|
|
|
|
&& p.Versions.Count() > 0)
|
|
|
|
|
.OrderBy(p => p.CommitNId);
|
|
|
|
|
|
|
|
|
|
return new PackageSearchResult(await scope.Skip(query.Skip).Take(query.Take)
|
|
|
|
|
.ToListAsync(), apiBase, scope.Count());
|
|
|
|
|
|
|
|
|
|
var packages = await dbContext.Packages
|
|
|
|
|
.Include(g => g.Versions)
|
|
|
|
|
.Where(d => d.Id.StartsWith(query.Query)
|
|
|
|
|
&& (query.Prerelease || d.Versions.Any(v => !v.IsPrerelease)))
|
|
|
|
|
.Skip(query.Skip).Take(query.Take).ToArrayAsync();
|
|
|
|
|
foreach (var package in packages)
|
|
|
|
|
foreach (var version in package.Versions)
|
|
|
|
|
{
|
|
|
|
|
version.DependencyGroups = dbContext.PackageDependencyGroups.Include(d => d.Dependencies)
|
|
|
|
|
.Where(d => d.PackageVersionFullString == version.FullString && d.PackageId == version.PackageId)
|
|
|
|
|
.ToList();
|
|
|
|
|
}
|
|
|
|
|
return new PackageSearchResult(packages, apiBase, packages.Count());
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<PackageVersion> PutPackageAsync(Stream packageStream, string ownerId)
|
|
|
|
@ -337,109 +355,130 @@ namespace isnd.Services
|
|
|
|
|
string fullPath;
|
|
|
|
|
|
|
|
|
|
using var specificationStream = spec.Open();
|
|
|
|
|
|
|
|
|
|
using XmlReader xmlReader = XmlReader.Create(specificationStream);
|
|
|
|
|
|
|
|
|
|
var xMeta = XElement.Load(xmlReader, LoadOptions.None).Descendants().First();
|
|
|
|
|
|
|
|
|
|
string packageDescription = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName == "description")?.Value;
|
|
|
|
|
|
|
|
|
|
var frameWorks = xMeta
|
|
|
|
|
.Descendants().FirstOrDefault(x => x.Name.LocalName =="frameworkReferences")
|
|
|
|
|
.Descendants().Where(x => x.Name.LocalName =="group")
|
|
|
|
|
.Select(x=> x.Attribute("targetFramework").Value).ToArray();
|
|
|
|
|
var types = "Package";
|
|
|
|
|
|
|
|
|
|
pkgId = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName =="id")?.Value;
|
|
|
|
|
string pkgVersion = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName =="version")?.Value;
|
|
|
|
|
|
|
|
|
|
if (!NuGetVersion.TryParse(pkgVersion, out nugetVersion))
|
|
|
|
|
throw new InvalidPackageException("metadata/version");
|
|
|
|
|
|
|
|
|
|
var frameworkReferences = frameWorks.Select(g => new PackageDependencyGroup
|
|
|
|
|
{
|
|
|
|
|
TargetFramework = g
|
|
|
|
|
}
|
|
|
|
|
).ToList();
|
|
|
|
|
|
|
|
|
|
string packageIdPath = Path.Combine(isndSettings.PackagesRootDir,
|
|
|
|
|
pkgId);
|
|
|
|
|
pkgPath = Path.Combine(packageIdPath, nugetVersion.ToFullString());
|
|
|
|
|
string name = $"{pkgId}-{nugetVersion}." + Constants.PacketFileExtension;
|
|
|
|
|
fullPath = Path.Combine(pkgPath, name);
|
|
|
|
|
|
|
|
|
|
var packageIdPathInfo = new DirectoryInfo(packageIdPath);
|
|
|
|
|
Data.Packages.Package pkg = dbContext.Packages.SingleOrDefault(p => p.Id == pkgId);
|
|
|
|
|
Commit commit = new Commit
|
|
|
|
|
|
|
|
|
|
using XmlReader xmlReader = XmlReader.Create(specificationStream);
|
|
|
|
|
|
|
|
|
|
var xMeta = XElement.Load(xmlReader, LoadOptions.None).Descendants().First();
|
|
|
|
|
|
|
|
|
|
string packageDescription = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName == "description")?.Value;
|
|
|
|
|
|
|
|
|
|
var frameWorks = xMeta
|
|
|
|
|
.Descendants().FirstOrDefault(x => x.Name.LocalName == "frameworkReferences")
|
|
|
|
|
.Descendants().Where(x => x.Name.LocalName == "group")
|
|
|
|
|
.Select(x => NewFrameworkDependencyGroup(x)).ToArray();
|
|
|
|
|
var types = "Package";
|
|
|
|
|
|
|
|
|
|
pkgId = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName == "id")?.Value;
|
|
|
|
|
string pkgVersion = xMeta.Descendants().FirstOrDefault(x => x.Name.LocalName == "version")?.Value;
|
|
|
|
|
|
|
|
|
|
if (!NuGetVersion.TryParse(pkgVersion, out nugetVersion))
|
|
|
|
|
throw new InvalidPackageException("metadata/version");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
string packageIdPath = Path.Combine(isndSettings.PackagesRootDir,
|
|
|
|
|
pkgId);
|
|
|
|
|
pkgPath = Path.Combine(packageIdPath, nugetVersion.ToFullString());
|
|
|
|
|
string name = $"{pkgId}-{nugetVersion}." + Constants.PacketFileExtension;
|
|
|
|
|
fullPath = Path.Combine(pkgPath, name);
|
|
|
|
|
|
|
|
|
|
var packageIdPathInfo = new DirectoryInfo(packageIdPath);
|
|
|
|
|
Data.Packages.Package pkg = dbContext.Packages.SingleOrDefault(p => p.Id == pkgId);
|
|
|
|
|
Commit commit = new Commit
|
|
|
|
|
{
|
|
|
|
|
Action = PackageAction.PublishPackage,
|
|
|
|
|
TimeStamp = DateTimeOffset.Now.ToUniversalTime()
|
|
|
|
|
};
|
|
|
|
|
if (pkg != null)
|
|
|
|
|
{
|
|
|
|
|
// Update
|
|
|
|
|
pkg.Description = packageDescription;
|
|
|
|
|
pkg.LatestCommit = commit;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
// First version
|
|
|
|
|
pkg = new Data.Packages.Package
|
|
|
|
|
{
|
|
|
|
|
Action = PackageAction.PublishPackage,
|
|
|
|
|
TimeStamp = DateTimeOffset.Now.ToUniversalTime()
|
|
|
|
|
Id = pkgId,
|
|
|
|
|
Description = packageDescription,
|
|
|
|
|
OwnerId = ownerId,
|
|
|
|
|
LatestCommit = commit
|
|
|
|
|
};
|
|
|
|
|
if (pkg != null)
|
|
|
|
|
{
|
|
|
|
|
// Update
|
|
|
|
|
pkg.Description = packageDescription;
|
|
|
|
|
pkg.LatestCommit = commit;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
// First version
|
|
|
|
|
pkg = new Data.Packages.Package
|
|
|
|
|
{
|
|
|
|
|
Id = pkgId,
|
|
|
|
|
Description = packageDescription,
|
|
|
|
|
OwnerId = ownerId,
|
|
|
|
|
LatestCommit = commit
|
|
|
|
|
};
|
|
|
|
|
dbContext.Packages.Add(pkg);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// here, the package is or new, or owned by the key owner
|
|
|
|
|
if (!packageIdPathInfo.Exists) packageIdPathInfo.Create();
|
|
|
|
|
dbContext.Packages.Add(pkg);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var dest = new FileInfo(fullPath);
|
|
|
|
|
var destDir = new DirectoryInfo(dest.DirectoryName);
|
|
|
|
|
if (dest.Exists) dest.Delete();
|
|
|
|
|
if (!destDir.Exists) destDir.Create();
|
|
|
|
|
// here, the package is or new, or owned by the key owner
|
|
|
|
|
if (!packageIdPathInfo.Exists) packageIdPathInfo.Create();
|
|
|
|
|
|
|
|
|
|
packageStream.Seek(0, SeekOrigin.Begin);
|
|
|
|
|
using (var fileStream = File.Create(fullPath))
|
|
|
|
|
{
|
|
|
|
|
await packageStream.CopyToAsync(fileStream);
|
|
|
|
|
}
|
|
|
|
|
var dest = new FileInfo(fullPath);
|
|
|
|
|
var destDir = new DirectoryInfo(dest.DirectoryName);
|
|
|
|
|
if (dest.Exists) dest.Delete();
|
|
|
|
|
if (!destDir.Exists) destDir.Create();
|
|
|
|
|
|
|
|
|
|
string fullStringVersion = nugetVersion.ToFullString();
|
|
|
|
|
var pkgVersions = dbContext.PackageVersions.Where
|
|
|
|
|
(v => v.PackageId == pkg.Id && v.FullString == fullStringVersion);
|
|
|
|
|
if (pkgVersions.Count() > 0)
|
|
|
|
|
{
|
|
|
|
|
foreach (var v in pkgVersions.ToArray())
|
|
|
|
|
dbContext.PackageVersions.Remove(v);
|
|
|
|
|
}
|
|
|
|
|
packageStream.Seek(0, SeekOrigin.Begin);
|
|
|
|
|
using (var fileStream = File.Create(fullPath))
|
|
|
|
|
{
|
|
|
|
|
await packageStream.CopyToAsync(fileStream);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// FIXME default type or null
|
|
|
|
|
dbContext.PackageVersions.Add
|
|
|
|
|
(version = new PackageVersion
|
|
|
|
|
{
|
|
|
|
|
string fullStringVersion = nugetVersion.ToFullString();
|
|
|
|
|
var pkgVersions = dbContext.PackageVersions.Where
|
|
|
|
|
(v => v.PackageId == pkg.Id && v.FullString == fullStringVersion);
|
|
|
|
|
if (pkgVersions.Count() > 0)
|
|
|
|
|
{
|
|
|
|
|
foreach (var v in pkgVersions.ToArray())
|
|
|
|
|
dbContext.PackageVersions.Remove(v);
|
|
|
|
|
}
|
|
|
|
|
string versionFullString = nugetVersion.ToFullString();
|
|
|
|
|
|
|
|
|
|
Package = pkg,
|
|
|
|
|
Major = nugetVersion.Major,
|
|
|
|
|
Minor = nugetVersion.Minor,
|
|
|
|
|
Patch = nugetVersion.Patch,
|
|
|
|
|
Revision = nugetVersion.Revision,
|
|
|
|
|
IsPrerelease = nugetVersion.IsPrerelease,
|
|
|
|
|
FullString = nugetVersion.ToFullString(),
|
|
|
|
|
Type =types,
|
|
|
|
|
LatestCommit = commit
|
|
|
|
|
});
|
|
|
|
|
// FIXME default package type or null
|
|
|
|
|
dbContext.PackageVersions.Add
|
|
|
|
|
(version = new PackageVersion
|
|
|
|
|
{
|
|
|
|
|
Package = pkg,
|
|
|
|
|
Major = nugetVersion.Major,
|
|
|
|
|
Minor = nugetVersion.Minor,
|
|
|
|
|
Patch = nugetVersion.Patch,
|
|
|
|
|
Revision = nugetVersion.Revision,
|
|
|
|
|
IsPrerelease = nugetVersion.IsPrerelease,
|
|
|
|
|
FullString = versionFullString,
|
|
|
|
|
Type = types,
|
|
|
|
|
LatestCommit = commit
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
dbContext.Commits.Add(commit);
|
|
|
|
|
|
|
|
|
|
foreach (var group in dbContext.PackageDependencyGroups.Include(g => g.PackageVersion)
|
|
|
|
|
.Where(x => x.PackageId == pkgId && x.PackageVersionFullString == versionFullString)
|
|
|
|
|
.ToList())
|
|
|
|
|
{
|
|
|
|
|
dbContext.PackageDependencyGroups.Remove(group);
|
|
|
|
|
}
|
|
|
|
|
version.DependencyGroups = new List<PackageDependencyGroup>();
|
|
|
|
|
foreach (var framework in frameWorks)
|
|
|
|
|
{
|
|
|
|
|
var group = new PackageDependencyGroup
|
|
|
|
|
{
|
|
|
|
|
TargetFramework = framework.FrameworkName,
|
|
|
|
|
PackageId = pkgId,
|
|
|
|
|
PackageVersionFullString = versionFullString,
|
|
|
|
|
Dependencies = framework.Dependencies.Select(
|
|
|
|
|
d => new Dependency
|
|
|
|
|
{
|
|
|
|
|
Id = d.PackageId,
|
|
|
|
|
Version = d.PackageVersion,
|
|
|
|
|
}).ToList()
|
|
|
|
|
};
|
|
|
|
|
version.DependencyGroups.Add(group);
|
|
|
|
|
dbContext.PackageDependencyGroups.Add(group);
|
|
|
|
|
|
|
|
|
|
dbContext.Commits.Add(commit);
|
|
|
|
|
}
|
|
|
|
|
await dbContext.SaveChangesAsync();
|
|
|
|
|
await UpdateCatalogForAsync(commit);
|
|
|
|
|
|
|
|
|
|
await dbContext.SaveChangesAsync();
|
|
|
|
|
version.DependencyGroups = frameworkReferences;
|
|
|
|
|
await UpdateCatalogForAsync(commit);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
using (var shaCrypto = System.Security.Cryptography.SHA512.Create())
|
|
|
|
|
{
|
|
|
|
|
using (var stream = System.IO.File.OpenRead(fullPath))
|
|
|
|
@ -465,5 +504,22 @@ namespace isnd.Services
|
|
|
|
|
}
|
|
|
|
|
return version;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private FrameworkDependencyGroup NewFrameworkDependencyGroup(XElement x)
|
|
|
|
|
{
|
|
|
|
|
var view = x.ToJson();
|
|
|
|
|
var frameworkReferences = x.Descendants();
|
|
|
|
|
var framework = x.Attribute("targetFramework").Value;
|
|
|
|
|
return new FrameworkDependencyGroup
|
|
|
|
|
{
|
|
|
|
|
FrameworkName = framework,
|
|
|
|
|
Dependencies = frameworkReferences.Select(r => new ShortDependencyInfo
|
|
|
|
|
{
|
|
|
|
|
PackageId = r.Attribute("name").Value,
|
|
|
|
|
PackageVersion = r.Attribute("version")?.Value
|
|
|
|
|
}).ToList()
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|