import { WorkflowError } from '../../utils/errors.js';
import { addressSchema, throwIfMissing } from '../../utils/validators.js';
import { TransferParams, TransferResponse } from '../types/index.js';
import { IExecConsumer } from '../types/internalTypes.js';

export const transferOwnership = async ({
  iexec = throwIfMissing(),
  protectedData,
  newOwner,
}: IExecConsumer & TransferParams): Promise<TransferResponse> => {
  const vProtectedData = addressSchema()
    .required()
    .label('protectedData')
    .validateSync(protectedData);
  const vNewOwner = addressSchema()
    .required()
    .label('newOwner')
    .validateSync(newOwner);

  return iexec.dataset.transferDataset(vProtectedData, vNewOwner).catch((e) => {
    throw new WorkflowError({
      message: 'Failed to transfer protectedData ownership',
      errorCause: e,
    });
  });
};