Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
3.5 kB · 126 lines
TSX
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127import { place } from "streamplace";import { getStreamplaceStoreFromContext, useDID, useStreamplaceStore,} from "./streamplace-store";import { usePDSAgent } from "./xrpc";
export function useGetChatProfile() { const did = useDID(); const pdsAgent = usePDSAgent(); const store = getStreamplaceStoreFromContext(); const createEmptyChatProfile = useCreateEmptyChatProfile();
return async () => { if (!did || !pdsAgent) { throw new Error("No DID or PDS agent"); } let res: any; let notFound = false; try { res = await pdsAgent.client.get(place.stream.chat.profile, { repo: did as any, rkey: "self", }); } catch (e) { // if the record is a 400 with "Record not found", then we want to create an empty chat profile if ( e.error.status === 400 && e.error.data?.error.includes("Record not found") ) { notFound = true; } else { console.error("Failed to get chat profile record", e); } } if (notFound || !res) { try { await createEmptyChatProfile(); res = await pdsAgent.client.get(place.stream.chat.profile, { repo: did as any, rkey: "self", }); } catch (e) { console.error("Failed to create empty chat profile record", e); } }
// if no response, assume some fluke happened and just return without setting state if (res === undefined) { console.error("No response from get or create chat profile"); return; }
if (place.stream.chat.profile.$isTypeOf(res.value)) { store.setState({ chatProfile: res.value }); } else { console.log("not a record", res.value); } };}
export function useCreateEmptyChatProfile() { const did = useDID(); const pdsAgent = usePDSAgent();
return async () => { if (!did || !pdsAgent) { throw new Error("No DID or PDS agent"); } await pdsAgent.client.put( place.stream.chat.profile, { color: DEFAULT_COLORS[Math.floor(Math.random() * DEFAULT_COLORS.length)], }, { repo: did as any, rkey: "self" }, ); };}
export function useGetBskyProfile() { const did = useDID(); const pdsAgent = usePDSAgent(); const store = getStreamplaceStoreFromContext();
return async () => { if (!did || !pdsAgent) { throw new Error("No DID or PDS agent"); } const res = await pdsAgent.app.bsky.actor.getProfile({ actor: did, }); if (!res.success) { throw new Error("Failed to get chat profile record"); }
store.setState({ handle: res.data.handle }); };}
export function useChatProfile() { return useStreamplaceStore((x) => x.chatProfile);}
const DEFAULT_COLORS: place.stream.chat.profile.Color[] = [ { red: 244, green: 67, blue: 54 }, { red: 233, green: 30, blue: 99 }, { red: 156, green: 39, blue: 176 }, { red: 103, green: 58, blue: 183 }, { red: 63, green: 81, blue: 181 }, { red: 33, green: 150, blue: 243 }, { red: 3, green: 169, blue: 244 }, { red: 0, green: 188, blue: 212 }, { red: 0, green: 150, blue: 136 }, { red: 76, green: 175, blue: 80 }, { red: 139, green: 195, blue: 74 }, { red: 205, green: 220, blue: 57 }, { red: 255, green: 235, blue: 59 }, { red: 255, green: 193, blue: 7 }, { red: 255, green: 152, blue: 0 }, { red: 255, green: 87, blue: 34 }, { red: 121, green: 85, blue: 72 }, { red: 158, green: 158, blue: 158 }, { red: 96, green: 125, blue: 139 },];