Fix Attachment handling for RELEASE stage command
ln.build - build0.waldrennach.l--n.de build job pending Details

master
Harald Wolff 2020-12-04 10:42:22 +01:00
parent 2e48a0ac99
commit ff4068c718
3 changed files with 111 additions and 26 deletions

View File

@ -38,7 +38,14 @@ namespace ln.build.pipeline
} }
stage.CommandEnvironment.Logger.Log(LogLevel.INFO, "Adding {0} to release as {1}", localPath, remoteFileName); stage.CommandEnvironment.Logger.Log(LogLevel.INFO, "Adding {0} to release as {1}", localPath, remoteFileName);
release.AddAttachement(localPath, remoteFileName); Attachment attachment = release.CreateOrReplaceAttachment( localPath, remoteFileName );
// Cleanup attachments
foreach (Attachment b in release.GetAttachments())
{
if (!b.Equals(attachment) && b.Name.Equals(attachment.Name))
b.Delete();
}
} }
} else { } else {

View File

@ -1,6 +1,7 @@
using System; using System;
using System.Net.Http.Headers; using System.Net.Http.Headers;
using System.Runtime;
namespace ln.build.repositories namespace ln.build.repositories
{ {
@ -16,27 +17,39 @@ namespace ln.build.repositories
public abstract Repository Repository { get; } public abstract Repository Repository { get; }
public abstract Attachement[] GetAttachements(); public abstract Attachment[] GetAttachments();
public abstract void AddAttachement(string localPath,string remoteFilename); public abstract Attachment CreateOrReplaceAttachment(string localPath, string remoteFileName);
public virtual Attachment FindAttachmentByName(string name)
public class Attachement
{ {
public Release Release { get; set; } foreach (Attachment attachment in GetAttachments())
public int Id { get; set; } = -1; if (attachment.Name.Equals(name))
public string Name { get; set; } return attachment;
public Guid UUID { get; set; } return null;
public string DownloadURL { get; set; }
public Attachement(Release release)
{
Release = release;
}
} }
} }
public abstract class Attachment
{
public abstract Release Release { get; }
public abstract int Id { get; set; }
public abstract string Name { get; set; }
public abstract string DownloadURL { get; set; }
public Attachment()
{
}
public abstract void Create(string localPath);
public abstract void Delete();
public override bool Equals(object obj) => (obj is Attachment attachment) && Id.Equals(attachment.Id);
public override int GetHashCode() => Id.GetHashCode();
}
} }

View File

@ -1,9 +1,12 @@
using System; using System;
using System.Collections.Generic;
using System.IO; using System.IO;
using System.Net; using System.Net;
using System.Net.Http; using System.Net.Http;
using System.Reflection.Emit;
using ln.json; using ln.json;
using ln.json.attributes;
using ln.type; using ln.type;
namespace ln.build.repositories.gitea namespace ln.build.repositories.gitea
@ -26,23 +29,85 @@ namespace ln.build.repositories.gitea
IsPreRelease = (bool)jsonRelease["prerelease"].ToNative(); IsPreRelease = (bool)jsonRelease["prerelease"].ToNative();
} }
public override void AddAttachement(string localPath, string remoteFileName) public override Attachment CreateOrReplaceAttachment(string localPath, string remoteFileName)
{
Attachment attachment = FindAttachmentByName(remoteFileName) ?? new GiteaAttachment(this){ Name = remoteFileName, };
attachment.Create(localPath);
return attachment;
}
public override Attachment[] GetAttachments()
{
if (HttpStatusCode.OK == GiteaRepository.Client.GetJson(out JSONValue jsonAssets, "repos", GiteaRepository.Owner, GiteaRepository.Name, "releases", Id.ToString(), "assets" ))
{
List<Attachment> attachments = new List<Attachment>();
foreach (JSONObject jsonAsset in (jsonAssets as JSONArray).Children)
attachments.Add(new GiteaAttachment(this, jsonAsset));
return attachments.ToArray();
}
return null;
}
}
public class GiteaAttachment : Attachment
{
public override Release Release => GiteaRelease;
public GiteaRelease GiteaRelease { get; }
int id = -1;
string downloadURL;
public override int Id { get => id; set => throw new NotImplementedException(); }
public override string Name { get; set; }
public override string DownloadURL { get => downloadURL; set => throw new NotImplementedException(); }
public GiteaAttachment(GiteaRelease giteaRelease)
{
GiteaRelease = giteaRelease;
}
public GiteaAttachment(GiteaRelease giteaRelease,JSONObject jsonAttachment) :this(giteaRelease)
{
LoadJson(jsonAttachment);
}
private void LoadJson(JSONObject jsonAttachment)
{
id = (int)(long)jsonAttachment["id"].ToNative();
Name = jsonAttachment["name"].ToNative().ToString();
downloadURL = jsonAttachment["browser_download_url"].ToNative().ToString();
}
public override void Delete()
{
if (id != -1)
{
if (HttpStatusCode.NoContent != GiteaRelease.GiteaRepository.Client.Delete("repos", GiteaRelease.GiteaRepository.Owner, GiteaRelease.GiteaRepository.Name, "releases", GiteaRelease.Id.ToString(), "assets", id.ToString()))
throw new Exception(String.Format("could not delete attachment {0}/{1}", GiteaRelease.Id, id));
id = -1;
}
}
public override void Create(string localPath)
{ {
using (FileStream fs = new FileStream(localPath,FileMode.Open)) using (FileStream fs = new FileStream(localPath,FileMode.Open))
{ {
StreamContent attachmentBytes = new StreamContent(fs); StreamContent attachmentBytes = new StreamContent(fs);
MultipartFormDataContent formDataContent = new MultipartFormDataContent(); MultipartFormDataContent formDataContent = new MultipartFormDataContent();
formDataContent.Add(attachmentBytes, "attachment", remoteFileName); formDataContent.Add(attachmentBytes, "attachment", Name);
if (HttpStatusCode.Created != GiteaRepository.Client.PostContent(formDataContent,out JSONValue response, "repos", GiteaRepository.Owner, GiteaRepository.Name, "releases", Id.ToString(), String.Format("assets?name={0}", remoteFileName))) if (HttpStatusCode.Created != GiteaRelease.GiteaRepository.Client.PostContent(formDataContent,out JSONValue response, "repos", GiteaRelease.GiteaRepository.Owner, GiteaRelease.GiteaRepository.Name, "releases", GiteaRelease.Id.ToString(), string.Format("assets?name={0}", Name)))
{ {
throw new Exception(String.Format("could not create attachment to release: {0}", localPath)); throw new Exception(String.Format("could not create attachment to release: {0}", localPath));
} }
if (id != -1)
Delete();
LoadJson(response as JSONObject);
} }
} }
public override Attachement[] GetAttachements()
{
throw new System.NotImplementedException();
}
} }
} }