// Copyright 2018 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package cache import ( "context" "go/ast" "go/token" "io/ioutil" "path/filepath" "strings" "golang.org/x/tools/internal/lsp/source" "golang.org/x/tools/internal/span" ) // viewFile extends source.File with helper methods for the view package. type viewFile interface { source.File setContent(content []byte) filename() string addURI(uri span.URI) int isActive() bool } // fileBase holds the common functionality for all files. // It is intended to be embedded in the file implementations type fileBase struct { uris []span.URI fname string view *view active bool content []byte token *token.File } // goFile holds all the information we know about a go file. type goFile struct { fileBase ast *ast.File pkg *pkg meta *metadata imports []*ast.ImportSpec } func basename(filename string) string { return strings.ToLower(filepath.Base(filename)) } func (f *fileBase) URI() span.URI { return f.uris[0] } func (f *fileBase) filename() string { return f.fname } func (f *fileBase) isActive() bool { return f.active } // View returns the view associated with the file. func (f *fileBase) View() source.View { return f.view } // GetContent returns the contents of the file, reading it from file system if needed. func (f *fileBase) GetContent(ctx context.Context) []byte { f.view.mu.Lock() defer f.view.mu.Unlock() if ctx.Err() == nil { f.read(ctx) } return f.content } func (f *fileBase) GetFileSet(ctx context.Context) *token.FileSet { return f.view.config.Fset } func (f *goFile) GetToken(ctx context.Context) *token.File { f.view.mu.Lock() defer f.view.mu.Unlock() if f.token == nil || len(f.view.contentChanges) > 0 { if _, err := f.view.parse(ctx, f); err != nil { return nil } } return f.token } func (f *goFile) GetAST(ctx context.Context) *ast.File { f.view.mu.Lock() defer f.view.mu.Unlock() if f.ast == nil || len(f.view.contentChanges) > 0 { if _, err := f.view.parse(ctx, f); err != nil { return nil } } return f.ast } func (f *goFile) GetPackage(ctx context.Context) source.Package { f.view.mu.Lock() defer f.view.mu.Unlock() if f.pkg == nil || len(f.view.contentChanges) > 0 { if errs, err := f.view.parse(ctx, f); err != nil { // Create diagnostics for errors if we are able to. if len(errs) > 0 { return &pkg{errors: errs} } return nil } } return f.pkg } // read is the internal part of GetContent. It assumes that the caller is // holding the mutex of the file's view. func (f *fileBase) read(ctx context.Context) { if f.content != nil { if len(f.view.contentChanges) == 0 { return } f.view.mcache.mu.Lock() err := f.view.applyContentChanges(ctx) f.view.mcache.mu.Unlock() if err == nil { return } } // We might have the content saved in an overlay. if content, ok := f.view.config.Overlay[f.filename()]; ok { f.content = content return } // We don't know the content yet, so read it. content, err := ioutil.ReadFile(f.filename()) if err != nil { f.view.Session().Logger().Errorf(ctx, "unable to read file %s: %v", f.filename(), err) return } f.content = content } // isPopulated returns true if all of the computed fields of the file are set. func (f *goFile) isPopulated() bool { return f.ast != nil && f.token != nil && f.pkg != nil && f.meta != nil && f.imports != nil } func (f *goFile) GetActiveReverseDeps(ctx context.Context) []source.GoFile { pkg := f.GetPackage(ctx) if pkg == nil { return nil } f.view.mu.Lock() defer f.view.mu.Unlock() f.view.mcache.mu.Lock() defer f.view.mcache.mu.Unlock() seen := make(map[string]struct{}) // visited packages results := make(map[*goFile]struct{}) f.view.reverseDeps(ctx, seen, results, pkg.PkgPath()) var files []source.GoFile for rd := range results { if rd == nil { continue } // Don't return any of the active files in this package. if rd.pkg != nil && rd.pkg == pkg { continue } files = append(files, rd) } return files } func (v *view) reverseDeps(ctx context.Context, seen map[string]struct{}, results map[*goFile]struct{}, pkgPath string) { if _, ok := seen[pkgPath]; ok { return } seen[pkgPath] = struct{}{} m, ok := v.mcache.packages[pkgPath] if !ok { return } for _, filename := range m.files { if f, err := v.getFile(span.FileURI(filename)); err == nil && f.isActive() { results[f.(*goFile)] = struct{}{} } } for parentPkgPath := range m.parents { v.reverseDeps(ctx, seen, results, parentPkgPath) } }