1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
package main
import (
"context"
"flag"
"fmt"
"log/slog"
"os"
"strings"
"github.com/jpappel/atlas/pkg/data"
"github.com/jpappel/atlas/pkg/index"
)
type IndexFlags struct {
Filters []index.DocFilter
Subcommand string
index.ParseOpts
}
func setupIndexFlags(args []string, fs *flag.FlagSet, flags *IndexFlags) {
fs.BoolVar(&flags.IgnoreDateError, "ignoreBadDates", false, "ignore malformed dates while indexing")
fs.BoolVar(&flags.IgnoreMetaError, "ignoreMetaError", false, "ignore errors while parsing general YAML header info")
fs.BoolVar(&flags.ParseMeta, "parseMeta", true, "parse YAML header values other title, authors, date, tags")
fs.BoolVar(&flags.ParseLinks, "parseLinks", true, "parse file contents for links")
fs.Usage = func() {
f := fs.Output()
fmt.Fprintf(f, "Usage of %s %s\n", os.Args[0], fs.Name())
fmt.Fprintf(f, "\t%s [global-flags] %s [index-flags] <subcommand>\n\n", os.Args[0], fs.Name())
fmt.Fprintln(f, "Subcommands:")
fmt.Fprintln(f, "build - create a new index")
fmt.Fprintln(f, "update - update an existing index")
fmt.Fprintln(f, "tidy - cleanup an index")
fmt.Fprintln(f, "\nIndex Flags:")
fs.PrintDefaults()
fmt.Fprintln(f, "\nGlobal Flags:")
flag.PrintDefaults()
}
customFilters := false
flags.Filters = index.DefaultFilters()
fs.Func("filter",
"accept or reject files from indexing, applied in supplied order"+
"\n(default Ext_.md, MaxSize_204800, YAMLHeader, ExcludeParent_templates)\n"+
index.FilterHelp,
func(s string) error {
if !customFilters {
flags.Filters = flags.Filters[:0]
}
filter, err := index.ParseFilter(s)
if err != nil {
return err
}
flags.Filters = append(flags.Filters, filter)
return nil
})
fs.Parse(args)
remainingArgs := fs.Args()
if len(remainingArgs) == 0 {
flags.Subcommand = "build"
} else if len(remainingArgs) == 1 {
flags.Subcommand = remainingArgs[0]
}
}
func runIndex(gFlags GlobalFlags, iFlags IndexFlags, db *data.Query) byte {
switch iFlags.Subcommand {
case "build", "update":
idx := index.Index{Root: gFlags.IndexRoot, Filters: iFlags.Filters}
if slog.Default().Enabled(context.Background(), slog.LevelDebug) {
filterNames := make([]string, 0, len(iFlags.Filters))
for _, filter := range iFlags.Filters {
filterNames = append(filterNames, filter.Name)
}
slog.Default().Debug("index",
slog.String("indexRoot", gFlags.IndexRoot),
slog.String("filters", strings.Join(filterNames, ", ")),
)
}
traversedFiles := idx.Traverse(gFlags.NumWorkers)
fmt.Print("Crawled ", len(traversedFiles))
filteredFiles := idx.Filter(traversedFiles, gFlags.NumWorkers)
fmt.Print(", Filtered ", len(filteredFiles))
idx.Documents = index.ParseDocs(filteredFiles, gFlags.NumWorkers, iFlags.ParseOpts)
fmt.Print(", Parsed ", len(idx.Documents), "\n")
var err error
// switch in order to appease gopls...
switch iFlags.Subcommand {
case "index":
err = db.Put(idx)
case "update":
err = db.Update(idx)
}
if err != nil {
fmt.Fprintln(os.Stderr, err)
return 1
}
case "tidy":
if err := db.Tidy(); err != nil {
fmt.Fprintln(os.Stderr, "Error while tidying:", err)
return 1
}
default:
fmt.Fprintln(os.Stderr, "Unrecognised index subcommands: ", iFlags.Subcommand)
return 2
}
return 0
}
|
