import type { NoOptionI18nKeys } from "i18next"; import { Component, linkEvent } from "inferno"; import { CommentResponse, CommentView, CommunityView, GetCommunity, GetCommunityResponse, GetPersonDetails, GetPersonDetailsResponse, GetSiteResponse, ListCommunities, ListCommunitiesResponse, ListingType, PersonView, PostResponse, PostView, ResolveObject, ResolveObjectResponse, Search as SearchForm, SearchResponse, SearchType, SortType, UserOperation, wsJsonToRes, wsUserOp, } from "lemmy-js-client"; import { Subscription } from "rxjs"; import { i18n } from "../i18next"; import { CommentViewType, InitialFetchRequest } from "../interfaces"; import { WebSocketService } from "../services"; import { Choice, QueryParams, WithPromiseKeys, capitalizeFirstLetter, commentsToFlatNodes, communityToChoice, createCommentLikeRes, createPostLikeFindRes, debounce, enableDownvotes, enableNsfw, fetchCommunities, fetchLimit, fetchUsers, getIdFromString, getPageFromString, getQueryParams, getQueryString, getUpdatedSearchId, myAuth, numToSI, personToChoice, restoreScrollPosition, saveScrollPosition, setIsoData, showLocal, toast, wsClient, wsSubscribe, } from "../utils"; import { CommentNodes } from "./comment/comment-nodes"; import { HtmlTags } from "./common/html-tags"; import { Spinner } from "./common/icon"; import { ListingTypeSelect } from "./common/listing-type-select"; import { Paginator } from "./common/paginator"; import { SearchableSelect } from "./common/searchable-select"; import { SortSelect } from "./common/sort-select"; import { CommunityLink } from "./community/community-link"; import { PersonListing } from "./person/person-listing"; import { PostListing } from "./post/post-listing"; interface SearchProps { q?: string; type: SearchType; sort: SortType; listingType: ListingType; communityId?: number | null; creatorId?: number | null; page: number; } interface SearchData { communityResponse?: GetCommunityResponse; listCommunitiesResponse?: ListCommunitiesResponse; creatorDetailsResponse?: GetPersonDetailsResponse; searchResponse?: SearchResponse; resolveObjectResponse?: ResolveObjectResponse; } type FilterType = "creator" | "community"; interface SearchState { searchResponse?: SearchResponse; communities: CommunityView[]; creatorDetails?: GetPersonDetailsResponse; searchLoading: boolean; searchCommunitiesLoading: boolean; searchCreatorLoading: boolean; siteRes: GetSiteResponse; searchText?: string; resolveObjectResponse?: ResolveObjectResponse; communitySearchOptions: Choice[]; creatorSearchOptions: Choice[]; } interface Combined { type_: string; data: CommentView | PostView | CommunityView | PersonView; published: string; } const defaultSearchType = "All"; const defaultSortType = "TopAll"; const defaultListingType = "All"; const searchTypes = ["All", "Comments", "Posts", "Communities", "Users", "Url"]; const getSearchQueryParams = () => getQueryParams({ q: getSearchQueryFromQuery, type: getSearchTypeFromQuery, sort: getSortTypeFromQuery, listingType: getListingTypeFromQuery, communityId: getIdFromString, creatorId: getIdFromString, page: getPageFromString, }); const getSearchQueryFromQuery = (q?: string): string | undefined => q ? decodeURIComponent(q) : undefined; function getSearchTypeFromQuery(type_?: string): SearchType { return type_ ? (type_ as SearchType) : defaultSearchType; } function getSortTypeFromQuery(sort?: string): SortType { return sort ? (sort as SortType) : defaultSortType; } function getListingTypeFromQuery(listingType?: string): ListingType { return listingType ? (listingType as ListingType) : defaultListingType; } function postViewToCombined(data: PostView): Combined { return { type_: "posts", data, published: data.post.published, }; } function commentViewToCombined(data: CommentView): Combined { return { type_: "comments", data, published: data.comment.published, }; } function communityViewToCombined(data: CommunityView): Combined { return { type_: "communities", data, published: data.community.published, }; } function personViewSafeToCombined(data: PersonView): Combined { return { type_: "users", data, published: data.person.published, }; } const Filter = ({ filterType, options, onChange, onSearch, value, loading, }: { filterType: FilterType; options: Choice[]; onSearch: (text: string) => void; onChange: (choice: Choice) => void; value?: number | null; loading: boolean; }) => { return (
); }; const communityListing = ({ community, counts: { subscribers }, }: CommunityView) => getListing( , subscribers, "number_of_subscribers" ); const personListing = ({ person, counts: { comment_count } }: PersonView) => getListing( , comment_count, "number_of_comments" ); function getListing( listing: JSX.ElementClass, count: number, translationKey: "number_of_comments" | "number_of_subscribers" ) { return ( <> {listing} {` - ${i18n.t(translationKey, { count: Number(count), formattedCount: numToSI(count), })}`} ); } export class Search extends Component { private isoData = setIsoData(this.context); private subscription?: Subscription; state: SearchState = { searchLoading: false, siteRes: this.isoData.site_res, communities: [], searchCommunitiesLoading: false, searchCreatorLoading: false, creatorSearchOptions: [], communitySearchOptions: [], }; constructor(props: any, context: any) { super(props, context); this.handleSortChange = this.handleSortChange.bind(this); this.handleListingTypeChange = this.handleListingTypeChange.bind(this); this.handlePageChange = this.handlePageChange.bind(this); this.handleCommunityFilterChange = this.handleCommunityFilterChange.bind(this); this.handleCreatorFilterChange = this.handleCreatorFilterChange.bind(this); this.parseMessage = this.parseMessage.bind(this); this.subscription = wsSubscribe(this.parseMessage); const { q } = getSearchQueryParams(); this.state = { ...this.state, searchText: q, }; // Only fetch the data if coming from another route if (this.isoData.path === this.context.router.route.match.url) { const { communityResponse, creatorDetailsResponse, listCommunitiesResponse, resolveObjectResponse, searchResponse, } = this.isoData.routeData; // This can be single or multiple communities given if (listCommunitiesResponse) { this.state = { ...this.state, communities: listCommunitiesResponse.communities, }; } if (communityResponse) { this.state = { ...this.state, communities: [communityResponse.community_view], communitySearchOptions: [ communityToChoice(communityResponse.community_view), ], }; } this.state = { ...this.state, creatorDetails: creatorDetailsResponse, creatorSearchOptions: creatorDetailsResponse ? [personToChoice(creatorDetailsResponse.person_view)] : [], }; if (q !== "") { this.state = { ...this.state, searchResponse, resolveObjectResponse, searchLoading: false, }; } else { this.search(); } } else { const listCommunitiesForm: ListCommunities = { type_: defaultListingType, sort: defaultSortType, limit: fetchLimit, auth: myAuth(false), }; WebSocketService.Instance.send( wsClient.listCommunities(listCommunitiesForm) ); if (q) { this.search(); } } } componentWillUnmount() { this.subscription?.unsubscribe(); saveScrollPosition(this.context); } static fetchInitialData({ client, auth, query: { communityId, creatorId, q, type, sort, listingType, page }, }: InitialFetchRequest< QueryParams >): WithPromiseKeys { const community_id = getIdFromString(communityId); let communityResponse: Promise | undefined = undefined; let listCommunitiesResponse: Promise | undefined = undefined; if (community_id) { const getCommunityForm: GetCommunity = { id: community_id, auth, }; communityResponse = client.getCommunity(getCommunityForm); } else { const listCommunitiesForm: ListCommunities = { type_: defaultListingType, sort: defaultSortType, limit: fetchLimit, auth, }; listCommunitiesResponse = client.listCommunities(listCommunitiesForm); } const creator_id = getIdFromString(creatorId); let creatorDetailsResponse: Promise | undefined = undefined; if (creator_id) { const getCreatorForm: GetPersonDetails = { person_id: creator_id, auth, }; creatorDetailsResponse = client.getPersonDetails(getCreatorForm); } const query = getSearchQueryFromQuery(q); let searchResponse: Promise | undefined = undefined; let resolveObjectResponse: | Promise | undefined = undefined; if (query) { const form: SearchForm = { q: query, community_id, creator_id, type_: getSearchTypeFromQuery(type), sort: getSortTypeFromQuery(sort), listing_type: getListingTypeFromQuery(listingType), page: getPageFromString(page), limit: fetchLimit, auth, }; if (query !== "") { searchResponse = client.search(form); if (auth) { const resolveObjectForm: ResolveObject = { q: query, auth, }; resolveObjectResponse = client .resolveObject(resolveObjectForm) .catch(() => undefined); } } } return { communityResponse, creatorDetailsResponse, listCommunitiesResponse, resolveObjectResponse, searchResponse, }; } get documentTitle(): string { const { q } = getSearchQueryParams(); const name = this.state.siteRes.site_view.site.name; return `${i18n.t("search")} - ${q ? `${q} - ` : ""}${name}`; } render() { const { type, page } = getSearchQueryParams(); return (
{i18n.t("search")}
{this.selects} {this.searchForm} {this.displayResults(type)} {this.resultsCount === 0 && !this.state.searchLoading && ( {i18n.t("no_results")} )}
); } displayResults(type: SearchType) { switch (type) { case "All": return this.all; case "Comments": return this.comments; case "Posts": case "Url": return this.posts; case "Communities": return this.communities; case "Users": return this.users; default: return <>; } } get searchForm() { return (
); } get selects() { const { type, listingType, sort, communityId, creatorId } = getSearchQueryParams(); const { communitySearchOptions, creatorSearchOptions, searchCommunitiesLoading, searchCreatorLoading, } = this.state; return (
{this.state.communities.length > 0 && ( )}
); } buildCombined(): Combined[] { const combined: Combined[] = []; const { resolveObjectResponse, searchResponse } = this.state; // Push the possible resolve / federated objects first if (resolveObjectResponse) { const { comment, post, community, person } = resolveObjectResponse; if (comment) { combined.push(commentViewToCombined(comment)); } if (post) { combined.push(postViewToCombined(post)); } if (community) { combined.push(communityViewToCombined(community)); } if (person) { combined.push(personViewSafeToCombined(person)); } } // Push the search results if (searchResponse) { const { comments, posts, communities, users } = searchResponse; combined.push( ...[ ...(comments?.map(commentViewToCombined) ?? []), ...(posts?.map(postViewToCombined) ?? []), ...(communities?.map(communityViewToCombined) ?? []), ...(users?.map(personViewSafeToCombined) ?? []), ] ); } const { sort } = getSearchQueryParams(); // Sort it if (sort === "New") { combined.sort((a, b) => b.published.localeCompare(a.published)); } else { combined.sort((a, b) => Number( ((b.data as CommentView | PostView).counts.score | (b.data as CommunityView).counts.subscribers | (b.data as PersonView).counts.comment_score) - ((a.data as CommentView | PostView).counts.score | (a.data as CommunityView).counts.subscribers | (a.data as PersonView).counts.comment_score) ) ); } return combined; } get all() { const combined = this.buildCombined(); return (
{combined.map(i => (
{i.type_ === "posts" && ( )} {i.type_ === "comments" && ( )} {i.type_ === "communities" && (
{communityListing(i.data as CommunityView)}
)} {i.type_ === "users" && (
{personListing(i.data as PersonView)}
)}
))}
); } get comments() { const { searchResponse, resolveObjectResponse, siteRes } = this.state; const comments = searchResponse?.comments ?? []; if (resolveObjectResponse?.comment) { comments.unshift(resolveObjectResponse?.comment); } return ( ); } get posts() { const { searchResponse, resolveObjectResponse, siteRes } = this.state; const posts = searchResponse?.posts ?? []; if (resolveObjectResponse?.post) { posts.unshift(resolveObjectResponse.post); } return ( <> {posts.map(pv => (
))} ); } get communities() { const { searchResponse, resolveObjectResponse } = this.state; const communities = searchResponse?.communities ?? []; if (resolveObjectResponse?.community) { communities.unshift(resolveObjectResponse.community); } return ( <> {communities.map(cv => (
{communityListing(cv)}
))} ); } get users() { const { searchResponse, resolveObjectResponse } = this.state; const users = searchResponse?.users ?? []; if (resolveObjectResponse?.person) { users.unshift(resolveObjectResponse.person); } return ( <> {users.map(pvs => (
{personListing(pvs)}
))} ); } get resultsCount(): number { const { searchResponse: r, resolveObjectResponse: resolveRes } = this.state; const searchCount = r ? r.posts.length + r.comments.length + r.communities.length + r.users.length : 0; const resObjCount = resolveRes ? resolveRes.post || resolveRes.person || resolveRes.community || resolveRes.comment ? 1 : 0 : 0; return resObjCount + searchCount; } search() { const auth = myAuth(false); const { searchText: q } = this.state; const { communityId, creatorId, type, sort, listingType, page } = getSearchQueryParams(); if (q && q !== "") { const form: SearchForm = { q, community_id: communityId ?? undefined, creator_id: creatorId ?? undefined, type_: type, sort, listing_type: listingType, page, limit: fetchLimit, auth, }; if (auth) { const resolveObjectForm: ResolveObject = { q, auth, }; WebSocketService.Instance.send( wsClient.resolveObject(resolveObjectForm) ); } this.setState({ searchResponse: undefined, resolveObjectResponse: undefined, searchLoading: true, }); WebSocketService.Instance.send(wsClient.search(form)); } } handleCreatorSearch = debounce(async (text: string) => { const { creatorId } = getSearchQueryParams(); const { creatorSearchOptions } = this.state; this.setState({ searchCreatorLoading: true, }); const newOptions: Choice[] = []; const selectedChoice = creatorSearchOptions.find( choice => getIdFromString(choice.value) === creatorId ); if (selectedChoice) { newOptions.push(selectedChoice); } if (text.length > 0) { newOptions.push(...(await fetchUsers(text)).users.map(personToChoice)); } this.setState({ searchCreatorLoading: false, creatorSearchOptions: newOptions, }); }); handleCommunitySearch = debounce(async (text: string) => { const { communityId } = getSearchQueryParams(); const { communitySearchOptions } = this.state; this.setState({ searchCommunitiesLoading: true, }); const newOptions: Choice[] = []; const selectedChoice = communitySearchOptions.find( choice => getIdFromString(choice.value) === communityId ); if (selectedChoice) { newOptions.push(selectedChoice); } if (text.length > 0) { newOptions.push( ...(await fetchCommunities(text)).communities.map(communityToChoice) ); } this.setState({ searchCommunitiesLoading: false, communitySearchOptions: newOptions, }); }); handleSortChange(sort: SortType) { this.updateUrl({ sort, page: 1 }); } handleTypeChange(i: Search, event: any) { const type = event.target.value as SearchType; i.updateUrl({ type, page: 1, }); } handlePageChange(page: number) { this.updateUrl({ page }); } handleListingTypeChange(listingType: ListingType) { this.updateUrl({ listingType, page: 1, }); } handleCommunityFilterChange({ value }: Choice) { this.updateUrl({ communityId: getIdFromString(value) ?? null, page: 1, }); } handleCreatorFilterChange({ value }: Choice) { this.updateUrl({ creatorId: getIdFromString(value) ?? null, page: 1, }); } handleSearchSubmit(i: Search, event: any) { event.preventDefault(); i.updateUrl({ q: i.state.searchText, page: 1, }); } handleQChange(i: Search, event: any) { i.setState({ searchText: event.target.value }); } updateUrl({ q, type, listingType, sort, communityId, creatorId, page, }: Partial) { const { q: urlQ, type: urlType, listingType: urlListingType, communityId: urlCommunityId, sort: urlSort, creatorId: urlCreatorId, page: urlPage, } = getSearchQueryParams(); let query = q ?? this.state.searchText ?? urlQ; if (query && query.length > 0) { query = encodeURIComponent(query); } const queryParams: QueryParams = { q: query, type: type ?? urlType, listingType: listingType ?? urlListingType, communityId: getUpdatedSearchId(communityId, urlCommunityId), creatorId: getUpdatedSearchId(creatorId, urlCreatorId), page: (page ?? urlPage).toString(), sort: sort ?? urlSort, }; this.props.history.push(`/search${getQueryString(queryParams)}`); this.search(); } parseMessage(msg: any) { console.log(msg); const op = wsUserOp(msg); if (msg.error) { if (msg.error === "couldnt_find_object") { this.setState({ resolveObjectResponse: {}, }); this.checkFinishedLoading(); } else { toast(i18n.t(msg.error), "danger"); } } else { switch (op) { case UserOperation.Search: { const searchResponse = wsJsonToRes(msg); this.setState({ searchResponse }); window.scrollTo(0, 0); this.checkFinishedLoading(); restoreScrollPosition(this.context); break; } case UserOperation.CreateCommentLike: { const { comment_view } = wsJsonToRes(msg); createCommentLikeRes( comment_view, this.state.searchResponse?.comments ); break; } case UserOperation.CreatePostLike: { const { post_view } = wsJsonToRes(msg); createPostLikeFindRes(post_view, this.state.searchResponse?.posts); break; } case UserOperation.ListCommunities: { const { communities } = wsJsonToRes(msg); this.setState({ communities }); break; } case UserOperation.ResolveObject: { const resolveObjectResponse = wsJsonToRes(msg); this.setState({ resolveObjectResponse }); this.checkFinishedLoading(); break; } } } } checkFinishedLoading() { if (this.state.searchResponse || this.state.resolveObjectResponse) { this.setState({ searchLoading: false }); } } }