Log returns a logger scoped to the request ID if present in the context.

Run is responsible for denormalizing data and handling our worker pools.

bool should be true if data was found.

error writes an error message. The status code defaults to 500 unless the error wraps a statusErr.

EXPECT returns an object that allows the caller to indicate expected use.

WorkKey returns a cache key for a work ID.

DoAndReturn rewrite *gomock.Call.DoAndReturn

Return rewrite *gomock.Call.Return

BookKey returns a cache key for a book (edition) ID.

Do rewrite *gomock.Call.Do

GetAuthor loads an author or returns a cached value if one exists.

AuthorKey returns a cache key for an author ID.

GetWork gets the work with the given ID. A work is an abstract collection of editions. The saveEditions callback can be invoked if the work can be loa

GetWork loads a work or returns a cached value if one exists.

MakeRequest mocks base method.

newMemoryCache returns a new in-memory cache.

bool should be true if data was found.

NewController creates a new controller. Background jobs to load author works and editions is bounded to at most 10 concurrent tasks.

GetBook loads a book (edition) or returns a cached value if one exists. TODO: This should only return a book!

AsContributions maps a slice of Contributions fragments into... a slice of Contributions fragments. I must not be thinking clearly because this seems

GetBook gets an individual edition of a work. The saveEditions callback can be invoked if the edition can be loaded with other editions in one request

cacheFor sets cache response headers. s-maxage controls CDN cache time; we default to an hour expiry for clients. Set varyParams to true if the cache

len returns the number of children currently waiting in the buffer.

Returns a serialized Work?? GetAuthor gets an author's details. A serialized AuthorResource is returned.

fuzz scales the given duration into the range (d, d * f).

NewCache constructs a new layered cache.

NewMockgetter creates a new mock instance.

denormalizeWorks ensures that the given works exist on the author. This is a no-op if our cached work already includes the work's ID. This is meant to

DSN returns the database's DSN based on the provided flags.

Returns book/edition IDs, not works. GetSeries returns a list of works contained in a series. The works may not all be by the same author.

NewBatchedGraphQLClient creates a batching GraphQL client. Queries are accumulated and executed regularly accurding to the given rate.

add extends the current query with a new field. The field's alias and name are returned so they can be recovered later.

Delete records an in-flight refresh as completed.

NewMetrics creates a new Rrometheus registry with default collectors already registered.

Persist records an author's refresh as in-flight.

RoundTrip forces the request to stick to the given host, so redirects can't send us elsewhere. Helpful to ensuring credentials don't leak to other dom

Search performs a natural language query against the upstream (or other search index). A serialied searchResource is returned.

accumulate reads values produced by the consumer into an in-memory buffer. A channel is returned which provides those buffered values for consumption.

gqlStatusErr translates errors into meaningful status codes. The client normally returns error responses with a 200 OK status code and a populated "Er

Cache returns the cloudflare cache, if it was configured, or nil otherwise.

Get returns a cache value, if it exists, and a boolean if a value was found.

GetBook fetches a book (edition) from GR.

MakeRequest implements graphql.Client.

NewGRGQL returns a new GraphQL client for use with GR. The provided [http.Client] must be non-nil and is used for issuing requests. If a non-empty coo

NewGRGetter creates a new Getter backed by G——R——.

NewHandler creates a new handler.

NewHardcoverGetter returns a new Getter backed by Hardcover.

NewMux registers a handler's routes on a new mux.

NewPersister creates a new Persister.

Recommendations returns a list of work IDs which are trending or popular. Eventually we may consider implementing OAuth in order to return custom-tail

Search hits the auto_complete API that has been used historically, so it returns exactly the same results as legacy.

Shutdown waits for all refresh and denormalization goroutines to finish submitting their work and then closes the denormalization channel. Run will ru

Build returns the merged query string and variables map.

denormalizeEditions ensures that the given editions exists on the work. It deserializes the target work once. (TODO: No-op if it includes an edition w

newQueryBuilder initializes a new QueryBuilder with an empty Document.

normalizePattern derives the constant label from the pattern: "/author/{foreignAuthorID}" → "/author" "/book/bulk" → "/book/bulk"

releaseDate parses a G— float into a formatted time R— can work with. TODO: We might be able to omit the month/day and have R use just the year?

EXPECT returns an object that allows the caller to indicate expected use.

GetASIN returns the best known edition ID for the given ASIN, or a not found error if there is none.

GetBook looks up a GR book (edition) in Hardcover's mappings.

GetISBN returns the best known edition ID for the given ISBN13, or a not found error if there is none.

NewMockgql creates a new mock instance.

NewUpstream creates a new http.Client with middleware appropriate for use with an upstream.

Persisted returns all in-flight author refreshes so they can be resumed. IDs are returned in FIFO order.

SetLogLevel sets the log level.

Wrap applies middleware.