using Disco.Plugins.ServiceTracker.Models; using System; using System.Collections.Generic; using System.IO; using System.Net; using System.Text; namespace Disco.Plugins.ServiceTracker.Services { public class GoogleSheetService { private readonly GoogleSheetConfig _config; private readonly string _cachePath; public GoogleSheetService(GoogleSheetConfig config, string dataDirectory) { _config = config; _cachePath = Path.Combine(dataDirectory, "sheet_cache.csv"); } public GoogleSheetResult FetchTickets() { var result = new GoogleSheetResult(); if (!_config.Enabled || string.IsNullOrEmpty(_config.SpreadsheetId)) { result.Error = "Google Sheet integration is disabled."; return result; } string csvData = null; if (File.Exists(_cachePath)) { var cacheAge = DateTime.Now - File.GetLastWriteTime(_cachePath); if (cacheAge.TotalMinutes < _config.RefreshMinutes) csvData = File.ReadAllText(_cachePath); } if (csvData == null) { try { string url; var id = _config.SpreadsheetId.Trim(); if (id.StartsWith("2PACX", StringComparison.OrdinalIgnoreCase)) url = "https://docs.google.com/spreadsheets/d/e/" + id + "/pub?output=csv&gid=" + _config.GId; else url = "https://docs.google.com/spreadsheets/d/" + id + "/export?format=csv&gid=" + _config.GId; using (var client = new WebClient()) { client.Encoding = Encoding.UTF8; client.Headers.Add("User-Agent", "Mozilla/5.0 DiscoServiceTracker/1.0"); csvData = client.DownloadString(url); } if (csvData != null && csvData.TrimStart().StartsWith(" ParseCsv(string csvData) { var tickets = new List(); var lines = csvData.Split(new[] { '\n' }, StringSplitOptions.RemoveEmptyEntries); var usedIds = new HashSet(); for (int i = _config.HeaderRows; i < lines.Length; i++) { var fields = ParseCsvLine(lines[i]); if (fields.Count == 0) continue; bool allEmpty = true; for (int j = 0; j < fields.Count; j++) if (!string.IsNullOrWhiteSpace(fields[j])) { allEmpty = false; break; } if (allEmpty) continue; var taskTitle = SafeGet(fields, _config.ColTask); var issueDesc = SafeGet(fields, _config.ColIssue); var requestedBy = SafeGet(fields, _config.ColRequestedBy); var email = SafeGet(fields, _config.ColEmail); var timestamp = SafeGetDate(fields, _config.ColTimestamp); var ticket = new ExternalTicket { Source = "ntt", Timestamp = timestamp, RequesterEmail = email, RequesterName = requestedBy, TaskTitle = taskTitle, DeviceName = taskTitle, Location = SafeGet(fields, _config.ColLocation), IssueDescription = issueDesc ?? taskTitle, RawPriority = SafeGet(fields, _config.ColPriority), RawStatus = SafeGet(fields, _config.ColStatus), AssignedTo = SafeGet(fields, _config.ColAssignedTo), PreferredDate = SafeGetDateNullable(fields, _config.ColPreferredDate), SheetNotes = SafeGet(fields, _config.ColNotes) }; // Generate STABLE IDs from content - same row always gets same ID var stableHash = GenerateStableHash(timestamp, email, taskTitle); ticket.InternalId = StableIdFromHash(stableHash, usedIds); ticket.ExternalId = "NTT" + ticket.InternalId.ToString(); usedIds.Add(ticket.InternalId); var status = (ticket.RawStatus ?? "").ToLower().Trim(); ticket.IsOpen = status != "completed" && status != "closed" && status != "resolved" && status != "done" && status != "cancelled"; if (ticket.IsOpen && (!string.IsNullOrWhiteSpace(taskTitle) || !string.IsNullOrWhiteSpace(issueDesc))) tickets.Add(ticket); } return tickets; } /// /// Generates a deterministic hash from the row's key fields. /// Same timestamp + email + task always produces the same number. /// private int GenerateStableHash(DateTime timestamp, string email, string task) { var key = timestamp.ToString("yyyyMMddHHmmss") + "|" + (email ?? "").ToLower().Trim() + "|" + (task ?? "").ToLower().Trim(); // Use a simple but stable hash (DJB2-like) uint hash = 5381; for (int i = 0; i < key.Length; i++) hash = ((hash << 5) + hash) + (uint)key[i]; return (int)(hash % 800000) + 100000; // Range: 100000-899999 } /// /// Returns the hash as an ID, resolving collisions by incrementing. /// private int StableIdFromHash(int baseId, HashSet used) { int id = baseId; while (used.Contains(id)) id++; return id; } public static string MapPriority(string raw) { if (string.IsNullOrEmpty(raw)) return "medium"; var lower = raw.ToLower().Trim(); if (lower.Contains("urgent") || lower.Contains("same day") || lower.Contains("critical")) return "critical"; if (lower.Contains("high") || lower.Contains("1-2 day")) return "high"; if (lower.Contains("medium") || lower.Contains("3-5 day")) return "medium"; if (lower.Contains("low") || lower.Contains("1 week") || lower.Contains("week+")) return "low"; if (lower.Contains("scheduled") || lower.Contains("planned")) return "scheduled"; // Emoji fallback if (raw.Contains("\U0001F534")) return "critical"; if (raw.Contains("\U0001F7E0")) return "high"; if (raw.Contains("\U0001F7E1")) return "medium"; if (raw.Contains("\U0001F7E2")) return "low"; return "medium"; } private string SafeGet(List fields, int index) { if (index < 0 || index >= fields.Count) return null; var val = fields[index].Trim(); return string.IsNullOrEmpty(val) ? null : val; } private DateTime SafeGetDate(List fields, int index) { var val = SafeGet(fields, index); if (val == null) return DateTime.Now; DateTime dt; if (DateTime.TryParse(val, out dt)) return dt; return DateTime.Now; } private DateTime? SafeGetDateNullable(List fields, int index) { var val = SafeGet(fields, index); if (val == null) return null; DateTime dt; if (DateTime.TryParse(val, out dt)) return dt; return null; } private List ParseCsvLine(string line) { var fields = new List(); bool inQuotes = false; var current = new StringBuilder(); for (int i = 0; i < line.Length; i++) { char c = line[i]; if (c == '"') { if (inQuotes && i + 1 < line.Length && line[i + 1] == '"') { current.Append('"'); i++; } else inQuotes = !inQuotes; } else if (c == ',' && !inQuotes) { fields.Add(current.ToString()); current.Clear(); } else if (c != '\r') current.Append(c); } fields.Add(current.ToString()); return fields; } } public class GoogleSheetResult { public List Tickets { get; set; } public string Error { get; set; } public string Warning { get; set; } public GoogleSheetResult() { Tickets = new List(); } } }