From c91c3afd8700138f8eb8a25a4ae422c2c9e46cea Mon Sep 17 00:00:00 2001 From: alex Date: Tue, 28 Jul 2026 17:37:06 +0200 Subject: refactored entire code base to be in the package core so i can later implement interfaces to interact with the engine --- ingest/ingest.go | 48 ------------------------------------------------ 1 file changed, 48 deletions(-) delete mode 100644 ingest/ingest.go (limited to 'ingest') diff --git a/ingest/ingest.go b/ingest/ingest.go deleted file mode 100644 index bffc417..0000000 --- a/ingest/ingest.go +++ /dev/null @@ -1,48 +0,0 @@ -package ingest - -import ( - "encoding/xml" - "io" - "os" -) - -type Page struct { - Title string `xml:"title"` - Text string `xml:"revision>text"` - Id int `xml:"id"` -} - -func IngestWikiDump(filePath string, jobQueue chan<- Page) error { - file, err := os.Open(filePath) - if err != nil { - return err - } - defer file.Close() - - // 3. Attach the streaming XML decoder - decoder := xml.NewDecoder(file) - - for { - t, err := decoder.Token() - if err == io.EOF { - break - } - if err != nil { - return err - } - - // Look for the opening tag - switch se := t.(type) { - case xml.StartElement: - if se.Name.Local == "page" { - var p Page - // Decode the entire page element into the struct - if err := decoder.DecodeElement(&p, &se); err == nil { - // Push to your worker pool channel - jobQueue <- p - } - } - } - } - return nil -} -- cgit v1.2.3