summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--ApiController.cs70
-rw-r--r--Config.cs6
-rw-r--r--FileObject.cs18
-rw-r--r--Program.cs4
-rw-r--r--download.csproj4
5 files changed, 101 insertions, 1 deletions
diff --git a/ApiController.cs b/ApiController.cs
index 3b75419..4257554 100644
--- a/ApiController.cs
+++ b/ApiController.cs
@@ -1,5 +1,6 @@
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
+using Npgsql;
using System.Net;
namespace download;
@@ -8,6 +9,73 @@ public class ApiController : Controller
{
public IActionResult Get(string? key)
{
- return StatusCode((int)HttpStatusCode.OK, "Hello World - " + key);
+ FileObject? file = GetDownload(key);
+
+ if (file == null)
+ {
+ return StatusCode((int)HttpStatusCode.NotFound, String.Empty);
+ }
+
+ RecordDownload(key,
+ Request?.HttpContext?.Connection?.RemoteIpAddress?.ToString() ?? "IP address unknown",
+ Request?.Headers?.UserAgent.ToString() ?? "User agent unknown",
+ DateTime.UtcNow);
+
+ return File(file.Data, file.MimeType, file.FileName);
+ }
+
+ private FileObject? GetDownload(string key)
+ {
+ FileObject? ret = null;
+
+ try
+ {
+ using var conn = new NpgsqlConnection(Config.Settings["ConnectionStrings:download"]);
+
+ conn.Open();
+
+ using var cmd = new NpgsqlCommand("SELECT mime_type, file_name, data FROM file_object WHERE key = @key", conn);
+ cmd.Parameters.AddWithValue("key", NpgsqlTypes.NpgsqlDbType.Varchar, key);
+ using var reader = cmd.ExecuteReader();
+
+ if(reader.Read())
+ {
+ ret = new FileObject(key, (string)reader["mime_type"], (string)reader["file_name"], (byte[])reader["data"]);
+ }
+ }
+ catch(Exception e)
+ {
+ System.Diagnostics.Debug.WriteLine("GetDownload: Caught exception {0} - {1}", e.GetType().ToString(), e.Message);
+ }
+
+ return ret;
+ }
+
+ private void RecordDownload(string key, string ip_address, string user_agent, DateTime time)
+ {
+ try
+ {
+ using var conn = new NpgsqlConnection(Config.Settings["ConnectionStrings:download"]);
+
+ conn.Open();
+
+ using var cmd = new NpgsqlCommand("INSERT INTO file_object (key, ip_address, user_agent, time) VALUES (@key, @ip_address, @user_agent, @time)", conn);
+
+ if (user_agent.Length > 256)
+ {
+ user_agent = user_agent.Substring(0,256);
+ }
+
+ cmd.Parameters.AddWithValue("key", NpgsqlTypes.NpgsqlDbType.Varchar, key);
+ cmd.Parameters.AddWithValue("ip_address", NpgsqlTypes.NpgsqlDbType.Varchar, ip_address);
+ cmd.Parameters.AddWithValue("user_agent", NpgsqlTypes.NpgsqlDbType.Varchar, user_agent);
+ cmd.Parameters.AddWithValue("time", NpgsqlTypes.NpgsqlDbType.Timestamp, time);
+
+ cmd.ExecuteNonQuery();
+ }
+ catch(Exception e)
+ {
+ System.Diagnostics.Debug.WriteLine("RecordDownload: Caught exception {0} - {1}", e.GetType().ToString(), e.Message);
+ }
}
}
diff --git a/Config.cs b/Config.cs
new file mode 100644
index 0000000..a361719
--- /dev/null
+++ b/Config.cs
@@ -0,0 +1,6 @@
+namespace download;
+
+public static class Config
+{
+ static public IConfiguration Settings {get; set;}
+}
diff --git a/FileObject.cs b/FileObject.cs
new file mode 100644
index 0000000..00c1784
--- /dev/null
+++ b/FileObject.cs
@@ -0,0 +1,18 @@
+namespace download;
+
+public class FileObject
+{
+ public string Key {get;private set;}
+ public string MimeType {get;private set;}
+ public string FileName {get;private set;}
+ public byte[] Data {get;private set;}
+
+ public FileObject(string key, string mimetype, string filename, byte[] data)
+ {
+ Key = key;
+ MimeType = mimetype;
+ FileName = filename;
+ Data = data;
+ }
+
+}
diff --git a/Program.cs b/Program.cs
index 1b97a78..a205fe2 100644
--- a/Program.cs
+++ b/Program.cs
@@ -1,3 +1,5 @@
+using download;
+
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddControllersWithViews();
@@ -13,4 +15,6 @@ app.UseAuthorization();
app.MapControllerRoute(name: "default", pattern: "{controller=Api}/{action=Get}/{key}");
+Config.Settings = app.Configuration;
+
app.Run();
diff --git a/download.csproj b/download.csproj
index 13d8127..439e5d7 100644
--- a/download.csproj
+++ b/download.csproj
@@ -6,4 +6,8 @@
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
+ <ItemGroup>
+ <PackageReference Include="npgsql" Version="8.0.2" />
+ </ItemGroup>
+
</Project>