node-iap/lib/google/index.js

var assert = require('assert');
var jwt = require('./jwt');
var apiUrls = require('./urls');
var https = require('../https');

function NetworkError(message) {
  this.message = message;
  this.name = "NetworkError";
}
NetworkError.prototype = new Error();
NetworkError.prototype.constructor = NetworkError;

exports.verifyPayment = function (payment, cb) {
	var keyObject;

	try {
		assert.equal(typeof payment.packageName, 'string', 'Package name must be a string');
		assert.equal(typeof payment.productId, 'string', 'Product ID must be a string');
		assert.equal(typeof payment.receipt, 'string', 'Receipt must be a string');

		if (typeof payment.keyObject === 'string' || Buffer.isBuffer(payment.keyObject)) {
			keyObject = JSON.parse(payment.keyObject);
		} else {
			keyObject = payment.keyObject;
		}

		/* jshint camelcase:false */
		assert(keyObject, 'Google API key object must be provided');
		assert.equal(typeof keyObject, 'object', 'Google API key object must be an object');
		assert.equal(typeof keyObject.client_email, 'string', 'Google API client_email must be a string');
		assert.equal(typeof keyObject.private_key, 'string', 'Google API private_key must be a string');
		/* jshint camelcase:true */
	} catch (error) {
		return process.nextTick(function () {
			cb(error);
		});
	}

	/* jshint camelcase:false */
	jwt.getToken(keyObject.client_email, keyObject.private_key, apiUrls.publisherScope, function (error, token) {
	/* jshint camelcase:true */
		if (error) {
			return cb(error);
		}
		if (payment.type == 'product' ) {
			var requestUrl = apiUrls.purchasesProductsGet(
				payment.packageName,
				payment.productId,
				payment.receipt,
				token
			);
		} else {
			var requestUrl = apiUrls.purchasesSubscriptionsGet(
				payment.packageName,
				payment.productId,
				payment.receipt,
				token
			);
		}

		https.get(requestUrl, null, function (error, res, responseString) {
			if (error) {
				return cb(error);
			}

			if (res.statusCode !== 200) {
				if (res.statusCode == 400) {
					var responseObject;
					try {
						responseObject = JSON.parse(responseString);
					} catch (e) {
						return cb(e);
					}
					return cb(null, {
						result: 'failed',
						message: responseObject.error.message
					});
				} else {
					return cb(new NetworkError('Received ' + res.statusCode + ' status code with body: ' + responseString));
				}
			}

			var responseObject;
			try {
				responseObject = JSON.parse(responseString);
			} catch (e) {
				return cb(e);
			}

			return cb(null, {
				result: 'verified',
				receipt: responseObject,
				transactionId: payment.receipt,
				productId: payment.productId,
			});
		});
	});
};