iframe-proxy | Sunbelt Computer Software

History

79 lines (70 loc) · 3.14 KB

Raw

using Microsoft.AspNetCore.Builder;

using Microsoft.AspNetCore.Http;

using Microsoft.Extensions.Logging;

using NpgsqlRest.CrudSource;

using Microsoft.Extensions.DependencyInjection;

using System.Security.Claims;

#pragma warning disable CS8633 // Nullability in constraints for type parameter doesn't match the constraints for type parameter in implicitly implemented interface method'.

#pragma warning disable CS8767 // Nullability of reference types in type of parameter doesn't match implicitly implemented member (possibly because of nullability attributes).

namespace NpgsqlRestTests;

public class EmptyLogger : ILogger

{

public IDisposable BeginScope<TState>(TState state) => throw new NotImplementedException();

public bool IsEnabled(LogLevel logLevel) => false;

public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception exception, Func<TState, Exception, string> formatter) { }

}

public class Program

{

static async Task ValidateAsync(ParameterValidationValues p)

{

if (p.Routine.Name == "case_jsonpath_param" && p.Parameter.Value?.ToString() == "XXX")

{

p.Context.Response.StatusCode = (int)HttpStatusCode.BadRequest;

await p.Context.Response.WriteAsync($"Paramater {p.ParamName} is not valid.");

}

public static void Main()

{

var connectionString = Database.Create();

// disable SQL rewriting to ensure that NpgsqlRest works with this option on.

AppContext.SetSwitch("Npgsql.EnableSqlRewriting", false);

var builder = WebApplication.CreateBuilder([]);

builder.Services.AddAuthentication().AddCookie("test_scheme");

var app = builder.Build();

app.MapGet("/login", () => Results.SignIn(new ClaimsPrincipal(new ClaimsIdentity(

claims: new[]

{

new Claim(ClaimTypes.Name, "user"),

new Claim(ClaimTypes.Role, "role1"),

new Claim(ClaimTypes.Role, "role2"),

new Claim(ClaimTypes.Role, "role3"),

authenticationType: "test_scheme"))));

app.UseNpgsqlRest(new(connectionString)

{

//NameSimilarTo = "authorized_roles%",

ValidateParametersAsync = ValidateAsync,

Logger = new EmptyLogger(),

CommandCallbackAsync = async p =>

{

if (string.Equals(p.routine.Name , "get_csv_data"))

{

p.context.Response.ContentType = "text/csv";

await using var reader = await p.command.ExecuteReaderAsync();

while (await reader.ReadAsync())

{

var line = $"{reader[0]},{reader[1]},{reader.GetDateTime(2):s},{reader.GetBoolean(3).ToString().ToLowerInvariant()}\n";

await p.context.Response.WriteAsync(line);

}

SourcesCreated = sources =>

{

//sources.Clear();

sources.Add(new CrudSource());

sources.Add(new TestSource());

});

app.Run();

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

Uh oh!

FilesExpand file tree

Program.cs

Latest commit

History

Program.cs

File metadata and controls