Media-Aggregation-and-Sorting-System/TEST/testGooglePhotosAPI.js

const PICKER_BASE = 'https://photospicker.googleapis.com/v1';
const USERINFO_URL = 'https://www.googleapis.com/oauth2/v2/userinfo';

function delay(ms) { return new Promise((r) => setTimeout(r, ms)); }

async function main() {
  const token = process.argv[2] || process.env.GOOGLE_ACCESS_TOKEN;

  if (!token) {
    console.error('\nNo access token provided.');
    console.error('Usage:  node TEST/testGooglePhotosAPI.js <ACCESS_TOKEN>');
    console.error('Or set: GOOGLE_ACCESS_TOKEN=ya29.xxx node TEST/testGooglePhotosAPI.js');
    console.error('\nTo obtain a token go to https://developers.google.com/oauthplayground');
    console.error('and authorise the photospicker.mediaitems.readonly scope.\n');
    process.exit(1);
  }

  const headers = { Authorization: `Bearer ${token}` };

  console.log('\n--- Google Photos Picker API Test ---\n');

  console.log('[1] Fetching user info...');
  try {
    const res = await fetch(USERINFO_URL, { headers });
    if (!res.ok) {
      console.log(`    Failed: HTTP ${res.status}: ${await res.text()}\n`);
    } else {
      const user = await res.json();
      console.log(`    Authenticated as: ${user.email} (${user.name})\n`);
    }
  } catch (err) {
    console.log(`    Failed: ${err.message}\n`);
  }

  console.log('[2] Creating Picker session...');
  let sessionId = null;
  try {
    const res = await fetch(`${PICKER_BASE}/sessions`, {
      method: 'POST',
      headers: { ...headers, 'Content-Type': 'application/json' },
      body: JSON.stringify({}),
    });
    if (!res.ok) {
      console.log(`    Failed: HTTP ${res.status}: ${await res.text()}\n`);
    } else {
      const session = await res.json();
      sessionId = session.id;
      console.log(`    Session created: ${sessionId}`);
      console.log(`    mediaItemsSet: ${session.mediaItemsSet}\n`);

      if (!session.mediaItemsSet) {
        console.log('    Waiting for session to become ready...');
        for (let i = 0; i < 10; i++) {
          await delay(1500);
          const pollRes = await fetch(`${PICKER_BASE}/sessions/${sessionId}`, { headers });
          const pollData = await pollRes.json();
          if (pollData.mediaItemsSet) {
            console.log('    Session is ready!\n');
            break;
          }
          if (i === 9) console.log('    Session timed out.\n');
        }
      }
    }
  } catch (err) {
    console.log(`    Failed: ${err.message}\n`);
  }

  if (sessionId) {
    console.log('[3] Fetching media items from session...');
    try {
      const params = new URLSearchParams({ sessionId, pageSize: '10' });
      const res = await fetch(`${PICKER_BASE}/mediaItems?${params.toString()}`, { headers });
      if (!res.ok) {
        console.log(`    Failed: HTTP ${res.status}: ${await res.text()}\n`);
      } else {
        const data = await res.json();
        const items = data.mediaItems || [];
        console.log(`    Found ${items.length} items`);
        items.slice(0, 5).forEach((item, i) => {
          const file = item.mediaFile || {};
          console.log(`    ${i + 1}. ${file.filename || '(no name)'}  (${file.mimeType || '?'})`);
        });
        if (items.length > 5) console.log(`    ... and ${items.length - 5} more`);
        if (data.nextPageToken) console.log('    More pages available');
        console.log();
      }
    } catch (err) {
      console.log(`    Failed: ${err.message}\n`);
    }
  }

  console.log('--- Tests complete ---\n');
}

main().catch((err) => {
  console.error('Unhandled error:', err);
  process.exit(1);
});