const { createClient } = require("@supabase/supabase-js");

const OLD_PROJECT_URL = "https://xxx.supabase.co";
const OLD_PROJECT_SERVICE_KEY = "old-project-service-key-xxx";

const NEW_PROJECT_URL = "https://yyy.supabase.co";
const NEW_PROJECT_SERVICE_KEY = "new-project-service-key-yyy";

(async () => {
  const oldSupabaseRestClient = createClient(
    OLD_PROJECT_URL,
    OLD_PROJECT_SERVICE_KEY,
    { schema: "storage" }
  );
  const oldSupabaseClient = createClient(
    OLD_PROJECT_URL,
    OLD_PROJECT_SERVICE_KEY
  );
  const newSupabaseClient = createClient(
    NEW_PROJECT_URL,
    NEW_PROJECT_SERVICE_KEY
  );

  // make sure you update max_rows in postgrest settings if you have a lot of objects
  // or paginate here
  const { data: oldObjects, error } = await oldSupabaseRestClient
    .from("objects")
    .select();
  if (error) {
    console.log("error getting objects from old bucket");
    throw error;
  }

  for (const objectData of oldObjects) {
    console.log(`moving ${objectData.id}`);
    try {
      const { data, error: downloadObjectError } =
        await oldSupabaseClient.storage
          .from(objectData.bucket_id)
          .download(objectData.name);
      if (downloadObjectError) {
        throw downloadObjectError;
      }

      const { _, error: uploadObjectError } = await newSupabaseClient.storage
        .from(objectData.bucket_id)
        .upload(objectData.name, data, {
          upsert: true,
          contentType: objectData.metadata.mimetype,
          cacheControl: objectData.metadata.cacheControl,
        });
      if (uploadObjectError) {
        throw uploadObjectError;
      }
    } catch (err) {
      console.log("error moving ", objectData);
      console.log(err);
    }
  }
})();