Skip to content
go-libfossil Artifact [b288992440]
Login

Artifact [b288992440]

Check-ins Using Download Hex

Artifact b288992440a2099af21db48aa93d3addc9d87da1934ff6c98e7b923dc432be39:

package content

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"strings"

	"github.com/danmestas/go-libfossil/db"
	"github.com/danmestas/go-libfossil/internal/deck"
	libfossil "github.com/danmestas/go-libfossil/internal/fsltype"
)

// nonArtifactTable is the crosslinker's record (internal/manifest) of blobs
// it expanded and found to be no artifact: either their bytes do not parse,
// or they parse as a card deck an artifact's required cards do not fit. A
// sub-manifest is the second kind, so the record alone does not prove a
// blob is file content; mlink naming it as a file version as well does.
const nonArtifactTable = "crosslink_nonartifact_v2"

// seenSubmanifestSetting is manifest.SeenSubmanifestSetting, set once any
// S-bearing artifact or sub-manifest has been parsed in this repository.
// The crosslinker records no tree, so with it set no check-in is answered
// from the tables.
const seenSubmanifestSetting = "seen-submanifest"

// linkedCheckin is a check-in the crosslinker linked completely: it has an
// event row, no orphan row, and a primary parent edge, so its mlink rows
// are the file transitions from that parent, and its plink, cherrypick and
// tagxref rows are its P, B, Q and T references.
type linkedCheckin struct {
	primary  libfossil.FslID
	baseline libfossil.FslID // 0 for a baseline manifest
}

// referenceTables are the crosslink facts that spare classification from
// reading file content and most manifests.
type referenceTables struct {
	files  map[libfossil.FslID]bool // Examined, no artifact, named by mlink.
	linked map[libfossil.FslID]linkedCheckin
	// present is whether the store has the non-artifact record, and trees
	// whether it has seen a tree, which makes it answer nothing.
	present, trees bool
}

const linkedCheckinSQL = `SELECT e.objid, p.pid, coalesce(p.baseid,0)
	FROM event e JOIN blob b ON b.rid=e.objid AND b.size>=0
	JOIN plink p ON p.cid=e.objid AND p.isprim
	WHERE e.type='ci' AND NOT EXISTS(SELECT 1 FROM orphan o WHERE o.rid=e.objid)`

func loadReferenceTables(ctx context.Context, q db.Querier) (*referenceTables, error) {
	return loadReferenceTablesFor(ctx, q, "")
}

// loadReferenceTablesFor is loadReferenceTables for the rids of the JSON
// array ids alone, or for every rid when ids is empty.
func loadReferenceTablesFor(ctx context.Context, q db.Querier, ids string) (*referenceTables, error) {
	t := &referenceTables{
		files: map[libfossil.FslID]bool{}, linked: map[libfossil.FslID]linkedCheckin{},
	}
	if err := q.QueryRow(`SELECT EXISTS(SELECT 1 FROM sqlite_master
		WHERE type='table' AND name=?), EXISTS(SELECT 1 FROM config WHERE name=?)`,
		nonArtifactTable, seenSubmanifestSetting).Scan(&t.present, &t.trees); err != nil {
		return nil, fmt.Errorf("sparse preparation: %s: %w", nonArtifactTable, err)
	}
	if err := t.loadFiles(ctx, q, ids); err != nil {
		return nil, err
	}
	if t.trees {
		return t, nil
	}
	duplicate := map[libfossil.FslID]bool{}
	query, args := restrictTo(linkedCheckinSQL+"%s", "e.objid", ids)
	err := referenceRows(ctx, q, query, func(scan func(...any) error) error {
		var rid libfossil.FslID
		var c linkedCheckin
		err := scan(&rid, &c.primary, &c.baseline)
		if _, seen := t.linked[rid]; seen {
			duplicate[rid] = true // Two primary parents: not a transition to trust.
		}
		t.linked[rid] = c
		return err
	}, args...)
	for rid := range duplicate {
		delete(t.linked, rid)
	}
	return t, err
}

// loadFiles reads the file versions the tables prove (fileVersionsSQL). A
// store this library crosslinked records each blob it found to be no
// artifact; one fossil crosslinked does not, and there every file version
// was read instead, past the byte budget on a real repository
// (fossil-scm.org's classification failed outright). So a version mlink
// names and no table an artifact's crosslink writes claims is taken as file
// content too, as the cone walk takes it (knownFile), without reading it.
//
// That is a decision, not a proof. Fossil links every blob it receives or
// rebuilds that parses as an artifact, so in a store it wrote a file whose
// bytes are an artifact is claimed and read as one. A blob nothing has
// linked as an artifact is the file mlink says it is, and goes where its
// name puts it: out of the cone it is elided, which no client of the cone
// misses, since none expects it. Its bytes go unread, so a corrupt version
// outside the cone is elided too, where reading it would retain it as
// unreadable; one inside the cone is sent by the walk and fails there. A
// memo follows the claim tables (claimRows). A store that has seen a tree
// proves nothing this way, since nothing claims its nodes.
func (t *referenceTables) loadFiles(ctx context.Context, q db.Querier, ids string) error {
	query, err := fileVersionsSQL(q, t.present, t.trees, false)
	if err != nil || query == "" {
		return err
	}
	var args []any
	if ids != "" {
		query, args = query+" WHERE r IN (SELECT value FROM json_each(?1))", []any{ids}
	}
	return referenceRows(ctx, q, query, func(scan func(...any) error) error {
		var rid libfossil.FslID
		err := scan(&rid)
		t.files[rid] = true
		return err
	}, args...)
}

// fileVersionsSQL selects, as column r, the file versions the tables prove:
// those the non-artifact record holds that mlink names, and, but in a store
// that has seen a tree, those mlink names that no claim table names. The
// two agree wherever the record is complete; taking both keeps a record a
// push started in a store fossil wrote, which names only what arrived, from
// sending every older version back to be read. byMids restricts the mlink
// rows to the check-ins of the JSON array ?1. Empty when nothing is proved.
func fileVersionsSQL(q db.Querier, present, trees, byMids bool) (string, error) {
	named := func(col string) string {
		where := " WHERE " + col + ">0"
		if byMids {
			where += " AND mid IN (SELECT value FROM json_each(?1))"
		}
		return "SELECT " + col + " FROM mlink" + where
	}
	var parts []string
	if present {
		parts = append(parts, "SELECT rid FROM "+nonArtifactTable+" WHERE rid IN ("+
			named("fid")+" UNION "+named("pid")+")")
	}
	if !trees {
		claims, err := artifactClaims(q)
		if err != nil {
			return "", err
		}
		parts = append(parts, "SELECT * FROM ("+named("fid")+" UNION "+named("pid")+claims+")")
	}
	if len(parts) == 0 {
		return "", nil
	}
	return "WITH f(r) AS (" + strings.Join(parts, " UNION ") + ") SELECT r FROM f", nil
}

// artifactTables are the rows an artifact's crosslink writes, by table and
// the column naming the artifact: check-ins and every event-bearing
// artifact, control artifacts and clusters, attachments, forum posts and
// ticket changes.
var artifactTables = []struct{ table, column, where string }{
	{"event", "objid", ""},
	{"plink", "cid", ""},
	{"tagxref", "srcid", ""},
	{"tagxref", "rid", "tagid=7"},
	{"attachment", "attachid", ""},
	{"forumpost", "fpid", ""},
	{"ticketchng", "tkt_rid", ""},
}

// artifactClaims is an EXCEPT clause per artifactTables row whose table the
// store has; a table it lacks claims nothing.
func artifactClaims(q db.Querier) (string, error) {
	var b strings.Builder
	for _, a := range artifactTables {
		exists, err := tableExists(q, a.table)
		if err != nil {
			return "", err
		}
		if !exists {
			continue
		}
		b.WriteString(" EXCEPT SELECT " + a.column + " FROM " + a.table)
		if a.where != "" {
			b.WriteString(" WHERE " + a.where)
		}
	}
	return b.String(), nil
}

// claimRows counts the rids at or below top and outside the JSON array
// except that a claim table names. File versions follow these claims
// (fileVersionsSQL), which a sweep linking an artifact late adds without
// adding a blob, so a memo holds only while the count does. It counts rids,
// not rows: a check-in's tags propagate as rows naming an older source, or
// none (srcid 0).
func claimRows(q db.Querier, top libfossil.FslID, except string) (int64, error) {
	var parts []string
	for _, a := range artifactTables {
		exists, err := tableExists(q, a.table)
		if err != nil {
			return 0, err
		}
		if !exists {
			continue
		}
		part := "SELECT " + a.column + " FROM " + a.table + " WHERE " + a.column + " BETWEEN 1 AND ?1 AND " +
			a.column + " NOT IN (SELECT value FROM json_each(?2))"
		if a.where != "" {
			part += " AND " + a.where
		}
		parts = append(parts, part)
	}
	if len(parts) == 0 {
		return 0, nil
	}
	var n int64
	if err := q.QueryRow("SELECT count(*) FROM ("+strings.Join(parts, " UNION ")+")", top, except).Scan(&n); err != nil {
		return 0, fmt.Errorf("sparse preparation: claims: %w", err)
	}
	return n, nil
}

func tableExists(q db.Querier, name string) (bool, error) {
	var exists bool
	err := q.QueryRow("SELECT EXISTS(SELECT 1 FROM sqlite_master WHERE type='table' AND name=?)", name).Scan(&exists)
	if err != nil {
		return false, fmt.Errorf("sparse preparation: %s: %w", name, err)
	}
	return exists, nil
}

// referenceRows scans every row of query; each row runs ctx's check first.
func referenceRows(
	ctx context.Context, q db.Querier, query string, row func(scan func(...any) error) error, args ...any,
) error {
	rows, err := q.Query(query, args...)
	if err != nil {
		return fmt.Errorf("sparse preparation: %w", err)
	}
	for rows.Next() {
		if err := ctx.Err(); err != nil {
			return errors.Join(err, rows.Close())
		}
		if err := row(rows.Scan); err != nil {
			return errors.Join(fmt.Errorf("sparse preparation: %w", err), rows.Close())
		}
	}
	return errors.Join(rows.Err(), rows.Close())
}

// answerable returns the linked check-ins whose raw F cards the tables can
// stand in for. mlink records a check-in's files only where they differ
// from its primary parent, and a delta manifest's only where its own cards
// say so; every other file of its tree is in the parent's tree or the
// baseline's. So the rows reproduce every F card exactly when both of those
// trees are themselves reproduced: by the tables, or by raw cards whose
// baseline chain is (covered). Trees (S cards) are not crosslinked, so a
// store that holds one answers nothing from the tables. Raw records come
// from the first round, which read everything the tables cannot answer.
func (t *referenceTables) answerable(facts *ConeReferenceFacts) map[libfossil.FslID]bool {
	raw := map[libfossil.FslID]string{} // A read check-in's B card.
	for _, record := range facts.records {
		if record.deck.Type == deck.Submanifest || len(record.deck.S) > 0 {
			return map[libfossil.FslID]bool{}
		}
		if record.deck.Type == deck.Checkin {
			raw[facts.held[record.uuid]] = record.deck.B
		}
	}
	rids := make(map[string]libfossil.FslID, len(t.linked)+len(raw))
	for rid := range t.linked {
		rids[facts.names[rid]] = rid
	}
	for rid := range raw {
		rids[facts.names[rid]] = rid
	}
	baseline := func(rid libfossil.FslID) (libfossil.FslID, bool) {
		if c, ok := t.linked[rid]; ok {
			return c.baseline, true
		}
		b, ok := raw[rid]
		if !ok || b == "" {
			return 0, ok
		}
		base, ok := rids[b]
		return base, ok
	}
	answer := map[libfossil.FslID]bool{}
	for rid, c := range t.linked {
		if covered(c.primary, baseline) && covered(rid, baseline) {
			answer[rid] = true
		}
	}
	return answer
}

// covered reports whether rid is a check-in whose whole tree is reproduced
// once its own cards are: a baseline manifest, or a delta manifest over a
// covered baseline. A baseline is a baseline manifest in every artifact the
// crosslinker accepts, so the chain is short; an unknown or overlong one is
// not covered.
func covered(rid libfossil.FslID, baseline func(libfossil.FslID) (libfossil.FslID, bool)) bool {
	for depth := 0; depth < coneReferenceDepth; depth++ {
		base, ok := baseline(rid)
		if !ok {
			return false
		}
		if base == 0 {
			return true
		}
		rid = base
	}
	return false
}

// linkedSpineSQL lists each linked check-in's references: P, B, Q targets
// and T targets. An absent parent or tag target still has a row, against a
// phantom, as an absent cherrypick target has none, exactly as the raw
// cards name it only by hash. Each query's %s is where the source column is
// restricted, or nothing.
var linkedSpineSQL = []struct{ query, src string }{
	{"SELECT cid, pid FROM plink%s", "cid"},
	{"SELECT cid, baseid FROM plink WHERE baseid IS NOT NULL%s", "cid"},
	{"SELECT childid, parentid FROM cherrypick%s", "childid"},
	{"SELECT srcid, rid FROM tagxref WHERE srcid>0%s", "srcid"},
}

// restrictTo spells query with src limited to the rids of the JSON array
// bound as ?1, or unrestricted when ids is empty, with the arguments that go
// with it.
func restrictTo(query, src, ids string) (string, []any) {
	if ids == "" {
		return fmt.Sprintf(query, ""), nil
	}
	join := " WHERE "
	if strings.Contains(query, " WHERE ") {
		join = " AND "
	}
	return fmt.Sprintf(query, join+src+" IN (SELECT value FROM json_each(?1))"), []any{ids}
}

// addLinked records for the linked check-ins what their raw cards would:
// each check-in itself, its references, and every (name, file) pair of its
// tree, from the mlink rows the induction in answerable relies on. only,
// when set, are the rids the tables are read for, a superset of linked; seen
// holds the pairs already recorded, and gains these.
func (facts *ConeReferenceFacts) addLinked(
	ctx context.Context, q db.Querier, linked map[libfossil.FslID]bool, only []libfossil.FslID,
	seen map[[2]int64]bool,
) error {
	if len(linked) == 0 {
		return nil
	}
	ids, err := ridsJSON(only)
	if err != nil {
		return err
	}
	for rid := range linked {
		facts.spine = append(facts.spine, facts.names[rid])
	}
	for _, spine := range linkedSpineSQL {
		query, args := restrictTo(spine.query, spine.src, ids)
		err := referenceRows(ctx, q, query, func(scan func(...any) error) error {
			var src, dst libfossil.FslID
			err := scan(&src, &dst)
			if uuid := facts.names[dst]; linked[src] && uuid != "" {
				facts.spine = append(facts.spine, uuid)
			}
			return err
		}, args...)
		if err != nil {
			return err
		}
	}
	return facts.addLinkedFiles(ctx, q, linked, ids, seen)
}

func (facts *ConeReferenceFacts) addLinkedFiles(
	ctx context.Context, q db.Querier, linked map[libfossil.FslID]bool, ids string, seen map[[2]int64]bool,
) error {
	names := map[int64]string{}
	query, args := "SELECT fnid, name FROM filename", []any(nil)
	if ids != "" {
		query += " WHERE fnid IN (SELECT fnid FROM mlink WHERE mid IN (SELECT value FROM json_each(?1)))"
		args = []any{ids}
	}
	err := referenceRows(ctx, q, query, func(scan func(...any) error) error {
		var fnid int64
		var name string
		err := scan(&fnid, &name)
		names[fnid] = name
		return err
	}, args...)
	if err != nil {
		return err
	}
	query, args = restrictTo("SELECT mid, fnid, fid FROM mlink WHERE fid>0%s", "mid", ids)
	return referenceRows(ctx, q, query,
		func(scan func(...any) error) error {
			var mid libfossil.FslID
			var key [2]int64
			if err := scan(&mid, &key[0], &key[1]); err != nil {
				return err
			}
			uuid := facts.names[libfossil.FslID(key[1])]
			if !linked[mid] || seen[key] || uuid == "" {
				return nil
			}
			if len(seen) >= coneReferenceNodes {
				return fmt.Errorf("sparse preparation: linked file budget exceeded")
			}
			seen[key] = true
			facts.files = append(facts.files, deck.FileCard{Name: names[key[0]], UUID: uuid})
			return nil
		}, args...)
}

// ridsJSON spells rids as a JSON array for json_each, "" for none. A rid is
// an integer, so the spelling carries nothing a query could misread.
func ridsJSON(rids []libfossil.FslID) (string, error) {
	if len(rids) == 0 {
		return "", nil
	}
	data, err := json.Marshal(rids)
	if err != nil {
		return "", fmt.Errorf("sparse preparation: %w", err)
	}
	return string(data), nil
}