Abbot – “weather v1.3.0” by Serious Business

Code

<br /> const int VERSION=1;</p> <p>var (cmd, args) = Bot.Arguments.Pop();</p> <p>Task reply = cmd switch {<br /> “check” => CheckSubscriptions(),<br /> “watch” or “start” or “add” => HandleSubscribe(args),<br /> “unwatch” or “stop” or “remove” => HandleUnsubscribe(args),<br /> “subs” => HandleSubs(args),<br /> _ => HandleOther(Bot.Arguments)<br /> };</p> <p>await reply;</p> <p>async Task<(string, string, bool, bool, bool, bool)> ParseLocation(IArguments args) {<br /> var (zc, ct) = args;<br /> var country = “US”;<br /> var zipOrCity = “”;<br /> var parsedFromLocation = false;<br /> var success = true;<br /> var isZip = false;<br /> var hasCountry = false;<br /> if (zc is IMissingArgument) {<br /> if (Bot.From.Location.Coordinate is null) {<br /> success = false;<br /> } else {<br /> var parts = Bot.From.Location.FormattedAddress.Split(‘,’)[^2..^0];<br /> country = parts[1];<br /> zipOrCity = parts[0];<br /> hasCountry = true;<br /> parsedFromLocation = true;<br /> }<br /> } else {<br /> zipOrCity = zc.Value;<br /> isZip = Regex.Match(zipOrCity, zipUSRegex).Success;<br /> hasCountry = !(ct is IMissingArgument);<br /> if (hasCountry) {<br /> country = ct.Value;<br /> } else if (!isZip) {<br /> var endpoint = $”{weatherEndpoint}?q={zipOrCity}”;<br /> try {<br /> var results = await Bot.Http.GetJsonAsync(endpoint);<br /> country = results.sys.country;<br /> hasCountry = true;<br /> } catch (HttpRequestException) {<br /> await Bot.ReplyAsync($”The location you provided ({zipOrCity}) could not be found.”);<br /> success = false;<br /> } catch (Exception e) {<br /> await Bot.ReplyAsync($”There was an unspecified error finding {zipOrCity} {e.Message}.”);<br /> success = false;<br /> }<br /> }<br /> }</p> <p> return (zipOrCity, country, isZip, parsedFromLocation, hasCountry, success);<br /> }</p> <p>async Task HandleSubscribe(IArguments args) {<br /> var (zipOrCity, country, isZip, _, hasCountry, success) = await ParseLocation(args);<br /> if (!success) {<br /> await Bot.ReplyAsync($”I do not know your location to give you the weather. You can try `@abbot my location is {{zip|city}}` to tell me your location. Also try `{Bot} help weather` to learn everything the weather skill can do.”);<br /> return;<br /> }<br /> await AddWeatherSubscription(zipOrCity, country, isZip, hasCountry);<br /> }</p> <p>async Task HandleUnsubscribe(IArguments args) {<br /> var (zipOrCity, _, __, parsedFromLocation, ___, success) = await ParseLocation(args);<br /> if (!success || parsedFromLocation) {<br /> await Bot.ReplyAsync($”I do not know what location to stop watching.”);<br /> return;<br /> }<br /> await RemoveWeatherSubscription(zipOrCity);<br /> }</p> <p>async Task HandleOther(IArguments args) {<br /> var (cmd, rest) = args;<br /> var (zipOrCity, country, isZip, _, hasCountry, success) = await ParseLocation(args);</p> <p> if (cmd is IMissingArgument) {<br /> if (!success) {<br /> await Bot.ReplyAsync($”I do not know your location to give you the weather. You can try `@abbot my location is {{zip|city}}` to tell me your location. Also try `{Bot} help weather` to learn everything the weather skill can do.”);<br /> return;<br /> }<br /> var (_, unit) = GetUnits(country);<br /> var daily = await GetWeather(Bot.From.Location.Coordinate, country);<br /> await Bot.ReplyAsync($”{Bot.From.Location.FormattedAddress} – {GetWeatherDescription(daily, unit)}.\n\nRun `@abbot help weather` to learn everything the weather skill can do.”);<br /> } else {<br /> await ReportWeather(zipOrCity, country, isZip, hasCountry);<br /> }<br /> }</p> <p>async Task HandleSubs(IArguments args) {<br /> var (subcmd, subargs) = args.Pop();</p> <p> switch (subcmd) {<br /> case “migrate”: {<br /> var items = await Bot.Brain.GetAllAsync();<br /> var subscriptions = new List<WeatherSubscription>();<br /> var keys = new List<string>();<br /> foreach (var item in items) {<br /> var z = (WeatherSubscription)item.Value;<br /> // migrating old subscription data<br /> if (z.Version == 0) {<br /> z.Country = “US”;<br /> (z.Units, z.Unit) = GetUnits(z.Country);<br /> z.Version++;<br /> }<br /> subscriptions.Add(z);<br /> keys.Add(item.Key);<br /> }<br /> for (var i = 0; i < keys.Count; i++) {<br /> await Bot.Brain.DeleteAsync(keys[i]);<br /> await Bot.Brain.WriteAsync(subscriptions[i].Zip, subscriptions[i]);<br /> }<br /> await Bot.ReplyAsync(“Migration done”);<br /> }<br /> break;<br /> case “list”:<br /> default: {<br /> var reply = new System.Text.StringBuilder();<br /> reply.AppendLine(“I’m tracking the following locations:”);<br /> reply.AppendLine();<br /> var items = await Bot.Brain.GetAllAsync();<br /> foreach (var item in items) {<br /> reply.AppendLine($”* {item.Key}”);<br /> }<br /> await Bot.ReplyAsync(reply.ToString());<br /> }<br /> break;<br /> }<br /> }</p> <p>// =============== Weather stuff ======================</p> <p>const string zipUSRegex = @”^\d{5}(?:[-\s]\d{4})?$”;</p> <p>public class WeatherSubscription {<br /> public string Name { get; set; }<br /> public string Zip { get; set; }<br /> public string Lat { get; set; }<br /> public string Lon { get; set; }<br /> public string Country { get; set; }<br /> public string Units { get; set; }<br /> public string Unit { get; set; }<br /> public string AddedBy { get; set; }<br /> public DateTime AddedAt { get; set; }<br /> public int Version { get; set; }<br /> }</p> <p>const string weatherEndpoint = “https://link.ab.bot/api/HFYFbHt2W6tLQ2v_23qvWCBg”;<br /> const string oneCallEndpoint = “https://link.ab.bot/api/sqRQB5M426T4W2HS8RVZ6NV1”;</p> <p>(string, string) GetUnits(string country) {<br /> var units = country.ToUpper() == “US” || country.ToUpper() == “USA” ? “imperial” : “metric”;<br /> var unit = units == “imperial” ? “F” : “C”;<br /> return (units, unit);<br /> }</p> <p>string GetEndpoint(string zipOrCity, string country, string units, bool isZip, bool hasCountry) =><br /> $”{weatherEndpoint}?{(isZip ? “zip” : “q”)}={zipOrCity}{(hasCountry || isZip ? “,”+country : “”)}&units={units}”;</p> <p>async Task ReportWeather(string zipOrCity, string country, bool isZip, bool hasCountry) {<br /> var (units, unit) = GetUnits(country);<br /> var endpoint = GetEndpoint(zipOrCity, country, units, isZip, hasCountry);</p> <p> try {<br /> var results = await Bot.Http.GetJsonAsync(endpoint);</p> <p> var response = $”The weather in {results.name} ({results.sys.country}) is currently {results.main.temp}{unit}. \n”;<br /> response += $”({results.weather[0].main}, feels like {results.main.feels_like}{unit})”;</p> <p> await Bot.ReplyAsync(response);<br /> } catch {<br /> await Bot.ReplyAsync(“Could not find a result for ” + zipOrCity);<br /> }<br /> }</p> <p>async Task<string> CheckWeather(WeatherSubscription sub) {<br /> try {<br /> var daily = await GetWeather(sub.Lat, sub.Lon, sub.Country);<br /> return $”* {sub.Name} ({sub.Zip}) – {GetWeatherDescription(daily, sub.Unit)}”;<br /> } catch {<br /> return $”There was a problem getting the weather report for {sub.Name} ({sub.Zip})”;<br /> }<br /> }</p> <p>async Task AddWeatherSubscription(string zipOrCity, string country, bool isZip, bool hasCountry) {<br /> var (units, unit) = GetUnits(country);<br /> // Need to get the lat/lng of the zipcode to get info from the right endpoint<br /> var endpoint = GetEndpoint(zipOrCity, country, units, isZip, hasCountry);</p> <p> try {<br /> var results = await Bot.Http.GetJsonAsync(endpoint);<br /> country = results.sys.country;<br /> var subscription = new WeatherSubscription{<br /> Name = $”{results.name}, {country}”,<br /> Zip = zipOrCity,<br /> Lat = results.coord.lat,<br /> Lon = results.coord.lon,<br /> Country = country,<br /> Units = units,<br /> Unit = unit,<br /> AddedBy = Bot.From.Id,<br /> AddedAt = DateTime.UtcNow,<br /> Version = VERSION<br /> };</p> <p> await Bot.Brain.WriteAsync(subscription.Zip.ToLower(), subscription);<br /> await Bot.ReplyAsync($”Adding a weather subscription for {zipOrCity},{country}”);<br /> } catch (HttpRequestException){<br /> await Bot.ReplyAsync($”The location you provided ({zipOrCity}) could not be found.”);<br /> } catch (Exception e) {<br /> await Bot.ReplyAsync($”There was an unspecified error subscribing to {zipOrCity} {e.Message}.”);<br /> }<br /> }</p> <p>async Task<dynamic> GetWeather(string lat, string lon, string country){<br /> var (units, _) = GetUnits(country);<br /> var endpoint = $”{oneCallEndpoint}?lat={lat}&lon={lon}&units={units}”;<br /> dynamic results = await Bot.Http.GetJsonAsync(endpoint);<br /> return results.daily[0];<br /> }</p> <p>Task<dynamic> GetWeather(ICoordinate coordinate, string country) {<br /> var (lat, lon) = coordinate;<br /> return GetWeather(lat.ToString(), lon.ToString(), country);<br /> }</p> <p>async Task RemoveWeatherSubscription(string zipOrCity) {<br /> if ((await Bot.Brain.GetAsync(zipOrCity)) != null) {<br /> await Bot.Brain.DeleteAsync(zipOrCity);<br /> await Bot.ReplyAsync($”Removed a weather subscription for {zipOrCity}”);<br /> } else {<br /> await Bot.ReplyAsync($”Hmmm, there isn’t a weather subscription for {zipOrCity}”);<br /> }<br /> }</p> <p>async Task CheckSubscriptions() {<br /> var items = await Bot.Brain.GetAllAsync();<br /> var report = “Here’s your weather report: “;</p> <p> foreach (var item in items) {<br /> var z = (WeatherSubscription)item.Value;<br /> // migrating old subscription data<br /> if (z.Version == 0) {<br /> z.Country = “US”;<br /> (z.Units, z.Unit) = GetUnits(z.Country);<br /> z.Version++;<br /> }<br /> report += “\n” + await CheckWeather(z);<br /> }</p> <p> await Bot.ReplyAsync(report);<br /> }</p> <p>string GetWeatherDescription(dynamic daily, string unit) {<br /> return $”High: {daily.temp.max}{unit} / Low: {daily.temp.min}{unit} with {daily.weather[0].description}”;<br /> }