M-3 fix: an adopted licence says where it came from, and a newer login keeps its reading (issue 1409)
Review round 1, finding 3: adoptedFrom is the node a login came from, or where an API key came from; a newer login of the same account keeps the latest reading and generation the key holds. Builds: design 39 bus-and-switch §2, §34, §46 Claude-Session: https://claude.ai/code/session_01NcbgfHb9d4T9nq5Q6WqdiJ
This commit is contained in:
@@ -384,9 +384,10 @@ func (m *Manager) adoptOne(ctx context.Context, c Candidate, reports []Holdings,
|
|||||||
}
|
}
|
||||||
now := m.Now().UnixMilli()
|
now := m.Now().UnixMilli()
|
||||||
l := Licence{Name: NameFor(c.Identity), Kind: "subscription", AccountUUID: c.Identity.AccountUUID,
|
l := Licence{Name: NameFor(c.Identity), Kind: "subscription", AccountUUID: c.Identity.AccountUUID,
|
||||||
Email: c.Identity.EmailAddress, OrganizationUUID: c.Identity.OrganizationUUID}
|
Email: c.Identity.EmailAddress, OrganizationUUID: c.Identity.OrganizationUUID, AdoptedFrom: c.Node}
|
||||||
if held != nil {
|
if held != nil {
|
||||||
l.Name, l.NotifiedAt, l.Generation = held.Name, held.NotifiedAt, held.Generation
|
// A newer login keeps what the key holds beside its grant: its latest reading (§2, §24).
|
||||||
|
l.Name, l.NotifiedAt, l.Generation, l.Usage = held.Name, held.NotifiedAt, held.Generation, held.Usage
|
||||||
if l.Email == "" {
|
if l.Email == "" {
|
||||||
l.Email = held.Email
|
l.Email = held.Email
|
||||||
}
|
}
|
||||||
@@ -898,9 +899,9 @@ func (m *Manager) adoptKey(ctx context.Context, name, key, from string) (map[str
|
|||||||
_ = m.Emit("licence.refused", map[string]any{"licence": name, "from": from, "reason": why})
|
_ = m.Emit("licence.refused", map[string]any{"licence": name, "from": from, "reason": why})
|
||||||
return nil, fmt.Errorf("%s is refused: %s", name, why)
|
return nil, fmt.Errorf("%s is refused: %s", name, why)
|
||||||
}
|
}
|
||||||
l := Licence{Name: name, Kind: "api-key", AdoptedAt: m.Now().UnixMilli()}
|
l := Licence{Name: name, Kind: "api-key", AdoptedAt: m.Now().UnixMilli(), AdoptedFrom: from}
|
||||||
if held != nil {
|
if held != nil {
|
||||||
l.Generation = held.Generation
|
l.Generation, l.Usage = held.Generation, held.Usage
|
||||||
}
|
}
|
||||||
if err := m.handOver(ctx, &l, key, key); err != nil {
|
if err := m.handOver(ctx, &l, key, key); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -231,6 +231,12 @@ func TestANewerLoginReplacesTheGrantHeldAndAnOlderOneDoesNot(t *testing.T) {
|
|||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
_, _ = mm.m.Consider(ctx, []Holdings{mm.login("laptop", "rt-a", true, t0.Add(-time.Minute))})
|
_, _ = mm.m.Consider(ctx, []Holdings{mm.login("laptop", "rt-a", true, t0.Add(-time.Minute))})
|
||||||
before, _ := mm.store.Licence(ctx, licence1)
|
before, _ := mm.store.Licence(ctx, licence1)
|
||||||
|
// §2: a licence says where it was adopted from, and a newer login keeps the latest reading the key holds.
|
||||||
|
pct := 42.0
|
||||||
|
before.Usage = &UsageReading{SessionPct: &pct, ReadAt: t0.Format(time.RFC3339Nano)}
|
||||||
|
if before.AdoptedFrom != "laptop" || mm.store.SaveLicence(ctx, *before) != nil {
|
||||||
|
t.Fatalf("the adopted licence is %+v", before)
|
||||||
|
}
|
||||||
_, _ = mm.m.Consider(ctx, []Holdings{mm.login("server", "rt-old", true, t0.Add(-24*time.Hour))})
|
_, _ = mm.m.Consider(ctx, []Holdings{mm.login("server", "rt-old", true, t0.Add(-24*time.Hour))})
|
||||||
if strings.Join(mm.vendor.exchanged, ",") != "rt-a" {
|
if strings.Join(mm.vendor.exchanged, ",") != "rt-a" {
|
||||||
t.Fatalf("an older login was exchanged: %v", mm.vendor.exchanged)
|
t.Fatalf("an older login was exchanged: %v", mm.vendor.exchanged)
|
||||||
@@ -241,6 +247,9 @@ func TestANewerLoginReplacesTheGrantHeldAndAnOlderOneDoesNot(t *testing.T) {
|
|||||||
if after.RefreshFingerprint == before.RefreshFingerprint || mm.vendor.exchanged[len(mm.vendor.exchanged)-1] != "rt-new" {
|
if after.RefreshFingerprint == before.RefreshFingerprint || mm.vendor.exchanged[len(mm.vendor.exchanged)-1] != "rt-new" {
|
||||||
t.Fatalf("a newer login did not win: %v", mm.vendor.exchanged)
|
t.Fatalf("a newer login did not win: %v", mm.vendor.exchanged)
|
||||||
}
|
}
|
||||||
|
if after.AdoptedFrom != "desktop" || after.Usage == nil || after.Usage.SessionPct == nil || *after.Usage.SessionPct != 42 {
|
||||||
|
t.Fatalf("after a newer login the licence is %+v", after)
|
||||||
|
}
|
||||||
if ls, _ := mm.store.Licences(ctx); len(ls) != 1 {
|
if ls, _ := mm.store.Licences(ctx); len(ls) != 1 {
|
||||||
t.Fatalf("one account became %d licences", len(ls))
|
t.Fatalf("one account became %d licences", len(ls))
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user