test1.js

require('dotenv').config();
const auth=require("@adobe/jwt-auth");
const fetch = require('node-fetch');
const fs = require('fs');

const CLIENT_ID = process.env.CLIENTID;
const CLIENT_SECRET = process.env.CLIENTSECRET;
const TECHNICAL_ACCOUNT_ID = process.env.TECHNICALACCOUNTID;
const ORG_ID = process.env.ORGID;
const KEY = process.env.KEY;

/*
Root URL for all REST stuff
*/
const REST_API = "https://pdf-services.adobe.io/";


async function getAccessToken(creds) {

	creds.metaScopes = "https://ims-na1.adobelogin.com/s/ent_documentcloud_sdk";

	let result = await auth(creds);
	return result.access_token;
}

async function getUploadData(mediaType, clientId, token) {

	let body = {
		'mediaType': mediaType
	};
	body = JSON.stringify(body);

	let req = await fetch(REST_API+'/assets', {
		method:'post',
		headers: {
			'X-API-Key':clientId,
			'Authorization':`Bearer ${token}`,
			'Content-Type':'application/json'
		},
		body: body
	});

	let data = await req.json();
	return data;
}

async function uploadFile(url, filePath, mediaType) {

	let stream = fs.createReadStream(filePath);
	let stats = fs.statSync(filePath);
	let fileSizeInBytes = stats.size;

	let upload = await fetch(url, {
		method:'PUT', 
		redirect:'follow',
		headers: {
			'Content-Type':mediaType, 
			'Content-Length':fileSizeInBytes
		},
		body:stream
	});

	if(upload.status === 200) return;
	else {
		throw('Bad result, handle later.');
	}

}

async function createOCRJob(asset, clientId, token) {

	let body = {
		'assetID': asset 
	};
	body = JSON.stringify(body);

	let req = await fetch(REST_API+'operation/ocr', {
		method:'post',
		headers: {
			'X-API-Key':clientId,
			'Authorization':`Bearer ${token}`,
			'Content-Type':'application/json'
		},
		body: body
	});

	return req.headers.get('location');
}

// Lame function to add a delay to my polling calls
async function delay(x) {
	return new Promise(resolve => {
		setTimeout(() => resolve(), x);
	});
}

async function pollJob(url, clientId, token) {

	let status = null;
	let location; 

	while(status !== 'done') {
		let req = await fetch(url, {
			method:'GET',
			headers: {
				'X-API-Key':clientId,
				'Authorization':`Bearer ${token}`,
			}
		});

		let res = await req.json();
		status = res.status;
		console.log('Polling...');
		if(status === 'done') location = res.asset.downloadUri;
		else await delay(2000);
	}

	return location;
}

async function downloadFile(url, filePath) {
	let res = await fetch(url);
	let stream = fs.createWriteStream(filePath);
	await new Promise((resolve, reject) => {
		res.body.pipe(stream);
		res.body.on('error', reject);
		stream.on('finish', resolve);
	});
	return;
}

(async () => {


	// specifics for this demo
	let filePath = 'pdf_that_needs_ocr.pdf';
	let mediaType = 'application/pdf';
	let downloadPath = 'pdf_that_is_ocr.pdf';

	/*
	Step one - get an access token
	*/
	let accessToken = await getAccessToken({
		clientId:CLIENT_ID, 
		technicalAccountId:TECHNICAL_ACCOUNT_ID, 
		orgId:ORG_ID, 
		clientSecret:CLIENT_SECRET, 
		privateKey: KEY
	});
	console.log('Access token received.');

	/*
	Step two - get an upload URL/asset id
	*/
	let uploadData = await getUploadData(mediaType, CLIENT_ID, accessToken);
	console.log(`Upload URI and asset ID (${uploadData.assetID}) received.`);

	//console.log(uploadData.uploadUri);

	/*
	Step 3 - upload our file to the cloud storage provider.
	*/

	console.log(`Sending ${filePath} to cloud provider.`);
	await uploadFile(uploadData.uploadUri, filePath, mediaType);
	console.log('File uploaded to cloud provider.');

	/*
	Step 4 - create the OCR job.
	*/
	let job = await createOCRJob(uploadData.assetID, CLIENT_ID, accessToken);
	console.log(`OCR job created, ${job}`);

	console.log('Now beginning poll process.');
	let downloadURL = await pollJob(job, CLIENT_ID, accessToken);
	console.log('Poll process complete, download URL retreived. Let\'s get it!');

	await downloadFile(downloadURL, downloadPath);
	console.log(`Download operation complete. File saved to ${downloadPath}.`);
})();