Artifact [8b14c22331]

Artifact 8b14c22331de1dcddedc5a8cccfc7fde95a71251ce651479cb5917f3a9d68e7b:

• File leaf/agent/clientid.go — part of check-in [38efed7a12] at 2026-08-12 20:50:57 on branch main — chore(deps): migrate to go-libfossil v0.9.0 (#195)

  * chore(deps): migrate to go-libfossil v0.9.0 (renamed module path)

  - import path danmestas/libfossil → danmestas/go-libfossil everywhere - CloneOpts.ProjectCode removed upstream; assert via CloneResult instead - Timeline now takes TimelineOpts (cursor pagination, newest-first) - testutil.HasFossil removed; check FossilBinary() != ""

  * ci: retrigger checks

  ---------

  Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> (user: [email protected], size: 1168) [annotate] [blame] [check-ins using]

package agent

import (
	"fmt"
	"io"

	libfossil "github.com/danmestas/go-libfossil"
)

// ensureClientID returns the persistent edgesync-client-id for this repo,
// generating and storing a new UUIDv4 if none exists.
func ensureClientID(r *libfossil.Repo, rng io.Reader) (string, error) {
	var id string
	err := r.DB().QueryRow("SELECT value FROM config WHERE name='edgesync-client-id'").Scan(&id)
	if err == nil && id != "" {
		return id, nil
	}

	id, err = generateUUID4(rng)
	if err != nil {
		return "", fmt.Errorf("ensureClientID: %w", err)
	}

	_, err = r.DB().Exec(
		"REPLACE INTO config(name, value, mtime) VALUES('edgesync-client-id', ?, strftime('%s','now'))",
		id,
	)
	if err != nil {
		return "", fmt.Errorf("ensureClientID: store: %w", err)
	}
	return id, nil
}

// generateUUID4 creates a random UUID v4 string from the given reader.
func generateUUID4(rng io.Reader) (string, error) {
	var b [16]byte
	if _, err := rng.Read(b[:]); err != nil {
		return "", err
	}
	b[6] = (b[6] & 0x0f) | 0x40 // version 4
	b[8] = (b[8] & 0x3f) | 0x80 // variant 10
	return fmt.Sprintf("%08x-%04x-%04x-%04x-%012x",
		b[0:4], b[4:6], b[6:8], b[8:10], b[10:16]), nil
}