import { 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 },
];