example.js

'use-strict'

// This sample will post a basic message in your LinkedIn profile

const https = require('https');
const accessToken = require('./token.json').access_token;

// ---------------------------------------------------------------------------------------------------------------------
// Example
// ---------------------------------------------------------------------------------------------------------------------

let title = "Hello World!";
let text = "This is my first post!";
let shareUrl = "https://www.example.com/content.html"
let shareThumbnailUrl = "https://www.example.com/image.jpg"

getLinkedinId(accessToken).then(ownerId => {
    postShare(accessToken, ownerId, title, text, shareUrl, shareThumbnailUrl).then(r => {
        console.log(r); // status 201 signal successful posting
    }).catch(e => console.log(e));
}).catch(e => console.log(e));

// ---------------------------------------------------------------------------------------------------------------------
// Generic Node.js API to post on LinkedIn
// ---------------------------------------------------------------------------------------------------------------------

// Get LinkedIn ID, i.e. ownerId
function getLinkedinId(accessToken) {
    return new Promise((res, rej) => {
        let hostname = 'api.linkedin.com';
        let path = '/v2/me';
        let method = 'GET';
        let headers = {
            'Authorization': 'Bearer ' + accessToken,
            'cache-control': 'no-cache',
            'X-Restli-Protocol-Version': '2.0.0'
        };
        let body = ''
        _request(method, hostname, path, headers, body).then(r => {
            res(JSON.parse(r.body).id)
        }).catch(e => rej(e))
    })
}

// Publish content on LinkedIn
function postShare(accessToken, ownerId, title, text, shareUrl, shareThumbnailUrl) {
    return new Promise((res, rej) => {
        let hostname = 'api.linkedin.com';
        let path = '/v2/shares';
        let method = 'POST';
        let body = {
            "owner": "urn:li:person:" + ownerId,
            "subject": title,
            "text": {
                "text": text // max 1300 characters
            },
            "content": {
                "contentEntities": [{
                    "entityLocation": shareUrl,
                    "thumbnails": [{
                        "resolvedUrl": shareThumbnailUrl
                    }]
                }],
                "title": title
            },
            "distribution": {
                "linkedInDistributionTarget": {}
            }
        }
        let headers = {
            'Authorization': 'Bearer ' + accessToken,
            'cache-control': 'no-cache',
            'X-Restli-Protocol-Version': '2.0.0',
            'Content-Type': 'application/json',
            'x-li-format': 'json',
            'Content-Length': Buffer.byteLength(JSON.stringify(body))
        };
        _request(method, hostname, path, headers, JSON.stringify(body)).then(r => {
            res(r);
        }).catch(e => rej(e))
    })
}

// Generic HTTP requester
function _request(method, hostname, path, headers, body) {
    return new Promise((resolve, reject) => {
        let reqOpts = {
            method,
            hostname,
            path,
            headers,
            "rejectUnauthorized": false // WARNING: accepting unauthorised end points for testing ONLY
        };
        let resBody = "";
        let req = https.request(reqOpts, res => {
            res.on('data', data => {
                resBody += data.toString('utf8');
            });
            res.on('end', () => {
                resolve({
                    "status": res.statusCode,
                    "headers": res.headers,
                    "body": resBody
                })
            });
        });
        req.on('error', e => {
            reject(e);
        });
        if (method !== 'GET') {
            req.write(body);
        }
        req.end();
    })
}