Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 14 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,20 @@ iap.cancelSubscription("google", payment, function (error, response) {
});
```

### Subscription deferral ( Google Play only )

Google exposes [an API for deferral](https://developers.google.com/android-publisher/api-ref/purchases/subscriptions/defer) of recurring suscriptions. This might be used to extend a user's subscription purchase until a specified future expiration time ( useful to grant your users some free days or months ).

```javascript
var deferralInfo = {
expectedExpiryTimeMillis: 1546616722237,
desiredExpiryTimeMillis: 1547716722237,
};
iap.deferSubscription("google", payment, deferralInfo, function (error, response) {
/* your code */
});
```

## Supported platforms

### Amazon
Expand Down
36 changes: 36 additions & 0 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -67,3 +67,39 @@ exports.cancelSubscription = function (platform, payment, cb) {
cb(null, result);
});
};


exports.deferSubscription = function (platform, payment, deferralInfo, cb) {
function syncError(error) {
process.nextTick(function () {
cb(error);
});
}

if (!payment) {
return syncError(new Error('No payment given'));
}

if (!deferralInfo) {
return syncError(new Error('No deferralInfo given'));
}

const engine = platforms[platform];

if (!engine) {
return syncError(new Error(`Platform ${platform} not recognized`));
}

if (!engine.deferSubscription) {
return syncError(new Error(`Platform ${platform
} does not have deferSubscription method`));
}

engine.deferSubscription(payment, deferralInfo, function (error, result) {
if (error) {
return cb(error);
}

cb(null, result);
});
};
60 changes: 60 additions & 0 deletions lib/google/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,17 @@ function validatePaymentAndParseKeyObject(payment) {
return keyObject;
}

function validateDeferralInfo(deferralInfo) {
assert.equal(typeof deferralInfo, 'object', 'deferralInfo must be an object');
assert.equal(typeof deferralInfo.expectedExpiryTimeMillis, 'number', 'expectedExpiryTimeMillis must be a number');
assert.equal(typeof deferralInfo.desiredExpiryTimeMillis, 'number', 'desiredExpiryTimeMillis must be a number');

assert(deferralInfo.desiredExpiryTimeMillis > deferralInfo.expectedExpiryTimeMillis, 'desiredExpiryTimeMillis must be greater than expectedExpiryTimeMillis');

return deferralInfo;
}


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

Expand Down Expand Up @@ -133,3 +144,52 @@ exports.cancelSubscription = function (payment, cb) {
});
});
};


exports.deferSubscription = function (payment, deferralInfo, cb) {
let keyObject;
let options;

try {
keyObject = validatePaymentAndParseKeyObject(payment);
options.json = {
deferralInfo: validateDeferralInfo(deferralInfo)
};
} catch (error) {
return process.nextTick(function () {
cb(error);
});
}

jwt.getToken(keyObject.client_email, keyObject.private_key, apiUrls.publisherScope, function (error, token) {
if (error) {
return cb(error);
}

const requestUrl = apiUrls.purchasesSubscriptionsDefer(
payment.packageName,
payment.productId,
payment.receipt,
token
);

https.post(requestUrl, options, function (error, res, resultString) {
if (error) {
return cb(error);
}

if (res.statusCode !== 200) {
return cb(new Error(`Received ${res.statusCode} status code with body: ${resultString}`));
}

var resultObject;
try {
resultObject = JSON.parse(resultString);
} catch (e) {
return cb(e);
}

return cb(null, resultObject);
});
});
};
15 changes: 13 additions & 2 deletions lib/google/urls.js
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,6 @@ exports.purchasesSubscriptionsGet = function (packageName, productId, receipt, a
);
};


// Android Subscriptions URLs & generators
exports.purchasesSubscriptionsCancel = function (packageName, productId, receipt, accessToken) {
const urlFormat = 'https://www.googleapis.com/androidpublisher/v3/applications/%s/purchases/subscriptions/%s/tokens/%s:cancel?access_token=%s';

Expand All @@ -51,3 +49,16 @@ exports.purchasesSubscriptionsCancel = function (packageName, productId, receipt
encodeURIComponent(accessToken) // API access token
);
};

// Android Subscriptions URLs & generators
exports.purchasesSubscriptionsDefer = function (packageName, productId, receipt, accessToken) {
const urlFormat = 'https://www.googleapis.com/androidpublisher/v3/applications/%s/purchases/subscriptions/%s/tokens/%s:defer?access_token=%s';

return util.format(
urlFormat,
encodeURIComponent(packageName), // application package name
encodeURIComponent(productId), // productId
encodeURIComponent(receipt), // purchase token
encodeURIComponent(accessToken) // API access token
);
};
17 changes: 13 additions & 4 deletions package.json
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
{
"name": "iap",
"version": "1.1.0",
"name": "@emma-app/iap",
"version": "1.1.1",
"description": "In-app purchase validation for Apple, Google, Amazon, Roku",
"main": "index.js",
"scripts": {
"test": "eslint ."
},
"repository": {
"type": "git",
"url": "https://github.com/Wizcorp/node-iap"
"url": "https://github.com/emma-app/node-iap"
},
"keywords": [
"iap",
Expand All @@ -21,7 +21,16 @@
"purchase",
"itunes"
],
"author": "Ron Korving <rkorving@wizcorp.jp>",
"author": {
"name": "Ron Korving",
"email": "rkorving@wizcorp.jp"
},
"contributors": [
{
"name": "Varadh Kalidasan",
"email": "varadh@emma-app.com"
}
],
"license": "MIT",
"dependencies": {
"jwt-simple": "0.5.6",
Expand Down