import git from 'isomorphic-git';
import { HttpClient } from 'isomorphic-git/http/node';

import { bodyToBuffer } from './util';
import { Pointer } from './pointers';


interface DownloadBlobRequset {
  http: HttpClient;
  headers?: Record<string, any>;

  /** Repository URL. */
  url: string;
}

interface LFSInfoResponse {
  objects: {
    actions: {
      download: {
        href: string;
      };
    };
  }[];
}

function isValidLFSInfoResponseData(val: Record<string, any>): val is LFSInfoResponse {
  return val.objects?.[0]?.actions?.download?.href?.trim !== undefined;
}


/** Downloads a blob corresponding to given LFS pointer. */
export default async function downloadBlobFromPointer(
  { http: { request }, headers = {}, url }: DownloadBlobRequset,
  { info, objectPath }: Pointer,
): Promise<Buffer> {

  // Request LFS metadata

  const lfsInfoRequestData = {
    operation: 'download',
    transfers: ['basic'],
    objects: [info],
  };

  const { body: lfsInfoBody } = await request({
    url: `${url}/info/lfs/objects/batch`,
    method: 'POST',
    headers: {
      // Github LFS doesn’t seem to accept this UA :(
      // 'User-Agent': `git/isomorphic-git@${git.version()}`,
      ...headers,
      'Accept': 'application/vnd.git-lfs+json',
      'Content-Type': 'application/vnd.git-lfs+json',
    },
    body: [Buffer.from(JSON.stringify(lfsInfoRequestData))],
  });

  const lfsInfoResponseData = JSON.parse((await bodyToBuffer(lfsInfoBody)).toString());

  if (isValidLFSInfoResponseData(lfsInfoResponseData)) {

    // Request the actual blob

    const lfsObjectDownloadURL = lfsInfoResponseData.objects[0].actions.download.href;

    const { body: lfsObjectBody } = await request({
      url: lfsObjectDownloadURL,
      method: 'GET',
      headers,
    });

    return await bodyToBuffer(lfsObjectBody);

  } else {
    throw new Error("LFS response didn’t return an expected structure");
  }
}