Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
79 changes: 34 additions & 45 deletions TransactionProcessing.SchedulerService/JobTestDriver/Program.cs
Original file line number Diff line number Diff line change
@@ -1,20 +1,9 @@
using Quartz;
using Quartz.Core;
using Quartz.Impl;
using TransactionProcessing.SchedulerService.Jobs.Configuration;
using TransactionProcessing.SchedulerService.Jobs.Jobs;

namespace JobTestDriver
namespace JobTestDriver
{
using MessagingService.Client;
using NLog.LayoutRenderers.Wrappers;
using SecurityService.Client;
using TransactionProcessing.SchedulerService.DataGenerator;
using TransactionProcessing.SchedulerService.Jobs;
using TransactionProcessor.Client;

//using TransactionProcessing.SchedulerService.DataGenerator;

internal class Program{
static async Task Main(string[] args){

Check warning on line 6 in TransactionProcessing.SchedulerService/JobTestDriver/Program.cs

View workflow job for this annotation

GitHub Actions / Build and Test Pull Requests

This async method lacks 'await' operators and will run synchronously. Consider using the 'await' operator to await non-blocking API calls, or 'await Task.Run(...)' to do CPU-bound work on a background thread.

//List<(String groupName, String streamName, Int64 parkedMessageCount)>? info = await Jobs.GetParkedQueueInformation("esdb://admin:changeit@192.168.0.133:2113?tls=false&tlsVerifyCert=false", CancellationToken.None);
//foreach ((String groupName, String streamName, Int64 parkedMessageCount) infoItem in info){
Expand All @@ -38,40 +27,40 @@
// messagingServiceClient,
// CancellationToken.None);

HttpClientHandler handler = new HttpClientHandler
{
ServerCertificateCustomValidationCallback = (message,
cert,
chain,
errors) =>
{
return true;
}
};
HttpClient client = new HttpClient(handler);
ISecurityServiceClient securityServiceClient = new SecurityServiceClient(delegate (String s) { return "https://192.168.1.167:5001"; }, client);
ITransactionProcessorClient transactionProcessorClient = new TransactionProcessorClient(delegate (String s) { return "https://eojrtqfzvyheu0l.m.pipedream.net"; }, client);
String transactionProcessorApi = "http://192.168.1.167:5002";
String fileProcessorApi = "http://192.168.1.167:5009";
String testHostApi = "http://192.168.1.167:9000";
String clientId = "serviceClient";
String clientSecret = "d192cbc46d834d0da90e8a9d50ded543";
//HttpClientHandler handler = new HttpClientHandler
//{
// ServerCertificateCustomValidationCallback = (message,
// cert,
// chain,
// errors) =>
// {
// return true;
// }
//};
//HttpClient client = new HttpClient(handler);
//ISecurityServiceClient securityServiceClient = new SecurityServiceClient(delegate (String s) { return "https://192.168.1.167:5001"; }, client);
//ITransactionProcessorClient transactionProcessorClient = new TransactionProcessorClient(delegate (String s) { return "https://eojrtqfzvyheu0l.m.pipedream.net"; }, client);
//String transactionProcessorApi = "http://192.168.1.167:5002";
//String fileProcessorApi = "http://192.168.1.167:5009";
//String testHostApi = "http://192.168.1.167:9000";
//String clientId = "serviceClient";
//String clientSecret = "d192cbc46d834d0da90e8a9d50ded543";

ITransactionDataGeneratorService t = new TransactionDataGeneratorService(securityServiceClient,
transactionProcessorClient,
transactionProcessorApi,
fileProcessorApi,
testHostApi,
clientId,
clientSecret,
RunningMode.WhatIf);
Guid estateId = Guid.Parse("435613ac-a468-47a3-ac4f-649d89764c22");
//ITransactionDataGeneratorService t = new TransactionDataGeneratorService(securityServiceClient,
// transactionProcessorClient,
// transactionProcessorApi,
// fileProcessorApi,
// testHostApi,
// clientId,
// clientSecret,
// RunningMode.WhatIf);
//Guid estateId = Guid.Parse("435613ac-a468-47a3-ac4f-649d89764c22");

MakeFloatCreditsJobConfig c = new MakeFloatCreditsJobConfig(clientId,clientSecret, fileProcessorApi,"","", transactionProcessorApi, estateId,
new List<DepositAmount> { new DepositAmount("" ,"", 100) }
);
//MakeFloatCreditsJobConfig c = new MakeFloatCreditsJobConfig(clientId,clientSecret, fileProcessorApi,"","", transactionProcessorApi, estateId,
// new List<DepositAmount> { new DepositAmount("" ,"", 100) }
//);

await Jobs.GenerateFloatCredits(t, c, CancellationToken.None);
//await Jobs.GenerateFloatCredits(t, c, CancellationToken.None);
//Guid merchantId = Guid.Parse("ab1c99fb-1c6c-4694-9a32-b71be5d1da33");
//await Jobs.GenerateTransactions(t, estateId, merchantId, false, CancellationToken.None);
////var d = TransactionDataGenerator.GetTransactionDateTime(new Random(), DateTime.Now);
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading
Loading