using System;
using System.Data.OleDb;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text.Json;
using System.Text.Json.Nodes;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

class Program
{
	static async Task Main(string[] args)
	{
		// URL da API que você deseja chamar
		string apiUrl = "https://api.pipefy.com/graphql";
		string PipefyToken = "eyJhbGciOiJIUzUxMiJ9.eyJpc3MiOiJQaXBlZnkiLCJpYXQiOjE2OTg4NTYyMjcsImp0aSI6IjM2N2Y4M2NhLWZjODYtNGRhOC04ODEyLTkzODRkZGZkODc0MiIsInN1YiI6MzAyNTM0MzY2LCJ1c2VyIjp7ImlkIjozMDI1MzQzNjYsImVtYWlsIjoiYmFjazVAZW5lcmdpYXNtYXJ0LmNvbS5iciIsImFwcGxpY2F0aW9uIjozMDAyODkyNDgsInNjb3BlcyI6W119LCJpbnRlcmZhY2VfdXVpZCI6bnVsbH0.o13j9c_y3G3HX35qhX4PmkkibGsmlHsk5dL_Bxsr1CKV5Jlgj218kJdEmriS7aHiw0-P7sfs-bu4YcElfuyiqg";
		string ConnSourcePath = @"C:\Users\contratos\Documents\Giuliano\Pipefy.accdb";
		string PipefyTokenTableID = "b9t-7uD5";


        // Crie uma instância HttpClient
        using (HttpClient httpClient = new HttpClient())
		{
			// Defina os headers da requisição (opcional)
			httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
			httpClient.DefaultRequestHeaders.Add("Accept", "application/json");
			httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " + PipefyToken);

			// Crie a consulta GraphQL
			string query = /*lang=json,strict*/ @"{""query"":""query{\r\n  table_records(table_id: \""wzirXS8w\"") {\r\n    edges {\r\n      node {\r\n        id\r\n        record_fields{\r\n          field{\r\n            id\r\n          }\r\n          value\r\n        }\r\n      }\r\n    }\r\n  }\r\n}"",""variables"":{}}";

			// Defina o conteúdo do corpo da requisição
			var content = new StringContent(query, System.Text.Encoding.UTF8, "application/json");

			// Envie a requisição POST com a consulta GraphQL
			var response = await httpClient.PostAsync(apiUrl, content);

			if (response.IsSuccessStatusCode)
			{
				string responseBody = await response.Content.ReadAsStringAsync();

				Console.WriteLine("Resposta bem-sucedida:");
				Console.WriteLine(responseBody);

				// Agora você pode comparar a resposta JSON com a tabela no banco de dados Access
				CompareResponseWithDatabase(responseBody, ConnSourcePath);
			}
			else
			{
				Console.WriteLine($"Erro na requisição: {response.StatusCode}");
			}
		}
	}
	static void CompareResponseWithDatabase(string jsonResponse, string ConnSourcePath)
	{
		// Defina a string de conexão para o banco de dados Access
		string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ConnSourcePath;
        var responseObject = JObject.Parse(jsonResponse);

        var idFromJson = responseObject["data"]["table_records"]["edges"];
        foreach( var id in idFromJson){
			var a = 10;
		}

        using (OleDbConnection connection = new OleDbConnection(connectionString))
		{
			connection.Open();

			// Execute uma consulta SQL para recuperar dados da tabela no banco de dados Access
			string sqlQuery = "SELECT * FROM tblEmpresas";
            using (OleDbCommand command = new OleDbCommand(sqlQuery, connection))
			{
				//teste
				using (OleDbDataReader reader = command.ExecuteReader())
				{
					while (reader.Read())
					{
                        int idFromDatabase = (int)reader["id"];
                        string nomeFromDatabase = (string)reader["nome"];

						// Compare os valores do JSON com os valores do banco de dados
						//if (idFromJson == idFromDatabase && nomeFromJson == nomeFromDatabase)
						//{
						//	// Realize ação quando houver correspondência
						//	Console.WriteLine("Correspondência encontrada!");
						//}
					}
				}
			}
		}
	}
}