V1SubscriptionManager.coffee 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
  1. UserGetter = require "../User/UserGetter"
  2. request = require "request"
  3. settings = require "settings-sharelatex"
  4. logger = require "logger-sharelatex"
  5. module.exports = V1SubscriptionManager =
  6. # Returned planCode = 'v1_pro' | 'v1_pro_plus' | 'v1_student' | 'v1_free' | null
  7. # For this to work, we need plans in settings with plan-codes:
  8. # - 'v1_pro'
  9. # - 'v1_pro_plus'
  10. # - 'v1_student'
  11. # - 'v1_free'
  12. getPlanCodeFromV1: (userId, callback=(err, planCode)->) ->
  13. logger.log {userId}, "[V1SubscriptionManager] fetching v1 plan for user"
  14. V1SubscriptionManager._v1Request userId, {
  15. method: 'GET',
  16. url: (v1Id) -> "/api/v1/sharelatex/users/#{v1Id}/plan_code"
  17. }, (error, body) ->
  18. return callback(error) if error?
  19. planName = body?.plan_name
  20. logger.log {userId, planName, body}, "[V1SubscriptionManager] fetched v1 plan for user"
  21. if planName in ['pro', 'pro_plus', 'student', 'free']
  22. planName = "v1_#{planName}"
  23. else
  24. # Throw away 'anonymous', etc as being equivalent to null
  25. planName = null
  26. return callback(null, planName)
  27. notifyV1OfFeaturesChange: (userId, callback = (error) ->) ->
  28. V1SubscriptionManager._v1Request userId, {
  29. method: 'POST',
  30. url: (v1Id) -> "/api/v1/sharelatex/users/#{v1Id}/sync"
  31. }, callback
  32. _v1Request: (userId, options, callback=(err, body)->) ->
  33. if !settings?.apis?.v1
  34. return callback null, null
  35. UserGetter.getUser userId, {'overleaf.id': 1}, (err, user) ->
  36. return callback(err) if err?
  37. v1Id = user?.overleaf?.id
  38. if !v1Id?
  39. logger.log {userId}, "[V1SubscriptionManager] no v1 id found for user"
  40. return callback(null, null)
  41. request {
  42. baseUrl: settings.apis.v1.url
  43. url: options.url(v1Id)
  44. method: options.method
  45. auth:
  46. user: settings.apis.v1.user
  47. pass: settings.apis.v1.pass
  48. sendImmediately: true
  49. json: true,
  50. timeout: 5 * 1000
  51. }, (error, response, body) ->
  52. return callback(error) if error?
  53. if 200 <= response.statusCode < 300
  54. return callback null, body
  55. else
  56. return callback new Error("non-success code from v1: #{response.statusCode}")