MyWorkPal

const string baseAddress = "[PLATFORMAPIURL]"; // ConfigurationManager.AppSettings["WebApi.Uri"];
const string uploadUrl = "/api/admin/tenant/datatransfer/template/json/upload";
const string statusurl = "/api/admin/tenant/datatransfer/template/status";
const string downloadDataUrl = "/api/admin/tenant/datatransfer/template/json/download";
const string downloadUrl = "/api/admin/tenant/datatransfer/template/json/requestdownload";
const string tenantId = "[TENANTID]"; // ConfigurationManager.AppSettings["tenantId"];
const string templateName = "[DTTNAME]"; // ConfigurationManager.AppSettings["TemplateName"];
const string uploadFileNameAndPath = "C:\\Git\\Test\\Upload.txt"; // ConfigurationManager.AppSettings["uploadFileNameAndPath"];
const string downloadFileAndPath = "C:\\Git\\Test\\Download.txt"; // ConfigurationManager.AppSettings["downloadFileAndPath"];
const string clientId = "[CLIENTAPI]"; // ConfigurationManager.AppSettings["ClientId"];
const string clientSecret = "[CLIENTSECRET]"; // ConfigurationManager.AppSettings["ClientSecret"];

Console.WriteLine("Test Harness to demostrate the API to use with Data Transfer Templates");
Console.Write("Enter an option [U]pload/[R]equestDownload/[S]tatus]/[D]ownloadData/[Q]uit: ");
var action = Console.ReadKey();
Console.WriteLine();
if (action.KeyChar == 'q')
{
	return action.KeyChar;
}

try
{

	var client = new HttpClient
	{
		BaseAddress = new Uri(baseAddress)
	};
	var formContent = new FormUrlEncodedContent(new[] {
		new KeyValuePair<string, string>("grant_type", "client_credentials"),
		new KeyValuePair<string, string>("scope", "api"),
		new KeyValuePair<string, string>("client_id", clientId),
		new KeyValuePair<string, string>("client_secret", clientSecret)
	});

	var response = await client.PostAsync("/idp/connect/token", formContent);
	var content = await response.Content.ReadAsStringAsync();

	// The content received is in Json format.  Parse this json object to retrieve the access token
	var accessToken = JsonConvert.DeserializeObject<dynamic>(content).access_token;
	Console.WriteLine("Connection made");

	// Add an authorization header to the http client and add the token.
	// Without this header you will not be able to get responses from the api.
	// Make note of the "Bearer " bit.  It is important to have this
	client.DefaultRequestHeaders.Add("Authorization", "Bearer " + accessToken);
	
	switch (action.KeyChar)
	{
		case 'd':
			Console.Write("Enter Scheduled Task Id to retrieve the data: ");
			var filedownloadSchduleTaskId = Console.ReadLine();
			Console.WriteLine("Attempting to get the file...");
			response = await client.GetAsync(downloadDataUrl + "/" + tenantId + "/" + filedownloadSchduleTaskId);

			if (response.IsSuccessStatusCode)
			{
				// Get the scheduled task status
				var downloadfileRequestResponse = await response.Content.ReadAsStringAsync();
				File.WriteAllText(downloadFileAndPath, JsonConvert.DeserializeObject<string>(downloadfileRequestResponse));
				Console.WriteLine($"Downloaded to {downloadFileAndPath}");
			}
			else
			{
				Console.WriteLine($"Failure message returned: {response.ReasonPhrase}.");
			}
			break;
		case 'u':
			if (File.Exists(uploadFileNameAndPath))
			{
				var jsonData = File.ReadAllText(uploadFileNameAndPath);
				var jsonUploadParams = new
				{
					tenantId,
					templateName,
					jsonData,
					dttUploadName = "April employee load",
					fileName = Path.GetFileName(uploadFileNameAndPath),
					uploadDescription = "Generated from system x",
					sendEmailWhenComplete = true,
				};

				//post content
				var uploadRequest = new StringContent(JsonConvert.SerializeObject(jsonUploadParams), Encoding.UTF8, "application/json");
				Console.WriteLine("Attempting upload...");
				response = await client.PostAsync(uploadUrl, uploadRequest);

				//get the result
				var uploadRequestResponse = await response.Content.ReadAsStringAsync();
				if (uploadRequestResponse.StartsWith("{\"message\":\"Failure. Error"))
				{
					Console.WriteLine($"Failure message returned:{uploadRequestResponse}");
				}
				else
				{
					Console.WriteLine($"Scheduled Task Id for job is : {uploadRequestResponse}");
				}
			}
			else
			{
				Console.WriteLine("Upload file not found");
			}
			break;
		case 'r':
			var jsonObject = new { tenantId, templateName };

			//post content
			var downloadRequest = new StringContent(JsonConvert.SerializeObject(jsonObject), Encoding.UTF8, "application/json");
			Console.WriteLine("Attempting download...");
			response = await client.PostAsync(downloadUrl, downloadRequest);

			//get the result
			var downloadRequestResponse = await response.Content.ReadAsStringAsync();
			if (downloadRequestResponse.StartsWith("{\"message\":\"Failure. Error") || downloadRequestResponse.StartsWith("{\"message\":\"Data transfer template not found\"}"))
				Console.WriteLine($"Failure message returned: {downloadRequestResponse}");
			else
			{
				Console.WriteLine($"Scheduled Task Id for job is : {downloadRequestResponse}");
			}
			break;
		case 's':
			Console.Write("Enter Scheduled Task Id to get the status for: ");
			var schduleTaskId = Console.ReadLine();
			Console.WriteLine("Attempting to get the status...");
			response = await client.GetAsync(statusurl + "/" + tenantId + "/" + schduleTaskId);

			if (response.IsSuccessStatusCode)
			{
				// Get the scheduled task status
				var statusRequestResponse = await response.Content.ReadAsStringAsync();
				Console.WriteLine($"Response for this request is: {statusRequestResponse}");
			}
			else
			{
				Console.WriteLine($"Failure message returned: {response.ReasonPhrase}.");
			}
			break;					
		default:
			Console.WriteLine("Invalid option");
			break;
	}
	
}
catch (Exception ex)
{
	Console.WriteLine($"An unplanned error occurred: {ex.Message}");
	Console.Write("Please check the configuration.");
}

return action.KeyChar;