create a new separate orgdata-code package, ready to be moved to a separate package

Author: hoxhaeris

pkg/orgdata-core/README.md

@@ -0,0 +1,59 @@
+# Organizational Data Core Package
+
+This package provides the core functionality for accessing and querying organizational data in a performant, indexed manner.
+
+## Overview
+
+The `orgdatacore` package is designed to be a reusable component that can be consumed by multiple services including:
+- Slack bots (ci-chat-bot)
+- REST APIs
+- CLI tools
+- Other organizational data consumers
+
+## Features
+
+- **Fast Data Access**: Pre-computed indexes enable O(1) lookups for common queries
+- **Thread-Safe**: Concurrent access with read-write mutex protection
+- **Hot Reload**: Support for dynamic data updates without service restart
+- **Flexible Data Sources**: Load from multiple JSON files with automatic merging
+- **Comprehensive Queries**: Employee, team, and organization lookups with membership validation
+
+## Usage
+
+### Basic Setup
+
+```go
+package main
+
+import (
+    "github.com/openshift/ci-chat-bot/pkg/orgdata-core"
+)
+
+func main() {
+    // Create a new service
+    service := orgdatacore.NewService()
+    
+    // Load data from JSON files
+    err := service.LoadFromFiles([]string{"comprehensive_index_dump.json"})
+    if err != nil {
+        log.Fatal(err)
+    }
+}
+```
+
+## Data Structure
+
+The package expects data in the `comprehensive_index_dump.json` format generated by the Python `orglib` indexing system.
+
+## Interface
+
+The package implements the `ServiceInterface` which provides comprehensive organizational data access methods.
+
+## Thread Safety
+
+All public methods are thread-safe and can be called concurrently from multiple goroutines.
+
+## Dependencies
+
+- Go 1.19+
+- Standard library only (no external dependencies)

pkg/orgdata-core/example/main.go

@@ -0,0 +1,45 @@
+package main
+
+import (
+	"fmt"
+	"log"
+
+	"github.com/openshift/ci-chat-bot/pkg/orgdata-core"
+)
+
+func main() {
+	// Create a new service
+	service := orgdatacore.NewService()
+
+	fmt.Println("✅ Created new organizational data service")
+
+	// Load data from JSON files
+	err := service.LoadFromFiles([]string{"../../test-data/comprehensive_index_dump.json"})
+	if err != nil {
+		log.Printf("    Could not load test data: %v", err)
+		log.Println("   This is expected if test data is not available")
+		log.Println("   The service is still functional for demonstration")
+	} else {
+		fmt.Println("✅ Loaded organizational data")
+
+		// Get version info
+		version := service.GetVersion()
+		fmt.Printf("📊 Data version: %d employees, %d orgs\n",
+			version.EmployeeCount, version.OrgCount)
+
+		// Example queries (these will work if test data is loaded)
+		if emp := service.GetEmployeeBySlackID("USE4Y4UG5"); emp != nil {
+			fmt.Printf("👤 Found employee: %s (%s)\n", emp.FullName, emp.JobTitle)
+		}
+
+		teams := service.GetTeamsForSlackID("USE4Y4UG5")
+		if len(teams) > 0 {
+			fmt.Printf("🏢 User is member of teams: %v\n", teams)
+		}
+	}
+
+	fmt.Println("\nCore package is ready for use!")
+	fmt.Println("   - Import: github.com/openshift/ci-chat-bot/pkg/orgdata-core")
+	fmt.Println("   - Interface: orgdatacore.ServiceInterface")
+	fmt.Println("   - Implementation: orgdatacore.Service")
+}

pkg/orgdata-core/interface.go

@@ -0,0 +1,40 @@
+package orgdatacore
+
+import "context"
+
+// ServiceInterface defines the core interface for organizational data services
+type ServiceInterface interface {
+
+	// Core data access methods
+
+	GetEmployeeByUID(uid string) *Employee
+	GetEmployeeBySlackID(slackID string) *Employee
+	GetTeamByName(teamName string) *Team
+	GetOrgByName(orgName string) *Org
+
+	// Membership queries
+
+	GetTeamsForUID(uid string) []string
+	GetTeamsForSlackID(slackID string) []string
+	GetTeamMembers(teamName string) []Employee
+	IsEmployeeInTeam(uid string, teamName string) bool
+	IsSlackUserInTeam(slackID string, teamName string) bool
+
+	// Organization queries
+
+	IsEmployeeInOrg(uid string, orgName string) bool
+	IsSlackUserInOrg(slackID string, orgName string) bool
+	GetUserOrganizations(slackUserID string) []OrgInfo
+
+	// Data management
+
+	GetVersion() DataVersion
+	LoadFromFiles(filePaths []string) error
+	StartConfigMapWatcher(ctx context.Context, configMapPaths []string)
+}
+
+// OrgInfo represents organization information for a user
+type OrgInfo struct {
+	Name string `json:"name"`
+	Type string `json:"type"`
+}