nugroho/agper-perubahan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: nugroho:f86fda4a6df476d2138977837ff7116d11fdcecc
Branches Tags
nugroho:main
..
compare: nugroho:a1d981a69c8053a5af806b8116004d725251b89e
Branches Tags
nugroho:main

No commits in common. "f86fda4a6df476d2138977837ff7116d11fdcecc" and "a1d981a69c8053a5af806b8116004d725251b89e" have entirely different histories.
f86fda4a6d ... a1d981a69c

19 changed files with 212 additions and 721 deletions
Show Stats Expand all files Collapse all files

5
.gitignore vendored
View File

@ -1,5 +0,0 @@
.DS_Store
bin/
obj/
settings.json
origin.pfx

75
APIHandler.cs
View File

@ -1,75 +0,0 @@
using System.Text.Json;
namespace perubahan;
public static class APIHandler
{
public static void Handle(IApplicationBuilder App)
{
App
.Map("/getunits", units =>{
units.Run(async runner=>{
if (!await RequestValidated(runner,2)) return;
await WriteJsonResponse(runner,StatusCodes.Status200OK,"Success",Deployments);
});
})
.Map("/chunit", unit =>{
unit.Run(async runner=>{
if (!await RequestValidated(runner, 2, "POST", true)) return;
if(await TryGetBodyJsonAsync(runner, ["deplid", "unitkerja"], CTS.Token) is Dictionary<string, JsonElement> InElement)
{
Deployment CorrectDeployment = new(
InElement["deplid"].GetInt16(),
InElement["unitkerja"].GetString() ?? ""
);
if (CorrectDeployment.UnitKerja.Length < 1)
{
await WriteJsonResponse(runner,StatusCodes.Status400BadRequest, "Unit Kerja can't be empty string.");
return;
}
int i = Deployments.FindIndex(depl=>depl.DeplID == CorrectDeployment.DeplID);
if(i<0)
{
await WriteJsonResponse(runner,StatusCodes.Status404NotFound,"Deployment ID not found.");
return;
}
_ = await RunNonQueryAsync(CS,"UPDATE deployment SET unitkerja = @uk WHERE deplid = @id",Comm=>{
Comm.Parameters.AddWithValue("@id", CorrectDeployment.DeplID);
Comm.Parameters.AddWithValue("@uk", CorrectDeployment.UnitKerja);
},CTS.Token);
Deployments[i] = CorrectDeployment;
await WriteJsonResponse(runner,StatusCodes.Status202Accepted,"Data updated.",Deployments[i]);
}
});
})
.Map("/addunit", unit =>{
unit.Run(async runner=>{
if (!await RequestValidated(runner, 2, "POST", true)) return;
if(await TryGetBodyJsonAsync(runner, ["unitkerja"], CTS.Token) is Dictionary<string, JsonElement> InElement)
{
string UnitKerja = InElement["unitkerja"].GetString() ?? "";
if (UnitKerja.Length < 1)
{
await WriteJsonResponse(runner,StatusCodes.Status400BadRequest, "Unit Kerja can't be empty string.");
return;
}
short DeplID = (short)await RunScalarAsync(CS,"INSERT INTO deployment OUTPUT INSERTED.deplid VALUES (@uk)",Comm=>{
Comm.Parameters.AddWithValue("@uk", UnitKerja);
},CTS.Token);
Deployment Inserted = new(DeplID,UnitKerja);
Deployments.Add(Inserted);
// EventsMarker.CacheUpdates = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString("X");
await WriteJsonResponse(runner,StatusCodes.Status201Created,"Data Created.",Inserted);
}
});
})
.Map("/getagents", agents=>{
agents.Run(async runner=>{
if (!await RequestValidated(runner,2)) return;
await WriteJsonResponse(runner,StatusCodes.Status200OK,"Success",Agents);
});
})
;
}
}

112
Auth.cs
View File

@ -1,112 +0,0 @@
using System;
using System.Text.Json;
namespace perubahan;
public static class Auth
{
internal static bool TryGetUser(HttpContext context, out SafeUser user)
{
if (context.Items.TryGetValue("AuthorizedUser", out object? userObj) && userObj is SafeUser safeUser)
{
user = safeUser;
return true;
}
user = null!;
return false;
}
internal static bool IsAuthorized(HttpContext context, int requiredLevel)
{
return TryGetUser(context, out SafeUser user) && user.Level <= requiredLevel;
}
internal static Task RejectUnauthorized(HttpContext context)
{
context.Response.StatusCode = StatusCodes.Status401Unauthorized;
return context.Response.WriteAsJsonAsync(new SimpleApiResponse(401, "Unauthorized."), SGContext.Default.SimpleApiResponse);
}
internal static void Handle(IApplicationBuilder App)
{
App
.Map("/logout", logout =>{
logout.Run(async runner=>{
if(!HttpMethods.IsGet(runner.Request.Method) || runner.Request.HasJsonContentType() || runner.Request.HasFormContentType)
{
await WriteJsonResponse(runner,StatusCodes.Status400BadRequest,"Improper request to log out.");
return;
}
runner.Response.Cookies.Append("session", "", Delete);
if(runner.Items.ContainsKey("AuthorizedUser"))
{
await WriteJsonResponse(runner,StatusCodes.Status200OK,"Log out successful. Authorisation token deleted.");
}
else
{
await WriteJsonResponse(runner,StatusCodes.Status200OK,"No user to log out. Authorisation token does not exists.");
}
});
})
.Map("/login", login =>{
login.Run(async runner=>{
if(runner.Items.ContainsKey("AuthorizedUser"))
{
await WriteJsonResponse(runner,StatusCodes.Status409Conflict,"Log in not allowed when an authorized user is already logged in.");
}
else if(runner.Request.ContentType != "application/json")
{
await WriteJsonResponse(runner,StatusCodes.Status400BadRequest,"Request Content-Type mismatch.");
}
else
{
LoginUser LoginInfo = (await runner.Request.ReadFromJsonAsync(SGContext.Default.LoginUser))!;
if(LoginInfo.Username is null || LoginInfo.Password is null)
{
await WriteJsonResponse(runner,StatusCodes.Status401Unauthorized,"No valid user information provided.");
return;
}
string SHA256Pass = Convert.ToHexString(SHA256.HashData(Encoding.UTF8.GetBytes(LoginInfo.Password)));
if (UserAccounts.TryGetValue(LoginInfo.Username, out User? FoundUser) && FoundUser.Password.Equals(SHA256Pass,StringComparison.InvariantCultureIgnoreCase) && FoundUser.Active)
{
SafeUser LoggedIn = SafeUser.FromUser(FoundUser);
string LoggedInBase64 = Convert.ToBase64String(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(LoggedIn,SGContext.Default.SafeUser)));
string Signature = Convert.ToBase64String(SHA256.HashData(Encoding.UTF8.GetBytes(LoggedInBase64+SecretKey)));
runner.Response.Cookies.Append("session", $"{LoggedInBase64}.{Signature}", HttpOnly);
await WriteJsonResponse(runner,StatusCodes.Status200OK,"User authorised. Authorisation token created.",LoggedIn);
}
else
{
await WriteJsonResponse(runner,StatusCodes.Status401Unauthorized,"Provided user information cannot be authorized");
}
}
});
})
.Map("/gate", auth =>{
auth.Run(async runner=>{
if(runner.Request.ContentType != "application/json")
{
await WriteJsonResponse(runner,StatusCodes.Status400BadRequest,"Request Content-Type mismatch.");
}
else
{
LoginUser LoginInfo = (await runner.Request.ReadFromJsonAsync(SGContext.Default.LoginUser))!;
if(LoginInfo.Username is null || LoginInfo.Password is null)
{
await WriteJsonResponse(runner,StatusCodes.Status401Unauthorized,"No valid user information provided.");
return;
}
string SHA256Pass = Convert.ToHexString(SHA256.HashData(Encoding.UTF8.GetBytes(LoginInfo.Password)));
if (UserAccounts.TryGetValue(LoginInfo.Username, out User? FoundUser) && FoundUser.Password.Equals(SHA256Pass,StringComparison.InvariantCultureIgnoreCase) && FoundUser.Active)
{
await WriteJsonResponse(runner,StatusCodes.Status200OK,"User authorised. Operation may continue.",SafeUser.FromUser(FoundUser));
}
else
{
await WriteJsonResponse(runner,StatusCodes.Status401Unauthorized,"Provided user information cannot be authorized");
}
}
});
});
}
}

343
Commons.cs
View File

@ -1,343 +0,0 @@
global using Microsoft.AspNetCore.Builder;
global using Microsoft.AspNetCore.Hosting;
global using Microsoft.AspNetCore.Http;
global using Microsoft.Data.SqlClient;
global using System.Text;
global using System.Text.Json.Nodes;
global using static perubahan.Commons;
global using static perubahan.Logging;
global using static perubahan.Middlewares;
global using System.Collections.Concurrent;
global using System.Security.Cryptography;
using System.Text.Json;
using System.Runtime.InteropServices;
namespace perubahan;
internal static class Commons
{
internal readonly static string VerNum = "0.1.250509.2301";
internal static ConcurrentDictionary<string,User> UserAccounts = [];
internal static List<Deployment> Deployments = [];
internal static List<Agent> Agents = [];
internal static readonly string SecretKey = "userandomlaterlikethecommented"; //RandomNumberGenerator.GetHexString(32);
internal static string CS = string.Empty ;
internal static JsonNode Settings = JsonNode.Parse("{}")!;
internal static readonly CookieOptions HttpOnly;
internal static readonly CookieOptions Delete;
// internal static EventStore EventsMarker = new (DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString("X"),DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString("X"));
internal static readonly CancellationTokenSource CTS = new();
static Commons()
{
Delete = new ()
{
Domain = "",
Path = "/",
Expires = DateTime.Parse("2023-06-14")
};
HttpOnly = new ()
{
Domain = "",
Path = "/",
HttpOnly = true,
IsEssential = true
};
Console.CancelKeyPress += (sender, e) =>
{
e.Cancel = true; // Prevents immediate termination
CTS.Cancel();
};
AppDomain.CurrentDomain.ProcessExit += (sender, e) =>
{
CTS.Cancel();
};
}
internal static async Task WriteJsonResponse(HttpContext Context, int Status, string Message, object Data)
{
Context.Response.StatusCode = Status;
await Context.Response.WriteAsJsonAsync(new ApiResponse(Status, Message, Data), SGContext.Default.ApiResponse,cancellationToken: CTS.Token);
}
internal static async Task WriteJsonResponse(HttpContext Context, int Status, string Message)
{
Context.Response.StatusCode = Status;
await Context.Response.WriteAsJsonAsync(new SimpleApiResponse(Status, Message), SGContext.Default.SimpleApiResponse,cancellationToken: CTS.Token);
}
internal static async Task<bool> RequestValidated(HttpContext Context, int RequiredLevel = 0, string ValidMethod = "GET", bool CheckJson = false)
{
if (!ValidMethod.Equals(Context.Request.Method,StringComparison.OrdinalIgnoreCase) ||
(CheckJson && !Context.Request.HasJsonContentType()))
{
await WriteJsonResponse(Context, StatusCodes.Status405MethodNotAllowed, "Method Not Allowed.");
return false;
}
if (!Auth.IsAuthorized(Context, RequiredLevel))
{
await WriteJsonResponse(Context, StatusCodes.Status401Unauthorized, "Unauthorized.");
return false;
}
return true;
}
internal static async Task<int> RunNonQueryAsync(string ConnectionString, string SQL, Action<SqlCommand>? Configure = null, CancellationToken Token = default)
{
await using SqlConnection Conn = new(ConnectionString);
await Conn.OpenAsync(Token);
await using SqlCommand Cmd = new(SQL, Conn);
Configure?.Invoke(Cmd);
return await Cmd.ExecuteNonQueryAsync(Token);
}
internal static async Task<SqlDataReader> RunReaderAsync(string ConnectionString, string SQL, Action<SqlCommand>? Configure = null, CancellationToken Token = default)
{
SqlConnection Conn = new(ConnectionString);
await Conn.OpenAsync(Token);
SqlCommand Cmd = new(SQL, Conn);
Configure?.Invoke(Cmd);
return await Cmd.ExecuteReaderAsync(System.Data.CommandBehavior.CloseConnection, Token);
}
internal static async Task<object> RunScalarAsync(string ConnectionString, string SQL, Action<SqlCommand>? Configure = null, CancellationToken Token = default)
{
await using SqlConnection Conn = new(ConnectionString);
await Conn.OpenAsync(Token);
await using SqlCommand Cmd = new(SQL, Conn);
Configure?.Invoke(Cmd);
return await Cmd.ExecuteScalarAsync(Token);
}
public static async Task RunTransactionAsync(string ConnStr, Func<SqlConnection, SqlTransaction, Task> Logic, CancellationToken Token)
{
using SqlConnection Conn = new(ConnStr);
await Conn.OpenAsync(Token);
using SqlTransaction Tran = Conn.BeginTransaction();
try
{
await Logic(Conn, Tran);
await Tran.CommitAsync(Token);
}
catch (SqlException)
{
await Tran.RollbackAsync(Token);
// if (ex.State != 255) throw; //state = 255 is custom sql error, designed just for this purpose of not rethrowing.
}
catch
{
throw;
}
}
internal static string GenerateUuidV7()
{
Span<byte> uuidBytes = stackalloc byte[16];
long time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
RandomNumberGenerator.Fill(uuidBytes[7..]);
if (BitConverter.IsLittleEndian)
{
MemoryMarshal.AsBytes(MemoryMarshal.CreateSpan(ref time, 1))[..6].CopyTo(uuidBytes[..6]);
uuidBytes[..6].Reverse();
}
else
{
MemoryMarshal.AsBytes(MemoryMarshal.CreateSpan(ref time, 1))[2..8].CopyTo(uuidBytes[..6]);
}
uuidBytes[6] = (byte)((uuidBytes[6] & 0x0F) | 0x70); // Set version to 7
uuidBytes[8] = (byte)((uuidBytes[8] & 0x3F) | 0x80); // Set variant to 10xx
return Convert.ToHexString(uuidBytes).ToLower().Insert(8, "-").Insert(13, "-").Insert(18, "-").Insert(23, "-");
}
internal static async Task<Dictionary<string, JsonElement>?> TryGetBodyJsonAsync(HttpContext Context, string[] Keys, CancellationToken Token)
{
using JsonDocument BodyDoc = await JsonDocument.ParseAsync(Context.Request.Body,cancellationToken: Token);
JsonElement Element = BodyDoc.RootElement;
Dictionary<string, JsonElement>? Result = new(StringComparer.OrdinalIgnoreCase);
foreach (string Key in Keys)
{
if (!Element.TryGetProperty(Key, out JsonElement Value))
{
await WriteJsonResponse(Context, StatusCodes.Status400BadRequest,
"Bad Request. One or more required properties were not received.");
return null;
}
Result[Key] = Value.Clone();
}
return Result;
}
internal static Dictionary<string, JsonElement>? JsonElementToDict(JsonElement Element, string[] Keys)
{
Dictionary<string, JsonElement>? Result = new(StringComparer.OrdinalIgnoreCase);
foreach (string Key in Keys)
{
if (!Element.TryGetProperty(Key, out JsonElement Value))
{
return null;
}
Result[Key] = Value.Clone();
}
return Result;
}
internal static async Task<int> UpdateCache()
{
Console.WriteLine("Updating app cache.");
Console.Write(" Caching User Accounts... ");
await using SqlConnection FConn = new(CS);
await FConn.OpenAsync().ConfigureAwait(false);
using SqlCommand FComm = new("SELECT * FROM users",FConn);
await using (SqlDataReader URead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
{
while(await URead.ReadAsync(CTS.Token).ConfigureAwait(false))
{
_ = UserAccounts.TryAdd((string)URead["uname"], new User((string)URead["uname"],(string)URead["name"],(string)URead["pass"],(byte)URead["level"],(bool)URead["active"]));
}
}
FComm.CommandText = "SELECT * FROM deployment";
await using (SqlDataReader SRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
{
Deployments = await SRead.ToListAsync<Deployment>(r=>new(
(short)r["deplid"],
(string)r["unitkerja"]
),CTS.Token);
}
FComm.CommandText = "SELECT * FROM agents";
await using (SqlDataReader SRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
{
Agents = await SRead.ToListAsync<Agent>(r=>new(
(string)r["agentid"],
(string)r["name"],
(string)r["jabatan"],
(short)r["deplid"],
(string)r["skangkat"],
DateOnly.FromDateTime((DateTime)r["tmt"]),
r["skperubahan"] == DBNull.Value ? null : (string)r["skperubahan"],
r["tgperubahan"] == DBNull.Value ? null : DateOnly.FromDateTime((DateTime)r["tgperubahan"]),
r["vision"] == DBNull.Value ? null : (string)r["vision"],
r["mission"] == DBNull.Value ? null : (string)r["mission"],
r["photourl"] == DBNull.Value ? null : (string)r["photourl"]
),CTS.Token);
}
// FComm.CommandText = "SELECT shift_sched.*, shifts.name FROM shifts LEFT JOIN shift_sched ON shifts.shiftid = shift_sched.shiftid ORDER BY shifts.shiftid, [day]";
// await using (SqlDataReader SRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
// {
// ShiftSched = await SRead.ToListAsync<ShiftSchedEntry>(r=>new(
// (byte)r["shiftid"],
// (string)r["name"],
// (byte)r["schedid"],
// (byte)r["day"],
// TimeOnly.FromTimeSpan((TimeSpan)r["start"]),
// TimeOnly.FromTimeSpan((TimeSpan)r["end"])
// ),CTS.Token);
// }
Console.WriteLine("Done.");
Console.WriteLine("App cache updated.");
return 0;
// FComm.CommandText = "SELECT shift_sched.*, shifts.name FROM shifts LEFT JOIN shift_sched ON shifts.shiftid = shift_sched.shiftid ORDER BY shifts.shiftid, [day]";
// await using (SqlDataReader SRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
// {
// ShiftSched = await SRead.ToListAsync<ShiftSchedEntry>(r=>new(
// (byte)r["shiftid"],
// (string)r["name"],
// (byte)r["schedid"],
// (byte)r["day"],
// TimeOnly.FromTimeSpan((TimeSpan)r["start"]),
// TimeOnly.FromTimeSpan((TimeSpan)r["end"])
// ),CTS.Token);
// }
// FComm.CommandText = "SELECT tariffs.*, tariff_sched.schedid, tariff_sched.amount FROM tariffs LEFT JOIN tariff_sched ON tariffs.tariffid = tariff_sched.tariffid ORDER BY tariffs.tariffid";
// await using (SqlDataReader TRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
// {
// TariffSched = await TRead.ToListAsync<TariffSchedEntry>(r=>new(
// (byte)r["tariffid"],
// (string)r["name"],
// (bool)r["active"],
// r["schedid"] == DBNull.Value ? null : (byte)r["schedid"],
// r["amount"] == DBNull.Value ? null : (int)r["amount"]
// ),CTS.Token);
// }
// FComm.CommandText = "SELECT * FROM charges";
// await using (SqlDataReader CRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
// {
// Charges = await CRead.ToListAsync<Charge>(r=>new(
// (byte)r["chargid"],
// (string)r["name"],
// r["percentage"] == DBNull.Value ? null : (byte)r["percentage"],
// r["amount"] == DBNull.Value ? null : (int)r["amount"]
// ),CTS.Token);
// }
// FComm.CommandText = "SELECT * FROM packview";
// await using (SqlDataReader PRead = await FComm.ExecuteReaderAsync(CTS.Token).ConfigureAwait(false))
// {
// Packages = await PRead.ToListAsync<PackItem>(r=>new(
// (byte)r["packid"],
// (string)r["name"],
// (short)r["durinmin"],
// (int)r["price"],
// (byte)r["shiftid"],
// (string)r["shift"],
// (byte)r["schedid"],
// (byte)r["day"],
// (bool)r["active"]
// ), CTS.Token);
// }
// EventsMarker.CacheUpdates = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString("X");
}
}
internal static class Logging
{
private static readonly object Lock = new();
internal static async void WriteLog(Exception ex, string location = "")
{
await Task.Run(()=>{
string Time = $"{DateTime.Now:yyy-MM-dd HH:mm:ss}";
string msg = $"{Time} [{"Error".PadRight(7)[0..7]}] {ex.Message}{(location.Length > 0 ? $" {location}" : "")}{Environment.NewLine}";
Console.Write(msg);
try
{
byte[] msgbytes = Encoding.UTF8.GetBytes(msg);
lock (Lock)
{
using FileStream LogWriter = new($"{AppContext.BaseDirectory}/{DateTime.Now:yyyyMMdd}.log", FileMode.Append);
LogWriter.Write(msgbytes, 0, msgbytes.Length);
}
}
finally
{
}
});
}
internal static async void WriteLog(string exm, string location = "")
{
await Task.Run(()=>{
string Time = $"{DateTime.Now:yyy-MM-dd HH:mm:ss}";
string msg = $"{Time} [{"Info".PadRight(7)[0..7]}] {exm}{(location.Length > 0 ? $" {location}" : "")}{Environment.NewLine}";
Console.Write(msg);
try
{
byte[] msgbytes = Encoding.UTF8.GetBytes(msg);
lock (Lock)
{
using FileStream LogWriter = new($"{AppContext.BaseDirectory}/{DateTime.Now:yyyyMMdd}.log", FileMode.Append);
LogWriter.Write(msgbytes, 0, msgbytes.Length);
}
}
finally
{
}
});
}
}
internal static class DataReaderExtensions
{
internal static async Task<List<T>> ToListAsync<T>(
this SqlDataReader reader,
Func<SqlDataReader, T> map,
CancellationToken cancellationToken = default)
{
var list = new List<T>();
while (await reader.ReadAsync(cancellationToken))
{
list.Add(map(reader));
}
return list;
}
}

78
Middlewares.cs
View File

@ -1,78 +0,0 @@
using System;
using Microsoft.Extensions.Hosting;
namespace perubahan;
public class Middlewares
{
public class AuthCheck(RequestDelegate next)
{
public async Task Invoke(HttpContext runner)
{
if(runner.Request.Cookies.ContainsKey("session"))
{
string Token = runner.Request.Cookies["session"] ?? ".";
string LoggedInBase64 = Token.Split(".")[0];
string Signature = Token.Split(".")[1];
if (Convert.ToBase64String(SHA256.HashData(Encoding.UTF8.GetBytes(LoggedInBase64+SecretKey))).Equals(Signature,StringComparison.InvariantCultureIgnoreCase))
{
string Username = (string?)JsonNode.Parse(Encoding.UTF8.GetString(Convert.FromBase64String(LoggedInBase64)))?["username"] ?? "";
SafeUser LoggedIn = SafeUser.FromUser(UserAccounts[Username]);
if (LoggedIn.Active)
{
runner.Items.Add("AuthorizedUser",LoggedIn);
}
else
{
runner.Response.Cookies.Append("session", "", Delete);
}
}
else
{
runner.Response.Cookies.Append("session", "", Delete);
}
}
await next(runner);
}
}
public class DomainNormalize(RequestDelegate next)
{
public async Task Invoke(HttpContext runner)
{
HttpOnly.Domain = runner.Request.Host.ToString();
Delete.Domain = runner.Request.Host.ToString();
await next(runner);
}
}
public class ErrorHandling(RequestDelegate next)
{
public async Task Invoke(HttpContext context)
{
try
{
await next(context);
}
catch (Exception ex)
{
await HandleExceptionAsync(context, ex);
throw;
}
}
private static Task HandleExceptionAsync(HttpContext context, Exception ex)
{
WriteLog(ex, $"at {Path.Combine(context.Request.PathBase, context.Request.Path)}");
context.Response.StatusCode = StatusCodes.Status500InternalServerError;
return context.Response.WriteAsJsonAsync(new SimpleApiResponse(context.Response.StatusCode, "Internal Server Error."), SGContext.Default.SimpleApiResponse);
}
}
public class CancellationTokenSourceLinker(RequestDelegate next, IHostApplicationLifetime Lifetime)
{
public async Task Invoke(HttpContext context)
{
CancellationTokenSource LinkedToken = CancellationTokenSource.CreateLinkedTokenSource(Lifetime.ApplicationStopping,context.RequestAborted,CTS.Token);
context.RequestAborted = LinkedToken.Token;
await next(context);
}
}
}

34
Partials.cs
View File

@ -1,34 +0,0 @@
using System;
using System.Text.Json;
using System.Text.Json.Serialization;
internal partial record Agent(string AgentID, string Name, string Jabatan, short DeplID, string SKAngkat, DateOnly TMT, string? SKPerb, DateOnly? TMUbah, string? Vision, string? Mission, string? PhotoURL);
internal partial record ApiResponse(int Status, string Message, object Data);
internal partial record Deployment(short DeplID, string UnitKerja);
internal partial record LoginUser(string Username, string Password);
internal partial record PasswdUser(string Username, string PlainPassword);
internal partial record SafeUser(string Username, string Name, byte Level, bool Active){
internal static SafeUser FromUser(User Source)
{
return new(Source.Username, Source.Name, Source.Level, Source.Active);
}
};
internal partial record SimpleApiResponse(int Status, string Message);
internal partial record User(string Username, string Name, string Password, byte Level, bool Active);
[JsonSerializable(typeof(Agent))]
[JsonSerializable(typeof(ApiResponse))]
[JsonSerializable(typeof(Deployment))]
[JsonSerializable(typeof(JsonElement))]
[JsonSerializable(typeof(JsonElement[]))]
[JsonSerializable(typeof(LoginUser))]
[JsonSerializable(typeof(PasswdUser))]
[JsonSerializable(typeof(SafeUser))]
[JsonSerializable(typeof(SimpleApiResponse))]
[JsonSerializable(typeof(User))]
//////////----------DICTIONARIES----------//////////
[JsonSerializable(typeof(Dictionary<string, JsonElement>))]
//////////-------------LISTS--------------//////////
[JsonSerializable(typeof(List<Agent>))]
[JsonSerializable(typeof(List<Deployment>))]
[JsonSourceGenerationOptions(GenerationMode =JsonSourceGenerationMode.Default, PropertyNameCaseInsensitive = true, PropertyNamingPolicy = JsonKnownNamingPolicy.CamelCase)]
internal partial class SGContext : JsonSerializerContext{}

66
Program.cs
View File

@ -1,64 +1,2 @@
using perubahan; // See https://aka.ms/new-console-template for more information
using Microsoft.Extensions.DependencyInjection; Console.WriteLine("Hello, World!");
try
{
Console.WriteLine($"Kementerian ATR/BPN Kanwil Riau");
Console.WriteLine($"Agen Perubahan Server Versi {VerNum}");
Console.Write($"Loading settings file...");
if (!File.Exists(Path.Combine(AppContext.BaseDirectory, "settings.json")))
{
Console.WriteLine("No settings file found. Make sure settings.json exists at BaseDirectory.");
WriteLog("No default settings file found. Make sure settings.json exists at BaseDirectory.");
return;
}
string SettingsJson = File.ReadAllText(Path.Combine(AppContext.BaseDirectory, "settings.json"));
Settings = JsonNode.Parse(SettingsJson) ?? JsonNode.Parse("{}")!;
Console.WriteLine($"Done.");
Console.Write($"Preparing database connection string... ");
SqlConnectionStringBuilder CSBuilder = new ()
{
DataSource = (string)Settings["database"]!["datasource"]! ?? "",
UserID = (string)Settings["database"]!["user"]! ?? "",
Password = (string)Settings["database"]!["pass"]! ?? "",
InitialCatalog = (string)Settings["database"]!["initialcatalog"]! ?? "",
Encrypt = SqlConnectionEncryptOption.Mandatory,
TrustServerCertificate = true
};
CS = CSBuilder.ConnectionString;
Console.WriteLine($"Done.");
_ = await UpdateCache();
Console.Write($"Configuring Kestrel Backend... ");
IWebHost host = new WebHostBuilder()
.UseKestrel(options => {
options.ListenAnyIP(443, opt =>{
opt.Protocols = Microsoft.AspNetCore.Server.Kestrel.Core.HttpProtocols.Http1AndHttp2;
opt.UseHttps(Path.Combine(AppContext.BaseDirectory,"origin.pfx"));
});
options.Limits.MaxRequestBodySize = 104857600;
})
.UseContentRoot(AppContext.BaseDirectory)
// .ConfigureServices(r=>{
// r.AddResponseCompression(o=>{
// o.EnableForHttps = true;
// o.Providers.Add<Microsoft.AspNetCore.ResponseCompression.BrotliCompressionProvider>();
// o.Providers.Add<Microsoft.AspNetCore.ResponseCompression.GzipCompressionProvider>();
// });
// })
.Configure(app=>{
app
.UseMiddleware<ErrorHandling>()
.UseMiddleware<CancellationTokenSourceLinker>()
.UseMiddleware<DomainNormalize>()
.UseMiddleware<AuthCheck>()
.UseDefaultFiles()
.Map("/api",APIHandler.Handle)
.Map("/auth",Auth.Handle)
.UseStaticFiles();
})
.Build();
host.Run();
}
catch (Exception ex)
{
WriteLog(ex, "Program.cs");
}

4
obj/Debug/net8.0/.NETCoreApp,Version=v8.0.AssemblyAttributes.cs Normal file
View File

@ -0,0 +1,4 @@
// <autogenerated />
using System;
using System.Reflection;
[assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETCoreApp,Version=v8.0", FrameworkDisplayName = ".NET 8.0")]

22
obj/Debug/net8.0/perubahan.AssemblyInfo.cs Normal file
View File

@ -0,0 +1,22 @@
//------------------------------------------------------------------------------
// <auto-generated>
// This code was generated by a tool.
//
// Changes to this file may cause incorrect behavior and will be lost if
// the code is regenerated.
// </auto-generated>
//------------------------------------------------------------------------------
using System;
using System.Reflection;
[assembly: System.Reflection.AssemblyCompanyAttribute("perubahan")]
[assembly: System.Reflection.AssemblyConfigurationAttribute("Debug")]
[assembly: System.Reflection.AssemblyFileVersionAttribute("1.0.0.0")]
[assembly: System.Reflection.AssemblyInformationalVersionAttribute("1.0.0")]
[assembly: System.Reflection.AssemblyProductAttribute("perubahan")]
[assembly: System.Reflection.AssemblyTitleAttribute("perubahan")]
[assembly: System.Reflection.AssemblyVersionAttribute("1.0.0.0")]
// Generated by the MSBuild WriteCodeFragment class.

1
obj/Debug/net8.0/perubahan.AssemblyInfoInputs.cache Normal file
View File

@ -0,0 +1 @@
d45aba3c94cb9998b108e314fcb8b32ee7f31cb89facf16db686b08c63200b65

13
obj/Debug/net8.0/perubahan.GeneratedMSBuildEditorConfig.editorconfig Normal file
View File

@ -0,0 +1,13 @@
is_global = true
build_property.TargetFramework = net8.0
build_property.TargetPlatformMinVersion =
build_property.UsingMicrosoftNETSdkWeb =
build_property.ProjectTypeGuids =
build_property.InvariantGlobalization =
build_property.PlatformNeutralAssembly =
build_property.EnforceExtendedAnalyzerRules =
build_property._SupportedPlatformList = Linux,macOS,Windows
build_property.RootNamespace = perubahan
build_property.ProjectDir = /Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/
build_property.EnableComHosting =
build_property.EnableGeneratedComInterfaceComImportInterop =

8
obj/Debug/net8.0/perubahan.GlobalUsings.g.cs Normal file
View File

@ -0,0 +1,8 @@
// <auto-generated/>
global using global::System;
global using global::System.Collections.Generic;
global using global::System.IO;
global using global::System.Linq;
global using global::System.Net.Http;
global using global::System.Threading;
global using global::System.Threading.Tasks;

BIN
obj/Debug/net8.0/perubahan.assets.cache Normal file
View File

Binary file not shown.

66
obj/perubahan.csproj.nuget.dgspec.json Normal file
View File

@ -0,0 +1,66 @@
{
"format": 1,
"restore": {
"/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj": {}
},
"projects": {
"/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj",
"projectName": "perubahan",
"projectPath": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj",
"packagesPath": "/Users/fajarnugroho/.nuget/packages/",
"outputPath": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/obj/",
"projectStyle": "PackageReference",
"configFilePaths": [
"/Users/fajarnugroho/.nuget/NuGet/NuGet.Config"
],
"originalTargetFrameworks": [
"net8.0"
],
"sources": {
"https://api.nuget.org/v3/index.json": {}
},
"frameworks": {
"net8.0": {
"targetAlias": "net8.0",
"projectReferences": {}
}
},
"warningProperties": {
"warnAsError": [
"NU1605"
]
},
"restoreAuditProperties": {
"enableAudit": "true",
"auditLevel": "low",
"auditMode": "direct"
}
},
"frameworks": {
"net8.0": {
"targetAlias": "net8.0",
"imports": [
"net461",
"net462",
"net47",
"net471",
"net472",
"net48",
"net481"
],
"assetTargetFallback": true,
"warn": true,
"frameworkReferences": {
"Microsoft.NETCore.App": {
"privateAssets": "all"
}
},
"runtimeIdentifierGraphPath": "/usr/local/share/dotnet/sdk/8.0.408/PortableRuntimeIdentifierGraph.json"
}
}
}
}
}

15
obj/perubahan.csproj.nuget.g.props Normal file
View File

@ -0,0 +1,15 @@
<?xml version="1.0" encoding="utf-8" standalone="no"?>
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<PropertyGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<RestoreSuccess Condition=" '$(RestoreSuccess)' == '' ">True</RestoreSuccess>
<RestoreTool Condition=" '$(RestoreTool)' == '' ">NuGet</RestoreTool>
<ProjectAssetsFile Condition=" '$(ProjectAssetsFile)' == '' ">$(MSBuildThisFileDirectory)project.assets.json</ProjectAssetsFile>
<NuGetPackageRoot Condition=" '$(NuGetPackageRoot)' == '' ">/Users/fajarnugroho/.nuget/packages/</NuGetPackageRoot>
<NuGetPackageFolders Condition=" '$(NuGetPackageFolders)' == '' ">/Users/fajarnugroho/.nuget/packages/</NuGetPackageFolders>
<NuGetProjectStyle Condition=" '$(NuGetProjectStyle)' == '' ">PackageReference</NuGetProjectStyle>
<NuGetToolVersion Condition=" '$(NuGetToolVersion)' == '' ">6.11.1</NuGetToolVersion>
</PropertyGroup>
<ItemGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<SourceRoot Include="/Users/fajarnugroho/.nuget/packages/" />
</ItemGroup>
</Project>

2
obj/perubahan.csproj.nuget.g.targets Normal file
View File

@ -0,0 +1,2 @@
<?xml version="1.0" encoding="utf-8" standalone="no"?>
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003" />

71
obj/project.assets.json Normal file
View File

@ -0,0 +1,71 @@
{
"version": 3,
"targets": {
"net8.0": {}
},
"libraries": {},
"projectFileDependencyGroups": {
"net8.0": []
},
"packageFolders": {
"/Users/fajarnugroho/.nuget/packages/": {}
},
"project": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj",
"projectName": "perubahan",
"projectPath": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj",
"packagesPath": "/Users/fajarnugroho/.nuget/packages/",
"outputPath": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/obj/",
"projectStyle": "PackageReference",
"configFilePaths": [
"/Users/fajarnugroho/.nuget/NuGet/NuGet.Config"
],
"originalTargetFrameworks": [
"net8.0"
],
"sources": {
"https://api.nuget.org/v3/index.json": {}
},
"frameworks": {
"net8.0": {
"targetAlias": "net8.0",
"projectReferences": {}
}
},
"warningProperties": {
"warnAsError": [
"NU1605"
]
},
"restoreAuditProperties": {
"enableAudit": "true",
"auditLevel": "low",
"auditMode": "direct"
}
},
"frameworks": {
"net8.0": {
"targetAlias": "net8.0",
"imports": [
"net461",
"net462",
"net47",
"net471",
"net472",
"net48",
"net481"
],
"assetTargetFallback": true,
"warn": true,
"frameworkReferences": {
"Microsoft.NETCore.App": {
"privateAssets": "all"
}
},
"runtimeIdentifierGraphPath": "/usr/local/share/dotnet/sdk/8.0.408/PortableRuntimeIdentifierGraph.json"
}
}
}
}

8
obj/project.nuget.cache Normal file
View File

@ -0,0 +1,8 @@
{
"version": 2,
"dgSpecHash": "LeHU7QVBO5Y=",
"success": true,
"projectFilePath": "/Users/fajarnugroho/Documents/Code Repository/agenperubahan/perubahan/perubahan.csproj",
"expectedPackageFiles": [],
"logs": []
}

10
perubahan.csproj
View File

@ -5,16 +5,6 @@
<TargetFramework>net8.0</TargetFramework> <TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<PublishAot>true</PublishAot>
</PropertyGroup> </PropertyGroup>
<ItemGroup>
<FrameworkReference Include="Microsoft.AspNetCore.App" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Data.SqlClient" Version="6.0.2" />
<PackageReference Include="System.Text.Json" Version="9.0.4" />
</ItemGroup>
</Project> </Project>