Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1f084b817c | ||
|
|
80050cd2a8 | ||
|
|
75dda1e7d6 | ||
|
|
76169920d6 |
@@ -50,6 +50,26 @@ type identityImportResponse struct {
|
|||||||
UID string `json:"uid"`
|
UID string `json:"uid"`
|
||||||
Curve string `json:"curve"`
|
Curve string `json:"curve"`
|
||||||
CreatedAt int64 `json:"createdAt"`
|
CreatedAt int64 `json:"createdAt"`
|
||||||
|
// Created distinguishes "this key was new here" (201) from "this key was
|
||||||
|
// already in the keystore" (200). Import is the sign-in primitive for
|
||||||
|
// clients: presenting the secret key is the proof of ownership, so a
|
||||||
|
// re-import must succeed rather than conflict. Clients use the flag only
|
||||||
|
// to word the confirmation ("new profile" vs "welcome back").
|
||||||
|
Created bool `json:"created"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// identityRevealRequest asks for an existing account's private key back. The
|
||||||
|
// key was shown once at generate; without a way to see it again, a client with
|
||||||
|
// a real sign-out has no recovery path for a user who never saved it.
|
||||||
|
type identityRevealRequest struct {
|
||||||
|
Confirm bool `json:"confirm"`
|
||||||
|
UID string `json:"uid"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type identityRevealResponse struct {
|
||||||
|
UID string `json:"uid"`
|
||||||
|
Curve string `json:"curve"`
|
||||||
|
PrivateKeyHex string `json:"privateKeyHex"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type identityDeleteRequest struct {
|
type identityDeleteRequest struct {
|
||||||
@@ -172,9 +192,17 @@ func (s *Server) handleIdentityImport(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
dir := s.config.IdentityAccountsDir()
|
dir := s.config.IdentityAccountsDir()
|
||||||
if identity.ExistsByUID(dir, id.UID) {
|
// Idempotent: importing a key that is already in the keystore is how a
|
||||||
writeErrorSlug(w, http.StatusConflict, "identity_exists",
|
// second device signs in to an existing account. Answer 200 with the
|
||||||
"an account with this key already exists", false)
|
// stored account (preserving its original createdAt) instead of 409 —
|
||||||
|
// the caller proved ownership by presenting the key.
|
||||||
|
if existing, err := identity.LoadByUID(dir, id.UID); err == nil && existing != nil {
|
||||||
|
writeJSON(w, http.StatusOK, identityImportResponse{
|
||||||
|
UID: existing.UID,
|
||||||
|
Curve: existing.Curve,
|
||||||
|
CreatedAt: existing.CreatedAt,
|
||||||
|
Created: false,
|
||||||
|
})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if err := identity.SaveAccount(dir, id); err != nil {
|
if err := identity.SaveAccount(dir, id); err != nil {
|
||||||
@@ -185,6 +213,35 @@ func (s *Server) handleIdentityImport(w http.ResponseWriter, r *http.Request) {
|
|||||||
UID: id.UID,
|
UID: id.UID,
|
||||||
Curve: id.Curve,
|
Curve: id.Curve,
|
||||||
CreatedAt: id.CreatedAt,
|
CreatedAt: id.CreatedAt,
|
||||||
|
Created: true,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleIdentityReveal returns an existing account's private key. Deliberately
|
||||||
|
// POST + explicit confirm (never a bare GET) so it cannot be triggered by a
|
||||||
|
// link or an image tag, and so it reads as the deliberate act it is. The
|
||||||
|
// endpoint is auth-gated at the perimeter like the rest of /api/identity/*.
|
||||||
|
func (s *Server) handleIdentityReveal(w http.ResponseWriter, r *http.Request) {
|
||||||
|
var body identityRevealRequest
|
||||||
|
_ = json.NewDecoder(r.Body).Decode(&body)
|
||||||
|
if !body.Confirm && r.URL.Query().Get("confirm") != "true" {
|
||||||
|
writeErrorSlug(w, http.StatusBadRequest, "confirm_required",
|
||||||
|
"revealing a private key requires {\"confirm\": true} or ?confirm=true", false)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
uid := strings.TrimSpace(body.UID)
|
||||||
|
if uid == "" {
|
||||||
|
uid = strings.TrimSpace(r.URL.Query().Get("uid"))
|
||||||
|
}
|
||||||
|
id, status, slug, msg := s.resolveAccount(uid)
|
||||||
|
if status != 0 {
|
||||||
|
writeErrorSlug(w, status, slug, msg, false)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, identityRevealResponse{
|
||||||
|
UID: id.UID,
|
||||||
|
Curve: id.Curve,
|
||||||
|
PrivateKeyHex: id.PrivateKeyHex,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -172,6 +172,7 @@ func (s *Server) setupRoutes() {
|
|||||||
s.router.HandleFunc("/api/identity/accounts", s.handleIdentityAccounts).Methods("GET")
|
s.router.HandleFunc("/api/identity/accounts", s.handleIdentityAccounts).Methods("GET")
|
||||||
s.router.HandleFunc("/api/identity/generate", s.handleIdentityGenerate).Methods("POST")
|
s.router.HandleFunc("/api/identity/generate", s.handleIdentityGenerate).Methods("POST")
|
||||||
s.router.HandleFunc("/api/identity/import", s.handleIdentityImport).Methods("POST")
|
s.router.HandleFunc("/api/identity/import", s.handleIdentityImport).Methods("POST")
|
||||||
|
s.router.HandleFunc("/api/identity/reveal", s.handleIdentityReveal).Methods("POST")
|
||||||
s.router.HandleFunc("/api/identity", s.handleIdentityDelete).Methods("DELETE")
|
s.router.HandleFunc("/api/identity", s.handleIdentityDelete).Methods("DELETE")
|
||||||
s.router.HandleFunc("/api/identity/sign", s.handleIdentitySign).Methods("POST")
|
s.router.HandleFunc("/api/identity/sign", s.handleIdentitySign).Methods("POST")
|
||||||
s.router.HandleFunc("/api/identity/aead-key", s.handleIdentityAEADKey).Methods("GET")
|
s.router.HandleFunc("/api/identity/aead-key", s.handleIdentityAEADKey).Methods("GET")
|
||||||
@@ -201,6 +202,15 @@ func (s *Server) setupRoutes() {
|
|||||||
s.router.HandleFunc("/api/kv/value", s.handleKVValueDelete).Methods("DELETE")
|
s.router.HandleFunc("/api/kv/value", s.handleKVValueDelete).Methods("DELETE")
|
||||||
s.router.HandleFunc("/api/kv/key/{key:.*}", s.handleKVGetKey).Methods("GET")
|
s.router.HandleFunc("/api/kv/key/{key:.*}", s.handleKVGetKey).Methods("GET")
|
||||||
|
|
||||||
|
// User Data Layer (UDL) routes — per-user signed records (My List,
|
||||||
|
// Continue Watching, ratings, profile). See internal/api/udl.go.
|
||||||
|
s.router.HandleFunc("/api/udl/record", s.handleUDLRecordGet).Methods("GET")
|
||||||
|
s.router.HandleFunc("/api/udl/record", s.handleUDLRecordPut).Methods("PUT")
|
||||||
|
s.router.HandleFunc("/api/udl/user/{uid}/key/{key}", s.handleUDLUserKey).Methods("GET")
|
||||||
|
s.router.HandleFunc("/api/udl/user/{uid}/cid/{cid}", s.handleUDLUserCid).Methods("GET")
|
||||||
|
s.router.HandleFunc("/api/udl/cid/{cid}/users", s.handleUDLCidUsers).Methods("GET")
|
||||||
|
s.router.HandleFunc("/api/udl/cid/{cid}/aggregate", s.handleUDLAggregate).Methods("GET")
|
||||||
|
|
||||||
// Metadata operations - base endpoints
|
// Metadata operations - base endpoints
|
||||||
s.router.HandleFunc("/meta/{hash}", s.handleGetMeta).Methods("GET")
|
s.router.HandleFunc("/meta/{hash}", s.handleGetMeta).Methods("GET")
|
||||||
s.router.HandleFunc("/meta/{hash}", s.handlePutMeta).Methods("PUT")
|
s.router.HandleFunc("/meta/{hash}", s.handlePutMeta).Methods("PUT")
|
||||||
|
|||||||
@@ -0,0 +1,239 @@
|
|||||||
|
package api
|
||||||
|
|
||||||
|
// User Data Layer (UDL) HTTP surface.
|
||||||
|
//
|
||||||
|
// Backs meta-watch's per-user store (My List, Continue Watching, ratings,
|
||||||
|
// profile) now that the authoritative store lives in meta-core instead of
|
||||||
|
// meta-watch's local op-log. Records arrive already signed (and, for
|
||||||
|
// private-tier keys, already encrypted) as opaque base64 CBOR blobs; meta-core
|
||||||
|
// version-gates and indexes them but never inspects the crypto. See
|
||||||
|
// internal/storage/udl.go for the Redis model.
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/json"
|
||||||
|
"math"
|
||||||
|
"net/http"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/gorilla/mux"
|
||||||
|
)
|
||||||
|
|
||||||
|
// UDLPutRequest is the body of PUT /api/udl/record.
|
||||||
|
type UDLPutRequest struct {
|
||||||
|
Uid string `json:"uid"`
|
||||||
|
Cid string `json:"cid"`
|
||||||
|
Key string `json:"key"`
|
||||||
|
Version int64 `json:"version"`
|
||||||
|
Ts int64 `json:"ts"`
|
||||||
|
Record string `json:"record"` // base64 CBOR, opaque + signed
|
||||||
|
Value *json.RawMessage `json:"value,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLPutResponse is the response of PUT /api/udl/record.
|
||||||
|
type UDLPutResponse struct {
|
||||||
|
Accepted bool `json:"accepted"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLRecordResponse is the response of GET /api/udl/record.
|
||||||
|
type UDLRecordResponse struct {
|
||||||
|
Record string `json:"record"`
|
||||||
|
Version int64 `json:"version"`
|
||||||
|
Ts int64 `json:"ts"`
|
||||||
|
Exists bool `json:"exists"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLAggregate mirrors meta-watch's Aggregate wire shape exactly (snake_case
|
||||||
|
// field names; `avg` is null for boolean keys like `like`), so the meta-watch
|
||||||
|
// client deserializes it into the same struct it serializes to the UI.
|
||||||
|
type UDLAggregate struct {
|
||||||
|
Key string `json:"key"`
|
||||||
|
Count int `json:"count"`
|
||||||
|
Avg *float64 `json:"avg"`
|
||||||
|
Trues int `json:"trues"`
|
||||||
|
SampleSize int `json:"sample_size"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLRecordGet handles GET /api/udl/record?uid&cid&key
|
||||||
|
func (s *Server) handleUDLRecordGet(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
q := r.URL.Query()
|
||||||
|
uid, cid, key := q.Get("uid"), q.Get("cid"), q.Get("key")
|
||||||
|
if uid == "" || cid == "" || key == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "uid, cid and key are required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
cell, exists, err := s.storage.UDLGetCell(uid, cid, key)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, UDLRecordResponse{
|
||||||
|
Record: cell.Record,
|
||||||
|
Version: cell.Version,
|
||||||
|
Ts: cell.Ts,
|
||||||
|
Exists: exists,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLRecordPut handles PUT /api/udl/record. Version-gated: a stale write
|
||||||
|
// (version <= stored) returns 409 stale_version so the client can re-read and
|
||||||
|
// retry with a higher version.
|
||||||
|
func (s *Server) handleUDLRecordPut(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
var req UDLPutRequest
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
||||||
|
writeError(w, http.StatusBadRequest, "invalid JSON body")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if req.Uid == "" || req.Cid == "" || req.Key == "" || req.Record == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "uid, cid, key and record are required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
publicValue := ""
|
||||||
|
hasValue := false
|
||||||
|
if req.Value != nil {
|
||||||
|
publicValue = string(*req.Value)
|
||||||
|
hasValue = true
|
||||||
|
}
|
||||||
|
|
||||||
|
accepted, err := s.storage.UDLUpsertIfNewer(req.Uid, req.Cid, req.Key, req.Version, req.Ts, req.Record, publicValue, hasValue)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if !accepted {
|
||||||
|
writeErrorSlug(w, http.StatusConflict, "stale_version", "a record with an equal or newer version already exists", true)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, UDLPutResponse{Accepted: true})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLUserKey handles GET /api/udl/user/{uid}/key/{key}
|
||||||
|
// (active_for_user_key — My List, Continue Watching).
|
||||||
|
func (s *Server) handleUDLUserKey(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
vars := mux.Vars(r)
|
||||||
|
uid, key := vars["uid"], vars["key"]
|
||||||
|
if uid == "" || key == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "uid and key are required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
entries, err := s.storage.UDLListUserKey(uid, key)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, map[string]interface{}{"entries": entries})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLUserCid handles GET /api/udl/user/{uid}/cid/{cid}
|
||||||
|
// (list_for_user_cid).
|
||||||
|
func (s *Server) handleUDLUserCid(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
vars := mux.Vars(r)
|
||||||
|
uid, cid := vars["uid"], vars["cid"]
|
||||||
|
if uid == "" || cid == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "uid and cid are required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
entries, err := s.storage.UDLListUserCid(uid, cid)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, map[string]interface{}{"entries": entries})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLCidUsers handles GET /api/udl/cid/{cid}/users (uids_for_cid).
|
||||||
|
func (s *Server) handleUDLCidUsers(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
cid := mux.Vars(r)["cid"]
|
||||||
|
if cid == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "cid is required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
users, err := s.storage.UDLCidUsers(cid)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, map[string]interface{}{"users": users})
|
||||||
|
}
|
||||||
|
|
||||||
|
// handleUDLAggregate handles GET /api/udl/cid/{cid}/aggregate?keys=like,rating.
|
||||||
|
// Computes per-key population stats from the stored public value fields
|
||||||
|
// (absorbs meta-watch's aggregate.rs). Reflects only records this core holds.
|
||||||
|
func (s *Server) handleUDLAggregate(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !s.storage.IsConnected() {
|
||||||
|
writeError(w, http.StatusServiceUnavailable, "storage not connected")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
cid := mux.Vars(r)["cid"]
|
||||||
|
if cid == "" {
|
||||||
|
writeError(w, http.StatusBadRequest, "cid is required")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
keysParam := r.URL.Query().Get("keys")
|
||||||
|
if keysParam == "" {
|
||||||
|
keysParam = "like,rating"
|
||||||
|
}
|
||||||
|
aggregates := make([]UDLAggregate, 0)
|
||||||
|
for _, key := range strings.Split(keysParam, ",") {
|
||||||
|
key = strings.TrimSpace(key)
|
||||||
|
if key == "" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
values, err := s.storage.UDLPublicValues(cid, key)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
aggregates = append(aggregates, aggregatePublicValues(key, values))
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, map[string]interface{}{"aggregates": aggregates})
|
||||||
|
}
|
||||||
|
|
||||||
|
// aggregatePublicValues folds raw JSON scalar values into an UDLAggregate:
|
||||||
|
// counts booleans as trues and averages numeric values.
|
||||||
|
func aggregatePublicValues(key string, values []string) UDLAggregate {
|
||||||
|
agg := UDLAggregate{Key: key, SampleSize: len(values), Count: len(values)}
|
||||||
|
var sum float64
|
||||||
|
var numeric int
|
||||||
|
for _, raw := range values {
|
||||||
|
var v interface{}
|
||||||
|
if err := json.Unmarshal([]byte(raw), &v); err != nil {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
switch t := v.(type) {
|
||||||
|
case bool:
|
||||||
|
if t {
|
||||||
|
agg.Trues++
|
||||||
|
}
|
||||||
|
case float64:
|
||||||
|
sum += t
|
||||||
|
numeric++
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if numeric > 0 {
|
||||||
|
avg := math.Round((sum/float64(numeric))*100) / 100
|
||||||
|
agg.Avg = &avg
|
||||||
|
}
|
||||||
|
return agg
|
||||||
|
}
|
||||||
@@ -19,9 +19,10 @@
|
|||||||
"ladder": {
|
"ladder": {
|
||||||
"40": "dag-pb (IPFS block)",
|
"40": "dag-pb (IPFS block)",
|
||||||
"30": "sha2-256 / sha3-256 / sha3-384 - real content digests",
|
"30": "sha2-256 / sha3-256 / sha3-384 - real content digests",
|
||||||
|
"25": "nzb-posting - content-derived (Message-ID set digest), but not itself fetchable",
|
||||||
"20": "BitTorrent infohashes - swarm interop",
|
"20": "BitTorrent infohashes - swarm interop",
|
||||||
"10": "midhash256 - the record address",
|
"10": "midhash256 - the record address",
|
||||||
"5": "opaque locators (nzb-release, url) - never outrank a real digest",
|
"5": "opaque locators (nzb-release, url, card) - never outrank a real digest",
|
||||||
"0": "weak/unknown digests, unparseable input"
|
"0": "weak/unknown digests, unparseable input"
|
||||||
},
|
},
|
||||||
"tieBreak": "lexicographically smaller cid wins",
|
"tieBreak": "lexicographically smaller cid wins",
|
||||||
@@ -56,6 +57,12 @@
|
|||||||
"rank": 30,
|
"rank": 30,
|
||||||
"note": "REAL meta-hash fixture"
|
"note": "REAL meta-hash fixture"
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"name": "nzb-posting",
|
||||||
|
"cid": "bagbsaeraaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
|
||||||
|
"rank": 25,
|
||||||
|
"note": "codec 0x1003 + REAL sha2-256 multihash (0x12) over the normalised, sorted Message-ID set - NOT a locator, so it sits ABOVE tier 5, but it addresses no fetchable block (bitswap can never satisfy a want for it - the digest is over an id set, not over any block's bytes), so it stays BELOW a real content digest (30): once meta-share materialises the media and re-seeds it, that genuine sha2-256 cid must win the canonical election, not this one. Rank MUST match on codec BEFORE falling through to the mh switch, or this scores 30 (same trap as nzb-release/url, in reverse: those need a codec check because their mh is identity 0x00; this needs one because its mh is REAL sha2-256 and would otherwise tie with tier 30)."
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"name": "btih-v2-codec-eq-mh",
|
"name": "btih-v2-codec-eq-mh",
|
||||||
"cid": "bag3sdnzbeaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
|
"cid": "bag3sdnzbeaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
|
||||||
@@ -103,6 +110,12 @@
|
|||||||
"rank": 5,
|
"rank": 5,
|
||||||
"note": "codec 0x1006 + IDENTITY multihash 0x00. Same tier/reasoning as nzb-release."
|
"note": "codec 0x1006 + IDENTITY multihash 0x00. Same tier/reasoning as nzb-release."
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"name": "card-locator",
|
||||||
|
"cid": "bagdsaaanar2g2zdcor3duojvgq3ts",
|
||||||
|
"rank": 5,
|
||||||
|
"note": "codec 0x1007 + IDENTITY multihash 0x00, digest = varint(len(source)) || source || id — here (\"tmdb\",\"tv:95479\"). Same codec-slot rule as nzb-release/url: match on the CODEC, never the mh. The limit case of the family — the only CID in MetaMesh with NO bytes behind it anywhere, ever: it addresses a *work* (a series, a film), not a file, so the byte path 404s by design and bitswap never offers it (seeding is gated on sha2-256). Tier 5 is load-bearing for the planned cross-source merge: one card record may carry BOTH a TMDB and a MyAnimeList locator, and if a real card body is ever added (see card-tier-search.md §4.3) its sha2-256 must win the canonical election over both locators without any addressing change. Ranking it 0 instead would still lose to a digest, but would put the implementations back out of agreement — which is the exact failure this fixture exists to prevent."
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"name": "sha1",
|
"name": "sha1",
|
||||||
"cid": "baeircff3eqvxxaqqot2lt242stkdtk3gq4c2vra",
|
"cid": "baeircff3eqvxxaqqot2lt242stkdtk3gq4c2vra",
|
||||||
|
|||||||
+40
-8
@@ -49,16 +49,37 @@ const (
|
|||||||
// these — matching on mh would see 0x00 and rank them 0.
|
// these — matching on mh would see 0x00 and rank them 0.
|
||||||
CodeNzbRelease = 0x1005 // custom — self-describing Newznab release locator
|
CodeNzbRelease = 0x1005 // custom — self-describing Newznab release locator
|
||||||
CodeURL = 0x1006 // custom — identity-multihash CID wrapping an http(s) URL
|
CodeURL = 0x1006 // custom — identity-multihash CID wrapping an http(s) URL
|
||||||
|
// CodeCard is the limit case of the family: the only CID with NO bytes
|
||||||
|
// behind it anywhere, ever. It addresses a *work* (a series, a film) via
|
||||||
|
// varint(len(source))‖source‖id — ("tmdb","tv:95479") — so `/api/file/{cid}`
|
||||||
|
// correctly 404s and bitswap never offers it. Ranking it here (rather than
|
||||||
|
// letting it fall to RankUnknown) is what makes the planned "one card, two
|
||||||
|
// CIDs" cross-source merge safe: a TMDB and a MyAnimeList locator can sit on
|
||||||
|
// one record, and a real digest added later still wins the election.
|
||||||
|
CodeCard = 0x1007 // custom — identity-multihash CID wrapping a card (work) id
|
||||||
|
|
||||||
|
// CodeNzbPosting is the INVERSE trap of the two above: its multihash is a
|
||||||
|
// REAL sha2-256 digest (over the normalised, sorted article Message-ID
|
||||||
|
// set of a Usenet posting we scanned ourselves — never a locator, no
|
||||||
|
// indexer host embedded), so it would silently fall into RankDigest via
|
||||||
|
// the mh switch unless matched on the codec FIRST. It is content-derived
|
||||||
|
// (so it outranks the opaque locators) but addresses no fetchable block —
|
||||||
|
// the digest is over an id set, not over any block's bytes, so it can
|
||||||
|
// never be bitswap-fetched under itself — so it must stay BELOW a real
|
||||||
|
// digest (once the media is materialised and re-seeded, that genuine
|
||||||
|
// sha2-256 cid has to win the canonical election, not this one).
|
||||||
|
CodeNzbPosting = 0x1003 // custom — self-scanned Usenet posting identity
|
||||||
)
|
)
|
||||||
|
|
||||||
// Rank tiers, named so the ladder reads as a ladder.
|
// Rank tiers, named so the ladder reads as a ladder.
|
||||||
const (
|
const (
|
||||||
RankIPFS = 40 // dag-pb — broadest network reach
|
RankIPFS = 40 // dag-pb — broadest network reach
|
||||||
RankDigest = 30 // sha2-256 / sha3-* — real content digests
|
RankDigest = 30 // sha2-256 / sha3-* — real content digests
|
||||||
RankBtih = 20 // BitTorrent infohashes — swarm interop
|
RankNzbPosting = 25 // content-derived, but the digest addresses no fetchable block
|
||||||
RankMidhash = 10 // the record address — internally meaningful, externally invisible
|
RankBtih = 20 // BitTorrent infohashes — swarm interop
|
||||||
RankLocator = 5 // opaque locators — never outrank a real digest
|
RankMidhash = 10 // the record address — internally meaningful, externally invisible
|
||||||
RankUnknown = 0 // weak/unknown digests, unparseable input
|
RankLocator = 5 // opaque locators — never outrank a real digest
|
||||||
|
RankUnknown = 0 // weak/unknown digests, unparseable input
|
||||||
)
|
)
|
||||||
|
|
||||||
// Decode parses a multibase-base32 CIDv1 string ("b…") into its content
|
// Decode parses a multibase-base32 CIDv1 string ("b…") into its content
|
||||||
@@ -112,11 +133,16 @@ func Decode(cidStr string) (codec uint64, mhCode uint64, err error) {
|
|||||||
// - dag-pb (chunked IPFS file) wins: best retrieval over the IPFS network.
|
// - dag-pb (chunked IPFS file) wins: best retrieval over the IPFS network.
|
||||||
// - sha2-256 / sha3 digests follow: standard content hashes (a raw IPFS
|
// - sha2-256 / sha3 digests follow: standard content hashes (a raw IPFS
|
||||||
// block of the file IS its sha2-256, so they share this tier).
|
// block of the file IS its sha2-256, so they share this tier).
|
||||||
|
// - nzb-posting is content-derived (a digest over a Usenet posting's article
|
||||||
|
// Message-ID set) so it outranks the opaque locators below, but the
|
||||||
|
// digest addresses no fetchable block, so it stays below a real content
|
||||||
|
// digest — once the media is materialised and re-seeded under a genuine
|
||||||
|
// sha2-256 cid, that cid must win the election, not this one.
|
||||||
// - BitTorrent infohashes (btih v2, per-file v1/v2) outrank midhash256 for
|
// - BitTorrent infohashes (btih v2, per-file v1/v2) outrank midhash256 for
|
||||||
// swarm interop, not strength.
|
// swarm interop, not strength.
|
||||||
// - midhash256 is the floor among real *digests*: internally meaningful,
|
// - midhash256 is the floor among real *digests*: internally meaningful,
|
||||||
// externally invisible.
|
// externally invisible.
|
||||||
// - opaque locators (nzb-release, url) sit BELOW midhash. They are not
|
// - opaque locators (nzb-release, url, card) sit BELOW midhash. They are not
|
||||||
// content-derived — two URLs to the same bytes yield two different locator
|
// content-derived — two URLs to the same bytes yield two different locator
|
||||||
// CIDs — so a locator must never displace a real digest as the identity a
|
// CIDs — so a locator must never displace a real digest as the identity a
|
||||||
// record is advertised under. Tier 5 means a locator wins the election only
|
// record is advertised under. Tier 5 means a locator wins the election only
|
||||||
@@ -139,9 +165,15 @@ func Rank(cidStr string) int {
|
|||||||
}
|
}
|
||||||
// Opaque locators. Codec-only: their multihash is identity (0x00), so
|
// Opaque locators. Codec-only: their multihash is identity (0x00), so
|
||||||
// there is nothing to match on the mh side.
|
// there is nothing to match on the mh side.
|
||||||
if codec == CodeNzbRelease || codec == CodeURL {
|
if codec == CodeNzbRelease || codec == CodeURL || codec == CodeCard {
|
||||||
return RankLocator
|
return RankLocator
|
||||||
}
|
}
|
||||||
|
// nzb-posting: codec-only, checked BEFORE the mh switch below — its
|
||||||
|
// multihash is a real sha2-256 and would otherwise match CodeSha256 there
|
||||||
|
// and rank 30, tying with genuine content digests.
|
||||||
|
if codec == CodeNzbPosting {
|
||||||
|
return RankNzbPosting
|
||||||
|
}
|
||||||
switch mh {
|
switch mh {
|
||||||
case CodeSha256, CodeSha3_256, CodeSha3_384:
|
case CodeSha256, CodeSha3_256, CodeSha3_384:
|
||||||
return RankDigest
|
return RankDigest
|
||||||
|
|||||||
@@ -150,12 +150,31 @@ func TestRank_Tiers(t *testing.T) {
|
|||||||
func TestRank_StrictOrdering(t *testing.T) {
|
func TestRank_StrictOrdering(t *testing.T) {
|
||||||
ipfs := Rank(buildCID(CodecDagPB, CodeSha256, 32))
|
ipfs := Rank(buildCID(CodecDagPB, CodeSha256, 32))
|
||||||
sha := Rank(cidSha256)
|
sha := Rank(cidSha256)
|
||||||
|
posting := Rank(buildCID(CodeNzbPosting, CodeSha256, 32))
|
||||||
btih := Rank(buildCID(CodeBtihV2, CodeBtihV2, 32))
|
btih := Rank(buildCID(CodeBtihV2, CodeBtihV2, 32))
|
||||||
mid := Rank(buildCID(CodeMidhash256, CodeMidhash256, 32))
|
mid := Rank(buildCID(CodeMidhash256, CodeMidhash256, 32))
|
||||||
unknown := Rank(cidMd5)
|
unknown := Rank(cidMd5)
|
||||||
if !(ipfs > sha && sha > btih && btih > mid && mid > unknown) {
|
if !(ipfs > sha && sha > posting && posting > btih && btih > mid && mid > unknown) {
|
||||||
t.Fatalf("rank ordering broken: ipfs=%d sha=%d btih=%d mid=%d unknown=%d",
|
t.Fatalf("rank ordering broken: ipfs=%d sha=%d posting=%d btih=%d mid=%d unknown=%d",
|
||||||
ipfs, sha, btih, mid, unknown)
|
ipfs, sha, posting, btih, mid, unknown)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// TestRank_NzbPostingMatchesCodecNotMultihash pins the inverse trap:
|
||||||
|
// nzb-posting's multihash is a REAL sha2-256 (unlike nzb-release/url, whose mh
|
||||||
|
// is identity 0x00), so Rank must match on the codec BEFORE falling into the
|
||||||
|
// mh switch — otherwise this ties with a genuine content digest at 30 instead
|
||||||
|
// of sitting at 25.
|
||||||
|
func TestRank_NzbPostingMatchesCodecNotMultihash(t *testing.T) {
|
||||||
|
posting := buildCID(CodeNzbPosting, CodeSha256, 32)
|
||||||
|
if got := Rank(posting); got != RankNzbPosting {
|
||||||
|
t.Errorf("Rank(nzb-posting) = %d, want %d (RankNzbPosting) — codec check must precede the mh switch", got, RankNzbPosting)
|
||||||
|
}
|
||||||
|
// A real sha2-256 with the SAME digest bytes must still rank 30 — the
|
||||||
|
// codec, not the digest, is what distinguishes the two.
|
||||||
|
realDigest := buildCID(CodecRaw, CodeSha256, 32)
|
||||||
|
if got := Rank(realDigest); got != RankDigest {
|
||||||
|
t.Errorf("Rank(sha2-256) regressed to %d, want %d", got, RankDigest)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,284 @@
|
|||||||
|
package storage
|
||||||
|
|
||||||
|
// User Data Layer (UDL) storage.
|
||||||
|
//
|
||||||
|
// Holds per-user, identity-signed records keyed by (uid, cid, key) — the
|
||||||
|
// subjective/per-user state that METADATA_KEYS.md rule #4 bars from the shared
|
||||||
|
// /file/{cid} hash (likes, ratings, watch progress, local paths). Each record
|
||||||
|
// is an opaque, client-signed (and, for private-tier keys, client-encrypted)
|
||||||
|
// CBOR blob; meta-core stores it verbatim and never needs the account key.
|
||||||
|
//
|
||||||
|
// Convergence is version-gated: a write is accepted only if its `version`
|
||||||
|
// strictly exceeds the stored one (a per-cell high-water-mark, replacing the
|
||||||
|
// op-log merge that used to live in meta-watch's store.rs).
|
||||||
|
//
|
||||||
|
// Redis model (all under the literal "udl:" prefix, mirroring the "file:" one):
|
||||||
|
//
|
||||||
|
// udl:rec:<uid>/<cid>/<key> HASH { record, version, ts, value? }
|
||||||
|
// udl:idx:user:<uid>:key:<key> SET of <cid> -> active_for_user_key (My List, Continue Watching)
|
||||||
|
// udl:idx:user:<uid>:cid:<cid> SET of <key> -> list_for_user_cid
|
||||||
|
// udl:idx:cid:<cid>:key:<key> SET of <uid> -> aggregate
|
||||||
|
// udl:idx:cid:<cid>:users SET of <uid> -> uids_for_cid
|
||||||
|
//
|
||||||
|
// The `value` hash field is the plaintext JSON scalar for PUBLIC keys only
|
||||||
|
// (like/rating), used for aggregation; it is absent for private-tier keys
|
||||||
|
// (whose real value rides encrypted inside `record`) and for tombstones.
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"fmt"
|
||||||
|
"strconv"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/redis/go-redis/v9"
|
||||||
|
)
|
||||||
|
|
||||||
|
// UDLCell is a decoded (uid, cid, key) record cell.
|
||||||
|
type UDLCell struct {
|
||||||
|
Record string // base64 CBOR, opaque + signed
|
||||||
|
Version int64
|
||||||
|
Ts int64
|
||||||
|
Value string // plaintext JSON scalar, public keys only
|
||||||
|
HasValue bool
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLUserKeyEntry is one row of active_for_user_key (all cids for a uid+key).
|
||||||
|
type UDLUserKeyEntry struct {
|
||||||
|
Cid string `json:"cid"`
|
||||||
|
Record string `json:"record"`
|
||||||
|
Version int64 `json:"version"`
|
||||||
|
Ts int64 `json:"ts"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLUserCidEntry is one row of list_for_user_cid (all keys for a uid+cid).
|
||||||
|
type UDLUserCidEntry struct {
|
||||||
|
Key string `json:"key"`
|
||||||
|
Record string `json:"record"`
|
||||||
|
Version int64 `json:"version"`
|
||||||
|
Ts int64 `json:"ts"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func udlRecKey(uid, cid, key string) string {
|
||||||
|
return fmt.Sprintf("udl:rec:%s/%s/%s", uid, cid, key)
|
||||||
|
}
|
||||||
|
func udlIdxUserKey(uid, key string) string { return fmt.Sprintf("udl:idx:user:%s:key:%s", uid, key) }
|
||||||
|
func udlIdxUserCid(uid, cid string) string { return fmt.Sprintf("udl:idx:user:%s:cid:%s", uid, cid) }
|
||||||
|
func udlIdxCidKey(cid, key string) string { return fmt.Sprintf("udl:idx:cid:%s:key:%s", cid, key) }
|
||||||
|
func udlIdxCidUsers(cid string) string { return fmt.Sprintf("udl:idx:cid:%s:users", cid) }
|
||||||
|
|
||||||
|
// udlUpsertScript performs the version-gated upsert + index maintenance
|
||||||
|
// atomically. Accepts (returns 1) only when the incoming version strictly
|
||||||
|
// exceeds the stored one; otherwise returns 0 (stale).
|
||||||
|
//
|
||||||
|
// KEYS: 1=cell 2=idx:user:key 3=idx:user:cid 4=idx:cid:key 5=idx:cid:users
|
||||||
|
// ARGV: 1=version 2=ts 3=record 4=value 5=hasValue("1"/"0")
|
||||||
|
// 6=cid 7=key 8=uid
|
||||||
|
var udlUpsertScript = redis.NewScript(`
|
||||||
|
local stored = redis.call('HGET', KEYS[1], 'version')
|
||||||
|
if stored and tonumber(stored) >= tonumber(ARGV[1]) then
|
||||||
|
return 0
|
||||||
|
end
|
||||||
|
redis.call('HSET', KEYS[1], 'version', ARGV[1], 'ts', ARGV[2], 'record', ARGV[3])
|
||||||
|
if ARGV[5] == '1' then
|
||||||
|
redis.call('HSET', KEYS[1], 'value', ARGV[4])
|
||||||
|
else
|
||||||
|
redis.call('HDEL', KEYS[1], 'value')
|
||||||
|
end
|
||||||
|
redis.call('SADD', KEYS[2], ARGV[6])
|
||||||
|
redis.call('SADD', KEYS[3], ARGV[7])
|
||||||
|
redis.call('SADD', KEYS[4], ARGV[8])
|
||||||
|
redis.call('SADD', KEYS[5], ARGV[8])
|
||||||
|
return 1
|
||||||
|
`)
|
||||||
|
|
||||||
|
// UDLUpsertIfNewer stores a record cell iff version strictly exceeds the stored
|
||||||
|
// one. publicValue/hasValue carry the plaintext JSON scalar for public keys
|
||||||
|
// (used by aggregation); pass hasValue=false for private-tier keys and
|
||||||
|
// tombstones. Returns accepted=false when the write is stale.
|
||||||
|
func (c *Client) UDLUpsertIfNewer(uid, cid, key string, version, ts int64, record, publicValue string, hasValue bool) (bool, error) {
|
||||||
|
c.mu.Lock()
|
||||||
|
defer c.mu.Unlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return false, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
keys := []string{
|
||||||
|
c.buildKey(udlRecKey(uid, cid, key)),
|
||||||
|
c.buildKey(udlIdxUserKey(uid, key)),
|
||||||
|
c.buildKey(udlIdxUserCid(uid, cid)),
|
||||||
|
c.buildKey(udlIdxCidKey(cid, key)),
|
||||||
|
c.buildKey(udlIdxCidUsers(cid)),
|
||||||
|
}
|
||||||
|
hv := "0"
|
||||||
|
if hasValue {
|
||||||
|
hv = "1"
|
||||||
|
}
|
||||||
|
res, err := udlUpsertScript.Run(ctx, c.client, keys, version, ts, record, publicValue, hv, cid, key, uid).Result()
|
||||||
|
if err != nil {
|
||||||
|
return false, fmt.Errorf("udl upsert failed: %w", err)
|
||||||
|
}
|
||||||
|
n, _ := res.(int64)
|
||||||
|
return n == 1, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLGetCell returns the record cell for (uid, cid, key). exists is false when
|
||||||
|
// no record has ever been written for the cell.
|
||||||
|
func (c *Client) UDLGetCell(uid, cid, key string) (UDLCell, bool, error) {
|
||||||
|
c.mu.RLock()
|
||||||
|
defer c.mu.RUnlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return UDLCell{}, false, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
return c.udlReadCell(ctx, udlRecKey(uid, cid, key))
|
||||||
|
}
|
||||||
|
|
||||||
|
// udlReadCell HMGETs a cell hash. Caller holds the lock. exists is false when
|
||||||
|
// the version field is absent (i.e. the hash does not exist).
|
||||||
|
func (c *Client) udlReadCell(ctx context.Context, recKey string) (UDLCell, bool, error) {
|
||||||
|
vals, err := c.client.HMGet(ctx, c.buildKey(recKey), "record", "version", "ts", "value").Result()
|
||||||
|
if err != nil {
|
||||||
|
return UDLCell{}, false, fmt.Errorf("hmget failed: %w", err)
|
||||||
|
}
|
||||||
|
// vals: [record, version, ts, value] — nil for absent fields.
|
||||||
|
if len(vals) < 4 || vals[1] == nil {
|
||||||
|
return UDLCell{}, false, nil
|
||||||
|
}
|
||||||
|
cell := UDLCell{}
|
||||||
|
if s, ok := vals[0].(string); ok {
|
||||||
|
cell.Record = s
|
||||||
|
}
|
||||||
|
if s, ok := vals[1].(string); ok {
|
||||||
|
cell.Version, _ = strconv.ParseInt(s, 10, 64)
|
||||||
|
}
|
||||||
|
if s, ok := vals[2].(string); ok {
|
||||||
|
cell.Ts, _ = strconv.ParseInt(s, 10, 64)
|
||||||
|
}
|
||||||
|
if s, ok := vals[3].(string); ok {
|
||||||
|
cell.Value = s
|
||||||
|
cell.HasValue = true
|
||||||
|
}
|
||||||
|
return cell, true, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLListUserKey returns every cell for (uid, key) across all cids — the
|
||||||
|
// projection behind active_for_user_key (My List, Continue Watching). Includes
|
||||||
|
// tombstones; the caller decodes each record and filters.
|
||||||
|
func (c *Client) UDLListUserKey(uid, key string) ([]UDLUserKeyEntry, error) {
|
||||||
|
c.mu.RLock()
|
||||||
|
defer c.mu.RUnlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return nil, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
cids, err := c.client.SMembers(ctx, c.buildKey(udlIdxUserKey(uid, key))).Result()
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("smembers failed: %w", err)
|
||||||
|
}
|
||||||
|
out := make([]UDLUserKeyEntry, 0, len(cids))
|
||||||
|
for _, cid := range cids {
|
||||||
|
cell, ok, err := c.udlReadCell(ctx, udlRecKey(uid, cid, key))
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if !ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
out = append(out, UDLUserKeyEntry{Cid: cid, Record: cell.Record, Version: cell.Version, Ts: cell.Ts})
|
||||||
|
}
|
||||||
|
return out, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLListUserCid returns every cell for (uid, cid) across all keys — the
|
||||||
|
// projection behind list_for_user_cid.
|
||||||
|
func (c *Client) UDLListUserCid(uid, cid string) ([]UDLUserCidEntry, error) {
|
||||||
|
c.mu.RLock()
|
||||||
|
defer c.mu.RUnlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return nil, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
keys, err := c.client.SMembers(ctx, c.buildKey(udlIdxUserCid(uid, cid))).Result()
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("smembers failed: %w", err)
|
||||||
|
}
|
||||||
|
out := make([]UDLUserCidEntry, 0, len(keys))
|
||||||
|
for _, key := range keys {
|
||||||
|
cell, ok, err := c.udlReadCell(ctx, udlRecKey(uid, cid, key))
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if !ok {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
out = append(out, UDLUserCidEntry{Key: key, Record: cell.Record, Version: cell.Version, Ts: cell.Ts})
|
||||||
|
}
|
||||||
|
return out, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLCidUsers returns every uid that has any record for cid — uids_for_cid.
|
||||||
|
func (c *Client) UDLCidUsers(cid string) ([]string, error) {
|
||||||
|
c.mu.RLock()
|
||||||
|
defer c.mu.RUnlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return nil, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
uids, err := c.client.SMembers(ctx, c.buildKey(udlIdxCidUsers(cid))).Result()
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("smembers failed: %w", err)
|
||||||
|
}
|
||||||
|
return uids, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// UDLPublicValues returns the live plaintext public JSON scalar values for
|
||||||
|
// (cid, key) across all uids — the input to aggregation. Cells without a value
|
||||||
|
// field (private-tier or tombstoned) are skipped.
|
||||||
|
func (c *Client) UDLPublicValues(cid, key string) ([]string, error) {
|
||||||
|
c.mu.RLock()
|
||||||
|
defer c.mu.RUnlock()
|
||||||
|
|
||||||
|
if c.client == nil {
|
||||||
|
return nil, fmt.Errorf("not connected")
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
uids, err := c.client.SMembers(ctx, c.buildKey(udlIdxCidKey(cid, key))).Result()
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("smembers failed: %w", err)
|
||||||
|
}
|
||||||
|
out := make([]string, 0, len(uids))
|
||||||
|
for _, uid := range uids {
|
||||||
|
v, err := c.client.HGet(ctx, c.buildKey(udlRecKey(uid, cid, key)), "value").Result()
|
||||||
|
if err == redis.Nil {
|
||||||
|
continue // private-tier or tombstoned
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("hget failed: %w", err)
|
||||||
|
}
|
||||||
|
out = append(out, v)
|
||||||
|
}
|
||||||
|
return out, nil
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user