log-level-checker.js 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. const fetch = require('node-fetch')
  2. const fs = require('fs')
  3. class LogLevelChecker {
  4. constructor(logger, defaultLevel) {
  5. this.logger = logger
  6. this.defaultLevel = defaultLevel
  7. }
  8. start() {
  9. // check for log level override on startup
  10. this.checkLogLevel()
  11. // re-check log level every minute
  12. this.checkInterval = setInterval(this.checkLogLevel.bind(this), 1000 * 60)
  13. }
  14. stop() {
  15. clearInterval(this.checkInterval)
  16. }
  17. async checkLogLevel() {
  18. try {
  19. const end = await this.getTracingEndTime()
  20. if (end > Date.now()) {
  21. this.logger.level('trace')
  22. } else {
  23. this.logger.level(this.defaultLevel)
  24. }
  25. } catch {
  26. this.logger.level(this.defaultLevel)
  27. }
  28. }
  29. async getTracingEndTime() {
  30. return 0
  31. }
  32. }
  33. class FileLogLevelChecker extends LogLevelChecker {
  34. async getTracingEndTime() {
  35. const strEndTime = await fs.promises.readFile('/logging/tracingEndTime')
  36. return parseInt(strEndTime, 10)
  37. }
  38. }
  39. class GCEMetadataLogLevelChecker extends LogLevelChecker {
  40. async getTracingEndTime() {
  41. const options = {
  42. headers: {
  43. 'Metadata-Flavor': 'Google'
  44. }
  45. }
  46. const uri = `http://metadata.google.internal/computeMetadata/v1/project/attributes/${this.logger.fields.name}-setLogLevelEndTime`
  47. const res = await fetch(uri, options)
  48. if (!res.ok) {
  49. throw new Error('Metadata not okay')
  50. }
  51. const strEndTime = await res.text()
  52. return parseInt(strEndTime, 10)
  53. }
  54. }
  55. module.exports = { FileLogLevelChecker, GCEMetadataLogLevelChecker }