import { ApolloClient, InMemoryCache, HttpLink } from '@apollo/client' import { decodeCursor, LIMIT } from './cursor' import { SSR } from './constants' function isFirstPage (cursor, existingThings, limit = LIMIT) { if (cursor) { const decursor = decodeCursor(cursor) return decursor.offset === limit } else { // we don't have anything cached, or our existing items are less than // or equal to a full page return existingThings?.length < limit } } const defaultFetchPolicy = SSR ? 'cache-only' : 'cache-first' const defaultNextFetchPolicy = SSR ? 'cache-only' : 'cache-first' export default function getApolloClient () { if (SSR) { return getClient(`${process.env.SELF_URL}/api/graphql`) } else { window.apolloClient ||= getClient('/api/graphql') return window.apolloClient } } function getClient (uri) { return new ApolloClient({ link: new HttpLink({ uri }), ssrMode: SSR, connectToDevTools: process.env.NODE_ENV !== 'production', cache: new InMemoryCache({ freezeResults: true, typePolicies: { Sub: { keyFields: ['name'], fields: { optional: { merge: true } } }, User: { // https://www.apollographql.com/docs/react/caching/cache-field-behavior/#merging-non-normalized-objects fields: { privates: { merge: true }, optional: { merge: true } } }, Fact: { keyFields: ['id', 'type'] }, Query: { fields: { sub: { keyArgs: ['name'], merge (existing, incoming) { return incoming } }, topSubs: { keyArgs: ['when', 'by', 'from', 'to', 'limit'], merge (existing, incoming, { args }) { if (isFirstPage(incoming.cursor, existing?.subs, args.limit)) { return incoming } return { cursor: incoming.cursor, subs: [...(existing?.subs || []), ...incoming.subs] } } }, topUsers: { keyArgs: ['when', 'by', 'from', 'to', 'limit'], merge (existing, incoming, { args }) { if (isFirstPage(incoming.cursor, existing?.users, args.limit)) { return incoming } return { cursor: incoming.cursor, users: [...(existing?.users || []), ...incoming.users] } } }, mySubscribedUsers: { keyArgs: false, merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.users)) { return incoming } return { cursor: incoming.cursor, users: [...(existing?.users || []), ...incoming.users] } } }, myMutedUsers: { keyArgs: false, merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.users)) { return incoming } return { cursor: incoming.cursor, users: [...(existing?.users || []), ...incoming.users] } } }, userSuggestions: { keyArgs: ['q', 'limit'], merge (existing, incoming) { return incoming } }, topCowboys: { keyArgs: [], merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.users)) { return incoming } return { cursor: incoming.cursor, users: [...(existing?.users || []), ...incoming.users] } } }, items: { keyArgs: ['sub', 'sort', 'type', 'name', 'when', 'by', 'from', 'to', 'limit'], merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.items)) { return incoming } return { cursor: incoming.cursor, items: [...(existing?.items || []), ...incoming.items], pins: [...(existing?.pins || []), ...(incoming.pins || [])] } } }, comments: { keyArgs: ['id', 'sort'], merge (existing, incoming) { return incoming } }, related: { keyArgs: ['id', 'title', 'minMatch', 'limit'], merge (existing, incoming, { args }) { if (isFirstPage(incoming.cursor, existing?.items, args.limit)) { return incoming } return { cursor: incoming.cursor, items: [...(existing?.items || []), ...incoming.items] } } }, search: { keyArgs: ['q', 'sub', 'sort', 'what', 'when', 'from', 'to', 'limit'], merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.items)) { return incoming } return { cursor: incoming.cursor, items: [...(existing?.items || []), ...incoming.items] } } }, searchUsers: { keyArgs: ['q', 'limit', 'similarity'], merge (existing, incoming) { return [...(existing?.searchUsers || []), ...incoming] } }, notifications: { keyArgs: ['inc'], merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.notifications)) { return incoming } return { cursor: incoming.cursor, earn: existing?.earn || incoming.earn, notifications: [...(existing?.notifications || []), ...incoming.notifications], lastChecked: existing?.lastChecked || incoming.lastChecked } } }, numBolt11s: { keyArgs: [], merge (existing, incoming) { return incoming } }, walletHistory: { keyArgs: ['inc'], merge (existing, incoming) { if (isFirstPage(incoming.cursor, existing?.facts)) { return incoming } return { cursor: incoming.cursor, facts: [...(existing?.facts || []), ...incoming.facts] } } } } }, Item: { fields: { meAnonSats: { read (meAnonSats, { readField }) { if (typeof window === 'undefined') return null const itemId = readField('id') return meAnonSats ?? Number(window.localStorage.getItem(`TIP-item:${itemId}`) || '0') } } } } } }), assumeImmutableResults: true, queryDeduplication: true, defaultOptions: { watchQuery: { initialFetchPolicy: defaultFetchPolicy, fetchPolicy: defaultFetchPolicy, nextFetchPolicy: defaultNextFetchPolicy, canonizeResults: true, ssr: SSR }, query: { initialFetchPolicy: defaultFetchPolicy, fetchPolicy: defaultFetchPolicy, nextFetchPolicy: defaultNextFetchPolicy, canonizeResults: true, ssr: SSR } } }) }