import { Accessor, JSX, createContext, createEffect, createSignal, useContext, createMemo } from "solid-js"; import { createStore } from 'solid-js/store' import { apiClient } from '../graphql/client/core' import { Author, AuthorFollows, Community, FollowingEntity, Topic } from "../graphql/schema/core.gen"; import { useSession } from './session' export type SubscriptionsData = { topics?: Topic[] authors?: Author[] communities?: Community[] } type SubscribeAction = { slug: string; type: 'subscribe' | 'unsubscribe' } interface FollowingContextType { loading: Accessor subscriptions: AuthorFollows setSubscriptions: (subscriptions: AuthorFollows) => void setFollowing: (what: FollowingEntity, slug: string, value: boolean) => void loadSubscriptions: () => void follow: (what: FollowingEntity, slug: string) => Promise unfollow: (what: FollowingEntity, slug: string) => Promise // followers: Accessor subscribeInAction?: Accessor } const FollowingContext = createContext() export function useFollowing() { return useContext(FollowingContext) } const EMPTY_SUBSCRIPTIONS: AuthorFollows = { topics: [], authors: [], communities: [], } export const FollowingProvider = (props: { children: JSX.Element }) => { const [loading, setLoading] = createSignal(false) const [subscriptions, setSubscriptions] = createStore(EMPTY_SUBSCRIPTIONS) const { session, author } = useSession() const [subscribeInAction, setSubscribeInAction] = createSignal() const fetchData = async () => { setLoading(true) try { if (apiClient.private) { console.debug('[context.following] fetching subs data...') const result = await apiClient.getAuthorFollows({ user: session()?.user.id }) setSubscriptions(result || EMPTY_SUBSCRIPTIONS) } } catch (error) { console.info('[context.following] cannot get subs', error) } finally { setLoading(false) } } createEffect(() => { console.info('[context.following] subs:', subscriptions); }) const follow = async (what: FollowingEntity, slug: string) => { if (!author()) return; setSubscribeInAction({ slug, type: 'subscribe' }); try { const subscriptionData = await apiClient.follow({ what, slug }); setSubscriptions((prevSubscriptions) => { if (!prevSubscriptions[what]) prevSubscriptions[what] = []; prevSubscriptions[what].push(subscriptionData); return prevSubscriptions; }); } catch (error) { console.error(error); } finally { setSubscribeInAction(); // Сбрасываем состояние действия подписки. } } const unfollow = async (what: FollowingEntity, slug: string) => { if (!author()) return setSubscribeInAction({ slug: slug, type: 'unsubscribe' }) try { await apiClient.unfollow({ what, slug }) } catch (error) { console.error(error) } finally { setSubscribeInAction() } } createEffect(() => { if (author()) { console.debug('[context.following] author update detect') fetchData() } }) const setFollowing = (what: FollowingEntity, slug: string, value = true) => { setSubscriptions((prevSubscriptions) => { const updatedSubs = { ...prevSubscriptions } if (!updatedSubs[what]) updatedSubs[what] = [] if (value) { const exists = updatedSubs[what]?.some((entity) => entity.slug === slug) if (!exists) updatedSubs[what].push(slug) } else { updatedSubs[what] = (updatedSubs[what] || []).filter((x) => x !== slug) } return updatedSubs }) try { ;(value ? follow : unfollow)(what, slug) } catch (error) { console.error(error) } finally { fetchData() } } const value: FollowingContextType = { loading, subscriptions, setSubscriptions, setFollowing, loadSubscriptions: fetchData, follow, unfollow, // followers, subscribeInAction, } return {props.children} }