Uploading Files to Microsoft One Drive using Apex

Hello,

what is TokenUrl__c?

Hi Dhanik,

How can I send file has public? I’m trying to use the link from the image in salesforce but is private, is that way in the upload let public?

Can we do this without Azure?

Hi Dhanik,

Thanks for the post.It helped me a lot. I am trying to create a folder in onedrive and upload the document to the folder but the folderId is returned as null although the folder gets created. PFB code. Please can you help.

public class OneDriveService {
private string clientId {get;set;}
private string clientSecret {get;set;}
private string scope {get;set;}
private string grantType{get;set;}
private string tokenUrl{get;set;}
private string redirectUrl {get;set;}
private string graphUrl{get;set;}
private string authUrl{get;set;}
private string adminConsentUrl{get;set;}

private static One_Drive_Auth_Setting__mdt setting;

public OneDriveService()
{
if(setting==null)
{
setting=MetadataTypeReader.OneDriveSetting;
}
if(setting!=null)
{
clientId=setting.Client_Id__c;
clientSecret=setting.Client_Secret__c;
scope=setting.Scope__c;
grantType=setting.Auth_Grant_Type__c;
redirectUrl=setting.Redirect_Url__c;
//authUrl=setting.Authorization_Endpoint__c;
//tokenUrl=setting.Token_Url__c;
authUrl=setting.Authorization_Endpoint__c.replace(‘{tenant}’, setting.TenantId__c);
tokenUrl=setting.Token_Url__c.replace(‘{tenant}’, setting.TenantId__c);
}
}

//use when Admin Consent required using Salesforce App
public String createAuthURL() {
String key = EncodingUtil.urlEncode(clientId,’UTF-8′);
String authuri = ”;
authuri = adminConsentUrl+’?’+
‘client_id=’+key+
‘&redirect_uri=’+redirectUrl+
‘&state=12345’;
return authuri;
}

//Content Type based on Content Version
public static string ContentType(string fileType)
{
switch on fileType.toLowerCase()
{
when ‘docx’
{
return ‘application/vnd.openxmlformats-officedocument.wordprocessingml.document’;
}
when ‘csv’
{
return ‘application/vnd.ms-excel’;
}
when ‘wav’
{
return ‘audio/wav’;
}
when ‘wmv’
{
return ‘video/x-ms-wmv’;
}
when ‘mp3’
{
return ‘audio/mpeg’;
}
when ‘mp4’
{
return ‘video/mp4’;
}
when ‘png’
{
return ‘image/png’;

}
when ‘pdf’
{
return ‘application/pdf’;

}
when ‘txt’
{
return ‘text/plain’;

}
when else {
return ‘image/jpeg’;
}
}
}

//Upload Documents of passed record id
public void UploadDocuments(string recordId)
{
string accessToken=getAccessToken();
String folderId= createFolder(accessToken,recordId);
system.debug(‘folder’ +folderId);

// createFolder.get(id);
if(string.isBlank(accessToken))
{
// throw new BaseException(‘Issue in Authentication’);
}
List links=[SELECT ContentDocumentId,Visibility,LinkedEntityId FROM ContentDocumentLink where LinkedEntityId=:recordId];
Set ids=new Set();
for(ContentDocumentLink link:links)
{
ids.add(link.ContentDocumentId);
link.Visibility=’AllUsers’;
update link;
}
List versions=[SELECT VersionData,Title,ContentDocumentId,FileExtension FROM ContentVersion WHERE ContentDocumentId = :ids AND IsLatest = true ];

for(ContentVersion attach:versions)
{
try
{

//getCreateFolder(accessToken, attach.VersionData, attach.Title, attach.FileExtension);
uploadFile(folderId,attach.title,accessToken, attach.VersionData, attach.Title, attach.FileExtension);
}
catch(Exception ex)
{
//throw new BaseException(ex);
}
}
}

//Get access Token
public string getAccessToken()
{
String key = EncodingUtil.urlEncode(clientId,’UTF-8′);
String secret = EncodingUtil.urlEncode(clientSecret,’UTF-8′);
//Getting access token from google
HttpRequest req = new HttpRequest();
req.setMethod(‘POST’);
//req.setEndpoint(‘https://login.microsoftonline.com/df90518a-bb1d-4202-8191-314022d9a40a/oauth2/v2.0/token’);
req.setEndpoint(tokenUrl);
req.setHeader(‘content-type’, ‘application/x-www-form-urlencoded’);

String messageBody=’client_id=’+key+
‘&scope=https://graph.microsoft.com/.default’+
‘&client_secret=’+secret+
‘&redirect_uri=’+redirectUrl+
‘&grant_type=client_credentials’;

req.setHeader(‘Content-length’, String.valueOf(messageBody.length()));
req.setBody(messageBody);
req.setTimeout(60*1000);

Http callout = new Http();
String responseText;
HttpResponse response = callout.send(req);

system.debug(‘response:’ + response.getBody());
if(response.getStatusCode()==200)
{
responseText = response.getBody();
Map responseMap =(Map)JSON.deserializeUntyped(responseText) ;
string token=String.valueOf(responseMap.get(‘access_token’));
system.debug(‘responseMap:’ + responseMap);
return token;
}
return ”;
}
@future(callout=true)
public static void createFolder(String accessToken,String folderName) {
// Step 1: Get Access Token
// String accessToken = getAccessToken();

// Step 2: Make API Call to create folder
String encodedFolderName = EncodingUtil.urlEncode(folderName, ‘UTF-8’);

//request.setBody(‘{“name”: “‘ + folderName + ‘”, “folder”: {}, “@microsoft.graph.conflictBehavior”: “rename”}’);
String endpointUrl = ‘https://graph.microsoft.com/v1.0/users/728e7840-2ac6-49bb-97ae-7c34ed560909/drive/root/children’;
//String endpointUrl =’https://graph.microsoft.com/v1.0/users/728e7840-2ac6-49bb-97ae-7c34ed560909/drive/root:/{folder_name}:/children’;
//endpointUrl=endpointUrl.replace(‘{folder_name}’,folderName);
HttpRequest request = new HttpRequest();
request.setEndpoint(endpointUrl);
request.setMethod(‘POST’);
request.setBody(‘{“name”: “‘ + encodedFolderName + ‘”, “folder”: {}, “@microsoft.graph.conflictBehavior”: “rename”}’);
//String requestBody = ‘{“name”: “‘ + folderName + ‘”, “folder”: {}}’;
//request.setBody(requestBody);
request.setHeader(‘Authorization’, ‘Bearer ‘ + accessToken);
request.setHeader(‘Content-Type’, ‘application/json’);

try {
HttpResponse response = new Http().send(request);
Map jsonResponse = (Map) JSON.deserializeUntyped(response.getBody());
return (String) jsonResponse.get(‘id’);
} catch (Exception e) {
System.debug(‘Error creating folder: ‘ + e.getMessage());
return null;
}

}

@Future(callout=true)
public static void uploadFile( string folderId, String documentName,string accessToken,blob versionData,string title,string extn){
//File Content
// String attachmentBody = EncodingUtil.base64Encode(versionData);

String filename = title;
string contentType=ContentType(extn);

//String encodedFolderName = EncodingUtil.urlEncode(folderId, ‘UTF-8’);
// system.debug(‘folder name’ +encodedFolderName);
String encodedDocumentName = EncodingUtil.urlEncode(documentName, ‘UTF-8′);

// string endpointUrl=’https://graph.microsoft.com/v1.0/users/728e7840-2ac6-49bb-97ae-7c34ed560909/drive/items/root:/{file}:/content’;
String endpointUrl = ‘https://graph.microsoft.com/v1.0/users/728e7840-2ac6-49bb-97ae-7c34ed560909/drive/items/’ + folderId + ‘:/’ + encodedDocumentName + ‘:/content’;
//string file=EncodingUtil.URLENCODE(filename,’UTF-8′).replace(‘+’, ‘%20’);
//endpointUrl=endpointUrl.replace(‘{file}’,file+’.’+extn);

HttpRequest req = new HttpRequest();
req.setEndpoint(endpointUrl);
req.setMethod(‘PUT’);
req.setHeader(‘Authorization’,’Bearer ‘ + accessToken);
//req.setHeader(‘Authorization’,’Bearer ‘ + accessToken);
//req.setHeader(‘Content-Encoding’, ‘UTF-8’);
req.setHeader(‘Content-Type’, contentType);
req.setHeader(‘accept’, ‘application/json’);
Http http = new Http();
system.debug(‘getBody1 ‘+req);
req.setBodyAsBlob(versionData);
// req.setBody(versionData.toString());
req.setTimeout(120000);
system.debug(‘Request Body: ‘ + req.getBody());

HTTPResponse res = http.send(req);
system.debug(‘getBody2 ‘+res.getBody());
system.debug(‘Response Status Code: ‘ + res.getStatusCode());
//system.debug(‘Response Body: ‘ + res.getBody());
if(res.getStatusCode()==200)
{
system.debug(‘getBody ‘+res.getBody());
}
}
}