using System;
using System.Threading.Tasks;
using InfluxDB.Client;
using InfluxDB.Client.Writes;

namespace Examples
{
    public class InfluxDB18Example
    {
        public static async Task Main()
        {
            const string database = "telegraf";
            const string retentionPolicy = "autogen";

            using var client = new InfluxDBClient("http://localhost:8086",
                "username",
                "password",
                database,
                retentionPolicy);

            Console.WriteLine("*** Write Points ***");

            using (var writeApi = client.GetWriteApi())
            {
                var point = PointData.Measurement("mem")
                    .Tag("host", "host1")
                    .Field("used_percent", 28.43234543);

                writeApi.WritePoint(point);
            }

            Console.WriteLine("*** Query Points ***");

            var query = $"from(bucket: \"{database}/{retentionPolicy}\") |> range(start: -1h)";
            var fluxTables = await client.GetQueryApi().QueryAsync(query);
            var fluxRecords = fluxTables[0].Records;
            fluxRecords.ForEach(record =>
            {
                Console.WriteLine(
                    $"{record.GetTime()} {record.GetMeasurement()}: {record.GetField()} {record.GetValue()}");
            });
        }
    }
}